[{"_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","cb8a548cff96feeeeb30b528c9619e76cb377f13","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","jessicaocean","name","untitled-1522","path","backend/database/queries.ts","project",{"_101":102,"_95":96,"_103":104,"_105":-5,"_106":20,"_107":108,"_109":-5,"_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","46229d30-93e4-11f0-9f38-0224a6c84d84","createdAt",["D",1758126908692],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","db8c40b0-3679-11f0-8fa1-55b6765ef200","pinnedFileId","pinPreview","screenshotVersion","likeCount","4b0eaab1-a083-4aa8-8d97-1e33d9e8e81f","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_127":128},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yeFExeUQyU0VlRHI3UGZ6NTE5RWJwak55S1IifQ","org",{"_93":94,"_131":128},"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",57,"46230068-93e4-11f0-9f38-0224a6c84d84","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},"7eb3de32-93eb-11f0-81f2-0224a6c84d84","queries.ts","fileId","66f114d2-93e5-11f0-bc6f-0224a6c84d84","parentId","77d6f0d9-f865-4fd7-aa4c-82690db0f2b5","branchId","branchVersion",52,"latest",true,["D",1758130010069],7,"fileType","script","content","import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport { USERS_TABLE, CONVERSATIONS_TABLE, MESSAGES_TABLE, PARTICIPANTS_TABLE, INVITES_TABLE } from \"./migrations.ts\";\nimport type { User, Conversation, Message, ConversationWithMessages, ConversationParticipant, ConversationInvite, InviteDetails } from \"../../shared/types.ts\";\n\n// User operations\nexport async function findOrCreateUser(email: string): Promise {\n // Try to find existing user\n const { rows } = await sqlite.execute(\n `SELECT * FROM ${USERS_TABLE} WHERE email = ?`,\n [email]\n );\n\n if (rows.length > 0) {\n return rows[0] as User;\n }\n\n // Create new user\n const result = await sqlite.execute(\n `INSERT INTO ${USERS_TABLE} (email) VALUES (?) RETURNING *`,\n [email]\n );\n\n return result.rows[0] as User;\n}\n\n// Conversation operations\nexport async function getUserConversations(userId: number): Promise {\n // Use the new participant-based query but return simple Conversation objects for backward compatibility\n const conversations = await getUserConversationsWithParticipants(userId);\n return conversations.map(({ participant_count, is_group, ...conversation }) => conversation);\n}\n\nexport async function createConversation(userId: number, title: string): Promise {\n const result = await sqlite.execute(\n `INSERT INTO ${CONVERSATIONS_TABLE} (user_id, title) VALUES (?, ?) RETURNING *`,\n [userId, title]\n );\n\n const conversation = result.rows[0] as Conversation;\n\n // Add creator as admin participant\n await addParticipant(conversation.id, userId, 'admin');\n\n return conversation;\n}\n\nexport async function updateConversationTimestamp(conversationId: number): Promise {\n await sqlite.execute(\n `UPDATE ${CONVERSATIONS_TABLE} SET updated_at = CURRENT_TIMESTAMP WHERE id = ?`,\n [conversationId]\n );\n}\n\nexport async function deleteConversation(conversationId: number, userId: number): Promise {\n // Check if user is admin\n const isAdmin = await isUserAdmin(conversationId, userId);\n if (!isAdmin) {\n return false;\n }\n\n // Delete all messages\n await sqlite.execute(\n `DELETE FROM ${MESSAGES_TABLE} WHERE conversation_id = ?`,\n [conversationId]\n );\n\n // Delete all participants\n await sqlite.execute(\n `DELETE FROM ${PARTICIPANTS_TABLE} WHERE conversation_id = ?`,\n [conversationId]\n );\n\n // Delete all invites\n await sqlite.execute(\n `DELETE FROM ${INVITES_TABLE} WHERE conversation_id = ?`,\n [conversationId]\n );\n\n // Delete the conversation\n const result = await sqlite.execute(\n `DELETE FROM ${CONVERSATIONS_TABLE} WHERE id = ?`,\n [conversationId]\n );\n\n return result.changes > 0;\n}\n\n// Message operations\nexport async function getConversationMessages(conversationId: number): Promise {\n const { rows } = await sqlite.execute(\n `SELECT * FROM ${MESSAGES_TABLE} WHERE conversation_id = ? ORDER BY timestamp ASC`,\n [conversationId]\n );\n\n return rows as Message[];\n}\n\nexport async function addMessage(conversationId: number, role: 'user' | 'assistant', content: string): Promise {\n const result = await sqlite.execute(\n `INSERT INTO ${MESSAGES_TABLE} (conversation_id, role, content) VALUES (?, ?, ?) RETURNING *`,\n [conversationId, role, content]\n );\n\n return result.rows[0] as Message;\n}\n\nexport async function getConversationWithMessages(conversationId: number, userId: number): Promise {\n // Check if user is participant\n const isParticipant = await isUserParticipant(conversationId, userId);\n if (!isParticipant) {\n return null;\n }\n\n // Get conversation\n const { rows: convRows } = await sqlite.execute(\n `SELECT * FROM ${CONVERSATIONS_TABLE} WHERE id = ?`,\n [conversationId]\n );\n\n if (convRows.length === 0) {\n return null;\n }\n\n const conversation = convRows[0] as Conversation;\n const messages = await getConversationMessages(conversationId);\n\n return {\n ...conversation,\n messages\n };\n}\n\n// Helper function to generate conversation title from first message\nexport function generateConversationTitle(firstMessage: string): string {\n // Take first 50 characters and add ellipsis if longer\n const title = firstMessage.trim();\n return title.length > 50 ? title.substring(0, 50) + '...' : title;\n}\n\n// Participant operations\nexport async function addParticipant(conversationId: number, userId: number, role: 'admin' | 'participant'): Promise {\n const result = await sqlite.execute(\n `INSERT INTO ${PARTICIPANTS_TABLE} (conversation_id, user_id, role) VALUES (?, ?, ?) RETURNING *`,\n [conversationId, userId, role]\n );\n\n return result.rows[0] as ConversationParticipant;\n}\n\nexport async function getConversationParticipants(conversationId: number): Promise {\n const { rows } = await sqlite.execute(`\n SELECT p.*, u.email as user_email \n FROM ${PARTICIPANTS_TABLE} p\n JOIN ${USERS_TABLE} u ON p.user_id = u.id\n WHERE p.conversation_id = ?\n ORDER BY p.role DESC, p.joined_at ASC\n `, [conversationId]);\n\n return rows as ConversationParticipant[];\n}\n\nexport async function isUserParticipant(conversationId: number, userId: number): Promise {\n const { rows } = await sqlite.execute(\n `SELECT 1 FROM ${PARTICIPANTS_TABLE} WHERE conversation_id = ? AND user_id = ?`,\n [conversationId, userId]\n );\n\n return rows.length > 0;\n}\n\nexport async function isUserAdmin(conversationId: number, userId: number): Promise {\n const { rows } = await sqlite.execute(\n `SELECT 1 FROM ${PARTICIPANTS_TABLE} WHERE conversation_id = ? AND user_id = ? AND role = 'admin'`,\n [conversationId, userId]\n );\n\n return rows.length > 0;\n}\n\nexport async function removeParticipant(conversationId: number, userId: number): Promise {\n const result = await sqlite.execute(\n `DELETE FROM ${PARTICIPANTS_TABLE} WHERE conversation_id = ? AND user_id = ?`,\n [conversationId, userId]\n );\n\n return result.changes > 0;\n}\n\nexport async function getUserConversationsWithParticipants(userId: number): Promise<(Conversation & { participant_count: number, is_group: boolean })[]> {\n const { rows } = await sqlite.execute(`\n SELECT c.*, \n COUNT(p.user_id) as participant_count,\n CASE WHEN COUNT(p.user_id) > 1 THEN 1 ELSE 0 END as is_group\n FROM ${CONVERSATIONS_TABLE} c\n JOIN ${PARTICIPANTS_TABLE} p ON c.id = p.conversation_id\n WHERE p.user_id = ?\n GROUP BY c.id\n ORDER BY c.updated_at DESC\n `, [userId]);\n\n return rows as (Conversation & { participant_count: number, is_group: boolean })[];\n}\n\n// Migration function to fix existing conversations without participants\nexport async function ensureUserIsParticipant(conversationId: number, userId: number): Promise {\n // Check if user is already a participant\n const isParticipant = await isUserParticipant(conversationId, userId);\n \n if (!isParticipant) {\n // Check if this conversation was created by this user (legacy check)\n const { rows } = await sqlite.execute(\n `SELECT user_id FROM ${CONVERSATIONS_TABLE} WHERE id = ?`,\n [conversationId]\n );\n \n if (rows.length > 0 && rows[0].user_id === userId) {\n // This user created the conversation, make them admin\n await addParticipant(conversationId, userId, 'admin');\n }\n }\n}\n\n// Invite operations\nexport async function createInvite(conversationId: number, invitedEmail: string, invitedBy: number): Promise {\n // Generate unique token\n const token = crypto.randomUUID();\n \n // Set expiration to 7 days from now\n const expiresAt = new Date();\n expiresAt.setDate(expiresAt.getDate() + 7);\n\n const result = await sqlite.execute(`\n INSERT INTO ${INVITES_TABLE} (conversation_id, invited_email, invite_token, invited_by, expires_at)\n VALUES (?, ?, ?, ?, ?) RETURNING *\n `, [conversationId, invitedEmail, token, invitedBy, expiresAt.toISOString()]);\n\n return result.rows[0] as ConversationInvite;\n}\n\nexport async function getInviteByToken(token: string): Promise<(ConversationInvite & { conversation_title: string, invited_by_email: string }) | null> {\n const { rows } = await sqlite.execute(`\n SELECT i.*, c.title as conversation_title, u.email as invited_by_email\n FROM ${INVITES_TABLE} i\n JOIN ${CONVERSATIONS_TABLE} c ON i.conversation_id = c.id\n JOIN ${USERS_TABLE} u ON i.invited_by = u.id\n WHERE i.invite_token = ?\n `, [token]);\n\n return rows.length > 0 ? rows[0] as (ConversationInvite & { conversation_title: string, invited_by_email: string }) : null;\n}\n\nexport async function deleteInvite(token: string): Promise {\n const result = await sqlite.execute(\n `DELETE FROM ${INVITES_TABLE} WHERE invite_token = ?`,\n [token]\n );\n\n return result.changes > 0;\n}\n\nexport async function isEmailAlreadyInvited(conversationId: number, email: string): Promise {\n const { rows } = await sqlite.execute(`\n SELECT 1 FROM ${INVITES_TABLE} \n WHERE conversation_id = ? AND invited_email = ? AND expires_at > datetime('now')\n `, [conversationId, email]);\n\n return rows.length > 0;\n}\n\nexport async function isEmailAlreadyParticipant(conversationId: number, email: string): Promise {\n const { rows } = await sqlite.execute(`\n SELECT 1 FROM ${PARTICIPANTS_TABLE} p\n JOIN ${USERS_TABLE} u ON p.user_id = u.id\n WHERE p.conversation_id = ? AND u.email = ?\n `, [conversationId, email]);\n\n return rows.length > 0;\n}","deleted","label",[168,169,149],"backend","database","permalink","https://www.val.town/x/jessicaocean/untitled-1522/code/backend/database/queries.ts","extension","actionData","errors"]