[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_211":212,"_213":214},"routes/_app.x.$handle.$name",{"_100":99,"_32":45,"_109":90,"_27":110,"_13":14,"_111":-5,"_11":112,"_113":114,"_115":116,"_117":118,"_119":120,"_20":-5,"_121":-5,"_122":-5,"_123":25,"_124":125,"_126":59,"_127":-5,"_128":-5,"_129":130},"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":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":25},"version",20,"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","db.ts","latestPath","fileId","71bc05b8-80fa-11f1-94d2-1607ee4eb77e","name","fileType","script","content","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport const INQUIRY_STATUSES = [\n \"new\",\n \"contacted\",\n \"in_progress\",\n \"closed\",\n] as const;\n\nexport type InquiryStatus = (typeof INQUIRY_STATUSES)[number];\nexport type EmailState = \"pending\" | \"sending\" | \"accepted\" | \"failed\";\n\nexport interface Inquiry {\n id: string;\n idempotency_key: string;\n created_at: string;\n updated_at: string;\n name: string;\n organisation: string;\n email: string;\n message: string;\n status: InquiryStatus;\n notes: string;\n confirmation_state: EmailState;\n notification_state: EmailState;\n}\n\nexport interface EmailJob {\n id: string;\n inquiry_id: string;\n kind: \"confirmation\" | \"notification\";\n recipient: string;\n state: EmailState;\n attempt_count: number;\n last_error: string | null;\n inquiry: Inquiry;\n}\n\nexport interface NewInquiry {\n id: string;\n idempotencyKey: string;\n name: string;\n organisation: string;\n email: string;\n message: string;\n}\n\nexport async function initDb() {\n await sqlite.batch([\n `CREATE TABLE IF NOT EXISTS partner_inquiries (\n id TEXT PRIMARY KEY,\n idempotency_key TEXT NOT NULL UNIQUE,\n created_at TEXT NOT NULL DEFAULT (datetime('now')),\n updated_at TEXT NOT NULL DEFAULT (datetime('now')),\n name TEXT NOT NULL,\n organisation TEXT NOT NULL,\n email TEXT NOT NULL,\n message TEXT NOT NULL,\n status TEXT NOT NULL DEFAULT 'new'\n CHECK (status IN ('new', 'contacted', 'in_progress', 'closed')),\n notes TEXT NOT NULL DEFAULT ''\n )`,\n `CREATE TABLE IF NOT EXISTS partner_email_outbox (\n id TEXT PRIMARY KEY,\n inquiry_id TEXT NOT NULL,\n kind TEXT NOT NULL CHECK (kind IN ('confirmation', 'notification')),\n recipient TEXT NOT NULL,\n state TEXT NOT NULL DEFAULT 'pending'\n CHECK (state IN ('pending', 'sending', 'accepted', 'failed')),\n attempt_count INTEGER NOT NULL DEFAULT 0,\n next_attempt_at TEXT NOT NULL DEFAULT (datetime('now')),\n accepted_at TEXT,\n last_error TEXT,\n created_at TEXT NOT NULL DEFAULT (datetime('now')),\n updated_at TEXT NOT NULL DEFAULT (datetime('now')),\n FOREIGN KEY (inquiry_id) REFERENCES partner_inquiries(id),\n UNIQUE (inquiry_id, kind)\n )`,\n `CREATE INDEX IF NOT EXISTS partner_inquiries_created_at\n ON partner_inquiries(created_at DESC)`,\n `CREATE INDEX IF NOT EXISTS partner_email_outbox_pending\n ON partner_email_outbox(state, next_attempt_at)`,\n `UPDATE partner_email_outbox\n SET state = 'failed', next_attempt_at = datetime('now'),\n last_error = 'Delivery attempt timed out and was queued again',\n updated_at = datetime('now')\n WHERE state = 'sending'\n AND updated_at <= datetime('now', '-15 minutes')`,\n ]);\n}\n\nexport async function findInquiryByIdempotencyKey(key: string) {\n const result = await sqlite.execute({\n sql: `SELECT id FROM partner_inquiries WHERE idempotency_key = ? LIMIT 1`,\n args: [key],\n });\n return result.rows[0] as { id: string } | undefined;\n}\n\nexport async function checkSubmissionLimit(email: string) {\n const [globalResult, recipientResult] = await Promise.all([\n sqlite.execute(\n `SELECT COUNT(*) AS count FROM partner_inquiries\n WHERE created_at >= datetime('now', '-1 hour')`,\n ),\n sqlite.execute({\n sql: `SELECT COUNT(*) AS count FROM partner_inquiries\n WHERE email = ? AND created_at >= datetime('now', '-15 minutes')`,\n args: [email],\n }),\n ]);\n\n const globalCount = Number((globalResult.rows[0] as { count: number }).count);\n const recipientCount = Number(\n (recipientResult.rows[0] as { count: number }).count,\n );\n\n return {\n allowed: globalCount < 20 && recipientCount < 2,\n reason: globalCount >= 20 ? \"global\" : \"recipient\",\n };\n}\n\nexport async function createInquiry(input: NewInquiry) {\n await sqlite.batch([\n {\n sql: `INSERT INTO partner_inquiries\n (id, idempotency_key, name, organisation, email, message)\n VALUES (?, ?, ?, ?, ?, ?)`,\n args: [\n input.id,\n input.idempotencyKey,\n input.name,\n input.organisation,\n input.email,\n input.message,\n ],\n },\n {\n sql: `INSERT INTO partner_email_outbox\n (id, inquiry_id, kind, recipient)\n VALUES (?, ?, 'confirmation', ?)`,\n args: [`${input.id}:confirmation`, input.id, input.email],\n },\n {\n sql: `INSERT INTO partner_email_outbox\n (id, inquiry_id, kind, recipient)\n VALUES (?, ?, 'notification', 'mail@livingstoriescollective.org')`,\n args: [`${input.id}:notification`, input.id],\n },\n ]);\n}\n\nconst INQUIRY_SELECT = `\n SELECT\n i.*,\n COALESCE(MAX(CASE WHEN o.kind = 'confirmation' THEN o.state END), 'pending')\n AS confirmation_state,\n COALESCE(MAX(CASE WHEN o.kind = 'notification' THEN o.state END), 'pending')\n AS notification_state\n FROM partner_inquiries i\n LEFT JOIN partner_email_outbox o ON o.inquiry_id = i.id\n`;\n\nexport async function listInquiries(limit = 100): Promise {\n const result = await sqlite.execute({\n sql: `${INQUIRY_SELECT}\n GROUP BY i.id\n ORDER BY i.created_at DESC\n LIMIT ?`,\n args: [limit],\n });\n return result.rows as unknown as Inquiry[];\n}\n\nexport async function getInquiry(id: string): Promise {\n const result = await sqlite.execute({\n sql: `${INQUIRY_SELECT}\n WHERE i.id = ?\n GROUP BY i.id\n LIMIT 1`,\n args: [id],\n });\n return result.rows[0] as unknown as Inquiry | undefined;\n}\n\nexport async function updateInquiry(\n id: string,\n status: InquiryStatus,\n notes: string,\n) {\n await sqlite.execute({\n sql: `UPDATE partner_inquiries\n SET status = ?, notes = ?, updated_at = datetime('now')\n WHERE id = ?`,\n args: [status, notes, id],\n });\n}\n\nexport async function listReadyEmailJobs(limit = 10): Promise {\n const result = await sqlite.execute({\n sql: `SELECT\n o.id, o.inquiry_id, o.kind, o.recipient, o.state,\n o.attempt_count, o.last_error,\n json_object(\n 'id', i.id,\n 'idempotency_key', i.idempotency_key,\n 'created_at', i.created_at,\n 'updated_at', i.updated_at,\n 'name', i.name,\n 'organisation', i.organisation,\n 'email', i.email,\n 'message', i.message,\n 'status', i.status,\n 'notes', i.notes,\n 'confirmation_state', 'pending',\n 'notification_state', 'pending'\n ) AS inquiry_json\n FROM partner_email_outbox o\n JOIN partner_inquiries i ON i.id = o.inquiry_id\n WHERE o.state IN ('pending', 'failed')\n AND o.next_attempt_at <= datetime('now')\n AND o.attempt_count < 5\n ORDER BY o.created_at ASC\n LIMIT ?`,\n args: [limit],\n });\n\n return result.rows.map((row) => {\n const raw = row as Record & { inquiry_json: string };\n const { inquiry_json, ...job } = raw;\n return { ...job, inquiry: JSON.parse(inquiry_json) } as EmailJob;\n });\n}\n\nexport async function markEmailSending(id: string) {\n const result = await sqlite.execute({\n sql: `UPDATE partner_email_outbox\n SET state = 'sending', attempt_count = attempt_count + 1,\n updated_at = datetime('now')\n WHERE id = ? AND state IN ('pending', 'failed')`,\n args: [id],\n });\n return result.rowsAffected > 0;\n}\n\nexport async function markEmailAccepted(id: string) {\n await sqlite.execute({\n sql: `UPDATE partner_email_outbox\n SET state = 'accepted', accepted_at = datetime('now'),\n last_error = NULL, updated_at = datetime('now')\n WHERE id = ?`,\n args: [id],\n });\n}\n\nexport async function markEmailFailed(id: string, error: string) {\n await sqlite.execute({\n sql: `UPDATE partner_email_outbox\n SET state = 'failed', last_error = ?,\n next_attempt_at = datetime('now', '+' || MIN(attempt_count * 5, 60) || ' minutes'),\n updated_at = datetime('now')\n WHERE id = ?`,\n args: [error.slice(0, 500), id],\n });\n}\n","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport const INQUIRY_STATUSES = [\n \"new\",\n \"contacted\",\n \"in_progress\",\n \"closed\",\n] as const;\n\nexport type InquiryStatus = (typeof INQUIRY_STATUSES)[number];\nexport type EmailState = \"pending\" | \"sending\" | \"accepted\" | \"failed\";\n\nexport interface Inquiry {\n id: string;\n idempotency_key: string;\n created_at: string;\n updated_at: string;\n name: string;\n organisation: string;\n email: string;\n message: string;\n status: InquiryStatus;\n notes: string;\n confirmation_state: EmailState;\n notification_state: EmailState;\n}\n\nexport interface EmailJob {\n id: string;\n inquiry_id: string;\n kind: \"confirmation\" | \"notification\";\n recipient: string;\n state: EmailState;\n attempt_count: number;\n last_error: string | null;\n inquiry: Inquiry;\n}\n\nexport interface NewInquiry {\n id: string;\n idempotencyKey: string;\n name: string;\n organisation: string;\n email: string;\n message: string;\n}\n\nexport async function initDb() {\n await sqlite.batch([\n `CREATE TABLE IF NOT EXISTS partner_inquiries (\n id TEXT PRIMARY KEY,\n idempotency_key TEXT NOT NULL UNIQUE,\n created_at TEXT NOT NULL DEFAULT (datetime('now')),\n updated_at TEXT NOT NULL DEFAULT (datetime('now')),\n name TEXT NOT NULL,\n organisation TEXT NOT NULL,\n email TEXT NOT NULL,\n message TEXT NOT NULL,\n status TEXT NOT NULL DEFAULT 'new'\n CHECK (status IN ('new', 'contacted', 'in_progress', 'closed')),\n notes TEXT NOT NULL DEFAULT ''\n )`,\n `CREATE TABLE IF NOT EXISTS partner_email_outbox (\n id TEXT PRIMARY KEY,\n inquiry_id TEXT NOT NULL,\n kind TEXT NOT NULL CHECK (kind IN ('confirmation', 'notification')),\n recipient TEXT NOT NULL,\n state TEXT NOT NULL DEFAULT 'pending'\n CHECK (state IN ('pending', 'sending', 'accepted', 'failed')),\n attempt_count INTEGER NOT NULL DEFAULT 0,\n next_attempt_at TEXT NOT NULL DEFAULT (datetime('now')),\n accepted_at TEXT,\n last_error TEXT,\n created_at TEXT NOT NULL DEFAULT (datetime('now')),\n updated_at TEXT NOT NULL DEFAULT (datetime('now')),\n FOREIGN KEY (inquiry_id) REFERENCES partner_inquiries(id),\n UNIQUE (inquiry_id, kind)\n )`,\n `CREATE INDEX IF NOT EXISTS partner_inquiries_created_at\n ON partner_inquiries(created_at DESC)`,\n `CREATE INDEX IF NOT EXISTS partner_email_outbox_pending\n ON partner_email_outbox(state, next_attempt_at)`,\n `UPDATE partner_email_outbox\n SET state = 'failed', next_attempt_at = datetime('now'),\n last_error = 'Delivery attempt timed out and was queued again',\n updated_at = datetime('now')\n WHERE state = 'sending'\n AND updated_at <= datetime('now', '-15 minutes')`,\n ], \"write\");\n}\n\nexport async function findInquiryByIdempotencyKey(key: string) {\n const result = await sqlite.execute({\n sql: `SELECT id FROM partner_inquiries WHERE idempotency_key = ? LIMIT 1`,\n args: [key],\n });\n return result.rows[0] as { id: string } | undefined;\n}\n\nexport async function createInquiry(input: NewInquiry) {\n const results = await sqlite.batch([\n {\n sql: `INSERT INTO partner_inquiries\n (id, idempotency_key, name, organisation, email, message)\n SELECT ?, ?, ?, ?, ?, ?\n WHERE (SELECT COUNT(*) FROM partner_inquiries\n WHERE created_at >= datetime('now', '-1 hour')) < 20\n AND (SELECT COUNT(*) FROM partner_inquiries\n WHERE email = ?\n AND created_at >= datetime('now', '-15 minutes')) < 2\n ON CONFLICT(idempotency_key) DO NOTHING`,\n args: [\n input.id,\n input.idempotencyKey,\n input.name,\n input.organisation,\n input.email,\n input.message,\n input.email,\n ],\n },\n {\n sql: `INSERT INTO partner_email_outbox\n (id, inquiry_id, kind, recipient)\n SELECT ?, id, 'confirmation', email\n FROM partner_inquiries WHERE id = ?`,\n args: [`${input.id}:confirmation`, input.id],\n },\n {\n sql: `INSERT INTO partner_email_outbox\n (id, inquiry_id, kind, recipient)\n SELECT ?, id, 'notification', 'mail@livingstoriescollective.org'\n FROM partner_inquiries WHERE id = ?`,\n args: [`${input.id}:notification`, input.id],\n },\n ], \"write\");\n\n return results[0].rowsAffected === 1;\n}\n\nconst INQUIRY_SELECT = `\n SELECT\n i.*,\n COALESCE(MAX(CASE WHEN o.kind = 'confirmation' THEN o.state END), 'pending')\n AS confirmation_state,\n COALESCE(MAX(CASE WHEN o.kind = 'notification' THEN o.state END), 'pending')\n AS notification_state\n FROM partner_inquiries i\n LEFT JOIN partner_email_outbox o ON o.inquiry_id = i.id\n`;\n\nexport async function listInquiries(limit = 100): Promise {\n const result = await sqlite.execute({\n sql: `${INQUIRY_SELECT}\n GROUP BY i.id\n ORDER BY i.created_at DESC\n LIMIT ?`,\n args: [limit],\n });\n return result.rows as unknown as Inquiry[];\n}\n\nexport async function getInquiry(id: string): Promise {\n const result = await sqlite.execute({\n sql: `${INQUIRY_SELECT}\n WHERE i.id = ?\n GROUP BY i.id\n LIMIT 1`,\n args: [id],\n });\n return result.rows[0] as unknown as Inquiry | undefined;\n}\n\nexport async function updateInquiry(\n id: string,\n status: InquiryStatus,\n notes: string,\n) {\n await sqlite.execute({\n sql: `UPDATE partner_inquiries\n SET status = ?, notes = ?, updated_at = datetime('now')\n WHERE id = ?`,\n args: [status, notes, id],\n });\n}\n\nexport async function listReadyEmailJobs(limit = 10): Promise {\n const result = await sqlite.execute({\n sql: `SELECT\n o.id, o.inquiry_id, o.kind, o.recipient, o.state,\n o.attempt_count, o.last_error,\n json_object(\n 'id', i.id,\n 'idempotency_key', i.idempotency_key,\n 'created_at', i.created_at,\n 'updated_at', i.updated_at,\n 'name', i.name,\n 'organisation', i.organisation,\n 'email', i.email,\n 'message', i.message,\n 'status', i.status,\n 'notes', i.notes,\n 'confirmation_state', 'pending',\n 'notification_state', 'pending'\n ) AS inquiry_json\n FROM partner_email_outbox o\n JOIN partner_inquiries i ON i.id = o.inquiry_id\n WHERE o.state IN ('pending', 'failed')\n AND o.next_attempt_at <= datetime('now')\n AND o.attempt_count < 5\n ORDER BY o.created_at ASC\n LIMIT ?`,\n args: [limit],\n });\n\n return result.rows.map((row) => {\n const raw = row as Record & { inquiry_json: string };\n const { inquiry_json, ...job } = raw;\n return { ...job, inquiry: JSON.parse(inquiry_json) } as EmailJob;\n });\n}\n\nexport async function claimEmailJob(id: string) {\n const result = await sqlite.execute({\n sql: `UPDATE partner_email_outbox\n SET state = 'sending', attempt_count = attempt_count + 1,\n updated_at = datetime('now')\n WHERE id = ? AND state IN ('pending', 'failed')\n AND next_attempt_at <= datetime('now')\n AND attempt_count < 5\n RETURNING attempt_count`,\n args: [id],\n });\n const row = result.rows[0] as { attempt_count: number } | undefined;\n return row ? Number(row.attempt_count) : null;\n}\n\nexport async function markEmailAccepted(id: string, attempt: number) {\n await sqlite.execute({\n sql: `UPDATE partner_email_outbox\n SET state = 'accepted', accepted_at = datetime('now'),\n last_error = NULL, updated_at = datetime('now')\n WHERE id = ? AND state = 'sending' AND attempt_count = ?`,\n args: [id, attempt],\n });\n}\n\nexport async function markEmailFailed(id: string, attempt: number, error: string) {\n await sqlite.execute({\n sql: `UPDATE partner_email_outbox\n SET state = 'failed', last_error = ?,\n next_attempt_at = datetime('now', '+' || MIN(attempt_count * 5, 60) || ' minutes'),\n updated_at = datetime('now')\n WHERE id = ? AND state = 'sending' AND attempt_count = ?`,\n args: [error.slice(0, 500), id, attempt],\n });\n}\n","createdAt",["D",1784198241938],"branchVersion","branchId","ab7875ae-3c8b-4743-8e00-88a2efe12f64","id","6f61e858-0df2-4c89-a4bf-9274b57bf27a","partner-inquiries",["D",1784194854385],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Partner inquiry intake and dashboard","imageUrl","3ee322c5-8742-48e0-86c7-5f3ae129683b","pinnedFileId","71c0e506-80fa-11f1-9373-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","f427167a-3263-4778-81d8-f79626323ff5","tursoName","6f61e8580df24c89a4bf9274b57bf27a","tursoHostname","6f61e8580df24c89a4bf9274b57bf27a-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789525843977],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_100":99,"_108":104},"org",{"_100":99,"_101":102,"_103":104,"_18":55,"_105":106,"_107":25},"branch",{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"isOwned",42,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","kamalnrf","handle","displayName","Kamal","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yaVpXT3l1d2hWSFdtWTNoZFIwZ0lFUUhOd2oifQ","tier","pro","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":206,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":207,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":208,"_84":209,"_86":210,"_88":25},"tree",[185,186,187,188,189],"files",[185,186,187,188,189],"counts",{"_174":63,"_175":176,"_177":63,"_178":179,"_180":181},"contents",[131,132,133,134,135],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":167,"_32":168,"_30":169,"_139":-5,"_41":42,"_40":170,"_141":25,"_38":171,"_13":63,"_33":34,"_35":172,"_24":25,"_146":-5,"_27":173},{"_43":164,"_32":28,"_30":31,"_139":-5,"_41":42,"_40":14,"_141":59,"_38":165,"_13":143,"_33":34,"_35":37,"_24":25,"_146":-5,"_27":166},{"_43":157,"_32":158,"_30":159,"_139":-5,"_41":42,"_40":160,"_141":25,"_38":161,"_13":63,"_33":34,"_35":162,"_24":25,"_146":-5,"_27":163},{"_43":148,"_32":149,"_30":57,"_139":-5,"_41":42,"_40":150,"_141":25,"_38":151,"_13":152,"_33":153,"_35":154,"_24":25,"_146":155,"_27":156},{"_43":136,"_32":137,"_30":138,"_139":-5,"_41":42,"_40":140,"_141":59,"_38":142,"_13":143,"_33":144,"_35":145,"_24":25,"_146":-5,"_27":147},"4fb5fa36-4b12-4024-a220-18170fb4aef4","retry.cron.ts","71ca8304-80fa-11f1-89a4-1607ee4eb77e","parentId",12,"latest",["D",1784195230355],2,"interval","import { initDb } from \"./db.ts\";\nimport { deliverReadyEmails } from \"./delivery.ts\";\n\nexport default async function () {\n await initDb();\n await deliverReadyEmails(20);\n}\n","label",[137],"66592335-c992-49b1-86c3-00d4b126d7e6","index.http.tsx",19,["D",1784195901418],6,"http","/** @jsxImportSource npm:hono@4/jsx */\nimport { Hono } from \"npm:hono@4\";\nimport {\n getOAuthUserData,\n oauthMiddleware,\n} from \"https://esm.town/v/std/oauth/middleware.ts\";\nimport {\n checkSubmissionLimit,\n createInquiry,\n findInquiryByIdempotencyKey,\n initDb,\n INQUIRY_STATUSES,\n listInquiries,\n updateInquiry,\n type InquiryStatus,\n} from \"./db.ts\";\nimport { AccessDeniedPage, DashboardPage } from \"./dashboard.tsx\";\nimport { deliverReadyEmails } from \"./delivery.ts\";\n\nconst DEFAULT_ALLOWED_EMAILS = [\n \"kamalnrf@gmail.com\",\n \"mail@livingstoriescollective.org\",\n];\nconst ALLOWED_ORIGINS = new Set([\n \"https://livingstoriescollective.org\",\n \"https://www.livingstoriescollective.org\",\n \"http://localhost:4321\",\n]);\nconst EMAIL_PATTERN = /^[^\\s@]+@[^\\s@]+\\.[^\\s@]+$/;\n\nawait initDb();\n\nconst app = new Hono();\napp.onError((error) => {\n console.error(\"Partner inquiries error\", error instanceof Error ? error.message : error);\n return new Response(JSON.stringify({ error: \"Something went wrong.\" }), {\n status: 500,\n headers: { \"content-type\": \"application/json; charset=utf-8\" },\n });\n});\n\napp.use(\"*\", async (c, next) => {\n if (!c.req.path.startsWith(\"/api/\")) {\n c.header(\"Access-Control-Allow-Origin\", new URL(c.req.url).origin);\n }\n await next();\n});\n\nfunction allowedDashboardEmails() {\n const configured = Deno.env.get(\"DASHBOARD_ALLOWED_EMAILS\");\n return new Set(\n (configured ? configured.split(\",\") : DEFAULT_ALLOWED_EMAILS)\n .map((value) => value.trim().toLowerCase())\n .filter(Boolean),\n );\n}\n\nfunction html(node: unknown, status = 200) {\n return new Response(`${String(node)}`, {\n status,\n headers: {\n \"content-type\": \"text/html; charset=utf-8\",\n \"cache-control\": \"no-store\",\n \"content-security-policy\":\n \"default-src 'none'; style-src 'unsafe-inline'; form-action 'self'; base-uri 'none'; frame-ancestors 'none'\",\n \"referrer-policy\": \"no-referrer\",\n \"x-content-type-options\": \"nosniff\",\n },\n });\n}\n\nasync function requireDashboardUser(c: any, next: any) {\n const session = await getOAuthUserData(c.req.raw);\n if (!session?.user) return c.redirect(\"/auth/login\");\n\n const userEmail = session.user.email?.trim().toLowerCase() ?? \"\";\n if (!allowedDashboardEmails().has(userEmail)) {\n return html(, 403);\n }\n\n c.set(\"userEmail\", userEmail);\n await next();\n}\n\nfunction applyCors(c: any) {\n const origin = c.req.header(\"origin\");\n if (origin && ALLOWED_ORIGINS.has(origin)) {\n c.header(\"Access-Control-Allow-Origin\", origin);\n c.header(\"Access-Control-Allow-Methods\", \"POST, OPTIONS\");\n c.header(\"Access-Control-Allow-Headers\", \"Content-Type\");\n c.header(\"Vary\", \"Origin\");\n }\n}\n\napp.options(\"/api/inquiries\", (c) => {\n applyCors(c);\n const origin = c.req.header(\"origin\");\n return ALLOWED_ORIGINS.has(origin ?? \"\") ? c.body(null, 204) : c.body(null, 403);\n});\n\napp.post(\"/api/inquiries\", async (c) => {\n applyCors(c);\n const origin = c.req.header(\"origin\") ?? \"\";\n if (!ALLOWED_ORIGINS.has(origin)) {\n return c.json({ error: \"This submission origin is not allowed.\" }, 403);\n }\n\n const contentLength = Number(c.req.header(\"content-length\") ?? 0);\n if (contentLength > 20_000) {\n return c.json({ error: \"The submission is too large.\" }, 413);\n }\n\n let body: Record;\n try {\n body = await c.req.json();\n } catch {\n return c.json({ error: \"Expected a JSON submission.\" }, 415);\n }\n\n const name = String(body.name ?? \"\").trim();\n const organisation = String(body.organisation ?? \"\").trim();\n const submittedEmail = String(body.email ?? \"\").trim().toLowerCase();\n const message = String(body.message ?? \"\").trim();\n const idempotencyKey = String(body.idempotencyKey ?? \"\").trim();\n const website = String(body.website ?? \"\").trim();\n\n if (website) {\n return c.json({ ok: true }, 202);\n }\n if (\n !name || name.length > 120 ||\n !organisation || organisation.length > 160 ||\n !EMAIL_PATTERN.test(submittedEmail) || submittedEmail.length > 254 ||\n !message || message.length > 5000 ||\n !/^[0-9a-f-]{36}$/i.test(idempotencyKey)\n ) {\n return c.json({ error: \"Please check the form fields and try again.\" }, 400);\n }\n\n const existing = await findInquiryByIdempotencyKey(idempotencyKey);\n if (existing) {\n return c.json({ ok: true, inquiryId: existing.id }, 202);\n }\n\n const limit = await checkSubmissionLimit(submittedEmail);\n if (!limit.allowed) {\n return c.json(\n { error: \"We’ve received several inquiries recently. Please try again later.\" },\n 429,\n );\n }\n\n const inquiryId = crypto.randomUUID();\n await createInquiry({\n id: inquiryId,\n idempotencyKey,\n name,\n organisation,\n email: submittedEmail,\n message,\n });\n\n await deliverReadyEmails(2);\n return c.json({ ok: true, inquiryId }, 202);\n});\n\napp.get(\"/\", (c) => c.redirect(\"/dashboard\"));\n\napp.get(\"/dashboard\", requireDashboardUser, async (c) => {\n const inquiries = await listInquiries();\n return html(\n ,\n );\n});\n\napp.post(\"/dashboard/inquiries/:id\", requireDashboardUser, async (c) => {\n const expectedOrigin = new URL(c.req.url).origin;\n if (c.req.header(\"origin\") !== expectedOrigin) return c.text(\"Forbidden\", 403);\n\n const form = await c.req.formData();\n const status = String(form.get(\"status\") ?? \"\") as InquiryStatus;\n const notes = String(form.get(\"notes\") ?? \"\").trim();\n if (!INQUIRY_STATUSES.includes(status) || notes.length > 2000) {\n return c.text(\"Invalid update\", 400);\n }\n\n await updateInquiry(c.req.param(\"id\"), status, notes);\n return c.redirect(\"/dashboard?saved=1\", 303);\n});\n\nexport default oauthMiddleware(app.fetch);\n","lsc-inquiries",[149],"619979ac-8b6d-4175-a08a-df7f445989d7","delivery.ts","5f217568-80fb-11f1-bb8a-1607ee4eb77e",14,["D",1784195254617],"import { email } from \"https://esm.town/v/std/email\";\nimport {\n listReadyEmailJobs,\n markEmailAccepted,\n markEmailFailed,\n markEmailSending,\n type EmailJob,\n} from \"./db.ts\";\n\n// Email jobs are persisted before delivery so a temporary send failure never\n// loses the inquiry itself.\nconst PARTNER_EMAIL = \"partner@livingstoriescollective.org\";\n\nfunction confirmationMessage(job: EmailJob) {\n return {\n to: job.recipient,\n replyTo: PARTNER_EMAIL,\n subject: \"We received your partnership inquiry\",\n text: `Hi ${job.inquiry.name},\n\nThank you for reaching out to Living Stories Collective. We’ve received your partnership inquiry and a member of our team will get back to you soon.\n\nIf you’d like to add anything, reply to this email and it will reach us at ${PARTNER_EMAIL}.\n\nWarmly,\nLiving Stories Collective`,\n };\n}\n\nfunction notificationMessage(job: EmailJob) {\n const inquiry = job.inquiry;\n return {\n to: job.recipient,\n replyTo: { email: inquiry.email, name: inquiry.name },\n subject: `New partner inquiry — ${inquiry.organisation}`,\n text: `A new partner inquiry was submitted.\n\nName: ${inquiry.name}\nOrganisation: ${inquiry.organisation}\nEmail: ${inquiry.email}\nInquiry ID: ${inquiry.id}\n\nMessage:\n${inquiry.message}\n\nReply to this email to respond directly to ${inquiry.name}.`,\n };\n}\n\nasync function deliverJob(job: EmailJob) {\n if (!(await markEmailSending(job.id))) return;\n\n try {\n await email(\n job.kind === \"confirmation\"\n ? confirmationMessage(job)\n : notificationMessage(job),\n );\n await markEmailAccepted(job.id);\n } catch (error) {\n const message = error instanceof Error ? error.message : String(error);\n await markEmailFailed(job.id, message);\n }\n}\n\nexport async function deliverReadyEmails(limit = 10) {\n const jobs = await listReadyEmailJobs(limit);\n await Promise.all(jobs.map(deliverJob));\n return jobs.length;\n}\n",[158],"f38ecf66-e856-4ce2-a7e6-0c0d52844277",["D",1784198241938],[28],"4a87d156-e3f1-4fd9-8c4b-f8f10eeb9368","dashboard.tsx","71dec4a4-80fa-11f1-aa0b-1607ee4eb77e",4,["D",1784194856347],"/** @jsxImportSource npm:hono@4/jsx */\nimport type { Inquiry, InquiryStatus } from \"./db.ts\";\n\nconst STATUS_LABELS: Record = {\n new: \"New\",\n contacted: \"Contacted\",\n in_progress: \"In progress\",\n closed: \"Closed\",\n};\n\nfunction formatDate(value: string) {\n return new Intl.DateTimeFormat(\"en-GB\", {\n day: \"numeric\",\n month: \"short\",\n year: \"numeric\",\n hour: \"2-digit\",\n minute: \"2-digit\",\n timeZone: \"Asia/Kolkata\",\n timeZoneName: \"short\",\n }).format(new Date(`${value.replace(\" \", \"T\")}Z`));\n}\n\nfunction DeliveryState({ state, label }: { state: string; label: string }) {\n return (\n \n \n {label}: {state === \"accepted\" ? \"sent\" : state}\n \n );\n}\n\nfunction InquiryCard({ inquiry }: { inquiry: Inquiry }) {\n return (\n

