📋 Holbie

\n\n \n

\n \n \n

\n\n \n

\n \n

Saved Requests

Loading…

\n\n \n

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

Loading history…

\n \n

\n\n

\n view source\n

\n\n \n\n\n","label",[201],"c2dfa896-56c0-11f1-98c3-ee650bb23af1",["D",1779552132822],"import { insertRequest, getAllRequests, insertChatMessage, getChatHistory } from \"./db.ts\";\nimport { parseVal } from \"https://esm.town/v/std/utils/index.ts\";\n\nconst channel = new BroadcastChannel(\"holbie-chat\");\nconst sseClients = new Set();\n\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 try {\n const body = await req.json();\n const message = typeof body.message === \"string\" ? body.message.trim() : \"\";\n if (message.length === 0) {\n return Response.json(\n { error: \"Message cannot be empty. Please enter a valid request.\" },\n { status: 400 },\n );\n }\n await insertRequest(message);\n return Response.json({ success: true });\n } catch {\n return Response.json({ error: \"Invalid request body.\" }, { 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\" ? body.username.trim() : \"\";\n const message = typeof body.message === \"string\" ? body.message.trim() : \"\";\n\n if (!username) return Response.json({ error: \"Username is required.\" }, { status: 400 });\n if (!message) return Response.json({ error: \"Message cannot be empty.\" }, { status: 400 });\n\n const saved = await insertChatMessage(username, message);\n channel.postMessage(saved);\n\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 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 controller.enqueue(new TextEncoder().encode(\": connected\\n\\n\"));\n },\n cancel(controller) {\n sseClients.delete(controller);\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 // --- Serve HTML UI Directly ---\n const html = `\n \n \n \n \n \n Holbie App\n \n \n \n

\n \n

\n 📋 Holbie\n

\n\n

\n \n \n

\n\n

\n \n

\n \n\n

📑 Submitted Requests

\n\n

\n \n\n

\n \n

\n\n