[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_231":232,"_233":234},"routes/_app.x.$handle.$name",{"_103":102,"_32":45,"_111":89,"_27":112,"_13":14,"_113":-5,"_11":114,"_115":116,"_117":118,"_119":120,"_121":122,"_20":-5,"_123":124,"_125":126,"_127":25,"_128":129,"_130":58,"_131":-5,"_132":-5,"_133":134},"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":31,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":25},"version",4,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.tsx","latestPath","fileId","01a0157c-7a0e-76a8-9d6f-d340704549ae","name","fileType","http","content","import { Hono } from \"npm:hono\";\nimport { acceptInvite, addSessionEvent, createInvite, createSession, deviceInConnection, finishSession, getActiveSession, getDevice, getInvite, getSession, insertDevice, listConnections, listSessionEvents, updateDeviceName, type RelationType } from \"./db.ts\";\n\nconst app = new Hono();\nconst allowedEventTypes = new Set([\"snapshot\", \"spot_request\", \"ready\", \"session_finished\"]);\n\nfunction json(c: any, data: unknown, status = 200) {\n c.header(\"Access-Control-Allow-Origin\", \"*\");\n c.header(\"Access-Control-Allow-Headers\", \"authorization, x-togethr-device, content-type\");\n c.header(\"Access-Control-Allow-Methods\", \"GET,POST,PATCH,OPTIONS\");\n return c.json(data, status as any);\n}\napp.options(\"*\", (c) => json(c, { ok: true }));\n\nfunction randomToken(bytes = 32) {\n const data = crypto.getRandomValues(new Uint8Array(bytes));\n return btoa(String.fromCharCode(...data)).replace(/\\+/g, \"-\").replace(/\\//g, \"_\").replace(/=+$/g, \"\");\n}\nfunction randomCode() {\n const alphabet = \"ABCDEFGHJKLMNPQRSTUVWXYZ23456789\";\n const data = crypto.getRandomValues(new Uint8Array(6));\n return Array.from(data, (value) => alphabet[value % alphabet.length]).join(\"\");\n}\nasync function hashToken(token: string) {\n const digest = await crypto.subtle.digest(\"SHA-256\", new TextEncoder().encode(token));\n return Array.from(new Uint8Array(digest), (b) => b.toString(16).padStart(2, \"0\")).join(\"\");\n}\nasync function requireDevice(c: any) {\n const deviceId = c.req.header(\"x-togethr-device\")?.trim();\n const auth = c.req.header(\"authorization\")?.trim() ?? \"\";\n const token = auth.startsWith(\"Bearer \") ? auth.slice(7).trim() : \"\";\n if (!deviceId || !token) return null;\n const device = await getDevice(deviceId);\n if (!device) return null;\n const hash = await hashToken(token);\n return hash === device.token_hash ? device : null;\n}\n\napp.get(\"/health\", (c) => json(c, { ok: true, service: \"togethr-beta-relay\", version: 1 }));\napp.post(\"/v1/devices\", async (c) => {\n const body = await c.req.json().catch(() => ({}));\n const displayName = String(body.displayName ?? \"\").trim().slice(0, 40);\n if (displayName.length < 2) return json(c, { error: \"display_name_required\" }, 400);\n const id = crypto.randomUUID(); const token = randomToken();\n await insertDevice(id, await hashToken(token), displayName);\n return json(c, { device: { id, token, displayName } }, 201);\n});\napp.patch(\"/v1/devices/me\", async (c) => {\n const device = await requireDevice(c); if (!device) return json(c, { error: \"unauthorized\" }, 401);\n const body = await c.req.json().catch(() => ({})); const displayName = String(body.displayName ?? \"\").trim().slice(0, 40);\n if (displayName.length < 2) return json(c, { error: \"display_name_required\" }, 400);\n await updateDeviceName(device.id, displayName); return json(c, { ok: true, displayName });\n});\napp.post(\"/v1/invites\", async (c) => {\n const device = await requireDevice(c); if (!device) return json(c, { error: \"unauthorized\" }, 401);\n const body = await c.req.json().catch(() => ({})); const relationType: RelationType = body.relationType === \"Gym buddy\" ? \"Gym buddy\" : \"Partner\";\n for (let attempt = 0; attempt < 6; attempt++) {\n const code = randomCode();\n try { const expiresAt = await createInvite(code, device.id, relationType); return json(c, { invite: { code, relationType, expiresAt } }, 201); }\n catch (error) { if (attempt === 5) throw error; }\n }\n return json(c, { error: \"invite_creation_failed\" }, 500);\n});\napp.get(\"/v1/invites/:code\", async (c) => {\n const code = c.req.param(\"code\").toUpperCase(); const invite = await getInvite(code);\n if (!invite) return json(c, { error: \"invite_not_found\" }, 404);\n if (String(invite.expires_at) <= new Date().toISOString() || invite.status !== \"pending\") return json(c, { error: \"invite_unavailable\" }, 410);\n return json(c, { invite: { code, creatorName: invite.creator_name, relationType: invite.relation_type, expiresAt: invite.expires_at } });\n});\napp.post(\"/v1/invites/:code/accept\", async (c) => {\n const device = await requireDevice(c); if (!device) return json(c, { error: \"unauthorized\" }, 401);\n const code = c.req.param(\"code\").toUpperCase(); const connectionId = crypto.randomUUID();\n try { await acceptInvite(code, device.id, connectionId); }\n catch (error) { const message = error instanceof Error ? error.message : \"INVITE_FAILED\"; const status = message === \"INVITE_NOT_FOUND\" ? 404 : message === \"INVITE_EXPIRED\" ? 410 : 409; return json(c, { error: message.toLowerCase() }, status); }\n const connections = await listConnections(device.id); return json(c, { connection: connections.find((item) => item.id === connectionId) }, 201);\n});\napp.get(\"/v1/connections\", async (c) => {\n const device = await requireDevice(c); if (!device) return json(c, { error: \"unauthorized\" }, 401);\n return json(c, { connections: await listConnections(device.id) });\n});\napp.post(\"/v1/sessions\", async (c) => {\n const device = await requireDevice(c); if (!device) return json(c, { error: \"unauthorized\" }, 401);\n const body = await c.req.json().catch(() => ({})); const connectionId = String(body.connectionId ?? \"\");\n if (!connectionId || !(await deviceInConnection(connectionId, device.id))) return json(c, { error: \"forbidden\" }, 403);\n const title = String(body.title ?? \"Shared workout\").trim().slice(0, 80) || \"Shared workout\"; const sessionId = crypto.randomUUID();\n await createSession(sessionId, connectionId, device.id, title);\n if (body.initialState) await addSessionEvent(crypto.randomUUID(), sessionId, device.id, \"snapshot\", body.initialState);\n return json(c, { session: { id: sessionId, connectionId, title, status: \"live\" } }, 201);\n});\napp.get(\"/v1/sessions/active\", async (c) => {\n const device = await requireDevice(c); if (!device) return json(c, { error: \"unauthorized\" }, 401);\n const connectionId = c.req.query(\"connectionId\") ?? \"\";\n if (!connectionId || !(await deviceInConnection(connectionId, device.id))) return json(c, { error: \"forbidden\" }, 403);\n const session = await getActiveSession(connectionId); if (!session) return json(c, { session: null });\n const events = await listSessionEvents(String(session.id), 0);\n return json(c, { session: { id: session.id, connectionId: session.connection_id, title: session.title, status: session.status }, latestEvent: events.at(-1) ?? null });\n});\napp.post(\"/v1/sessions/:sessionId/events\", async (c) => {\n const device = await requireDevice(c); if (!device) return json(c, { error: \"unauthorized\" }, 401);\n const sessionId = c.req.param(\"sessionId\"); const session = await getSession(sessionId); if (!session) return json(c, { error: \"session_not_found\" }, 404);\n if (!(await deviceInConnection(String(session.connection_id), device.id))) return json(c, { error: \"forbidden\" }, 403);\n const body = await c.req.json().catch(() => ({})); const eventId = String(body.eventId ?? crypto.randomUUID()); const type = String(body.type ?? \"snapshot\");\n if (!allowedEventTypes.has(type)) return json(c, { error: \"event_type_invalid\" }, 400);\n const seq = await addSessionEvent(eventId, sessionId, device.id, type, body.payload ?? {}); return json(c, { seq }, 201);\n});\napp.get(\"/v1/sessions/:sessionId/events\", async (c) => {\n const device = await requireDevice(c); if (!device) return json(c, { error: \"unauthorized\" }, 401);\n const sessionId = c.req.param(\"sessionId\"); const session = await getSession(sessionId); if (!session) return json(c, { error: \"session_not_found\" }, 404);\n if (!(await deviceInConnection(String(session.connection_id), device.id))) return json(c, { error: \"forbidden\" }, 403);\n const after = Math.max(0, Number(c.req.query(\"after\") ?? 0) || 0); return json(c, { events: await listSessionEvents(sessionId, after) });\n});\napp.post(\"/v1/sessions/:sessionId/finish\", async (c) => {\n const device = await requireDevice(c); if (!device) return json(c, { error: \"unauthorized\" }, 401);\n const sessionId = c.req.param(\"sessionId\"); const session = await getSession(sessionId); if (!session) return json(c, { error: \"session_not_found\" }, 404);\n if (!(await deviceInConnection(String(session.connection_id), device.id))) return json(c, { error: \"forbidden\" }, 403);\n await finishSession(sessionId); await addSessionEvent(crypto.randomUUID(), sessionId, device.id, \"session_finished\", { at: new Date().toISOString() }); return json(c, { ok: true });\n});\napp.onError((error, c) => { console.error(error); return json(c, { error: \"internal_error\" }, 500); });\nexport default app.fetch;\n","import { Hono } from \"npm:hono\";\nimport { acceptInvite, addSessionEvent, createInvite, createSession, deviceInConnection, finishSession, getActiveSession, getDevice, getInvite, getSession, insertDevice, listConnections, listSessionEvents, updateDeviceName, type RelationType } from \"./db.ts\";\n\nconst app = new Hono();\nconst allowedEventTypes = new Set([\"snapshot\", \"spot_request\", \"ready\", \"session_finished\"]);\n\nfunction json(c: any, data: unknown, status = 200) {\n c.header(\"Access-Control-Allow-Origin\", \"*\");\n c.header(\"Access-Control-Allow-Headers\", \"authorization, x-togethr-device, content-type\");\n c.header(\"Access-Control-Allow-Methods\", \"GET,POST,PATCH,OPTIONS\");\n return c.json(data, status as any);\n}\napp.options(\"*\", (c) => json(c, { ok: true }));\n\nfunction randomToken(bytes = 32) {\n const data = crypto.getRandomValues(new Uint8Array(bytes));\n return btoa(String.fromCharCode(...data)).replace(/\\+/g, \"-\").replace(/\\//g, \"_\").replace(/=+$/g, \"\");\n}\nfunction randomCode() {\n const alphabet = \"ABCDEFGHJKLMNPQRSTUVWXYZ23456789\";\n const data = crypto.getRandomValues(new Uint8Array(6));\n return Array.from(data, (value) => alphabet[value % alphabet.length]).join(\"\");\n}\nasync function hashToken(token: string) {\n const digest = await crypto.subtle.digest(\"SHA-256\", new TextEncoder().encode(token));\n return Array.from(new Uint8Array(digest), (b) => b.toString(16).padStart(2, \"0\")).join(\"\");\n}\nasync function requireDevice(c: any) {\n const deviceId = c.req.header(\"x-togethr-device\")?.trim();\n const auth = c.req.header(\"authorization\")?.trim() ?? \"\";\n const token = auth.startsWith(\"Bearer \") ? auth.slice(7).trim() : \"\";\n if (!deviceId || !token) return null;\n const device = await getDevice(deviceId);\n if (!device) return null;\n const hash = await hashToken(token);\n return hash === device.token_hash ? device : null;\n}\n\napp.get(\"/health\", (c) => json(c, { ok: true, service: \"togethr-beta-relay\", version: 1 }));\napp.post(\"/v1/devices\", async (c) => {\n const body = await c.req.json().catch(() => ({}));\n const displayName = String(body.displayName ?? \"\").trim().slice(0, 40);\n if (displayName.length < 2) return json(c, { error: \"display_name_required\" }, 400);\n const id = crypto.randomUUID(); const token = randomToken();\n await insertDevice(id, await hashToken(token), displayName);\n return json(c, { device: { id, token, displayName } }, 201);\n});\napp.patch(\"/v1/devices/me\", async (c) => {\n const device = await requireDevice(c); if (!device) return json(c, { error: \"unauthorized\" }, 401);\n const body = await c.req.json().catch(() => ({})); const displayName = String(body.displayName ?? \"\").trim().slice(0, 40);\n if (displayName.length < 2) return json(c, { error: \"display_name_required\" }, 400);\n await updateDeviceName(device.id, displayName); return json(c, { ok: true, displayName });\n});\napp.post(\"/v1/invites\", async (c) => {\n const device = await requireDevice(c); if (!device) return json(c, { error: \"unauthorized\" }, 401);\n const body = await c.req.json().catch(() => ({})); const relationType: RelationType = body.relationType === \"Gym buddy\" ? \"Gym buddy\" : \"Partner\";\n for (let attempt = 0; attempt < 6; attempt++) {\n const code = randomCode();\n try { const expiresAt = await createInvite(code, device.id, relationType); return json(c, { invite: { code, relationType, expiresAt } }, 201); }\n catch (error) { if (attempt === 5) throw error; }\n }\n return json(c, { error: \"invite_creation_failed\" }, 500);\n});\napp.get(\"/v1/invites/:code\", async (c) => {\n const code = c.req.param(\"code\").toUpperCase(); const invite = await getInvite(code);\n if (!invite) return json(c, { error: \"invite_not_found\" }, 404);\n if (String(invite.expires_at) <= new Date().toISOString() || invite.status !== \"pending\") return json(c, { error: \"invite_unavailable\" }, 410);\n return json(c, { invite: { code, creatorName: invite.creator_name, relationType: invite.relation_type, expiresAt: invite.expires_at } });\n});\napp.get(\"/join/:code\", async (c) => {\n const code = c.req.param(\"code\").toUpperCase();\n const invite = await getInvite(code);\n const unavailable = !invite || invite.status !== \"pending\" || String(invite.expires_at) <= new Date().toISOString();\n const creatorName = unavailable ? \"Your friend\" : String(invite.creator_name);\n const relationType = unavailable ? \"training partner\" : String(invite.relation_type).toLowerCase();\n const safeCode = code.replace(/[^A-Z0-9]/g, \"\").slice(0, 6);\n const deepLink = `togethr://join?code=${safeCode}`;\n return c.html(`Togethr invite