\n \n\n

{inquiry.message}

\n\n

\n \n \n

\n\n

Follow-up and private notes

\n \n

\n );\n}\n\nexport function DashboardPage({\n inquiries,\n userEmail,\n saved,\n}: {\n inquiries: Inquiry[];\n userEmail: string;\n saved: boolean;\n}) {\n const openCount = inquiries.filter((item) => item.status !== \"closed\").length;\n\n return (\n \n \n \n \n \n \n Partner inquiries · Living Stories Collective\n \n \n \n \n\n

\n {saved && (\n

Inquiry updated.

\n )}\n

Partner desk

Inquiries

New conversations and follow-up notes in one quiet place.

Open: {openCount}
Total: {inquiries.length}

\n\n

\n {inquiries.length ? (\n inquiries.map((inquiry) => )\n ) : (\n

All clear

No inquiries yet

New partner submissions will appear here.

\n )}\n

\n \n \n );\n}\n\nexport function AccessDeniedPage({ email }: { email: string }) {\n return (\n \n \n \n \n \n Access denied · Living Stories Collective\n \n \n \n

Partner desk

Access isn’t enabled

\n {email} is signed in, but is not on the dashboard allowlist.\n

\n Sign in with another account\n

\n \n \n );\n}\n\nconst styles = String.raw`\n :root {\n color: #25251f;\n background: #f2efe7;\n font-family: Inter, ui-sans-serif, system-ui, -apple-system, BlinkMacSystemFont, \"Segoe UI\", sans-serif;\n font-synthesis: none;\n }\n * { box-sizing: border-box; }\n body { margin: 0; min-width: 320px; background: #f2efe7; }\n a { color: inherit; text-underline-offset: 3px; }\n button, select, textarea { font: inherit; }\n .site-header {\n min-height: 72px; padding: 12px clamp(18px, 4vw, 48px); display: flex;\n align-items: center; justify-content: space-between; gap: 24px;\n border-bottom: 1px solid #d8d3c7; background: rgba(248, 246, 240, .92);\n }\n .brand { display: inline-flex; align-items: center; gap: 12px; text-decoration: none; }\n .brand__mark {\n width: 42px; height: 42px; display: grid; place-items: center; border-radius: 50%;\n color: #f8f6f0; background: #38372f; font-family: Georgia, serif; font-size: 14px;\n }\n .brand strong, .brand small { display: block; }\n .brand strong { font-family: Georgia, serif; font-size: 16px; font-weight: 500; }\n .brand small { margin-top: 2px; color: #777266; font-size: 12px; }\n .account { display: flex; align-items: center; gap: 16px; color: #69655b; font-size: 13px; }\n .account a { min-height: 44px; display: inline-flex; align-items: center; }\n main { width: min(1080px, calc(100% - 36px)); margin: 0 auto; padding: 56px 0 80px; }\n .intro { display: flex; align-items: flex-end; justify-content: space-between; gap: 32px; margin-bottom: 34px; }\n .eyebrow {\n margin: 0 0 8px; color: #817b6d; font-size: 11px; font-weight: 650;\n letter-spacing: .12em; line-height: 1.4; text-transform: uppercase;\n }\n h1, h2 { margin: 0; font-family: Georgia, \"Times New Roman\", serif; font-weight: 400; }\n h1 { font-size: clamp(42px, 7vw, 68px); letter-spacing: -.04em; line-height: .98; }\n .intro > div > p:last-child { max-width: 510px; margin: 14px 0 0; color: #68645a; font-size: 16px; line-height: 1.55; }\n .summary { display: flex; gap: 8px; margin: 0; }\n .summary div { min-width: 86px; padding: 12px 14px; border: 1px solid #d8d3c7; background: #f8f6f0; }\n .summary dt { color: #777266; font-size: 11px; letter-spacing: .08em; text-transform: uppercase; }\n .summary dd { margin: 6px 0 0; font-family: Georgia, serif; font-size: 28px; font-variant-numeric: tabular-nums; }\n .inquiry-list { display: grid; gap: 14px; }\n .inquiry-card { padding: clamp(20px, 4vw, 32px); border: 1px solid #d8d3c7; background: #fbfaf6; box-shadow: 0 10px 30px rgba(61, 57, 47, .04); }\n .inquiry-card__header { display: flex; justify-content: space-between; gap: 24px; }\n .inquiry-card h2 { font-size: clamp(25px, 4vw, 34px); line-height: 1.1; }\n .contact-line { margin: 8px 0 0; color: #68645a; font-size: 14px; line-height: 1.5; }\n .status { align-self: flex-start; padding: 7px 10px; border-radius: 999px; font-size: 12px; white-space: nowrap; }\n .status--new { color: #254d3b; background: #dcebe3; }\n .status--contacted { color: #604519; background: #f3e4bd; }\n .status--in_progress { color: #334b66; background: #dce7f0; }\n .status--closed { color: #68645a; background: #e8e5de; }\n .message { margin: 24px 0; max-width: 780px; white-space: pre-wrap; font-family: Georgia, serif; font-size: 18px; line-height: 1.65; }\n .delivery-row { display: flex; flex-wrap: wrap; gap: 12px; padding-top: 16px; border-top: 1px solid #ebe7de; }\n .delivery { display: inline-flex; align-items: center; gap: 7px; color: #777266; font-size: 12px; }\n .delivery__dot { width: 7px; height: 7px; border-radius: 50%; background: #b1aca0; }\n .delivery--accepted .delivery__dot { background: #4a7b62; }\n .delivery--failed .delivery__dot { background: #a34d42; }\n .delivery--sending .delivery__dot { background: #b68a31; }\n .follow-up { margin-top: 20px; border-top: 1px solid #ebe7de; }\n .follow-up summary { min-height: 48px; display: flex; align-items: center; color: #615d53; font-size: 14px; cursor: pointer; }\n .follow-up summary::marker { color: #8a8477; }\n .follow-up form { padding-top: 6px; }\n .field-row { display: grid; grid-template-columns: 180px minmax(0, 1fr); gap: 16px; }\n label span { display: block; margin-bottom: 7px; color: #777266; font-size: 12px; }\n select, textarea { width: 100%; border: 1px solid #cfc9bc; border-radius: 0; background: #fff; color: #25251f; font-size: 16px; }\n select { min-height: 46px; padding: 0 12px; }\n textarea { min-height: 96px; padding: 11px 12px; line-height: 1.5; resize: vertical; }\n select:focus, textarea:focus, button:focus-visible, a:focus-visible { outline: 2px solid #435d4f; outline-offset: 3px; }\n .follow-up button, .button-link {\n min-height: 44px; margin-top: 14px; padding: 0 17px; display: inline-flex; align-items: center;\n justify-content: center; border: 1px solid #35342e; background: #35342e; color: #fff;\n font-size: 14px; text-decoration: none; cursor: pointer;\n }\n .toast { padding: 12px 14px; border: 1px solid #b9d2c2; background: #e5f0e9; color: #254d3b; }\n .empty-state, .access-card { padding: clamp(28px, 6vw, 56px); border: 1px solid #d8d3c7; background: #fbfaf6; text-align: center; }\n .empty-state h2, .access-card h1 { font-size: clamp(30px, 5vw, 48px); }\n .empty-state > p:last-child, .access-card p { color: #68645a; line-height: 1.6; }\n .centred-page { min-height: 100vh; display: grid; place-items: center; padding: 20px; }\n .centred-page main { width: min(620px, 100%); margin: 0; padding: 0; }\n @media (hover: hover) {\n .follow-up button:hover, .button-link:hover { background: #4a4940; }\n }\n @media (max-width: 700px) {\n .site-header { align-items: flex-start; }\n .brand strong { max-width: 170px; }\n .account { align-items: flex-end; flex-direction: column; gap: 2px; text-align: right; }\n main { width: min(100% - 28px, 1080px); padding-top: 38px; }\n .intro { align-items: flex-start; flex-direction: column; gap: 22px; }\n .summary { width: 100%; }\n .summary div { flex: 1; }\n .inquiry-card__header { flex-direction: column; gap: 14px; }\n .field-row { grid-template-columns: 1fr; }\n .follow-up button { width: 100%; }\n }\n`;\n",[168],"pulls","branches",1,"forks","envVars",{"_182":176,"_184":63},"connections",{"_182":63,"_183":63},"count","unfilledCount","emptyCount",{"_43":167,"_32":168,"_30":169,"_139":-5,"_41":42,"_40":170,"_141":25,"_38":203,"_13":63,"_33":34,"_35":172,"_24":25,"_146":-5,"_191":204,"_27":205},{"_43":164,"_32":28,"_30":31,"_139":-5,"_41":42,"_40":14,"_141":59,"_38":200,"_13":143,"_33":34,"_35":37,"_24":25,"_146":-5,"_191":201,"_27":202},{"_43":157,"_32":158,"_30":159,"_139":-5,"_41":42,"_40":160,"_141":25,"_38":197,"_13":63,"_33":34,"_35":162,"_24":25,"_146":-5,"_191":198,"_27":199},{"_43":148,"_32":149,"_30":57,"_139":-5,"_41":42,"_40":150,"_141":25,"_38":194,"_13":152,"_33":153,"_35":154,"_24":25,"_146":155,"_191":195,"_27":196},{"_43":136,"_32":137,"_30":138,"_139":-5,"_41":42,"_40":140,"_141":59,"_38":190,"_13":143,"_33":144,"_35":145,"_24":25,"_146":-5,"_191":192,"_27":193},["D",1784195230355],"children",[],[137],["D",1784195901418],[],[149],["D",1784195254617],[],[158],["D",1784198241938],[],[28],["D",1784194856347],[],[168],["D",1784194854385],["D",1789525843977],{"_100":99,"_108":104},{"_100":99,"_101":102,"_103":104,"_18":55,"_105":106,"_107":25},{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"ctx",{"_82":-5,"_128":244,"_245":246,"_247":248,"_249":25,"_250":25,"_251":25,"_252":59,"_253":-5,"_254":-7,"_255":-7,"_256":63,"_257":25,"_258":25,"_259":-5,"_260":25,"_261":25,"_262":25,"_263":-5},"ENV",{"_215":216,"_217":218,"_219":90,"_220":221,"_222":223,"_224":225,"_226":227,"_228":229,"_230":231,"_232":233,"_234":235,"_236":237,"_238":239,"_240":241,"_242":243},"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 · v20