[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_109":110,"_111":112},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","khxu","name","presentation-survey","path","backend/surveys.ts","project",{"_22":48,"_11":12,"_35":49,"_50":-5,"_51":44,"_52":53,"_54":53,"_55":56,"_57":-5,"_58":59,"_60":61,"_62":34,"_63":-5,"_64":-5,"_65":66,"_67":68,"_69":70,"_71":72,"_73":74,"_75":-5,"_76":77,"_78":77,"_79":80,"_81":80,"_82":80,"_83":77,"_84":77,"_85":86,"_87":88,"_89":90,"_91":44},"file",{"_22":23,"_11":24,"_25":26,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":-5,"_13":46},"permalink","https://www.val.town/x/khxu/presentation-survey/code/backend/surveys.ts","extension","id","ebc91960-909a-4908-9018-8634da6d7e25","surveys.ts","fileId","65dd734e-a8eb-11f1-83ff-1607ee4eb77e","parentId","a73fa0d1-3dea-4570-b0fc-54f92da89dd6","branchId","00e09eca-4d1b-4e02-b98f-8565c54b4542","branchVersion",138,"latest",true,"createdAt",["D",1788849921413],"version",7,"fileType","script","content","import type { Answers, Question, Survey } from \"../shared/types.ts\";\nimport {\n canonicalizeChoiceSelection,\n normalizeMatrixAnswer,\n normalizeStoredQuestions,\n QUESTION_LIMITS,\n} from \"../shared/questions.ts\";\nimport { ensureSchema, randomId, sha256, sqlite } from \"./db.ts\";\nimport { RequestError } from \"./errors.ts\";\n\nfunction rowToSurvey(r: Record): Survey {\n return {\n id: String(r.id),\n slug: String(r.slug),\n title: String(r.title),\n description: String(r.description ?? \"\"),\n resultsVisible: Number(r.results_visible) === 1,\n acceptingResponses: Number(r.accepting_responses) === 1,\n audienceFacets: Number(r.audience_facets) === 1,\n createdAt: String(r.created_at),\n questions: normalizeStoredQuestions(\n JSON.parse(String(r.questions_json ?? \"[]\")),\n ),\n };\n}\n\nexport function publicSurvey(survey: Survey): Survey {\n return {\n ...survey,\n questions: survey.questions\n .filter((question) => question.released)\n .map((question, position) => ({ ...question, position })),\n };\n}\n\nexport function filterAnswers(\n answers: Answers | null,\n questions: Question[],\n): Answers | null {\n if (!answers) return null;\n const visible = new Set(questions.map((question) => question.id));\n return Object.fromEntries(\n Object.entries(answers).filter(([questionId]) => visible.has(questionId)),\n );\n}\n\nexport function mergeReleasedAnswers(\n existing: Answers | null,\n releasedQuestions: Question[],\n incoming: Answers,\n): Answers {\n const merged = { ...(existing ?? {}) };\n for (const question of releasedQuestions) delete merged[question.id];\n return { ...merged, ...incoming };\n}\n\nexport async function createSurvey(\n title: string,\n): Promise<{ survey: Survey; adminKey: string }> {\n await ensureSchema();\n const id = randomId(12);\n const slug = randomId(6);\n const adminKey = randomId(28);\n const hash = await sha256(adminKey);\n await sqlite.execute({\n sql:\n `INSERT INTO surveys (id, slug, admin_key_hash, title) VALUES (?, ?, ?, ?)`,\n args: [id, slug, hash, title || \"Untitled survey\"],\n });\n const survey = await getSurveyBySlug(slug);\n return { survey: survey!, adminKey };\n}\n\nexport async function getSurveyBySlug(slug: string): Promise {\n await ensureSchema();\n const r = await sqlite.execute({\n sql: `SELECT * FROM surveys WHERE slug = ?`,\n args: [slug],\n });\n return r.rows[0] ? rowToSurvey(r.rows[0] as Record) : null;\n}\n\nexport async function getSurveyByAdminKey(\n adminKey: string,\n): Promise {\n await ensureSchema();\n const hash = await sha256(adminKey);\n const r = await sqlite.execute({\n sql: `SELECT * FROM surveys WHERE admin_key_hash = ?`,\n args: [hash],\n });\n return r.rows[0] ? rowToSurvey(r.rows[0] as Record) : null;\n}\n\nexport interface SurveyPatch {\n title?: string;\n description?: string;\n resultsVisible?: boolean;\n acceptingResponses?: boolean;\n audienceFacets?: boolean;\n questions?: Question[];\n expectedQuestions?: Question[];\n}\n\nexport async function updateSurvey(\n id: string,\n patch: SurveyPatch,\n): Promise {\n await ensureSchema();\n const sets: string[] = [];\n const args: (string | number)[] = [];\n let expectedPersistedQuestions: string | undefined;\n if (patch.title !== undefined) sets.push(\"title = ?\"), args.push(patch.title);\n if (patch.description !== undefined) {\n sets.push(\"description = ?\"), args.push(patch.description);\n }\n if (patch.resultsVisible !== undefined) {\n sets.push(\"results_visible = ?\"), args.push(patch.resultsVisible ? 1 : 0);\n }\n if (patch.acceptingResponses !== undefined) {\n sets.push(\"accepting_responses = ?\"),\n args.push(patch.acceptingResponses ? 1 : 0);\n }\n if (patch.audienceFacets !== undefined) {\n sets.push(\"audience_facets = ?\"), args.push(patch.audienceFacets ? 1 : 0);\n }\n if (patch.questions !== undefined) {\n if (\n !Array.isArray(patch.questions) || !Array.isArray(patch.expectedQuestions)\n ) {\n throw new RequestError(\n \"Reload the builder before saving questions.\",\n 409,\n );\n }\n for (const question of patch.questions) {\n if (question.type !== \"matrix_2x2\") continue;\n if (question.matrixSize !== 2) {\n throw new RequestError(\n \"Only 2x2 matrix questions are supported.\",\n 400,\n );\n }\n if (\n typeof question.matrixSubjectLabel !== \"string\" ||\n !question.matrixSubjectLabel.trim() ||\n question.matrixSubjectLabel.trim().length >\n QUESTION_LIMITS.matrixSubjectLabel\n ) {\n throw new RequestError(\n `Matrix subject label must contain 1-${QUESTION_LIMITS.matrixSubjectLabel} characters.`,\n 400,\n );\n }\n }\n const currentResult = await sqlite.execute({\n sql: `SELECT questions_json FROM surveys WHERE id = ?`,\n args: [id],\n });\n const currentJson = currentResult.rows[0]?.questions_json;\n if (currentJson === undefined) {\n throw new RequestError(\"Survey not found.\", 404);\n }\n const currentQuestions = normalizeStoredQuestions(\n JSON.parse(String(currentJson)),\n );\n if (\n JSON.stringify(currentQuestions) !==\n JSON.stringify(patch.expectedQuestions)\n ) {\n throw new RequestError(\n \"Questions changed in another tab. Reload before saving.\",\n 409,\n );\n }\n expectedPersistedQuestions = String(currentJson);\n const qs = patch.questions.map((q, i) => ({\n ...q,\n position: i,\n released: q.released === true,\n ...(q.type === \"matrix_2x2\"\n ? { matrixSubjectLabel: q.matrixSubjectLabel!.trim() }\n : {}),\n }));\n sets.push(\"questions_json = ?\"), args.push(JSON.stringify(qs));\n }\n if (!sets.length) return;\n args.push(id);\n // Compare the last saved snapshot so an older builder cannot erase an approval.\n const condition = patch.questions !== undefined\n ? \" AND json(questions_json) = json(?)\"\n : \"\";\n if (expectedPersistedQuestions !== undefined) {\n args.push(expectedPersistedQuestions);\n }\n const result = await sqlite.execute({\n sql: `UPDATE surveys SET ${\n sets.join(\", \")\n } WHERE id = ?${condition} RETURNING *`,\n args,\n });\n if (!result.rowsAffected) {\n throw new RequestError(\n \"Questions changed in another tab. Reload before saving.\",\n 409,\n );\n }\n return rowToSurvey(result.rows[0] as Record);\n}\n\nexport async function setQuestionReleased(\n surveyId: string,\n questionId: string,\n released: boolean,\n): Promise {\n await ensureSchema();\n const currentResult = await sqlite.execute({\n sql: `SELECT * FROM surveys WHERE id = ?`,\n args: [surveyId],\n });\n if (!currentResult.rows[0]) throw new RequestError(\"Survey not found.\", 404);\n const currentRow = currentResult.rows[0] as Record;\n const current = rowToSurvey(currentRow);\n if (!current.questions.some((question) => question.id === questionId)) {\n throw new RequestError(\"Question not found.\", 404);\n }\n const questions = current.questions.map((question) =>\n question.id === questionId ? { ...question, released } : question\n );\n const result = await sqlite.execute({\n sql:\n `UPDATE surveys SET questions_json = ? WHERE id = ? AND json(questions_json) = json(?) RETURNING *`,\n args: [\n JSON.stringify(questions),\n surveyId,\n String(currentRow.questions_json),\n ],\n });\n if (!result.rowsAffected) {\n throw new RequestError(\n \"Questions changed in another tab. Retry the release action.\",\n 409,\n );\n }\n return rowToSurvey(result.rows[0] as Record);\n}\n\nexport async function deleteSurvey(id: string): Promise {\n await ensureSchema();\n await sqlite.batch([\n {\n sql:\n `DELETE FROM proposal_votes WHERE proposal_id IN (SELECT id FROM question_proposals WHERE survey_id = ?)`,\n args: [id],\n },\n { sql: `DELETE FROM question_proposals WHERE survey_id = ?`, args: [id] },\n { sql: `DELETE FROM responses WHERE survey_id = ?`, args: [id] },\n { sql: `DELETE FROM surveys WHERE id = ?`, args: [id] },\n ]);\n}\n\nexport async function clearResponses(surveyId: string): Promise {\n await ensureSchema();\n await sqlite.execute({\n sql: `DELETE FROM responses WHERE survey_id = ?`,\n args: [surveyId],\n });\n}\n\nexport async function upsertResponse(\n surveyId: string,\n sid: string,\n answers: Answers,\n): Promise {\n await ensureSchema();\n await sqlite.execute({\n sql: `INSERT INTO responses (survey_id, sid, answers_json) VALUES (?, ?, ?)\n ON CONFLICT(survey_id, sid) DO UPDATE SET answers_json = excluded.answers_json, updated_at = datetime('now')`,\n args: [surveyId, sid, JSON.stringify(answers)],\n });\n}\n\nexport async function getResponse(\n surveyId: string,\n sid: string,\n): Promise {\n await ensureSchema();\n const r = await sqlite.execute({\n sql: `SELECT answers_json FROM responses WHERE survey_id = ? AND sid = ?`,\n args: [surveyId, sid],\n });\n return r.rows[0] ? JSON.parse(String(r.rows[0].answers_json)) : null;\n}\n\nexport async function getAllResponses(surveyId: string): Promise {\n await ensureSchema();\n const r = await sqlite.execute({\n sql: `SELECT answers_json FROM responses WHERE survey_id = ? ORDER BY id`,\n args: [surveyId],\n });\n return r.rows.map((row) => JSON.parse(String(row.answers_json)));\n}\n\n/** Validate & normalize incoming answers against the survey's questions. Drops unknown keys. */\nexport function sanitizeAnswers(survey: Survey, raw: unknown): Answers {\n const out: Answers = {};\n if (!raw || typeof raw !== \"object\") return out;\n const input = raw as Record;\n for (const q of survey.questions) {\n const v = input[q.id];\n if (v === undefined || v === null || v === \"\") continue;\n const optIds = new Set(q.options.map((o) => o.id));\n switch (q.type) {\n case \"single_choice\":\n case \"emoji_reaction\":\n if (typeof v === \"string\" && optIds.has(v)) out[q.id] = v;\n break;\n case \"multi_choice\":\n {\n const selected = canonicalizeChoiceSelection(q.options, v);\n if (selected) out[q.id] = selected;\n }\n break;\n case \"ranked_choice\":\n if (Array.isArray(v)) {\n const seen = new Set();\n out[q.id] = v.filter((x) =>\n typeof x === \"string\" && optIds.has(x) && !seen.has(x) &&\n seen.add(x)\n );\n }\n break;\n case \"scale\": {\n const n = Number(v);\n const min = q.scaleMin ?? 1, max = q.scaleMax ?? 5;\n if (Number.isFinite(n) && n >= min && n <= max) {\n out[q.id] = Math.round(n);\n }\n break;\n }\n case \"free_text\":\n if (typeof v === \"string\") out[q.id] = v.slice(0, 2000);\n break;\n case \"word_cloud\":\n if (typeof v === \"string\") out[q.id] = v.trim().slice(0, 40);\n break;\n case \"matrix_2x2\": {\n const size = q.matrixSize ?? 2;\n const answer = normalizeMatrixAnswer(v, size);\n if (answer) out[q.id] = answer;\n break;\n }\n }\n }\n return out;\n}\n","deleted",false,"label",[47,24],"backend","ae520107-1d25-47b9-ad83-831e36befb67",["D",1788585574393],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Live talk polling: QR join, ranked choice, demographic facets","imageUrl","userId","0198fc74-a2ac-77df-bbdc-e23a8e395bee","pinnedFileId","01a0700e-6ffa-7369-be27-ef5029df6316","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","0198fc74-a2ad-7019-840f-e164a0170dfc","tursoName","ae5201071d2547b9ad83831e36befb67","tursoHostname","ae5201071d2547b9ad83831e36befb67-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789542098478],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_108":104},"org",{"_9":10,"_102":-5,"_103":104,"_58":59,"_105":106,"_107":44},"branch",{"_37":92,"_11":93,"_22":30,"_94":48,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":12,"_101":10},"isOwned",150,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18zMjFKVFdGYXdiZmFXS0hOajdwWHNBOUlZUE4ifQ","tier","pro","canRestrictVals","profileImageUrl","ctx",{"_85":-5,"_142":143,"_144":145,"_146":147,"_148":44,"_149":44,"_150":44,"_151":34,"_152":-5,"_153":-7,"_154":-7,"_155":66,"_156":44,"_157":44,"_158":-5,"_159":44,"_160":44,"_161":44,"_162":-5},"ENV",{"_113":114,"_115":116,"_117":93,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133,"_134":135,"_136":137,"_138":139,"_140":141},"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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]