[{"_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","569c2cab8ded44a221d3e33107e42257e157d49b","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,"_147":148,"_170":171,"_172":-5},"handle","JoeEdoh","name","tos","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":116,"_14":117,"_118":119,"_120":119,"_121":122,"_123":122,"_124":122,"_125":119,"_126":119,"_23":127,"_130":131,"_133":134,"_146":20},"id","a89baf20-330d-11f0-a521-9e149126039e","createdAt",["D",1747479420483],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","49235890-330d-11f0-b519-ff88f6bc2fe6","pinnedFileId","pinPreview","screenshotVersion","likeCount",1,"d60b7af2-266f-4ef3-83b8-0b9c027b3a51","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_128":129},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzJ4RGlwbTBIZUdpcGJ5SzdyNWttb2RJYXo0ZCJ9","org",{"_93":94,"_132":129,"_12":111},"avatar","branch",{"_135":136,"_95":43,"_101":137,"_138":102,"_139":-5,"_140":-5,"_141":-5,"_142":-5,"_143":-5,"_144":96,"_145":94},"version",19,"a89be634-330d-11f0-a521-9e149126039e","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_101":149,"_95":150,"_151":152,"_153":154,"_155":137,"_156":157,"_158":159,"_103":160,"_135":32,"_161":162,"_163":164,"_165":20,"_166":-5,"_97":167},"f44ef990-330d-11f0-b940-9e149126039e","queries.ts","fileId","f44efa6c-330d-11f0-b940-9e149126039e","parentId","ac587efc-7881-44cc-b5cf-fcc097f4e7fb","branchId","branchVersion",3,"latest",true,["D",1747479547485],"fileType","script","content","import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport * as bcrypt from \"https://esm.sh/bcrypt@5.1.1\";\nimport {\n USERS_TABLE,\n POSTS_TABLE,\n COMMENTS_TABLE,\n LIKES_TABLE,\n MESSAGES_TABLE,\n CHAT_ROOMS_TABLE,\n CHAT_ROOM_MESSAGES_TABLE,\n CHAT_ROOM_USERS_TABLE,\n ONLINE_USERS_TABLE\n} from \"./migrations.ts\";\n\n// Types\nimport { User, Post, Comment, Message, ChatRoom, ChatRoomMessage } from \"../../shared/types.ts\";\n\n// User queries\nexport async function createUser(email: string, username: string, password: string): Promise {\n const passwordHash = await bcrypt.hash(password, 10);\n \n try {\n const result = await sqlite.execute(\n `INSERT INTO ${USERS_TABLE} (email, username, password_hash) VALUES (?, ?, ?) RETURNING *`,\n [email, username, passwordHash]\n );\n \n if (result.rows.length > 0) {\n const user = result.rows[0];\n return {\n id: user.id,\n email: user.email,\n username: user.username,\n bio: user.bio || \"\",\n profilePicUrl: user.profile_pic_url || \"\",\n isAdmin: Boolean(user.is_admin),\n createdAt: user.created_at\n };\n }\n return null;\n } catch (error) {\n console.error(\"Error creating user:\", error);\n return null;\n }\n}\n\nexport async function getUserByEmail(email: string): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${USERS_TABLE} WHERE email = ?`,\n [email]\n );\n \n if (result.rows.length > 0) {\n const user = result.rows[0];\n return {\n id: user.id,\n email: user.email,\n username: user.username,\n bio: user.bio || \"\",\n profilePicUrl: user.profile_pic_url || \"\",\n isAdmin: Boolean(user.is_admin),\n createdAt: user.created_at\n };\n }\n return null;\n}\n\nexport async function getUserById(id: number): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${USERS_TABLE} WHERE id = ?`,\n [id]\n );\n \n if (result.rows.length > 0) {\n const user = result.rows[0];\n return {\n id: user.id,\n email: user.email,\n username: user.username,\n bio: user.bio || \"\",\n profilePicUrl: user.profile_pic_url || \"\",\n isAdmin: Boolean(user.is_admin),\n createdAt: user.created_at\n };\n }\n return null;\n}\n\nexport async function updateUserProfile(\n userId: number, \n updates: { username?: string; bio?: string; profilePicUrl?: string }\n): Promise {\n const { username, bio, profilePicUrl } = updates;\n const updateFields = [];\n const values = [];\n \n if (username) {\n updateFields.push(\"username = ?\");\n values.push(username);\n }\n \n if (bio !== undefined) {\n updateFields.push(\"bio = ?\");\n values.push(bio);\n }\n \n if (profilePicUrl !== undefined) {\n updateFields.push(\"profile_pic_url = ?\");\n values.push(profilePicUrl);\n }\n \n if (updateFields.length === 0) {\n return await getUserById(userId);\n }\n \n values.push(userId);\n \n const result = await sqlite.execute(\n `UPDATE ${USERS_TABLE} SET ${updateFields.join(\", \")} WHERE id = ? RETURNING *`,\n values\n );\n \n if (result.rows.length > 0) {\n const user = result.rows[0];\n return {\n id: user.id,\n email: user.email,\n username: user.username,\n bio: user.bio || \"\",\n profilePicUrl: user.profile_pic_url || \"\",\n isAdmin: Boolean(user.is_admin),\n createdAt: user.created_at\n };\n }\n return null;\n}\n\nexport async function verifyUser(email: string, password: string): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${USERS_TABLE} WHERE email = ?`,\n [email]\n );\n \n if (result.rows.length > 0) {\n const user = result.rows[0];\n const passwordMatch = await bcrypt.compare(password, user.password_hash);\n \n if (passwordMatch) {\n return {\n id: user.id,\n email: user.email,\n username: user.username,\n bio: user.bio || \"\",\n profilePicUrl: user.profile_pic_url || \"\",\n isAdmin: Boolean(user.is_admin),\n createdAt: user.created_at\n };\n }\n }\n return null;\n}\n\n// Post queries\nexport async function createPost(userId: number, content: string, imageUrl?: string): Promise {\n try {\n const result = await sqlite.execute(\n `INSERT INTO ${POSTS_TABLE} (user_id, content, image_url) VALUES (?, ?, ?) RETURNING *`,\n [userId, content, imageUrl || null]\n );\n \n if (result.rows.length > 0) {\n const post = result.rows[0];\n const user = await getUserById(userId);\n \n return {\n id: post.id,\n userId: post.user_id,\n content: post.content,\n imageUrl: post.image_url || \"\",\n createdAt: post.created_at,\n user: user || undefined,\n likes: 0,\n comments: 0,\n liked: false\n };\n }\n return null;\n } catch (error) {\n console.error(\"Error creating post:\", error);\n return null;\n }\n}\n\nexport async function getPosts(userId?: number, limit = 20, offset = 0): Promise {\n const query = `\n SELECT \n p.*,\n u.username,\n u.profile_pic_url,\n (SELECT COUNT(*) FROM ${LIKES_TABLE} WHERE post_id = p.id) as likes_count,\n (SELECT COUNT(*) FROM ${COMMENTS_TABLE} WHERE post_id = p.id) as comments_count,\n (SELECT COUNT(*) FROM ${LIKES_TABLE} WHERE post_id = p.id AND user_id = ?) as user_liked\n FROM ${POSTS_TABLE} p\n JOIN ${USERS_TABLE} u ON p.user_id = u.id\n ORDER BY p.created_at DESC\n LIMIT ? OFFSET ?\n `;\n \n const result = await sqlite.execute(query, [userId || 0, limit, offset]);\n \n return result.rows.map(row => ({\n id: row.id,\n userId: row.user_id,\n content: row.content,\n imageUrl: row.image_url || \"\",\n createdAt: row.created_at,\n user: {\n id: row.user_id,\n username: row.username,\n profilePicUrl: row.profile_pic_url || \"\"\n },\n likes: row.likes_count,\n comments: row.comments_count,\n liked: Boolean(row.user_liked)\n }));\n}\n\nexport async function getPostById(postId: number, userId?: number): Promise {\n const query = `\n SELECT \n p.*,\n u.username,\n u.profile_pic_url,\n (SELECT COUNT(*) FROM ${LIKES_TABLE} WHERE post_id = p.id) as likes_count,\n (SELECT COUNT(*) FROM ${COMMENTS_TABLE} WHERE post_id = p.id) as comments_count,\n (SELECT COUNT(*) FROM ${LIKES_TABLE} WHERE post_id = p.id AND user_id = ?) as user_liked\n FROM ${POSTS_TABLE} p\n JOIN ${USERS_TABLE} u ON p.user_id = u.id\n WHERE p.id = ?\n `;\n \n const result = await sqlite.execute(query, [userId || 0, postId]);\n \n if (result.rows.length > 0) {\n const row = result.rows[0];\n return {\n id: row.id,\n userId: row.user_id,\n content: row.content,\n imageUrl: row.image_url || \"\",\n createdAt: row.created_at,\n user: {\n id: row.user_id,\n username: row.username,\n profilePicUrl: row.profile_pic_url || \"\"\n },\n likes: row.likes_count,\n comments: row.comments_count,\n liked: Boolean(row.user_liked)\n };\n }\n return null;\n}\n\nexport async function getUserPosts(userId: number, currentUserId?: number): Promise {\n const query = `\n SELECT \n p.*,\n u.username,\n u.profile_pic_url,\n (SELECT COUNT(*) FROM ${LIKES_TABLE} WHERE post_id = p.id) as likes_count,\n (SELECT COUNT(*) FROM ${COMMENTS_TABLE} WHERE post_id = p.id) as comments_count,\n (SELECT COUNT(*) FROM ${LIKES_TABLE} WHERE post_id = p.id AND user_id = ?) as user_liked\n FROM ${POSTS_TABLE} p\n JOIN ${USERS_TABLE} u ON p.user_id = u.id\n WHERE p.user_id = ?\n ORDER BY p.created_at DESC\n `;\n \n const result = await sqlite.execute(query, [currentUserId || 0, userId]);\n \n return result.rows.map(row => ({\n id: row.id,\n userId: row.user_id,\n content: row.content,\n imageUrl: row.image_url || \"\",\n createdAt: row.created_at,\n user: {\n id: row.user_id,\n username: row.username,\n profilePicUrl: row.profile_pic_url || \"\"\n },\n likes: row.likes_count,\n comments: row.comments_count,\n liked: Boolean(row.user_liked)\n }));\n}\n\nexport async function deletePost(postId: number, userId: number, isAdmin: boolean): Promise {\n try {\n // First check if the user is the post owner or an admin\n const post = await sqlite.execute(\n `SELECT * FROM ${POSTS_TABLE} WHERE id = ?`,\n [postId]\n );\n \n if (post.rows.length === 0) {\n return false;\n }\n \n if (post.rows[0].user_id !== userId && !isAdmin) {\n return false;\n }\n \n // Delete associated likes and comments first\n await sqlite.execute(`DELETE FROM ${LIKES_TABLE} WHERE post_id = ?`, [postId]);\n await sqlite.execute(`DELETE FROM ${COMMENTS_TABLE} WHERE post_id = ?`, [postId]);\n \n // Then delete the post\n await sqlite.execute(`DELETE FROM ${POSTS_TABLE} WHERE id = ?`, [postId]);\n \n return true;\n } catch (error) {\n console.error(\"Error deleting post:\", error);\n return false;\n }\n}\n\n// Comment queries\nexport async function createComment(postId: number, userId: number, content: string): Promise {\n try {\n const result = await sqlite.execute(\n `INSERT INTO ${COMMENTS_TABLE} (post_id, user_id, content) VALUES (?, ?, ?) RETURNING *`,\n [postId, userId, content]\n );\n \n if (result.rows.length > 0) {\n const comment = result.rows[0];\n const user = await getUserById(userId);\n \n return {\n id: comment.id,\n postId: comment.post_id,\n userId: comment.user_id,\n content: comment.content,\n createdAt: comment.created_at,\n user: user || undefined\n };\n }\n return null;\n } catch (error) {\n console.error(\"Error creating comment:\", error);\n return null;\n }\n}\n\nexport async function getPostComments(postId: number): Promise {\n const query = `\n SELECT \n c.*,\n u.username,\n u.profile_pic_url\n FROM ${COMMENTS_TABLE} c\n JOIN ${USERS_TABLE} u ON c.user_id = u.id\n WHERE c.post_id = ?\n ORDER BY c.created_at ASC\n `;\n \n const result = await sqlite.execute(query, [postId]);\n \n return result.rows.map(row => ({\n id: row.id,\n postId: row.post_id,\n userId: row.user_id,\n content: row.content,\n createdAt: row.created_at,\n user: {\n id: row.user_id,\n username: row.username,\n profilePicUrl: row.profile_pic_url || \"\"\n }\n }));\n}\n\nexport async function deleteComment(commentId: number, userId: number, isAdmin: boolean): Promise {\n try {\n // First check if the user is the comment owner or an admin\n const comment = await sqlite.execute(\n `SELECT * FROM ${COMMENTS_TABLE} WHERE id = ?`,\n [commentId]\n );\n \n if (comment.rows.length === 0) {\n return false;\n }\n \n if (comment.rows[0].user_id !== userId && !isAdmin) {\n return false;\n }\n \n // Delete the comment\n await sqlite.execute(`DELETE FROM ${COMMENTS_TABLE} WHERE id = ?`, [commentId]);\n \n return true;\n } catch (error) {\n console.error(\"Error deleting comment:\", error);\n return false;\n }\n}\n\n// Like queries\nexport async function toggleLike(postId: number, userId: number): Promise<{ liked: boolean; count: number }> {\n try {\n // Check if the user already liked the post\n const existingLike = await sqlite.execute(\n `SELECT * FROM ${LIKES_TABLE} WHERE post_id = ? AND user_id = ?`,\n [postId, userId]\n );\n \n if (existingLike.rows.length > 0) {\n // Unlike the post\n await sqlite.execute(\n `DELETE FROM ${LIKES_TABLE} WHERE post_id = ? AND user_id = ?`,\n [postId, userId]\n );\n \n // Get updated like count\n const countResult = await sqlite.execute(\n `SELECT COUNT(*) as count FROM ${LIKES_TABLE} WHERE post_id = ?`,\n [postId]\n );\n \n return { liked: false, count: countResult.rows[0].count };\n } else {\n // Like the post\n await sqlite.execute(\n `INSERT INTO ${LIKES_TABLE} (post_id, user_id) VALUES (?, ?)`,\n [postId, userId]\n );\n \n // Get updated like count\n const countResult = await sqlite.execute(\n `SELECT COUNT(*) as count FROM ${LIKES_TABLE} WHERE post_id = ?`,\n [postId]\n );\n \n return { liked: true, count: countResult.rows[0].count };\n }\n } catch (error) {\n console.error(\"Error toggling like:\", error);\n return { liked: false, count: 0 };\n }\n}\n\nexport async function getUserLikedPosts(userId: number): Promise {\n const query = `\n SELECT \n p.*,\n u.username,\n u.profile_pic_url,\n (SELECT COUNT(*) FROM ${LIKES_TABLE} WHERE post_id = p.id) as likes_count,\n (SELECT COUNT(*) FROM ${COMMENTS_TABLE} WHERE post_id = p.id) as comments_count,\n 1 as user_liked\n FROM ${POSTS_TABLE} p\n JOIN ${USERS_TABLE} u ON p.user_id = u.id\n JOIN ${LIKES_TABLE} l ON p.id = l.post_id\n WHERE l.user_id = ?\n ORDER BY l.created_at DESC\n `;\n \n const result = await sqlite.execute(query, [userId]);\n \n return result.rows.map(row => ({\n id: row.id,\n userId: row.user_id,\n content: row.content,\n imageUrl: row.image_url || \"\",\n createdAt: row.created_at,\n user: {\n id: row.user_id,\n username: row.username,\n profilePicUrl: row.profile_pic_url || \"\"\n },\n likes: row.likes_count,\n comments: row.comments_count,\n liked: Boolean(row.user_liked)\n }));\n}\n\n// Chat and message queries\nexport async function sendDirectMessage(senderId: number, receiverId: number, content: string): Promise {\n try {\n const result = await sqlite.execute(\n `INSERT INTO ${MESSAGES_TABLE} (sender_id, receiver_id, content) VALUES (?, ?, ?) RETURNING *`,\n [senderId, receiverId, content]\n );\n \n if (result.rows.length > 0) {\n const message = result.rows[0];\n const sender = await getUserById(senderId);\n \n return {\n id: message.id,\n senderId: message.sender_id,\n receiverId: message.receiver_id,\n content: message.content,\n isRead: Boolean(message.is_read),\n createdAt: message.created_at,\n sender: sender || undefined\n };\n }\n return null;\n } catch (error) {\n console.error(\"Error sending message:\", error);\n return null;\n }\n}\n\nexport async function getDirectMessages(userId1: number, userId2: number): Promise {\n const query = `\n SELECT \n m.*,\n u.username as sender_username,\n u.profile_pic_url as sender_profile_pic\n FROM ${MESSAGES_TABLE} m\n JOIN ${USERS_TABLE} u ON m.sender_id = u.id\n WHERE (m.sender_id = ? AND m.receiver_id = ?) OR (m.sender_id = ? AND m.receiver_id = ?)\n ORDER BY m.created_at ASC\n `;\n \n const result = await sqlite.execute(query, [userId1, userId2, userId2, userId1]);\n \n return result.rows.map(row => ({\n id: row.id,\n senderId: row.sender_id,\n receiverId: row.receiver_id,\n content: row.content,\n isRead: Boolean(row.is_read),\n createdAt: row.created_at,\n sender: {\n id: row.sender_id,\n username: row.sender_username,\n profilePicUrl: row.sender_profile_pic || \"\"\n }\n }));\n}\n\nexport async function markMessagesAsRead(userId: number, otherUserId: number): Promise {\n try {\n await sqlite.execute(\n `UPDATE ${MESSAGES_TABLE} SET is_read = 1 WHERE sender_id = ? AND receiver_id = ? AND is_read = 0`,\n [otherUserId, userId]\n );\n return true;\n } catch (error) {\n console.error(\"Error marking messages as read:\", error);\n return false;\n }\n}\n\nexport async function getUnreadMessageCounts(userId: number): Promise<{ [senderId: number]: number }> {\n const query = `\n SELECT sender_id, COUNT(*) as count\n FROM ${MESSAGES_TABLE}\n WHERE receiver_id = ? AND is_read = 0\n GROUP BY sender_id\n `;\n \n const result = await sqlite.execute(query, [userId]);\n \n const counts: { [senderId: number]: number } = {};\n for (const row of result.rows) {\n counts[row.sender_id] = row.count;\n }\n \n return counts;\n}\n\n// Chat room queries\nexport async function getChatRooms(): Promise {\n const query = `\n SELECT \n cr.*,\n (SELECT COUNT(*) FROM ${CHAT_ROOM_USERS_TABLE} WHERE chat_room_id = cr.id) as member_count\n FROM ${CHAT_ROOMS_TABLE} cr\n WHERE cr.is_public = 1\n ORDER BY cr.created_at DESC\n `;\n \n const result = await sqlite.execute(query);\n \n return result.rows.map(row => ({\n id: row.id,\n name: row.name,\n isPublic: Boolean(row.is_public),\n memberCount: row.member_count,\n createdAt: row.created_at\n }));\n}\n\nexport async function joinChatRoom(userId: number, chatRoomId: number): Promise {\n try {\n // Check if user is already in the chat room\n const existingMember = await sqlite.execute(\n `SELECT * FROM ${CHAT_ROOM_USERS_TABLE} WHERE chat_room_id = ? AND user_id = ?`,\n [chatRoomId, userId]\n );\n \n if (existingMember.rows.length === 0) {\n await sqlite.execute(\n `INSERT INTO ${CHAT_ROOM_USERS_TABLE} (chat_room_id, user_id) VALUES (?, ?)`,\n [chatRoomId, userId]\n );\n }\n \n return true;\n } catch (error) {\n console.error(\"Error joining chat room:\", error);\n return false;\n }\n}\n\nexport async function leaveChatRoom(userId: number, chatRoomId: number): Promise {\n try {\n await sqlite.execute(\n `DELETE FROM ${CHAT_ROOM_USERS_TABLE} WHERE chat_room_id = ? AND user_id = ?`,\n [chatRoomId, userId]\n );\n \n return true;\n } catch (error) {\n console.error(\"Error leaving chat room:\", error);\n return false;\n }\n}\n\nexport async function sendChatRoomMessage(chatRoomId: number, userId: number, content: string): Promise {\n try {\n const result = await sqlite.execute(\n `INSERT INTO ${CHAT_ROOM_MESSAGES_TABLE} (chat_room_id, user_id, content) VALUES (?, ?, ?) RETURNING *`,\n [chatRoomId, userId, content]\n );\n \n if (result.rows.length > 0) {\n const message = result.rows[0];\n const user = await getUserById(userId);\n \n return {\n id: message.id,\n chatRoomId: message.chat_room_id,\n userId: message.user_id,\n content: message.content,\n createdAt: message.created_at,\n user: user || undefined\n };\n }\n return null;\n } catch (error) {\n console.error(\"Error sending chat room message:\", error);\n return null;\n }\n}\n\nexport async function getChatRoomMessages(chatRoomId: number, limit = 50): Promise {\n const query = `\n SELECT \n crm.*,\n u.username,\n u.profile_pic_url\n FROM ${CHAT_ROOM_MESSAGES_TABLE} crm\n JOIN ${USERS_TABLE} u ON crm.user_id = u.id\n WHERE crm.chat_room_id = ?\n ORDER BY crm.created_at DESC\n LIMIT ?\n `;\n \n const result = await sqlite.execute(query, [chatRoomId, limit]);\n \n return result.rows.map(row => ({\n id: row.id,\n chatRoomId: row.chat_room_id,\n userId: row.user_id,\n content: row.content,\n createdAt: row.created_at,\n user: {\n id: row.user_id,\n username: row.username,\n profilePicUrl: row.profile_pic_url || \"\"\n }\n })).reverse(); // Reverse to get oldest messages first\n}\n\nexport async function getChatRoomMembers(chatRoomId: number): Promise {\n const query = `\n SELECT \n u.*\n FROM ${USERS_TABLE} u\n JOIN ${CHAT_ROOM_USERS_TABLE} cru ON u.id = cru.user_id\n WHERE cru.chat_room_id = ?\n ORDER BY u.username ASC\n `;\n \n const result = await sqlite.execute(query, [chatRoomId]);\n \n return result.rows.map(row => ({\n id: row.id,\n email: row.email,\n username: row.username,\n bio: row.bio || \"\",\n profilePicUrl: row.profile_pic_url || \"\",\n isAdmin: Boolean(row.is_admin),\n createdAt: row.created_at\n }));\n}\n\n// Online users\nexport async function updateUserOnlineStatus(userId: number): Promise {\n try {\n // Check if user is already in the online users table\n const existingUser = await sqlite.execute(\n `SELECT * FROM ${ONLINE_USERS_TABLE} WHERE user_id = ?`,\n [userId]\n );\n \n if (existingUser.rows.length === 0) {\n await sqlite.execute(\n `INSERT INTO ${ONLINE_USERS_TABLE} (user_id) VALUES (?)`,\n [userId]\n );\n } else {\n await sqlite.execute(\n `UPDATE ${ONLINE_USERS_TABLE} SET last_active = CURRENT_TIMESTAMP WHERE user_id = ?`,\n [userId]\n );\n }\n \n return true;\n } catch (error) {\n console.error(\"Error updating online status:\", error);\n return false;\n }\n}\n\nexport async function getOnlineUsers(timeoutMinutes = 5): Promise {\n const query = `\n SELECT \n u.*\n FROM ${USERS_TABLE} u\n JOIN ${ONLINE_USERS_TABLE} ou ON u.id = ou.user_id\n WHERE datetime(ou.last_active, '+${timeoutMinutes} minutes') > datetime('now')\n ORDER BY u.username ASC\n `;\n \n const result = await sqlite.execute(query);\n \n return result.rows.map(row => ({\n id: row.id,\n email: row.email,\n username: row.username,\n bio: row.bio || \"\",\n profilePicUrl: row.profile_pic_url || \"\",\n isAdmin: Boolean(row.is_admin),\n createdAt: row.created_at\n }));\n}\n\nexport async function removeOfflineUsers(timeoutMinutes = 5): Promise {\n await sqlite.execute(\n `DELETE FROM ${ONLINE_USERS_TABLE} WHERE datetime(last_active, '+${timeoutMinutes} minutes') < datetime('now')`\n );\n}","deleted","label",[168,169,150],"backend","database","permalink","https://www.val.town/x/JoeEdoh/tos/code/backend/database/queries.ts","extension","actionData","errors"]