🥣 Oatmeal Dashboard

\n\n

\n ✓ Successfully logged in as {{email}}\n

\n\n

🔑 Your API Token

This is your authentication token for API requests. Keep it secure!

\n \n

\n\n

📖 How to Use Your Token

Include this header in all API requests:

\n Authorization: Token {{api_token}}\n

\n\n

API Documentation:

\n GET /api/docs - View all available endpoints\n

\n\n

Account Information

Email: {{email}}

Name: {{full_name}}

Created: {{created_at}}

\n\n

🔧 Tools

🪝 View Webhook Logs - Monitor incoming webhook requests

\n\n \n\n \n\n`;\n\nconst LOGIN_HTML = `\n\n\n \n \n Oatmeal - Login\n \n \n\n\n

🥣 Oatmeal

\n \n \n

\n \n

\n\n`;\n\nconst WEBHOOKS_HTML = `\n\n\n \n \n Oatmeal - Webhooks\n \n \n\n\n

\n ← Back to Dashboard\n

\n\n

🪝 Webhook Logs

\n\n {{webhooks_html}}\n\n {{pagination_html}}\n\n`;\n\nconst ERROR_HTML = `\n\n\n \n \n Error\n \n\n\n

Error

\n Back\n\n`;\n\nfunction renderTemplate(template: string, data: Record): string {\n let result = template;\n for (const [key, value] of Object.entries(data)) {\n result = result.replaceAll(`{{${key}}}`, value);\n }\n return result;\n}\n\nexport function registerUIRoutes(app: Hono) {\n // Root endpoint - Dashboard or Login\n app.get(\"/\", async (c) => {\n const sessionToken = getCookie(c.req.header(\"Cookie\"), \"session\");\n const db = getDb();\n\n let user: Partial | null = null;\n\n if (sessionToken) {\n const result = await db.execute({\n sql: `SELECT id, email, first_name, last_name, api_token, created_at FROM users WHERE api_token = ? AND is_active = 1 LIMIT 1`,\n args: [sessionToken],\n });\n user = firstRow>(result);\n }\n\n if (user) {\n const baseUrl = `${c.req.url.split('/')[0]}//${c.req.url.split('/')[2]}`;\n\n const html = renderTemplate(DASHBOARD_HTML, {\n email: user.email!,\n api_token: user.api_token!,\n base_url: baseUrl,\n full_name: `${user.first_name || ''} ${user.last_name || ''}`.trim() || 'N/A',\n created_at: new Date(user.created_at!).toLocaleString(),\n });\n\n return c.html(html);\n }\n\n return c.html(LOGIN_HTML);\n });\n\n // Auth Routes\n app.post(\"/login\", async (c) => {\n const body = await c.req.parseBody();\n const email = body.email as string;\n const password = body.password as string;\n\n if (!email || !password) {\n return c.html(renderTemplate(ERROR_HTML, { message: \"Email and password required\" }), 400);\n }\n\n const db = getDb();\n const result = await db.execute({\n sql: `SELECT id, email, password_hash, api_token FROM users WHERE email = ? AND is_active = 1 LIMIT 1`,\n args: [email],\n });\n\n const user = firstRow>(result);\n\n if (!user || !user.password_hash) {\n return c.html(renderTemplate(ERROR_HTML, { message: \"Invalid email or password\" }), 401);\n }\n\n const isValid = await verifyPassword(password, user.password_hash);\n\n if (!isValid) {\n return c.html(renderTemplate(ERROR_HTML, { message: \"Invalid email or password\" }), 401);\n }\n\n // Set session cookie\n c.header(\"Set-Cookie\", `session=${user.api_token}; Path=/; HttpOnly; Max-Age=2592000; SameSite=Lax`);\n\n return c.redirect(\"/\");\n });\n\n app.post(\"/register\", async (c) => {\n const body = await c.req.parseBody();\n const email = body.email as string;\n const password = body.password as string;\n const firstName = body.first_name as string || null;\n const lastName = body.last_name as string || null;\n\n if (!email || !password) {\n return c.html(renderTemplate(ERROR_HTML, { message: \"Email and password required\" }), 400);\n }\n\n if (password.length < 6) {\n return c.html(renderTemplate(ERROR_HTML, { message: \"Password must be at least 6 characters\" }), 400);\n }\n\n const db = getDb();\n\n const existing = await db.execute({\n sql: `SELECT id FROM users WHERE email = ? LIMIT 1`,\n args: [email],\n });\n\n if (firstRow(existing)) {\n return c.html(renderTemplate(ERROR_HTML, { message: \"Email already registered\" }), 400);\n }\n\n const userId = crypto.randomUUID();\n const apiToken = crypto.randomUUID();\n const passwordHash = await hashPassword(password);\n const now = Date.now();\n\n await db.execute({\n sql: `INSERT INTO users (id, email, password_hash, first_name, last_name, api_token, created_at, updated_at, is_active)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, 1)`,\n args: [userId, email, passwordHash, firstName, lastName, apiToken, now, now],\n });\n\n // Set session cookie\n c.header(\"Set-Cookie\", `session=${apiToken}; Path=/; HttpOnly; Max-Age=2592000; SameSite=Lax`);\n\n return c.redirect(\"/\");\n });\n\n app.post(\"/logout\", (c) => {\n const response = c.redirect(\"/\");\n response.headers.set(\"Set-Cookie\", \"session=; Path=/; HttpOnly; Max-Age=0\");\n return response;\n });\n\n // Webhooks UI\n app.get(\"/webhooks\", async (c) => {\n const sessionToken = getCookie(c.req.header(\"Cookie\"), \"session\");\n if (!sessionToken) {\n return c.redirect(\"/\");\n }\n\n const db = getDb();\n const page = parseInt(c.req.query(\"page\") || \"1\");\n const limit = 50;\n const offset = (page - 1) * limit;\n\n const countResult = await db.execute({\n sql: `SELECT COUNT(*) as count FROM webhook_logs`,\n args: [],\n });\n const totalCount = countResult.rows[0]?.[0] as number || 0;\n const totalPages = Math.ceil(totalCount / limit);\n\n const result = await db.execute({\n sql: `SELECT * FROM webhook_logs ORDER BY created_at DESC LIMIT ? OFFSET ?`,\n args: [limit, offset],\n });\n\n const webhooks = parseRows(result);\n\n // Generate webhooks HTML\n let webhooksHtml = '';\n if (webhooks.length === 0) {\n webhooksHtml = '

