[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_152":153,"_154":155},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_18":19,"_17":-7,"_115":-5,"_20":116,"_22":117,"_118":119,"_120":121,"_25":122,"_24":-5,"_123":-5,"_124":-5,"_125":53,"_126":127,"_128":44,"_129":-5,"_130":-5,"_131":132},"routes/_app.x.$handle.$name.branch.$branch.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":-7,"_25":26,"_27":-5,"_28":-5,"_29":-5,"_30":-5,"_31":-5},"handle","rchx","name","viewer-queue","branchName","main","version","path","","project",{"_33":61,"_13":14,"_45":62,"_63":-5,"_64":53,"_65":66,"_67":66,"_68":69,"_70":-5,"_71":72,"_73":-5,"_74":53,"_75":-5,"_76":-5,"_77":78,"_79":80,"_81":-5,"_82":-5,"_83":-5,"_84":-5,"_85":86,"_87":86,"_88":89,"_90":89,"_91":89,"_92":86,"_93":86,"_94":95,"_96":97,"_98":99,"_100":53},"tree",[56],"file","contents",[32],"upstream","pull","ahead","behind","envVars",{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":46,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_18":55},"id","b83d3179-e5ed-41c8-9ccf-fa6a2fb88d58","main.ts","fileId","53e0b1a0-7d72-11f1-94c5-1607ee4eb77e","parentId","branchId","44cf6e27-1e14-456f-9a34-053a842b8395","branchVersion",3,"latest",true,"createdAt",["D",1783806799406],2,"fileType","http","content","// ============================================================\n// PLAY WITH VIEWERS — multi-platform viewer queue\n// Works with Twitch + YouTube + Kick via your existing chat\n// bots (Botrix / Nightbot / StreamElements / KickBot).\n//\n// Dashboard: /\n// OBS overlay: /overlay\n// ============================================================\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\n\n// ------------------- EDIT THESE -------------------\n// Secret for mod commands (!next, !open...). Set MOD_KEY in the val's\n// Environment Variables (left sidebar) — never hardcode it in public code.\nconst MOD_KEY = Deno.env.get(\"MOD_KEY\") || \"\";\nconst TITLE = \"Play with the Streamer\"; // shown on the overlay\nconst JOIN_HINT = \"Type !join in chat\"; // shown on the overlay\nconst MAX_QUEUE = 100; // max people in queue\nconst OVERLAY_SHOW = 10; // rows visible on overlay\n// ---------------------------------------------------\n\nconst DEFAULT_STATE = { open: true, queue: [], playing: [], updated: 0 };\n\nasync function loadState() {\n await sqlite.execute(\n `CREATE TABLE IF NOT EXISTS pwv_state (id INTEGER PRIMARY KEY CHECK (id=1), data TEXT)`,\n );\n const r = await sqlite.execute({\n sql: `SELECT data FROM pwv_state WHERE id = 1`,\n args: [],\n });\n if (!r.rows || r.rows.length === 0) return { ...DEFAULT_STATE };\n const row = r.rows[0];\n const raw = row.data ?? row[0];\n try {\n return { ...DEFAULT_STATE, ...JSON.parse(String(raw)) };\n } catch {\n return { ...DEFAULT_STATE };\n }\n}\n\nasync function saveState(s) {\n s.updated = Date.now();\n await sqlite.execute({\n sql: `INSERT INTO pwv_state (id, data) VALUES (1, ?)\n ON CONFLICT(id) DO UPDATE SET data = excluded.data`,\n args: [JSON.stringify(s)],\n });\n}\n\nconst norm = (u) => String(u || \"\").trim().replace(/^@/, \"\").toLowerCase();\nconst text = (msg) =>\n new Response(msg, {\n headers: { \"content-type\": \"text/plain; charset=utf-8\" },\n });\nconst html = (body) =>\n new Response(body, {\n headers: { \"content-type\": \"text/html; charset=utf-8\" },\n });\n\nconst PLATFORM_ICONS = { twitch: \"🟣\", youtube: \"🔴\", kick: \"🟢\" };\nconst pIcon = (p) => PLATFORM_ICONS[p] || \"\";\n\nexport default async function (req) {\n const url = new URL(req.url);\n const path = url.pathname.replace(/\\/+$/, \"\").toLowerCase() || \"/\";\n const q = url.searchParams;\n\n // --- identify caller ---\n const nb = new URLSearchParams(req.headers.get(\"nightbot-user\") || \"\");\n const user = q.get(\"user\") || nb.get(\"displayName\") || \"\";\n const id = norm(user);\n const display = String(user || \"\").trim().replace(/^@/, \"\");\n const platform = (q.get(\"platform\") || nb.get(\"provider\") || \"\")\n .toLowerCase();\n const nbLevel = (nb.get(\"userLevel\") || \"\").toLowerCase();\n const isMod = (MOD_KEY && q.get(\"key\") === MOD_KEY) ||\n [\"owner\", \"moderator\"].includes(nbLevel);\n\n // --- pages & JSON (no state mutation) ---\n if (path === \"/\" || path === \"/dashboard\") {\n return html(dashboardPage(url.origin));\n }\n if (path === \"/overlay\") return html(overlayPage());\n if (path === \"/state\") {\n const s = await loadState();\n return new Response(\n JSON.stringify({\n open: s.open,\n playing: s.playing,\n playingNames: s.playingNames || [],\n queue: s.queue.map((e) => ({ name: e.d, platform: e.p })),\n updated: s.updated,\n }),\n {\n headers: {\n \"content-type\": \"application/json\",\n \"cache-control\": \"no-store\",\n },\n },\n );\n }\n\n const s = await loadState();\n const posOf = (i) => s.queue.findIndex((e) => e.n === i);\n\n // ---------------- viewer commands ----------------\n if (path === \"/join\") {\n if (!id) return text(\"Missing user.\");\n if (!s.open) return text(`@${display} the queue is closed right now.`);\n const p = posOf(id);\n if (p !== -1) {\n return text(\n `@${display} you're already in the queue at position ${p + 1}.`,\n );\n }\n if (s.queue.length >= MAX_QUEUE) {\n return text(`@${display} the queue is full (max ${MAX_QUEUE}).`);\n }\n s.queue.push({ n: id, d: display, p: platform, t: Date.now() });\n await saveState(s);\n return text(\n `@${display} you joined the queue at position ${s.queue.length}. ✅`,\n );\n }\n\n if (path === \"/leave\") {\n if (!id) return text(\"Missing user.\");\n const p = posOf(id);\n if (p === -1) return text(`@${display} you're not in the queue.`);\n s.queue.splice(p, 1);\n await saveState(s);\n return text(`@${display} you left the queue. 👋`);\n }\n\n if (path === \"/pos\" || path === \"/position\") {\n if (!id) return text(\"Missing user.\");\n if (s.playing.includes(id)) {\n return text(`@${display} it's your turn right now! 🎮`);\n }\n const p = posOf(id);\n if (p === -1) {\n return text(`@${display} you're not in the queue. Type !join to join.`);\n }\n return text(\n `@${display} you're #${p + 1} of ${s.queue.length} in the queue.`,\n );\n }\n\n if (path === \"/list\" || path === \"/queue\") {\n if (s.queue.length === 0) {\n return text(\n s.open\n ? \"The queue is empty — type !join to be first! ✨\"\n : \"The queue is empty and closed.\",\n );\n }\n let out = `Queue (${s.queue.length})${s.open ? \"\" : \" [CLOSED]\"}: `;\n let shown = 0;\n for (let i = 0; i < s.queue.length; i++) {\n const piece = `${i + 1}. ${s.queue[i].d}${\n i < s.queue.length - 1 ? \" • \" : \"\"\n }`;\n if (out.length + piece.length > 360) break;\n out += piece;\n shown++;\n }\n if (shown < s.queue.length) out += `… +${s.queue.length - shown} more`;\n return text(out);\n }\n\n // ---------------- mod commands ----------------\n const MOD_PATHS = [\n \"/next\",\n \"/open\",\n \"/close\",\n \"/clear\",\n \"/random\",\n \"/shuffle\",\n \"/remove\",\n ];\n if (MOD_PATHS.includes(path)) {\n if (!isMod) return text(\"⚠️ Mods only.\");\n\n if (path === \"/next\") {\n const n = Math.max(1, Math.min(10, parseInt(q.get(\"n\") || \"1\", 10) || 1));\n if (s.queue.length === 0) {\n return text(\"Queue is empty — nobody to call up.\");\n }\n const up = s.queue.splice(0, n);\n s.playing = up.map((e) => e.n);\n s.playingNames = up.map((e) => e.d);\n await saveState(s);\n return text(\n `🎮 It's your turn: ${up.map((e) => \"@\" + e.d).join(\" \")} — get in!`,\n );\n }\n if (path === \"/open\") {\n s.open = true;\n await saveState(s);\n return text(\"✅ Queue is now OPEN — type !join to play!\");\n }\n if (path === \"/close\") {\n s.open = false;\n await saveState(s);\n return text(\"⛔ Queue is now CLOSED. No new joins.\");\n }\n if (path === \"/clear\") {\n s.queue = [];\n s.playing = [];\n s.playingNames = [];\n await saveState(s);\n return text(\"🧹 Queue cleared.\");\n }\n if (path === \"/random\" || path === \"/shuffle\") {\n for (let i = s.queue.length - 1; i > 0; i--) {\n const j = Math.floor(Math.random() * (i + 1));\n [s.queue[i], s.queue[j]] = [s.queue[j], s.queue[i]];\n }\n await saveState(s);\n return text(\"🔀 Queue shuffled!\");\n }\n if (path === \"/remove\") {\n if (!id) return text(\"Missing user.\");\n const p = posOf(id);\n if (p === -1) return text(`@${display} is not in the queue.`);\n s.queue.splice(p, 1);\n await saveState(s);\n return text(`@${display} was removed from the queue.`);\n }\n }\n\n return text(\n \"Viewer Queue is running. Endpoints: /join /leave /pos /list (viewers) — /next /open /close /clear /random /remove (mods, need ?key=) — /overlay /state and / (dashboard).\",\n );\n}\n\n// ================= OBS OVERLAY =================\nfunction overlayPage() {\n return `\n

