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","label","children",[72],"contentHash","bb6397384def93bac5d0b2a6cbad0f8248c881f7325f2afd7e6b1be8c98e9a53","0bcd4b7b-4987-4fd6-8d3a-452a7bd57b5c","019eb3e7-9e0e-75d5-89dd-d1cbbcb576b4",["D",1781134761362],"/** @jsxImportSource npm:hono/jsx */\nimport { parseVal } from \"https://esm.town/v/std/utils/index.ts\";\nimport { Hono } from \"npm:hono\";\nimport FormPage from \"./components/FormPage.tsx\";\nimport SubmissionsPage from \"./components/SubmissionsPage.tsx\";\nimport { addSubmission, listSubmissions } from \"./db.ts\";\n\nconst app = new Hono();\n\napp.get(\"/\", (c) => c.html());\n\napp.post(\"/submit\", async (c) => {\n const form = await c.req.formData();\n const name = String(form.get(\"name\") ?? \"\").trim();\n const email = String(form.get(\"email\") ?? \"\").trim();\n const message = String(form.get(\"message\") ?? \"\").trim();\n if (!name || !email || !message) {\n return c.text(\"Name, email, and message are all required.\", 400);\n }\n await addSubmission(name, email, message);\n return c.redirect(\"/submissions\");\n});\n\napp.get(\"/submissions\", async (c) => {\n const submissions = await listSubmissions();\n return c.html();\n});\n\napp.get(\"/source\", (c) => c.redirect(parseVal().links.self.val));\n\napp.onError((err) => Promise.reject(err));\n\nexport default app.fetch;\n",[72],"3444614cf3e968b28a07c7de8077c4c708eab1479f005f0a1bd9aa0a664fabb8","db.ts",{"_32":112,"_13":102,"_78":113,"_80":-5,"_81":33,"_82":41,"_84":26,"_34":114,"_40":22,"_87":108,"_89":115,"_65":48,"_91":-5,"_92":-7,"_71":116,"_94":117},{"_32":105,"_13":102,"_78":106,"_80":-5,"_81":58,"_82":86,"_84":26,"_34":107,"_40":41,"_87":108,"_89":109,"_65":48,"_91":-5,"_92":-7,"_71":110,"_94":111},"53254fea-c879-4c8d-8f86-ed19b333a67f","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",[102],"6e1d2655042c911deb1d8a40a905c20bb3e7e525de3cc89daffb45a86e83984a","de425f0c-092f-42c8-85b0-92ccf1f6de9b","019eb3e7-9e0e-75d5-89dd-cc01edb75581",["D",1781134761362],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport interface Submission {\n id: number;\n name: string;\n email: string;\n message: string;\n created_at: string;\n}\n\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS submissions (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT NOT NULL,\n email TEXT NOT NULL,\n message TEXT NOT NULL,\n created_at TEXT NOT NULL DEFAULT (datetime('now'))\n)`);\n\nexport async function addSubmission(name: string, email: string, message: string) {\n await sqlite.execute({\n sql: \"INSERT INTO submissions (name, email, message) VALUES (?, ?, ?)\",\n args: [name, email, message],\n });\n}\n\nexport async function listSubmissions(): Promise {\n const result = await sqlite.execute(\n \"SELECT id, name, email, message, created_at FROM submissions ORDER BY id DESC\",\n );\n return result.rows as unknown as Submission[];\n}\n",[102],"c2c07edcd11f5670074bbc6a45b0a56e4af7c5b69a64dfaf3e4c833eccc17ecd",{"_71":128,"_73":-7,"_75":129},{"_71":120,"_73":-7,"_75":121},"selftest.ts",{"_32":122,"_13":120,"_78":123,"_80":-5,"_81":58,"_82":20,"_84":26,"_34":124,"_40":22,"_87":108,"_89":125,"_65":48,"_91":-5,"_92":-7,"_71":126,"_94":127},"3d0118d6-6033-4174-93ff-51075a74c14c","a08d8b60-9b1b-11f1-8101-1607ee4eb77e",["D",1787067838518],"const base = \"https://togethr-beta-relay.val.run\";\n\nfunction assert(condition: unknown, message: string): asserts condition {\n if (!condition) throw new Error(message);\n}\n\nasync function jsonRequest(path: string, init?: RequestInit) {\n const response = await fetch(`${base}${path}`, init);\n const body = await response.json().catch(() => ({}));\n return { response, body };\n}\n\nconst suffix = Date.now().toString().slice(-6);\nconst hostCreate = await jsonRequest(\"/v1/devices\", { method: \"POST\", headers: { \"content-type\": \"application/json\" }, body: JSON.stringify({ displayName: `Selftest Host ${suffix}` }) });\nassert(hostCreate.response.status === 201, `host device status ${hostCreate.response.status}`);\nconst friendCreate = await jsonRequest(\"/v1/devices\", { method: \"POST\", headers: { \"content-type\": \"application/json\" }, body: JSON.stringify({ displayName: `Selftest Friend ${suffix}` }) });\nassert(friendCreate.response.status === 201, `friend device status ${friendCreate.response.status}`);\n\nconst host = hostCreate.body.device;\nconst friend = friendCreate.body.device;\nconst hostHeaders = { \"content-type\": \"application/json\", \"x-togethr-device\": host.id, authorization: `Bearer ${host.token}` };\nconst friendHeaders = { \"content-type\": \"application/json\", \"x-togethr-device\": friend.id, authorization: `Bearer ${friend.token}` };\n\nconst inviteCreate = await jsonRequest(\"/v1/invites\", { method: \"POST\", headers: hostHeaders, body: JSON.stringify({ relationType: \"Gym buddy\" }) });\nassert(inviteCreate.response.status === 201, `invite create status ${inviteCreate.response.status}`);\nconst code = inviteCreate.body.invite.code;\n\nconst preview = await jsonRequest(`/v1/invites/${code}`);\nassert(preview.response.status === 200, `preview status ${preview.response.status}`);\nassert(preview.body.invite.creatorName === `Selftest Host ${suffix}`, \"preview creator mismatch\");\n\nconst accept = await jsonRequest(`/v1/invites/${code}/accept`, { method: \"POST\", headers: friendHeaders, body: \"{}\" });\nassert(accept.response.status === 201, `accept status ${accept.response.status}: ${JSON.stringify(accept.body)}`);\nconst connection = accept.body.connection;\nassert(connection?.peer?.displayName === `Selftest Host ${suffix}`, \"friend peer mismatch\");\n\nconst hostConnections = await jsonRequest(\"/v1/connections\", { headers: hostHeaders });\nassert(hostConnections.response.status === 200, `host connections status ${hostConnections.response.status}`);\nassert(hostConnections.body.connections?.some((item: any) => item.id === connection.id && item.peer.displayName === `Selftest Friend ${suffix}`), \"host connection missing\");\n\nconst initialState = { status: \"live\", participants: [\"a\", \"b\"], currentExerciseId: \"bench\", activeUserId: \"a\", exercises: [{ id: \"bench\", name: \"Bench\", sets: 4, targetReps: \"8\", restSeconds: 75 }], logs: [] };\nconst sessionCreate = await jsonRequest(\"/v1/sessions\", { method: \"POST\", headers: hostHeaders, body: JSON.stringify({ connectionId: connection.id, title: \"Selftest Push\", initialState }) });\nassert(sessionCreate.response.status === 201, `session create status ${sessionCreate.response.status}: ${JSON.stringify(sessionCreate.body)}`);\nconst sessionId = sessionCreate.body.session.id;\n\nconst active = await jsonRequest(`/v1/sessions/active?connectionId=${encodeURIComponent(connection.id)}`, { headers: friendHeaders });\nassert(active.response.status === 200 && active.body.session?.id === sessionId, \"friend cannot see active session\");\n\nconst nextState = { ...initialState, activeUserId: \"b\", logs: [{ userId: \"a\", exerciseId: \"bench\", setNumber: 1, weight: 95, reps: 8 }] };\nconst event = await jsonRequest(`/v1/sessions/${sessionId}/events`, { method: \"POST\", headers: hostHeaders, body: JSON.stringify({ eventId: `selftest-${suffix}`, type: \"snapshot\", payload: nextState }) });\nassert(event.response.status === 201, `event status ${event.response.status}`);\n\nconst events = await jsonRequest(`/v1/sessions/${sessionId}/events?after=0`, { headers: friendHeaders });\nassert(events.response.status === 200, `events read status ${events.response.status}`);\nassert(events.body.events?.some((item: any) => item.type === \"snapshot\" && item.payload?.logs?.[0]?.weight === 95), \"friend snapshot missing\");\n\nconst finish = await jsonRequest(`/v1/sessions/${sessionId}/finish`, { method: \"POST\", headers: hostHeaders, body: \"{}\" });\nassert(finish.response.status === 200, `finish status ${finish.response.status}`);\n\nconsole.log(JSON.stringify({ ok: true, checks: 10, connectionId: connection.id, sessionId }));\n",[120],"cc0ac6d1220131220ecc9c4a18d2509c8ea1f798cfea329a7d072643e4641fd6","selftest-spotter.ts",{"_32":130,"_13":128,"_78":131,"_80":-5,"_81":58,"_82":57,"_84":26,"_34":132,"_40":22,"_87":108,"_89":133,"_65":48,"_91":-5,"_92":-7,"_71":134,"_94":135},"3695b0bd-c788-4707-89b3-347af3472311","c4fe25d8-9b32-11f1-86e1-1607ee4eb77e",["D",1787077778057],"const base = \"https://togethr-beta-relay.val.run\";\nfunction assert(condition: unknown, message: string): asserts condition { if (!condition) throw new Error(message); }\nasync function req(path: string, init?: RequestInit) { const response = await fetch(`${base}${path}`, init); const body = await response.json().catch(() => ({})); return { response, body }; }\nconst suffix = Date.now().toString().slice(-6);\nconst hostR = await req(\"/v1/devices\", { method: \"POST\", headers: { \"content-type\": \"application/json\" }, body: JSON.stringify({ displayName: `Spot Host ${suffix}` }) });\nconst friendR = await req(\"/v1/devices\", { method: \"POST\", headers: { \"content-type\": \"application/json\" }, body: JSON.stringify({ displayName: `Spot Friend ${suffix}` }) });\nassert(hostR.response.status === 201 && friendR.response.status === 201, \"device create failed\");\nconst host = hostR.body.device; const friend = friendR.body.device;\nconst hh = { \"content-type\": \"application/json\", \"x-togethr-device\": host.id, authorization: `Bearer ${host.token}` };\nconst fh = { \"content-type\": \"application/json\", \"x-togethr-device\": friend.id, authorization: `Bearer ${friend.token}` };\nconst inviteR = await req(\"/v1/invites\", { method: \"POST\", headers: hh, body: JSON.stringify({ relationType: \"Gym buddy\" }) });\nassert(inviteR.response.status === 201, \"invite failed\");\nconst acceptR = await req(`/v1/invites/${inviteR.body.invite.code}/accept`, { method: \"POST\", headers: fh, body: \"{}\" });\nassert(acceptR.response.status === 201, \"accept failed\");\nconst connectionId = acceptR.body.connection.id;\nconst state = { id: `spot-session-${suffix}`, title: \"Spot Test\", participants: [\"a\", \"b\"], activeUserId: \"a\", currentExerciseId: \"bench\", status: \"live\", exercises: [{ id: \"bench\", name: \"Barbell Bench Press\", sets: 4, targetReps: \"6-10\", restSeconds: 90, userOverrides: {} }], logs: [] };\nconst sessionR = await req(\"/v1/sessions\", { method: \"POST\", headers: hh, body: JSON.stringify({ connectionId, title: \"Spot Test\", initialState: state }) });\nassert(sessionR.response.status === 201, \"session failed\");\nconst sessionId = sessionR.body.session.id;\nconst spot = { id: `spot-${suffix}`, requesterId: \"a\", spotterId: \"b\", exerciseId: \"bench\", exerciseName: \"Barbell Bench Press\", setNumber: 2, stage: \"ready\", requestedAt: new Date().toISOString(), updatedAt: new Date().toISOString() };\nconst pushR = await req(`/v1/sessions/${sessionId}/events`, { method: \"POST\", headers: fh, body: JSON.stringify({ type: \"ready\", payload: spot }) });\nassert(pushR.response.status === 201, `ready event rejected ${pushR.response.status}`);\nconst eventsR = await req(`/v1/sessions/${sessionId}/events?after=0`, { headers: hh });\nassert(eventsR.response.status === 200, \"event read failed\");\nconst found = eventsR.body.events?.find((event: any) => event.type === \"ready\" && event.payload?.id === spot.id && event.payload?.stage === \"ready\");\nassert(found, \"spotter ready event missing\");\nconsole.log(JSON.stringify({ ok: true, checks: 7, eventType: found.type, stage: found.payload.stage }));",[128],"a1d61bb47f8b0d84a070d00967928850164ea438181adcb5775f1ab69b0eece6",["D",1787066874304],"legacyEnvVars","httpPrivacy","description","Togethr beta invite and session relay","imageUrl","userId","bdda9a4c-13e6-4481-b3c2-7ac3d6eab867","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","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",{"_11":12,"_177":173},"org",{"_11":12,"_171":12,"_172":173,"_142":143,"_174":175,"_176":48},"branch","displayName","avatar","https://lh3.googleusercontent.com/a/ACg8ocIDM6L3j1I5a-9KRxESWnU76mLAa66fJBhefbGOknwGZXzF-g=s96-c","tier","free","canRestrictVals","profileImageUrl","","adoptOrgId",{"_32":59,"_13":14,"_34":287,"_46":-5,"_137":48,"_49":50,"_138":50,"_139":140,"_141":-5,"_142":143,"_144":79,"_145":26,"_146":-5,"_147":-5,"_148":22,"_53":149,"_150":151,"_152":153,"_154":288,"_156":-5,"_157":158,"_159":158,"_160":161,"_162":161,"_163":161,"_164":158,"_165":158,"_166":289,"_168":290,"_170":291,"_47":48},"tree",[243,247,248,249,250,251],"files",[243,244,245,246,247,248,249,250,251],"counts",{"_233":22,"_234":41,"_235":22,"_236":237,"_238":239},"contents",[207,208,209,210,211,212],"file","upstreamProject",{"_32":39,"_13":56,"_139":204,"_141":-5,"_49":50,"_166":205},"upstreamBranch",{"_32":33,"_34":202,"_36":203,"_13":16,"_38":39,"_40":41,"_42":-5,"_43":-5,"_44":45,"_46":-5,"_47":48,"_49":50,"_51":52,"_53":54,"_55":56},"emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1781134761362],["D",1781134761362],"Put a form online and save submissions to SQLite",{"_11":52,"_177":206},"https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/129cab32-3bd7-4c3e-f39b-f12900c76100/square512?exp=1789552799&sig=d49f90d93e120483cdf15d03d3545ffc812712f79bb9ed726650e50aa3216f06",{"_32":227,"_13":228,"_78":229,"_80":-5,"_81":58,"_82":41,"_84":26,"_34":230,"_40":22,"_87":231,"_89":-5,"_65":48,"_91":-5,"_71":232},{"_32":221,"_13":222,"_78":223,"_80":-5,"_81":58,"_82":41,"_84":26,"_34":224,"_40":22,"_87":189,"_89":225,"_65":48,"_91":-5,"_71":226},{"_32":105,"_13":102,"_78":106,"_80":-5,"_81":58,"_82":86,"_84":26,"_34":219,"_40":41,"_87":108,"_89":109,"_65":48,"_91":-5,"_71":220},{"_32":77,"_13":72,"_78":79,"_80":-5,"_81":58,"_82":83,"_84":26,"_34":217,"_40":86,"_87":88,"_89":90,"_65":48,"_91":14,"_71":218},{"_32":130,"_13":128,"_78":131,"_80":-5,"_81":58,"_82":57,"_84":26,"_34":215,"_40":22,"_87":108,"_89":133,"_65":48,"_91":-5,"_71":216},{"_32":122,"_13":120,"_78":123,"_80":-5,"_81":58,"_82":20,"_84":26,"_34":213,"_40":22,"_87":108,"_89":125,"_65":48,"_91":-5,"_71":214},["D",1787067838518],[120],["D",1787077778057],[128],["D",1787067299119],[72],["D",1787067080726],[102],"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",[222],"2aa5abda-6cb8-4e95-8170-67c8bdffc208","components","01a0157c-7a0e-76a8-9d6f-c6e8f43f6e8b",["D",1787066874304],"directory",[228],"pulls","branches","forks","envVars",{"_240":22,"_242":22},"connections",{"_240":22,"_241":22},"count","unfilledCount","emptyCount",{"_32":227,"_13":228,"_78":229,"_80":-5,"_81":58,"_82":41,"_84":26,"_34":284,"_40":22,"_87":231,"_89":-5,"_65":48,"_91":-5,"_92":285,"_71":286},{"_32":277,"_13":278,"_78":279,"_80":229,"_81":58,"_82":41,"_84":26,"_34":280,"_40":22,"_87":108,"_89":281,"_65":48,"_91":-5,"_92":282,"_71":283},{"_32":270,"_13":271,"_78":272,"_80":229,"_81":58,"_82":41,"_84":26,"_34":273,"_40":22,"_87":108,"_89":274,"_65":48,"_91":-5,"_92":275,"_71":276},{"_32":263,"_13":264,"_78":265,"_80":229,"_81":58,"_82":41,"_84":26,"_34":266,"_40":22,"_87":108,"_89":267,"_65":48,"_91":-5,"_92":268,"_71":269},{"_32":221,"_13":222,"_78":223,"_80":-5,"_81":58,"_82":41,"_84":26,"_34":260,"_40":22,"_87":189,"_89":225,"_65":48,"_91":-5,"_92":261,"_71":262},{"_32":105,"_13":102,"_78":106,"_80":-5,"_81":58,"_82":86,"_84":26,"_34":107,"_40":41,"_87":108,"_89":109,"_65":48,"_91":-5,"_92":258,"_71":259},{"_32":77,"_13":72,"_78":79,"_80":-5,"_81":58,"_82":83,"_84":26,"_34":85,"_40":86,"_87":88,"_89":90,"_65":48,"_91":14,"_92":256,"_71":257},{"_32":130,"_13":128,"_78":131,"_80":-5,"_81":58,"_82":57,"_84":26,"_34":132,"_40":22,"_87":108,"_89":133,"_65":48,"_91":-5,"_92":254,"_71":255},{"_32":122,"_13":120,"_78":123,"_80":-5,"_81":58,"_82":20,"_84":26,"_34":124,"_40":22,"_87":108,"_89":125,"_65":48,"_91":-5,"_92":252,"_71":253},[],[120],[],[128],[],[72],[],[102],["D",1787066874304],[],[222],"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",[],[228,264],"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",[],[228,271],"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",[],[228,278],["D",1787066874304],[244,245,246],[228],["D",1787066874304],["D",1789499469860],{"_11":12,"_177":173},{"_11":12,"_171":12,"_172":173,"_142":143,"_174":175,"_176":48},{"_40":57,"_13":16,"_32":58,"_38":59,"_42":33,"_43":41,"_60":50,"_61":39,"_62":54,"_55":14,"_51":12},"ctx",{"_166":-5,"_199":325,"_326":327,"_328":329,"_330":48,"_331":48,"_332":48,"_333":26,"_334":-5,"_335":-7,"_336":-7,"_337":22,"_338":48,"_339":48,"_340":-5,"_341":48,"_342":48,"_343":48,"_344":-5},"ENV",{"_296":297,"_298":299,"_300":16,"_301":302,"_303":304,"_305":306,"_307":308,"_309":310,"_311":312,"_313":314,"_315":316,"_317":318,"_319":320,"_321":322,"_323":324},"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"]

Compare

Mergemanas/mainintotemplates/main

db.ts+115-22

Hmain.tsx+120-23

selftest-spotter.ts+27-0

selftest.ts+60-0