[{"_1":2,"_175":-5,"_176":-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","77fda040d260e43e66e3017d68686b51ac04eda6","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,"_153":154,"_172":173,"_174":-5},"handle","dcm31","name","vtProjectSearch","path","db.ts","project",{"_101":102,"_95":96,"_103":104,"_105":-5,"_106":20,"_107":108,"_109":-5,"_110":111,"_12":112,"_113":114,"_115":116,"_117":-5,"_118":32,"_14":119,"_120":121,"_122":121,"_123":124,"_125":124,"_126":124,"_127":121,"_128":121,"_23":129,"_132":133,"_135":136,"_152":20},"id","1df6efd4-2222-11f0-8908-569c3dd06744","createdAt",["D",1745619037535],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/57406a01-9ef3-451b-14e4-2df202e53900/square512","9319c175-2593-4f88-ba21-04f2ef7b1c28","pinnedFileId","90d61d2e-3c95-47cb-bc12-539199e6e624","pinPreview",true,"screenshotVersion","likeCount","d663a026-6449-42f6-9156-1d4a2d64d38c","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_130":131},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvdXBsb2FkZWQvaW1nXzJ3SGtIMlhlMGwwT0JoSXZJckVVTXJuajN1YyJ9","org",{"_93":94,"_134":131},"avatar","branch",{"_137":138,"_95":43,"_101":139,"_140":102,"_141":142,"_143":144,"_145":108,"_146":147,"_148":149,"_150":96,"_151":94},"version",18,"1df92cf4-2222-11f0-8908-569c3dd06744","projectId","forkedBranchId","cdebffc6-0105-11f0-90bd-569c3dd06744","forkedBranchVersion",158,"forkedProjectPrivacy","forkedProjectId","cdebb08e-0105-11f0-90bd-569c3dd06744","forkedProjectOrgId","c1e7642a-74cc-4d69-8652-20abbdeaa94e","projectName","userHandle","isOwned","file",{"_101":155,"_95":98,"_156":157,"_158":-5,"_159":139,"_160":161,"_162":116,"_103":163,"_137":164,"_165":166,"_167":168,"_169":20,"_170":-5,"_97":171},"285bf78e-2237-11f0-8db6-569c3dd06744","fileId","0a86d8b2-f42a-486a-9f67-03c67c297c9b","parentId","branchId","branchVersion",6,"latest",["D",1745628074402],2,"fileType","script","content","import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport { z } from \"npm:zod\";\nimport {\n EnhancedSearchResult as TypesEnhancedSearchResult,\n SearchResponse as TypesSearchResponse,\n UserSearchResult,\n ValSearchResult,\n} from \"./types.tsx\";\n\n// In-memory data structure for typeahead\nexport const typeaheadStrings: string[] = [];\n\n// Load all usernames and val paths into memory for fast typeahead\nexport async function loadTypeaheadDataIntoMemory(): Promise {\n console.log(\"Loading typeahead data into memory...\");\n\n // Clear existing data\n typeaheadStrings.length = 0;\n\n // Load unique usernames\n const usersResult = await sqlite.execute(\n `SELECT DISTINCT username\n FROM ${tablePrefix}_vals\n ORDER BY username`,\n );\n\n for (const row of usersResult.rows) {\n if (row.username) typeaheadStrings.push(String(row.username));\n }\n\n // Load vals with username prefix\n const valsResult = await sqlite.execute(\n `SELECT username, name\n FROM ${tablePrefix}_vals\n ORDER BY updated_at DESC`,\n );\n\n for (const row of valsResult.rows) {\n typeaheadStrings.push(`${row.username}/${row.name}`);\n }\n\n console.log(`Loaded ${typeaheadStrings.length} typeahead strings into memory`);\n}\n\n/**\n * Search typeahead data by prefix\n */\nexport function searchTypeahead(query: string, limit: number = 10): string[] {\n const lowerQuery = query.toLowerCase();\n const results: string[] = [];\n\n for (const str of typeaheadStrings) {\n if (str.toLowerCase().includes(lowerQuery)) {\n results.push(str);\n if (results.length >= limit) break;\n }\n }\n\n return results;\n}\n\n/**\n * Get activity data for the last 6 months\n */\nexport async function getActivityHeatmap(): Promise<{\n date: string;\n count: number;\n}[]> {\n // Calculate date for 6 months ago\n const now = new Date();\n const sixMonthsAgo = new Date(now);\n sixMonthsAgo.setMonth(now.getMonth() - 6);\n\n // Format dates for SQL\n const sixMonthsAgoStr = sixMonthsAgo.toISOString();\n\n // Get file activity data grouped by day\n const activityResult = await sqlite.execute(\n `SELECT \n strftime('%Y-%m-%d', updated_at) as date,\n COUNT(*) as count\n FROM ${tablePrefix}_files\n WHERE updated_at >= ?\n GROUP BY date\n ORDER BY date ASC`,\n [sixMonthsAgoStr],\n );\n\n return activityResult.rows.map(row => ({\n date: String(row.date),\n count: Number(row.count),\n }));\n}\n\n/**\n * Get top contributors based on recency\n */\nexport async function getTopContributors(limit: number = 10): Promise<{\n username: string;\n valCount: number;\n fileCount: number;\n url: string;\n profile_image_url: string | null;\n updated_at: string;\n}[]> {\n const result = await sqlite.execute(\n `SELECT \n p.username,\n COUNT(DISTINCT p.id) as val_count,\n COUNT(DISTINCT f.id) as file_count,\n 'https://val.town/u/' || p.username as url,\n u.profile_image_url,\n MAX(p.updated_at) as updated_at\n FROM ${tablePrefix}_vals p\n LEFT JOIN ${tablePrefix}_users u ON p.username = u.username\n LEFT JOIN ${tablePrefix}_files f ON p.id = f.val_id\n GROUP BY p.username\n ORDER BY updated_at DESC, val_count DESC\n LIMIT ?`,\n [limit],\n );\n\n return result.rows.map(row => ({\n username: String(row.username),\n valCount: Number(row.val_count),\n fileCount: Number(row.file_count),\n url: String(row.url),\n profile_image_url: row.profile_image_url ? String(row.profile_image_url) : null,\n updated_at: String(row.updated_at),\n }));\n}\n\n/**\n * Get most active vals based on recency and file count\n */\nexport async function getMostActiveVals(limit: number = 10): Promise<{\n name: string;\n username: string;\n fileCount: number;\n description: string | null;\n url: string;\n image_url: string | null;\n updated_at: string;\n}[]> {\n const result = await sqlite.execute(\n `SELECT \n p.name,\n p.username,\n COUNT(f.id) as file_count,\n p.description,\n p.url,\n p.image_url,\n p.updated_at\n FROM ${tablePrefix}_vals p\n LEFT JOIN ${tablePrefix}_files f ON p.id = f.val_id\n GROUP BY p.id\n ORDER BY p.updated_at DESC, file_count DESC\n LIMIT ?`,\n [limit],\n );\n\n return result.rows.map(row => ({\n name: String(row.name),\n username: String(row.username),\n fileCount: Number(row.file_count),\n description: row.description ? String(row.description) : null,\n url: String(row.url),\n image_url: row.image_url ? String(row.image_url) : null,\n updated_at: String(row.updated_at),\n }));\n}\n\n/**\n * Get database statistics for the homepage\n */\nexport async function getSearchStats(): Promise<{\n totalVals: number;\n totalFiles: number;\n valsLastDay: number;\n valsLastWeek: number;\n valsLastMonth: number;\n activityHeatmap: { date: string; count: number }[];\n topContributors: {\n username: string;\n valCount: number;\n fileCount: number;\n url: string;\n profile_image_url: string | null;\n updated_at: string;\n }[];\n mostActiveVals: {\n name: string;\n username: string;\n fileCount: number;\n description: string | null;\n url: string;\n image_url: string | null;\n updated_at: string;\n }[];\n}> {\n // Get current time and dates for 1 day, 1 week, and 1 month ago\n const now = new Date();\n const oneDayAgo = new Date(now);\n oneDayAgo.setDate(now.getDate() - 1);\n\n const oneWeekAgo = new Date(now);\n oneWeekAgo.setDate(now.getDate() - 7);\n\n const oneMonthAgo = new Date(now);\n oneMonthAgo.setMonth(now.getMonth() - 1);\n\n // Format dates for SQL\n const oneDayAgoStr = oneDayAgo.toISOString();\n const oneWeekAgoStr = oneWeekAgo.toISOString();\n const oneMonthAgoStr = oneMonthAgo.toISOString();\n\n // Execute all queries in parallel for better performance\n const [\n totalValsResult,\n totalFilesResult,\n recentValsResult,\n activityHeatmap,\n topContributors,\n mostActiveVals,\n ] = await Promise.all([\n // Get total counts\n sqlite.execute(\n `SELECT COUNT(*) as count FROM ${tablePrefix}_vals`,\n ),\n\n sqlite.execute(\n `SELECT COUNT(*) as count FROM ${tablePrefix}_files`,\n ),\n\n // Get counts for recent vals\n sqlite.execute(\n `SELECT\n SUM(CASE WHEN updated_at >= ? THEN 1 ELSE 0 END) as last_day,\n SUM(CASE WHEN updated_at >= ? THEN 1 ELSE 0 END) as last_week,\n SUM(CASE WHEN updated_at >= ? THEN 1 ELSE 0 END) as last_month\n FROM ${tablePrefix}_vals`,\n [oneDayAgoStr, oneWeekAgoStr, oneMonthAgoStr],\n ),\n\n // Get activity heatmap data\n getActivityHeatmap(),\n\n // Get top contributors\n getTopContributors(10),\n\n // Get most active vals\n getMostActiveVals(10),\n ]);\n\n return {\n totalVals: Number(totalValsResult.rows[0]?.count || 0),\n totalFiles: Number(totalFilesResult.rows[0]?.count || 0),\n valsLastDay: Number(recentValsResult.rows[0]?.last_day || 0),\n valsLastWeek: Number(recentValsResult.rows[0]?.last_week || 0),\n valsLastMonth: Number(recentValsResult.rows[0]?.last_month || 0),\n activityHeatmap,\n topContributors,\n mostActiveVals,\n };\n}\n\n// Original example code\nconst tablePrefix = \"vt_val_search_v5\";\n\n// Create tables for val file content search\nawait sqlite.batch([\n // Users table\n `CREATE TABLE IF NOT EXISTS ${tablePrefix}_users (\n id TEXT PRIMARY KEY,\n username TEXT,\n bio TEXT,\n profile_image_url TEXT,\n url TEXT NOT NULL,\n updated_at TIMESTAMP NOT NULL\n )`,\n\n // Vals table\n `CREATE TABLE IF NOT EXISTS ${tablePrefix}_vals (\n id TEXT PRIMARY KEY,\n url TEXT NOT NULL,\n name TEXT NOT NULL,\n username TEXT NOT NULL,\n updated_at TIMESTAMP NOT NULL,\n forked_branch_id TEXT,\n description TEXT,\n image_url TEXT,\n user_id TEXT,\n FOREIGN KEY (user_id) REFERENCES ${tablePrefix}_users(id)\n )`,\n\n // Files table with foreign key to vals\n `CREATE TABLE IF NOT EXISTS ${tablePrefix}_files (\n id TEXT PRIMARY KEY,\n url TEXT NOT NULL,\n val_id TEXT NOT NULL,\n name TEXT NOT NULL,\n content TEXT,\n updated_at TIMESTAMP NOT NULL,\n FOREIGN KEY (val_id) REFERENCES ${tablePrefix}_vals(id)\n )`,\n\n // Create index for faster text searches\n `CREATE INDEX IF NOT EXISTS idx_${tablePrefix}_files_content ON ${tablePrefix}_files(content)`,\n\n // Create index for val lookups\n `CREATE INDEX IF NOT EXISTS idx_${tablePrefix}_files_val_id ON ${tablePrefix}_files(val_id)`,\n\n // Create index for username lookups\n `CREATE INDEX IF NOT EXISTS idx_${tablePrefix}_users_username ON ${tablePrefix}_users(username)`,\n]);\n\n// Define types with Zod schemas\nconst UserSchema = z.object({\n id: z.string(),\n username: z.string().nullable(),\n bio: z.string().nullable(),\n profile_image_url: z.string().nullable(),\n url: z.string(),\n updated_at: z.string().datetime(),\n});\n\nconst ValSchema = z.object({\n id: z.string(),\n url: z.string(),\n name: z.string(),\n username: z.string(),\n description: z.string().nullable(),\n image_url: z.string().nullable(),\n forked_branch_id: z.string().nullable(),\n updated_at: z.string().datetime(),\n user_id: z.string().nullable(),\n});\n\nconst FileSchema = z.object({\n id: z.string(),\n url: z.string(),\n val_id: z.string(),\n name: z.string(),\n content: z.string().nullable(),\n updated_at: z.string().datetime(),\n});\n\nconst ValWithFilesSchema = ValSchema.extend({\n files: z.array(FileSchema).optional(),\n});\n\n// TypeScript interfaces derived from Zod schemas\ntype User = z.infer;\ntype Val = z.infer;\ntype File = z.infer;\ntype ValWithFiles = z.infer;\n\n// Search result type\ntype FileSearchResult = File & {\n val_name: string;\n username: string;\n val_url: string;\n};\n\n// Helper functions for val and file management\n\n/**\n * Get a user by ID\n */\nexport async function getUser(userId: string): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${tablePrefix}_users WHERE id = ?`,\n [userId],\n );\n\n if (result.rows.length === 0) return null;\n\n try {\n return UserSchema.parse(result.rows[0]);\n } catch (error) {\n console.error(\"Invalid user data:\", error);\n return null;\n }\n}\n\n/**\n * Insert or update a user if it's newer than existing data\n */\nexport async function upsertUser(user: User): Promise {\n // Check if user exists and compare timestamps\n const existingUser = await getUser(user.id);\n\n if (!existingUser) {\n // Insert new user\n await sqlite.execute(\n `INSERT INTO ${tablePrefix}_users (id, username, bio, profile_image_url, url, updated_at)\n VALUES (?, ?, ?, ?, ?, ?)`,\n [\n user.id,\n user.username,\n user.bio,\n user.profile_image_url,\n user.url,\n user.updated_at,\n ],\n );\n return true; // Inserted\n } else if (user.updated_at > existingUser.updated_at) {\n // Update existing user if newer\n await sqlite.execute(\n `UPDATE ${tablePrefix}_users\n SET username = ?, bio = ?, profile_image_url = ?, url = ?, updated_at = ?\n WHERE id = ?`,\n [\n user.username,\n user.bio,\n user.profile_image_url,\n user.url,\n user.updated_at,\n user.id,\n ],\n );\n return true; // Updated\n }\n\n return false; // Not updated (existing data is newer)\n}\n\n/**\n * Get a val by ID\n */\nasync function getVal(valId: string): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${tablePrefix}_vals WHERE id = ?`,\n [valId],\n );\n\n if (result.rows.length === 0) return null;\n\n try {\n return ValSchema.parse(result.rows[0]);\n } catch (error) {\n console.error(\"Invalid val data:\", error);\n return null;\n }\n}\n\n/**\n * Insert or update a val if it's newer than existing data\n */\nexport async function upsertVal(val: Val): Promise {\n // Convert Date object to string if needed\n const updatedAt = val.updated_at;\n\n // Check if val exists and compare timestamps\n const existingVal = await getVal(val.id);\n\n if (!existingVal) {\n // Insert new val\n await sqlite.execute(\n `INSERT INTO ${tablePrefix}_vals (id, url, name, username, updated_at, forked_branch_id, description, image_url, user_id)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n val.id,\n val.url,\n val.name,\n val.username,\n updatedAt,\n val.forked_branch_id,\n val.description,\n val.image_url,\n val.user_id,\n ],\n );\n return true; // Inserted\n } else if (updatedAt > existingVal.updated_at) {\n // Update existing val if newer\n await sqlite.execute(\n `UPDATE ${tablePrefix}_vals\n SET url = ?, name = ?, username = ?, updated_at = ?, forked_branch_id = ?, description = ?, image_url = ?, user_id = ?\n WHERE id = ?`,\n [\n val.url,\n val.name,\n val.username,\n updatedAt,\n val.forked_branch_id,\n val.description,\n val.image_url,\n val.user_id,\n val.id,\n ],\n );\n return true; // Updated\n }\n\n return false; // Not updated (existing data is newer)\n}\n\n/**\n * Get a file by ID\n */\nasync function getFile(fileId: string): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${tablePrefix}_files WHERE id = ?`,\n [fileId],\n );\n\n if (result.rows.length === 0) return null;\n\n try {\n return FileSchema.parse(result.rows[0]);\n } catch (error) {\n console.error(\"Invalid file data:\", error);\n return null;\n }\n}\n\n/**\n * Insert or update a file if it's newer than existing data\n */\nexport async function upsertFile(file: File): Promise {\n // Convert Date object to string if needed\n\n // Check if file exists and compare timestamps\n const existingFile = await getFile(file.id);\n\n if (!existingFile) {\n // Insert new file\n await sqlite.execute(\n `INSERT INTO ${tablePrefix}_files (id, url, val_id, name, content, updated_at)\n VALUES (?, ?, ?, ?, ?, ?)`,\n [\n file.id,\n file.url,\n file.val_id,\n file.name,\n file.content,\n file.updated_at,\n ],\n );\n return true; // Inserted\n } else if (file.updated_at > existingFile.updated_at) {\n // Update existing file if newer\n await sqlite.execute(\n `UPDATE ${tablePrefix}_files SET url = ?, val_id = ?, name = ?, content = ?, updated_at = ?\n WHERE id = ?`,\n [\n file.url,\n file.val_id,\n file.name,\n file.content,\n file.updated_at,\n file.id,\n ],\n );\n return true; // Updated\n }\n\n return false; // Not updated (existing data is newer)\n}\n\n/**\n * Enhanced search result with code context for internal use\n */\ntype EnhancedSearchResult = TypesEnhancedSearchResult;\n\n/**\n * Extract matched lines with context around matches\n */\nfunction extractMatchedLines(\n content: string,\n searchText: string,\n contextLines: number = 2,\n): EnhancedSearchResult[\"matchedLines\"] {\n if (!content) return [];\n\n const lines = content.split(\"\\n\");\n const matchedLineIndices: number[] = [];\n\n // Find all matching lines\n for (let i = 0; i < lines.length; i++) {\n if (lines[i].toLowerCase().includes(searchText.toLowerCase())) {\n matchedLineIndices.push(i);\n }\n }\n\n // Create groups of matched lines with context\n const result: {\n lineNumber: number;\n lineContent: string;\n isMatch: boolean;\n }[] = [];\n const processedLines = new Set();\n\n for (const matchIndex of matchedLineIndices) {\n // Calculate range for context\n const startLine = Math.max(0, matchIndex - contextLines);\n const endLine = Math.min(lines.length - 1, matchIndex + contextLines);\n\n // Add lines with context\n for (let i = startLine; i <= endLine; i++) {\n if (!processedLines.has(i)) {\n result.push({\n lineNumber: i + 1, // 1-based line number for display\n lineContent: lines[i],\n isMatch: matchedLineIndices.includes(i),\n });\n processedLines.add(i);\n }\n }\n\n // Add a separator between non-contiguous blocks\n if (\n result.length > 0 && result[result.length - 1].lineNumber !== endLine + 1\n ) {\n result.push({\n lineNumber: -1, // Sentinel value for separator\n lineContent: \"...\",\n isMatch: false,\n });\n }\n }\n\n return result;\n}\n\n/**\n * Search for files containing specific text\n */\nexport async function searchFileContent(\n searchText: string,\n): Promise {\n const searchPattern = `%${searchText}%`;\n\n const result = await sqlite.execute(\n `SELECT f.*, p.name as val_name, p.url as val_url, p.username, p.description\n FROM ${tablePrefix}_files f\n JOIN ${tablePrefix}_vals p ON f.val_id = p.id\n WHERE f.content LIKE ?\n OR p.username LIKE ?\n OR p.name LIKE ?\n OR f.name LIKE ?\n OR p.description LIKE ?\n ORDER BY f.updated_at DESC`,\n [searchPattern, searchPattern, searchPattern, searchPattern, searchPattern],\n );\n\n const FileSearchResultSchema = FileSchema.extend({\n val_name: z.string(),\n val_url: z.string(),\n username: z.string(),\n description: z.string().nullable(),\n });\n\n try {\n return z.array(FileSearchResultSchema).parse(result.rows);\n } catch (error) {\n console.error(\"Invalid search results:\", error);\n return [];\n }\n}\n\n/**\n * Search response with pagination and timing info\n */\nexport type SearchResponse = {\n results: EnhancedSearchResult[];\n totalResults: number;\n page: number;\n pageSize: number;\n totalPages: number;\n executionTimeMs: number;\n};\n\n/**\n * Count total file search results\n */\nexport async function countFileSearchResults(searchText: string): Promise {\n const searchPattern = `%${searchText}%`;\n\n const result = await sqlite.execute(\n `SELECT COUNT(*) as total\n FROM ${tablePrefix}_files f\n JOIN ${tablePrefix}_vals p ON f.val_id = p.id\n WHERE f.content LIKE ?\n OR f.name LIKE ?`,\n [searchPattern, searchPattern],\n );\n\n return Number(result.rows[0]?.total) || 0;\n}\n\n/**\n * Count total val search results\n */\nexport async function countValSearchResults(searchText: string): Promise {\n const searchPattern = `%${searchText}%`;\n\n const result = await sqlite.execute(\n `SELECT COUNT(DISTINCT p.id) as total\n FROM ${tablePrefix}_vals p\n WHERE p.name LIKE ?\n OR p.description LIKE ?`,\n [searchPattern, searchPattern],\n );\n\n return Number(result.rows[0]?.total) || 0;\n}\n\n/**\n * Count total user search results\n */\nexport async function countUserSearchResults(searchText: string): Promise {\n const searchPattern = `%${searchText}%`;\n\n const result = await sqlite.execute(\n `SELECT COUNT(*) as total\n FROM ${tablePrefix}_users u\n WHERE u.username LIKE ?\n OR u.bio LIKE ?`,\n [searchPattern, searchPattern],\n );\n\n return Number(result.rows[0]?.total) || 0;\n}\n\n/**\n * Count total vals for a specific username\n */\nexport async function countUserVals(username: string): Promise {\n const result = await sqlite.execute(\n `SELECT COUNT(*) as total\n FROM ${tablePrefix}_vals\n WHERE username = ?`,\n [username],\n );\n\n return Number(result.rows[0]?.total) || 0;\n}\n\n/**\n * Get vals by username with pagination\n */\nexport async function getValsByUsername(\n username: string,\n page: number = 1,\n pageSize: number = 10\n): Promise {\n const offset = (page - 1) * pageSize;\n\n const result = await sqlite.execute(\n `SELECT v.*,\n (SELECT COUNT(*) FROM ${tablePrefix}_files f WHERE f.val_id = v.id) as matchCount\n FROM ${tablePrefix}_vals v\n WHERE v.username = ?\n ORDER BY v.updated_at DESC\n LIMIT ? OFFSET ?`,\n [username, pageSize, offset],\n );\n\n const ValSearchResultSchema = ValSchema.extend({\n matchCount: z.number(),\n });\n\n try {\n return z.array(ValSearchResultSchema).parse(result.rows);\n } catch (error) {\n console.error(\"Invalid vals by username results:\", error);\n return [];\n }\n}\n\n/**\n * Search for vals matching the query\n */\nexport async function searchVals(\n searchText: string,\n page: number = 1,\n pageSize: number = 10,\n): Promise {\n const searchPattern = `%${searchText}%`;\n const offset = (page - 1) * pageSize;\n\n const result = await sqlite.execute(\n `SELECT p.*,\n (SELECT COUNT(*) FROM ${tablePrefix}_files f WHERE f.val_id = p.id AND\n (f.content LIKE ? OR f.name LIKE ?)) as matchCount\n FROM ${tablePrefix}_vals p\n WHERE p.name LIKE ?\n OR p.description LIKE ?\n ORDER BY p.updated_at DESC\n LIMIT ? OFFSET ?`,\n [searchPattern, searchPattern, searchPattern, searchPattern, pageSize, offset],\n );\n\n const ValSearchResultSchema = ValSchema.extend({\n matchCount: z.number(),\n });\n\n try {\n return z.array(ValSearchResultSchema).parse(result.rows);\n } catch (error) {\n console.error(\"Invalid val search results:\", error);\n return [];\n }\n}\n\n/**\n * Search for users matching the query\n */\nexport async function searchUsers(\n searchText: string,\n page: number = 1,\n pageSize: number = 10,\n): Promise {\n const searchPattern = `%${searchText}%`;\n const offset = (page - 1) * pageSize;\n\n const result = await sqlite.execute(\n `SELECT u.id, u.username, u.bio, u.profile_image_url, u.url, u.updated_at,\n (SELECT COUNT(*) FROM ${tablePrefix}_vals p\n WHERE p.user_id = u.id) as matchCount\n FROM ${tablePrefix}_users u\n WHERE u.username LIKE ?\n OR u.bio LIKE ?\n ORDER BY u.updated_at DESC\n LIMIT ? OFFSET ?`,\n [searchPattern, searchPattern, pageSize, offset],\n );\n\n const UserSearchResultSchema = z.object({\n id: z.string(),\n username: z.string().nullable(),\n bio: z.string().nullable(),\n profile_image_url: z.string().nullable(),\n url: z.string(),\n updated_at: z.string().datetime(),\n matchCount: z.number(),\n });\n\n try {\n return z.array(UserSearchResultSchema).parse(result.rows);\n } catch (error) {\n console.error(\"Invalid user search results:\", error);\n return [];\n }\n}\n\n/**\n * Enhanced search that returns matched content with context and pagination\n */\nexport async function searchFileContentWithContext(\n searchText: string,\n contextLines: number = 2,\n page: number = 1,\n pageSize: number = 10,\n resultType: \"files\" | \"vals\" | \"users\" = \"files\",\n): Promise {\n if (!searchText.trim()) {\n return {\n fileResults: [],\n valResults: [],\n userResults: [],\n docResults: [],\n totalFileResults: 0,\n totalValResults: 0,\n totalUserResults: 0,\n totalDocResults: 0,\n page,\n pageSize,\n totalPages: 0,\n executionTimeMs: 0,\n resultType,\n };\n }\n\n const startTime = performance.now();\n\n // Calculate pagination parameters\n const offset = (page - 1) * pageSize;\n\n // Start all database queries in parallel\n // 1. Launch count queries\n const countsPromise = Promise.all([\n countFileSearchResults(searchText),\n countValSearchResults(searchText),\n countUserSearchResults(searchText),\n ]);\n\n // 2. Start preparing search pattern\n const searchPattern = `%${searchText}%`;\n\n // 3. Start all data fetching queries in parallel, regardless of result type\n // This way we don't wait for counts to finish before starting data queries\n const fileResultsPromise = (async () => {\n // Always launch the files query for the active type or for samples\n const result = await sqlite.execute(\n `SELECT f.*, p.name as val_name, p.url as val_url, p.username, p.description, p.image_url\n FROM ${tablePrefix}_files f\n JOIN ${tablePrefix}_vals p ON f.val_id = p.id\n WHERE f.content LIKE ?\n OR f.name LIKE ?\n ORDER BY f.updated_at DESC\n LIMIT ? OFFSET ?`,\n [searchPattern, searchPattern, resultType === \"files\" ? pageSize : 5, resultType === \"files\" ? offset : 0],\n );\n\n const FileSearchResultSchema = FileSchema.extend({\n val_name: z.string(),\n val_url: z.string(),\n username: z.string(),\n description: z.string().nullable(),\n image_url: z.string().nullable(),\n });\n\n try {\n const rawFileResults = z.array(FileSearchResultSchema).parse(result.rows);\n\n return rawFileResults.map((result) => {\n const matchedLines = extractMatchedLines(\n result.content || \"\",\n searchText,\n contextLines,\n );\n const totalMatches = matchedLines.filter((line) => line.isMatch).length;\n\n // If we have a match but no matched lines (username/val match only),\n // show the first few lines of the file\n if (totalMatches === 0 && result.content) {\n const firstLines = result.content.split(\"\\n\").slice(0, 5).map((lineContent, i) => ({\n lineNumber: i + 1,\n lineContent,\n isMatch: false,\n }));\n\n return {\n ...result,\n matchedLines: firstLines,\n totalMatches: 0,\n };\n }\n\n return {\n ...result,\n matchedLines,\n totalMatches,\n };\n });\n } catch (error) {\n console.error(\"Invalid file search results:\", error);\n return [];\n }\n })();\n\n // Launch vals query\n const valResultsPromise = searchVals(\n searchText,\n resultType === \"vals\" ? page : 1,\n resultType === \"vals\" ? pageSize : 5,\n );\n\n // Launch users query\n const userResultsPromise = searchUsers(\n searchText,\n resultType === \"users\" ? page : 1,\n resultType === \"users\" ? pageSize : 5,\n );\n\n // Wait for all database operations to complete in parallel\n const [\n [totalFileResults, totalValResults, totalUserResults],\n rawFileResults,\n valResults,\n userResults,\n ] = await Promise.all([\n countsPromise,\n fileResultsPromise,\n valResultsPromise,\n userResultsPromise,\n ]);\n\n // Determine result type if not specified (use the one with most results)\n let effectiveResultType = resultType;\n if (!resultType) {\n if (totalFileResults >= totalValResults && totalFileResults >= totalUserResults) {\n effectiveResultType = \"files\";\n } else if (totalValResults >= totalFileResults && totalValResults >= totalUserResults) {\n effectiveResultType = \"vals\";\n } else {\n effectiveResultType = \"users\";\n }\n }\n\n // Calculate total pages based on the active result type\n let totalResults: number;\n switch (effectiveResultType) {\n case \"files\":\n totalResults = totalFileResults;\n break;\n case \"vals\":\n totalResults = totalValResults;\n break;\n case \"users\":\n totalResults = totalUserResults;\n break;\n }\n\n const totalPages = Math.ceil(totalResults / pageSize);\n\n // Filter the results to use based on result type\n // We already have all the data, just need to use the right ones\n let fileResults: EnhancedSearchResult[] = [];\n if (effectiveResultType === \"files\" || totalFileResults > 0) {\n if (effectiveResultType === \"files\") {\n // Use all results for active type\n fileResults = rawFileResults;\n } else if (totalFileResults > 0) {\n // Use limited sample for other types\n fileResults = rawFileResults.slice(0, 5);\n }\n }\n\n const endTime = performance.now();\n const executionTimeMs = Math.round(endTime - startTime);\n\n return {\n fileResults,\n valResults,\n userResults,\n docResults: [],\n totalFileResults,\n totalValResults,\n totalUserResults,\n totalDocResults: 0,\n page,\n pageSize,\n totalPages,\n executionTimeMs,\n resultType: effectiveResultType,\n };\n}","deleted","label",[98],"permalink","https://www.val.town/x/dcm31/vtProjectSearch/code/db.ts","extension","actionData","errors"]