[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_182":183,"_184":185},"routes/_app.x.$handle.$name",{"_108":107,"_38":56,"_116":98,"_33":117,"_13":14,"_118":-5,"_11":119,"_120":121,"_122":123,"_124":125,"_126":127,"_27":-5,"_128":-5,"_129":-5,"_130":31,"_131":132,"_133":70,"_134":-5,"_135":-5,"_136":137},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_54":55,"_38":56,"_44":57,"_58":-5,"_59":31,"_60":61,"_62":61,"_63":64,"_65":-5,"_19":66,"_67":68,"_69":70,"_71":-5,"_72":-5,"_73":74,"_75":76,"_77":-5,"_78":-5,"_79":-5,"_80":-5,"_81":82,"_83":82,"_84":85,"_86":85,"_87":85,"_88":82,"_89":82,"_90":91,"_92":93,"_94":95,"_96":31},"version",2,"changes",[25,26],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","6b8449f0-57c6-4c3e-ba02-a695a1ddc292","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_27":49,"_29":-7,"_30":31,"_32":31,"_33":50,"_35":50},{"_27":28,"_29":-7,"_30":31,"_32":31,"_33":34,"_35":34},"file",{"_36":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":14,"_47":48,"_30":31},"previous","deleted",false,"deletedHere","path","lib/gorgias.ts","latestPath","fileId","e93d39ce-a8c6-11f1-afef-1607ee4eb77e","name","gorgias.ts","fileType","script","content","/**\n * Gorgias data layer.\n *\n * Uses two signals to classify each agent:\n * - ACTIVITY (online/offline): Gorgias's own definition of online is having\n * performed an action in Gorgias within the last 10 minutes. We read that\n * from the audit trail (`GET /api/events`), falling back to the agent's\n * most-recently-updated assigned ticket when an event can't be attributed.\n * - AVAILABILITY (out of office): Gorgias agents set an availability status.\n * We honor an explicit out-of-office flag on the agent record and an\n * OUT_OF_OFFICE_AGENTS env var override (comma-separated emails).\n *\n * Requires env vars:\n * GORGIAS_DOMAIN your Gorgias subdomain, e.g. \"mybrand\"\n * GORGIAS_API_KEY API key created by an admin (Settings -> REST API)\n */\n\nconst DOMAIN = Deno.env.get(\"GORGIAS_DOMAIN\")?.trim();\nconst API_KEY = Deno.env.get(\"GORGIAS_API_KEY\")?.trim();\nconst OUT_OF_OFFICE = new Set(\n (Deno.env.get(\"OUT_OF_OFFICE_AGENTS\") ?? \"\")\n .split(\",\").map((s) => s.trim().toLowerCase()).filter(Boolean),\n);\n\nexport const IDLE_THRESHOLD_MINUTES = 10;\nconst BASE = DOMAIN ? `https://${DOMAIN}.gorgias.com/api` : \"\";\n\nasync function gorgias(path: string, extra?: RequestInit): Promise {\n const res = await fetch(`${BASE}${path}`, {\n ...extra,\n headers: { ...(extra?.headers ?? {}), \"X-Auth-Key\": API_KEY ?? \"\" },\n });\n if (!res.ok) {\n throw new Error(`Gorgias ${res.status} on ${path}: ${await res.text()}`);\n }\n return res.json();\n}\n\nasync function listAgents(): Promise {\n const agents: any[] = [];\n let cursor: string | null = null;\n do {\n const page = await gorgias(`/agents?cursor=${cursor ?? \"\"}&limit=100`);\n agents.push(...(page?.data ?? []));\n cursor = page?.meta?.next_cursor ?? null;\n } while (cursor);\n return agents;\n}\n\n// Newest audit events give the \"who did something when\" trail.\nasync function recentEvents(limit = 200): Promise {\n const page = await gorgias(`/events?limit=${limit}`);\n return page?.data ?? [];\n}\n\n// Pull the actor (user id) out of an event, tolerating the different shapes\n// different event types use.\nfunction eventActorId(e: any): number | null | undefined {\n const candidates = [\n e?.actor?.id, e?.actor, e?.user?.id, e?.user, e?.agent?.id,\n e?.assigned_user_id, e?.assignee_user_id, e?.admin_user_id,\n e?.created_by?.id, e?.created_by, e?.author?.id, e?.actor_id,\n e?.user_id, e?.agent_id, e?.user_account_id,\n ];\n for (const c of candidates) {\n if (typeof c === \"number\") return c;\n if (c && typeof c.id === \"number\") return c.id;\n }\n return undefined;\n}\n\nasync function lastTicketActionMs(agentId: number): Promise {\n try {\n const res = await gorgias(\n `/tickets?limit=1&assignee_user_id=${agentId}&order_by=-updated_datetime`,\n );\n const t = res?.data?.[0]?.updated_datetime;\n return t ? new Date(t).getTime() : null;\n } catch {\n return null;\n }\n}\n\nexport async function buildReport(now = new Date()) {\n if (!DOMAIN || !API_KEY) {\n return {\n ok: false,\n error: \"Missing GORGIAS_DOMAIN or GORGIAS_API_KEY environment variable.\",\n help:\n `👉 Add GORGIAS_DOMAIN here: https://www.val.town/x/koalaSleep/gorgias-agent-monitor/environment-variables?key=GORGIAS_DOMAIN\\n` +\n `👉 Add GORGIAS_API_KEY here: https://www.val.town/x/koalaSleep/gorgias-agent-monitor/environment-variables?key=GORGIAS_API_KEY`,\n };\n }\n\n const nowMs = now.getTime();\n const thresholdMs = IDLE_THRESHOLD_MINUTES * 60_000;\n\n const [agents, events] = await Promise.all([\n listAgents(),\n recentEvents(),\n ]);\n\n const byId = new Map();\n const byEmail = new Map();\n for (const a of agents) {\n if (typeof a.id === \"number\") byId.set(a.id, a);\n if (a.email) byEmail.set((a.email as string).toLowerCase(), a);\n }\n\n // Build an activity map from the audit trail.\n const lastEventMs = new Map();\n for (const e of events) {\n const id = eventActorId(e);\n const t = e?.created_datetime ? new Date(e.created_datetime).getTime() : NaN;\n if (typeof id === \"number\" && byId.has(id) && Number.isFinite(t)) {\n const prev = lastEventMs.get(id) ?? 0;\n if (t > prev) lastEventMs.set(id, t);\n }\n }\n\n const rows = await Promise.all(\n agents.map(async (agent) => {\n const email = (agent.email ?? \"\").toLowerCase();\n let lastActionMs = lastEventMs.get(agent.id) ?? null;\n let source: \"audit\" | \"ticket\" | \"none\" = \"audit\";\n\n if (lastActionMs === null) {\n lastActionMs = await lastTicketActionMs(agent.id);\n if (lastActionMs !== null) source = \"ticket\";\n else source = \"none\";\n }\n\n const minutesIdle = lastActionMs !== null\n ? Math.max(0, Math.floor((nowMs - lastActionMs) / 60_000))\n : null;\n const online = lastActionMs !== null &&\n (nowMs - lastActionMs) <= thresholdMs;\n\n const availability = agent.available === undefined\n ? null\n : agent.available ? \"available\" : \"unavailable\";\n const oooExplicit = agent.out_of_office === true ||\n [\"out-of-office\", \"out_of_office\", \"ooo\", \"unavailable\"]\n .includes(String(agent.availability ?? \"\").toLowerCase()) ||\n OUT_OF_OFFICE.has(email);\n\n let status: \"active\" | \"offline\" | \"out_of_office\";\n if (oooExplicit) status = \"out_of_office\";\n else if (online) status = \"active\";\n else status = \"offline\";\n\n return {\n id: agent.id,\n name: agent.name ?? `Agent ${agent.id}`,\n email: agent.email ?? null,\n active: agent.active ?? null,\n availability,\n status,\n online,\n source,\n last_action_utc: lastActionMs ? new Date(lastActionMs).toISOString() : null,\n minutes_idle: minutesIdle,\n };\n }),\n );\n\n const flagged = rows.filter((r) => r.status !== \"active\");\n\n return {\n ok: true,\n generated_at_utc: now.toISOString(),\n idle_threshold_minutes: IDLE_THRESHOLD_MINUTES,\n summary: {\n total: rows.length,\n active: rows.filter((r) => r.status === \"active\").length,\n out_of_office: rows.filter((r) => r.status === \"out_of_office\").length,\n offline: rows.filter((r) => r.status === \"offline\").length,\n },\n flagged,\n agents: rows,\n };\n}\n","createdAt",["D",1788570769513],"branchVersion","branchId","bf74b66c-1d09-401c-84fb-1c4cb97afda3",{"_36":51,"_38":50,"_40":52,"_42":-5,"_44":53,"_46":14,"_47":48,"_30":31},"lib","b8f263ab-dd2e-4511-a3d4-fed02a6d5cf4","directory",["D",1788570769513],"id","587ec25a-3463-4522-92ee-0f100d4675c4","gorgias-agent-monitor",["D",1788570602124],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Monitor when Gorgias agents are offline or idle >10min","imageUrl","8583b458-3920-4bba-b0ba-b7738de05dc6","pinnedFileId","96dc5692-a8c6-11f1-9401-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a06f1b-c859-73e8-af0c-9564d48edc04","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_108":107,"_115":-5},"org",{"_108":107,"_109":110,"_111":-5,"_19":-5,"_112":113,"_114":31},"branch",{"_13":97,"_38":98,"_54":48,"_99":55,"_100":-5,"_101":-5,"_102":-5,"_103":-5,"_104":-5,"_105":56,"_106":107},"isOwned",16,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","koalaSleep","handle","displayName","Koala","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_54":55,"_38":56,"_44":178,"_58":-5,"_59":31,"_60":61,"_62":61,"_63":64,"_65":-5,"_19":66,"_67":68,"_69":70,"_71":-5,"_72":-5,"_73":74,"_75":76,"_77":-5,"_78":-5,"_79":-5,"_80":-5,"_81":82,"_83":82,"_84":85,"_86":85,"_87":85,"_88":82,"_89":82,"_90":179,"_92":180,"_94":181,"_96":31},"tree",[164,166],"files",[164,165,166],"counts",{"_153":74,"_154":143,"_155":74,"_156":157,"_158":159},"contents",[138,139],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_54":150,"_38":50,"_36":51,"_142":-5,"_47":48,"_46":14,"_144":70,"_44":151,"_13":74,"_40":52,"_42":-5,"_30":31,"_148":-5,"_33":152},{"_54":140,"_38":141,"_36":68,"_142":-5,"_47":48,"_46":143,"_144":31,"_44":145,"_13":74,"_40":146,"_42":147,"_30":31,"_148":56,"_33":149},"3b94881f-9204-4400-851a-f63599bd78ba","main.ts","parentId",1,"latest",["D",1788570631300],"http","/**\n * Gorgias Agent Monitor\n *\n * Returns JSON listing every Gorgias agent that is either offline or has had\n * no ticket action in the last 10 minutes. Designed to be embedded/called by\n * other tools (PagerDuty, Slack bots, dashboards, cron checks, etc.).\n *\n * GET / -> JSON report (latest run of course)\n * GET /?format=human -> human-readable plain text\n *\n * Environment variables (set in the Val Town UI):\n * GORGIAS_DOMAIN your Gorgias subdomain, e.g. \"mybrand\"\n * GORGIAS_API_KEY an API key created by an admin in Gorgias\n *\n * Auth is done with the X-Auth-Key header against\n * https://.gorgias.com/api/... (Gorgias API v1).\n */\n\nimport { cors } from \"https://esm.town/v/std/cors\";\n\nconst DOMAIN = Deno.env.get(\"GORGIAS_DOMAIN\")?.trim();\nconst API_KEY = Deno.env.get(\"GORGIAS_API_KEY\")?.trim();\nconst IDLE_MS = 10 * 60 * 1000; // 10 minutes\n\nconst BASE = DOMAIN ? `https://${DOMAIN}.gorgias.com/api` : \"\";\n\nfunction authHeaders(): HeadersInit {\n const headers: Record = { \"Content-Type\": \"application/json\" };\n if (API_KEY) headers[\"X-Auth-Key\"] = API_KEY;\n else headers[\"Accept\"] = \"application/json\";\n return headers;\n}\n\nasync function gorgias(path: string, extra?: RequestInit): Promise {\n const res = await fetch(`${BASE}${path}`, {\n ...extra,\n headers: { ...authHeaders(), ...(extra?.headers ?? {}) },\n });\n if (!res.ok) {\n throw new Error(`Gorgias ${res.status} on ${path}: ${await res.text()}`);\n }\n return res.json();\n}\n\nasync function lastTicketActivity(agentId: number): Promise {\n // Most recently updated ticket assigned to this agent gives us their last action time.\n const res = await gorgias(\n `/tickets?limit=1&assignee_user_id=${agentId}&order_by=-updated_datetime`,\n );\n const ticket = res?.data?.[0];\n return ticket?.updated_datetime ? new Date(ticket.updated_datetime) : null;\n}\n\nasync function buildReport() {\n const now = new Date();\n\n if (!DOMAIN || !API_KEY) {\n return {\n ok: false,\n error: \"Missing GORGIAS_DOMAIN or GORGIAS_API_KEY environment variable.\",\n help: \"Set them in the val's environment variables and re-run.\",\n };\n }\n\n let agents: any[] = [];\n let cursor: string | null = null;\n // Paginate through all agents (Gorgias returns ~25 per page by default).\n do {\n const page = await gorgias(`/agents?cursor=${cursor ?? \"\"}&limit=100`);\n agents = agents.concat(page?.data ?? []);\n cursor = page?.meta?.next_cursor ?? null;\n } while (cursor);\n\n const results = await Promise.allSettled(\n agents.map(async (agent) => {\n const lastAction = await lastTicketActivity(agent.id);\n const minsIdle = lastAction\n ? Math.max(0, Math.round((now.getTime() - lastAction.getTime()) / 60000))\n : null;\n const flagged = minsIdle === null || minsIdle > 10;\n return {\n id: agent.id,\n name: agent.name,\n email: agent.email ?? null,\n active: agent.active ?? null,\n last_ticket_action_utc: lastAction?.toISOString() ?? null,\n minutes_idle: minsIdle,\n flagged,\n };\n }),\n );\n\n const agentRows = results\n .filter((r): r is PromiseFulfilledResult => r.status === \"fulfilled\")\n .map((r) => r.value);\n\n const flaggedAgents = agentRows.filter((a) => a.flagged);\n const offline = flaggedAgents.filter((a) => a.active === false);\n const idle = flaggedAgents.filter((a) => a.active !== false);\n\n return {\n ok: true,\n generated_at_utc: now.toISOString(),\n idle_threshold_minutes: 10,\n summary: {\n total_agents: agentRows.length,\n offline_or_idle: flaggedAgents.length,\n offline: offline.length,\n idle_over_10_min: idle.length,\n healthy: agentRows.length - flaggedAgents.length,\n },\n flagged_agents: flaggedAgents,\n };\n}\n\nexport default async function handler(req: Request): Promise {\n const report = await buildReport();\n\n const url = new URL(req.url);\n if (url.searchParams.get(\"format\") === \"human\") {\n if (!report.ok) return new Response(report.error + \"\\n\" + (report.help ?? \"\"), { status: 500 });\n const s = report.summary;\n const lines = [\n `Gorgias agent monitor @ ${report.generated_at_utc}`,\n ` total agents: ${s.total_agents}`,\n ` offline or idle: ${s.offline_or_idle}`,\n ` offline: ${s.offline}`,\n ` idle >10 min: ${s.idle_over_10_min}`,\n ` healthy: ${s.healthy}`,\n ``,\n ];\n if (s.offline_or_idle === 0) {\n lines.push(\" ✅ All agents accounted for and acting on tickets.\");\n } else {\n lines.push(\" Check these:\");\n for (const a of report.flagged_agents) {\n lines.push(` - ${a.name} (${a.email ?? a.id}): ${a.active === false ? \"OFFLINE\" : `${a.minutes_idle} min idle`}`);\n }\n }\n return new Response(lines.join(\"\\n\"), {\n headers: { ...cors(req), \"Content-Type\": \"text/plain; charset=utf-8\" },\n });\n }\n\n return new Response(JSON.stringify(report, null, 2), {\n status: report.ok ? 200 : 500,\n headers: { ...cors(req), \"Content-Type\": \"application/json; charset=utf-8\" },\n });\n}\n","label",[141],"713e4d14-9c17-4959-ad02-15870f700bf5",["D",1788570769513],[50],"pulls","branches","forks","envVars",{"_160":162,"_163":74},"connections",{"_160":74,"_161":74},"count","unfilledCount",4,"emptyCount",{"_54":150,"_38":50,"_36":51,"_142":-5,"_47":48,"_46":14,"_144":70,"_44":175,"_13":74,"_40":52,"_42":-5,"_30":31,"_148":-5,"_168":176,"_33":177},{"_54":171,"_38":39,"_36":37,"_142":51,"_47":48,"_46":14,"_144":31,"_44":172,"_13":74,"_40":41,"_42":43,"_30":31,"_148":-5,"_168":173,"_33":174},{"_54":140,"_38":141,"_36":68,"_142":-5,"_47":48,"_46":143,"_144":31,"_44":167,"_13":74,"_40":146,"_42":147,"_30":31,"_148":56,"_168":169,"_33":170},["D",1788570631300],"children",[],[141],"04ed4789-3785-4869-863c-9c7b61280899",["D",1788570769513],[],[50,39],["D",1788570769513],[165],[50],["D",1788570602124],{"_108":107,"_115":-5},{"_108":107,"_109":110,"_111":-5,"_19":-5,"_112":113,"_114":31},{"_13":97,"_38":98,"_54":48,"_99":55,"_100":-5,"_101":-5,"_102":-5,"_103":-5,"_104":-5,"_105":56,"_106":107},"ctx",{"_90":-5,"_135":215,"_216":217,"_218":219,"_220":31,"_221":31,"_222":31,"_223":70,"_224":-5,"_225":-7,"_226":-7,"_227":74,"_228":31,"_229":31,"_230":-5,"_231":31,"_232":31,"_233":31,"_234":-5},"ENV",{"_186":187,"_188":189,"_190":98,"_191":192,"_193":194,"_195":196,"_197":198,"_199":200,"_201":202,"_203":204,"_205":206,"_207":208,"_209":210,"_211":212,"_213":214},"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 · v2