No webhooks received yet

';\n } else {\n webhooksHtml = webhooks.map((wh: any) => {\n const headersHtml = wh.headers ? `\n

\n Headers:\n

${JSON.stringify(JSON.parse(wh.headers), null, 2)}

\n ` : '';\n\n const bodyHtml = wh.body ? `\n

\n Body:\n

${JSON.stringify(JSON.parse(wh.body), null, 2)}

\n ` : '';\n\n return `\n

\n ${wh.method}\n ${wh.path}\n

${new Date(wh.created_at).toLocaleString()}

\n \n

\n ${headersHtml}\n ${bodyHtml}\n

\n `;\n }).join('');\n }\n\n // Generate pagination HTML\n let paginationHtml = '';\n if (totalPages > 1) {\n const prevLink = page > 1 ? `← Previous` : '';\n const nextLink = page < totalPages ? `Next →` : '';\n\n paginationHtml = `\n

\n ${prevLink}\n Page ${page} of ${totalPages}\n ${nextLink}\n

\n `;\n }\n\n const html = renderTemplate(WEBHOOKS_HTML, {\n webhooks_html: webhooksHtml,\n pagination_html: paginationHtml,\n });\n\n return c.html(html);\n });\n\n // API Docs\n app.get(\"/api/docs\", (c) => {\n return c.json({\n status: \"ok\",\n service: \"oatmeal\",\n version: \"1.0.0\",\n platform: isLocal ? \"Local Deno\" : \"Val Town\",\n endpoints: {\n health: \"GET /health\",\n recordings: {\n list: \"GET /api/recordings\",\n update: \"POST /api/recordings/update\",\n upload: \"POST /recordings/upload\",\n sendBot: \"POST /recordings/send_bot\",\n refreshStatus: \"POST /recordings/:id/refresh_status\",\n createClip: \"POST /recordings/:id/create_clip\",\n },\n calendars: {\n preferences: \"GET/POST /api/calendars/preferences\",\n events: \"GET /api/calendars/events\",\n desktopEvents: \"GET /api/desktop-calendars/events\",\n updateEvent: \"POST /api/calendars/events/update\",\n syncStatus: \"POST /api/calendars/events/sync_status\",\n },\n users: {\n heartbeat: \"POST /api/heartbeat\",\n },\n webhooks: {\n recall: \"POST /webhooks/recall\",\n },\n },\n authentication: 'Authorization: Token header (required)',\n });\n });\n\n app.get(\"/health\", (c) => c.json({ status: \"healthy\" }));\n}\n",[],[246],{"_103":255,"_95":256,"_152":257,"_154":-5,"_155":137,"_156":258,"_157":158,"_105":259,"_100":32,"_161":205,"_163":260,"_165":22,"_166":-5,"_167":261,"_98":262},"12456bf4-c73e-11f0-b18e-42dde27851f2","utils.ts","12456cb2-c73e-11f0-b18e-42dde27851f2",142,["D",1763772985685],"/**\n * Utility Functions\n */\n\nexport async function hashPassword(password: string): Promise {\n const encoder = new TextEncoder();\n const data = encoder.encode(password);\n const hash = await crypto.subtle.digest(\"SHA-256\", data);\n return Array.from(new Uint8Array(hash))\n .map((b) => b.toString(16).padStart(2, \"0\"))\n .join(\"\");\n}\n\nexport async function verifyPassword(password: string, hash: string): Promise {\n const passwordHash = await hashPassword(password);\n return passwordHash === hash;\n}\n\nexport function getCookie(cookieHeader: string | null, name: string): string | null {\n if (!cookieHeader) return null;\n const cookies = cookieHeader.split(\";\").map((c) => c.trim());\n const cookie = cookies.find((c) => c.startsWith(`${name}=`));\n return cookie ? cookie.substring(name.length + 1) : null;\n}\n",[],[256],{"_103":264,"_95":265,"_152":266,"_154":-5,"_155":137,"_156":267,"_157":158,"_105":268,"_100":269,"_161":270,"_163":271,"_165":22,"_166":-5,"_167":272,"_98":273},"6d4071b2-c73d-11f0-b4b3-42dde27851f2","val.ts","bc2a0158-c724-11f0-9f1d-42dde27851f2",139,["D",1763772708825],54,"http","/**\n * Oatmeal - Meeting Recording Automation Platform\n *\n * Deploy to Val Town: Copy this file to a new HTTP Val\n * Run locally: deno run --allow-net --allow-read --allow-env --allow-write val.ts\n */\n\nimport { initializeSchema, ensureDefaultUser } from \"./database.ts\";\nimport { createApp } from \"./routes.ts\";\n\n// ============================================================================\n// ENVIRONMENT SETUP\n// ============================================================================\n\nconst isLocal = typeof Deno !== \"undefined\" && !Deno.env.get(\"DENO_DEPLOYMENT_ID\");\n\nif (isLocal) {\n try {\n const envContent = await Deno.readTextFile(\".env\");\n envContent.split(\"\\n\").forEach((line) => {\n const trimmed = line.trim();\n if (trimmed && !trimmed.startsWith(\"#\")) {\n const [key, ...valueParts] = trimmed.split(\"=\");\n if (key && valueParts.length > 0) {\n Deno.env.set(key.trim(), valueParts.join(\"=\").trim());\n }\n }\n });\n console.log(\"✅ Loaded .env file\");\n } catch {\n console.log(\"⚠️ No .env file found (optional for local dev)\");\n }\n}\n\n// ============================================================================\n// MAIN APPLICATION\n// ============================================================================\n\nlet apiToken: string | null = null;\n\nasync function initApp() {\n await initializeSchema();\n apiToken = isLocal ? await ensureDefaultUser() : null;\n return createApp();\n}\n\nconst app = await initApp();\n\n// ============================================================================\n// EXPORT & LOCAL SERVER\n// ============================================================================\n\n// Export handler for Val Town\nexport default async function(request: Request): Promise {\n console.log(`[Handler] Received request: ${request.method} ${new URL(request.url).pathname}`);\n\n try {\n const response = await app.fetch(request);\n console.log(`[Handler] Returning response with status: ${response.status}`);\n return response;\n } catch (error) {\n console.error(\"[Handler] Error processing request:\", error);\n return new Response(\n JSON.stringify({\n error: \"Internal server error\",\n message: error instanceof Error ? error.message : String(error),\n }),\n {\n status: 500,\n headers: { \"Content-Type\": \"application/json\" },\n }\n );\n }\n};\n\n// Run local server if executed directly\nif (import.meta.main) {\n const port = parseInt(Deno.env.get(\"PORT\") || \"8000\");\n\n console.log(`🚀 Starting Oatmeal server on port ${port}...`);\n console.log(`📍 Running in: ${isLocal ? \"Local Development\" : \"Production\"} mode`);\n\n Deno.serve({\n port,\n onListen: ({ hostname, port }) => {\n console.log(`\\n✨ Server running at http://${hostname}:${port}`);\n console.log(`\\n📝 Endpoints:`);\n console.log(` Documentation: http://${hostname}:${port}/`);\n console.log(` Health Check: http://${hostname}:${port}/health`);\n console.log(` Recordings API: http://${hostname}:${port}/api/recordings`);\n console.log(` Calendar API: http://${hostname}:${port}/api/calendars/*`);\n\n if (apiToken) {\n console.log(`\\n🔑 API Token: ${apiToken}`);\n console.log(` Use with header: Authorization: Token ${apiToken}`);\n console.log(`\\n📋 Example cURL:`);\n console.log(` curl -H \"Authorization: Token ${apiToken}\" http://${hostname}:${port}/api/recordings`);\n } else {\n console.log(`\\n💡 Tip: Set Authorization: Token header for authenticated requests`);\n }\n\n console.log(`💾 Database: /tmp/local-deno-oatmeal.db\\n`);\n },\n }, app.fetch);\n}\n",[],[265],"files",[149,170,179,189,199,209,217,226,235,244,254,263],"counts",{"_278":32,"_279":280,"_281":32,"_282":283},"pulls","branches",1,"forks","envVars",{"_284":185,"_285":32},"count","emptyCount","contents",[],{"_103":210,"_95":99,"_152":211,"_154":-5,"_155":137,"_156":212,"_157":158,"_105":289,"_100":32,"_161":205,"_163":214,"_165":22,"_166":-5,"_98":290},["D",1763772575216],[99],"upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.code.$",{"_93":94,"_95":96,"_97":43,"_100":-7,"_98":99,"_101":299,"_147":304,"_274":341,"_162":342,"_286":344,"_345":-5,"_346":-5,"_347":-5,"_348":-5,"_349":350},{"_103":104,"_95":96,"_105":300,"_107":-5,"_108":22,"_109":110,"_111":72,"_112":-5,"_14":113,"_114":-5,"_115":22,"_116":-5,"_117":32,"_16":118,"_119":120,"_121":120,"_122":123,"_124":123,"_125":123,"_126":120,"_127":120,"_23":301,"_131":302,"_134":303,"_146":22},["D",1763762101176],{"_93":94,"_129":130},{"_93":94,"_133":130,"_14":113},{"_100":136,"_95":43,"_103":137,"_138":104,"_139":-5,"_140":-5,"_141":-5,"_142":-5,"_143":-5,"_144":96,"_145":94},[305,308,311,314,317,320,323,326,329,332,335,338],{"_103":150,"_95":151,"_152":153,"_154":-5,"_155":137,"_156":136,"_157":158,"_105":159,"_100":160,"_161":162,"_163":164,"_165":22,"_166":-5,"_167":306,"_98":307},[],[151],{"_103":171,"_95":172,"_152":173,"_154":-5,"_155":137,"_156":174,"_157":158,"_105":175,"_100":32,"_161":162,"_163":176,"_165":22,"_166":-5,"_167":309,"_98":310},[],[172],{"_103":180,"_95":181,"_152":182,"_154":-5,"_155":137,"_156":183,"_157":158,"_105":184,"_100":185,"_161":162,"_163":186,"_165":22,"_166":-5,"_167":312,"_98":313},[],[181],{"_103":190,"_95":191,"_152":192,"_154":-5,"_155":137,"_156":193,"_157":158,"_105":194,"_100":195,"_161":162,"_163":196,"_165":22,"_166":-5,"_167":315,"_98":316},[],[191],{"_103":200,"_95":201,"_152":202,"_154":-5,"_155":137,"_156":203,"_157":158,"_105":204,"_100":32,"_161":205,"_163":206,"_165":22,"_166":-5,"_167":318,"_98":319},[],[201],{"_103":210,"_95":99,"_152":211,"_154":-5,"_155":137,"_156":212,"_157":158,"_105":213,"_100":32,"_161":205,"_163":214,"_165":22,"_166":-5,"_167":321,"_98":322},[],[99],{"_103":218,"_95":219,"_152":220,"_154":-5,"_155":137,"_156":221,"_157":158,"_105":222,"_100":32,"_161":205,"_163":223,"_165":22,"_166":-5,"_167":324,"_98":325},[],[219],{"_103":227,"_95":228,"_152":229,"_154":-5,"_155":137,"_156":230,"_157":158,"_105":231,"_100":32,"_161":205,"_163":232,"_165":22,"_166":-5,"_167":327,"_98":328},[],[228],{"_103":236,"_95":237,"_152":238,"_154":-5,"_155":137,"_156":239,"_157":158,"_105":240,"_100":32,"_161":205,"_163":241,"_165":22,"_166":-5,"_167":330,"_98":331},[],[237],{"_103":245,"_95":246,"_152":247,"_154":-5,"_155":137,"_156":248,"_157":158,"_105":249,"_100":250,"_161":205,"_163":251,"_165":22,"_166":-5,"_167":333,"_98":334},[],[246],{"_103":255,"_95":256,"_152":257,"_154":-5,"_155":137,"_156":258,"_157":158,"_105":259,"_100":32,"_161":205,"_163":260,"_165":22,"_166":-5,"_167":336,"_98":337},[],[256],{"_103":264,"_95":265,"_152":266,"_154":-5,"_155":137,"_156":267,"_157":158,"_105":268,"_100":269,"_161":270,"_163":271,"_165":22,"_166":-5,"_167":339,"_98":340},[],[265],[305,308,311,314,317,320,323,326,329,332,335,338],{"_103":210,"_95":99,"_152":211,"_154":-5,"_155":137,"_156":212,"_157":158,"_105":289,"_100":32,"_161":205,"_163":214,"_165":22,"_166":-5,"_98":343},[99],[],"upstream","pull","ahead","behind","templates",[],"actionData","errors"]

kvey

oatmeal