[{"_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","e3ca0a77ab07ff2ce3097208ffd6aa0e378d3c47","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","jpd3v","name","offx","path","backend/database/benchmark.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":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","a93616c0-55f2-11f0-8cdc-f69ea79377d9","createdAt",["D",1751316115780],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","da7efaa0-3a43-11f0-b284-7173a8a6f515","pinnedFileId","pinPreview","screenshotVersion","likeCount",1,"f1d76965-949f-4699-906d-07e921194179","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_128":129},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yeGRlTk9ERTV0VzdNb2FqR0NxOGRuM0NlaTEifQ","org",{"_93":94,"_132":129},"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",98,"a93670de-55f2-11f0-8cdc-f69ea79377d9","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},"8410d740-8a7c-11f0-af15-0224a6c84d84","benchmark.ts","fileId","8410d7fe-8a7c-11f0-af15-0224a6c84d84","parentId","06a4dc18-55f5-11f0-9d32-f69ea79377d9","branchId","branchVersion",41,"latest",true,["D",1757092784458],"fileType","script","content","import { initializeDatabase } from \"./migrations.ts\";\nimport * as queries from \"./queries.ts\";\nimport { Post, PostMedia } from \"./queries.ts\";\n\n/**\n * Simple benchmarking utility for database operations\n * This helps identify performance bottlenecks in the data access layer\n */\n\n// Helper function to measure execution time\nasync function measureTime(\n name: string,\n fn: () => Promise,\n iterations: number = 1,\n): Promise<{ result: T; avgTime: number }> {\n console.log(`Running benchmark: ${name} (${iterations} iterations)`);\n\n const times: number[] = [];\n let result: T = null as unknown as T;\n\n for (let i = 0; i < iterations; i++) {\n const start = performance.now();\n result = await fn();\n const end = performance.now();\n const time = end - start;\n times.push(time);\n\n if (iterations > 1) {\n console.log(` Iteration ${i + 1}: ${time.toFixed(2)}ms`);\n }\n }\n\n const avgTime = times.reduce((sum, time) => sum + time, 0) / times.length;\n console.log(` Average time: ${avgTime.toFixed(2)}ms`);\n\n return { result, avgTime };\n}\n\n// Sample data generation\nfunction generateSampleTopic(index: number) {\n return {\n title: `Test Topic ${index}`,\n description: `This is a test topic ${index} for benchmarking purposes.`,\n };\n}\n\nfunction generateSamplePost(index: number): Omit {\n return {\n external_id: `test-${index}`,\n content:\n `This is test post content ${index} with some additional text to make it more realistic. #testing #benchmark`,\n author: `Test Author ${index % 10}`,\n author_username: `testuser${index % 10}`,\n platform: index % 2 === 0 ? \"twitter\" : \"mastodon\",\n created_at: new Date(Date.now() - index * 3600000).toISOString(),\n url: `https://example.com/post/${index}`,\n };\n}\n\nfunction generateSampleMedia(\n postId: number,\n index: number,\n): Omit {\n return {\n post_id: postId,\n media_url: `https://example.com/media/${postId}-${index}.jpg`,\n media_type: \"image\",\n alt_text: `Sample image ${index} for post ${postId}`,\n };\n}\n\nfunction generateSampleSummarization(topicId: number, index: number) {\n const endDate = new Date();\n const startDate = new Date(endDate.getTime() - (24 * 3600000)); // 24 hours before\n\n return {\n topic_id: topicId,\n content:\n `This is a sample summarization ${index} for topic ${topicId}. It contains multiple sentences to simulate a realistic summary. The key points discussed were testing, benchmarking, and performance optimization.`,\n prompt: \"Summarize the latest posts about this topic\",\n post_count: 25,\n time_period_start: startDate.toISOString(),\n time_period_end: endDate.toISOString(),\n };\n}\n\n// Benchmark scenarios\nasync function benchmarkTopicOperations(count: number = 10) {\n console.log(\"\\n=== Benchmarking Topic Operations ===\");\n\n // Create topics\n const topicIds: number[] = [];\n await measureTime(\"Create topics\", async () => {\n for (let i = 0; i < count; i++) {\n const topic = generateSampleTopic(i);\n const id = await queries.createTopic(topic);\n topicIds.push(id);\n }\n });\n\n // Get all topics\n await measureTime(\"Get all topics\", async () => {\n return await queries.getAllTopics();\n });\n\n // Get individual topics\n await measureTime(\"Get topic by ID\", async () => {\n for (const id of topicIds.slice(0, Math.min(count, 5))) {\n await queries.getTopicById(id);\n }\n });\n\n // Update topics\n await measureTime(\"Update topics\", async () => {\n for (const id of topicIds.slice(0, Math.min(count, 5))) {\n await queries.updateTopic({\n id,\n title: `Updated Topic ${id}`,\n description: `This topic was updated during benchmarking.`,\n });\n }\n });\n\n return topicIds;\n}\n\nasync function benchmarkPostOperations(\n count: number = 20,\n topicIds: number[] = [],\n) {\n console.log(\"\\n=== Benchmarking Post Operations ===\");\n\n // Create posts\n const postIds: number[] = [];\n await measureTime(\"Create posts\", async () => {\n for (let i = 0; i < count; i++) {\n const post = generateSamplePost(i) as Post;\n // Add media to some posts\n if (i % 3 === 0) {\n post.media = [\n generateSampleMedia(0, 1),\n generateSampleMedia(0, 2),\n ];\n }\n const id = await queries.createPost(post);\n postIds.push(id);\n }\n });\n\n // Get posts by ID\n await measureTime(\"Get posts by ID\", async () => {\n for (const id of postIds.slice(0, Math.min(count, 5))) {\n await queries.getPostById(id);\n }\n });\n\n // Get posts by external ID\n await measureTime(\"Get posts by external ID\", async () => {\n for (let i = 0; i < Math.min(count, 5); i++) {\n await queries.getPostByExternalId(`test-${i}`);\n }\n });\n\n // Get recent posts\n await measureTime(\"Get recent posts\", async () => {\n return await queries.getRecentPosts(10);\n });\n\n // Add posts to topics\n if (topicIds.length > 0) {\n await measureTime(\"Add posts to topics\", async () => {\n for (const postId of postIds) {\n // Add each post to 1-3 random topics\n const numTopics = Math.floor(Math.random() * 3) + 1;\n for (let i = 0; i < numTopics; i++) {\n const randomTopicIndex = Math.floor(Math.random() * topicIds.length);\n await queries.addPostToTopic(topicIds[randomTopicIndex], postId);\n }\n }\n });\n\n // Get posts for topics\n await measureTime(\"Get posts for topic\", async () => {\n for (const topicId of topicIds.slice(0, Math.min(topicIds.length, 3))) {\n await queries.getPostsForTopic(topicId, 10);\n }\n });\n }\n\n return postIds;\n}\n\nasync function benchmarkSummarizationOperations(\n count: number = 5,\n topicIds: number[] = [],\n) {\n console.log(\"\\n=== Benchmarking Summarization Operations ===\");\n\n if (topicIds.length === 0) {\n console.log(\"No topics available for summarization benchmarking\");\n return [];\n }\n\n // Create summarizations\n const summaryIds: number[] = [];\n await measureTime(\"Create summarizations\", async () => {\n for (let i = 0; i < count; i++) {\n // Distribute summarizations across available topics\n const topicId = topicIds[i % topicIds.length];\n const summarization = generateSampleSummarization(topicId, i);\n const id = await queries.createSummarization(summarization);\n summaryIds.push(id);\n }\n });\n\n // Get summarizations by ID\n await measureTime(\"Get summarization by ID\", async () => {\n for (const id of summaryIds.slice(0, Math.min(count, 3))) {\n await queries.getSummarizationById(id);\n }\n });\n\n // Get summarizations for topic\n await measureTime(\"Get summarizations for topic\", async () => {\n for (const topicId of topicIds.slice(0, Math.min(topicIds.length, 3))) {\n await queries.getSummarizationsForTopic(topicId, 5);\n }\n });\n\n // Get recent summarizations\n await measureTime(\"Get recent summarizations\", async () => {\n return await queries.getRecentSummarizations(5);\n });\n\n return summaryIds;\n}\n\n// Main benchmark function\nexport async function runBenchmarks() {\n console.log(\"Starting database benchmarks...\");\n\n try {\n // Initialize the database\n await initializeDatabase();\n\n // Run benchmarks\n const topicIds = await benchmarkTopicOperations(10);\n const postIds = await benchmarkPostOperations(20, topicIds);\n await benchmarkSummarizationOperations(5, topicIds);\n\n // Clean up test data if needed\n // Uncomment this section to delete test data after benchmarking\n /*\n console.log(\"\\n=== Cleaning up test data ===\");\n for (const id of postIds) {\n await queries.deletePost(id);\n }\n for (const id of topicIds) {\n await queries.deleteTopic(id);\n }\n */\n\n console.log(\"\\nBenchmarks completed successfully!\");\n } catch (error: unknown) {\n console.error(\"Error during benchmarking:\", error);\n }\n}\n\n// Run benchmarks if this file is executed directly\n// Comment out this check for now as we'll run it manually\n// if (import.meta.url === Deno.mainModule) {\n// runBenchmarks();\n// }\n","deleted","label",[168,169,150],"backend","database","permalink","https://www.val.town/x/jpd3v/offx/code/backend/database/benchmark.ts","extension","actionData","errors"]