[{"_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",{"_94":93,"_32":45,"_102":84,"_27":96,"_13":14,"_103":-5,"_11":104,"_105":106,"_107":108,"_109":110,"_111":112,"_20":-5,"_113":-5,"_114":-5,"_115":25,"_116":117,"_118":119,"_120":-5,"_121":-5,"_122":123},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":25},"version",3,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":37,"_35":36,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","53e0b1a0-7d72-11f1-94c5-1607ee4eb77e","name","fileType","script","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}","http","createdAt",["D",1783806799406],"branchVersion","branchId","44cf6e27-1e14-456f-9a34-053a842b8395","id","08bfbab6-9f3b-453f-8b35-087b6fd7e6b4","viewer-queue",["D",1783806541192],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Twitch/YouTube/Kick viewer queue with OBS overlay","imageUrl","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",{"_94":93,"_101":96},"org",{"_94":93,"_95":96,"_97":96,"_18":55,"_98":99,"_100":25},"branch",{"_13":14,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","rchx","handle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_43":44,"_32":45,"_38":148,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":149,"_79":150,"_81":151,"_83":25},"tree",[143],"files",[143],"counts",{"_132":61,"_133":134,"_135":61,"_136":137,"_138":139},"contents",[124],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":125,"_32":28,"_30":31,"_126":-5,"_41":42,"_40":14,"_127":119,"_38":128,"_13":129,"_33":37,"_35":36,"_24":25,"_130":-5,"_27":131},"b83d3179-e5ed-41c8-9ccf-fa6a2fb88d58","parentId","latest",["D",1783806799406],2,"label",[28],"pulls","branches",1,"forks","envVars",{"_140":134,"_142":61},"connections",{"_140":61,"_141":61},"count","unfilledCount","emptyCount",{"_43":125,"_32":28,"_30":31,"_126":-5,"_41":42,"_40":14,"_127":119,"_38":144,"_13":129,"_33":37,"_35":36,"_24":25,"_130":-5,"_145":146,"_27":147},["D",1783806799406],"children",[],[28],["D",1783806541192],{"_94":93,"_101":96},{"_94":93,"_95":96,"_97":96,"_18":55,"_98":99,"_100":25},{"_13":14,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"ctx",{"_77":-5,"_121":185,"_186":187,"_188":189,"_190":25,"_191":25,"_192":25,"_193":119,"_194":-5,"_195":-7,"_196":-7,"_197":61,"_198":25,"_199":25,"_200":-5,"_201":25,"_202":25,"_203":25,"_204":-5},"ENV",{"_156":157,"_158":159,"_160":84,"_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"]

Diff · v3