OPEN\n

${TITLE}

${\n JOIN_HINT.replace(/!(\\w+)/, \"!$1\")\n }

\n `;\n}\n\n// ================= DASHBOARD =================\nfunction dashboardPage(origin) {\n return `Viewer Queue — Dashboard\n \n

🎮 Viewer Queue OPEN

Dashboard — actions need your mod key

\n \n \n \n \n \n

\n Links:
\n OBS overlay (Browser Source, 360×620): ${origin}/overlay
\n This dashboard: ${origin}/
\n Bot endpoints: ${origin}/join?user=... — see the setup guide for\n Botrix / Nightbot / StreamElements / KickBot command templates.\n

\n `;\n}","deleted",false,"label",[35],{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":57,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_58":59,"_18":60},["D",1783806799406],"children",[],[35],"08bfbab6-9f3b-453f-8b35-087b6fd7e6b4",["D",1783806541192],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Twitch/YouTube/Kick viewer queue with OBS overlay","imageUrl","userId","87c78a14-69cb-4067-aad5-3f139f00c0a2","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019f5320-f168-75ce-a5c8-a7f64595a6d0","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_114":19},"org",{"_11":12,"_109":19,"_110":19,"_71":72,"_111":112,"_113":53},"branch",{"_17":42,"_13":16,"_33":40,"_101":61,"_102":-5,"_103":-5,"_104":-5,"_105":-5,"_106":-5,"_107":14,"_108":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","avatar","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_33":61,"_13":14,"_45":148,"_63":-5,"_64":53,"_65":66,"_67":66,"_68":69,"_70":-5,"_71":72,"_73":-5,"_74":53,"_75":-5,"_76":-5,"_77":78,"_79":80,"_81":-5,"_82":-5,"_83":-5,"_84":-5,"_85":86,"_87":86,"_88":89,"_90":89,"_91":89,"_92":86,"_93":86,"_94":149,"_96":150,"_98":151,"_100":53},[145],"files",[145],"counts",{"_135":78,"_136":137,"_138":78,"_31":139,"_140":141},[133],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":46,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_18":134},[35],"pulls","branches",1,"forks",{"_142":137,"_144":78},"connections",{"_142":78,"_143":78},"count","unfilledCount","emptyCount",{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":57,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_58":146,"_18":147},[],[35],["D",1783806541192],{"_11":12,"_114":19},{"_11":12,"_109":19,"_110":19,"_71":72,"_111":112,"_113":53},{"_17":42,"_13":16,"_33":40,"_101":61,"_102":-5,"_103":-5,"_104":-5,"_105":-5,"_106":-5,"_107":14,"_108":12},"ctx",{"_94":-5,"_130":185,"_186":187,"_188":189,"_190":53,"_191":53,"_192":53,"_193":44,"_194":-5,"_195":-7,"_196":-7,"_197":78,"_198":53,"_199":53,"_200":-5,"_201":53,"_202":53,"_203":53,"_204":-5},"ENV",{"_156":157,"_158":159,"_160":16,"_161":162,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184},"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"]

Code