[{"_1":2,"_176":-5,"_177":-5},"loaderData",{"_3":4,"_93":94},"root",{"_5":6,"_36":37,"_66":67},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":-5,"_32":33,"_34":20,"_35":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesChatPanelState","notificationCount",0,"flagDenols","isTeamOrgMember","ENV",{"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63,"_64":65},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","939580425be10a31a46c456dba7cc90bab2194e6","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","API_URL","https://api.val.town","clerkState",{"_68":69},"__internal_clerk_state",{"_70":71,"_72":47,"_73":74,"_75":74,"_76":20,"_77":74,"_78":74,"_79":74,"_80":74,"_81":82,"_91":20,"_92":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_83":20,"_19":20,"_84":74,"_85":86,"_87":74,"_88":47,"_89":20,"_90":74},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_95":96,"_97":98,"_99":100,"_101":102,"_154":155,"_173":174,"_175":-5},"handle","nandini0620","name","slackproxyunifiedautomation","path","main.ts","project",{"_103":104,"_97":98,"_105":106,"_107":-5,"_108":20,"_109":110,"_111":-5,"_112":-5,"_12":113,"_114":-5,"_115":20,"_116":-5,"_117":-5,"_118":33,"_14":119,"_120":-5,"_121":-5,"_122":-5,"_123":124,"_125":124,"_126":127,"_128":127,"_129":127,"_130":124,"_131":124,"_23":132,"_135":136,"_140":141,"_153":20},"id","1e2737fa-16e3-11f1-a410-42dde27851f2","createdAt",["D",1772530014443],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","019c575a-85f2-7330-9147-a0b1510fc7a2","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","019c575a-85f2-7330-9147-a6688df1f350","tursoName","tursoHostname","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_95":96,"_133":134},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzM5Y09uYlQ5Y1FhYTdkRUVGeDRRcHZnYmd2NCJ9","org",{"_95":96,"_137":134,"_12":113,"_138":139},"avatar","tier","free","branch",{"_142":143,"_97":45,"_103":144,"_145":104,"_146":-5,"_147":-5,"_148":-5,"_149":-5,"_150":-5,"_151":98,"_152":96},"version",4,"1e279740-16e3-11f1-a410-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_103":156,"_97":100,"_157":158,"_159":-5,"_160":144,"_161":143,"_162":163,"_105":164,"_142":165,"_166":167,"_168":169,"_170":20,"_171":-5,"_99":172},"e9232db4-16e4-11f1-a771-42dde27851f2","fileId","1e29ead6-16e3-11f1-a410-42dde27851f2","parentId","branchId","branchVersion","latest",true,["D",1772530784480],3,"fileType","http","content","/**\n * ====================================================================\n * VAL TOWN: Unified Automation Engine — Slack Interactivity Handler\n * ====================================================================\n *\n * Architecture:\n * Slack → Val Town (respond 200 immediately) → fire-and-forget to Apps Script\n * Exception: Modal opens → synchronous call to Apps Script (trigger_id expires in 3s)\n *\n * SETUP:\n * 1. Create this as an HTTP val in Val Town\n * 2. Set env vars in Val Town:\n * - SLACK_BOT_TOKEN : xoxb-... (your Slack bot token)\n * - GAS_EXEC_URL : https://script.google.com/macros/s/.../exec\n * 3. Slack App Settings:\n * - Interactivity Request URL = this Val Town URL\n * - Event Subscriptions URL = this Val Town URL\n * - Subscribe to bot events: message.channels, file_shared\n *\n * ====================================================================\n */\n\nconst SLACK_BOT_TOKEN = Deno.env.get(\"SLACK_BOT_TOKEN\") || \"\";\nconst GAS_EXEC_URL = Deno.env.get(\"GAS_EXEC_URL\") || \"\";\n\nexport default async function handler(req: Request): Promise {\n // GET — health check\n if (req.method === \"GET\") {\n return Response.json({\n status: \"ok\",\n service: \"UE Slack Handler\",\n timestamp: new Date().toISOString(),\n });\n }\n\n if (req.method !== \"POST\") {\n return new Response(\"Method not allowed\", { status: 405 });\n }\n\n try {\n const rawBody = await req.text();\n const contentType = req.headers.get(\"content-type\") || \"\";\n\n // ---- Slack URL Verification ----\n if (contentType.includes(\"application/json\")) {\n const jsonBody = JSON.parse(rawBody);\n\n if (jsonBody.type === \"url_verification\") {\n console.log(\"[UE] URL verification challenge\");\n return Response.json({ challenge: jsonBody.challenge });\n }\n\n // Event callback (file_shared, message events)\n if (jsonBody.type === \"event_callback\") {\n forwardToGAS({ type: \"event_callback\", payload: JSON.stringify(jsonBody) });\n return new Response(\"ok\", { status: 200 });\n }\n }\n\n // ---- Slack Interactivity ----\n if (contentType.includes(\"application/x-www-form-urlencoded\")) {\n const params = new URLSearchParams(rawBody);\n const payloadStr = params.get(\"payload\");\n\n if (!payloadStr) {\n return new Response(\"ok\", { status: 200 });\n }\n\n const payload = JSON.parse(payloadStr);\n const payloadType = payload.type;\n\n console.log(\"[UE] Interaction:\", payloadType);\n\n // ---- Button Actions ----\n if (payloadType === \"block_actions\") {\n const action = payload.actions?.[0];\n const actionId = action?.action_id || \"\";\n\n // Ignore non-UE actions\n if (!actionId.startsWith(\"ue_\")) {\n return new Response(\"ok\", { status: 200 });\n }\n\n // Modal-opening actions — SYNCHRONOUS (trigger_id expires in 3s)\n if (\n actionId === \"ue_open_input\" ||\n actionId === \"ue_open_modal\" ||\n actionId === \"ue_open_action_modal\"\n ) {\n let value: Record = {};\n try { value = JSON.parse(action.value || \"{}\"); } catch (_) {}\n\n console.log(\"[UE] Opening modal:\", value.actionId);\n\n try {\n await fetch(GAS_EXEC_URL, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n source: \"valtown\",\n type: \"open_modal\",\n trigger_id: payload.trigger_id,\n action_id: actionId,\n ue_action_id: value.actionId,\n user_id: payload.user?.id || \"\",\n channel_id: payload.channel?.id || \"\",\n message_ts: payload.message?.ts || \"\",\n }),\n });\n } catch (err) {\n console.error(\"[UE] Modal call failed:\", err);\n }\n\n return new Response(\"\", { status: 200 });\n }\n\n // All other buttons — fire and forget\n forwardToGAS({ type: \"block_actions\", payload: payloadStr });\n return new Response(\"\", { status: 200 });\n }\n\n // ---- Modal Submissions ----\n if (payloadType === \"view_submission\") {\n const callbackId = payload.view?.callback_id || \"\";\n if (!callbackId.startsWith(\"ue_\")) {\n return new Response(\"\", { status: 200 });\n }\n\n forwardToGAS({ type: \"view_submission\", payload: payloadStr });\n return new Response(\"\", { status: 200 });\n }\n\n return new Response(\"\", { status: 200 });\n }\n\n return new Response(\"ok\", { status: 200 });\n } catch (err) {\n console.error(\"[UE] Error:\", err);\n return new Response(\"ok\", { status: 200 });\n }\n}\n\n/**\n * Fire-and-forget forward to Apps Script.\n */\nfunction forwardToGAS(data: Record) {\n data.source = \"valtown\";\n\n fetch(GAS_EXEC_URL, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(data),\n redirect: \"follow\",\n }).catch((err) => console.error(\"[UE] Forward error:\", err));\n}\n\nconst REDIS_URL = Deno.env.get(\"UPSTASH_REDIS_REST_URL\") || \"\";\nconst REDIS_TOKEN = Deno.env.get(\"UPSTASH_REDIS_REST_TOKEN\") || \"\";\n\n// ============= REDIS REST HELPER =============\n\n/**\n * Execute a Redis command via Upstash REST API.\n * @param command - Array of command parts, e.g. [\"SET\", \"key\", \"value\"]\n * @returns Parsed response\n */\nasync function redis(command: string[]): Promise {\n const resp = await fetch(`${REDIS_URL}`, {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${REDIS_TOKEN}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(command),\n });\n\n const data = await resp.json();\n\n if (data.error) {\n console.error(\"[Redis] Error:\", data.error);\n throw new Error(data.error);\n }\n\n return data.result;\n}\n\n\n// ============= REPORT JSON OPERATIONS =============\n\n/**\n * @typedef {Object} UE_ReportJSON\n * @property {string} reportId\n * @property {string} reportTypeId\n * @property {string} reportTypeName\n * @property {string} farm\n * @property {string} goatIds\n * @property {string} reportDate\n * @property {string} reportTime\n * @property {string} createdBy\n * @property {string} status - \"Active\", \"Completed\"\n * @property {string} reportStatus - \"Open\", \"Closed\"\n * @property {string} channelId\n * @property {string} parentTs\n * @property {string} parentLink\n * @property {Object} formData - Original form submission data\n * @property {Array} actions - Array of action objects\n * @property {Object} metadata - { createdAt, lastUpdated, syncedAt }\n */\n\n/**\n * Save a full report JSON to Redis.\n * TTL: 7 days (604800 seconds). Reports older than this should already be synced.\n */\nexport async function saveReport(report: Record): Promise {\n const key = `rpt:${report.reportId}`;\n report.metadata = report.metadata || {};\n report.metadata.lastUpdated = new Date().toISOString();\n\n await redis([\"SET\", key, JSON.stringify(report), \"EX\", \"604800\"]);\n\n // Create action index pointers\n const actions = report.actions || [];\n for (let i = 0; i < actions.length; i++) {\n if (actions[i].actionId) {\n await redis([\n \"SET\",\n `act:${actions[i].actionId}`,\n JSON.stringify({ reportId: report.reportId, index: i }),\n \"EX\", \"604800\",\n ]);\n }\n }\n\n // Add to active set for farm\n if (report.farm && report.reportStatus !== \"Closed\") {\n await redis([\"SADD\", `active:${report.farm}`, report.reportId]);\n }\n}\n\n/**\n * Get a full report JSON from Redis.\n * @returns Report object or null if not found\n */\nexport async function getReport(reportId: string): Promise | null> {\n const raw = await redis([\"GET\", `rpt:${reportId}`]);\n if (!raw) return null;\n return JSON.parse(raw);\n}\n\n/**\n * Find which report an action belongs to and its index.\n * @returns { reportId, index } or null\n */\nexport async function findActionReport(actionId: string): Promise<{ reportId: string; index: number } | null> {\n const raw = await redis([\"GET\", `act:${actionId}`]);\n if (!raw) return null;\n return JSON.parse(raw);\n}\n\n/**\n * Get an action object by looking up its report.\n * @returns Action object or null\n */\nexport async function getAction(actionId: string): Promise | null> {\n const pointer = await findActionReport(actionId);\n if (!pointer) return null;\n\n const report = await getReport(pointer.reportId);\n if (!report || !report.actions) return null;\n\n return report.actions[pointer.index] || null;\n}\n\n/**\n * Update specific fields on an action within a report.\n * Reads the report, updates the action, writes back.\n */\nexport async function updateAction(\n actionId: string,\n updates: Record,\n): Promise | null> {\n const pointer = await findActionReport(actionId);\n if (!pointer) {\n console.log(\"[Redis] Action not found:\", actionId);\n return null;\n }\n\n const report = await getReport(pointer.reportId);\n if (!report || !report.actions || !report.actions[pointer.index]) {\n console.log(\"[Redis] Report or action index not found:\", pointer.reportId, pointer.index);\n return null;\n }\n\n // Apply updates\n const action = report.actions[pointer.index];\n Object.keys(updates).forEach((key) => {\n action[key] = updates[key];\n });\n\n // Mark as needing sync\n action._dirty = true;\n report.metadata = report.metadata || {};\n report.metadata.lastUpdated = new Date().toISOString();\n report.metadata.needsSync = true;\n\n // Check if all actions are done\n const allDone = report.actions.every((a: any) => {\n const s = (a.status || \"\").toLowerCase();\n return s === \"completed\" || s === \"approved\" || s === \"rejected\" ||\n s === \"skipped\" || s === \"cancelled\";\n });\n\n if (allDone) {\n report.reportStatus = \"Closed\";\n report.status = \"Completed\";\n // Remove from active set\n if (report.farm) {\n await redis([\"SREM\", `active:${report.farm}`, report.reportId]);\n }\n }\n\n await saveReport(report);\n\n return action;\n}\n\n/**\n * Save thread metadata for a report.\n */\nexport async function saveThreadInfo(\n reportId: string,\n channelId: string,\n parentTs: string,\n parentLink: string,\n): Promise {\n const report = await getReport(reportId);\n if (report) {\n report.channelId = channelId;\n report.parentTs = parentTs;\n report.parentLink = parentLink;\n await saveReport(report);\n }\n}\n\n/**\n * Get all active report IDs for a farm.\n */\nexport async function getActiveReports(farm: string): Promise {\n const result = await redis([\"SMEMBERS\", `active:${farm}`]);\n return result || [];\n}\n\n/**\n * Get all reports that need syncing to Sheets.\n * Scans active reports and returns those with needsSync = true.\n */\nexport async function getReportsNeedingSync(farm: string): Promise[]> {\n const reportIds = await getActiveReports(farm);\n const needsSync: Record[] = [];\n\n for (const id of reportIds) {\n const report = await getReport(id);\n if (report?.metadata?.needsSync) {\n needsSync.push(report);\n }\n }\n\n return needsSync;\n}\n\n/**\n * Mark a report as synced (after Apps Script writes to Sheets).\n */\nexport async function markSynced(reportId: string): Promise {\n const report = await getReport(reportId);\n if (report) {\n report.metadata = report.metadata || {};\n report.metadata.needsSync = false;\n report.metadata.syncedAt = new Date().toISOString();\n\n // Clear dirty flags on actions\n (report.actions || []).forEach((a: any) => {\n delete a._dirty;\n });\n\n await saveReport(report);\n }\n}\n\n/**\n * Delete a report from Redis (after it's fully synced and closed).\n */\nexport async function deleteReport(reportId: string): Promise {\n const report = await getReport(reportId);\n if (report) {\n // Delete action pointers\n for (const action of report.actions || []) {\n if (action.actionId) {\n await redis([\"DEL\", `act:${action.actionId}`]);\n }\n }\n // Remove from active set\n if (report.farm) {\n await redis([\"SREM\", `active:${report.farm}`, reportId]);\n }\n }\n\n await redis([\"DEL\", `rpt:${reportId}`]);\n}","deleted","label",[100],"permalink","https://www.val.town/x/nandini0620/slackproxyunifiedautomation/code/main.ts","extension","actionData","errors"]