/**
* ============================================================================
* PULSE 256 PLATFORM - MASTER BACKEND ENGINE (FIXED & OPTIMIZED)
* ============================================================================
*/
const ADMIN_CREDENTIALS = {
token: "admin_override"
};
const SCHEMAS = {
"Programs": ["ProgramID", "ProgramName", "Type", "StartDate", "EndDate", "LiveLink", "PosterUrl", "IsFeatured"],
"Artists": ["ArtistInitials", "Name", "Image", "Bio", "Followers", "MonthlyListeners", "Link", "LabelLink", "Aliases", "Rank", "IsFeatured"],
"Songs": ["SongID", "ArtistInitials", "Title", "AudioUrl", "CoverImage", "VideoUrl", "DownloadSize", "IsNew", "PageUrl", "UploadDate", "LabelTag", "IsFeatured"],
"Categories": ["ProgramID", "CategoryID", "CategoryName", "Type", "StartDate", "EndDate", "LiveLink"],
"Competitors": ["CategoryID", "CompetitorID", "Name", "Image", "Emoji", "ArtistInitials", "Votes"],
"Merch": ["ProductID", "ArtistInitials", "Name", "Image", "OldPrice", "NewPrice", "Stock", "SoldCount", "WhatsAppNumber"],
"MerchOrders": ["OrderID", "UserID", "ProductID", "ArtistInitials", "Timestamp"],
"CalendarEvents": ["EventID", "Date", "Title", "Venue", "Time", "TicketUrl", "UserID", "Status"],
"Tickets": ["TicketID", "Category", "EventName", "Venue", "Month", "Day", "Year", "Time", "Phone", "PosterUrl", "DefaultPrice", "Status"],
"TicketTiers": ["TicketID", "TierName", "Price"],
"Podcasts": ["PodcastID", "Type", "Title", "Host", "Duration", "ThumbnailUrl", "PlayUrl", "Status", "Category"],
"PodcastStats": ["PodcastID", "Listens", "Views", "Likes", "Dislikes"],
"Carousels": ["Page", "Eyebrow", "Title", "Description", "ButtonText", "ImageUrl", "TargetID", "Icon"],
"Reviews": ["ReviewID", "UserID", "SongID", "ArtistInitials", "UserName", "Rating", "ReviewText", "Timestamp", "Email"],
"Users": ["UserID", "Name", "Email", "Phone", "Password", "Timestamp"],
"Votes": ["VoteID", "UserID", "CompetitorID", "CategoryID", "Timestamp"],
"SongStats": ["SongID", "ArtistInitials", "Plays", "Downloads", "Likes", "Dislikes", "TrendingScore"]
};
function jsonResponse(data) {
return ContentService.createTextOutput(JSON.stringify(data)).setMimeType(ContentService.MimeType.JSON);
}
// Fixed getSheetObjects (Eliminated the Infinite Recursion loop)
function getSheetObjects(sheetName, ss) {
let sheet = ss.getSheetByName(sheetName);
if (!sheet) {
sheet = ss.insertSheet(sheetName);
if (SCHEMAS[sheetName]) {
sheet.appendRow(SCHEMAS[sheetName]);
}
SpreadsheetApp.flush(); // Ensure sheet saves immediately
}
let data = sheet.getDataRange().getValues();
// Safe Users initialization (No recursion needed)
if (sheetName === "Users" && data.length <= 1) {
sheet.appendRow(["ADMIN", "Admin", "admin@pulse256.com", "admin123", "admin123", new Date().toISOString()]);
SpreadsheetApp.flush();
data = sheet.getDataRange().getValues(); // Re-fetch the updated data directly
}
if (data.length <= 1) return [];
const schemaHeaders = SCHEMAS[sheetName] || [];
const headers = data[0].map(h => {
const trimmedHeader = String(h).trim();
const matchedSchema = schemaHeaders.find(sh => sh.toLowerCase() === trimmedHeader.toLowerCase());
return matchedSchema || trimmedHeader;
});
const rows = data.slice(1);
return rows.filter(r => r.some(cell => String(cell).trim() !== "")).map(row => {
let obj = {};
headers.forEach((header, i) => { obj[header] = row[i]; });
return obj;
});
}
function doGet(e) {
// Keeping your read-only routines unchanged, but providing safe ss access
try {
const params = e.parameter || {};
const action = String(params.action || params.ACTION || "").toLowerCase().trim();
const ss = SpreadsheetApp.getActiveSpreadsheet();
if (action === "get_programs_data") { /* Keep your original logic... */ return jsonResponse({status: "success"}); }
// ... Any other GET logic you had
return jsonResponse({ status: "error", message: "Invalid GET action." });
} catch (err) {
return jsonResponse({ status: "error", message: err.toString() });
}
}
// THE FIXED POST ROUTE - No more lock leaks, no scattered manual release statements!
function doPost(e) {
const lock = LockService.getScriptLock();
try {
lock.waitLock(10000);
} catch (err) {
return jsonResponse({ status: "error", message: "Server busy." });
}
// Entire execution wrapped in a try/finally to GUARANTEE lock release
try {
const ss = SpreadsheetApp.getActiveSpreadsheet();
if (!ss) throw new Error("Could not connect to active spreadsheet.");
let payload = {};
if (e.postData && e.postData.contents) {
payload = JSON.parse(e.postData.contents);
} else {
payload = e.parameter || {};
}
const action = String(payload.action || e.parameter.action || "").toLowerCase().trim();
// ── 1. ADMIN PANEL SECURE SYNC ──
if (action === "get_admin_data") {
const token = String(payload.token || "");
if (!token) return jsonResponse({ status: "error", message: "Unauthorized token" });
let adminData = {};
Object.keys(SCHEMAS).forEach(sheetName => {
adminData[sheetName] = getSheetObjects(sheetName, ss);
});
return jsonResponse({ status: "success", data: adminData });
}
// ── 2. ADMIN WRITE/EDIT ROW ──
if (action === "admin_write_row") {
const { sheetName, idColumn, idValue, rowData } = payload;
if (!sheetName || !SCHEMAS[sheetName]) return jsonResponse({ status: "error", message: "Invalid sheet." });
const sheet = ss.getSheetByName(sheetName) || ss.insertSheet(sheetName);
let data = sheet.getDataRange().getValues();
if (data.length === 0) {
sheet.appendRow(SCHEMAS[sheetName]);
SpreadsheetApp.flush();
data = sheet.getDataRange().getValues();
}
let headers = data[0].map(h => String(h).trim().toLowerCase());
let idColIdx = headers.indexOf(String(idColumn).toLowerCase());
let foundRow = -1;
if (idColIdx !== -1 && idValue) {
for (let i = 1; i < data.length; i++) {
if (String(data[i][idColIdx]).trim() === String(idValue).trim()) {
foundRow = i + 1;
break;
}
}
}
let newRowArray = [];
data[0].forEach(h => {
let key = Object.keys(rowData).find(k => k.toLowerCase() === String(h).toLowerCase());
newRowArray.push(key ? rowData[key] : "");
});
if (foundRow !== -1) {
sheet.getRange(foundRow, 1, 1, newRowArray.length).setValues([newRowArray]);
} else {
sheet.appendRow(newRowArray);
}
SpreadsheetApp.flush();
return jsonResponse({ status: "success" });
}
// ── 3. ADMIN DELETE ROW ──
if (action === "admin_delete_row") {
const { sheetName, idColumn, idValue } = payload;
if (!sheetName || !SCHEMAS[sheetName]) return jsonResponse({ status: "error", message: "Invalid sheet." });
const sheet = ss.getSheetByName(sheetName);
if (!sheet) return jsonResponse({ status: "error", message: "Sheet not found." });
let data = sheet.getDataRange().getValues();
let headers = data[0].map(h => String(h).trim().toLowerCase());
let idColIdx = headers.indexOf(String(idColumn).toLowerCase());
if (idColIdx !== -1 && idValue) {
for (let i = 1; i < data.length; i++) {
if (String(data[i][idColIdx]).trim() === String(idValue).trim()) {
sheet.deleteRow(i + 1);
SpreadsheetApp.flush();
return jsonResponse({ status: "success" });
}
}
}
return jsonResponse({ status: "error", message: "Record not found." });
}
// ── 4. LOG PODCAST EVENT ──
if (action === "log_podcast_event") {
// (Your original logic stays here, ending with:)
SpreadsheetApp.flush();
return jsonResponse({ status: "success" });
}
// ── 5. LOG SONG / ARTIST EVENT ──
if (action === "log_event") {
// (Your original logic stays here, ending with:)
SpreadsheetApp.flush();
return jsonResponse({ status: "success" });
}
// ── 6. VOTING SUBMISSION ──
if (action === "submit_vote") {
// (Your original logic stays here, ending with:)
SpreadsheetApp.flush();
return jsonResponse({ status: "success", message: "Vote recorded!" });
}
// ── 7. USER AUTHENTICATION ──
if (action === "user_login") {
const identifier = String(payload.identifier || "").trim().toLowerCase();
const password = String(payload.password || "").trim();
// Emergency fallback check
if (identifier === "admin" && password === "admin123") {
return jsonResponse({ status: "success", userID: "admin_override", userName: "Admin", token: "admin_override" });
}
const usersSheet = ss.getSheetByName("Users");
if (!usersSheet) return jsonResponse({ status: "error", message: "System initializing. Try again in 10 seconds." });
const users = usersSheet.getDataRange().getValues();
for (let i = 1; i < users.length; i++) {
let isEmailMatch = String(users[i][2] || "").trim().toLowerCase() === identifier;
let isPhoneMatch = String(users[i][3] || "").trim() === identifier;
let isNameMatch = String(users[i][1] || "").trim().toLowerCase() === identifier;
if ((isEmailMatch || isPhoneMatch || isNameMatch) && password === String(users[i][4] || "").trim()) {
return jsonResponse({ status: "success", userID: users[i][0], userName: users[i][1], token: users[i][0] });
}
}
return jsonResponse({ status: "error", message: "Invalid credentials." });
}
// Unrecognized action fallback
return jsonResponse({ status: "error", message: "Unknown action." });
// Error handling captures EVERYTHING that crashes above
} catch (err) {
return jsonResponse({ status: "error", message: err.toString() });
// FINALLY block guarantees the lock releases 100% of the time, no matter what happens
} finally {
lock.releaseLock();
}
}
