[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_364":365,"_366":367},"routes/_app.x.$handle.$name",{"_100":99,"_32":49,"_108":90,"_27":109,"_13":14,"_110":-5,"_11":111,"_112":113,"_114":115,"_116":117,"_118":119,"_21":-5,"_120":-5,"_121":-5,"_122":25,"_123":124,"_125":62,"_126":-5,"_127":-5,"_128":129},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_47":48,"_32":49,"_37":50,"_51":-5,"_52":25,"_53":54,"_55":54,"_56":-5,"_57":-5,"_18":58,"_59":60,"_61":62,"_63":62,"_64":-5,"_65":66,"_67":68,"_69":-5,"_70":-5,"_71":-5,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":25},"version",17,"changes",[19,20],"aiChatInfo","userId",{"_21":42,"_23":-7,"_24":25,"_26":25,"_27":43,"_29":43},{"_21":22,"_23":-7,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":33,"_34":21,"_35":36,"_37":38,"_39":14,"_40":41,"_24":25},"previous","deleted",false,"deletedHere","path","frontend/index.html","latestPath","fileId","c18526b8-3cba-11f0-aa86-9e149126039e","name","index.html","fileType","content","\n\n\n \n \n AI Media Recognition Platform\n \n \n 🤖\">\n \n\n\n

