[{"_1":2,"_173":-5,"_174":-5},"loaderData",{"_3":4,"_91":92},"root",{"_5":6,"_34":35,"_64":65},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","notificationCount",0,"flagDenols","ENV",{"_36":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","0fffb492b08724537e73cd8bc4c3f31babbf0bd5","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","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","API_URL","https://api.val.town","clerkState",{"_66":67},"__internal_clerk_state",{"_68":69,"_70":45,"_71":72,"_73":72,"_74":20,"_75":72,"_76":72,"_77":72,"_78":72,"_79":80,"_89":20,"_90":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_81":20,"_19":20,"_82":72,"_83":84,"_85":72,"_86":45,"_87":20,"_88":72},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_93":94,"_95":96,"_97":98,"_99":100,"_146":147,"_170":171,"_172":-5},"handle","fwfben","name","live-talk","path","backend/database/queries.ts","project",{"_101":102,"_95":96,"_103":104,"_105":-5,"_106":20,"_107":108,"_109":72,"_110":-5,"_12":111,"_112":-5,"_113":20,"_114":-5,"_115":32,"_14":116,"_117":118,"_119":118,"_120":121,"_122":121,"_123":121,"_124":118,"_125":118,"_23":126,"_129":130,"_132":133,"_145":20},"id","87b7a7c6-c513-11f0-af71-42dde27851f2","createdAt",["D",1763534812047],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","019a99cf-17a5-73e9-9336-0e5533d91416","pinnedFileId","pinPreview","screenshotVersion","likeCount","019a99cf-17a6-7560-a9f3-42b1c49a588c","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_127":128},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzM1ZzFtdHVvVkZJTHg0YkVzM2Vkd0tGQjRMOCJ9","org",{"_93":94,"_131":128,"_12":111},"avatar","branch",{"_134":135,"_95":43,"_101":136,"_137":102,"_138":-5,"_139":-5,"_140":-5,"_141":-5,"_142":-5,"_143":96,"_144":94},"version",486,"87b7e164-c513-11f0-af71-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_101":148,"_95":149,"_150":151,"_152":153,"_154":136,"_155":156,"_157":158,"_103":159,"_134":160,"_161":162,"_163":164,"_165":20,"_166":-5,"_97":167},"f3ab1dec-c77e-11f0-98c3-42dde27851f2","queries.ts","fileId","8a27feb2-c517-11f0-8062-42dde27851f2","parentId","2f79193e-c516-11f0-9a1a-42dde27851f2","branchId","branchVersion",481,"latest",true,["D",1763800851623],14,"fileType","script","content","import { getAdapter } from \"./adapter.ts\";\nimport { TABLES } from \"./migrations.ts\";\nimport type {\n Presentation,\n Step,\n Session,\n Response,\n} from \"../../shared/types.ts\";\n\nconst sqlite = getAdapter();\n\n// Presentations\nexport async function createPresentation(\n name: string,\n presenter: string,\n creator_session_id: string,\n talk_deck_link: string | null = null\n): Promise {\n const result = await sqlite.execute(\n `INSERT INTO ${TABLES.presentations} (name, presenter, creator_session_id, talk_deck_link) VALUES (?, ?, ?, ?)`,\n [name, presenter, creator_session_id, talk_deck_link]\n );\n return result.lastInsertRowId as number;\n}\n\nexport async function getPresentation(\n id: number\n): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLES.presentations} WHERE id = ?`,\n [id]\n );\n return result.rows[0] as Presentation | null;\n}\n\nexport async function getAllPresentations(): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLES.presentations} ORDER BY created_at DESC`\n );\n return result.rows as Presentation[];\n}\n\nexport async function getPresentationsByCreator(\n creator_session_id: string\n): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLES.presentations} WHERE creator_session_id = ? ORDER BY created_at DESC`,\n [creator_session_id]\n );\n return result.rows as Presentation[];\n}\n\nexport async function updatePresentation(\n id: number,\n name: string,\n presenter: string,\n talk_deck_link: string | null\n): Promise {\n await sqlite.execute(\n `UPDATE ${TABLES.presentations} SET name = ?, presenter = ?, talk_deck_link = ? WHERE id = ?`,\n [name, presenter, talk_deck_link, id]\n );\n}\n\nexport async function deletePresentation(id: number): Promise {\n await sqlite.execute(`DELETE FROM ${TABLES.presentations} WHERE id = ?`, [\n id,\n ]);\n}\n\nexport async function deleteAllPresentationsByCreator(\n creator_session_id: string\n): Promise {\n await sqlite.execute(\n `DELETE FROM ${TABLES.presentations} WHERE creator_session_id = ?`,\n [creator_session_id]\n );\n}\n\n// Steps\nexport async function createStep(\n presentation_id: number,\n step_number: number,\n widget_type: string,\n widget_config: string,\n name: string | null = null\n): Promise {\n const result = await sqlite.execute(\n `INSERT INTO ${TABLES.steps} (presentation_id, step_number, name, widget_type, widget_config) VALUES (?, ?, ?, ?, ?)`,\n [presentation_id, step_number, name, widget_type, widget_config]\n );\n return result.lastInsertRowId as number;\n}\n\nexport async function getStepsByPresentation(\n presentation_id: number\n): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLES.steps} WHERE presentation_id = ? ORDER BY step_number ASC`,\n [presentation_id]\n );\n return result.rows as Step[];\n}\n\nexport async function getStep(id: number): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLES.steps} WHERE id = ?`,\n [id]\n );\n return result.rows[0] as Step | null;\n}\n\nexport async function activateStep(\n step_id: number,\n presentation_id: number\n): Promise {\n // First, deactivate all steps in this presentation\n await sqlite.execute(\n `UPDATE ${TABLES.steps} SET is_active = 0 WHERE presentation_id = ?`,\n [presentation_id]\n );\n // Then activate the specified step\n await sqlite.execute(\n `UPDATE ${TABLES.steps} SET is_active = 1 WHERE id = ?`,\n [step_id]\n );\n}\n\nexport async function getActiveStep(\n presentation_id: number\n): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLES.steps} WHERE presentation_id = ? AND is_active = 1 LIMIT 1`,\n [presentation_id]\n );\n return result.rows[0] as Step | null;\n}\n\nexport async function updateStep(\n id: number,\n widget_type: string,\n widget_config: string,\n name: string | null = null\n): Promise {\n await sqlite.execute(\n `UPDATE ${TABLES.steps} SET widget_type = ?, widget_config = ?, name = ? WHERE id = ?`,\n [widget_type, widget_config, name, id]\n );\n}\n\nexport async function updateStepName(\n id: number,\n name: string | null\n): Promise {\n await sqlite.execute(`UPDATE ${TABLES.steps} SET name = ? WHERE id = ?`, [\n name,\n id,\n ]);\n}\n\nexport async function deleteStep(id: number): Promise {\n await sqlite.execute(`DELETE FROM ${TABLES.steps} WHERE id = ?`, [id]);\n}\n\nexport async function reorderSteps(\n presentation_id: number,\n stepIds: number[]\n): Promise {\n try {\n // First, set all step numbers to negative values (using negative of their ID)\n // This ensures uniqueness and frees up all positive step numbers\n for (const stepId of stepIds) {\n await sqlite.execute(\n `UPDATE ${TABLES.steps} SET step_number = ? WHERE id = ? AND presentation_id = ?`,\n [-stepId, stepId, presentation_id]\n );\n }\n \n // Then set them to their final positive values\n // Since all positive numbers are now free, there won't be conflicts\n for (let i = 0; i < stepIds.length; i++) {\n await sqlite.execute(\n `UPDATE ${TABLES.steps} SET step_number = ? WHERE id = ? AND presentation_id = ?`,\n [i + 1, stepIds[i], presentation_id]\n );\n }\n } catch (error) {\n console.error(\"Error in reorderSteps:\", error);\n console.error(\"Presentation ID:\", presentation_id);\n console.error(\"Step IDs:\", stepIds);\n throw error;\n }\n}\n\n// Sessions\nexport async function createSession(\n session_id: string,\n presentation_id: number\n): Promise {\n await sqlite.execute(\n `INSERT INTO ${TABLES.sessions} (id, presentation_id) VALUES (?, ?)`,\n [session_id, presentation_id]\n );\n}\n\nexport async function getSession(session_id: string): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLES.sessions} WHERE id = ?`,\n [session_id]\n );\n return result.rows[0] as Session | null;\n}\n\nexport async function getOrCreateSession(\n session_id: string,\n presentation_id: number\n): Promise {\n let session = await getSession(session_id);\n if (!session) {\n await createSession(session_id, presentation_id);\n session = await getSession(session_id);\n }\n return session!;\n}\n\n// Responses\nexport async function submitResponse(\n session_id: string,\n step_id: number,\n response_data: string\n): Promise {\n // Use INSERT OR REPLACE to handle unique constraint (one response per session per step)\n const result = await sqlite.execute(\n `INSERT OR REPLACE INTO ${TABLES.responses} (session_id, step_id, response_data) VALUES (?, ?, ?)`,\n [session_id, step_id, response_data]\n );\n return result.lastInsertRowId as number;\n}\n\nexport async function getResponsesForStep(\n step_id: number\n): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLES.responses} WHERE step_id = ? ORDER BY created_at ASC`,\n [step_id]\n );\n return result.rows as Response[];\n}\n\nexport async function getResponseForSessionAndStep(\n session_id: string,\n step_id: number\n): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLES.responses} WHERE session_id = ? AND step_id = ? LIMIT 1`,\n [session_id, step_id]\n );\n return result.rows[0] as Response | null;\n}\n\nexport async function deleteResponsesForStep(step_id: number): Promise {\n await sqlite.execute(`DELETE FROM ${TABLES.responses} WHERE step_id = ?`, [\n step_id,\n ]);\n}\n\n// User Attributes\nexport async function getUserAttribute(\n session_id: string,\n attribute_key: string\n): Promise {\n const result = await sqlite.execute(\n `SELECT attribute_value FROM ${TABLES.user_attributes} WHERE session_id = ? AND attribute_key = ? LIMIT 1`,\n [session_id, attribute_key]\n );\n return result.rows[0]\n ? (result.rows[0] as { attribute_value: string }).attribute_value\n : null;\n}\n\nexport async function setUserAttribute(\n session_id: string,\n attribute_key: string,\n attribute_value: string\n): Promise {\n await sqlite.execute(\n `INSERT OR REPLACE INTO ${TABLES.user_attributes} (session_id, attribute_key, attribute_value, updated_at) VALUES (?, ?, ?, datetime('now'))`,\n [session_id, attribute_key, attribute_value]\n );\n}\n\nexport async function getAllUserAttributes(\n session_id: string\n): Promise> {\n const result = await sqlite.execute(\n `SELECT attribute_key, attribute_value FROM ${TABLES.user_attributes} WHERE session_id = ?`,\n [session_id]\n );\n const attributes: Record = {};\n for (const row of result.rows) {\n const r = row as { attribute_key: string; attribute_value: string };\n attributes[r.attribute_key] = r.attribute_value;\n }\n return attributes;\n}\n\nexport async function findSessionByEmail(\n email: string\n): Promise {\n // Find the most recent session with this email\n const result = await sqlite.execute(\n `SELECT s.* FROM ${TABLES.sessions} s\n INNER JOIN ${TABLES.user_attributes} ua ON s.id = ua.session_id\n WHERE ua.attribute_key = 'email' AND ua.attribute_value = ?\n ORDER BY s.created_at DESC\n LIMIT 1`,\n [email]\n );\n return result.rows[0] as Session | null;\n}\n","deleted","label",[168,169,149],"backend","database","permalink","https://www.val.town/x/fwfben/live-talk/code/backend/database/queries.ts","extension","actionData","errors"]