\n \n

🤖 Holbie

Assistance requests & live support chat.

\n\n \n

\n \n \n

\n\n \n

\n \n

\n\n \n

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

\n \n

\n \n Chatting as \n \n \n \n Connecting…\n \n

\n\n \n

Loading history…

\n\n \n

\n View source\n

\n\n \n\n\n","label",[18],"pulls","branches",1,"forks","envVars",{"_180":26,"_182":26},"connections",{"_180":26,"_181":26},"count","unfilledCount","emptyCount",{"_34":200,"_13":201,"_64":202,"_44":-5,"_36":37,"_164":203,"_165":158,"_38":204,"_40":174,"_66":205,"_168":206,"_67":24,"_170":-5,"_187":207,"_17":208},{"_34":190,"_13":191,"_64":192,"_44":-5,"_36":37,"_164":193,"_165":158,"_38":194,"_40":195,"_66":196,"_168":197,"_67":24,"_170":-5,"_187":198,"_17":199},{"_34":163,"_13":18,"_64":65,"_44":-5,"_36":37,"_164":82,"_165":158,"_38":186,"_40":167,"_66":21,"_168":169,"_67":24,"_170":-5,"_187":188,"_17":189},["D",1779553255368],"children",[],[18],"db00732c-56c2-11f1-b74d-ee650bb23af1","main.ts","e4103954-56c0-11f1-a1d6-ee650bb23af1",10,["D",1779553032291],5,"http","import {\n getAllRequests,\n getChatHistory,\n insertChatMessage,\n insertRequest,\n} from \"./db.ts\";\nimport { parseVal, serveFile } from \"https://esm.town/v/std/utils/index.ts\";\n\n// BroadcastChannel lets multiple isolates share real-time messages\nconst channel = new BroadcastChannel(\"holbie-chat\");\n\n// Track SSE clients so we can push to them\nconst sseClients = new Set();\n\n// When a message arrives on the BroadcastChannel, push to all SSE clients\nchannel.onmessage = (event: MessageEvent) => {\n const payload = `event: chat\\ndata: ${JSON.stringify(event.data)}\\n\\n`;\n for (const controller of sseClients) {\n try {\n controller.enqueue(new TextEncoder().encode(payload));\n } catch {\n sseClients.delete(controller);\n }\n }\n};\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n\n // --- API: Submit a request ---\n if (req.method === \"POST\" && url.pathname === \"/api/submit\") {\n let body: unknown;\n try {\n body = await req.json();\n } catch {\n return Response.json(\n { error: \"Invalid JSON in request body.\" },\n { status: 400 },\n );\n }\n\n // Validate: message field must be a non-empty string\n const raw = (body as Record)?.message;\n if (typeof raw !== \"string\" || raw.trim().length === 0) {\n return Response.json(\n { error: \"Message cannot be empty. Please enter a valid assistance request.\" },\n { status: 400 },\n );\n }\n\n try {\n const saved = await insertRequest(raw);\n return Response.json({ success: true, request: saved });\n } catch (err: unknown) {\n const msg = err instanceof Error ? err.message : \"Failed to save request.\";\n return Response.json({ error: msg }, { status: 400 });\n }\n }\n\n // --- API: Get all requests ---\n if (req.method === \"GET\" && url.pathname === \"/api/requests\") {\n return Response.json(await getAllRequests());\n }\n\n // --- API: Send a chat message ---\n if (req.method === \"POST\" && url.pathname === \"/api/chat/send\") {\n try {\n const body = await req.json();\n const username = typeof body.username === \"string\"\n ? body.username.trim()\n : \"\";\n const message = typeof body.message === \"string\"\n ? body.message.trim()\n : \"\";\n\n if (!username) {\n return Response.json({ error: \"Username is required.\" }, {\n status: 400,\n });\n }\n if (!message) {\n return Response.json({ error: \"Message cannot be empty.\" }, {\n status: 400,\n });\n }\n\n // Save to SQLite\n const saved = await insertChatMessage(username, message);\n\n // Broadcast to all connected SSE clients via BroadcastChannel\n channel.postMessage(saved);\n\n // Also push directly to local SSE clients (same isolate)\n const payload = `event: chat\\ndata: ${JSON.stringify(saved)}\\n\\n`;\n for (const controller of sseClients) {\n try {\n controller.enqueue(new TextEncoder().encode(payload));\n } catch {\n sseClients.delete(controller);\n }\n }\n\n return Response.json({ success: true });\n } catch {\n return Response.json({ error: \"Invalid request body.\" }, { status: 400 });\n }\n }\n\n // --- API: Get chat history ---\n if (req.method === \"GET\" && url.pathname === \"/api/chat/history\") {\n return Response.json(await getChatHistory());\n }\n\n // --- API: SSE stream for real-time chat ---\n if (req.method === \"GET\" && url.pathname === \"/api/chat/stream\") {\n const body = new ReadableStream({\n start(controller) {\n sseClients.add(controller);\n // Send a keep-alive comment immediately\n controller.enqueue(new TextEncoder().encode(\": connected\\n\\n\"));\n },\n cancel(controller) {\n sseClients.delete(controller);\n },\n });\n\n return new Response(body, {\n headers: {\n \"Content-Type\": \"text/event-stream\",\n \"Cache-Control\": \"no-cache\",\n \"Connection\": \"keep-alive\",\n },\n });\n }\n\n // --- View source ---\n if (url.pathname === \"/source\") {\n return new Response(null, {\n status: 302,\n headers: { Location: parseVal().links.self.val },\n });\n }\n\n // --- Serve the HTML UI ---\n return serveFile(\"./ui.html\", import.meta.url);\n}\n",[],[191],"b6f0afc4-56c2-11f1-aeb7-ee650bb23af1","db.ts","227a7848-56c2-11f1-b8a2-ee650bb23af1",7,["D",1779552971790],"script","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n// Initialize tables (idempotent — safe to run on every cold start)\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS requests (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n message TEXT NOT NULL,\n created_at TEXT NOT NULL DEFAULT (datetime('now'))\n )\n`);\n\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS chat_messages (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n username TEXT NOT NULL,\n message TEXT NOT NULL,\n created_at TEXT NOT NULL DEFAULT (datetime('now'))\n )\n`);\n\n/**\n * Validate and insert a new assistance request.\n * Returns the saved row (id, message, created_at).\n * Throws if the message is empty or whitespace-only.\n */\nexport async function insertRequest(message: string) {\n const trimmed = message?.trim() ?? \"\";\n if (trimmed.length === 0) {\n throw new Error(\"Message cannot be empty. Please enter a valid assistance request.\");\n }\n const result = await sqlite.execute({\n sql: \"INSERT INTO requests (message) VALUES (?) RETURNING id, message, created_at\",\n args: [trimmed],\n });\n return result.rows[0];\n}\n\n/** Return every request, newest first. */\nexport async function getAllRequests() {\n const result = await sqlite.execute(\n \"SELECT id, message, created_at FROM requests ORDER BY created_at DESC\",\n );\n return result.rows;\n}\n\nexport async function insertChatMessage(username: string, message: string) {\n const result = await sqlite.execute({\n sql: \"INSERT INTO chat_messages (username, message) VALUES (?, ?) RETURNING *\",\n args: [username, message],\n });\n return result.rows[0];\n}\n\nexport async function getChatHistory(limit = 50) {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM chat_messages ORDER BY created_at DESC LIMIT ?\",\n args: [limit],\n });\n return result.rows.reverse();\n}\n",[],[201],["D",1779552188489],["D",1789498239291],{"_11":12,"_140":70},{"_11":12,"_135":136,"_69":70,"_30":68,"_137":138,"_139":24},{"_40":82,"_13":16,"_34":37,"_127":90,"_128":-5,"_129":-5,"_130":-5,"_131":-5,"_132":-5,"_133":14,"_134":12},"ctx",{"_54":-5,"_160":247,"_248":249,"_250":251,"_252":24,"_253":24,"_254":24,"_255":158,"_256":-5,"_257":-7,"_258":-7,"_259":26,"_260":24,"_261":24,"_262":-5,"_263":24,"_264":24,"_265":24,"_266":-5},"ENV",{"_218":219,"_220":221,"_222":16,"_223":224,"_225":226,"_227":228,"_229":230,"_231":232,"_233":234,"_235":236,"_237":238,"_239":240,"_241":242,"_243":244,"_245":246},"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"]

🤖 Holbie

Recent Requests

History · ui.html