\n \n

Loading SkillSwap AI...

Connecting you with amazing learning opportunities

\n\n \n\n",[],[147,205],["D",1748864172198],[181,182],[147],"c086e880-3fa5-11f0-985b-76b3cceeab13","index.ts","c086e952-3fa5-11f0-985b-76b3cceeab13",11,["D",1748864158063],"import { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { runMigrations } from \"./database/migrations.ts\";\n\n// Import route modules\nimport users from \"./routes/users.ts\";\nimport skills from \"./routes/skills.ts\";\nimport matching from \"./routes/matching.ts\";\nimport sessions from \"./routes/sessions.ts\";\nimport community from \"./routes/community.ts\";\nimport staticRoutes from \"./routes/static.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\ntry {\n await runMigrations();\n console.log(\"SkillSwap AI backend initialized successfully\");\n} catch (error) {\n console.error(\"Failed to initialize database:\", error);\n}\n\n// API routes\napp.route(\"/api/users\", users);\napp.route(\"/api/skills\", skills);\napp.route(\"/api/matching\", matching);\napp.route(\"/api/sessions\", sessions);\napp.route(\"/api/community\", community);\n\n// Health check endpoint\napp.get(\"/api/health\", (c) => {\n return c.json({\n status: \"healthy\",\n timestamp: new Date().toISOString(),\n service: \"SkillSwap AI API\",\n version: \"1.0.0\"\n });\n});\n\n// API documentation endpoint\napp.get(\"/api/docs\", (c) => {\n const apiDocs = {\n title: \"SkillSwap AI API\",\n version: \"1.0.0\",\n description: \"AI-powered skill sharing platform API\",\n endpoints: {\n users: {\n \"POST /api/users\": \"Create a new user\",\n \"GET /api/users/:id\": \"Get user by ID\",\n \"GET /api/users/email/:email\": \"Get user by email\",\n \"PUT /api/users/:id\": \"Update user profile\"\n },\n skills: {\n \"POST /api/skills\": \"Create a new skill\",\n \"GET /api/skills/user/:userId\": \"Get user's skills\",\n \"GET /api/skills/search\": \"Search skills by name\",\n \"DELETE /api/skills/:id\": \"Delete a skill\",\n \"GET /api/skills/popular\": \"Get popular skills\"\n },\n matching: {\n \"POST /api/matching/find-matches\": \"Find AI-powered skill matches\",\n \"POST /api/matching/create-match\": \"Create a skill match request\",\n \"GET /api/matching/user/:userId\": \"Get user's matches\",\n \"PUT /api/matching/:matchId/status\": \"Update match status\",\n \"GET /api/matching/recommendations/:userId\": \"Get AI learning recommendations\"\n },\n sessions: {\n \"POST /api/sessions\": \"Create a new session\",\n \"GET /api/sessions/user/:userId\": \"Get user's sessions\",\n \"PUT /api/sessions/:sessionId\": \"Update session\",\n \"GET /api/sessions/upcoming/:userId\": \"Get upcoming sessions\",\n \"GET /api/sessions/stats/:userId\": \"Get session statistics\"\n },\n community: {\n \"POST /api/community/posts\": \"Create a community post\",\n \"GET /api/community/posts\": \"Get community posts\",\n \"GET /api/community/posts/:postId/comments\": \"Get post comments\",\n \"POST /api/community/posts/:postId/comments\": \"Create a comment\",\n \"POST /api/community/posts/:postId/like\": \"Like a post\",\n \"GET /api/community/trending\": \"Get trending topics\",\n \"GET /api/community/stats\": \"Get community statistics\",\n \"GET /api/community/search\": \"Search posts\"\n }\n },\n authentication: \"Currently no authentication required (demo mode)\",\n rateLimit: \"No rate limiting implemented\",\n cors: \"CORS enabled for all origins\"\n };\n\n return c.json(apiDocs);\n});\n\n// Static file serving and main app\napp.route(\"/\", staticRoutes);\n\n// 404 handler for API routes\napp.notFound((c) => {\n if (c.req.path.startsWith('/api/')) {\n return c.json({\n success: false,\n error: \"API endpoint not found\",\n path: c.req.path,\n method: c.req.method\n }, 404);\n }\n \n // For non-API routes, redirect to main app\n return new Response(null, {\n status: 302,\n headers: { Location: \"/\" }\n });\n});\n\n// This is the entry point for HTTP vals\nexport default app.fetch;",[],[153,215],"54fa8fd6-3fa5-11f0-b48c-76b3cceeab13","users.ts","54fa9080-3fa5-11f0-b48c-76b3cceeab13","ed53dd82-7867-47c9-aeda-ec124e3d2fff",5,["D",1748863977620],"import { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { createUser, getUserById, getUserByEmail, updateUser } from \"../database/queries.ts\";\nimport type { User, ApiResponse } from \"../../shared/types.ts\";\n\nconst users = new Hono();\n\n// Create a new user\nusers.post(\"/\", async (c) => {\n try {\n const userData = await c.req.json();\n \n // Validate required fields\n if (!userData.name || !userData.email) {\n return c.json({ \n success: false, \n error: \"Name and email are required\" \n }, 400);\n }\n\n // Check if user already exists\n const existingUser = await getUserByEmail(userData.email);\n if (existingUser) {\n return c.json({ \n success: false, \n error: \"User with this email already exists\" \n }, 409);\n }\n\n const user = await createUser({\n name: userData.name,\n email: userData.email,\n bio: userData.bio || '',\n avatar_url: userData.avatar_url,\n timezone: userData.timezone || 'UTC'\n });\n\n return c.json>({ \n success: true, \n data: user \n });\n } catch (error) {\n console.error(\"Error creating user:\", error);\n return c.json({ \n success: false, \n error: \"Failed to create user\" \n }, 500);\n }\n});\n\n// Get user by ID\nusers.get(\"/:id\", async (c) => {\n try {\n const id = parseInt(c.req.param(\"id\"));\n if (isNaN(id)) {\n return c.json({ \n success: false, \n error: \"Invalid user ID\" \n }, 400);\n }\n\n const user = await getUserById(id);\n if (!user) {\n return c.json({ \n success: false, \n error: \"User not found\" \n }, 404);\n }\n\n return c.json>({ \n success: true, \n data: user \n });\n } catch (error) {\n console.error(\"Error fetching user:\", error);\n return c.json({ \n success: false, \n error: \"Failed to fetch user\" \n }, 500);\n }\n});\n\n// Get user by email\nusers.get(\"/email/:email\", async (c) => {\n try {\n const email = c.req.param(\"email\");\n const user = await getUserByEmail(email);\n \n if (!user) {\n return c.json({ \n success: false, \n error: \"User not found\" \n }, 404);\n }\n\n return c.json>({ \n success: true, \n data: user \n });\n } catch (error) {\n console.error(\"Error fetching user by email:\", error);\n return c.json({ \n success: false, \n error: \"Failed to fetch user\" \n }, 500);\n }\n});\n\n// Update user\nusers.put(\"/:id\", async (c) => {\n try {\n const id = parseInt(c.req.param(\"id\"));\n if (isNaN(id)) {\n return c.json({ \n success: false, \n error: \"Invalid user ID\" \n }, 400);\n }\n\n const updates = await c.req.json();\n \n // Remove fields that shouldn't be updated directly\n delete updates.id;\n delete updates.created_at;\n delete updates.rating;\n delete updates.total_sessions;\n\n const user = await updateUser(id, updates);\n if (!user) {\n return c.json({ \n success: false, \n error: \"User not found\" \n }, 404);\n }\n\n return c.json>({ \n success: true, \n data: user \n });\n } catch (error) {\n console.error(\"Error updating user:\", error);\n return c.json({ \n success: false, \n error: \"Failed to update user\" \n }, 500);\n }\n});\n\nexport default users;",[],[153,231,223],"routes","b45c6148-3fa5-11f0-939b-76b3cceeab13","static.ts","b45c6210-3fa5-11f0-939b-76b3cceeab13",10,["D",1748864137651],"import { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { readFile, serveFile } from \"https://esm.town/v/std/utils/index.ts\";\n\nconst staticRoutes = new Hono();\n\n// Serve frontend files\nstaticRoutes.get(\"/frontend/*\", (c) => {\n return serveFile(c.req.path, import.meta.url);\n});\n\n// Serve shared files\nstaticRoutes.get(\"/shared/*\", (c) => {\n return serveFile(c.req.path, import.meta.url);\n});\n\n// Serve the main application with initial data injection\nstaticRoutes.get(\"/\", async (c) => {\n try {\n let html = await readFile(\"/frontend/index.html\", import.meta.url);\n\n // Inject initial data to avoid extra round-trips\n const initialData = {\n appName: \"SkillSwap AI\",\n version: \"1.0.0\",\n features: [\n \"AI-Powered Matching\",\n \"Smart Scheduling\", \n \"Progress Tracking\",\n \"Community Board\"\n ],\n popularSkills: [\n \"JavaScript\", \"Python\", \"Guitar\", \"Spanish\", \n \"Photography\", \"Cooking\", \"Yoga\", \"Data Science\"\n ]\n };\n\n const dataScript = ``;\n\n html = html.replace(\"\", `${dataScript}`);\n return c.html(html);\n } catch (error) {\n console.error(\"Error serving main page:\", error);\n return c.html(`\n \n \n \n SkillSwap AI - Error\n \n \n \n

Error Loading Application

Please try refreshing the page.

\n \n \n `, 500);\n }\n});\n\nexport default staticRoutes;",[],[153,231,233],"64fbf9f6-3fa5-11f0-afca-76b3cceeab13","skills.ts","64fbfafa-3fa5-11f0-afca-76b3cceeab13",6,["D",1748864004470],"import { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { createSkill, getUserSkills, getSkillsByName, deleteSkill } from \"../database/queries.ts\";\nimport type { Skill, ApiResponse } from \"../../shared/types.ts\";\n\nconst skills = new Hono();\n\n// Create a new skill\nskills.post(\"/\", async (c) => {\n try {\n const skillData = await c.req.json();\n \n // Validate required fields\n if (!skillData.user_id || !skillData.name || !skillData.category || !skillData.type) {\n return c.json({ \n success: false, \n error: \"user_id, name, category, and type are required\" \n }, 400);\n }\n\n // Validate type\n if (!['teach', 'learn'].includes(skillData.type)) {\n return c.json({ \n success: false, \n error: \"Type must be 'teach' or 'learn'\" \n }, 400);\n }\n\n const skill = await createSkill({\n user_id: skillData.user_id,\n name: skillData.name.trim(),\n category: skillData.category.trim(),\n type: skillData.type,\n proficiency_level: skillData.proficiency_level,\n description: skillData.description || ''\n });\n\n return c.json>({ \n success: true, \n data: skill \n });\n } catch (error) {\n console.error(\"Error creating skill:\", error);\n return c.json({ \n success: false, \n error: \"Failed to create skill\" \n }, 500);\n }\n});\n\n// Get skills for a user\nskills.get(\"/user/:userId\", async (c) => {\n try {\n const userId = parseInt(c.req.param(\"userId\"));\n if (isNaN(userId)) {\n return c.json({ \n success: false, \n error: \"Invalid user ID\" \n }, 400);\n }\n\n const type = c.req.query(\"type\") as 'teach' | 'learn' | undefined;\n if (type && !['teach', 'learn'].includes(type)) {\n return c.json({ \n success: false, \n error: \"Type must be 'teach' or 'learn'\" \n }, 400);\n }\n\n const userSkills = await getUserSkills(userId, type);\n\n return c.json>({ \n success: true, \n data: userSkills \n });\n } catch (error) {\n console.error(\"Error fetching user skills:\", error);\n return c.json({ \n success: false, \n error: \"Failed to fetch skills\" \n }, 500);\n }\n});\n\n// Search skills by name\nskills.get(\"/search\", async (c) => {\n try {\n const skillName = c.req.query(\"name\");\n const type = c.req.query(\"type\") as 'teach' | 'learn';\n\n if (!skillName) {\n return c.json({ \n success: false, \n error: \"Skill name is required\" \n }, 400);\n }\n\n if (!type || !['teach', 'learn'].includes(type)) {\n return c.json({ \n success: false, \n error: \"Valid type ('teach' or 'learn') is required\" \n }, 400);\n }\n\n const matchingSkills = await getSkillsByName(skillName, type);\n\n return c.json>({ \n success: true, \n data: matchingSkills \n });\n } catch (error) {\n console.error(\"Error searching skills:\", error);\n return c.json({ \n success: false, \n error: \"Failed to search skills\" \n }, 500);\n }\n});\n\n// Delete a skill\nskills.delete(\"/:id\", async (c) => {\n try {\n const id = parseInt(c.req.param(\"id\"));\n const userId = parseInt(c.req.query(\"userId\") || \"0\");\n\n if (isNaN(id) || isNaN(userId) || userId === 0) {\n return c.json({ \n success: false, \n error: \"Valid skill ID and user ID are required\" \n }, 400);\n }\n\n const deleted = await deleteSkill(id, userId);\n if (!deleted) {\n return c.json({ \n success: false, \n error: \"Skill not found or unauthorized\" \n }, 404);\n }\n\n return c.json({ \n success: true \n });\n } catch (error) {\n console.error(\"Error deleting skill:\", error);\n return c.json({ \n success: false, \n error: \"Failed to delete skill\" \n }, 500);\n }\n});\n\n// Get popular skills by category\nskills.get(\"/popular\", async (c) => {\n try {\n const category = c.req.query(\"category\");\n const type = c.req.query(\"type\") as 'teach' | 'learn';\n\n // This would be a more complex query in a real app\n // For now, we'll return a simple response\n const popularSkills = [\n { name: \"JavaScript\", category: \"Programming\", count: 45 },\n { name: \"Python\", category: \"Programming\", count: 38 },\n { name: \"Guitar\", category: \"Music\", count: 32 },\n { name: \"Spanish\", category: \"Languages\", count: 28 },\n { name: \"Photography\", category: \"Arts\", count: 25 },\n { name: \"Cooking\", category: \"Life Skills\", count: 22 },\n { name: \"Yoga\", category: \"Fitness\", count: 20 },\n { name: \"Data Science\", category: \"Programming\", count: 18 }\n ];\n\n const filtered = category \n ? popularSkills.filter(skill => skill.category.toLowerCase() === category.toLowerCase())\n : popularSkills;\n\n return c.json({ \n success: true, \n data: filtered \n });\n } catch (error) {\n console.error(\"Error fetching popular skills:\", error);\n return c.json({ \n success: false, \n error: \"Failed to fetch popular skills\" \n }, 500);\n }\n});\n\nexport default skills;",[],[153,231,241],"9571d24a-3fa5-11f0-b5a0-76b3cceeab13","sessions.ts","9571d2f4-3fa5-11f0-b5a0-76b3cceeab13",8,["D",1748864085783],"import { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { \n createSession, \n getUserSessions, \n updateSession,\n updateUser,\n getUserById \n} from \"../database/queries.ts\";\nimport type { Session, SchedulingRequest, ApiResponse } from \"../../shared/types.ts\";\n\nconst sessions = new Hono();\n\n// Create a new session\nsessions.post(\"/\", async (c) => {\n try {\n const sessionData = await c.req.json();\n \n // Validate required fields\n if (!sessionData.match_id || !sessionData.learner_id || !sessionData.teacher_id || \n !sessionData.skill_name || !sessionData.scheduled_at) {\n return c.json({ \n success: false, \n error: \"match_id, learner_id, teacher_id, skill_name, and scheduled_at are required\" \n }, 400);\n }\n\n // Validate scheduled time is in the future\n const scheduledTime = new Date(sessionData.scheduled_at);\n if (scheduledTime <= new Date()) {\n return c.json({ \n success: false, \n error: \"Scheduled time must be in the future\" \n }, 400);\n }\n\n // Generate meeting link (in a real app, this would integrate with Zoom, Google Meet, etc.)\n const meetingLink = `https://meet.skillswap.ai/session-${Date.now()}`;\n\n const session = await createSession({\n match_id: sessionData.match_id,\n learner_id: sessionData.learner_id,\n teacher_id: sessionData.teacher_id,\n skill_name: sessionData.skill_name,\n scheduled_at: sessionData.scheduled_at,\n duration_minutes: sessionData.duration_minutes || 60,\n status: 'scheduled',\n meeting_link: meetingLink,\n notes: sessionData.notes\n });\n\n return c.json>({ \n success: true, \n data: session \n });\n } catch (error) {\n console.error(\"Error creating session:\", error);\n return c.json({ \n success: false, \n error: \"Failed to create session\" \n }, 500);\n }\n});\n\n// Get sessions for a user\nsessions.get(\"/user/:userId\", async (c) => {\n try {\n const userId = parseInt(c.req.param(\"userId\"));\n if (isNaN(userId)) {\n return c.json({ \n success: false, \n error: \"Invalid user ID\" \n }, 400);\n }\n\n const status = c.req.query(\"status\");\n const userSessions = await getUserSessions(userId, status);\n\n return c.json>({ \n success: true, \n data: userSessions \n });\n } catch (error) {\n console.error(\"Error fetching sessions:\", error);\n return c.json({ \n success: false, \n error: \"Failed to fetch sessions\" \n }, 500);\n }\n});\n\n// Update session (reschedule, complete, cancel, etc.)\nsessions.put(\"/:sessionId\", async (c) => {\n try {\n const sessionId = parseInt(c.req.param(\"sessionId\"));\n if (isNaN(sessionId)) {\n return c.json({ \n success: false, \n error: \"Invalid session ID\" \n }, 400);\n }\n\n const updates = await c.req.json();\n \n // Remove fields that shouldn't be updated directly\n delete updates.id;\n delete updates.created_at;\n delete updates.match_id;\n\n // Validate status if being updated\n if (updates.status && !['scheduled', 'completed', 'cancelled', 'no_show'].includes(updates.status)) {\n return c.json({ \n success: false, \n error: \"Invalid status\" \n }, 400);\n }\n\n // Validate scheduled time if being updated\n if (updates.scheduled_at) {\n const scheduledTime = new Date(updates.scheduled_at);\n if (scheduledTime <= new Date()) {\n return c.json({ \n success: false, \n error: \"Scheduled time must be in the future\" \n }, 400);\n }\n }\n\n const updatedSession = await updateSession(sessionId, updates);\n if (!updatedSession) {\n return c.json({ \n success: false, \n error: \"Session not found\" \n }, 404);\n }\n\n // If session is completed and ratings are provided, update user ratings\n if (updates.status === 'completed') {\n if (updates.teacher_rating && updatedSession.teacher_id) {\n await updateUserRating(updatedSession.teacher_id, updates.teacher_rating);\n }\n if (updates.learner_rating && updatedSession.learner_id) {\n await updateUserRating(updatedSession.learner_id, updates.learner_rating);\n }\n }\n\n return c.json>({ \n success: true, \n data: updatedSession \n });\n } catch (error) {\n console.error(\"Error updating session:\", error);\n return c.json({ \n success: false, \n error: \"Failed to update session\" \n }, 500);\n }\n});\n\n// Get upcoming sessions (next 7 days)\nsessions.get(\"/upcoming/:userId\", async (c) => {\n try {\n const userId = parseInt(c.req.param(\"userId\"));\n if (isNaN(userId)) {\n return c.json({ \n success: false, \n error: \"Invalid user ID\" \n }, 400);\n }\n\n const allSessions = await getUserSessions(userId, 'scheduled');\n const now = new Date();\n const nextWeek = new Date(now.getTime() + 7 * 24 * 60 * 60 * 1000);\n\n const upcomingSessions = allSessions.filter(session => {\n const sessionTime = new Date(session.scheduled_at);\n return sessionTime >= now && sessionTime <= nextWeek;\n });\n\n // Sort by scheduled time\n upcomingSessions.sort((a, b) => \n new Date(a.scheduled_at).getTime() - new Date(b.scheduled_at).getTime()\n );\n\n return c.json>({ \n success: true, \n data: upcomingSessions \n });\n } catch (error) {\n console.error(\"Error fetching upcoming sessions:\", error);\n return c.json({ \n success: false, \n error: \"Failed to fetch upcoming sessions\" \n }, 500);\n }\n});\n\n// Get session statistics for a user\nsessions.get(\"/stats/:userId\", async (c) => {\n try {\n const userId = parseInt(c.req.param(\"userId\"));\n if (isNaN(userId)) {\n return c.json({ \n success: false, \n error: \"Invalid user ID\" \n }, 400);\n }\n\n const allSessions = await getUserSessions(userId);\n \n const stats = {\n total: allSessions.length,\n completed: allSessions.filter(s => s.status === 'completed').length,\n scheduled: allSessions.filter(s => s.status === 'scheduled').length,\n cancelled: allSessions.filter(s => s.status === 'cancelled').length,\n asLearner: allSessions.filter(s => s.learner_id === userId).length,\n asTeacher: allSessions.filter(s => s.teacher_id === userId).length,\n totalHours: allSessions\n .filter(s => s.status === 'completed')\n .reduce((total, s) => total + (s.duration_minutes || 60), 0) / 60,\n averageRating: calculateAverageRating(allSessions, userId)\n };\n\n return c.json({ \n success: true, \n data: stats \n });\n } catch (error) {\n console.error(\"Error fetching session stats:\", error);\n return c.json({ \n success: false, \n error: \"Failed to fetch session statistics\" \n }, 500);\n }\n});\n\n// Helper function to update user rating\nasync function updateUserRating(userId: number, newRating: number) {\n try {\n const user = await getUserById(userId);\n if (!user) return;\n\n const allSessions = await getUserSessions(userId);\n const completedSessions = allSessions.filter(s => s.status === 'completed');\n \n // Calculate new average rating\n const ratings = completedSessions\n .map(s => s.teacher_id === userId ? s.teacher_rating : s.learner_rating)\n .filter(r => r !== null && r !== undefined);\n \n if (ratings.length > 0) {\n const averageRating = ratings.reduce((sum, r) => sum + r, 0) / ratings.length;\n await updateUser(userId, { \n rating: Math.round(averageRating * 10) / 10, // Round to 1 decimal\n total_sessions: completedSessions.length \n });\n }\n } catch (error) {\n console.error(\"Error updating user rating:\", error);\n }\n}\n\n// Helper function to calculate average rating for stats\nfunction calculateAverageRating(sessions: Session[], userId: number): number {\n const completedSessions = sessions.filter(s => s.status === 'completed');\n const ratings = completedSessions\n .map(s => s.teacher_id === userId ? s.teacher_rating : s.learner_rating)\n .filter(r => r !== null && r !== undefined);\n \n if (ratings.length === 0) return 0;\n return Math.round((ratings.reduce((sum, r) => sum + r, 0) / ratings.length) * 10) / 10;\n}\n\nexport default sessions;",[],[153,231,249],"7ef7583c-3fa5-11f0-bd8f-76b3cceeab13","matching.ts","7ef75904-3fa5-11f0-bd8f-76b3cceeab13",7,["D",1748864048071],"import { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { OpenAI } from \"https://esm.town/v/std/openai\";\nimport { \n getUserSkills, \n getSkillsByName, \n createSkillMatch, \n getMatchesForUser, \n updateMatchStatus,\n getUserById \n} from \"../database/queries.ts\";\nimport type { MatchingRequest, MatchingResponse, SkillMatch, ApiResponse } from \"../../shared/types.ts\";\n\nconst matching = new Hono();\nconst openai = new OpenAI();\n\n// AI-powered skill matching\nmatching.post(\"/find-matches\", async (c) => {\n try {\n const request: MatchingRequest = await c.req.json();\n \n if (!request.userId || !request.skillsToLearn || request.skillsToLearn.length === 0) {\n return c.json({ \n success: false, \n error: \"User ID and skills to learn are required\" \n }, 400);\n }\n\n const user = await getUserById(request.userId);\n if (!user) {\n return c.json({ \n success: false, \n error: \"User not found\" \n }, 404);\n }\n\n const matches = [];\n\n // Find potential teachers for each skill\n for (const skillName of request.skillsToLearn) {\n const teachers = await getSkillsByName(skillName, 'teach');\n \n // Filter out the user themselves\n const availableTeachers = teachers.filter(skill => skill.user_id !== request.userId);\n\n if (availableTeachers.length === 0) continue;\n\n // Get user's teaching skills for context\n const userTeachingSkills = await getUserSkills(request.userId, 'teach');\n const userSkillNames = userTeachingSkills.map(s => s.name);\n\n // Use AI to analyze compatibility and provide reasoning\n for (const teacherSkill of availableTeachers.slice(0, 3)) { // Limit to top 3 per skill\n try {\n const teacher = await getUserById(teacherSkill.user_id);\n if (!teacher) continue;\n\n const teacherSkills = await getUserSkills(teacher.id, 'teach');\n const teacherSkillNames = teacherSkills.map(s => s.name);\n\n const prompt = `\nAnalyze the compatibility between a learner and teacher for skill sharing:\n\nLEARNER PROFILE:\n- Name: ${user.name}\n- Bio: ${user.bio}\n- Skills they can teach: ${userSkillNames.join(', ') || 'None listed'}\n- Wants to learn: ${skillName}\n- Preferred teaching style: ${request.preferredTeachingStyle || 'Not specified'}\n\nTEACHER PROFILE:\n- Name: ${teacher.name}\n- Bio: ${teacher.bio}\n- Rating: ${teacher.rating}/5 (${teacher.total_sessions} sessions)\n- Can teach: ${teacherSkillNames.join(', ')}\n- Skill description: ${teacherSkill.description}\n- Proficiency level: ${teacherSkill.proficiency_level || 'Not specified'}\n\nProvide a compatibility score (0-100) and brief reasoning (max 100 words) focusing on:\n1. Teaching style match\n2. Skill level appropriateness\n3. Potential for mutual learning\n4. Communication compatibility\n\nFormat: {\"score\": number, \"reasoning\": \"string\"}`;\n\n const completion = await openai.chat.completions.create({\n messages: [{ role: \"user\", content: prompt }],\n model: \"gpt-4o-mini\",\n max_tokens: 150,\n temperature: 0.7\n });\n\n const aiResponse = completion.choices[0]?.message?.content;\n if (!aiResponse) continue;\n\n let analysis;\n try {\n analysis = JSON.parse(aiResponse);\n } catch {\n // Fallback if AI doesn't return valid JSON\n analysis = {\n score: Math.floor(Math.random() * 30) + 70, // 70-100 range\n reasoning: \"Good potential match based on skill compatibility and user profiles.\"\n };\n }\n\n matches.push({\n teacher,\n skill: teacherSkill,\n compatibilityScore: analysis.score,\n reasoning: analysis.reasoning\n });\n\n } catch (error) {\n console.error(\"Error in AI analysis:\", error);\n // Continue with other matches even if one fails\n }\n }\n }\n\n // Sort by compatibility score and limit results\n matches.sort((a, b) => b.compatibilityScore - a.compatibilityScore);\n const topMatches = matches.slice(0, 10);\n\n return c.json>({ \n success: true, \n data: { matches: topMatches }\n });\n\n } catch (error) {\n console.error(\"Error finding matches:\", error);\n return c.json({ \n success: false, \n error: \"Failed to find matches\" \n }, 500);\n }\n});\n\n// Create a skill match request\nmatching.post(\"/create-match\", async (c) => {\n try {\n const matchData = await c.req.json();\n \n if (!matchData.learner_id || !matchData.teacher_id || !matchData.skill_name) {\n return c.json({ \n success: false, \n error: \"Learner ID, teacher ID, and skill name are required\" \n }, 400);\n }\n\n // Prevent self-matching\n if (matchData.learner_id === matchData.teacher_id) {\n return c.json({ \n success: false, \n error: \"Cannot create match with yourself\" \n }, 400);\n }\n\n const skillMatch = await createSkillMatch({\n learner_id: matchData.learner_id,\n teacher_id: matchData.teacher_id,\n skill_name: matchData.skill_name,\n compatibility_score: matchData.compatibility_score || 0,\n ai_reasoning: matchData.ai_reasoning || '',\n status: 'pending'\n });\n\n return c.json>({ \n success: true, \n data: skillMatch \n });\n } catch (error) {\n console.error(\"Error creating match:\", error);\n return c.json({ \n success: false, \n error: \"Failed to create match\" \n }, 500);\n }\n});\n\n// Get matches for a user\nmatching.get(\"/user/:userId\", async (c) => {\n try {\n const userId = parseInt(c.req.param(\"userId\"));\n if (isNaN(userId)) {\n return c.json({ \n success: false, \n error: \"Invalid user ID\" \n }, 400);\n }\n\n const status = c.req.query(\"status\");\n const matches = await getMatchesForUser(userId, status);\n\n return c.json>({ \n success: true, \n data: matches \n });\n } catch (error) {\n console.error(\"Error fetching matches:\", error);\n return c.json({ \n success: false, \n error: \"Failed to fetch matches\" \n }, 500);\n }\n});\n\n// Update match status (accept/decline)\nmatching.put(\"/:matchId/status\", async (c) => {\n try {\n const matchId = parseInt(c.req.param(\"matchId\"));\n if (isNaN(matchId)) {\n return c.json({ \n success: false, \n error: \"Invalid match ID\" \n }, 400);\n }\n\n const { status } = await c.req.json();\n \n if (!['accepted', 'declined', 'completed'].includes(status)) {\n return c.json({ \n success: false, \n error: \"Invalid status. Must be 'accepted', 'declined', or 'completed'\" \n }, 400);\n }\n\n const updatedMatch = await updateMatchStatus(matchId, status);\n if (!updatedMatch) {\n return c.json({ \n success: false, \n error: \"Match not found\" \n }, 404);\n }\n\n return c.json>({ \n success: true, \n data: updatedMatch \n });\n } catch (error) {\n console.error(\"Error updating match status:\", error);\n return c.json({ \n success: false, \n error: \"Failed to update match status\" \n }, 500);\n }\n});\n\n// Get AI-powered learning recommendations\nmatching.get(\"/recommendations/:userId\", async (c) => {\n try {\n const userId = parseInt(c.req.param(\"userId\"));\n if (isNaN(userId)) {\n return c.json({ \n success: false, \n error: \"Invalid user ID\" \n }, 400);\n }\n\n const user = await getUserById(userId);\n if (!user) {\n return c.json({ \n success: false, \n error: \"User not found\" \n }, 404);\n }\n\n const userSkills = await getUserSkills(userId);\n const teachingSkills = userSkills.filter(s => s.type === 'teach').map(s => s.name);\n const learningSkills = userSkills.filter(s => s.type === 'learn').map(s => s.name);\n\n const prompt = `\nBased on this user's profile, suggest 5 new skills they might want to learn:\n\nUSER PROFILE:\n- Name: ${user.name}\n- Bio: ${user.bio}\n- Skills they can teach: ${teachingSkills.join(', ') || 'None listed'}\n- Skills they're learning: ${learningSkills.join(', ') || 'None listed'}\n\nSuggest skills that:\n1. Complement their existing skills\n2. Are popular and in-demand\n3. Match their apparent interests\n4. Offer good learning opportunities\n\nReturn as JSON array: [\"skill1\", \"skill2\", \"skill3\", \"skill4\", \"skill5\"]`;\n\n const completion = await openai.chat.completions.create({\n messages: [{ role: \"user\", content: prompt }],\n model: \"gpt-4o-mini\",\n max_tokens: 100,\n temperature: 0.8\n });\n\n const aiResponse = completion.choices[0]?.message?.content;\n let recommendations;\n \n try {\n recommendations = JSON.parse(aiResponse || '[]');\n } catch {\n // Fallback recommendations\n recommendations = [\n \"Communication Skills\",\n \"Time Management\", \n \"Critical Thinking\",\n \"Digital Marketing\",\n \"Data Analysis\"\n ];\n }\n\n return c.json>({ \n success: true, \n data: recommendations \n });\n\n } catch (error) {\n console.error(\"Error getting recommendations:\", error);\n return c.json({ \n success: false, \n error: \"Failed to get recommendations\" \n }, 500);\n }\n});\n\nexport default matching;",[],[153,231,257],"aad010e8-3fa5-11f0-b9d5-76b3cceeab13","community.ts","aad011b0-3fa5-11f0-b9d5-76b3cceeab13",9,["D",1748864121630],"import { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { \n createCommunityPost, \n getCommunityPosts, \n createCommunityComment, \n getPostComments,\n likePost \n} from \"../database/queries.ts\";\nimport type { CommunityPost, CommunityComment, ApiResponse } from \"../../shared/types.ts\";\n\nconst community = new Hono();\n\n// Create a new community post\ncommunity.post(\"/posts\", async (c) => {\n try {\n const postData = await c.req.json();\n \n // Validate required fields\n if (!postData.user_id || !postData.user_name || !postData.title || !postData.content) {\n return c.json({ \n success: false, \n error: \"user_id, user_name, title, and content are required\" \n }, 400);\n }\n\n // Validate post type\n const validTypes = ['question', 'success_story', 'tip', 'general'];\n if (postData.type && !validTypes.includes(postData.type)) {\n return c.json({ \n success: false, \n error: `Type must be one of: ${validTypes.join(', ')}` \n }, 400);\n }\n\n const post = await createCommunityPost({\n user_id: postData.user_id,\n user_name: postData.user_name,\n title: postData.title.trim(),\n content: postData.content.trim(),\n type: postData.type || 'general',\n skill_tags: postData.skill_tags || []\n });\n\n return c.json>({ \n success: true, \n data: post \n });\n } catch (error) {\n console.error(\"Error creating community post:\", error);\n return c.json({ \n success: false, \n error: \"Failed to create post\" \n }, 500);\n }\n});\n\n// Get community posts with pagination and filtering\ncommunity.get(\"/posts\", async (c) => {\n try {\n const type = c.req.query(\"type\");\n const limit = parseInt(c.req.query(\"limit\") || \"20\");\n const offset = parseInt(c.req.query(\"offset\") || \"0\");\n\n // Validate limit and offset\n if (limit < 1 || limit > 100) {\n return c.json({ \n success: false, \n error: \"Limit must be between 1 and 100\" \n }, 400);\n }\n\n if (offset < 0) {\n return c.json({ \n success: false, \n error: \"Offset must be non-negative\" \n }, 400);\n }\n\n // Validate type if provided\n const validTypes = ['question', 'success_story', 'tip', 'general'];\n if (type && !validTypes.includes(type)) {\n return c.json({ \n success: false, \n error: `Type must be one of: ${validTypes.join(', ')}` \n }, 400);\n }\n\n const posts = await getCommunityPosts(type, limit, offset);\n\n return c.json>({ \n success: true, \n data: posts \n });\n } catch (error) {\n console.error(\"Error fetching community posts:\", error);\n return c.json({ \n success: false, \n error: \"Failed to fetch posts\" \n }, 500);\n }\n});\n\n// Get comments for a specific post\ncommunity.get(\"/posts/:postId/comments\", async (c) => {\n try {\n const postId = parseInt(c.req.param(\"postId\"));\n if (isNaN(postId)) {\n return c.json({ \n success: false, \n error: \"Invalid post ID\" \n }, 400);\n }\n\n const comments = await getPostComments(postId);\n\n return c.json>({ \n success: true, \n data: comments \n });\n } catch (error) {\n console.error(\"Error fetching comments:\", error);\n return c.json({ \n success: false, \n error: \"Failed to fetch comments\" \n }, 500);\n }\n});\n\n// Create a comment on a post\ncommunity.post(\"/posts/:postId/comments\", async (c) => {\n try {\n const postId = parseInt(c.req.param(\"postId\"));\n if (isNaN(postId)) {\n return c.json({ \n success: false, \n error: \"Invalid post ID\" \n }, 400);\n }\n\n const commentData = await c.req.json();\n \n // Validate required fields\n if (!commentData.user_id || !commentData.user_name || !commentData.content) {\n return c.json({ \n success: false, \n error: \"user_id, user_name, and content are required\" \n }, 400);\n }\n\n const comment = await createCommunityComment({\n post_id: postId,\n user_id: commentData.user_id,\n user_name: commentData.user_name,\n content: commentData.content.trim()\n });\n\n return c.json>({ \n success: true, \n data: comment \n });\n } catch (error) {\n console.error(\"Error creating comment:\", error);\n return c.json({ \n success: false, \n error: \"Failed to create comment\" \n }, 500);\n }\n});\n\n// Like a post\ncommunity.post(\"/posts/:postId/like\", async (c) => {\n try {\n const postId = parseInt(c.req.param(\"postId\"));\n if (isNaN(postId)) {\n return c.json({ \n success: false, \n error: \"Invalid post ID\" \n }, 400);\n }\n\n const success = await likePost(postId);\n if (!success) {\n return c.json({ \n success: false, \n error: \"Post not found\" \n }, 404);\n }\n\n return c.json({ \n success: true \n });\n } catch (error) {\n console.error(\"Error liking post:\", error);\n return c.json({ \n success: false, \n error: \"Failed to like post\" \n }, 500);\n }\n});\n\n// Get trending topics/skills\ncommunity.get(\"/trending\", async (c) => {\n try {\n // In a real app, this would analyze post content and skill tags\n // For now, we'll return mock trending data\n const trendingTopics = [\n { name: \"JavaScript\", posts: 45, growth: \"+12%\" },\n { name: \"Remote Work Tips\", posts: 38, growth: \"+8%\" },\n { name: \"Language Learning\", posts: 32, growth: \"+15%\" },\n { name: \"Photography\", posts: 28, growth: \"+5%\" },\n { name: \"Cooking\", posts: 25, growth: \"+20%\" },\n { name: \"Data Science\", posts: 22, growth: \"+10%\" },\n { name: \"Guitar\", posts: 20, growth: \"+7%\" },\n { name: \"Public Speaking\", posts: 18, growth: \"+25%\" }\n ];\n\n return c.json({ \n success: true, \n data: trendingTopics \n });\n } catch (error) {\n console.error(\"Error fetching trending topics:\", error);\n return c.json({ \n success: false, \n error: \"Failed to fetch trending topics\" \n }, 500);\n }\n});\n\n// Get community statistics\ncommunity.get(\"/stats\", async (c) => {\n try {\n // In a real app, these would be calculated from the database\n const stats = {\n totalPosts: 1247,\n totalComments: 3891,\n activeUsers: 342,\n questionsAnswered: 89,\n successStories: 156,\n tipsShared: 203,\n topContributors: [\n { name: \"Sarah Chen\", posts: 23, helpful_votes: 145 },\n { name: \"Mike Rodriguez\", posts: 19, helpful_votes: 132 },\n { name: \"Emma Thompson\", posts: 17, helpful_votes: 98 },\n { name: \"David Kim\", posts: 15, helpful_votes: 87 },\n { name: \"Lisa Johnson\", posts: 14, helpful_votes: 76 }\n ]\n };\n\n return c.json({ \n success: true, \n data: stats \n });\n } catch (error) {\n console.error(\"Error fetching community stats:\", error);\n return c.json({ \n success: false, \n error: \"Failed to fetch community statistics\" \n }, 500);\n }\n});\n\n// Search posts by content or skill tags\ncommunity.get(\"/search\", async (c) => {\n try {\n const query = c.req.query(\"q\");\n const type = c.req.query(\"type\");\n \n if (!query || query.trim().length < 2) {\n return c.json({ \n success: false, \n error: \"Search query must be at least 2 characters\" \n }, 400);\n }\n\n // In a real app, this would use full-text search\n // For now, we'll return a simple response\n const searchResults = [\n {\n id: 1,\n title: \"How to get started with JavaScript?\",\n content: \"I'm new to programming and want to learn JavaScript...\",\n type: \"question\",\n user_name: \"John Doe\",\n skill_tags: [\"JavaScript\", \"Programming\"],\n likes: 12,\n created_at: new Date().toISOString()\n }\n ];\n\n return c.json({ \n success: true, \n data: searchResults \n });\n } catch (error) {\n console.error(\"Error searching posts:\", error);\n return c.json({ \n success: false, \n error: \"Failed to search posts\" \n }, 500);\n }\n});\n\nexport default community;",[],[153,231,265],"54fa9c1a-3fa5-11f0-b48c-76b3cceeab13",["D",1748863977620],[173,174,175,176,177,178],[153,231],"4b1812a4-3fa5-11f0-ad43-76b3cceeab13","queries.ts","9569732a-62bc-445b-9421-9ed3e3701759",4,["D",1748863961043],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport type { User, Skill, SkillMatch, Session, Progress, CommunityPost, CommunityComment } from \"../../shared/types.ts\";\n\n// User operations\nexport async function createUser(userData: Omit): Promise {\n const result = await sqlite.execute(\n `INSERT INTO users_v1 (name, email, bio, avatar_url, timezone) \n VALUES (?, ?, ?, ?, ?) RETURNING *`,\n [userData.name, userData.email, userData.bio, userData.avatar_url || null, userData.timezone]\n );\n return result[0] as User;\n}\n\nexport async function getUserById(id: number): Promise {\n const result = await sqlite.execute(`SELECT * FROM users_v1 WHERE id = ?`, [id]);\n return result[0] as User || null;\n}\n\nexport async function getUserByEmail(email: string): Promise {\n const result = await sqlite.execute(`SELECT * FROM users_v1 WHERE email = ?`, [email]);\n return result[0] as User || null;\n}\n\nexport async function updateUser(id: number, updates: Partial): Promise {\n const fields = Object.keys(updates).filter(key => key !== 'id' && key !== 'created_at');\n const values = fields.map(field => updates[field as keyof User]);\n const setClause = fields.map(field => `${field} = ?`).join(', ');\n \n const result = await sqlite.execute(\n `UPDATE users_v1 SET ${setClause} WHERE id = ? RETURNING *`,\n [...values, id]\n );\n return result[0] as User || null;\n}\n\n// Skill operations\nexport async function createSkill(skillData: Omit): Promise {\n const result = await sqlite.execute(\n `INSERT INTO skills_v1 (user_id, name, category, type, proficiency_level, description) \n VALUES (?, ?, ?, ?, ?, ?) RETURNING *`,\n [skillData.user_id, skillData.name, skillData.category, skillData.type, \n skillData.proficiency_level || null, skillData.description]\n );\n return result[0] as Skill;\n}\n\nexport async function getUserSkills(userId: number, type?: 'teach' | 'learn'): Promise {\n const query = type \n ? `SELECT * FROM skills_v1 WHERE user_id = ? AND type = ? ORDER BY created_at DESC`\n : `SELECT * FROM skills_v1 WHERE user_id = ? ORDER BY created_at DESC`;\n const params = type ? [userId, type] : [userId];\n \n const result = await sqlite.execute(query, params);\n return result as Skill[];\n}\n\nexport async function getSkillsByName(skillName: string, type: 'teach' | 'learn'): Promise {\n const result = await sqlite.execute(\n `SELECT s.*, u.name as user_name, u.rating as user_rating \n FROM skills_v1 s \n JOIN users_v1 u ON s.user_id = u.id \n WHERE s.name LIKE ? AND s.type = ? \n ORDER BY u.rating DESC`,\n [`%${skillName}%`, type]\n );\n return result as Skill[];\n}\n\nexport async function deleteSkill(id: number, userId: number): Promise {\n const result = await sqlite.execute(\n `DELETE FROM skills_v1 WHERE id = ? AND user_id = ?`,\n [id, userId]\n );\n return result.changes > 0;\n}\n\n// Skill match operations\nexport async function createSkillMatch(matchData: Omit): Promise {\n const result = await sqlite.execute(\n `INSERT INTO skill_matches_v1 (learner_id, teacher_id, skill_name, compatibility_score, ai_reasoning, status) \n VALUES (?, ?, ?, ?, ?, ?) RETURNING *`,\n [matchData.learner_id, matchData.teacher_id, matchData.skill_name, \n matchData.compatibility_score, matchData.ai_reasoning, matchData.status]\n );\n return result[0] as SkillMatch;\n}\n\nexport async function getMatchesForUser(userId: number, status?: string): Promise {\n const query = status\n ? `SELECT m.*, \n l.name as learner_name, l.email as learner_email,\n t.name as teacher_name, t.email as teacher_email\n FROM skill_matches_v1 m\n JOIN users_v1 l ON m.learner_id = l.id\n JOIN users_v1 t ON m.teacher_id = t.id\n WHERE (m.learner_id = ? OR m.teacher_id = ?) AND m.status = ?\n ORDER BY m.created_at DESC`\n : `SELECT m.*, \n l.name as learner_name, l.email as learner_email,\n t.name as teacher_name, t.email as teacher_email\n FROM skill_matches_v1 m\n JOIN users_v1 l ON m.learner_id = l.id\n JOIN users_v1 t ON m.teacher_id = t.id\n WHERE m.learner_id = ? OR m.teacher_id = ?\n ORDER BY m.created_at DESC`;\n \n const params = status ? [userId, userId, status] : [userId, userId];\n const result = await sqlite.execute(query, params);\n return result as SkillMatch[];\n}\n\nexport async function updateMatchStatus(id: number, status: string): Promise {\n const result = await sqlite.execute(\n `UPDATE skill_matches_v1 SET status = ? WHERE id = ? RETURNING *`,\n [status, id]\n );\n return result[0] as SkillMatch || null;\n}\n\n// Session operations\nexport async function createSession(sessionData: Omit): Promise {\n const result = await sqlite.execute(\n `INSERT INTO sessions_v1 (match_id, learner_id, teacher_id, skill_name, scheduled_at, duration_minutes, meeting_link, notes) \n VALUES (?, ?, ?, ?, ?, ?, ?, ?) RETURNING *`,\n [sessionData.match_id, sessionData.learner_id, sessionData.teacher_id, sessionData.skill_name,\n sessionData.scheduled_at, sessionData.duration_minutes, sessionData.meeting_link || null, sessionData.notes || null]\n );\n return result[0] as Session;\n}\n\nexport async function getUserSessions(userId: number, status?: string): Promise {\n const query = status\n ? `SELECT s.*, \n l.name as learner_name, t.name as teacher_name\n FROM sessions_v1 s\n JOIN users_v1 l ON s.learner_id = l.id\n JOIN users_v1 t ON s.teacher_id = t.id\n WHERE (s.learner_id = ? OR s.teacher_id = ?) AND s.status = ?\n ORDER BY s.scheduled_at ASC`\n : `SELECT s.*, \n l.name as learner_name, t.name as teacher_name\n FROM sessions_v1 s\n JOIN users_v1 l ON s.learner_id = l.id\n JOIN users_v1 t ON s.teacher_id = t.id\n WHERE s.learner_id = ? OR s.teacher_id = ?\n ORDER BY s.scheduled_at ASC`;\n \n const params = status ? [userId, userId, status] : [userId, userId];\n const result = await sqlite.execute(query, params);\n return result as Session[];\n}\n\nexport async function updateSession(id: number, updates: Partial): Promise {\n const fields = Object.keys(updates).filter(key => key !== 'id' && key !== 'created_at');\n const values = fields.map(field => updates[field as keyof Session]);\n const setClause = fields.map(field => `${field} = ?`).join(', ');\n \n const result = await sqlite.execute(\n `UPDATE sessions_v1 SET ${setClause} WHERE id = ? RETURNING *`,\n [...values, id]\n );\n return result[0] as Session || null;\n}\n\n// Progress operations\nexport async function upsertProgress(progressData: Omit): Promise {\n const result = await sqlite.execute(\n `INSERT INTO progress_v1 (user_id, skill_name, current_level, sessions_completed, milestones_achieved, notes)\n VALUES (?, ?, ?, ?, ?, ?)\n ON CONFLICT(user_id, skill_name) DO UPDATE SET\n current_level = excluded.current_level,\n sessions_completed = excluded.sessions_completed,\n milestones_achieved = excluded.milestones_achieved,\n notes = excluded.notes,\n updated_at = CURRENT_TIMESTAMP\n RETURNING *`,\n [progressData.user_id, progressData.skill_name, progressData.current_level,\n progressData.sessions_completed, JSON.stringify(progressData.milestones_achieved), progressData.notes]\n );\n return result[0] as Progress;\n}\n\nexport async function getUserProgress(userId: number): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM progress_v1 WHERE user_id = ? ORDER BY updated_at DESC`,\n [userId]\n );\n return result.map(row => ({\n ...row,\n milestones_achieved: JSON.parse(row.milestones_achieved)\n })) as Progress[];\n}\n\n// Community operations\nexport async function createCommunityPost(postData: Omit): Promise {\n const result = await sqlite.execute(\n `INSERT INTO community_posts_v1 (user_id, user_name, title, content, type, skill_tags) \n VALUES (?, ?, ?, ?, ?, ?) RETURNING *`,\n [postData.user_id, postData.user_name, postData.title, postData.content, \n postData.type, JSON.stringify(postData.skill_tags)]\n );\n return {\n ...result[0],\n skill_tags: JSON.parse(result[0].skill_tags)\n } as CommunityPost;\n}\n\nexport async function getCommunityPosts(type?: string, limit: number = 20, offset: number = 0): Promise {\n const query = type\n ? `SELECT * FROM community_posts_v1 WHERE type = ? ORDER BY created_at DESC LIMIT ? OFFSET ?`\n : `SELECT * FROM community_posts_v1 ORDER BY created_at DESC LIMIT ? OFFSET ?`;\n \n const params = type ? [type, limit, offset] : [limit, offset];\n const result = await sqlite.execute(query, params);\n \n return result.map(row => ({\n ...row,\n skill_tags: JSON.parse(row.skill_tags)\n })) as CommunityPost[];\n}\n\nexport async function createCommunityComment(commentData: Omit): Promise {\n const result = await sqlite.execute(\n `INSERT INTO community_comments_v1 (post_id, user_id, user_name, content) \n VALUES (?, ?, ?, ?) RETURNING *`,\n [commentData.post_id, commentData.user_id, commentData.user_name, commentData.content]\n );\n return result[0] as CommunityComment;\n}\n\nexport async function getPostComments(postId: number): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM community_comments_v1 WHERE post_id = ? ORDER BY created_at ASC`,\n [postId]\n );\n return result as CommunityComment[];\n}\n\nexport async function likePost(postId: number): Promise {\n const result = await sqlite.execute(\n `UPDATE community_posts_v1 SET likes = likes + 1 WHERE id = ?`,\n [postId]\n );\n return result.changes > 0;\n}",[],[153,284,277],"database","32eebf98-3fa5-11f0-8de5-76b3cceeab13","migrations.ts","32eec06a-3fa5-11f0-8de5-76b3cceeab13",["D",1748863920489],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n\n// Database schema for SkillSwap AI\n// Change table names when modifying schemas (add _2, _3, etc.)\n\nexport async function runMigrations() {\n // Users table\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS users_v1 (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT NOT NULL,\n email TEXT UNIQUE NOT NULL,\n bio TEXT DEFAULT '',\n avatar_url TEXT,\n timezone TEXT DEFAULT 'UTC',\n rating REAL DEFAULT 0.0,\n total_sessions INTEGER DEFAULT 0,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP\n )\n `);\n\n // Skills table - tracks both skills users can teach and want to learn\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS skills_v1 (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n user_id INTEGER NOT NULL,\n name TEXT NOT NULL,\n category TEXT NOT NULL,\n type TEXT NOT NULL CHECK (type IN ('teach', 'learn')),\n proficiency_level TEXT CHECK (proficiency_level IN ('beginner', 'intermediate', 'advanced', 'expert')),\n description TEXT DEFAULT '',\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n FOREIGN KEY (user_id) REFERENCES users_v1 (id)\n )\n `);\n\n // Skill matches - AI-generated matches between learners and teachers\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS skill_matches_v1 (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n learner_id INTEGER NOT NULL,\n teacher_id INTEGER NOT NULL,\n skill_name TEXT NOT NULL,\n compatibility_score REAL NOT NULL,\n ai_reasoning TEXT NOT NULL,\n status TEXT DEFAULT 'pending' CHECK (status IN ('pending', 'accepted', 'declined', 'completed')),\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n FOREIGN KEY (learner_id) REFERENCES users_v1 (id),\n FOREIGN KEY (teacher_id) REFERENCES users_v1 (id)\n )\n `);\n\n // Sessions - scheduled learning sessions\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS sessions_v1 (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n match_id INTEGER NOT NULL,\n learner_id INTEGER NOT NULL,\n teacher_id INTEGER NOT NULL,\n skill_name TEXT NOT NULL,\n scheduled_at DATETIME NOT NULL,\n duration_minutes INTEGER DEFAULT 60,\n status TEXT DEFAULT 'scheduled' CHECK (status IN ('scheduled', 'completed', 'cancelled', 'no_show')),\n meeting_link TEXT,\n notes TEXT,\n learner_rating INTEGER CHECK (learner_rating BETWEEN 1 AND 5),\n teacher_rating INTEGER CHECK (teacher_rating BETWEEN 1 AND 5),\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n FOREIGN KEY (match_id) REFERENCES skill_matches_v1 (id),\n FOREIGN KEY (learner_id) REFERENCES users_v1 (id),\n FOREIGN KEY (teacher_id) REFERENCES users_v1 (id)\n )\n `);\n\n // Progress tracking\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS progress_v1 (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n user_id INTEGER NOT NULL,\n skill_name TEXT NOT NULL,\n current_level TEXT DEFAULT 'beginner' CHECK (current_level IN ('beginner', 'intermediate', 'advanced', 'expert')),\n sessions_completed INTEGER DEFAULT 0,\n milestones_achieved TEXT DEFAULT '[]', -- JSON array of milestone strings\n notes TEXT DEFAULT '',\n updated_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n FOREIGN KEY (user_id) REFERENCES users_v1 (id),\n UNIQUE(user_id, skill_name)\n )\n `);\n\n // Community posts\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS community_posts_v1 (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n user_id INTEGER NOT NULL,\n user_name TEXT NOT NULL,\n title TEXT NOT NULL,\n content TEXT NOT NULL,\n type TEXT DEFAULT 'general' CHECK (type IN ('question', 'success_story', 'tip', 'general')),\n skill_tags TEXT DEFAULT '[]', -- JSON array of skill tags\n likes INTEGER DEFAULT 0,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n FOREIGN KEY (user_id) REFERENCES users_v1 (id)\n )\n `);\n\n // Community comments\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS community_comments_v1 (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n post_id INTEGER NOT NULL,\n user_id INTEGER NOT NULL,\n user_name TEXT NOT NULL,\n content TEXT NOT NULL,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n FOREIGN KEY (post_id) REFERENCES community_posts_v1 (id),\n FOREIGN KEY (user_id) REFERENCES users_v1 (id)\n )\n `);\n\n // Create indexes for better performance\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_skills_user_type ON skills_v1 (user_id, type)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_skills_name_type ON skills_v1 (name, type)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_matches_status ON skill_matches_v1 (status)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_sessions_scheduled ON sessions_v1 (scheduled_at)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_posts_type ON community_posts_v1 (type, created_at DESC)`);\n\n console.log(\"Database migrations completed successfully\");\n}",[],[153,284,286],"32eed5a0-3fa5-11f0-8de5-76b3cceeab13",["D",1748863920489],[170,171],[153,284],["D",1748863920489],[169,172,179],[153],["D",1748863817576],{"_95":94,"_102":98},{"_95":94,"_96":-5,"_97":98,"_18":53,"_99":100,"_101":24},{"_13":84,"_31":85,"_42":41,"_86":43,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":44,"_93":94},"ctx",{"_77":-5,"_122":336,"_337":338,"_339":340,"_341":24,"_342":24,"_343":24,"_344":57,"_345":-5,"_346":-7,"_347":-7,"_348":135,"_349":24,"_350":24,"_351":-5,"_352":24,"_353":24,"_354":24,"_355":-5},"ENV",{"_307":308,"_309":310,"_311":85,"_312":313,"_314":315,"_316":317,"_318":319,"_320":321,"_322":323,"_324":325,"_326":327,"_328":329,"_330":331,"_332":333,"_334":335},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","a3e067d4463eea85f6334f8e583e8516ae58c4f6","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 · v13