[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_107":108,"_109":110},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","StonedSheamus","name","The-Wandering-Clerik","path","helix.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":58,"_59":32,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/StonedSheamus/The-Wandering-Clerik/code/helix.ts","extension","id","a19ccef9-1eec-4de8-99db-22eddcd6f514","fileId","ef32123e-aa1d-11f1-940f-1607ee4eb77e","parentId","branchId","14611edd-64e7-4a83-ae11-563983a50244","branchVersion",62,"latest",true,"createdAt",["D",1789172971701],"version",6,"fileType","script","content","// =============================================================================\n// helix.ts — small Helix API client. This bot uses the modern chat stack\n// (EventSub for reading, Helix REST for sending) instead of legacy IRC.\n// =============================================================================\n\nconst CLIENT_ID = Deno.env.get(\"TWITCH_CLIENT_ID\") || \"\";\nconst CLIENT_SECRET = Deno.env.get(\"TWITCH_CLIENT_SECRET\") || \"\";\nconst REFRESH_TOKEN = Deno.env.get(\"TWITCH_BOT_REFRESH_TOKEN\") || \"\";\nlet currentAccessToken = Deno.env.get(\"TWITCH_BOT_ACCESS_TOKEN\") || \"\";\n\nif (!CLIENT_ID) {\n console.error(\"Missing TWITCH_CLIENT_ID env var.\");\n}\nif (!currentAccessToken && !REFRESH_TOKEN) {\n console.error(\n \"Missing both TWITCH_BOT_ACCESS_TOKEN and TWITCH_BOT_REFRESH_TOKEN — the bot has no way to authenticate.\",\n );\n}\n\nconst BASE = \"https://api.twitch.tv/helix\";\n\nfunction authHeaders(): HeadersInit {\n return {\n \"Client-Id\": CLIENT_ID,\n \"Authorization\": `Bearer ${currentAccessToken}`,\n \"Content-Type\": \"application/json\",\n };\n}\n\n// Separate from the bot's user-token auth above: sendChatMessage needs an\n// App Access Token (client-credentials grant) so it can pass\n// for_source_only during Shared Chat — see sendChatMessage below. Cached at\n// module scope so it's reused across calls instead of re-fetched every send.\nlet appAccessToken = \"\";\nlet appAccessTokenExpiresAt = 0;\n\nasync function getAppAccessToken(): Promise {\n if (appAccessToken && Date.now() < appAccessTokenExpiresAt - 60_000) {\n return appAccessToken;\n }\n const params = new URLSearchParams({\n client_id: CLIENT_ID,\n client_secret: CLIENT_SECRET,\n grant_type: \"client_credentials\",\n });\n const res = await fetch(\n `https://id.twitch.tv/oauth2/token?${params.toString()}`,\n { method: \"POST\" },\n );\n if (!res.ok) {\n console.error(\"getAppAccessToken failed:\", res.status, await res.text());\n throw new Error(\"Could not obtain app access token\");\n }\n const json = await res.json();\n appAccessToken = json.access_token;\n appAccessTokenExpiresAt = Date.now() + json.expires_in * 1000;\n return appAccessToken;\n}\n\n// Twitch user access tokens expire (typically ~4 hours) but refresh\n// tokens don't, so this can be called as often as needed. Called\n// proactively at startup and periodically during long runs (see\n// twitch.ts), and reactively whenever a call comes back 401 — matching\n// Twitch's own recommended pattern (see helixFetch below).\nexport async function refreshAccessToken(): Promise {\n if (!CLIENT_ID || !CLIENT_SECRET || !REFRESH_TOKEN) {\n console.error(\n \"Cannot refresh access token — missing TWITCH_CLIENT_ID, TWITCH_CLIENT_SECRET, or TWITCH_BOT_REFRESH_TOKEN.\",\n );\n return false;\n }\n const params = new URLSearchParams({\n client_id: CLIENT_ID,\n client_secret: CLIENT_SECRET,\n grant_type: \"refresh_token\",\n refresh_token: REFRESH_TOKEN,\n });\n const res = await fetch(\n `https://id.twitch.tv/oauth2/token?${params.toString()}`,\n { method: \"POST\" },\n );\n if (!res.ok) {\n console.error(\"refreshAccessToken failed:\", res.status, await res.text());\n return false;\n }\n const json = await res.json();\n currentAccessToken = json.access_token;\n console.log(\"Refreshed the bot's Twitch access token.\");\n return true;\n}\n\n// Wraps fetch with Twitch's recommended pattern: on a 401, refresh the\n// token once and retry the request before giving up.\nasync function helixFetch(\n url: string,\n init: RequestInit = {},\n): Promise {\n let res = await fetch(url, {\n ...init,\n headers: { ...authHeaders(), ...(init.headers || {}) },\n });\n if (res.status === 401) {\n const refreshed = await refreshAccessToken();\n if (refreshed) {\n res = await fetch(url, {\n ...init,\n headers: { ...authHeaders(), ...(init.headers || {}) },\n });\n }\n }\n return res;\n}\n\nexport interface HelixUser {\n id: string;\n login: string;\n display_name: string;\n}\n\nconst userCache = new Map();\n\nexport async function getUser(login: string): Promise {\n const key = login.toLowerCase();\n if (userCache.has(key)) return userCache.get(key)!;\n const res = await helixFetch(\n `${BASE}/users?login=${encodeURIComponent(key)}`,\n );\n if (!res.ok) {\n console.error(\"getUser failed:\", res.status, await res.text());\n return null;\n }\n const json = await res.json();\n const user = json.data?.[0] as HelixUser | undefined;\n if (!user) return null;\n userCache.set(key, user);\n return user;\n}\n\n// Subscribes the bot (user_id) to chat messages in a given channel\n// (broadcaster_user_id) over the already-open EventSub WebSocket session.\n// This call fails with 403 if that broadcaster hasn't granted this\n// Client ID the channel:bot permission (see setup steps).\nexport async function createChatMessageSubscription(\n broadcasterId: string,\n botId: string,\n sessionId: string,\n): Promise {\n const res = await helixFetch(`${BASE}/eventsub/subscriptions`, {\n method: \"POST\",\n body: JSON.stringify({\n type: \"channel.chat.message\",\n version: \"1\",\n condition: { broadcaster_user_id: broadcasterId, user_id: botId },\n transport: { method: \"websocket\", session_id: sessionId },\n }),\n });\n if (!res.ok) {\n console.error(\n \"createChatMessageSubscription failed:\",\n res.status,\n await res.text(),\n );\n return false;\n }\n return true;\n}\n\nexport async function sendChatMessage(\n broadcasterId: string,\n senderId: string,\n text: string,\n): Promise {\n const appToken = await getAppAccessToken();\n const res = await fetch(`${BASE}/chat/messages`, {\n method: \"POST\",\n headers: {\n \"Client-Id\": CLIENT_ID,\n \"Authorization\": `Bearer ${appToken}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({\n broadcaster_id: broadcasterId,\n sender_id: senderId,\n message: text,\n for_source_only: true,\n }),\n });\n if (!res.ok) {\n console.error(\n \"sendChatMessage HTTP failure:\",\n res.status,\n await res.text(),\n );\n return;\n }\n const json = await res.json();\n const result = json.data?.[0];\n // Twitch can return 200 OK and still silently drop the message — e.g.\n // AutoMod held it, or a chat mode (slow/unique/followers-only) blocked\n // a non-moderator bot. Surface that instead of failing silently.\n if (result && result.is_sent === false) {\n console.error(\n \"sendChatMessage was NOT delivered — drop_reason:\",\n result.drop_reason?.message || \"(none given)\",\n );\n }\n}\n\n// Checks which of the given channels are currently live, in a single\n// batched call (Twitch's Get Streams endpoint accepts multiple\n// user_login params at once). Used to keep the Clerk's unprompted,\n// periodic chat lines quiet in channels that aren't streaming.\nexport async function getLiveChannels(logins: string[]): Promise> {\n if (!logins.length) return new Set();\n const params = logins.map((l) => `user_login=${encodeURIComponent(l)}`).join(\n \"&\",\n );\n const res = await helixFetch(`${BASE}/streams?${params}`);\n if (!res.ok) {\n console.error(\"getLiveChannels failed:\", res.status, await res.text());\n return new Set();\n }\n const json = await res.json();\n const live = new Set();\n for (const stream of json.data || []) {\n if (stream.user_login) live.add(String(stream.user_login).toLowerCase());\n }\n return live;\n}\n\n// -----------------------------------------------------------------------\n// One-click broadcaster onboarding (Authorization Code flow). A broadcaster\n// clicking the /onboard link authorizes just the channel:bot scope; we\n// exchange the resulting code for a short-lived token, use it only to\n// identify who authorized (their user id/login), then discard it — the\n// bot keeps running on its own long-lived TWITCH_BOT_ACCESS_TOKEN.\n// -----------------------------------------------------------------------\nexport async function exchangeCodeForToken(\n code: string,\n redirectUri: string,\n): Promise<{ access_token: string } | null> {\n const params = new URLSearchParams({\n client_id: CLIENT_ID,\n client_secret: CLIENT_SECRET,\n code,\n grant_type: \"authorization_code\",\n redirect_uri: redirectUri,\n });\n const res = await fetch(\n `https://id.twitch.tv/oauth2/token?${params.toString()}`,\n { method: \"POST\" },\n );\n if (!res.ok) {\n console.error(\"exchangeCodeForToken failed:\", res.status, await res.text());\n return null;\n }\n return await res.json();\n}\n\nexport async function getAuthorizingUser(\n accessToken: string,\n): Promise {\n const res = await fetch(`${BASE}/users`, {\n headers: {\n \"Client-Id\": CLIENT_ID,\n \"Authorization\": `Bearer ${accessToken}`,\n },\n });\n if (!res.ok) {\n console.error(\"getAuthorizingUser failed:\", res.status, await res.text());\n return null;\n }\n const json = await res.json();\n return (json.data?.[0] as HelixUser) ?? null;\n}","deleted",false,"label",[14],"18a739db-79f6-405b-989c-5ec0b798f374",["D",1788715747973],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","userId","cc37ba10-6e6d-4af6-a801-9955c92d23c4","pinnedFileId","77260020-aa18-11f1-9dac-1607ee4eb77e","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a04ba1-c79f-7319-b4f2-7c4f3772837b","tursoName","18a739db79f6405b989c5ec0b798f374","tursoHostname","18a739db79f6405b989c5ec0b798f374-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789500689328],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_106":102},"org",{"_9":10,"_99":100,"_101":102,"_55":56,"_103":104,"_105":42},"branch",{"_35":89,"_11":90,"_22":28,"_91":45,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":12,"_98":10},"isOwned",65,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Shea Stolp","avatar","https://lh3.googleusercontent.com/a/ACg8ocIWmQgR3gyoMMicg2zCAoN1c7i36qX5mf9gRIdIXm8F2mo-ig=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_82":-5,"_140":141,"_142":143,"_144":145,"_146":42,"_147":42,"_148":42,"_149":32,"_150":-5,"_151":-7,"_152":-7,"_153":63,"_154":42,"_155":42,"_156":-5,"_157":42,"_158":42,"_159":42,"_160":-5},"ENV",{"_111":112,"_113":114,"_115":90,"_116":117,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133,"_134":135,"_136":137,"_138":139},"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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]