[{"_1":2,"_172":-5,"_173":-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","d481f3d28ac6dd3f9b89bb10f2a0c9798df3020a","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,"_169":170,"_171":-5},"handle","lantholin","name","YapTrap","path","backend/monitoring/metrics.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","e0b6bffa-8eaa-11f0-b609-0224a6c84d84","createdAt",["D",1757552501410],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","01991120-79d9-71bf-ab3a-268b208877c6","pinnedFileId","pinPreview","screenshotVersion","likeCount","01991120-79d9-71bf-ab3a-2b0a78a4a875","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_127":128},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18zMkNlUHBrVWxlV3k1VG50eDloQVRhOU5WQWUifQ","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",69,"e0b72094-8eaa-11f0-b609-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":32,"_160":161,"_162":163,"_164":20,"_165":-5,"_97":166},"3eb1c034-8eae-11f0-8a5a-0224a6c84d84","metrics.ts","fileId","3eb1c106-8eae-11f0-8a5a-0224a6c84d84","parentId","33f7ed79-11d9-4621-9fc9-98d73d6ef2f2","branchId","branchVersion",14,"latest",true,["D",1757553947568],"fileType","script","content","/**\n * Metrics collection and analysis for YapTrap system\n * Tracks performance, usage, and operational metrics\n */\n\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport { TABLES } from '../database/schema.ts';\nimport type { SystemMetrics } from '../../shared/types.ts';\nimport { generateId } from '../../shared/utils.ts';\n\nexport class MetricsCollector {\n \n /**\n * Record an HTTP request metric\n */\n static async recordHttpRequest(\n method: string, \n path: string, \n status: number, \n duration: number\n ): Promise {\n try {\n await sqlite.execute(`\n INSERT INTO ${TABLES.metrics} \n (id, timestamp, metric_type, metric_name, value, dimensions)\n VALUES (?, ?, ?, ?, ?, ?)\n `, [\n generateId('metric'),\n new Date().toISOString(),\n 'http',\n 'request',\n duration,\n JSON.stringify({ method, path, status })\n ]);\n } catch (error) {\n console.error('Failed to record HTTP request metric:', error);\n }\n }\n \n /**\n * Record a message processing metric\n */\n static async recordMessageProcessing(\n platform: string,\n conversationId: string,\n processingTime: number,\n success: boolean\n ): Promise {\n try {\n await sqlite.execute(`\n INSERT INTO ${TABLES.metrics} \n (id, timestamp, metric_type, metric_name, value, dimensions, conversation_id, platform)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)\n `, [\n generateId('metric'),\n new Date().toISOString(),\n 'message',\n 'processing_time',\n processingTime,\n JSON.stringify({ success }),\n conversationId,\n platform\n ]);\n } catch (error) {\n console.error('Failed to record message processing metric:', error);\n }\n }\n \n /**\n * Record an AI response generation metric\n */\n static async recordAIResponse(\n provider: string,\n model: string,\n tokensUsed: number,\n responseTime: number,\n success: boolean\n ): Promise {\n try {\n await sqlite.execute(`\n INSERT INTO ${TABLES.metrics} \n (id, timestamp, metric_type, metric_name, value, dimensions)\n VALUES (?, ?, ?, ?, ?, ?)\n `, [\n generateId('metric'),\n new Date().toISOString(),\n 'ai',\n 'response_generation',\n responseTime,\n JSON.stringify({ provider, model, tokensUsed, success })\n ]);\n } catch (error) {\n console.error('Failed to record AI response metric:', error);\n }\n }\n \n /**\n * Record a platform API call metric\n */\n static async recordPlatformAPI(\n platform: string,\n operation: string,\n responseTime: number,\n success: boolean\n ): Promise {\n try {\n await sqlite.execute(`\n INSERT INTO ${TABLES.metrics} \n (id, timestamp, metric_type, metric_name, value, dimensions, platform)\n VALUES (?, ?, ?, ?, ?, ?, ?)\n `, [\n generateId('metric'),\n new Date().toISOString(),\n 'platform',\n 'api_call',\n responseTime,\n JSON.stringify({ operation, success }),\n platform\n ]);\n } catch (error) {\n console.error('Failed to record platform API metric:', error);\n }\n }\n \n /**\n * Get current system metrics\n */\n static async getCurrentMetrics(): Promise {\n try {\n const now = new Date();\n const oneHourAgo = new Date(now.getTime() - 60 * 60 * 1000);\n \n // Get message volume (last hour)\n const messageVolumeResult = await sqlite.execute(`\n SELECT COUNT(*) as count \n FROM ${TABLES.messages} \n WHERE timestamp > ?\n `, [oneHourAgo.toISOString()]);\n \n const messageVolume = messageVolumeResult[0]?.count as number || 0;\n \n // Get response rate (YapTrap messages vs user messages)\n const responseRateResult = await sqlite.execute(`\n SELECT \n SUM(CASE WHEN sender_type = 'yaptrap' THEN 1 ELSE 0 END) as yaptrap_messages,\n SUM(CASE WHEN sender_type = 'user' THEN 1 ELSE 0 END) as user_messages\n FROM ${TABLES.messages} \n WHERE timestamp > ?\n `, [oneHourAgo.toISOString()]);\n \n const yapTrapMessages = responseRateResult[0]?.yaptrap_messages as number || 0;\n const userMessages = responseRateResult[0]?.user_messages as number || 0;\n const responseRate = userMessages > 0 ? yapTrapMessages / userMessages : 0;\n \n // Get average response time\n const responseTimeResult = await sqlite.execute(`\n SELECT AVG(value) as avg_time \n FROM ${TABLES.metrics} \n WHERE metric_type = 'message' AND metric_name = 'processing_time' \n AND timestamp > ?\n `, [oneHourAgo.toISOString()]);\n \n const averageResponseTime = responseTimeResult[0]?.avg_time as number || 0;\n \n // Get error rate\n const errorRateResult = await sqlite.execute(`\n SELECT COUNT(*) as error_count \n FROM ${TABLES.system_logs} \n WHERE level = 'error' AND timestamp > ?\n `, [oneHourAgo.toISOString()]);\n \n const errorCount = errorRateResult[0]?.error_count as number || 0;\n const errorRate = messageVolume > 0 ? errorCount / messageVolume : 0;\n \n // Get active conversations\n const activeConversationsResult = await sqlite.execute(`\n SELECT COUNT(*) as count \n FROM ${TABLES.conversations} \n WHERE is_active = 1 AND last_activity > ?\n `, [new Date(now.getTime() - 24 * 60 * 60 * 1000).toISOString()]);\n \n const activeConversations = activeConversationsResult[0]?.count as number || 0;\n \n // Get active users\n const activeUsersResult = await sqlite.execute(`\n SELECT COUNT(DISTINCT user_id) as count \n FROM ${TABLES.messages} \n WHERE timestamp > ?\n `, [oneHourAgo.toISOString()]);\n \n const activeUsers = activeUsersResult[0]?.count as number || 0;\n \n // Get platform breakdown\n const platformBreakdownResult = await sqlite.execute(`\n SELECT c.platform, COUNT(m.id) as message_count\n FROM ${TABLES.messages} m\n JOIN ${TABLES.conversations} c ON m.conversation_id = c.id\n WHERE m.timestamp > ?\n GROUP BY c.platform\n `, [oneHourAgo.toISOString()]);\n \n const platformBreakdown: Record = {};\n for (const row of platformBreakdownResult) {\n platformBreakdown[row.platform as string] = row.message_count as number;\n }\n \n return {\n timestamp: now,\n messageVolume,\n responseRate,\n averageResponseTime,\n errorRate,\n activeConversations,\n activeUsers,\n platformBreakdown: platformBreakdown as any\n };\n \n } catch (error) {\n console.error('Failed to get current metrics:', error);\n \n // Return default metrics on error\n return {\n timestamp: new Date(),\n messageVolume: 0,\n responseRate: 0,\n averageResponseTime: 0,\n errorRate: 0,\n activeConversations: 0,\n activeUsers: 0,\n platformBreakdown: {}\n };\n }\n }\n \n /**\n * Get historical metrics for a time range\n */\n static async getMetrics(timeRange: string): Promise {\n try {\n const now = new Date();\n let startTime: Date;\n \n // Parse time range\n switch (timeRange) {\n case '1h':\n startTime = new Date(now.getTime() - 60 * 60 * 1000);\n break;\n case '24h':\n startTime = new Date(now.getTime() - 24 * 60 * 60 * 1000);\n break;\n case '7d':\n startTime = new Date(now.getTime() - 7 * 24 * 60 * 60 * 1000);\n break;\n case '30d':\n startTime = new Date(now.getTime() - 30 * 24 * 60 * 60 * 1000);\n break;\n default:\n startTime = new Date(now.getTime() - 60 * 60 * 1000);\n }\n \n // Get metrics by type\n const metricsResult = await sqlite.execute(`\n SELECT \n metric_type,\n metric_name,\n AVG(value) as avg_value,\n MIN(value) as min_value,\n MAX(value) as max_value,\n COUNT(*) as count\n FROM ${TABLES.metrics}\n WHERE timestamp > ?\n GROUP BY metric_type, metric_name\n ORDER BY metric_type, metric_name\n `, [startTime.toISOString()]);\n \n const metrics: Record = {};\n \n for (const row of metricsResult) {\n const type = row.metric_type as string;\n const name = row.metric_name as string;\n \n if (!metrics[type]) {\n metrics[type] = {};\n }\n \n metrics[type][name] = {\n average: row.avg_value as number,\n minimum: row.min_value as number,\n maximum: row.max_value as number,\n count: row.count as number\n };\n }\n \n // Get time series data for key metrics\n const timeSeriesResult = await sqlite.execute(`\n SELECT \n datetime(timestamp, 'start of hour') as hour,\n metric_type,\n metric_name,\n AVG(value) as avg_value,\n COUNT(*) as count\n FROM ${TABLES.metrics}\n WHERE timestamp > ?\n GROUP BY hour, metric_type, metric_name\n ORDER BY hour\n `, [startTime.toISOString()]);\n \n const timeSeries: Record = {};\n \n for (const row of timeSeriesResult) {\n const key = `${row.metric_type}.${row.metric_name}`;\n \n if (!timeSeries[key]) {\n timeSeries[key] = [];\n }\n \n timeSeries[key].push({\n timestamp: row.hour,\n value: row.avg_value as number,\n count: row.count as number\n });\n }\n \n return {\n timeRange,\n startTime,\n endTime: now,\n summary: metrics,\n timeSeries\n };\n \n } catch (error) {\n console.error('Failed to get historical metrics:', error);\n return {\n timeRange,\n error: error.message,\n summary: {},\n timeSeries: {}\n };\n }\n }\n \n /**\n * Clean up old metrics data\n */\n static async cleanupOldMetrics(retentionDays: number = 30): Promise {\n try {\n const cutoffDate = new Date();\n cutoffDate.setDate(cutoffDate.getDate() - retentionDays);\n \n const result = await sqlite.execute(`\n DELETE FROM ${TABLES.metrics} \n WHERE timestamp < ?\n `, [cutoffDate.toISOString()]);\n \n return result.changes || 0;\n \n } catch (error) {\n console.error('Failed to cleanup old metrics:', error);\n return 0;\n }\n }\n \n /**\n * Get top performing conversations by message volume\n */\n static async getTopConversations(limit: number = 10): Promise {\n try {\n const result = await sqlite.execute(`\n SELECT \n c.id,\n c.name,\n c.platform,\n COUNT(m.id) as message_count,\n MAX(m.timestamp) as last_message\n FROM ${TABLES.conversations} c\n LEFT JOIN ${TABLES.messages} m ON c.id = m.conversation_id\n WHERE c.is_active = 1\n GROUP BY c.id, c.name, c.platform\n ORDER BY message_count DESC\n LIMIT ?\n `, [limit]);\n \n return result.map(row => ({\n id: row.id,\n name: row.name || 'Unnamed Conversation',\n platform: row.platform,\n messageCount: row.message_count as number,\n lastMessage: row.last_message ? new Date(row.last_message as string) : null\n }));\n \n } catch (error) {\n console.error('Failed to get top conversations:', error);\n return [];\n }\n }\n}","deleted","label",[167,168,149],"backend","monitoring","permalink","https://www.val.town/x/lantholin/YapTrap/code/backend/monitoring/metrics.ts","extension","actionData","errors"]