\n \n \n\n","createdAt",["D",1748543325673],"branchVersion","branchId","61cd9f9a-3cb8-11f0-a555-9e149126039e",{"_30":44,"_32":43,"_34":45,"_35":-5,"_37":46,"_39":14,"_40":41,"_24":25},"frontend","b8367289-7745-4625-961a-e594774f7d4d","directory",["D",1748543325673],"id","61cd709c-3cb8-11f0-a555-9e149126039e","my-first-val",["D",1748542306097],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","5468f8e0-3cb8-11f0-8166-d94e9c211fd2","pinnedFileId","61d290ea-3cb8-11f0-a555-9e149126039e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","5d0995c1-fabc-4a0d-8c50-4107c4a34e15","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_100":99,"_107":103},"org",{"_100":99,"_101":-5,"_102":103,"_18":58,"_104":105,"_106":25},"branch",{"_13":89,"_32":90,"_47":41,"_91":48,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":49,"_98":99},"isOwned",24,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","Mahi77","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzJ4bVRUM0tHbVEwRVZFSHJ1R2VNb0ZvQnZReCJ9","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_47":48,"_32":49,"_37":360,"_51":-5,"_52":25,"_53":54,"_55":54,"_56":-5,"_57":-5,"_18":58,"_59":60,"_61":62,"_63":62,"_64":-5,"_65":66,"_67":68,"_69":-5,"_70":-5,"_71":-5,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":361,"_84":362,"_86":363,"_88":25},"tree",[212,224,226,229,230,231,232,233,234],"files",[212,213,214,215,216,217,218,219,220,221,222,223,224,225,226,227,228,229,230,231,232,233,234],"counts",{"_202":66,"_203":154,"_204":66,"_205":206,"_207":208},"contents",[130,131,132,133,134,135,136,137,138],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_47":196,"_32":197,"_30":198,"_142":-5,"_40":41,"_39":199,"_144":62,"_37":200,"_13":66,"_34":45,"_35":-5,"_24":25,"_147":-5,"_27":201},{"_47":193,"_32":43,"_30":44,"_142":-5,"_40":41,"_39":14,"_144":62,"_37":194,"_13":66,"_34":45,"_35":-5,"_24":25,"_147":-5,"_27":195},{"_47":187,"_32":188,"_30":189,"_142":-5,"_40":41,"_39":190,"_144":62,"_37":191,"_13":66,"_34":45,"_35":-5,"_24":25,"_147":-5,"_27":192},{"_47":180,"_32":181,"_30":182,"_142":-5,"_40":41,"_39":183,"_144":62,"_37":184,"_13":66,"_34":146,"_35":185,"_24":25,"_147":-5,"_27":186},{"_47":173,"_32":174,"_30":60,"_142":-5,"_40":41,"_39":175,"_144":62,"_37":176,"_13":66,"_34":177,"_35":178,"_24":25,"_147":-5,"_27":179},{"_47":165,"_32":166,"_30":167,"_142":-5,"_40":41,"_39":168,"_144":62,"_37":169,"_13":66,"_34":170,"_35":171,"_24":25,"_147":-5,"_27":172},{"_47":157,"_32":158,"_30":159,"_142":-5,"_40":41,"_39":160,"_144":62,"_37":161,"_13":66,"_34":162,"_35":163,"_24":25,"_147":-5,"_27":164},{"_47":149,"_32":150,"_30":151,"_142":-5,"_40":41,"_39":152,"_144":62,"_37":153,"_13":154,"_34":21,"_35":155,"_24":25,"_147":-5,"_27":156},{"_47":139,"_32":140,"_30":141,"_142":-5,"_40":41,"_39":143,"_144":62,"_37":145,"_13":66,"_34":146,"_35":109,"_24":25,"_147":-5,"_27":148},"b767872c-3cb8-11f0-9e5d-9e149126039e","new-file-5453.tsx","b76787cc-3cb8-11f0-9e5d-9e149126039e","parentId",6,"latest",["D",1748542449711],"script","label",[140],"4cd1f45e-3cba-11f0-9eda-9e149126039e","README.md","61ceda04-3cb8-11f0-a555-9e149126039e",7,["D",1748543129866],1,"# AI/ML Media Recognition Platform\n\nA comprehensive platform for AI-powered media recognition with user authentication, real-time analysis, and intelligent search capabilities.\n\n## Features\n\n- **User Authentication**: Secure login/signup system with session management\n- **Multi-Media Support**: Image, video, and audio recognition\n- **Real-time Capture**: In-browser media capture capabilities\n- **AI Analysis**: Powered by OpenAI's vision and audio models\n- **Intelligent Search**: Find similar content based on descriptions\n- **Secure Storage**: User data and media metadata stored securely\n\n## Architecture\n\n### Backend (`/backend/`)\n- **index.ts**: Main Hono server with API routes\n- **database/**: SQLite database setup and queries\n- **routes/**: Modular route handlers\n- **auth/**: Authentication middleware and utilities\n\n### Frontend (`/frontend/`)\n- **index.html**: Main application shell\n- **components/**: React components for UI\n- **services/**: API communication and media handling\n- **utils/**: Client-side utilities\n\n### Shared (`/shared/`)\n- **types.ts**: TypeScript interfaces and types\n- **utils.ts**: Shared utility functions\n\n## API Endpoints\n\n- `POST /api/auth/login` - User login\n- `POST /api/auth/signup` - User registration\n- `POST /api/auth/logout` - User logout\n- `GET /api/auth/me` - Get current user\n- `POST /api/media/analyze` - Analyze uploaded media\n- `POST /api/media/search` - Search similar content\n- `GET /api/media/history` - Get user's analysis history\n\n## Technology Stack\n\n- **Backend**: Hono, SQLite, OpenAI API\n- **Frontend**: React, TailwindCSS\n- **AI/ML**: OpenAI GPT-4 Vision, Whisper\n- **Storage**: Val Town Blob storage\n- **Authentication**: JWT-based sessions\n\n## Getting Started\n\n1. Set up environment variables:\n - `OPENAI_API_KEY`: Your OpenAI API key\n - `JWT_SECRET`: Secret for JWT token signing\n\n2. The application will automatically create database tables on first run\n\n3. Access the application at the HTTP endpoint URL\n\n## Security Features\n\n- Password hashing with bcrypt\n- JWT-based authentication\n- CORS protection\n- Input validation and sanitization\n- Secure file upload handling",[150],"61d6e258-3cb8-11f0-a555-9e149126039e","04_email.tsx","61d6e2ee-3cb8-11f0-a555-9e149126039e",5,["D",1748542306158],"email","// This code is triggered when an email is sent to its unique address.\n// Click \"Run\", copy and paste the email address and send an email to it.\n// This example will log the email details received.\nexport default async function emailHandler(email: Email){\n console.log(\"Email received!\", email.from, email.subject, email.text);\n for (const file of email.attachments) {\n console.log(`Filename: ${file.name}`);\n console.log(`Content Type: ${file.type}`);\n console.log(`Content: ${await file.text()}`);\n }\n}",[158],"61d4961a-3cb8-11f0-a555-9e149126039e","03_cron.tsx","61d496ba-3cb8-11f0-a555-9e149126039e",4,["D",1748542306141],"interval","// This cron runs on a schedule (e.g. every hour, day).\n// Configure the timer with the 🕒 icon in the top right.\n// This example just logs the current time.\nexport function scheduledHandler() {\n const timestamp = new Date().toISOString();\n console.log(`Cron val executed at: ${timestamp}`);\n return `Executed at ${timestamp}`;\n}",[166],"61d29036-3cb8-11f0-a555-9e149126039e","02_http.tsx",3,["D",1748542306129],"http","// This code responds to HTTP web requests.\n// Access it via its public URL (you can also pick a nicer subdomain).\n// Try adding ?name=YourName to the URL!\nexport default function httpHandler(req: Request): Response {\n const url = new URL(req.url);\n const name = url.searchParams.get(\"name\") || \"Friend\";\n console.log(`Greeted ${name} via HTTP`);\n return new Response(`Hello, ${name}! Welcome to Val Town.`);\n}",[174],"61d0c65c-3cb8-11f0-a555-9e149126039e","01_script.tsx","61d0c706-3cb8-11f0-a555-9e149126039e",2,["D",1748542306117],"// This script returns a random fun fact\n// You can run scripts manually in this view or call it from other vals.\nexport default function getRandomFact() {\n const funFacts = [\n \"Honey never spoils.\",\n \"Bananas are actually berries, but strawberries are not.\",\n \"Val Town has a citizen Juicy Bear. 🐻\",\n ];\n const fact = funFacts[Math.floor(Math.random() * funFacts.length)];\n return fact;\n}\nconsole.log(\"Fun fact:\", getRandomFact());\n",[181],"532f31b8-3cba-11f0-b872-9e149126039e","shared","d1679996-877c-44a1-9d8e-b54e3dba81a5",8,["D",1748543140561],[188],"c18548fa-3cba-11f0-aa86-9e149126039e",["D",1748543325673],[43],"630ab242-3cba-11f0-bbbe-9e149126039e","backend","b451bc98-fdf2-4a33-a9e6-5d661aed07bd",10,["D",1748543167164],[197],"pulls","branches","forks","envVars",{"_209":66,"_211":66},"connections",{"_209":66,"_210":66},"count","unfilledCount","emptyCount",{"_47":196,"_32":197,"_30":198,"_142":-5,"_40":41,"_39":199,"_144":62,"_37":357,"_13":66,"_34":45,"_35":-5,"_24":25,"_147":-5,"_236":358,"_27":359},{"_47":353,"_32":352,"_30":346,"_142":198,"_40":41,"_39":347,"_144":62,"_37":354,"_13":66,"_34":45,"_35":-5,"_24":25,"_147":-5,"_236":355,"_27":356},{"_47":344,"_32":255,"_30":345,"_142":346,"_40":41,"_39":347,"_144":62,"_37":348,"_13":66,"_34":146,"_35":349,"_24":25,"_147":-5,"_236":350,"_27":351},{"_47":340,"_32":332,"_30":326,"_142":198,"_40":41,"_39":199,"_144":62,"_37":341,"_13":66,"_34":45,"_35":-5,"_24":25,"_147":-5,"_236":342,"_27":343},{"_47":333,"_32":334,"_30":335,"_142":326,"_40":41,"_39":199,"_144":62,"_37":336,"_13":66,"_34":146,"_35":337,"_24":25,"_147":-5,"_236":338,"_27":339},{"_47":323,"_32":324,"_30":325,"_142":326,"_40":41,"_39":327,"_144":62,"_37":328,"_13":66,"_34":146,"_35":329,"_24":25,"_147":-5,"_236":330,"_27":331},{"_47":319,"_32":310,"_30":304,"_142":198,"_40":41,"_39":314,"_144":62,"_37":320,"_13":66,"_34":45,"_35":-5,"_24":25,"_147":-5,"_236":321,"_27":322},{"_47":311,"_32":312,"_30":313,"_142":304,"_40":41,"_39":314,"_144":62,"_37":315,"_13":66,"_34":146,"_35":316,"_24":25,"_147":-5,"_236":317,"_27":318},{"_47":301,"_32":302,"_30":303,"_142":304,"_40":41,"_39":305,"_144":62,"_37":306,"_13":66,"_34":146,"_35":307,"_24":25,"_147":-5,"_236":308,"_27":309},{"_47":297,"_32":296,"_30":290,"_142":198,"_40":41,"_39":291,"_144":62,"_37":298,"_13":66,"_34":45,"_35":-5,"_24":25,"_147":-5,"_236":299,"_27":300},{"_47":287,"_32":288,"_30":289,"_142":290,"_40":41,"_39":291,"_144":62,"_37":292,"_13":66,"_34":146,"_35":293,"_24":25,"_147":-5,"_236":294,"_27":295},{"_47":279,"_32":280,"_30":281,"_142":198,"_40":41,"_39":282,"_144":62,"_37":283,"_13":66,"_34":146,"_35":284,"_24":25,"_147":-5,"_236":285,"_27":286},{"_47":193,"_32":43,"_30":44,"_142":-5,"_40":41,"_39":14,"_144":62,"_37":276,"_13":66,"_34":45,"_35":-5,"_24":25,"_147":-5,"_236":277,"_27":278},{"_47":272,"_32":33,"_30":31,"_142":44,"_40":41,"_39":14,"_144":62,"_37":273,"_13":66,"_34":21,"_35":36,"_24":25,"_147":-5,"_236":274,"_27":275},{"_47":187,"_32":188,"_30":189,"_142":-5,"_40":41,"_39":190,"_144":62,"_37":269,"_13":66,"_34":45,"_35":-5,"_24":25,"_147":-5,"_236":270,"_27":271},{"_47":262,"_32":263,"_30":264,"_142":189,"_40":41,"_39":190,"_144":62,"_37":265,"_13":66,"_34":146,"_35":266,"_24":25,"_147":-5,"_236":267,"_27":268},{"_47":254,"_32":255,"_30":256,"_142":189,"_40":41,"_39":257,"_144":62,"_37":258,"_13":66,"_34":146,"_35":259,"_24":25,"_147":-5,"_236":260,"_27":261},{"_47":180,"_32":181,"_30":182,"_142":-5,"_40":41,"_39":183,"_144":62,"_37":251,"_13":66,"_34":146,"_35":185,"_24":25,"_147":-5,"_236":252,"_27":253},{"_47":173,"_32":174,"_30":60,"_142":-5,"_40":41,"_39":175,"_144":62,"_37":248,"_13":66,"_34":177,"_35":178,"_24":25,"_147":-5,"_236":249,"_27":250},{"_47":165,"_32":166,"_30":167,"_142":-5,"_40":41,"_39":168,"_144":62,"_37":245,"_13":66,"_34":170,"_35":171,"_24":25,"_147":-5,"_236":246,"_27":247},{"_47":157,"_32":158,"_30":159,"_142":-5,"_40":41,"_39":160,"_144":62,"_37":242,"_13":66,"_34":162,"_35":163,"_24":25,"_147":-5,"_236":243,"_27":244},{"_47":149,"_32":150,"_30":151,"_142":-5,"_40":41,"_39":152,"_144":62,"_37":239,"_13":154,"_34":21,"_35":155,"_24":25,"_147":-5,"_236":240,"_27":241},{"_47":139,"_32":140,"_30":141,"_142":-5,"_40":41,"_39":143,"_144":62,"_37":235,"_13":66,"_34":146,"_35":109,"_24":25,"_147":-5,"_236":237,"_27":238},["D",1748542449711],"children",[],[140],["D",1748543129866],[],[150],["D",1748542306158],[],[158],["D",1748542306141],[],[166],["D",1748542306129],[],[174],["D",1748542306117],[],[181],"5ac9717c-3cba-11f0-a693-9e149126039e","utils.ts","5ac97244-3cba-11f0-a693-9e149126039e",9,["D",1748543153316],"// Shared utility functions\n\nexport function validateEmail(email: string): boolean {\n const emailRegex = /^[^\\s@]+@[^\\s@]+\\.[^\\s@]+$/;\n return emailRegex.test(email);\n}\n\nexport function validatePassword(password: string): { valid: boolean; message?: string } {\n if (password.length < 8) {\n return { valid: false, message: 'Password must be at least 8 characters long' };\n }\n if (!/(?=.*[a-z])/.test(password)) {\n return { valid: false, message: 'Password must contain at least one lowercase letter' };\n }\n if (!/(?=.*[A-Z])/.test(password)) {\n return { valid: false, message: 'Password must contain at least one uppercase letter' };\n }\n if (!/(?=.*\\d)/.test(password)) {\n return { valid: false, message: 'Password must contain at least one number' };\n }\n return { valid: true };\n}\n\nexport function formatFileSize(bytes: number): string {\n if (bytes === 0) return '0 Bytes';\n const k = 1024;\n const sizes = ['Bytes', 'KB', 'MB', 'GB'];\n const i = Math.floor(Math.log(bytes) / Math.log(k));\n return parseFloat((bytes / Math.pow(k, i)).toFixed(2)) + ' ' + sizes[i];\n}\n\nexport function formatDate(dateString: string): string {\n const date = new Date(dateString);\n return date.toLocaleDateString() + ' ' + date.toLocaleTimeString();\n}\n\nexport function generateId(): string {\n return Math.random().toString(36).substr(2, 9);\n}\n\nexport function sanitizeFileName(fileName: string): string {\n return fileName.replace(/[^a-zA-Z0-9.-]/g, '_');\n}\n\nexport function extractFileExtension(fileName: string): string {\n return fileName.split('.').pop()?.toLowerCase() || '';\n}\n\nexport function isValidMediaType(mimeType: string, allowedTypes: string[]): boolean {\n return allowedTypes.includes(mimeType);\n}\n\nexport function truncateText(text: string, maxLength: number): string {\n if (text.length <= maxLength) return text;\n return text.substr(0, maxLength) + '...';\n}\n\nexport function debounce any>(\n func: T,\n wait: number\n): (...args: Parameters) => void {\n let timeout: number | undefined;\n return (...args: Parameters) => {\n clearTimeout(timeout);\n timeout = setTimeout(() => func(...args), wait);\n };\n}\n\nexport function createFormData(data: Record): FormData {\n const formData = new FormData();\n Object.entries(data).forEach(([key, value]) => {\n if (value instanceof File) {\n formData.append(key, value);\n } else {\n formData.append(key, JSON.stringify(value));\n }\n });\n return formData;\n}",[],[188,255],"532f12f0-3cba-11f0-b872-9e149126039e","types.ts","532f13cc-3cba-11f0-b872-9e149126039e",["D",1748543140561],"// Shared TypeScript types and interfaces\n\nexport interface User {\n id: number;\n email: string;\n username: string;\n created_at: string;\n}\n\nexport interface AuthResponse {\n success: boolean;\n user?: User;\n token?: string;\n message?: string;\n}\n\nexport interface MediaAnalysis {\n id: number;\n user_id: number;\n media_type: 'image' | 'video' | 'audio';\n file_name: string;\n file_size: number;\n analysis_result: string;\n tags: string[];\n confidence_score: number;\n created_at: string;\n}\n\nexport interface AnalysisRequest {\n mediaType: 'image' | 'video' | 'audio';\n fileName: string;\n fileData: string; // base64 encoded\n}\n\nexport interface AnalysisResponse {\n success: boolean;\n analysis?: {\n description: string;\n tags: string[];\n confidence: number;\n objects?: string[];\n emotions?: string[];\n text?: string;\n };\n message?: string;\n}\n\nexport interface SearchRequest {\n query: string;\n mediaType?: 'image' | 'video' | 'audio';\n limit?: number;\n}\n\nexport interface SearchResponse {\n success: boolean;\n results?: MediaAnalysis[];\n message?: string;\n}\n\nexport interface ApiResponse {\n success: boolean;\n data?: T;\n message?: string;\n error?: string;\n}\n\nexport interface CaptureOptions {\n video?: boolean;\n audio?: boolean;\n facingMode?: 'user' | 'environment';\n}\n\nexport interface MediaConstraints {\n maxFileSize: number; // in bytes\n allowedTypes: string[];\n maxDuration?: number; // for video/audio in seconds\n}\n\nexport const MEDIA_CONSTRAINTS: MediaConstraints = {\n maxFileSize: 50 * 1024 * 1024, // 50MB\n allowedTypes: [\n 'image/jpeg',\n 'image/png',\n 'image/webp',\n 'video/mp4',\n 'video/webm',\n 'audio/mp3',\n 'audio/wav',\n 'audio/webm'\n ],\n maxDuration: 300 // 5 minutes\n};",[],[188,263],["D",1748543140561],[227,228],[188],"c185260e-3cba-11f0-aa86-9e149126039e",["D",1748543325673],[],[43,33],["D",1748543325673],[225],[43],"b77b18a8-3cba-11f0-8e85-9e149126039e","index.ts","b77b1966-3cba-11f0-8e85-9e149126039e",16,["D",1748543308833],"import { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { readFile, serveFile } from \"https://esm.town/v/std/utils@85-main/index.ts\";\nimport { initializeDatabase, cleanupExpiredSessions } from \"./database/migrations.ts\";\nimport authRoutes from \"./routes/auth.ts\";\nimport mediaRoutes from \"./routes/media.ts\";\n\nconst app = new Hono();\n\n// Unwrap Hono errors to see original error details\napp.onError((err, c) => {\n throw err;\n});\n\n// Initialize database on startup\nawait initializeDatabase();\n\n// Clean up expired sessions periodically\nsetInterval(cleanupExpiredSessions, 60 * 60 * 1000); // Every hour\n\n// Health check endpoint\napp.get('/health', (c) => {\n return c.json({ \n status: 'healthy', \n timestamp: new Date().toISOString(),\n version: '1.0.0'\n });\n});\n\n// API routes\napp.route('/api/auth', authRoutes);\napp.route('/api/media', mediaRoutes);\n\n// Serve static files\napp.get(\"/frontend/*\", c => serveFile(c.req.path, import.meta.url));\napp.get(\"/shared/*\", c => serveFile(c.req.path, import.meta.url));\n\n// Serve main application\napp.get(\"/\", async c => {\n try {\n let html = await readFile(\"/frontend/index.html\", import.meta.url);\n \n // Inject initial configuration\n const config = {\n apiUrl: '/api',\n maxFileSize: 50 * 1024 * 1024, // 50MB\n supportedFormats: {\n image: ['image/jpeg', 'image/png', 'image/webp'],\n video: ['video/mp4', 'video/webm'],\n audio: ['audio/mp3', 'audio/wav', 'audio/webm']\n }\n };\n \n const configScript = ``;\n \n html = html.replace(\"\", `${configScript}`);\n return c.html(html);\n } catch (error) {\n console.error('Error serving main page:', error);\n return c.html(`\n \n \n \n AI Media Recognition Platform\n \n \n \n \n

