{agent.name}

\n {agent.email ?? \"-\"}\n

\n \n {meta.emoji} {meta.label.toUpperCase()}\n \n

\n {agent.status === \"active\"\n ? <>Last action {timeAgo(agent.last_action_utc)}.\n : agent.status === \"out_of_office\"\n ? <>Marked out of office. Last action {timeAgo(agent.last_action_utc)}.\n : agent.minutes_idle === null\n ? \"No activity found — treating as offline.\"\n : `No action in ${agent.minutes_idle} min (threshold 10 min).`}\n

\n Idle {agent.minutes_idle === null ? \"—\" : `${agent.minutes_idle} min`}\n {\" · \"}\n Source: {agent.source === \"audit\" ? \"audit log\" : agent.source === \"ticket\" ? \"last ticket\" : \"none\"}\n

\n \n );\n}\n\nexport function renderDashboard(report: any): string {\n if (!report.ok) {\n return \"\" +\n \"

Gorgias Agent Monitor

\" +\n `

${report.error}

${report.help ?? \"\"}

`;\n }\n\n const s = report.summary;\n const counts: Record = {\n active: s.active, offline: s.offline, out_of_office: s.out_of_office,\n };\n\n const body = renderToString(\n \n \n \n \n Gorgias Agent Monitor\n \n \n \n \n \n

Gorgias Agent Monitor

\n ✅ {counts.active} active\n 🌴 {counts.out_of_office} OOO\n 🔴 {counts.offline} offline\n

\n Threshold: no action in {report.idle_threshold_minutes}+ min = offline ·{\" \"}\n generated {timeAgo(report.generated_at_utc)} (auto-refreshes) ·{\" \"}\n view source · JSON API\n

\n {report.agents.map((a) => )}\n

\n \n ,\n );\n\n return \"\" + body;\n}\n",[],[198],["D",1788571177314],[],[18],"5183103e-6460-4514-a5fc-9fa59ee8a358","gorgias.ts","e93d39ce-a8c6-11f1-afef-1607ee4eb77e","b8f263ab-dd2e-4511-a3d4-fed02a6d5cf4",15,["D",1788571305232],8,"/**\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\nlet DOMAIN = Deno.env.get(\"GORGIAS_DOMAIN\")?.trim() ?? \"\";\nconst EMAIL = Deno.env.get(\"GORGIAS_EMAIL\")?.trim() ?? \"\";\nconst API_KEY = Deno.env.get(\"GORGIAS_API_KEY\")?.trim() ?? \"\";\n\n// Accept either \"koala\" or \"koala.gorgias.com\" or a full https URL.\nif (DOMAIN) {\n const m = DOMAIN.match(/https?:\\/\\/([\\w-]+)\\.gorgias\\.com/);\n if (m) {\n DOMAIN = m[1];\n } else {\n DOMAIN = DOMAIN.replace(/\\.gorgias\\.com$/, \"\").replace(/^https?:\\/\\/|\\/$/g, \"\");\n }\n}\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\nfunction authHeaders(): Record {\n // Gorgias REST API uses HTTP Basic auth: username = account email, password = API key.\n if (EMAIL && API_KEY) {\n const basic = btoa(`${EMAIL}:${API_KEY}`);\n return { Authorization: `Basic ${basic}` };\n }\n // Fallback: some accounts accept the API key via X-Auth-Key.\n if (API_KEY) return { \"X-Auth-Key\": API_KEY };\n return {};\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\n// Gorgias exposes people under /users (agents, managers, admins).\nasync function listAgents(): Promise {\n const users: any[] = [];\n let cursor: string | null = null;\n do {\n const page = await gorgias(`/users?cursor=${cursor ?? \"\"}&limit=100`);\n users.push(...(page?.data ?? []));\n cursor = page?.meta?.next_cursor ?? null;\n } while (cursor);\n\n // Keep only support-facing people: agents and managers, and drop disabled accounts.\n return users.filter((u) => {\n if (u.role === \"admin\" || u.role === \"shared\") return false;\n if (u.role === \"agent\" || u.role === \"manager\") return true;\n return u.enabled !== false; // fallback: keep users unless disabled\n });\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 || !EMAIL || !API_KEY) {\n return {\n ok: false,\n error: \"Missing GORGIAS_DOMAIN, GORGIAS_EMAIL, or GORGIAS_API_KEY environment variable.\",\n help:\n `Set GORGIAS_DOMAIN to your subdomain (e.g. koala), GORGIAS_EMAIL to your Gorgias account email, and GORGIAS_API_KEY to your REST API key.\\n` +\n `👉 Add GORGIAS_DOMAIN here: https://www.val.town/x/koalaSleep/gorgias-agent-monitor/environment-variables?key=GORGIAS_DOMAIN\\n` +\n `👉 Add GORGIAS_EMAIL here: https://www.val.town/x/koalaSleep/gorgias-agent-monitor/environment-variables?key=GORGIAS_EMAIL\\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().catch(() => []), // audit trail needs OAuth; fall back to tickets\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 const teamNames = (agent.teams ?? [])\n .map((t) => (t && (t.name ?? t.id)) as string).filter(Boolean);\n\n return {\n id: agent.id,\n name: agent.name ?? agent.full_name ?? `Agent ${agent.id}`,\n email: agent.email ?? null,\n role: agent.role ?? null,\n active: agent.enabled ?? null,\n teams: teamNames,\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",[],[219,210],"lib","713e4d14-9c17-4959-ad02-15870f700bf5",2,["D",1788570769513],"directory",[175],[219],["D",1788570602124],{"_11":12,"_133":-5},{"_11":12,"_128":129,"_70":-5,"_30":-5,"_130":131,"_132":24},{"_39":119,"_13":16,"_33":36,"_120":82,"_121":-5,"_122":-5,"_123":-5,"_124":-5,"_125":-5,"_126":14,"_127":12},"ctx",{"_54":-5,"_152":263,"_264":265,"_266":267,"_268":24,"_269":24,"_270":24,"_271":95,"_272":-5,"_273":-7,"_274":-7,"_275":26,"_276":24,"_277":24,"_278":-5,"_279":24,"_280":24,"_281":24,"_282":-5},"ENV",{"_234":235,"_236":237,"_238":16,"_239":240,"_241":242,"_243":244,"_245":246,"_247":248,"_249":250,"_251":252,"_253":254,"_255":256,"_257":258,"_259":260,"_261":262},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","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"]

History · README.md