Togethr beta invite

${unavailable ? \"Invite unavailable\" : `${creatorName} wants to train with you.`}

${unavailable ? \"This code has expired or was already used.\" : `Open Togethr and pair as a ${relationType}. Your private body metrics are not shared by accepting.`}

${safeCode}

${unavailable ? \"\" : `OPEN TOGETHR`}

If the button does not open the beta app, enter the six-character code manually on the Partner Up screen.

`);\n});\n\napp.post(\"/v1/invites/:code/accept\", async (c) => {\n const device = await requireDevice(c); if (!device) return json(c, { error: \"unauthorized\" }, 401);\n const code = c.req.param(\"code\").toUpperCase(); const connectionId = crypto.randomUUID();\n try { await acceptInvite(code, device.id, connectionId); }\n catch (error) { const message = error instanceof Error ? error.message : \"INVITE_FAILED\"; const status = message === \"INVITE_NOT_FOUND\" ? 404 : message === \"INVITE_EXPIRED\" ? 410 : 409; return json(c, { error: message.toLowerCase() }, status); }\n const connections = await listConnections(device.id); return json(c, { connection: connections.find((item) => item.id === connectionId) }, 201);\n});\napp.get(\"/v1/connections\", async (c) => {\n const device = await requireDevice(c); if (!device) return json(c, { error: \"unauthorized\" }, 401);\n return json(c, { connections: await listConnections(device.id) });\n});\napp.post(\"/v1/sessions\", async (c) => {\n const device = await requireDevice(c); if (!device) return json(c, { error: \"unauthorized\" }, 401);\n const body = await c.req.json().catch(() => ({})); const connectionId = String(body.connectionId ?? \"\");\n if (!connectionId || !(await deviceInConnection(connectionId, device.id))) return json(c, { error: \"forbidden\" }, 403);\n const title = String(body.title ?? \"Shared workout\").trim().slice(0, 80) || \"Shared workout\"; const sessionId = crypto.randomUUID();\n await createSession(sessionId, connectionId, device.id, title);\n if (body.initialState) await addSessionEvent(crypto.randomUUID(), sessionId, device.id, \"snapshot\", body.initialState);\n return json(c, { session: { id: sessionId, connectionId, title, status: \"live\" } }, 201);\n});\napp.get(\"/v1/sessions/active\", async (c) => {\n const device = await requireDevice(c); if (!device) return json(c, { error: \"unauthorized\" }, 401);\n const connectionId = c.req.query(\"connectionId\") ?? \"\";\n if (!connectionId || !(await deviceInConnection(connectionId, device.id))) return json(c, { error: \"forbidden\" }, 403);\n const session = await getActiveSession(connectionId); if (!session) return json(c, { session: null });\n const events = await listSessionEvents(String(session.id), 0);\n return json(c, { session: { id: session.id, connectionId: session.connection_id, title: session.title, status: session.status }, latestEvent: events.at(-1) ?? null });\n});\napp.post(\"/v1/sessions/:sessionId/events\", async (c) => {\n const device = await requireDevice(c); if (!device) return json(c, { error: \"unauthorized\" }, 401);\n const sessionId = c.req.param(\"sessionId\"); const session = await getSession(sessionId); if (!session) return json(c, { error: \"session_not_found\" }, 404);\n if (!(await deviceInConnection(String(session.connection_id), device.id))) return json(c, { error: \"forbidden\" }, 403);\n const body = await c.req.json().catch(() => ({})); const eventId = String(body.eventId ?? crypto.randomUUID()); const type = String(body.type ?? \"snapshot\");\n if (!allowedEventTypes.has(type)) return json(c, { error: \"event_type_invalid\" }, 400);\n const seq = await addSessionEvent(eventId, sessionId, device.id, type, body.payload ?? {}); return json(c, { seq }, 201);\n});\napp.get(\"/v1/sessions/:sessionId/events\", async (c) => {\n const device = await requireDevice(c); if (!device) return json(c, { error: \"unauthorized\" }, 401);\n const sessionId = c.req.param(\"sessionId\"); const session = await getSession(sessionId); if (!session) return json(c, { error: \"session_not_found\" }, 404);\n if (!(await deviceInConnection(String(session.connection_id), device.id))) return json(c, { error: \"forbidden\" }, 403);\n const after = Math.max(0, Number(c.req.query(\"after\") ?? 0) || 0); return json(c, { events: await listSessionEvents(sessionId, after) });\n});\napp.post(\"/v1/sessions/:sessionId/finish\", async (c) => {\n const device = await requireDevice(c); if (!device) return json(c, { error: \"unauthorized\" }, 401);\n const sessionId = c.req.param(\"sessionId\"); const session = await getSession(sessionId); if (!session) return json(c, { error: \"session_not_found\" }, 404);\n if (!(await deviceInConnection(String(session.connection_id), device.id))) return json(c, { error: \"forbidden\" }, 403);\n await finishSession(sessionId); await addSessionEvent(crypto.randomUUID(), sessionId, device.id, \"session_finished\", { at: new Date().toISOString() }); return json(c, { ok: true });\n});\napp.onError((error, c) => { console.error(error); return json(c, { error: \"internal_error\" }, 500); });\nexport default app.fetch;\n","createdAt",["D",1787067299119],"branchVersion","branchId","095fa0fe-5a43-4bf0-9222-aaa30fc6f0b0","id","f81ec633-62da-4fa6-8a9b-5ee623c88180","togethr-beta-relay",["D",1787066874304],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Togethr beta invite and session relay","imageUrl","bdda9a4c-13e6-4481-b3c2-7ac3d6eab867","pinnedFileId","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019fcccd-fd9a-74cd-9f90-ade6d5af4f67","tursoName","f81ec63362da4fa68a9b5ee623c88180","tursoHostname","f81ec63362da4fa68a9b5ee623c88180-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789499469860],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_103":102,"_110":106},"org",{"_103":102,"_104":102,"_105":106,"_18":55,"_107":108,"_109":25},"branch",{"_13":88,"_32":89,"_43":42,"_90":44,"_91":92,"_93":94,"_95":50,"_96":97,"_98":99,"_100":45,"_101":102},"isOwned",6,"main","projectId","forkedBranchId","fb141f8d-047d-43b3-b09c-7fd59d8ddcfe","forkedBranchVersion",1,"forkedProjectPrivacy","forkedProjectId","a35fc79f-ccd4-4375-94dc-260d312636c6","forkedProjectOrgId","019aa807-52c2-709c-928b-2029bae9a558","projectName","userHandle","manas","handle","displayName","avatar","https://lh3.googleusercontent.com/a/ACg8ocIDM6L3j1I5a-9KRxESWnU76mLAa66fJBhefbGOknwGZXzF-g=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":226,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":31,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":227,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":228,"_83":229,"_85":230,"_87":25},"tree",[185,189,190,191],"files",[185,186,187,188,189,190,191],"counts",{"_175":62,"_176":94,"_177":62,"_178":179,"_180":181},"contents",[145,146,147,148],"upstreamProject",{"_43":97,"_32":141,"_52":142,"_54":-5,"_49":50,"_81":143},"upstreamBranch",{"_43":92,"_38":135,"_136":137,"_32":89,"_90":97,"_13":94,"_91":-5,"_93":-5,"_138":139,"_47":-5,"_87":25,"_49":50,"_101":140,"_63":99,"_100":141},"emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1781134761362],"updatedAt",["D",1781134761362],"lockfileKey","1781135021367-esm.town_v_templates_form-to-sqlite@1-main","templates","form-to-sqlite","Put a form online and save submissions to SQLite",{"_103":140,"_110":144},"https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/129cab32-3bd7-4c3e-f39b-f12900c76100/square512?exp=1789545599&sig=2316df07e67031dd48e537f6ce0c4c14b92716fed790ec83ecf27974cc65aa31",{"_43":169,"_32":170,"_30":171,"_150":-5,"_41":42,"_40":94,"_151":58,"_38":172,"_13":62,"_33":173,"_35":-5,"_24":25,"_154":-5,"_27":174},{"_43":163,"_32":164,"_30":165,"_150":-5,"_41":42,"_40":94,"_151":58,"_38":166,"_13":62,"_33":20,"_35":167,"_24":25,"_154":-5,"_27":168},{"_43":156,"_32":157,"_30":158,"_150":-5,"_41":42,"_40":153,"_151":58,"_38":159,"_13":94,"_33":160,"_35":161,"_24":25,"_154":-5,"_27":162},{"_43":149,"_32":28,"_30":31,"_150":-5,"_41":42,"_40":14,"_151":58,"_38":152,"_13":153,"_33":34,"_35":37,"_24":25,"_154":45,"_27":155},"abc7177e-148c-45c0-aaaa-b1a68fb0d261","parentId","latest",["D",1787067299119],2,"label",[28],"53254fea-c879-4c8d-8f86-ed19b333a67f","db.ts","01a0157c-7a0e-76a8-9d6f-cd5a6bfb415a",["D",1787067080726],"script","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport type RelationType = \"Partner\" | \"Gym buddy\";\nexport type DeviceRow = { id: string; token_hash: string; display_name: string; created_at: string };\nexport type ConnectionView = { id: string; relationType: RelationType; peer: { id: string; displayName: string }; createdAt: string };\n\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS devices (\n id TEXT PRIMARY KEY,\n token_hash TEXT NOT NULL,\n display_name TEXT NOT NULL,\n created_at TEXT NOT NULL DEFAULT (datetime('now'))\n)`);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS invites (\n code TEXT PRIMARY KEY,\n creator_device_id TEXT NOT NULL REFERENCES devices(id) ON DELETE CASCADE,\n accepted_device_id TEXT REFERENCES devices(id) ON DELETE SET NULL,\n connection_id TEXT,\n relation_type TEXT NOT NULL CHECK (relation_type IN ('Partner', 'Gym buddy')),\n status TEXT NOT NULL DEFAULT 'pending' CHECK (status IN ('pending', 'accepted', 'revoked')),\n expires_at TEXT NOT NULL,\n created_at TEXT NOT NULL DEFAULT (datetime('now'))\n)`);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS connections (\n id TEXT PRIMARY KEY,\n device_a_id TEXT NOT NULL REFERENCES devices(id) ON DELETE CASCADE,\n device_b_id TEXT NOT NULL REFERENCES devices(id) ON DELETE CASCADE,\n relation_type TEXT NOT NULL CHECK (relation_type IN ('Partner', 'Gym buddy')),\n created_at TEXT NOT NULL DEFAULT (datetime('now')),\n UNIQUE(device_a_id, device_b_id)\n)`);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS sessions (\n id TEXT PRIMARY KEY,\n connection_id TEXT NOT NULL REFERENCES connections(id) ON DELETE CASCADE,\n created_by_device_id TEXT NOT NULL REFERENCES devices(id) ON DELETE CASCADE,\n title TEXT NOT NULL,\n status TEXT NOT NULL DEFAULT 'live' CHECK (status IN ('live', 'completed')),\n created_at TEXT NOT NULL DEFAULT (datetime('now')),\n completed_at TEXT\n)`);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS session_events (\n seq INTEGER PRIMARY KEY AUTOINCREMENT,\n event_id TEXT NOT NULL UNIQUE,\n session_id TEXT NOT NULL REFERENCES sessions(id) ON DELETE CASCADE,\n device_id TEXT NOT NULL REFERENCES devices(id) ON DELETE CASCADE,\n event_type TEXT NOT NULL,\n payload_json TEXT NOT NULL,\n created_at TEXT NOT NULL DEFAULT (datetime('now'))\n)`);\n\nexport async function insertDevice(id: string, tokenHash: string, displayName: string) {\n await sqlite.execute({ sql: \"INSERT INTO devices (id, token_hash, display_name) VALUES (?, ?, ?)\", args: [id, tokenHash, displayName] });\n}\nexport async function getDevice(id: string): Promise {\n const result = await sqlite.execute({ sql: \"SELECT * FROM devices WHERE id = ? LIMIT 1\", args: [id] });\n return (result.rows[0] as unknown as DeviceRow | undefined) ?? null;\n}\nexport async function updateDeviceName(id: string, displayName: string) {\n await sqlite.execute({ sql: \"UPDATE devices SET display_name = ? WHERE id = ?\", args: [displayName, id] });\n}\nexport async function createInvite(code: string, creatorDeviceId: string, relationType: RelationType) {\n const expiresAt = new Date(Date.now() + 24 * 60 * 60 * 1000).toISOString();\n await sqlite.execute({ sql: \"INSERT INTO invites (code, creator_device_id, relation_type, expires_at) VALUES (?, ?, ?, ?)\", args: [code, creatorDeviceId, relationType, expiresAt] });\n return expiresAt;\n}\nexport async function getInvite(code: string) {\n const result = await sqlite.execute({\n sql: `SELECT i.code, i.creator_device_id, i.relation_type, i.status, i.expires_at, d.display_name AS creator_name\n FROM invites i JOIN devices d ON d.id = i.creator_device_id WHERE i.code = ? LIMIT 1`,\n args: [code],\n });\n return (result.rows[0] as Record | undefined) ?? null;\n}\nexport async function acceptInvite(code: string, acceptedDeviceId: string, connectionId: string) {\n const invite = await getInvite(code);\n if (!invite) throw new Error(\"INVITE_NOT_FOUND\");\n if (invite.status !== \"pending\") throw new Error(\"INVITE_NOT_PENDING\");\n if (String(invite.expires_at) <= new Date().toISOString()) throw new Error(\"INVITE_EXPIRED\");\n if (invite.creator_device_id === acceptedDeviceId) throw new Error(\"INVITE_SELF\");\n await sqlite.execute({ sql: \"INSERT INTO connections (id, device_a_id, device_b_id, relation_type) VALUES (?, ?, ?, ?)\", args: [connectionId, String(invite.creator_device_id), acceptedDeviceId, String(invite.relation_type)] });\n await sqlite.execute({ sql: \"UPDATE invites SET accepted_device_id = ?, connection_id = ?, status = 'accepted' WHERE code = ?\", args: [acceptedDeviceId, connectionId, code] });\n return connectionId;\n}\nexport async function listConnections(deviceId: string): Promise {\n const result = await sqlite.execute({\n sql: `SELECT c.id, c.relation_type, c.created_at,\n CASE WHEN c.device_a_id = ? THEN b.id ELSE a.id END AS peer_id,\n CASE WHEN c.device_a_id = ? THEN b.display_name ELSE a.display_name END AS peer_name\n FROM connections c JOIN devices a ON a.id = c.device_a_id JOIN devices b ON b.id = c.device_b_id\n WHERE c.device_a_id = ? OR c.device_b_id = ? ORDER BY c.created_at DESC`,\n args: [deviceId, deviceId, deviceId, deviceId],\n });\n return (result.rows as unknown as Array>).map((row) => ({\n id: String(row.id), relationType: String(row.relation_type) as RelationType,\n peer: { id: String(row.peer_id), displayName: String(row.peer_name) }, createdAt: String(row.created_at),\n }));\n}\nexport async function deviceInConnection(connectionId: string, deviceId: string) {\n const result = await sqlite.execute({ sql: \"SELECT 1 AS ok FROM connections WHERE id = ? AND (device_a_id = ? OR device_b_id = ?) LIMIT 1\", args: [connectionId, deviceId, deviceId] });\n return result.rows.length > 0;\n}\nexport async function createSession(id: string, connectionId: string, deviceId: string, title: string) {\n await sqlite.execute({ sql: \"UPDATE sessions SET status = 'completed', completed_at = datetime('now') WHERE connection_id = ? AND status = 'live'\", args: [connectionId] });\n await sqlite.execute({ sql: \"INSERT INTO sessions (id, connection_id, created_by_device_id, title) VALUES (?, ?, ?, ?)\", args: [id, connectionId, deviceId, title] });\n}\nexport async function getActiveSession(connectionId: string) {\n const result = await sqlite.execute({ sql: \"SELECT * FROM sessions WHERE connection_id = ? AND status = 'live' ORDER BY created_at DESC LIMIT 1\", args: [connectionId] });\n return (result.rows[0] as Record | undefined) ?? null;\n}\nexport async function getSession(sessionId: string) {\n const result = await sqlite.execute({ sql: \"SELECT * FROM sessions WHERE id = ? LIMIT 1\", args: [sessionId] });\n return (result.rows[0] as Record | undefined) ?? null;\n}\nexport async function addSessionEvent(eventId: string, sessionId: string, deviceId: string, eventType: string, payload: unknown) {\n await sqlite.execute({ sql: \"INSERT OR IGNORE INTO session_events (event_id, session_id, device_id, event_type, payload_json) VALUES (?, ?, ?, ?, ?)\", args: [eventId, sessionId, deviceId, eventType, JSON.stringify(payload)] });\n const result = await sqlite.execute({ sql: \"SELECT seq FROM session_events WHERE event_id = ? LIMIT 1\", args: [eventId] });\n return Number((result.rows[0] as Record | undefined)?.seq ?? 0);\n}\nexport async function listSessionEvents(sessionId: string, afterSeq: number) {\n const result = await sqlite.execute({ sql: \"SELECT seq, event_id, device_id, event_type, payload_json, created_at FROM session_events WHERE session_id = ? AND seq > ? ORDER BY seq ASC LIMIT 100\", args: [sessionId, afterSeq] });\n return (result.rows as unknown as Array>).map((row) => ({ seq: Number(row.seq), eventId: String(row.event_id), deviceId: String(row.device_id), type: String(row.event_type), payload: JSON.parse(String(row.payload_json)), createdAt: String(row.created_at) }));\n}\nexport async function finishSession(sessionId: string) {\n await sqlite.execute({ sql: \"UPDATE sessions SET status = 'completed', completed_at = datetime('now') WHERE id = ?\", args: [sessionId] });\n}\n",[157],"d63df2cf-a945-4023-95f6-25bcc544d53f","README.md","01a0157c-7a0e-76a8-9d6f-cbb4f3644591",["D",1787066874304],"# What's the easiest way to put a form online and save submissions?\n\nRemix this val. It serves a contact form (name, email, message) at `/`, saves every submission to the val's own SQLite database, and lists everything received at `/submissions`. No external services, no API keys, no env vars.\n\n## Setup\n\n1. Remix this val.\n2. Open the HTTP endpoint of `main.tsx` — that is your live form. Share the URL.\n3. Visit `/submissions` on the same URL to see what people sent.\n\nEach remix gets its own private SQLite database, so your submissions stay with your copy.\n\n## Files\n\n- `main.tsx` — Hono routes: GET `/` (form), POST `/submit` (save), GET `/submissions` (list)\n- `db.ts` — creates the `submissions` table and holds the two queries\n- `components/Layout.tsx` — shared page shell with Tailwind (via Twind)\n- `components/FormPage.tsx` — the form\n- `components/SubmissionsPage.tsx` — the list\n\n## Notes\n\n- `/submissions` is public by default. If your form collects anything sensitive, protect that route before sharing the form URL.\n- No client-side JavaScript: the form is a plain HTML POST.\n",[164],"2aa5abda-6cb8-4e95-8170-67c8bdffc208","components","01a0157c-7a0e-76a8-9d6f-c6e8f43f6e8b",["D",1787066874304],"directory",[170],"pulls","branches","forks","envVars",{"_182":62,"_184":62},"connections",{"_182":62,"_183":62},"count","unfilledCount","emptyCount",{"_43":169,"_32":170,"_30":171,"_150":-5,"_41":42,"_40":94,"_151":58,"_38":223,"_13":62,"_33":173,"_35":-5,"_24":25,"_154":-5,"_193":224,"_27":225},{"_43":216,"_32":217,"_30":218,"_150":171,"_41":42,"_40":94,"_151":58,"_38":219,"_13":62,"_33":160,"_35":220,"_24":25,"_154":-5,"_193":221,"_27":222},{"_43":209,"_32":210,"_30":211,"_150":171,"_41":42,"_40":94,"_151":58,"_38":212,"_13":62,"_33":160,"_35":213,"_24":25,"_154":-5,"_193":214,"_27":215},{"_43":202,"_32":203,"_30":204,"_150":171,"_41":42,"_40":94,"_151":58,"_38":205,"_13":62,"_33":160,"_35":206,"_24":25,"_154":-5,"_193":207,"_27":208},{"_43":163,"_32":164,"_30":165,"_150":-5,"_41":42,"_40":94,"_151":58,"_38":199,"_13":62,"_33":20,"_35":167,"_24":25,"_154":-5,"_193":200,"_27":201},{"_43":156,"_32":157,"_30":158,"_150":-5,"_41":42,"_40":153,"_151":58,"_38":196,"_13":94,"_33":160,"_35":161,"_24":25,"_154":-5,"_193":197,"_27":198},{"_43":149,"_32":28,"_30":31,"_150":-5,"_41":42,"_40":14,"_151":58,"_38":192,"_13":153,"_33":34,"_35":37,"_24":25,"_154":45,"_193":194,"_27":195},["D",1787067299119],"children",[],[28],["D",1787067080726],[],[157],["D",1787066874304],[],[164],"6d7cc32c-5d18-4735-aac6-88ef61dd0f7d","SubmissionsPage.tsx","01a0157c-7a0e-76a8-9d6f-c157ad5287e3",["D",1787066874304],"/** @jsxImportSource npm:hono/jsx */\nimport type { Submission } from \"../db.ts\";\nimport Layout from \"./Layout.tsx\";\n\nexport default function SubmissionsPage({ submissions }: { submissions: Submission[] }) {\n return (\n \n

Submissions ({submissions.length})

\n {submissions.length === 0\n ?

Nothing yet. Be the first to submit the form.

\n : (\n

\n
\n {s.name}\n {s.created_at}\n
\n
{s.email}
\n
{s.message}
\n

\n )}\n

\n back to form\n view source\n

\n \n );\n}\n",[],[170,203],"d5c2d863-87b2-4c3a-aec1-b8133c6e2ae5","Layout.tsx","01a0157c-7a0e-76a8-9d6f-bc925064b5ed",["D",1787066874304],"/** @jsxImportSource npm:hono/jsx */\n\nexport default function Layout({ title, children }: { title: string; children?: unknown }) {\n return (\n \n \n \n \n {title}\n \n \n \n \n

{children}

\n \n \n );\n}\n",[],[170,210],"e73cf472-c272-4d79-a907-09e8466f7848","FormPage.tsx","01a0157c-7a0e-76a8-9d6f-b945b8cace71",["D",1787066874304],"/** @jsxImportSource npm:hono/jsx */\nimport Layout from \"./Layout.tsx\";\n\nexport default function FormPage() {\n return (\n \n

Contact form

\n Submissions are saved to this val's SQLite database.\n

\n \n

\n view submissions\n view source\n

\n \n );\n}\n",[],[170,217],["D",1787066874304],[186,187,188],[170],["D",1787066874304],["D",1789499469860],{"_103":102,"_110":106},{"_103":102,"_104":102,"_105":106,"_18":55,"_107":108,"_109":25},{"_13":88,"_32":89,"_43":42,"_90":44,"_91":92,"_93":94,"_95":50,"_96":97,"_98":99,"_100":45,"_101":102},"ctx",{"_81":-5,"_132":264,"_265":266,"_267":268,"_269":25,"_270":25,"_271":25,"_272":58,"_273":-5,"_274":-7,"_275":-7,"_276":62,"_277":25,"_278":25,"_279":-5,"_280":25,"_281":25,"_282":25,"_283":-5},"ENV",{"_235":236,"_237":238,"_239":89,"_240":241,"_242":243,"_244":245,"_246":247,"_248":249,"_250":251,"_252":253,"_254":255,"_256":257,"_258":259,"_260":261,"_262":263},"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 · v4