AI Media Recognition Platform

Loading application...

Error: ${error.message}

\n \n \n `);\n }\n});\n\n// Catch-all route for SPA routing\napp.get(\"*\", async c => {\n // For any other route, serve the main app (SPA routing)\n return app.fetch(new Request(new URL(\"/\", c.req.url)));\n});\n\n// This is the entry point for HTTP vals\nexport default app.fetch;",[],[197,280],"8b012448-3cba-11f0-8bcc-9e149126039e","ai-analysis.ts","8b012510-3cba-11f0-8bcc-9e149126039e","25c031c1-741e-47c3-9312-45c5ab04aaf1",13,["D",1748543234212],"import { OpenAI } from \"https://esm.town/v/std/openai\";\nimport type { AnalysisResponse } from \"../../shared/types.ts\";\n\nconst openai = new OpenAI();\n\nexport async function analyzeImage(imageData: string, fileName: string): Promise {\n try {\n // Remove data URL prefix if present\n const base64Data = imageData.replace(/^data:image\\/[a-z]+;base64,/, '');\n \n const response = await openai.chat.completions.create({\n model: \"gpt-4o-mini\",\n messages: [\n {\n role: \"user\",\n content: [\n {\n type: \"text\",\n text: `Analyze this image and provide:\n1. A detailed description of what you see\n2. List of objects/subjects in the image\n3. Emotions or mood if people are present\n4. Any text visible in the image\n5. Tags for categorization\n6. Confidence level (0-1)\n\nFormat your response as JSON with the following structure:\n{\n \"description\": \"detailed description\",\n \"objects\": [\"object1\", \"object2\"],\n \"emotions\": [\"emotion1\", \"emotion2\"],\n \"text\": \"any visible text\",\n \"tags\": [\"tag1\", \"tag2\", \"tag3\"],\n \"confidence\": 0.95\n}`\n },\n {\n type: \"image_url\",\n image_url: {\n url: `data:image/jpeg;base64,${base64Data}`\n }\n }\n ]\n }\n ],\n max_tokens: 1000\n });\n\n const content = response.choices[0]?.message?.content;\n if (!content) {\n throw new Error('No response from AI model');\n }\n\n // Parse the JSON response\n const analysis = JSON.parse(content);\n \n return {\n success: true,\n analysis: {\n description: analysis.description,\n tags: analysis.tags || [],\n confidence: analysis.confidence || 0.8,\n objects: analysis.objects || [],\n emotions: analysis.emotions || [],\n text: analysis.text || ''\n }\n };\n } catch (error) {\n console.error('Image analysis error:', error);\n return {\n success: false,\n message: `Failed to analyze image: ${error.message}`\n };\n }\n}\n\nexport async function analyzeAudio(audioData: string, fileName: string): Promise {\n try {\n // For audio analysis, we'll use Whisper for transcription and then analyze the text\n // Note: This is a simplified approach. In production, you might want to use specialized audio analysis APIs\n \n // Convert base64 to blob for Whisper API\n const base64Data = audioData.replace(/^data:audio\\/[^;]+;base64,/, '');\n const audioBuffer = Uint8Array.from(atob(base64Data), c => c.charCodeAt(0));\n const audioBlob = new Blob([audioBuffer], { type: 'audio/wav' });\n \n // Create a File object for the API\n const audioFile = new File([audioBlob], fileName, { type: 'audio/wav' });\n \n const transcription = await openai.audio.transcriptions.create({\n file: audioFile,\n model: \"whisper-1\",\n });\n\n const text = transcription.text;\n \n // Analyze the transcribed text\n const textAnalysis = await openai.chat.completions.create({\n model: \"gpt-4o-mini\",\n messages: [\n {\n role: \"user\",\n content: `Analyze this audio transcription and provide:\n1. A summary of the content\n2. Key topics discussed\n3. Emotional tone\n4. Language detected\n5. Tags for categorization\n6. Confidence level (0-1)\n\nTranscription: \"${text}\"\n\nFormat your response as JSON:\n{\n \"description\": \"summary of audio content\",\n \"topics\": [\"topic1\", \"topic2\"],\n \"emotions\": [\"emotion1\", \"emotion2\"],\n \"language\": \"detected language\",\n \"tags\": [\"tag1\", \"tag2\", \"tag3\"],\n \"confidence\": 0.95\n}`\n }\n ],\n max_tokens: 800\n });\n\n const analysisContent = textAnalysis.choices[0]?.message?.content;\n if (!analysisContent) {\n throw new Error('No response from AI model');\n }\n\n const analysis = JSON.parse(analysisContent);\n \n return {\n success: true,\n analysis: {\n description: analysis.description,\n tags: analysis.tags || [],\n confidence: analysis.confidence || 0.8,\n objects: analysis.topics || [],\n emotions: analysis.emotions || [],\n text: text\n }\n };\n } catch (error) {\n console.error('Audio analysis error:', error);\n return {\n success: false,\n message: `Failed to analyze audio: ${error.message}`\n };\n }\n}\n\nexport async function analyzeVideo(videoData: string, fileName: string): Promise {\n try {\n // For video analysis, we'll extract a frame and analyze it as an image\n // In a production environment, you might want to extract multiple frames or use specialized video analysis\n \n // This is a simplified approach - we'll treat the video thumbnail as an image\n // In practice, you'd need to extract frames from the video\n \n const response = await openai.chat.completions.create({\n model: \"gpt-4o-mini\",\n messages: [\n {\n role: \"user\",\n content: `Analyze this video file and provide:\n1. A description of what the video likely contains based on the filename: \"${fileName}\"\n2. Estimated content type (educational, entertainment, documentary, etc.)\n3. Suggested tags for categorization\n4. Confidence level (0-1)\n\nFormat your response as JSON:\n{\n \"description\": \"estimated video content description\",\n \"contentType\": \"content type\",\n \"tags\": [\"tag1\", \"tag2\", \"tag3\"],\n \"confidence\": 0.7\n}`\n }\n ],\n max_tokens: 500\n });\n\n const content = response.choices[0]?.message?.content;\n if (!content) {\n throw new Error('No response from AI model');\n }\n\n const analysis = JSON.parse(content);\n \n return {\n success: true,\n analysis: {\n description: analysis.description,\n tags: analysis.tags || [],\n confidence: analysis.confidence || 0.6, // Lower confidence for filename-based analysis\n objects: [analysis.contentType] || [],\n emotions: [],\n text: ''\n }\n };\n } catch (error) {\n console.error('Video analysis error:', error);\n return {\n success: false,\n message: `Failed to analyze video: ${error.message}`\n };\n }\n}\n\nexport async function generateSearchSuggestions(query: string): Promise {\n try {\n const response = await openai.chat.completions.create({\n model: \"gpt-4o-mini\",\n messages: [\n {\n role: \"user\",\n content: `Generate 5 related search suggestions for the query: \"${query}\"\n \n Focus on:\n - Similar concepts\n - Related objects or subjects\n - Alternative descriptions\n - Broader or narrower terms\n \n Return as a JSON array of strings:\n [\"suggestion1\", \"suggestion2\", \"suggestion3\", \"suggestion4\", \"suggestion5\"]`\n }\n ],\n max_tokens: 200\n });\n\n const content = response.choices[0]?.message?.content;\n if (!content) {\n return [];\n }\n\n return JSON.parse(content);\n } catch (error) {\n console.error('Search suggestions error:', error);\n return [];\n }\n}",[],[197,296,288],"services","8b014a68-3cba-11f0-8bcc-9e149126039e",["D",1748543234212],[222],[197,296],"ad0f3fc0-3cba-11f0-93f2-9e149126039e","media.ts","ad0f406a-3cba-11f0-93f2-9e149126039e","8ff4979e-279f-4940-9f37-2aa3515ba625",15,["D",1748543291349],"import { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { requireAuth, getCurrentUser } from \"../auth/utils.ts\";\nimport { \n createMediaAnalysis, \n getUserMediaAnalyses, \n searchMediaAnalyses,\n createSearchHistory,\n deleteMediaAnalysis \n} from \"../database/queries.ts\";\nimport { \n analyzeImage, \n analyzeAudio, \n analyzeVideo,\n generateSearchSuggestions \n} from \"../services/ai-analysis.ts\";\nimport { \n sanitizeFileName, \n extractFileExtension, \n isValidMediaType \n} from \"../../shared/utils.ts\";\nimport { MEDIA_CONSTRAINTS } from \"../../shared/types.ts\";\nimport type { AnalysisRequest, AnalysisResponse, SearchRequest } from \"../../shared/types.ts\";\n\nconst media = new Hono();\n\n// Analyze uploaded media\nmedia.post('/analyze', requireAuth, async (c) => {\n try {\n const user = getCurrentUser(c);\n const { mediaType, fileName, fileData }: AnalysisRequest = await c.req.json();\n\n // Validate input\n if (!mediaType || !fileName || !fileData) {\n return c.json({ \n success: false, \n message: 'Media type, file name, and file data are required' \n }, 400);\n }\n\n if (!['image', 'video', 'audio'].includes(mediaType)) {\n return c.json({ \n success: false, \n message: 'Invalid media type' \n }, 400);\n }\n\n // Validate file size (rough estimate from base64)\n const estimatedSize = (fileData.length * 3) / 4;\n if (estimatedSize > MEDIA_CONSTRAINTS.maxFileSize) {\n return c.json({ \n success: false, \n message: `File too large. Maximum size is ${MEDIA_CONSTRAINTS.maxFileSize / (1024 * 1024)}MB` \n }, 400);\n }\n\n // Sanitize filename\n const cleanFileName = sanitizeFileName(fileName);\n \n // Store file in blob storage\n const blobKey = `media_${user.id}_${Date.now()}_${cleanFileName}`;\n await blob.set(blobKey, fileData);\n\n // Analyze based on media type\n let analysisResult: AnalysisResponse;\n \n switch (mediaType) {\n case 'image':\n analysisResult = await analyzeImage(fileData, cleanFileName);\n break;\n case 'audio':\n analysisResult = await analyzeAudio(fileData, cleanFileName);\n break;\n case 'video':\n analysisResult = await analyzeVideo(fileData, cleanFileName);\n break;\n default:\n return c.json({ \n success: false, \n message: 'Unsupported media type' \n }, 400);\n }\n\n if (!analysisResult.success) {\n // Clean up blob if analysis failed\n await blob.delete(blobKey);\n return c.json(analysisResult, 500);\n }\n\n // Save analysis to database\n const mediaAnalysis = await createMediaAnalysis(\n user.id,\n mediaType,\n cleanFileName,\n estimatedSize,\n blobKey,\n analysisResult.analysis!.description,\n analysisResult.analysis!.tags,\n analysisResult.analysis!.confidence\n );\n\n return c.json({\n success: true,\n analysis: analysisResult.analysis,\n mediaId: mediaAnalysis.id,\n message: 'Media analyzed successfully'\n });\n\n } catch (error) {\n console.error('Media analysis error:', error);\n return c.json({ \n success: false, \n message: 'Failed to analyze media' \n }, 500);\n }\n});\n\n// Search media analyses\nmedia.post('/search', requireAuth, async (c) => {\n try {\n const user = getCurrentUser(c);\n const { query, mediaType, limit = 20 }: SearchRequest = await c.req.json();\n\n if (!query || query.trim().length === 0) {\n return c.json({ \n success: false, \n message: 'Search query is required' \n }, 400);\n }\n\n // Perform search\n const results = await searchMediaAnalyses(\n user.id, \n query.trim(), \n mediaType, \n Math.min(limit, 50) // Cap at 50 results\n );\n\n // Save search to history\n await createSearchHistory(user.id, query.trim(), mediaType || null, results.length);\n\n // Generate search suggestions\n const suggestions = await generateSearchSuggestions(query);\n\n return c.json({\n success: true,\n results,\n suggestions,\n message: `Found ${results.length} results`\n });\n\n } catch (error) {\n console.error('Search error:', error);\n return c.json({ \n success: false, \n message: 'Search failed' \n }, 500);\n }\n});\n\n// Get user's media history\nmedia.get('/history', requireAuth, async (c) => {\n try {\n const user = getCurrentUser(c);\n const limit = parseInt(c.req.query('limit') || '50');\n \n const analyses = await getUserMediaAnalyses(user.id, Math.min(limit, 100));\n \n return c.json({\n success: true,\n analyses,\n message: `Retrieved ${analyses.length} analyses`\n });\n\n } catch (error) {\n console.error('History error:', error);\n return c.json({ \n success: false, \n message: 'Failed to retrieve history' \n }, 500);\n }\n});\n\n// Delete media analysis\nmedia.delete('/:id', requireAuth, async (c) => {\n try {\n const user = getCurrentUser(c);\n const id = parseInt(c.req.param('id'));\n\n if (isNaN(id)) {\n return c.json({ \n success: false, \n message: 'Invalid media ID' \n }, 400);\n }\n\n const deleted = await deleteMediaAnalysis(id, user.id);\n \n if (!deleted) {\n return c.json({ \n success: false, \n message: 'Media analysis not found or access denied' \n }, 404);\n }\n\n return c.json({\n success: true,\n message: 'Media analysis deleted successfully'\n });\n\n } catch (error) {\n console.error('Delete error:', error);\n return c.json({ \n success: false, \n message: 'Failed to delete media analysis' \n }, 500);\n }\n});\n\n// Get media file (for viewing)\nmedia.get('/file/:id', requireAuth, async (c) => {\n try {\n const user = getCurrentUser(c);\n const id = parseInt(c.req.param('id'));\n\n if (isNaN(id)) {\n return c.json({ \n success: false, \n message: 'Invalid media ID' \n }, 400);\n }\n\n // Get media analysis to verify ownership and get blob key\n const analysis = await getUserMediaAnalyses(user.id, 1000)\n .then(analyses => analyses.find(a => a.id === id));\n\n if (!analysis) {\n return c.json({ \n success: false, \n message: 'Media not found or access denied' \n }, 404);\n }\n\n // Get file from blob storage\n const fileData = await blob.get(analysis.blob_key);\n \n if (!fileData) {\n return c.json({ \n success: false, \n message: 'Media file not found in storage' \n }, 404);\n }\n\n // Determine content type\n const extension = extractFileExtension(analysis.file_name);\n let contentType = 'application/octet-stream';\n \n if (['jpg', 'jpeg'].includes(extension)) contentType = 'image/jpeg';\n else if (extension === 'png') contentType = 'image/png';\n else if (extension === 'webp') contentType = 'image/webp';\n else if (extension === 'mp4') contentType = 'video/mp4';\n else if (extension === 'webm') contentType = 'video/webm';\n else if (extension === 'mp3') contentType = 'audio/mpeg';\n else if (extension === 'wav') contentType = 'audio/wav';\n\n return new Response(fileData, {\n headers: {\n 'Content-Type': contentType,\n 'Content-Disposition': `inline; filename=\"${analysis.file_name}\"`\n }\n });\n\n } catch (error) {\n console.error('File retrieval error:', error);\n return c.json({ \n success: false, \n message: 'Failed to retrieve media file' \n }, 500);\n }\n});\n\nexport default media;",[],[197,310,302],"routes","98a5cb58-3cba-11f0-8962-9e149126039e","auth.ts","98a5cbf8-3cba-11f0-8962-9e149126039e",14,["D",1748543257101],"import { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { \n createUser, \n getUserByEmail, \n getUserByUsername, \n getUserPasswordHash,\n deleteUserSessions \n} from \"../database/queries.ts\";\nimport { \n hashPassword, \n verifyPassword, \n createUserSession, \n invalidateSession,\n requireAuth,\n getCurrentUser,\n getTokenFromRequest\n} from \"../auth/utils.ts\";\nimport { validateEmail, validatePassword } from \"../../shared/utils.ts\";\nimport type { AuthResponse } from \"../../shared/types.ts\";\n\nconst auth = new Hono();\n\n// Register new user\nauth.post('/signup', async (c) => {\n try {\n const { email, username, password } = await c.req.json();\n\n // Validate input\n if (!email || !username || !password) {\n return c.json({ \n success: false, \n message: 'Email, username, and password are required' \n }, 400);\n }\n\n if (!validateEmail(email)) {\n return c.json({ \n success: false, \n message: 'Invalid email format' \n }, 400);\n }\n\n const passwordValidation = validatePassword(password);\n if (!passwordValidation.valid) {\n return c.json({ \n success: false, \n message: passwordValidation.message \n }, 400);\n }\n\n // Check if user already exists\n const existingUserByEmail = await getUserByEmail(email);\n if (existingUserByEmail) {\n return c.json({ \n success: false, \n message: 'User with this email already exists' \n }, 409);\n }\n\n const existingUserByUsername = await getUserByUsername(username);\n if (existingUserByUsername) {\n return c.json({ \n success: false, \n message: 'Username already taken' \n }, 409);\n }\n\n // Create user\n const passwordHash = await hashPassword(password);\n const user = await createUser(email, username, passwordHash);\n const token = await createUserSession(user.id);\n\n const response: AuthResponse = {\n success: true,\n user,\n token,\n message: 'User created successfully'\n };\n\n return c.json(response, 201);\n } catch (error) {\n console.error('Signup error:', error);\n return c.json({ \n success: false, \n message: 'Internal server error' \n }, 500);\n }\n});\n\n// Login user\nauth.post('/login', async (c) => {\n try {\n const { email, password } = await c.req.json();\n\n if (!email || !password) {\n return c.json({ \n success: false, \n message: 'Email and password are required' \n }, 400);\n }\n\n // Get user and password hash\n const user = await getUserByEmail(email);\n if (!user) {\n return c.json({ \n success: false, \n message: 'Invalid email or password' \n }, 401);\n }\n\n const passwordHash = await getUserPasswordHash(email);\n if (!passwordHash) {\n return c.json({ \n success: false, \n message: 'Invalid email or password' \n }, 401);\n }\n\n // Verify password\n const isValidPassword = await verifyPassword(password, passwordHash);\n if (!isValidPassword) {\n return c.json({ \n success: false, \n message: 'Invalid email or password' \n }, 401);\n }\n\n // Create session\n const token = await createUserSession(user.id);\n\n const response: AuthResponse = {\n success: true,\n user,\n token,\n message: 'Login successful'\n };\n\n return c.json(response);\n } catch (error) {\n console.error('Login error:', error);\n return c.json({ \n success: false, \n message: 'Internal server error' \n }, 500);\n }\n});\n\n// Logout user\nauth.post('/logout', requireAuth, async (c) => {\n try {\n const token = getTokenFromRequest(c);\n if (token) {\n await invalidateSession(token);\n }\n\n return c.json({ \n success: true, \n message: 'Logout successful' \n });\n } catch (error) {\n console.error('Logout error:', error);\n return c.json({ \n success: false, \n message: 'Internal server error' \n }, 500);\n }\n});\n\n// Get current user\nauth.get('/me', requireAuth, async (c) => {\n try {\n const user = getCurrentUser(c);\n return c.json({ \n success: true, \n user \n });\n } catch (error) {\n console.error('Get user error:', error);\n return c.json({ \n success: false, \n message: 'Internal server error' \n }, 500);\n }\n});\n\n// Logout from all devices\nauth.post('/logout-all', requireAuth, async (c) => {\n try {\n const user = getCurrentUser(c);\n await deleteUserSessions(user.id);\n\n return c.json({ \n success: true, \n message: 'Logged out from all devices' \n });\n } catch (error) {\n console.error('Logout all error:', error);\n return c.json({ \n success: false, \n message: 'Internal server error' \n }, 500);\n }\n});\n\nexport default auth;",[],[197,310,312],"98a5d85a-3cba-11f0-8962-9e149126039e",["D",1748543257101],[219,220],[197,310],"70861c36-3cba-11f0-8367-9e149126039e","queries.ts","70861cf4-3cba-11f0-8367-9e149126039e","7007d617-c866-4d62-b49d-4382369ad7cd",11,["D",1748543189786],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport type { User, MediaAnalysis } from \"../../shared/types.ts\";\n\n// User queries\nexport async function createUser(email: string, username: string, passwordHash: string): Promise {\n const result = await sqlite.execute(\n `INSERT INTO users_v1 (email, username, password_hash) VALUES (?, ?, ?) RETURNING *`,\n [email, username, passwordHash]\n );\n return result[0] as User;\n}\n\nexport async function getUserByEmail(email: string): Promise {\n const result = await sqlite.execute(\n `SELECT id, email, username, created_at FROM users_v1 WHERE email = ?`,\n [email]\n );\n return result[0] as User || null;\n}\n\nexport async function getUserByUsername(username: string): Promise {\n const result = await sqlite.execute(\n `SELECT id, email, username, created_at FROM users_v1 WHERE username = ?`,\n [username]\n );\n return result[0] as User || null;\n}\n\nexport async function getUserById(id: number): Promise {\n const result = await sqlite.execute(\n `SELECT id, email, username, created_at FROM users_v1 WHERE id = ?`,\n [id]\n );\n return result[0] as User || null;\n}\n\nexport async function getUserPasswordHash(email: string): Promise {\n const result = await sqlite.execute(\n `SELECT password_hash FROM users_v1 WHERE email = ?`,\n [email]\n );\n return result[0]?.password_hash || null;\n}\n\n// Session queries\nexport async function createSession(userId: number, tokenHash: string, expiresAt: string): Promise {\n await sqlite.execute(\n `INSERT INTO user_sessions_v1 (user_id, token_hash, expires_at) VALUES (?, ?, ?)`,\n [userId, tokenHash, expiresAt]\n );\n}\n\nexport async function validateSession(tokenHash: string): Promise {\n const result = await sqlite.execute(\n `SELECT user_id FROM user_sessions_v1 WHERE token_hash = ? AND expires_at > datetime('now')`,\n [tokenHash]\n );\n return result[0]?.user_id || null;\n}\n\nexport async function deleteSession(tokenHash: string): Promise {\n await sqlite.execute(\n `DELETE FROM user_sessions_v1 WHERE token_hash = ?`,\n [tokenHash]\n );\n}\n\nexport async function deleteUserSessions(userId: number): Promise {\n await sqlite.execute(\n `DELETE FROM user_sessions_v1 WHERE user_id = ?`,\n [userId]\n );\n}\n\n// Media analysis queries\nexport async function createMediaAnalysis(\n userId: number,\n mediaType: string,\n fileName: string,\n fileSize: number,\n blobKey: string,\n analysisResult: string,\n tags: string[],\n confidenceScore: number\n): Promise {\n const result = await sqlite.execute(\n `INSERT INTO media_analyses_v1 \n (user_id, media_type, file_name, file_size, blob_key, analysis_result, tags, confidence_score) \n VALUES (?, ?, ?, ?, ?, ?, ?, ?) RETURNING *`,\n [userId, mediaType, fileName, fileSize, blobKey, JSON.stringify(tags), analysisResult, confidenceScore]\n );\n \n const analysis = result[0] as any;\n return {\n ...analysis,\n tags: JSON.parse(analysis.tags)\n } as MediaAnalysis;\n}\n\nexport async function getUserMediaAnalyses(userId: number, limit: number = 50): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM media_analyses_v1 WHERE user_id = ? ORDER BY created_at DESC LIMIT ?`,\n [userId, limit]\n );\n \n return result.map((analysis: any) => ({\n ...analysis,\n tags: JSON.parse(analysis.tags)\n })) as MediaAnalysis[];\n}\n\nexport async function getMediaAnalysisById(id: number, userId: number): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM media_analyses_v1 WHERE id = ? AND user_id = ?`,\n [id, userId]\n );\n \n if (!result[0]) return null;\n \n const analysis = result[0] as any;\n return {\n ...analysis,\n tags: JSON.parse(analysis.tags)\n } as MediaAnalysis;\n}\n\nexport async function searchMediaAnalyses(\n userId: number,\n query: string,\n mediaType?: string,\n limit: number = 20\n): Promise {\n let sql = `\n SELECT * FROM media_analyses_v1 \n WHERE user_id = ? AND (\n analysis_result LIKE ? OR \n tags LIKE ? OR \n file_name LIKE ?\n )\n `;\n \n const params: any[] = [userId, `%${query}%`, `%${query}%`, `%${query}%`];\n \n if (mediaType) {\n sql += ` AND media_type = ?`;\n params.push(mediaType);\n }\n \n sql += ` ORDER BY created_at DESC LIMIT ?`;\n params.push(limit);\n \n const result = await sqlite.execute(sql, params);\n \n return result.map((analysis: any) => ({\n ...analysis,\n tags: JSON.parse(analysis.tags)\n })) as MediaAnalysis[];\n}\n\nexport async function deleteMediaAnalysis(id: number, userId: number): Promise {\n const result = await sqlite.execute(\n `DELETE FROM media_analyses_v1 WHERE id = ? AND user_id = ?`,\n [id, userId]\n );\n return result.changes > 0;\n}\n\n// Search history queries\nexport async function createSearchHistory(\n userId: number,\n query: string,\n mediaType: string | null,\n resultsCount: number\n): Promise {\n await sqlite.execute(\n `INSERT INTO search_history_v1 (user_id, query, media_type, results_count) VALUES (?, ?, ?, ?)`,\n [userId, query, mediaType, resultsCount]\n );\n}\n\nexport async function getUserSearchHistory(userId: number, limit: number = 10): Promise {\n const result = await sqlite.execute(\n `SELECT query, media_type, results_count, created_at \n FROM search_history_v1 \n WHERE user_id = ? \n ORDER BY created_at DESC \n LIMIT ?`,\n [userId, limit]\n );\n return result;\n}",[],[197,332,324],"database","630a8f06-3cba-11f0-bbbe-9e149126039e","migrations.ts","630a8fe2-3cba-11f0-bbbe-9e149126039e",["D",1748543167164],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n\n// Database schema definitions and migrations\n\nexport async function initializeDatabase() {\n // Users table\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS users_v1 (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n email TEXT UNIQUE NOT NULL,\n username TEXT UNIQUE NOT NULL,\n password_hash TEXT NOT NULL,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n updated_at DATETIME DEFAULT CURRENT_TIMESTAMP\n )\n `);\n\n // Media analyses table\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS media_analyses_v1 (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n user_id INTEGER NOT NULL,\n media_type TEXT NOT NULL CHECK (media_type IN ('image', 'video', 'audio')),\n file_name TEXT NOT NULL,\n file_size INTEGER NOT NULL,\n blob_key TEXT NOT NULL,\n analysis_result TEXT NOT NULL,\n tags TEXT NOT NULL, -- JSON array of tags\n confidence_score REAL NOT NULL DEFAULT 0.0,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n FOREIGN KEY (user_id) REFERENCES users_v1 (id) ON DELETE CASCADE\n )\n `);\n\n // User sessions table for JWT token management\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS user_sessions_v1 (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n user_id INTEGER NOT NULL,\n token_hash TEXT NOT NULL,\n expires_at DATETIME NOT NULL,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n FOREIGN KEY (user_id) REFERENCES users_v1 (id) ON DELETE CASCADE\n )\n `);\n\n // Search history table\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS search_history_v1 (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n user_id INTEGER NOT NULL,\n query TEXT NOT NULL,\n media_type TEXT,\n results_count INTEGER NOT NULL DEFAULT 0,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n FOREIGN KEY (user_id) REFERENCES users_v1 (id) ON DELETE CASCADE\n )\n `);\n\n // Create indexes for better performance\n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_media_analyses_user_id ON media_analyses_v1(user_id)\n `);\n \n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_media_analyses_type ON media_analyses_v1(media_type)\n `);\n \n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_media_analyses_created_at ON media_analyses_v1(created_at)\n `);\n \n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_user_sessions_user_id ON user_sessions_v1(user_id)\n `);\n \n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_user_sessions_expires_at ON user_sessions_v1(expires_at)\n `);\n\n console.log('Database initialized successfully');\n}\n\nexport async function cleanupExpiredSessions() {\n await sqlite.execute(`\n DELETE FROM user_sessions_v1 \n WHERE expires_at < datetime('now')\n `);\n}",[],[197,332,334],"630ab3dc-3cba-11f0-bbbe-9e149126039e",["D",1748543167164],[216,217],[197,332],"79666162-3cba-11f0-a622-9e149126039e","79666202-3cba-11f0-a622-9e149126039e","4a597fca-4fe3-4edc-9b5a-2d40ac8f5452",12,["D",1748543204677],"import { Context } from \"https://esm.sh/hono@3.11.7\";\nimport { sign, verify } from \"https://esm.sh/jsonwebtoken@9.0.2\";\nimport { hash, compare } from \"https://esm.sh/bcryptjs@2.4.3\";\nimport { getUserById, validateSession, createSession, deleteSession } from \"../database/queries.ts\";\nimport type { User } from \"../../shared/types.ts\";\n\nconst JWT_SECRET = Deno.env.get('JWT_SECRET') || 'your-secret-key-change-in-production';\nconst TOKEN_EXPIRY = '7d'; // 7 days\n\nexport async function hashPassword(password: string): Promise {\n return await hash(password, 12);\n}\n\nexport async function verifyPassword(password: string, hash: string): Promise {\n return await compare(password, hash);\n}\n\nexport function generateToken(userId: number): string {\n return sign({ userId }, JWT_SECRET, { expiresIn: TOKEN_EXPIRY });\n}\n\nexport async function verifyToken(token: string): Promise {\n try {\n const decoded = verify(token, JWT_SECRET) as { userId: number };\n return decoded.userId;\n } catch {\n return null;\n }\n}\n\nexport async function createUserSession(userId: number): Promise {\n const token = generateToken(userId);\n const tokenHash = await hash(token, 10);\n const expiresAt = new Date(Date.now() + 7 * 24 * 60 * 60 * 1000).toISOString(); // 7 days\n \n await createSession(userId, tokenHash, expiresAt);\n return token;\n}\n\nexport async function validateUserSession(token: string): Promise {\n const userId = await verifyToken(token);\n if (!userId) return null;\n \n const tokenHash = await hash(token, 10);\n const sessionUserId = await validateSession(tokenHash);\n \n if (!sessionUserId || sessionUserId !== userId) return null;\n \n return await getUserById(userId);\n}\n\nexport async function invalidateSession(token: string): Promise {\n const tokenHash = await hash(token, 10);\n await deleteSession(tokenHash);\n}\n\nexport function getTokenFromRequest(c: Context): string | null {\n const authHeader = c.req.header('Authorization');\n if (authHeader && authHeader.startsWith('Bearer ')) {\n return authHeader.substring(7);\n }\n \n // Also check cookies as fallback\n const cookieToken = c.req.header('Cookie')\n ?.split(';')\n .find(cookie => cookie.trim().startsWith('auth_token='))\n ?.split('=')[1];\n \n return cookieToken || null;\n}\n\nexport async function requireAuth(c: Context, next: () => Promise) {\n const token = getTokenFromRequest(c);\n \n if (!token) {\n return c.json({ success: false, message: 'Authentication required' }, 401);\n }\n \n const user = await validateUserSession(token);\n if (!user) {\n return c.json({ success: false, message: 'Invalid or expired token' }, 401);\n }\n \n // Add user to context\n c.set('user', user);\n await next();\n}\n\nexport function getCurrentUser(c: Context): User {\n return c.get('user');\n}",[],[197,352,255],"auth","796685e8-3cba-11f0-a622-9e149126039e",["D",1748543204677],[214],[197,352],["D",1748543167164],[213,215,218,221,223],[197],["D",1748542306097],{"_100":99,"_107":103},{"_100":99,"_101":-5,"_102":103,"_18":58,"_104":105,"_106":25},{"_13":89,"_32":90,"_47":41,"_91":48,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":49,"_98":99},"ctx",{"_82":-5,"_127":397,"_398":399,"_400":401,"_402":25,"_403":25,"_404":25,"_405":62,"_406":-5,"_407":-7,"_408":-7,"_409":66,"_410":25,"_411":25,"_412":-5,"_413":25,"_414":25,"_415":25,"_416":-5},"ENV",{"_368":369,"_370":371,"_372":90,"_373":374,"_375":376,"_377":378,"_379":380,"_381":382,"_383":384,"_385":386,"_387":388,"_389":390,"_391":392,"_393":394,"_395":396},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","c73f21da490985bff19c279eb0e09db24d688e4f","RENDER_GIT_BRANCH","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","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v17