[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_158":159,"_160":161},"routes/_app.x.$handle.$name",{"_97":96,"_32":45,"_105":87,"_27":106,"_13":14,"_107":-5,"_11":108,"_109":110,"_111":112,"_113":114,"_115":116,"_20":-5,"_117":-5,"_118":-5,"_119":25,"_120":121,"_122":123,"_124":-5,"_125":-5,"_126":127},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":64,"_65":66,"_67":68,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":80,"_81":82,"_83":84,"_85":25},"version",7,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","1e29ead6-16e3-11f1-a410-42dde27851f2","name","fileType","http","content","const GAS_URL = Deno.env.get(\"GAS_EXEC_URL\") || \"\";\nconst SLACK_BOT_TOKEN = Deno.env.get(\"SLACK_BOT_TOKEN\") || \"\";\nconst REDIS_URL = Deno.env.get(\"UPSTASH_REDIS_REST_URL\") || \"\";\nconst REDIS_TOKEN = Deno.env.get(\"UPSTASH_REDIS_REST_TOKEN\") || \"\";\n\nexport default async function slackProxy(req: Request): Promise {\n if (req.method === \"GET\") {\n return new Response(\"UE Slack Proxy is running.\");\n }\n\n try {\n const contentType = req.headers.get(\"content-type\") || \"\";\n let body: any = {};\n let rawBody = \"\";\n\n // Parse the incoming payload\n if (contentType.includes(\"application/x-www-form-urlencoded\")) {\n const formData = await req.text();\n rawBody = formData;\n const params = new URLSearchParams(formData);\n const payloadStr = params.get(\"payload\") || \"\";\n try {\n body = JSON.parse(payloadStr);\n } catch (_) {}\n } else {\n const text = await req.text();\n rawBody = text;\n try {\n body = JSON.parse(text);\n } catch (_) {}\n }\n\n const payloadType = body.type || \"unknown\";\n console.log(\"[UE Proxy] Received:\", payloadType);\n\n // ---- URL Verification ----\n if (payloadType === \"url_verification\") {\n return Response.json({ challenge: body.challenge });\n }\n\n // ---- Block Actions: Check for modal-opening actions ----\n if (payloadType === \"block_actions\") {\n const action = body.actions?.[0];\n const actionId = action?.action_id || \"\";\n\n // Modal-opening actions — handle directly (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 {\n value = JSON.parse(action.value || \"{}\");\n } catch (_) {}\n\n console.log(\n \"[UE Proxy] Modal open for:\",\n value.actionId,\n \"trigger:\",\n body.trigger_id,\n );\n\n // Fetch action details from Redis (fast) to build the modal\n const actionData = await getActionFromRedis(\n value.reportId || \"\",\n value.goatId || \"ALL\",\n value.actionId,\n );\n\n if (actionData) {\n // Build and open modal directly from Val Town\n await openModal(body.trigger_id, actionData, value.actionId);\n } else {\n // Fallback: forward to Apps Script synchronously for modal\n try {\n await fetch(GAS_URL, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n source: \"valtown_modal\",\n type: \"open_modal\",\n trigger_id: body.trigger_id,\n action_id: actionId,\n ue_action_id: value.actionId,\n }),\n });\n } catch (err) {\n console.error(\"[UE Proxy] Modal fallback error:\", err);\n }\n }\n\n return new Response(\"\", { status: 200 });\n }\n\n // Button clicks (Yes/No/Done) — update Redis, then forward to Apps Script\n if (actionId.startsWith(\"ue_\")) {\n let value: Record = {};\n try {\n value = JSON.parse(action.value || \"{}\");\n } catch (_) {}\n\n // Update Redis entity JSON (fast, non-blocking)\n if (REDIS_URL && value.reportId && value.goatId && value.actionId) {\n updateActionRedis(value.reportId, value.goatId, value.actionId, {\n status: \"Completed\",\n response: value.answer || \"Done\",\n }).catch((err) =>\n console.error(\"[UE Proxy] Redis update error:\", err)\n );\n }\n }\n }\n\n // ---- Forward raw payload to Apps Script (all cases) ----\n fetch(GAS_URL, {\n method: \"POST\",\n headers: { \"Content-Type\": contentType || \"application/json\" },\n body: rawBody,\n }).catch((err) => console.error(\"[UE Proxy] GAS forward error:\", err));\n\n return Response.json({});\n } catch (err) {\n console.error(\"[UE Proxy] Error:\", err);\n return Response.json({});\n }\n}\n\n// ============= REDIS HELPERS =============\n\nasync function redis(command: string[]): Promise {\n if (!REDIS_URL || !REDIS_TOKEN) return null;\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 const data = await resp.json();\n return data.error ? null : data.result;\n}\n\nasync function getActionFromRedis(\n reportId: string,\n goatId: string,\n actionId: string,\n): Promise {\n try {\n const key = `ue:${reportId}:${goatId || \"ALL\"}`;\n const raw = await redis([\"GET\", key]);\n if (!raw) return null;\n const entity = JSON.parse(raw);\n const action = entity.actions?.find((a: any) => a.actionId === actionId);\n return action || null;\n } catch {\n return null;\n }\n}\n\nasync function updateActionRedis(\n reportId: string,\n goatId: string,\n actionId: string,\n updates: Record,\n): Promise {\n try {\n const key = `ue:${reportId}:${goatId || \"ALL\"}`;\n const raw = await redis([\"GET\", key]);\n if (!raw) return;\n const entity = JSON.parse(raw);\n const action = entity.actions?.find((a: any) => a.actionId === actionId);\n if (!action) return;\n\n Object.keys(updates).forEach((k) => {\n action[k] = updates[k];\n });\n action._dirty = true;\n entity.metadata.lastUpdated = new Date().toISOString();\n entity.metadata.needsSync = true;\n\n await redis([\"SET\", key, JSON.stringify(entity), \"EX\", \"604800\"]);\n } catch (err) {\n console.error(\"[UE Proxy] Redis update failed:\", err);\n }\n}\n\n// ============= MODAL OPENER =============\n\nasync function openModal(\n triggerId: string,\n actionData: any,\n ueActionId: string,\n) {\n const actionText = actionData.actionText || \"\";\n const actionType = actionData.actionType || \"\";\n\n // Build a simple input modal (most common case)\n // For specialized modals (Milk Feeding, Shift Count), fallback to Apps Script\n const view: any = {\n type: \"modal\",\n callback_id: `ue_input_submit_${ueActionId}`,\n title: { type: \"plain_text\", text: actionText.substring(0, 24) || \"Input\" },\n submit: { type: \"plain_text\", text: \"Submit\" },\n blocks: [\n {\n type: \"input\",\n block_id: \"ue_input_value\",\n label: { type: \"plain_text\", text: actionText || \"Enter value\" },\n element: {\n type: \"plain_text_input\",\n action_id: \"value\",\n placeholder: { type: \"plain_text\", text: \"Enter your response...\" },\n },\n },\n ],\n private_metadata: JSON.stringify({ actionId: ueActionId }),\n };\n\n const res = await fetch(\"https://slack.com/api/views.open\", {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${SLACK_BOT_TOKEN}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({ trigger_id: triggerId, view }),\n });\n\n const data = await res.json();\n if (!data.ok) console.error(\"[UE Proxy] views.open error:\", data.error);\n return data;\n}","const GAS_URL = Deno.env.get(\"GAS_EXEC_URL\") || \"\";\nconst SLACK_BOT_TOKEN = Deno.env.get(\"SLACK_BOT_TOKEN\") || \"\";\nconst REDIS_URL = Deno.env.get(\"UPSTASH_REDIS_REST_URL\") || \"\";\nconst REDIS_TOKEN = Deno.env.get(\"UPSTASH_REDIS_REST_TOKEN\") || \"\";\n\nexport default async function slackProxy(req: Request): Promise {\n if (req.method === \"GET\") {\n return new Response(\"UE Slack Proxy is running.\");\n }\n\n try {\n const contentType = req.headers.get(\"content-type\") || \"\";\n let body: any = {};\n let rawBody = \"\";\n\n // Parse the incoming payload\n if (contentType.includes(\"application/x-www-form-urlencoded\")) {\n const formData = await req.text();\n rawBody = formData;\n const params = new URLSearchParams(formData);\n const payloadStr = params.get(\"payload\") || \"\";\n try {\n body = JSON.parse(payloadStr);\n } catch (_) {}\n } else {\n const text = await req.text();\n rawBody = text;\n try {\n body = JSON.parse(text);\n } catch (_) {}\n }\n\n const payloadType = body.type || \"unknown\";\n console.log(\"[UE Proxy] Received:\", payloadType);\n\n // ---- URL Verification ----\n if (payloadType === \"url_verification\") {\n return Response.json({ challenge: body.challenge });\n }\n\n // ---- Block Actions: Check for modal-opening actions ----\n if (payloadType === \"block_actions\") {\n const action = body.actions?.[0];\n const actionId = action?.action_id || \"\";\n\n // Modal-opening actions — handle directly (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 {\n value = JSON.parse(action.value || \"{}\");\n } catch (_) {}\n\n console.log(\n \"[UE Proxy] Modal open for:\",\n value.actionId,\n \"trigger:\",\n body.trigger_id,\n );\n\n // Fetch action details from Redis (fast) to build the modal\n const actionData = await getActionFromRedis(\n value.reportId || \"\",\n value.goatId || \"ALL\",\n value.actionId,\n );\n\n if (actionData) {\n // Build and open modal directly from Val Town\n await openModal(body.trigger_id, actionData, value.actionId);\n } else {\n // Fallback: forward to Apps Script synchronously for modal\n try {\n await fetch(GAS_URL, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n source: \"valtown_modal\",\n type: \"open_modal\",\n trigger_id: body.trigger_id,\n action_id: actionId,\n ue_action_id: value.actionId,\n }),\n });\n } catch (err) {\n console.error(\"[UE Proxy] Modal fallback error:\", err);\n }\n }\n\n return new Response(\"\", { status: 200 });\n }\n\n // Button clicks (Yes/No/Done) — save response to Redis (status stays Posted)\n if (actionId.startsWith(\"ue_\")) {\n let value: Record = {};\n try {\n value = JSON.parse(action.value || \"{}\");\n } catch (_) {}\n\n // Save response to Redis (non-blocking) — do NOT change status\n if (REDIS_URL && value.reportId && value.goatId && value.actionId) {\n updateActionRedis(value.reportId, value.goatId, value.actionId, {\n response: value.answer || \"Done\",\n verifiedBy: body.user?.id || \"\",\n }).catch((err) =>\n console.error(\"[UE Proxy] Redis update error:\", err)\n );\n }\n }\n }\n\n // ---- Forward raw payload to Apps Script (all cases) ----\n fetch(GAS_URL, {\n method: \"POST\",\n headers: { \"Content-Type\": contentType || \"application/json\" },\n body: rawBody,\n }).catch((err) => console.error(\"[UE Proxy] GAS forward error:\", err));\n\n return Response.json({});\n } catch (err) {\n console.error(\"[UE Proxy] Error:\", err);\n return Response.json({});\n }\n}\n\n// ============= REDIS HELPERS =============\n\nasync function redis(command: string[]): Promise {\n if (!REDIS_URL || !REDIS_TOKEN) return null;\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 const data = await resp.json();\n return data.error ? null : data.result;\n}\n\nasync function getActionFromRedis(\n reportId: string,\n goatId: string,\n actionId: string,\n): Promise {\n try {\n const key = `ue:${reportId}:${goatId || \"ALL\"}`;\n const raw = await redis([\"GET\", key]);\n if (!raw) return null;\n const entity = JSON.parse(raw);\n const action = entity.actions?.find((a: any) => a.actionId === actionId);\n return action || null;\n } catch {\n return null;\n }\n}\n\nasync function updateActionRedis(\n reportId: string,\n goatId: string,\n actionId: string,\n updates: Record,\n): Promise {\n try {\n const key = `ue:${reportId}:${goatId || \"ALL\"}`;\n const raw = await redis([\"GET\", key]);\n if (!raw) return;\n const entity = JSON.parse(raw);\n const action = entity.actions?.find((a: any) => a.actionId === actionId);\n if (!action) return;\n\n Object.keys(updates).forEach((k) => {\n action[k] = updates[k];\n });\n action._dirty = true;\n entity.metadata.lastUpdated = new Date().toISOString();\n entity.metadata.needsSync = true;\n\n await redis([\"SET\", key, JSON.stringify(entity), \"EX\", \"604800\"]);\n } catch (err) {\n console.error(\"[UE Proxy] Redis update failed:\", err);\n }\n}\n\n// ============= MODAL OPENER =============\n\nasync function openModal(\n triggerId: string,\n actionData: any,\n ueActionId: string,\n) {\n const actionText = actionData.actionText || \"\";\n const actionType = actionData.actionType || \"\";\n\n // Build a simple input modal (most common case)\n // For specialized modals (Milk Feeding, Shift Count), fallback to Apps Script\n const view: any = {\n type: \"modal\",\n callback_id: `ue_input_submit_${ueActionId}`,\n title: { type: \"plain_text\", text: actionText.substring(0, 24) || \"Input\" },\n submit: { type: \"plain_text\", text: \"Submit\" },\n blocks: [\n {\n type: \"input\",\n block_id: \"ue_input_value\",\n label: { type: \"plain_text\", text: actionText || \"Enter value\" },\n element: {\n type: \"plain_text_input\",\n action_id: \"value\",\n placeholder: { type: \"plain_text\", text: \"Enter your response...\" },\n },\n },\n ],\n private_metadata: JSON.stringify({ actionId: ueActionId }),\n };\n\n const res = await fetch(\"https://slack.com/api/views.open\", {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${SLACK_BOT_TOKEN}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({ trigger_id: triggerId, view }),\n });\n\n const data = await res.json();\n if (!data.ok) console.error(\"[UE Proxy] views.open error:\", data.error);\n return data;\n}","createdAt",["D",1772798478944],"branchVersion","branchId","1e279740-16e3-11f1-a410-42dde27851f2","id","1e2737fa-16e3-11f1-a410-42dde27851f2","slackproxyunifiedautomation",["D",1772530014443],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","019c575a-85f2-7330-9147-a0b1510fc7a2","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019c575a-85f2-7330-9147-a6688df1f350","tursoName","1e2737fa16e311f1a41042dde27851f2","tursoHostname","1e2737fa16e311f1a41042dde27851f2-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789506093912],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_97":96,"_104":100},"org",{"_97":96,"_98":-5,"_99":100,"_18":54,"_101":102,"_103":25},"branch",{"_13":86,"_32":87,"_43":42,"_88":44,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":45,"_95":96},"isOwned",40,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","nandini0620","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzM5Y09uYlQ5Y1FhYTdkRUVGeDRRcHZnYmd2NCJ9","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":153,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":64,"_65":66,"_67":154,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":155,"_81":156,"_83":157,"_85":25},"tree",[148],"files",[148],"counts",{"_136":60,"_137":138,"_139":60,"_140":141,"_142":143},"contents",[128],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":129,"_32":28,"_30":31,"_130":-5,"_41":42,"_40":14,"_131":25,"_38":132,"_13":133,"_33":34,"_35":37,"_24":25,"_134":-5,"_27":135},"2f79c388-1954-11f1-8c20-42dde27851f2","parentId","latest",["D",1772798478944],6,"label",[28],"pulls","branches",1,"forks","envVars",{"_144":146,"_147":60},"connections",{"_144":60,"_145":60},"count","unfilledCount",4,"emptyCount",{"_43":129,"_32":28,"_30":31,"_130":-5,"_41":42,"_40":14,"_131":25,"_38":149,"_13":133,"_33":34,"_35":37,"_24":25,"_134":-5,"_150":151,"_27":152},["D",1772798478944],"children",[],[28],["D",1772530014443],["D",1789506093912],{"_97":96,"_104":100},{"_97":96,"_98":-5,"_99":100,"_18":54,"_101":102,"_103":25},{"_13":86,"_32":87,"_43":42,"_88":44,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":45,"_95":96},"ctx",{"_79":-5,"_125":191,"_192":193,"_194":195,"_196":25,"_197":25,"_198":25,"_199":123,"_200":-5,"_201":-7,"_202":-7,"_203":60,"_204":25,"_205":25,"_206":-5,"_207":25,"_208":25,"_209":25,"_210":-5},"ENV",{"_162":163,"_164":165,"_166":87,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","5015b8df46402d8bba4f485ecc37aec202b0e06b","RENDER_GIT_BRANCH","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","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v7