[{"_1":2,"_168":-5,"_169":-5},"loaderData",{"_3":4,"_91":92},"root",{"_5":6,"_34":35,"_64":65},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":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","notificationCount",0,"flagDenols","ENV",{"_36":37,"_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},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","4ff166458996ccfe3bfa8627489090938620785a","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",{"_66":67},"__internal_clerk_state",{"_68":69,"_70":45,"_71":72,"_73":72,"_74":20,"_75":72,"_76":72,"_77":72,"_78":72,"_79":80,"_89":20,"_90":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",{"_81":20,"_19":20,"_82":72,"_83":84,"_85":72,"_86":45,"_87":20,"_88":72},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_93":94,"_95":96,"_97":98,"_99":100,"_146":147,"_165":166,"_167":-5},"handle","wade","name","vestaboard","path","gong.tsx","project",{"_101":102,"_95":96,"_103":104,"_105":-5,"_106":20,"_107":108,"_109":-5,"_110":-5,"_12":111,"_112":-5,"_113":20,"_114":-5,"_115":32,"_14":116,"_117":118,"_119":118,"_120":121,"_122":121,"_123":121,"_124":118,"_125":118,"_23":126,"_129":130,"_132":133,"_145":20},"id","6c045964-7876-11f0-9781-0224a6c84d84","createdAt",["D",1755111046214],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","b4b94da1-c039-4c04-91b0-2c4b56a0e86e","pinnedFileId","pinPreview","screenshotVersion","likeCount","125022f8-1988-42f0-8ce0-4fd1cf2a72f9","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_127":128},"profileImageUrl","https://images.clerk.dev/oauth_github/img_2QF3DipgzsC9OCpGJxKanZykT4l.png","org",{"_93":94,"_131":128},"avatar","branch",{"_134":135,"_95":43,"_101":136,"_137":102,"_138":-5,"_139":-5,"_140":-5,"_141":-5,"_142":-5,"_143":96,"_144":94},"version",13,"6c04b1c0-7876-11f0-9781-0224a6c84d84","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_101":148,"_95":98,"_149":150,"_151":-5,"_152":136,"_153":135,"_154":155,"_103":156,"_134":157,"_158":159,"_160":161,"_162":20,"_163":-5,"_97":164},"cda33b84-78a0-11f0-9e62-0224a6c84d84","fileId","d0f2223a-787a-11f0-b488-0224a6c84d84","parentId","branchId","branchVersion","latest",true,["D",1755129248846],3,"fileType","script","content","// val: @wingspan/gong_voc_vestaboard_cron.ts\n// Schedule: every 15 minutes (Val.town Cron)\n\n// --- Imports ---\nimport { blob } from \"https://esm.town/v/std/blob\"; // Val.town Blob Storage :contentReference[oaicite:14]{index=14}\nimport OpenAI from \"npm:openai\"; // Official OpenAI SDK (works in Deno via npm:) :contentReference[oaicite:15]{index=15}\n\n// --- Types ---\ntype Interval = { lastRunAt?: Date };\n\ntype GongParty = {\n id: string;\n emailAddress?: string;\n name?: string;\n title?: string;\n userId?: string;\n speakerId?: string;\n affiliation?: \"Internal\" | \"External\" | \"Unknown\";\n};\n\ntype GongMeta = {\n id: string;\n title?: string;\n started?: string; // ISO\n};\n\ntype GongExtensiveCall = {\n metaData: GongMeta;\n context?: unknown; // not relied upon, but used if present\n parties?: GongParty[];\n};\n\ntype GongExtensiveResp = {\n calls?: GongExtensiveCall[];\n records?: { cursor?: string };\n};\n\ntype GongSentence = { start?: number; end?: number; text: string };\ntype GongMonologue = { speakerId: string; sentences?: GongSentence[] };\ntype GongCallTranscript = { callId: string; transcript?: GongMonologue[] };\ntype GongTranscriptResp = {\n callTranscripts?: GongCallTranscript[];\n records?: { cursor?: string };\n};\n\ntype Quote = {\n id: string; // stable hash\n callId: string;\n capturedAt: string; // ISO\n quote: string;\n speaker: { name: string; role: string };\n account: { name?: string; domain?: string };\n tags: string[];\n confidence?: number;\n};\n\ntype State = {\n version: 1;\n processedCalls: Record; // callId -> transcriptHash\n quotes: Quote[];\n nextIndex: number; // rotation pointer\n};\n\n// --- Config ---\nconst GONG_BASE_URL = Deno.env.get(\"GONG_BASE_URL\") ?? \"https://api.gong.io\";\nconst GONG_BASIC_TOKEN = Deno.env.get(\"GONG_BASIC_TOKEN\") ??\n (Deno.env.get(\"GONG_ACCESS_KEY\") && Deno.env.get(\"GONG_ACCESS_KEY_SECRET\")\n ? b64(\n `${Deno.env.get(\"GONG_ACCESS_KEY\")}:${\n Deno.env.get(\"GONG_ACCESS_KEY_SECRET\")\n }`,\n )\n : undefined);\nconst OPENAI_API_KEY = Deno.env.get(\"OPENAI_API_KEY\");\nconst OPENAI_MODEL = Deno.env.get(\"OPENAI_MODEL\") ?? \"gpt-5\";\nconst ORG_EMAIL_DOMAIN = (Deno.env.get(\"ORG_EMAIL_DOMAIN\") ?? \"wingspan.app\")\n .toLowerCase();\nconst VESTABOARD_RW_KEY = Deno.env.get(\"VESTABOARD_RW_KEY\");\nconst STATE_KEY = \"voc/state.json\";\n\n// Fetch window + batching\nconst LOOKBACK_HOURS = 48;\nconst TRANSCRIPT_BATCH = 30; // callIds per /transcript request (safe batch size)\nconst MAX_OPENAI_INPUT_CHARS = 120_000; // guard rails per call extraction\n\n// Color cycle for the bottom bar (Vestaboard char codes)\nconst COLOR_CODES = [63, 64, 65, 66, 67, 68]; // RED..VIOLET :contentReference[oaicite:16]{index=16}\n\n// --- Entry point (Val.town Cron signature) ---\nexport async function gong_voc_vestaboard_cron(interval: Interval) {\n assertEnv();\n\n const now = new Date();\n const lookbackMs = LOOKBACK_HOURS * 60 * 60 * 1000;\n const fromMs = interval?.lastRunAt\n ? Math.min(\n now.getTime() - lookbackMs,\n interval.lastRunAt.getTime() - 60 * 60 * 1000,\n )\n : now.getTime() - lookbackMs;\n const from = new Date(fromMs).toISOString();\n const to = now.toISOString();\n\n // Load state\n const state = await loadState();\n\n // 1) Pull new/updated calls with external participants\n const calls = await listCustomerCalls(from, to);\n\n // Filter out calls we've already processed with the same transcript hash\n const newCallIds = calls\n .map((c) => c.metaData.id)\n .filter((id): id is string => !!id)\n .filter((id) => !state.processedCalls[id]); // we'll verify via hash after fetching transcripts\n\n // 2) Fetch transcripts for new calls\n const transcripts = await fetchTranscripts(newCallIds);\n\n // 3) Build diarized text & extract quotes per call\n const openai = new OpenAI({ apiKey: OPENAI_API_KEY });\n const extracted: Quote[] = [];\n\n for (const tr of transcripts) {\n const call = calls.find((c) => c.metaData.id === tr.callId);\n if (!call) continue;\n\n const diarized = buildDiarized(call, tr);\n if (!diarized) {\n // mark as processed with sentinel to avoid loops\n state.processedCalls[call.metaData.id] = \"NO_TRANSCRIPT\";\n continue;\n }\n\n const transcriptHash = await sha256Hex(diarized);\n if (state.processedCalls[call.metaData.id] === transcriptHash) {\n continue; // unchanged\n }\n\n const account = deriveAccountFromParties(call.parties) ??\n { name: undefined, domain: undefined };\n\n const quotes = await extractQuotes(openai, diarized, {\n accountName: account?.name,\n accountDomain: account?.domain,\n participants: call.parties ?? [],\n });\n\n // Deduplicate & persist\n for (const q of quotes) {\n const id = await sha256Hex(\n `${q.quote}|${q.speaker.name}|${q.speaker.role}|${call.metaData.id}`,\n );\n // skip if we already have this quote id\n if (state.quotes.some((existing) => existing.id === id)) continue;\n\n extracted.push({\n id,\n callId: call.metaData.id,\n capturedAt: call.metaData.started ?? new Date().toISOString(),\n quote: q.quote,\n speaker: q.speaker,\n account: {\n name: q.account?.name ?? account?.name,\n domain: q.account?.domain ?? account?.domain,\n },\n tags: q.tags,\n confidence: q.confidence,\n });\n }\n\n // mark call as processed with latest hash\n state.processedCalls[call.metaData.id] = transcriptHash;\n }\n\n if (extracted.length) {\n state.quotes.push(...extracted);\n // keep storage lean: retain only last 90 days of quotes\n const ninetyDaysAgo = new Date(Date.now() - 90 * 24 * 3600 * 1000);\n state.quotes = state.quotes.filter((q) =>\n new Date(q.capturedAt) >= ninetyDaysAgo\n );\n }\n\n // 4) Rotate a quote from the last 7 days to Vestaboard\n const oneWeekAgo = new Date(Date.now() - 7 * 24 * 3600 * 1000);\n const recent = state.quotes\n .filter((q) => new Date(q.capturedAt) >= oneWeekAgo)\n .sort((a, b) =>\n new Date(a.capturedAt).getTime() - new Date(b.capturedAt).getTime()\n );\n\n let posted = false;\n\n if (recent.length > 0) {\n const index = state.nextIndex % recent.length;\n const quote = recent[index];\n const color = COLOR_CODES[index % COLOR_CODES.length];\n\n try {\n const msg = buildVestaboardMessage(quote, color);\n const codes = await composeVBML(msg); // array of arrays (6x22)\n await postVestaboard(codes);\n posted = true;\n state.nextIndex = (state.nextIndex + 1) % recent.length;\n } catch (err) {\n console.error(\"VBML compose failed, falling back to plain text:\", err);\n const fallback = plainVestaboardText(quote);\n await postVestaboard(fallback);\n posted = true;\n state.nextIndex = (state.nextIndex + 1) % recent.length;\n }\n } else {\n // Fallback: nothing from last week\n const fallbackCodes = await composeVBML({\n components: [\n {\n style: { justify: \"center\", align: \"center\", height: 6, width: 22 },\n template: \"NO NEW VOC IN LAST 7 DAYS\",\n },\n ],\n });\n await postVestaboard(fallbackCodes);\n posted = true;\n }\n\n // Persist state\n await saveState(state);\n\n return {\n fetchedCalls: calls.length,\n newTranscripts: transcripts.length,\n newQuotes: extracted.length,\n postedToVestaboard: posted,\n };\n}\n\n// ----------------------- Gong -----------------------\n\nasync function listCustomerCalls(\n fromISO: string,\n toISO: string,\n): Promise {\n const calls: GongExtensiveCall[] = [];\n let cursor: string | undefined;\n\n do {\n const body: any = {\n filter: { fromDateTime: fromISO, toDateTime: toISO },\n contentSelector: {\n context: \"Basic\",\n exposedFields: { parties: true }, // parties needed to map speakerId -> name/title :contentReference[oaicite:17]{index=17}\n },\n };\n if (cursor) body.cursor = cursor;\n\n const resp = await gongFetch(\"/v2/calls/extensive\", {\n method: \"POST\",\n body: JSON.stringify(body),\n });\n const data = (await resp.json()) as GongExtensiveResp;\n const page = (data.calls ?? []).filter(isExternalMeeting);\n calls.push(...page);\n cursor = data.records?.cursor;\n } while (cursor);\n\n return calls;\n}\n\nfunction isExternalMeeting(call: GongExtensiveCall): boolean {\n const parties = call.parties ?? [];\n // \"Customer/prospect meeting\" = any non-internal (not @wingspan.app) participant\n return parties.some((p) => {\n const email = (p.emailAddress ?? \"\").toLowerCase();\n if (!email) return p.affiliation === \"External\";\n return !email.endsWith(`@${ORG_EMAIL_DOMAIN}`);\n });\n}\n\nasync function fetchTranscripts(\n callIds: string[],\n): Promise {\n const out: GongCallTranscript[] = [];\n for (let i = 0; i < callIds.length; i += TRANSCRIPT_BATCH) {\n const batch = callIds.slice(i, i + TRANSCRIPT_BATCH);\n const resp = await gongFetch(\"/v2/calls/transcript\", {\n method: \"POST\",\n body: JSON.stringify({ filter: { callIds: batch } }),\n }); // :contentReference[oaicite:18]{index=18}\n const data = (await resp.json()) as GongTranscriptResp;\n out.push(...(data.callTranscripts ?? []));\n }\n return out;\n}\n\nfunction buildDiarized(\n call: GongExtensiveCall,\n tr: GongCallTranscript,\n): string | null {\n const monologues = tr.transcript ?? [];\n if (!monologues.length) return null;\n\n const partyBySpeaker = new Map();\n (call.parties ?? []).forEach((p) => {\n if (p.speakerId) partyBySpeaker.set(p.speakerId, p);\n });\n\n let buf = \"\";\n buf += `CALL: ${call.metaData.title ?? \"Untitled\"} (${call.metaData.id})\\n`;\n if (call.metaData.started) buf += `DATE: ${call.metaData.started}\\n`;\n buf += \"TRANSCRIPT:\\n\";\n\n for (const m of monologues) {\n const party = partyBySpeaker.get(m.speakerId);\n const label = party?.name ?? `Speaker ${m.speakerId}`;\n buf += `${label}:\\n`;\n const sentences = m.sentences ?? [];\n for (const s of sentences) {\n const text = (s.text ?? \"\").trim();\n if (text) buf += ` ${text} `;\n }\n buf += \"\\n\\n\";\n }\n\n // Truncate to protect token usage\n if (buf.length > MAX_OPENAI_INPUT_CHARS) {\n buf = buf.slice(0, MAX_OPENAI_INPUT_CHARS) + \"\\n[TRUNCATED]\\n\";\n }\n return buf;\n}\n\nfunction deriveAccountFromParties(parties?: GongParty[]) {\n if (!parties?.length) return undefined;\n const externals = parties.filter((p) => {\n const email = (p.emailAddress ?? \"\").toLowerCase();\n return email && !email.endsWith(`@${ORG_EMAIL_DOMAIN}`);\n });\n if (!externals.length) return undefined;\n // naive account from dominant domain\n const counts = new Map();\n for (const p of externals) {\n const domain = (p.emailAddress ?? \"\").split(\"@\")[1]?.toLowerCase();\n if (!domain) continue;\n counts.set(domain, 1 + (counts.get(domain) ?? 0));\n }\n const domain = [...counts.entries()].sort((a, b) => b[1] - a[1])[0]?.[0];\n return domain ? { name: toCompanyName(domain), domain } : undefined;\n}\n\nfunction toCompanyName(domain: string) {\n const root = domain.split(\".\")[0] ?? domain;\n return root.replace(/[-_]/g, \" \").replace(/\\b\\w/g, (c) => c.toUpperCase());\n}\n\n// -------------------- OpenAI extraction --------------------\n\nasync function extractQuotes(\n openai: OpenAI,\n diarized: string,\n ctx: {\n accountName?: string;\n accountDomain?: string;\n participants: GongParty[];\n },\n): Promise {\n const participants = ctx.participants\n .filter((p) =>\n (p.emailAddress ?? \"\").toLowerCase() &&\n !(p.emailAddress ?? \"\").toLowerCase().endsWith(`@${ORG_EMAIL_DOMAIN}`)\n )\n .map((p) => ({\n name: p.name ?? \"Unknown\",\n title: p.title ?? \"\",\n email: p.emailAddress ?? \"\",\n roleFallback: p.affiliation && p.affiliation !== \"Internal\"\n ? \"Customer\"\n : \"Internal\",\n domain: p.emailAddress?.split(\"@\")[1]?.toLowerCase() ?? \"\",\n }));\n\n const schema = {\n type: \"object\",\n properties: {\n quotes: {\n type: \"array\",\n items: {\n type: \"object\",\n properties: {\n quote: { type: \"string\", maxLength: 160 },\n speaker: {\n type: \"object\",\n properties: {\n name: { type: \"string\" },\n role: { type: \"string\" }, // title if present; else classification\n },\n required: [\"name\", \"role\"],\n additionalProperties: false,\n },\n account: {\n type: \"object\",\n properties: {\n name: { type: \"string\" },\n domain: { type: \"string\" },\n },\n additionalProperties: false,\n },\n tags: {\n type: \"array\",\n items: {\n type: \"string\",\n enum: [\n \"product_feedback\",\n \"feature_request\",\n \"bug\",\n \"pricing\",\n \"objection\",\n \"workflow\",\n \"integration\",\n \"security\",\n \"compliance\",\n \"other\",\n ],\n },\n },\n confidence: { type: \"number\", minimum: 0, maximum: 1 },\n },\n required: [\"quote\", \"speaker\", \"tags\"],\n additionalProperties: false,\n },\n },\n },\n required: [\"quotes\"],\n additionalProperties: false,\n } as const;\n\n const system = [\n \"You extract Voice‑of‑Customer quotes from sales/CS meetings.\",\n \"Return concise, representative quotes (≤ 120 chars) that capture product feedback, pain points, requests, objections.\",\n \"Prefer externally‑spoken content (non‑@wingspan.app).\",\n \"Use the speaker's job title for role when present; otherwise use a basic classification: Customer, Prospect, Partner, Internal.\",\n \"Normalize whitespace; remove filler/pleasantries; keep the essence verbatim when possible.\",\n \"Output JSON ONLY, conforming to the provided schema.\",\n ].join(\" \");\n\n // Best effort account default\n const account = {\n name: ctx.accountName ??\n (ctx.accountDomain ? toCompanyName(ctx.accountDomain) : undefined),\n domain: ctx.accountDomain,\n };\n\n const input = `\nSYSTEM CONTEXT:\nKnown external participants (name | title | email | domain): \n${\n participants.map((p) =>\n `- ${p.name} | ${p.title || \"(no title)\"} | ${p.email} | ${p.domain}`\n ).join(\"\\n\")\n }\n\nKNOWN ACCOUNT (best effort): ${JSON.stringify(account)}\n\nTRANSCRIPT:\n${diarized}\n`;\n\n const r = await openai.responses.create({\n model: OPENAI_MODEL,\n input,\n // Force structured JSON output\n response_format: {\n type: \"json_schema\",\n json_schema: {\n name: \"VoCQuotes\",\n schema,\n strict: true,\n },\n },\n // Slightly bias towards precision over recall\n temperature: 0.2,\n });\n\n const text = extractOutputText(r); // Responses API puts content under `output` :contentReference[oaicite:19]{index=19}\n const parsed = safeJson(text) as { quotes?: Quote[] } | null;\n if (!parsed?.quotes?.length) return [];\n\n // Fill in missing account fields and sanitize\n return parsed.quotes\n .map((q) => ({\n ...q,\n quote: sanitizeQuote(q.quote),\n speaker: {\n name: q.speaker.name,\n role: q.speaker.role || classifyRole(q.speaker.name, participants),\n },\n account: {\n name: q.account?.name ?? account.name,\n domain: q.account?.domain ?? account.domain,\n },\n tags: q.tags?.length ? q.tags : [\"other\"],\n confidence: typeof q.confidence === \"number\" ? q.confidence : undefined,\n }))\n .filter((q) => q.quote.length > 0);\n}\n\nfunction classifyRole(\n name: string,\n parts: { name: string; title: string; roleFallback: string }[],\n) {\n const p = parts.find((x) => x.name.toLowerCase() === name.toLowerCase());\n if (!p) return \"Customer\";\n return p.title?.trim() ? p.title.trim() : p.roleFallback || \"Customer\";\n}\n\nfunction sanitizeQuote(s: string) {\n return s.replace(/\\s+/g, \" \").trim().replace(/[“”]/g, '\"').replace(\n /[‘’]/g,\n \"'\",\n );\n}\n\n// Responses API helper: prefer flattened `output_text`, else reconstruct\nfunction extractOutputText(r: any): string {\n if (r?.output_text) return r.output_text;\n const out = r?.output ?? [];\n const chunks: string[] = [];\n for (const item of out) {\n for (const c of item?.content ?? []) {\n if (typeof c?.text === \"string\") chunks.push(c.text);\n }\n }\n return chunks.join(\"\\n\");\n}\n\nfunction safeJson(s: string) {\n try {\n const start = s.indexOf(\"{\");\n const end = s.lastIndexOf(\"}\");\n if (start >= 0 && end >= start) return JSON.parse(s.slice(start, end + 1));\n } catch (e) {\n console.warn(\"Failed to parse JSON:\", e);\n }\n return null;\n}\n\n// -------------------- Vestaboard --------------------\n\nfunction buildVestaboardMessage(quote: Quote, colorCode: number) {\n const maxWidth = 22, maxLines = 4;\n const wrapped = wrapToWidth(quote.quote.toUpperCase(), maxWidth, maxLines);\n\n const who = [\n quote.speaker.name?.toUpperCase(),\n quote.speaker.role?.toUpperCase(),\n ]\n .filter(Boolean)\n .join(\", \");\n\n const company = quote.account?.name?.toUpperCase() ??\n (quote.account?.domain\n ? toCompanyName(quote.account.domain).toUpperCase()\n : \"\");\n\n const signature = [\"—\", who, company ? `@ ${company}` : \"\"]\n .filter(Boolean)\n .join(\" \");\n\n // Bottom color bar\n const bar = `{${String(colorCode)}}`.repeat(22); // e.g. {63}{63}... :contentReference[oaicite:20]{index=20}\n\n return {\n components: [\n {\n style: { justify: \"center\", align: \"center\", height: 4, width: 22 },\n template: wrapped,\n },\n {\n style: { justify: \"center\", align: \"center\", height: 1, width: 22 },\n template: signature.slice(0, 22),\n },\n {\n style: { justify: \"left\", align: \"bottom\", height: 1, width: 22 },\n template: bar,\n },\n ],\n };\n}\n\nfunction plainVestaboardText(q: Quote | string) {\n const text = typeof q === \"string\"\n ? q\n : `\"${q.quote}\" — ${q.speaker.name}${\n q.speaker.role ? \", \" + q.speaker.role : \"\"\n }${q.account?.name ? \" @ \" + q.account.name : \"\"}`;\n return { text: text.slice(0, 132) }; // fallback: single message\n}\n\nasync function composeVBML(vbml: any) {\n const r = await fetch(\"https://vbml.vestaboard.com/compose\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(vbml),\n }); // :contentReference[oaicite:21]{index=21}\n if (!r.ok) {\n throw new Error(`VBML compose failed: ${r.status} ${await r.text()}`);\n }\n return await r.json(); // returns 6x22 array of character codes\n}\n\nasync function postVestaboard(body: any) {\n if (!VESTABOARD_RW_KEY) throw new Error(\"Missing VESTABOARD_RW_KEY\");\n const r = await fetch(\"https://rw.vestaboard.com/\", {\n method: \"POST\",\n headers: {\n \"X-Vestaboard-Read-Write-Key\": VESTABOARD_RW_KEY,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify(body),\n }); // :contentReference[oaicite:22]{index=22}\n if (!r.ok) {\n throw new Error(`Vestaboard post failed: ${r.status} ${await r.text()}`);\n }\n}\n\n// -------------------- State & Utilities --------------------\n\nasync function loadState(): Promise {\n const s = (await blob.getJSON(STATE_KEY)) as State | undefined; // returns undefined if missing :contentReference[oaicite:23]{index=23}\n if (\n s?.version === 1 && s.processedCalls && s.quotes &&\n typeof s.nextIndex === \"number\"\n ) {\n return s;\n }\n return { version: 1, processedCalls: {}, quotes: [], nextIndex: 0 };\n}\n\nasync function saveState(state: State) {\n await blob.setJSON(STATE_KEY, state); // :contentReference[oaicite:24]{index=24}\n}\n\nfunction wrapToWidth(s: string, width: number, maxLines: number) {\n const words = s.replace(/[{}]/g, \"()\") // avoid colliding with VBML char codes\n .split(/\\s+/);\n const lines: string[] = [];\n let cur = \"\";\n for (const w of words) {\n if ((cur ? cur.length + 1 : 0) + w.length <= width) {\n cur = cur ? `${cur} ${w}` : w;\n } else {\n lines.push(cur);\n cur = w;\n if (lines.length >= maxLines - 1) break;\n }\n }\n if (lines.length < maxLines && cur) lines.push(cur);\n return lines.join(\"\\n\");\n}\n\nfunction b64(s: string) {\n return (typeof btoa !== \"undefined\")\n ? btoa(s)\n : Buffer.from(s, \"utf-8\").toString(\"base64\");\n}\n\nasync function sha256Hex(s: string) {\n const data = new TextEncoder().encode(s);\n const hash = await crypto.subtle.digest(\"SHA-256\", data);\n return [...new Uint8Array(hash)].map((b) => b.toString(16).padStart(2, \"0\"))\n .join(\"\");\n}\n\nfunction assertEnv() {\n if (\n !GONG_BASIC_TOKEN &&\n !(Deno.env.get(\"GONG_ACCESS_KEY\") && Deno.env.get(\"GONG_ACCESS_KEY_SECRET\"))\n ) {\n throw new Error(\n \"Set GONG_BASIC_TOKEN or GONG_ACCESS_KEY/GONG_ACCESS_KEY_SECRET.\",\n );\n }\n if (!OPENAI_API_KEY) throw new Error(\"Set OPENAI_API_KEY.\");\n if (!VESTABOARD_RW_KEY) throw new Error(\"Set VESTABOARD_RW_KEY.\");\n}\n\nasync function gongFetch(path: string, init: RequestInit) {\n const headers: Record = {\n \"Authorization\": `Basic ${GONG_BASIC_TOKEN}`,\n \"Content-Type\": \"application/json\",\n \"Accept\": \"application/json\",\n };\n\n let tries = 0;\n const maxTries = 5;\n\n // simple retry w/ Retry-After + exp backoff (429, 5xx) :contentReference[oaicite:25]{index=25}\n while (true) {\n const r = await fetch(`${GONG_BASE_URL}${path}`, { ...init, headers });\n if (r.status === 429 || (r.status >= 500 && r.status <= 599)) {\n tries++;\n if (tries >= maxTries) return r; // let caller handle\n const ra = r.headers.get(\"Retry-After\");\n const wait = ra\n ? parseInt(ra, 10) * 1000\n : Math.min(30000, 500 * 2 ** tries);\n await new Promise((res) => setTimeout(res, isFinite(wait) ? wait : 3000));\n continue;\n }\n return r;\n }\n}","deleted","label",[98],"permalink","https://www.val.town/x/wade/vestaboard/code/gong.tsx","extension","actionData","errors"]