Welcome to MCP Cognitive Tools!

Thank you for registering. Please click the link below to verify your email address and get your access token:

Verify Email Address

Or copy and paste this link into your browser:

${verificationUrl}

This link will expire in 24 hours.

If you didn't request this verification, please ignore this email.

\n `,\n text: `\nWelcome to MCP Cognitive Tools!\n\nThank you for registering. Please visit the following link to verify your email address and get your access token:\n\n${verificationUrl}\n\nThis link will expire in 24 hours.\n\nIf you didn't request this verification, please ignore this email.\n `\n });\n\n return {\n success: true,\n message: \"Registration initiated. Please check your email for verification instructions.\",\n email: userEmail,\n verificationSent: true\n };\n } catch (error) {\n console.error(\"Failed to send verification email:\", error);\n throw new Error(\"Failed to send verification email. Please try again later.\");\n }\n}\n\nasync function verifyEmail(args: { verificationToken: string }): Promise {\n const { verificationToken } = args;\n\n if (!verificationToken) {\n throw new Error(\"Verification token is required\");\n }\n\n // Get verification record\n const verification = await getEmailVerificationByToken(verificationToken);\n if (!verification) {\n throw new Error(\"Invalid or expired verification token\");\n }\n\n // Check if token is expired\n if (new Date(verification.expiresAt) < new Date()) {\n throw new Error(\"Verification token has expired. Please request a new verification email.\");\n }\n\n // Get user by email\n const user = await getUserByEmail(verification.email);\n if (!user) {\n throw new Error(\"User not found\");\n }\n\n // Mark user as verified\n await updateUserVerification(user.id, true);\n \n // Mark verification as used\n await markEmailVerificationAsUsed(verificationToken);\n\n return {\n success: true,\n message: \"Email verified successfully! You can now use your access token.\",\n accessToken: user.accessToken,\n email: user.email,\n userId: user.id\n };\n}\n\nasync function resendVerification(args: { email: string }): Promise {\n const { email: userEmail } = args;\n\n if (!userEmail || !isValidEmail(userEmail)) {\n throw new Error(\"Valid email address is required\");\n }\n\n // Check if user exists\n const user = await getUserByEmail(userEmail);\n if (!user) {\n throw new Error(\"No user found with this email address\");\n }\n\n if (user.isVerified) {\n throw new Error(\"User is already verified\");\n }\n\n return await createVerificationAndSendEmail(userEmail, user.id);\n}\n\nfunction isValidEmail(email: string): boolean {\n const emailRegex = /^[^\\s@]+@[^\\s@]+\\.[^\\s@]+$/;\n return emailRegex.test(email);\n}",[],[155,209,215,284],[155,209,215],{"_103":293,"_95":294,"_156":295,"_158":210,"_159":138,"_160":296,"_161":162,"_105":297,"_100":298,"_164":184,"_166":299,"_167":22,"_168":-5,"_169":300,"_98":301},"58ecf5a0-4533-11f0-8a4b-76b3cceeab13","auth.ts","32241a1e-3e63-4ab7-816c-124f12a2dc13",158,["D",1749474728591],3,"import type { Context } from \"https://esm.sh/hono@3.11.7\";\nimport type { User } from \"../../shared/types.ts\";\nimport { getUserByAccessToken } from \"../database/user-queries.ts\";\n\nexport interface AuthContext {\n isAdmin: boolean;\n user?: User;\n}\n\nexport async function validateAuth(c: Context): Promise {\n const authHeader = c.req.header(\"Authorization\");\n console.log(`[MCP Auth] requested auth: ${!!authHeader}`);\n if (!authHeader) {\n return null;\n }\n\n // Support both \"Bearer token\" and just \"token\" formats\n const token = authHeader.startsWith(\"Bearer \")\n ? authHeader.slice(7)\n : authHeader;\n\n // Check if it's the admin token\n const adminToken = Deno.env.get(\"MCP_AUTH_TOKEN\");\n if (adminToken && token === adminToken) {\n console.log(`[MCP Auth] Is admin.`);\n return { isAdmin: true };\n }\n\n // Check if it's a user token\n try {\n console.log(`[MCP Auth] Getting user for token`);\n const user = await getUserByAccessToken(token);\n if (user && user.isVerified) {\n return { isAdmin: false, user };\n }\n } catch (error) {\n console.warn(\"Error validating user token:\", error);\n }\n\n return null;\n}\n\nexport function requireAuth() {\n return async (c: Context, next: () => Promise) => {\n const authContext = await validateAuth(c);\n\n if (!authContext) {\n return c.json({\n jsonrpc: \"2.0\",\n id: null,\n error: {\n code: -32001,\n message: \"Unauthorized: Invalid or missing authentication token\",\n },\n }, 401);\n }\n\n // Store auth context for use in handlers\n c.set(\"authContext\", authContext);\n\n await next();\n };\n}\n\nexport function requireUserAuth() {\n return async (c: Context, next: () => Promise) => {\n const authContext = await validateAuth(c);\n\n if (!authContext || (!authContext.isAdmin && !authContext.user)) {\n return c.json({\n jsonrpc: \"2.0\",\n id: null,\n error: {\n code: -32001,\n message: \"Unauthorized: Valid user token required\",\n },\n }, 401);\n }\n\n // Store auth context for use in handlers\n c.set(\"authContext\", authContext);\n\n await next();\n };\n}\n\nexport function getAuthContext(c: Context): AuthContext | null {\n return c.get(\"authContext\") || null;\n}",[],[155,209,294],{"_103":303,"_95":304,"_156":305,"_158":210,"_159":138,"_160":306,"_161":162,"_105":307,"_100":308,"_164":184,"_166":309,"_167":22,"_168":-5,"_169":310,"_98":311},"3c15efb6-4530-11f0-a384-76b3cceeab13","server.ts","445cbf12-a201-4a93-84b3-35ae889dcab9",154,["D",1749473391715],49,"import type { MCPRequest, MCPResponse, MCPTool } from \"../../shared/types.ts\";\nimport type { AuthContext } from \"./auth.ts\";\nimport { blobTools, handleBlobTool } from \"./tools/blob.ts\";\nimport { forkThoughtTools, handleForkThoughtTool } from \"./tools/fork-thought.ts\";\nimport { goalTools, handleGoalTool } from \"./tools/goals.ts\";\nimport { getDynamicSkillTools, handleDynamicSkillTool, handleSkillTool, skillTools } from \"./tools/skills.ts\";\nimport { handleSqliteTool, sqliteTools } from \"./tools/sqlite.ts\";\nimport { handleStateTool, stateTools } from \"./tools/states.ts\";\nimport { handleTaskTool, taskTools } from \"./tools/tasks.ts\";\nimport { handleUserRegistrationTool, userRegistrationTools } from \"./tools/user-registration.ts\";\n\n// Valid MCP notification methods\nconst VALID_NOTIFICATIONS = [\n \"notifications/initialized\",\n \"notifications/progress\",\n \"notifications/resources/updated\",\n \"notifications/resources/list/changed\",\n \"notifications/tools/list/changed\",\n \"notifications/prompts/list/changed\",\n];\n\nexport class MCPCognitiveServer {\n private tools: MCPTool[] = [];\n private authRequiredTools: MCPTool[] = [];\n private initialized: boolean = false;\n\n constructor() {\n // User registration tools (no auth required)\n this.tools = [\n ...userRegistrationTools,\n ];\n\n // Core cognitive tools (auth required)\n this.authRequiredTools = [\n ...blobTools,\n // ...forkThoughtTools, // TODO: needs rethinking\n ...goalTools,\n ...taskTools,\n // ...stateTools, // TODO: needs rethinking\n ...skillTools,\n ...sqliteTools,\n ];\n\n this.initialized = true;\n console.log(`[MCP Server] Initlized with ${this.tools.length + this.authRequiredTools.length} tools`);\n }\n\n private async getDynamicToolsForUser(userId?: string | null): Promise {\n // Add dynamic skill tools\n try {\n const dynamicTools = await getDynamicSkillTools(userId);\n return dynamicTools;\n } catch (error) {\n console.warn(\"Failed to load dynamic skill tools:\", error.message);\n return [];\n }\n }\n\n async handleRequest(request: MCPRequest, authContext?: AuthContext): Promise {\n try {\n // Handle notifications\n if (request.method?.startsWith(\"notifications/\")) {\n if (VALID_NOTIFICATIONS.includes(request.method)) {\n return {\n jsonrpc: \"2.0\",\n id: request.id,\n result: {},\n };\n } else {\n return {\n jsonrpc: \"2.0\",\n id: request.id,\n error: {\n code: -32601,\n message: `Unknown notification method: ${request.method}`,\n },\n };\n }\n }\n\n switch (request.method) {\n case \"initialize\":\n return this.handleInitialize(request);\n\n case \"tools/list\":\n return this.handleListTools(request, authContext);\n\n case \"tools/call\":\n return await this.handleToolCall(request, authContext);\n\n case \"prompts/list\":\n return await this.handleListPrompts(request, authContext);\n\n case \"prompts/get\":\n return await this.handleGetPrompt(request, authContext);\n\n default:\n return {\n jsonrpc: \"2.0\",\n id: request.id,\n error: {\n code: -32601,\n message: `Method not found: ${request.method}`,\n },\n };\n }\n } catch (error) {\n console.error(error);\n return {\n jsonrpc: \"2.0\",\n id: request.id,\n error: {\n code: -32603,\n message: \"Internal error\",\n data: error.message,\n },\n };\n }\n }\n\n private handleInitialize(request: MCPRequest): MCPResponse {\n console.log(\"[MCP Server] Initialize request received\");\n return {\n jsonrpc: \"2.0\",\n id: request.id,\n result: {\n protocolVersion: \"2024-11-05\",\n capabilities: {\n tools: {},\n prompts: {},\n },\n serverInfo: {\n name: \"Contextual MCP Cognitive Tools Server\",\n version: \"1.0.0\",\n description: \"Cognitive tools for thought processes, goal tracking, and dynamic skill creation\",\n },\n },\n };\n }\n\n private async handleListTools(request: MCPRequest, authContext?: AuthContext): Promise {\n let availableTools = [];\n\n // Add auth-required tools if authenticated\n if (authContext) {\n const userId = authContext.isAdmin ? null : authContext.user?.id;\n const dynamicTools = []; // await this.getDynamicToolsForUser(userId);\n availableTools.push(...this.authRequiredTools, ...dynamicTools);\n } else {\n availableTools.push(...this.tools); // Always include registration tools\n }\n\n return {\n jsonrpc: \"2.0\",\n id: request.id,\n result: {\n tools: availableTools,\n },\n };\n }\n\n private async handleListPrompts(request: MCPRequest, authContext?: AuthContext): Promise {\n let prompts = [];\n if (!authContext) {\n prompts.push({\n name: \"register\",\n description: \"Register your user account\",\n arguments: [\n {\n name: \"username\",\n description: \"Your desired username\",\n required: true,\n },\n {\n name: \"email\",\n description: \"Your email address\",\n required: true,\n },\n {\n name: \"password\",\n description: \"Your password\",\n required: true,\n },\n ],\n });\n } else {\n prompts.push({\n name: \"server-test\",\n description: \"Test system functionality\",\n arguments: [\n {\n name: \"test_type\",\n description: \"Type of test to run (connectivity, auth, tools)\",\n required: false,\n },\n ],\n });\n }\n return {\n jsonrpc: \"2.0\",\n id: request.id,\n result: {\n prompts: prompts,\n },\n };\n }\n\n private async handleGetPrompt(request: MCPRequest, authContext?: AuthContext): Promise {\n const { name, arguments: promptArgs } = request.params || {};\n\n if (!name) {\n return {\n jsonrpc: \"2.0\",\n id: request.id,\n error: {\n code: -32602,\n message: \"Invalid params: missing prompt name\",\n },\n };\n }\n\n let promptContent = \"\";\n\n if (name === \"register\" && !authContext) {\n const username = promptArgs?.username || \"[username]\";\n const email = promptArgs?.email || \"[email]\";\n promptContent = `Please register the user with:\n- Username: ${username}\n- Email: ${email}\n- Password: [hidden]\n\nUse the register_user tool to complete the registration.`;\n } else if (name === \"server-test\" && authContext) {\n const testType = promptArgs?.test_type || \"all\";\n promptContent = `Running server test: ${testType}\n\nAvailable test types:\n- connectivity: Check server connection\n- auth: Verify authentication status\n- tools: List available tools\n\nCurrent auth status: ${authContext.isAdmin ? \"Admin\" : \"User\"} (${authContext.user?.username || \"Unknown\"})`;\n } else {\n return {\n jsonrpc: \"2.0\",\n id: request.id,\n error: {\n code: -32602,\n message: `Unknown prompt: ${name}`,\n },\n };\n }\n\n return {\n jsonrpc: \"2.0\",\n id: request.id,\n result: {\n messages: [\n {\n role: \"user\",\n content: {\n type: \"text\",\n text: promptContent,\n },\n },\n ],\n },\n };\n }\n\n private async handleToolCall(\n request: MCPRequest,\n authContext?: AuthContext,\n bypassJsonRpc: boolean = false,\n ): Promise {\n const { name: toolName, arguments: toolArgs } = request.params;\n\n if (!toolName) {\n return {\n jsonrpc: \"2.0\",\n id: request.id,\n error: {\n code: -32602,\n message: \"Missing tool name\",\n },\n };\n }\n\n try {\n let result: any;\n\n // Check if it's a registration tool (no auth required)\n if (userRegistrationTools.some(t => t.name === toolName)) {\n result = await handleUserRegistrationTool(toolName, toolArgs);\n } else {\n // All other tools require authentication\n if (!authContext) {\n return {\n jsonrpc: \"2.0\",\n id: request.id,\n error: {\n code: -32000, // Using standard server error range\n message: \"Authentication required for this tool\",\n },\n };\n }\n\n // Route to appropriate tool handler with auth context\n if (blobTools.some(t => t.name === toolName)) {\n result = await handleBlobTool(toolName, toolArgs, authContext);\n } else if (forkThoughtTools.some(t => t.name === toolName)) {\n result = await handleForkThoughtTool(toolName, toolArgs, authContext);\n } else if (goalTools.some(t => t.name === toolName)) {\n result = await handleGoalTool(toolName, toolArgs, authContext);\n } else if (taskTools.some(t => t.name === toolName)) {\n result = await handleTaskTool(toolName, toolArgs, authContext);\n } else if (stateTools.some(t => t.name === toolName)) {\n result = await handleStateTool(toolName, toolArgs, authContext);\n } else if (skillTools.some(t => t.name === toolName)) {\n result = await handleSkillTool(\n toolName,\n toolArgs,\n authContext,\n this.getAvailableTools(authContext),\n this.handleToolCall.bind(this),\n );\n } else if (sqliteTools.some(t => t.name === toolName)) {\n result = await handleSqliteTool(toolName, toolArgs, authContext);\n } else if (toolName.startsWith(\"skill_\")) {\n // Handle dynamic skill execution\n result = await handleDynamicSkillTool(\n toolName,\n toolArgs,\n authContext,\n this.getAvailableTools(authContext),\n this.handleToolCall.bind(this),\n );\n } else {\n return {\n jsonrpc: \"2.0\",\n id: request.id,\n error: {\n code: -32601,\n message: `Unknown tool: ${toolName}`,\n },\n };\n }\n }\n\n // Keep bypassJsonRpc as requested\n if (bypassJsonRpc) {\n return result;\n }\n\n return {\n jsonrpc: \"2.0\",\n id: request.id,\n result: {\n content: [\n {\n type: \"text\",\n text: JSON.stringify(result, null, 2),\n },\n ],\n },\n };\n } catch (error) {\n console.error(error);\n return {\n jsonrpc: \"2.0\",\n id: request.id,\n error: {\n code: -32603,\n message: error.message,\n },\n };\n }\n }\n\n getAvailableTools(authContext?: AuthContext): MCPTool[] {\n let availableTools: MCPTool[] = [];\n\n if (!authContext) {\n availableTools = [...this.tools]; // Always include registration tools\n }\n // Add auth-required tools if authenticated\n if (authContext) {\n availableTools.push(...this.authRequiredTools);\n // Note: Dynamic tools are loaded async, so this is a simplified view\n }\n\n return availableTools;\n }\n}",[],[155,209,304],[155,209],{"_103":314,"_95":315,"_156":316,"_158":157,"_159":138,"_160":317,"_161":162,"_105":318,"_100":319,"_164":320,"_166":321,"_167":22,"_168":-5,"_169":322,"_98":323},"9041df26-4532-11f0-a12f-76b3cceeab13","index.ts","1564b217-248f-4a97-a4d3-7bfe82cb8b19",156,["D",1749474391929],21,"http","import { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport type { MCPRequest } from \"../shared/types.ts\";\nimport { runMigrations } from \"./database/migrations.ts\";\nimport { getAuthContext, requireAuth, requireUserAuth, validateAuth } from \"./mcp/auth.ts\";\nimport { MCPCognitiveServer } from \"./mcp/server.ts\";\nimport { handleUserRegistrationTool } from \"./mcp/tools/user-registration.ts\";\n\nconst app = new Hono();\n\n// Unwrap Hono errors to see original error details\napp.onError((err, c) => {\n console.error(\"[ERROR\", err);\n throw err;\n});\n\n// // CORS headers (Val Town handles CORS automatically)\n// // -- 0. CORS pre-flight ------------------------------------------------------\n// app.options(\"/*\", (c) => {\n// c.header(\"Access-Control-Allow-Origin\", \"*\");\n// c.header(\"Access-Control-Allow-Methods\", \"GET, POST, PUT, DELETE, OPTIONS\");\n// // keep header names lowercase; some browsers are case-sensitive\n// c.header(\"Access-Control-Allow-Headers\", \"authorization, content-type\");\n// return c.text(\"\", 204);\n// });\n\n// Initialize database and MCP server\nlet mcpServer: MCPCognitiveServer;\n\nasync function initializeServer() {\n console.log(\"Initializing MCP Cognitive Tools Server...\");\n\n // Run database migrations\n // await runMigrations();\n\n // Initialize MCP server\n mcpServer = new MCPCognitiveServer();\n\n console.log(\"MCP Cognitive Tools Server initialized successfully\");\n}\n\n// Health check endpoint\napp.get(\"/health\", (c) => {\n return c.json({\n status: \"healthy\",\n timestamp: new Date().toISOString(),\n server: \"MCP Cognitive Tools Server\",\n version: \"1.0.0\",\n });\n});\n\n// Email verification endpoint\napp.get(\"/verify\", async (c) => {\n const token = c.req.query(\"token\");\n\n if (!token) {\n return c.html(`\n \n \n \n Email Verification - Error\n \n \n \n

🧠 MCP Cognitive Tools

Invalid Verification Link

The verification link is missing required parameters.

\n \n \n `);\n }\n\n try {\n const result = await handleUserRegistrationTool(\"verify_email\", { verificationToken: token });\n\n return c.html(`\n \n \n \n Email Verification - Success\n \n \n \n

🧠 MCP Cognitive Tools

✅ Email Verified Successfully!

Your email has been verified. Here is your access token:

${result.accessToken}

\n \n

Important: Save this token securely. You'll need it to access the MCP tools.

Email: ${result.email}

\n \n \n \n \n `);\n } catch (error) {\n return c.html(`\n \n \n \n Email Verification - Error\n \n \n \n

🧠 MCP Cognitive Tools

❌ Verification Failed

${error.message}

Please try registering again or contact support if the problem persists.

\n \n \n `);\n }\n});\n\n// Public registration endpoint (no auth required)\napp.post(\"/register\", async (c) => {\n try {\n const body = await c.req.json();\n const result = await handleUserRegistrationTool(\"register_user\", body);\n return c.json(result);\n } catch (error) {\n return c.json({\n success: false,\n error: error.message,\n }, 400);\n }\n});\n\n// Main MCP endpoint with conditional authentication\napp.post(\"/mcp\", async (c) => {\n // Initialize on startup\n await initializeServer();\n try {\n console.log(\"/mcp\");\n const request: MCPRequest = await c.req.json();\n console.log(\"POST /mcp\", request);\n // Validate MCP request structure\n if (!request.jsonrpc || request.jsonrpc !== \"2.0\") {\n return c.json({\n jsonrpc: \"2.0\",\n id: request.id || null,\n error: {\n code: -32600,\n message: \"Invalid Request: jsonrpc must be '2.0'\",\n },\n }, 400);\n }\n\n if (!request.method) {\n return c.json({\n jsonrpc: \"2.0\",\n id: request.id || null,\n error: {\n code: -32600,\n message: \"Invalid Request: method is required\",\n },\n }, 400);\n }\n\n // Check if this is a registration tool call (no auth required)\n const isRegistrationTool = request.method === \"tools/call\"\n && request.params?.name\n && (request.params.name.startsWith(\"register_\")\n || request.params.name.startsWith(\"verify_\")\n || request.params.name.startsWith(\"resend_\"));\n\n let authContext = null;\n\n const isOpenMethod = request.method === \"tools/list\" // already open\n || request.method === \"initialize\"\n || request.method === \"notifications/initialized\";\n\n authContext = await validateAuth(c);\n\n // Handle the MCP request\n const response = await mcpServer.handleRequest(request, authContext);\n console.log(\"[Server] MCP server response\", response);\n return c.json(response);\n } catch (error) {\n console.error(\"MCP request error:\", error);\n\n return c.json({\n jsonrpc: \"2.0\",\n id: null,\n error: {\n code: -32603,\n message: \"Internal error\",\n data: error.message,\n },\n }, 500);\n }\n});\n\n// List available tools endpoint (for debugging)\napp.get(\"/tools\", requireUserAuth(), async (c) => {\n try {\n const authContext = getAuthContext(c);\n const tools = mcpServer.getAvailableTools(authContext);\n\n return c.json({\n success: true,\n tools,\n count: tools.length,\n authContext: {\n isAdmin: authContext?.isAdmin || false,\n hasUser: Boolean(authContext?.user),\n },\n });\n } catch (error) {\n return c.json({\n success: false,\n error: error.message,\n }, 500);\n }\n});\n\n// API documentation endpoint\napp.get(\"/\", (c) => {\n const authToken = Deno.env.get(\"MCP_AUTH_TOKEN\");\n const hasAuth = Boolean(authToken);\n\n return c.html(`\n \n \n \n MCP Cognitive Tools Server\n \n \n \n

🧠 MCP Cognitive Tools Server

\n \n

A Model Context Protocol (MCP) server providing cognitive tools for thought processes, goal tracking, and dynamic skill creation.

\n \n

\n Authentication Status: ${hasAuth ? \"✅ Configured\" : \"❌ Missing MCP_AUTH_TOKEN\"}\n

\n \n

Available Endpoints

\n \n

GET /health

Health check endpoint (no auth required)

\n \n

POST /register

Send JSON: {\"email\": \"user@example.com\"}

\n \n

GET /verify?token=...

Email verification endpoint (no auth required)

Used by verification emails

\n \n

POST /mcp

Main MCP protocol endpoint (requires user or admin auth)

Send MCP requests with Authorization header

\n \n

GET /tools

List available tools (requires user or admin auth)

\n \n

Getting Started

Register: POST to /register with your email
Verify: Check your email and click the verification link
Use Tools: Use your access token to call MCP tools via /mcp

\n \n

Core Cognitive Tools

Fork Thought: Parallel exploration of ideas before merging insights
Goal Tracking: Hierarchical goal management with progress tracking
Task Management: Break down goals into actionable tasks
State Management: Save and restore cognitive states
Skills System: Create and execute dynamic tools

\n \n

Authentication

There are two types of authentication:

Admin Token: Set via MCP_AUTH_TOKEN environment variable (full access)
User Token: Obtained after email verification (user-scoped access)

Include your token in the Authorization header for protected endpoints.

\n \n

Example MCP Request

{\n  \"jsonrpc\": \"2.0\",\n  \"id\": 1,\n  \"method\": \"tools/list\"\n}

\n \n

Server Version: 1.0.0

\n \n \n `);\n});\n\n// 404 handler\napp.notFound((c) => {\n return c.json({\n error: \"Not Found\",\n message: \"The requested endpoint does not exist\",\n availableEndpoints: [\"/\", \"/health\", \"/register\", \"/verify\", \"/mcp\", \"/tools\"],\n }, 404);\n});\n\nexport default app.fetch;",[],[155,315],[155],{"_103":326,"_95":327,"_156":328,"_158":-5,"_159":138,"_160":118,"_161":162,"_105":329,"_100":32,"_164":165,"_166":-5,"_167":22,"_168":-5,"_169":330,"_98":340},"4882579c-3e20-11f0-a873-76b3cceeab13","shared","a60cd0e8-5948-484f-b608-47d0c2420cfd",["D",1748696882441],[331],{"_103":332,"_95":333,"_156":334,"_158":328,"_159":138,"_160":335,"_161":162,"_105":336,"_100":298,"_164":184,"_166":337,"_167":22,"_168":-5,"_169":338,"_98":339},"11a6c0fc-3fc2-11f0-824e-76b3cceeab13","types.ts","a9d743ae-ae8d-4e45-a661-0208f4594b98",77,["D",1748876320069],"// Shared types for MCP Cognitive Tools Server\n\nexport interface MCPRequest {\n jsonrpc: \"2.0\";\n id: string | number;\n method: string;\n params?: any;\n}\n\nexport interface MCPResponse {\n jsonrpc: \"2.0\";\n id: string | number;\n result?: any;\n error?: MCPError;\n}\n\nexport interface MCPError {\n code: number;\n message: string;\n data?: any;\n}\n\nexport interface MCPTool {\n name: string;\n description: string;\n inputSchema: {\n type: \"object\";\n properties: Record;\n required?: string[];\n };\n}\n\n// Thought Management Types\nexport interface ThoughtFork {\n id: string;\n parentId?: string;\n title: string;\n description: string;\n explorations: ThoughtExploration[];\n mergedInsights?: string;\n status: \"exploring\" | \"merged\" | \"abandoned\";\n createdAt: string;\n updatedAt: string;\n}\n\nexport interface ThoughtExploration {\n id: string;\n forkId: string;\n branch: string;\n content: string;\n insights: string[];\n confidence: number; // 0-1\n createdAt: string;\n}\n\n// Goal Management Types\nexport interface Goal {\n id: string;\n parentId?: string;\n title: string;\n description: string;\n priority: \"low\" | \"medium\" | \"high\" | \"critical\";\n status: \"draft\" | \"active\" | \"completed\" | \"paused\" | \"cancelled\";\n progress: number; // 0-100\n deadline?: string;\n tags: string[];\n subGoals: string[]; // Goal IDs\n tasks: string[]; // Task IDs\n createdAt: string;\n updatedAt: string;\n}\n\n// Task Management Types\nexport interface Task {\n id: string;\n goalId?: string;\n title: string;\n description: string;\n status: \"todo\" | \"in_progress\" | \"blocked\" | \"completed\" | \"cancelled\";\n priority: \"low\" | \"medium\" | \"high\" | \"urgent\";\n estimatedHours?: number;\n actualHours?: number;\n dependencies: string[]; // Task IDs\n assignee?: string;\n dueDate?: string;\n tags: string[];\n createdAt: string;\n updatedAt: string;\n}\n\n// State Management Types\nexport interface CognitiveState {\n id: string;\n name: string;\n description: string;\n context: Record;\n activeGoals: string[];\n activeTasks: string[];\n thoughtForks: string[];\n metadata: Record;\n createdAt: string;\n updatedAt: string;\n}\n\n// Skills System Types\nexport interface Skill {\n id: string;\n name: string;\n description: string;\n code: string;\n inputSchema: {\n type: \"object\";\n properties: Record;\n required?: string[];\n };\n outputSchema?: {\n type: \"object\";\n properties: Record;\n };\n tags: string[];\n version: string;\n isActive: boolean;\n createdAt: string;\n updatedAt: string;\n}\n\nexport interface SkillExecution {\n id: string;\n skillId: string;\n input: Record;\n output?: any;\n error?: string;\n duration: number;\n executedAt: string;\n}\n\n// Database Models\nexport interface DBThoughtFork extends Omit {\n explorations: string; // JSON string\n}\n\nexport interface DBGoal extends Omit {\n subGoals: string; // JSON string\n tasks: string; // JSON string\n tags: string; // JSON string\n}\n\nexport interface DBTask extends Omit {\n dependencies: string; // JSON string\n tags: string; // JSON string\n}\n\nexport interface DBCognitiveState extends Omit {\n context: string; // JSON string\n activeGoals: string; // JSON string\n activeTasks: string; // JSON string\n thoughtForks: string; // JSON string\n metadata: string; // JSON string\n}\n\nexport interface DBSkill extends Omit {\n inputSchema: string; // JSON string\n outputSchema?: string; // JSON string\n tags: string; // JSON string\n}\n\n// User Management Types\nexport interface User {\n id: string;\n email: string;\n isVerified: boolean;\n accessToken: string;\n createdAt: string;\n updatedAt: string;\n}\n\nexport interface EmailVerification {\n id: string;\n email: string;\n verificationToken: string;\n expiresAt: string;\n isUsed: boolean;\n createdAt: string;\n}\n\n// Extended types with user scoping\nexport interface UserScopedThoughtFork extends ThoughtFork {\n userId: string;\n}\n\nexport interface UserScopedGoal extends Goal {\n userId: string;\n}\n\nexport interface UserScopedTask extends Task {\n userId: string;\n}\n\nexport interface UserScopedCognitiveState extends CognitiveState {\n userId: string;\n}\n\nexport interface UserScopedSkill extends Skill {\n userId: string;\n}\n\n// Database models for user-scoped entities\nexport interface DBUserScopedThoughtFork extends Omit {\n explorations: string; // JSON string\n}\n\nexport interface DBUserScopedGoal extends Omit {\n subGoals: string; // JSON string\n tasks: string; // JSON string\n tags: string; // JSON string\n}\n\nexport interface DBUserScopedTask extends Omit {\n dependencies: string; // JSON string\n tags: string; // JSON string\n}\n\nexport interface DBUserScopedCognitiveState extends Omit {\n context: string; // JSON string\n activeGoals: string; // JSON string\n activeTasks: string; // JSON string\n thoughtForks: string; // JSON string\n metadata: string; // JSON string\n}\n\nexport interface DBUserScopedSkill extends Omit {\n inputSchema: string; // JSON string\n outputSchema?: string; // JSON string\n tags: string; // JSON string\n}",[],[327,333],[327],{"_103":342,"_95":343,"_156":344,"_158":-5,"_159":138,"_160":345,"_161":162,"_105":346,"_100":347,"_164":348,"_166":349,"_167":22,"_168":-5,"_169":350,"_98":351},"ccf99652-42a3-11f0-bc4c-76b3cceeab13","README.md","86d62dae-b3b8-4bc3-853a-700ff753f99a",138,["D",1749193173438],14,"file","# MCP Cognitive Tools Server\n\nA Model Context Protocol (MCP) server that provides cognitive tools for thought processes, goal tracking, and dynamic skill creation with user registration and email verification.\n\nTry it out here: https://www.val.town/x/c15r/Chat\n\n## Features\n\n### User Management\n- **Email Registration**: Register with email verification\n- **Access Tokens**: Secure token-based authentication\n- **User-Scoped Resources**: All resources are isolated per user\n- **Admin Access**: Admin users can access legacy global resources\n\n### Core Cognitive Tools\n- **AI-Enhanced Thought Forking**: Automatically generate parallel explorations using OpenAI\n- **Goal Tracking**: Create, update, and monitor goals with hierarchical structure\n- **Task Management**: Break down goals into actionable tasks with state tracking\n- **State Management**: Track and persist cognitive states across sessions\n- **Blob Storage**: Secure key-value storage with automatic user namespacing\n- **SQLite Database**: General-purpose database operations with user-scoped table isolation\n- **Resource Deletion**: Full deletion support with foreign key dependency handling\n\n### Dynamic Skills System\n- **Skill Creation**: Write and store reusable scripts as \"skills\"\n- **Skill Execution**: Dynamically invoke created skills as tools\n- **Skill Management**: List, update, and delete skills with execution history\n\n### Enhanced Thought Forking\n- **Automatic AI Generation**: Create thought forks with 2-8 parallel AI-generated explorations\n- **Perspective Analysis**: AI generates diverse analytical perspectives automatically\n- **AI Synthesis**: Merge explorations using AI to create comprehensive insights\n- **Insight Extraction**: Automatically extract key insights from each exploration\n\n## Project Structure\n\n```\n├── backend/\n│ ├── database/\n│ │ ├── migrations.ts # Database schema (user-scoped + legacy)\n│ │ ├── queries.ts # Database operations with user scoping\n│ │ └── user-queries.ts # User management operations\n│ ├── mcp/\n│ │ ├── server.ts # MCP server implementation\n│ │ ├── auth.ts # Authentication (admin + user tokens)\n│ │ └── tools/ # Cognitive tools\n│ │ ├── blob.ts # Blob storage management\n│ │ ├── fork-thought.ts # AI-enhanced thought forking\n│ │ ├── goals.ts # Goal management with deletion\n│ │ ├── tasks.ts # Task management with deletion\n│ │ ├── states.ts # Cognitive state management\n│ │ ├── skills.ts # Dynamic skills with deletion\n│ │ ├── sqlite.ts # SQLite database operations\n│ │ └── user-registration.ts # User registration & verification\n│ └── index.ts # Main entry point with verification endpoint\n├── shared/\n│ └── types.ts # Shared TypeScript types (user-scoped)\n└── README.md\n```\n\n## Environment Variables\n\n- `MCP_AUTH_TOKEN`: Admin authentication token (optional)\n- `BASE_URL`: Base URL for email verification links (optional)\n\n## API Endpoints\n\n- `GET /` - API documentation and status\n- `GET /health` - Health check endpoint\n- `POST /register` - User registration (no auth required)\n- `GET /verify?token=...` - Email verification (no auth required)\n- `POST /mcp` - Main MCP protocol endpoint (conditional auth)\n- `GET /tools` - List available tools (conditional auth)\n\n## Getting Started\n\n### 1. Register a User Account\n```bash\n# Register via HTTP endpoint\ncurl -X POST https://your-server.com/register \\\n -H \"Content-Type: application/json\" \\\n -d '{\"email\": \"user@example.com\"}'\n\n# Or via MCP (no auth required)\n{\n \"jsonrpc\": \"2.0\",\n \"id\": 1,\n \"method\": \"tools/call\",\n \"params\": {\n \"name\": \"register_user\",\n \"arguments\": {\n \"email\": \"user@example.com\"\n }\n }\n}\n```\n\n### 2. Verify Email\nCheck your email and click the verification link, or visit:\n```\nhttps://your-server.com/verify?token=YOUR_VERIFICATION_TOKEN\n```\n\n### 3. Use Your Access Token\nUse the access token from the verification page in the `Authorization` header:\n```bash\ncurl -X POST https://your-server.com/mcp \\\n -H \"Authorization: YOUR_ACCESS_TOKEN\" \\\n -H \"Content-Type: application/json\" \\\n -d '{\"jsonrpc\": \"2.0\", \"id\": 1, \"method\": \"tools/list\"}'\n```\n\n## Enhanced Thought Forking\n\nCreate AI-enhanced thought forks that automatically generate multiple perspectives:\n\n```json\n{\n \"jsonrpc\": \"2.0\",\n \"id\": 1,\n \"method\": \"tools/call\",\n \"params\": {\n \"name\": \"create_thought_fork\",\n \"arguments\": {\n \"title\": \"AI Ethics in Healthcare\",\n \"description\": \"Explore the ethical implications of AI in medical diagnosis and treatment\",\n \"branches\": 4\n }\n }\n}\n```\n\nThis will:\n1. Create a thought fork\n2. Generate 4 different analytical perspectives using AI\n3. Create parallel explorations for each perspective\n4. Extract key insights from each exploration\n5. Return the complete thought fork with all explorations\n\nMerge the explorations with AI synthesis:\n```json\n{\n \"jsonrpc\": \"2.0\",\n \"id\": 2,\n \"method\": \"tools/call\",\n \"params\": {\n \"name\": \"merge_thought_fork\",\n \"arguments\": {\n \"id\": \"thought-fork-id\"\n }\n }\n}\n```\n\n## Blob Storage Management\n\nThe blob storage system provides secure, user-namespaced key-value storage for arbitrary data:\n\n```json\n{\n \"jsonrpc\": \"2.0\",\n \"id\": 1,\n \"method\": \"tools/call\",\n \"params\": {\n \"name\": \"blob_set\",\n \"arguments\": {\n \"key\": \"user-preferences\",\n \"value\": {\n \"theme\": \"dark\",\n \"language\": \"en\",\n \"notifications\": true\n }\n }\n }\n}\n```\n\nRetrieve stored data:\n```json\n{\n \"jsonrpc\": \"2.0\",\n \"id\": 2,\n \"method\": \"tools/call\",\n \"params\": {\n \"name\": \"blob_get\",\n \"arguments\": {\n \"key\": \"user-preferences\"\n }\n }\n}\n```\n\nList all your stored blobs:\n```json\n{\n \"jsonrpc\": \"2.0\",\n \"id\": 3,\n \"method\": \"tools/call\",\n \"params\": {\n \"name\": \"blob_list\",\n \"arguments\": {\n \"prefix\": \"config-\"\n }\n }\n}\n```\n\n### Blob Storage Features\n\n- **Automatic Namespacing**: All blob keys are automatically prefixed with your user ID\n- **JSON Support**: Automatic JSON serialization/deserialization (can be disabled)\n- **Prefix Filtering**: List blobs with specific prefixes\n- **Existence Checking**: Check if a blob exists without retrieving its value\n- **Admin Access**: Admin users can access global blob storage\n- **Secure Isolation**: Users can only access their own blobs\n\n## SQLite Database Management\n\nThe SQLite database system provides secure, user-scoped database operations for structured data storage:\n\n```json\n{\n \"jsonrpc\": \"2.0\",\n \"id\": 1,\n \"method\": \"tools/call\",\n \"params\": {\n \"name\": \"sqlite_create_table\",\n \"arguments\": {\n \"tableName\": \"user_notes\",\n \"schema\": \"id INTEGER PRIMARY KEY AUTOINCREMENT, title TEXT NOT NULL, content TEXT, created_at TEXT NOT NULL DEFAULT CURRENT_TIMESTAMP\"\n }\n }\n}\n```\n\nInsert data into your table:\n```json\n{\n \"jsonrpc\": \"2.0\",\n \"id\": 2,\n \"method\": \"tools/call\",\n \"params\": {\n \"name\": \"sqlite_execute\",\n \"arguments\": {\n \"query\": \"INSERT INTO user_notes (title, content) VALUES (?, ?)\",\n \"params\": [\"My First Note\", \"This is the content of my note\"]\n }\n }\n}\n```\n\nQuery your data:\n```json\n{\n \"jsonrpc\": \"2.0\",\n \"id\": 3,\n \"method\": \"tools/call\",\n \"params\": {\n \"name\": \"sqlite_execute\",\n \"arguments\": {\n \"query\": \"SELECT * FROM user_notes WHERE title LIKE ?\",\n \"params\": [\"%First%\"]\n }\n }\n}\n```\n\nList all your tables:\n```json\n{\n \"jsonrpc\": \"2.0\",\n \"id\": 4,\n \"method\": \"tools/call\",\n \"params\": {\n \"name\": \"sqlite_list_tables\",\n \"arguments\": {}\n }\n}\n```\n\nGet table schema information:\n```json\n{\n \"jsonrpc\": \"2.0\",\n \"id\": 5,\n \"method\": \"tools/call\",\n \"params\": {\n \"name\": \"sqlite_describe_table\",\n \"arguments\": {\n \"tableName\": \"user_notes\"\n }\n }\n}\n```\n\n### SQLite Security Features\n\n- **Automatic Table Namespacing**: All table names are automatically prefixed with your user ID\n- **Query Validation**: Dangerous operations (DROP DATABASE, PRAGMA, etc.) are blocked\n- **User Isolation**: Users can only access their own tables\n- **Admin Access**: Admin users can access global tables with admin prefix\n- **SQL Injection Protection**: Parameterized queries and input validation\n- **Secure Table Names**: Table names are validated to prevent injection attacks\n\n## Resource Management\n\nAll resources support full deletion with dependency handling:\n\n- **Goals**: Deleting a goal removes all subgoals and associated tasks\n- **Tasks**: Deleting a task removes it from goals and other task dependencies\n- **Thought Forks**: Deleting removes all associated explorations\n- **Skills**: Deleting removes all execution history\n- **States**: Direct deletion of cognitive states\n\n## Authentication Types\n\n### User Authentication\n- Obtained through email verification\n- Scoped to user's own resources\n- Required for all cognitive tools\n\n### Admin Authentication\n- Set via `MCP_AUTH_TOKEN` environment variable\n- Access to legacy global resources\n- Full system access\n\n### Public Access\n- User registration tools only\n- No authentication required\n\n## MCP Tool Categories\n\n### Registration Tools (No Auth)\n- `register_user` - Register with email\n- `verify_email` - Verify email with token\n- `resend_verification` - Resend verification email\n\n### Cognitive Tools (Auth Required)\n- **Blob Storage**: `blob_list`, `blob_get`, `blob_set`, `blob_delete`, `blob_exists`\n- **SQLite Database**: `sqlite_execute`, `sqlite_create_table`, `sqlite_list_tables`, `sqlite_describe_table`, `sqlite_drop_table`\n- **Thought Forking**: `create_thought_fork`, `merge_thought_fork`, `delete_thought_fork`\n- **Goals**: `create_goal`, `update_goal`, `delete_goal`, `list_goals`\n- **Tasks**: `create_task`, `update_task`, `delete_task`, `list_tasks`\n- **States**: `save_cognitive_state`, `load_cognitive_state`, `delete_cognitive_state`\n- **Skills**: `create_skill`, `execute_skill`, `delete_skill`, `list_skills`\n\n### Dynamic Skills (Auth Required)\n- `skill_[name]` - Execute user-created skills dynamically\n\n## Example Workflow\n\n1. **Register**: `register_user` with email\n2. **Verify**: Click email link to get access token\n3. **Store Data**: Use `blob_set` to store configuration or data\n4. **Create Database**: Use `sqlite_create_table` to set up structured data storage\n5. **Create Goal**: Use `create_goal` to set objectives\n6. **Fork Thoughts**: Use `create_thought_fork` for AI-assisted analysis\n7. **Merge Insights**: Use `merge_thought_fork` for AI synthesis\n8. **Create Tasks**: Break down goals with `create_task`\n9. **Store Structured Data**: Use `sqlite_execute` to insert and query data\n10. **Build Skills**: Create reusable tools with `create_skill`\n11. **Save State**: Capture progress with `save_cognitive_state`\n\n## Security Features\n\n- Email verification required for access\n- User-scoped resource isolation\n- Automatic blob storage namespacing\n- Automatic SQLite table namespacing\n- SQL injection protection with parameterized queries\n- Query validation to block dangerous operations\n- Secure skill execution sandboxing\n- Token-based authentication\n- Foreign key constraint handling\n\n*Server Version: 2.0.0 - Now with user registration and AI-enhanced cognitive tools*",[],[343],"files",[153,171,177,188,198,207,213,219,228,236,245,255,264,273,282,292,302,313,325,331,341],"counts",{"_356":32,"_357":118,"_358":32,"_359":118},"pulls","branches","forks","envVars","contents",[],{"_103":189,"_95":190,"_156":191,"_158":174,"_159":138,"_160":192,"_161":162,"_105":363,"_100":194,"_164":184,"_166":195,"_167":22,"_168":-5,"_98":364},["D",1748709562413],[155,173,190],"upstreamProject","upstreamBranch",{"_103":141,"_105":368,"_369":370,"_95":43,"_139":146,"_100":143,"_140":-5,"_142":-5,"_371":-5,"_107":-5,"_150":22,"_109":110,"_149":94,"_16":119,"_148":372},["D",1748556642802],"updatedAt",["D",1748620785935],"lockfileKey","ContextualMCP","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.history_.$",{"_93":94,"_95":96,"_97":43,"_98":99,"_101":379,"_348":384,"_387":388,"_415":416,"_424":-7,"_425":32,"_426":22},{"_103":104,"_95":96,"_105":380,"_107":-5,"_108":22,"_109":110,"_111":-5,"_112":-5,"_14":113,"_114":-5,"_115":22,"_116":-5,"_117":118,"_16":119,"_120":121,"_122":121,"_123":124,"_125":124,"_126":124,"_127":121,"_128":121,"_23":381,"_132":382,"_135":383,"_150":22},["D",1748696882441],{"_93":94,"_130":131},{"_93":94,"_134":131},{"_100":137,"_95":43,"_103":138,"_139":104,"_140":141,"_142":143,"_144":110,"_145":146,"_147":119,"_148":96,"_149":94},{"_103":189,"_95":190,"_156":191,"_158":174,"_159":138,"_160":192,"_161":162,"_105":385,"_100":194,"_164":184,"_166":195,"_167":22,"_168":-5,"_98":386},["D",1748709562413],[155,173,190],"history",[389,391,396,401,406,411],{"_103":189,"_159":138,"_156":191,"_95":190,"_166":195,"_164":184,"_100":194,"_158":174,"_105":390,"_160":192,"_168":-5},["D",1748709562413],{"_103":392,"_159":138,"_156":191,"_95":190,"_166":393,"_164":184,"_100":181,"_158":174,"_105":394,"_160":395,"_168":-5},"fa8e00c2-3e38-11f0-9bc3-76b3cceeab13","import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport type {\n CognitiveState,\n DBCognitiveState,\n DBGoal,\n DBSkill,\n DBTask,\n DBThoughtFork,\n Goal,\n Skill,\n SkillExecution,\n Task,\n ThoughtExploration,\n ThoughtFork,\n UserScopedThoughtFork,\n UserScopedGoal,\n UserScopedTask,\n UserScopedCognitiveState,\n UserScopedSkill,\n DBUserScopedThoughtFork,\n DBUserScopedGoal,\n DBUserScopedTask,\n DBUserScopedCognitiveState,\n DBUserScopedSkill,\n} from \"../../shared/types.ts\";\nimport { TABLES } from \"./migrations.ts\";\n\n// Utility functions for JSON serialization\nfunction serializeJSON(obj: any): string {\n return JSON.stringify(obj);\n}\n\nfunction parseJSON(str: string): T {\n try {\n return JSON.parse(str);\n } catch {\n return [] as T;\n }\n}\n\n// Helper function to determine which table to use based on user context\nfunction getTableName(baseTable: string, userId?: string | null): string {\n if (userId === null || userId === undefined) {\n // Admin context - use legacy tables\n return baseTable;\n }\n // User context - use user-scoped tables\n switch (baseTable) {\n case TABLES.THOUGHT_FORKS:\n return TABLES.USER_THOUGHT_FORKS;\n case TABLES.THOUGHT_EXPLORATIONS:\n return TABLES.USER_THOUGHT_EXPLORATIONS;\n case TABLES.GOALS:\n return TABLES.USER_GOALS;\n case TABLES.TASKS:\n return TABLES.USER_TASKS;\n case TABLES.COGNITIVE_STATES:\n return TABLES.USER_COGNITIVE_STATES;\n case TABLES.SKILLS:\n return TABLES.USER_SKILLS;\n case TABLES.SKILL_EXECUTIONS:\n return TABLES.USER_SKILL_EXECUTIONS;\n default:\n return baseTable;\n }\n}\n\n// Thought Fork Queries\nexport async function createThoughtFork(\n fork: Omit,\n userId?: string | null\n): Promise {\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n const tableName = getTableName(TABLES.THOUGHT_FORKS, userId);\n\n const baseFields = {\n id,\n parentId: fork.parentId || null,\n title: fork.title,\n description: fork.description,\n explorations: serializeJSON([]), // Start with empty explorations\n mergedInsights: fork.mergedInsights || null,\n status: fork.status,\n createdAt: now,\n updatedAt: now,\n };\n\n if (userId) {\n // User-scoped table\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, userId, parentId, title, description, explorations, mergedInsights, status, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n userId,\n baseFields.parentId,\n baseFields.title,\n baseFields.description,\n baseFields.explorations,\n baseFields.mergedInsights,\n baseFields.status,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n } else {\n // Admin table\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, parentId, title, description, explorations, mergedInsights, status, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n baseFields.parentId,\n baseFields.title,\n baseFields.description,\n baseFields.explorations,\n baseFields.mergedInsights,\n baseFields.status,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n }\n\n return {\n ...baseFields,\n explorations: [],\n };\n}\n\nexport async function getThoughtFork(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.THOUGHT_FORKS, userId);\n const explorationTableName = getTableName(TABLES.THOUGHT_EXPLORATIONS, userId);\n \n let query: string;\n let params: any[];\n \n if (userId) {\n query = `SELECT * FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `SELECT * FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n if (result.length === 0) return null;\n\n const dbFork = result.rows[0] as any;\n \n // Get explorations for this fork\n let explorationQuery: string;\n let explorationParams: any[];\n \n if (userId) {\n explorationQuery = `SELECT * FROM ${explorationTableName} WHERE forkId = ? AND userId = ? ORDER BY createdAt ASC`;\n explorationParams = [id, userId];\n } else {\n explorationQuery = `SELECT * FROM ${explorationTableName} WHERE forkId = ? ORDER BY createdAt ASC`;\n explorationParams = [id];\n }\n\n const explorationResult = await sqlite.execute(explorationQuery, explorationParams);\n const explorations = explorationResult.rows.map((row: any) => ({\n ...row,\n insights: parseJSON(row.insights),\n }));\n\n return {\n id: dbFork.id,\n parentId: dbFork.parentId,\n title: dbFork.title,\n description: dbFork.description,\n explorations,\n mergedInsights: dbFork.mergedInsights,\n status: dbFork.status,\n createdAt: dbFork.createdAt,\n updatedAt: dbFork.updatedAt,\n };\n}\n\nexport async function updateThoughtFork(\n id: string,\n updates: Partial,\n userId?: string | null\n): Promise {\n const existing = await getThoughtFork(id, userId);\n if (!existing) return null;\n\n const updatedFork = { ...existing, ...updates, updatedAt: new Date().toISOString() };\n const tableName = getTableName(TABLES.THOUGHT_FORKS, userId);\n\n let query: string;\n let params: any[];\n\n if (userId) {\n query = `UPDATE ${tableName} SET title = ?, description = ?, mergedInsights = ?, status = ?, updatedAt = ? WHERE id = ? AND userId = ?`;\n params = [\n updatedFork.title,\n updatedFork.description,\n updatedFork.mergedInsights,\n updatedFork.status,\n updatedFork.updatedAt,\n id,\n userId,\n ];\n } else {\n query = `UPDATE ${tableName} SET title = ?, description = ?, mergedInsights = ?, status = ?, updatedAt = ? WHERE id = ?`;\n params = [\n updatedFork.title,\n updatedFork.description,\n updatedFork.mergedInsights,\n updatedFork.status,\n updatedFork.updatedAt,\n id,\n ];\n }\n\n await sqlite.execute(query, params);\n return updatedFork;\n}\n\nexport async function listThoughtForks(\n filters: { status?: string; parentId?: string } = {},\n userId?: string | null\n): Promise {\n const tableName = getTableName(TABLES.THOUGHT_FORKS, userId);\n const { status, parentId } = filters;\n\n let query = `SELECT * FROM ${tableName}`;\n const params: any[] = [];\n const conditions: string[] = [];\n\n if (userId) {\n conditions.push(\"userId = ?\");\n params.push(userId);\n }\n\n if (status) {\n conditions.push(\"status = ?\");\n params.push(status);\n }\n\n if (parentId) {\n conditions.push(\"parentId = ?\");\n params.push(parentId);\n }\n\n if (conditions.length > 0) {\n query += ` WHERE ${conditions.join(\" AND \")}`;\n }\n\n query += ` ORDER BY createdAt DESC`;\n\n const result = await sqlite.execute(query, params);\n\n // Get explorations for each fork\n const forks = await Promise.all(\n result.rows.map(async (row: any) => {\n const fork = await getThoughtFork(row.id, userId);\n return fork!;\n })\n );\n\n return forks;\n}\n\nexport async function deleteThoughtFork(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.THOUGHT_FORKS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `DELETE FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `DELETE FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n return result.changes > 0;\n}\n\n// Thought Exploration Queries\nexport async function createThoughtExploration(\n exploration: Omit,\n userId?: string | null\n): Promise {\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n const tableName = getTableName(TABLES.THOUGHT_EXPLORATIONS, userId);\n\n const newExploration: ThoughtExploration = {\n id,\n ...exploration,\n createdAt: now,\n };\n\n if (userId) {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, userId, forkId, branch, content, insights, confidence, createdAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n id,\n userId,\n exploration.forkId,\n exploration.branch,\n exploration.content,\n serializeJSON(exploration.insights),\n exploration.confidence,\n now,\n ]\n );\n } else {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, forkId, branch, content, insights, confidence, createdAt)\n VALUES (?, ?, ?, ?, ?, ?, ?)`,\n [\n id,\n exploration.forkId,\n exploration.branch,\n exploration.content,\n serializeJSON(exploration.insights),\n exploration.confidence,\n now,\n ]\n );\n }\n\n return newExploration;\n}\n\nexport async function deleteThoughtExploration(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.THOUGHT_EXPLORATIONS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `DELETE FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `DELETE FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n return result.changes > 0;\n}\n\n// Goal Queries\nexport async function createGoal(\n goal: Omit,\n userId?: string | null\n): Promise {\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n const tableName = getTableName(TABLES.GOALS, userId);\n\n const baseFields = {\n id,\n parentId: goal.parentId || null,\n title: goal.title,\n description: goal.description,\n priority: goal.priority,\n status: goal.status,\n progress: goal.progress,\n deadline: goal.deadline || null,\n tags: serializeJSON(goal.tags),\n subGoals: serializeJSON(goal.subGoals),\n tasks: serializeJSON(goal.tasks),\n createdAt: now,\n updatedAt: now,\n };\n\n if (userId) {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, userId, parentId, title, description, priority, status, progress, deadline, tags, subGoals, tasks, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n userId,\n baseFields.parentId,\n baseFields.title,\n baseFields.description,\n baseFields.priority,\n baseFields.status,\n baseFields.progress,\n baseFields.deadline,\n baseFields.tags,\n baseFields.subGoals,\n baseFields.tasks,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n } else {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, parentId, title, description, priority, status, progress, deadline, tags, subGoals, tasks, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n baseFields.parentId,\n baseFields.title,\n baseFields.description,\n baseFields.priority,\n baseFields.status,\n baseFields.progress,\n baseFields.deadline,\n baseFields.tags,\n baseFields.subGoals,\n baseFields.tasks,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n }\n\n return {\n ...baseFields,\n tags: parseJSON(baseFields.tags),\n subGoals: parseJSON(baseFields.subGoals),\n tasks: parseJSON(baseFields.tasks),\n };\n}\n\nexport async function getGoal(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.GOALS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `SELECT * FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `SELECT * FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n if (result.length === 0) return null;\n\n const dbGoal = result.rows[0] as any;\n return {\n ...dbGoal,\n tags: parseJSON(dbGoal.tags),\n subGoals: parseJSON(dbGoal.subGoals),\n tasks: parseJSON(dbGoal.tasks),\n };\n}\n\nexport async function updateGoal(\n id: string,\n updates: Partial,\n userId?: string | null\n): Promise {\n const existing = await getGoal(id, userId);\n if (!existing) return null;\n\n const updatedGoal = { ...existing, ...updates, updatedAt: new Date().toISOString() };\n const tableName = getTableName(TABLES.GOALS, userId);\n\n let query: string;\n let params: any[];\n\n if (userId) {\n query = `UPDATE ${tableName} SET title = ?, description = ?, priority = ?, status = ?, progress = ?, deadline = ?, tags = ?, subGoals = ?, tasks = ?, updatedAt = ? WHERE id = ? AND userId = ?`;\n params = [\n updatedGoal.title,\n updatedGoal.description,\n updatedGoal.priority,\n updatedGoal.status,\n updatedGoal.progress,\n updatedGoal.deadline,\n serializeJSON(updatedGoal.tags),\n serializeJSON(updatedGoal.subGoals),\n serializeJSON(updatedGoal.tasks),\n updatedGoal.updatedAt,\n id,\n userId,\n ];\n } else {\n query = `UPDATE ${tableName} SET title = ?, description = ?, priority = ?, status = ?, progress = ?, deadline = ?, tags = ?, subGoals = ?, tasks = ?, updatedAt = ? WHERE id = ?`;\n params = [\n updatedGoal.title,\n updatedGoal.description,\n updatedGoal.priority,\n updatedGoal.status,\n updatedGoal.progress,\n updatedGoal.deadline,\n serializeJSON(updatedGoal.tags),\n serializeJSON(updatedGoal.subGoals),\n serializeJSON(updatedGoal.tasks),\n updatedGoal.updatedAt,\n id,\n ];\n }\n\n await sqlite.execute(query, params);\n return updatedGoal;\n}\n\nexport async function listGoals(\n filters: { status?: string; parentId?: string } = {},\n userId?: string | null\n): Promise {\n const tableName = getTableName(TABLES.GOALS, userId);\n const { status, parentId } = filters;\n\n let query = `SELECT * FROM ${tableName}`;\n const params: any[] = [];\n const conditions: string[] = [];\n\n if (userId) {\n conditions.push(\"userId = ?\");\n params.push(userId);\n }\n\n if (status) {\n conditions.push(\"status = ?\");\n params.push(status);\n }\n\n if (parentId) {\n conditions.push(\"parentId = ?\");\n params.push(parentId);\n }\n\n if (conditions.length > 0) {\n query += ` WHERE ${conditions.join(\" AND \")}`;\n }\n\n query += ` ORDER BY priority DESC, createdAt DESC`;\n\n const result = await sqlite.execute(query, params);\n\n return result.rows.map((row: any) => ({\n ...row,\n tags: parseJSON(row.tags),\n subGoals: parseJSON(row.subGoals),\n tasks: parseJSON(row.tasks),\n }));\n}\n\nexport async function deleteGoal(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.GOALS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `DELETE FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `DELETE FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n return result.changes > 0;\n}\n\n// Task Queries\nexport async function createTask(\n task: Omit,\n userId?: string | null\n): Promise {\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n const tableName = getTableName(TABLES.TASKS, userId);\n\n const baseFields = {\n id,\n goalId: task.goalId || null,\n title: task.title,\n description: task.description,\n status: task.status,\n priority: task.priority,\n estimatedHours: task.estimatedHours || null,\n actualHours: task.actualHours || null,\n dependencies: serializeJSON(task.dependencies),\n assignee: task.assignee || null,\n dueDate: task.dueDate || null,\n tags: serializeJSON(task.tags),\n createdAt: now,\n updatedAt: now,\n };\n\n if (userId) {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, userId, goalId, title, description, status, priority, estimatedHours, actualHours, dependencies, assignee, dueDate, tags, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n userId,\n baseFields.goalId,\n baseFields.title,\n baseFields.description,\n baseFields.status,\n baseFields.priority,\n baseFields.estimatedHours,\n baseFields.actualHours,\n baseFields.dependencies,\n baseFields.assignee,\n baseFields.dueDate,\n baseFields.tags,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n } else {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, goalId, title, description, status, priority, estimatedHours, actualHours, dependencies, assignee, dueDate, tags, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n baseFields.goalId,\n baseFields.title,\n baseFields.description,\n baseFields.status,\n baseFields.priority,\n baseFields.estimatedHours,\n baseFields.actualHours,\n baseFields.dependencies,\n baseFields.assignee,\n baseFields.dueDate,\n baseFields.tags,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n }\n\n return {\n ...baseFields,\n dependencies: parseJSON(baseFields.dependencies),\n tags: parseJSON(baseFields.tags),\n };\n}\n\nexport async function getTask(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.TASKS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `SELECT * FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `SELECT * FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n if (result.length === 0) return null;\n\n const dbTask = result.rows[0] as any;\n return {\n ...dbTask,\n dependencies: parseJSON(dbTask.dependencies),\n tags: parseJSON(dbTask.tags),\n };\n}\n\nexport async function updateTask(\n id: string,\n updates: Partial,\n userId?: string | null\n): Promise {\n const existing = await getTask(id, userId);\n if (!existing) return null;\n\n const updatedTask = { ...existing, ...updates, updatedAt: new Date().toISOString() };\n const tableName = getTableName(TABLES.TASKS, userId);\n\n let query: string;\n let params: any[];\n\n if (userId) {\n query = `UPDATE ${tableName} SET title = ?, description = ?, status = ?, priority = ?, estimatedHours = ?, actualHours = ?, dependencies = ?, assignee = ?, dueDate = ?, tags = ?, updatedAt = ? WHERE id = ? AND userId = ?`;\n params = [\n updatedTask.title,\n updatedTask.description,\n updatedTask.status,\n updatedTask.priority,\n updatedTask.estimatedHours,\n updatedTask.actualHours,\n serializeJSON(updatedTask.dependencies),\n updatedTask.assignee,\n updatedTask.dueDate,\n serializeJSON(updatedTask.tags),\n updatedTask.updatedAt,\n id,\n userId,\n ];\n } else {\n query = `UPDATE ${tableName} SET title = ?, description = ?, status = ?, priority = ?, estimatedHours = ?, actualHours = ?, dependencies = ?, assignee = ?, dueDate = ?, tags = ?, updatedAt = ? WHERE id = ?`;\n params = [\n updatedTask.title,\n updatedTask.description,\n updatedTask.status,\n updatedTask.priority,\n updatedTask.estimatedHours,\n updatedTask.actualHours,\n serializeJSON(updatedTask.dependencies),\n updatedTask.assignee,\n updatedTask.dueDate,\n serializeJSON(updatedTask.tags),\n updatedTask.updatedAt,\n id,\n ];\n }\n\n await sqlite.execute(query, params);\n return updatedTask;\n}\n\nexport async function listTasks(\n filters: { goalId?: string; status?: string } = {},\n userId?: string | null\n): Promise {\n const tableName = getTableName(TABLES.TASKS, userId);\n const { goalId, status } = filters;\n\n let query = `SELECT * FROM ${tableName}`;\n const params: any[] = [];\n const conditions: string[] = [];\n\n if (userId) {\n conditions.push(\"userId = ?\");\n params.push(userId);\n }\n\n if (goalId) {\n conditions.push(\"goalId = ?\");\n params.push(goalId);\n }\n\n if (status) {\n conditions.push(\"status = ?\");\n params.push(status);\n }\n\n if (conditions.length > 0) {\n query += ` WHERE ${conditions.join(\" AND \")}`;\n }\n\n query += ` ORDER BY priority DESC, createdAt DESC`;\n\n const result = await sqlite.execute(query, params);\n\n return result.rows.map((row: any) => ({\n ...row,\n dependencies: parseJSON(row.dependencies),\n tags: parseJSON(row.tags),\n }));\n}\n\nexport async function deleteTask(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.TASKS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `DELETE FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `DELETE FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n return result.changes > 0;\n}\n\n// Cognitive State Queries\nexport async function createCognitiveState(\n state: Omit,\n userId?: string | null\n): Promise {\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n const tableName = getTableName(TABLES.COGNITIVE_STATES, userId);\n\n const baseFields = {\n id,\n name: state.name,\n description: state.description,\n context: serializeJSON(state.context),\n activeGoals: serializeJSON(state.activeGoals),\n activeTasks: serializeJSON(state.activeTasks),\n thoughtForks: serializeJSON(state.thoughtForks),\n metadata: serializeJSON(state.metadata),\n createdAt: now,\n updatedAt: now,\n };\n\n if (userId) {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, userId, name, description, context, activeGoals, activeTasks, thoughtForks, metadata, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n userId,\n baseFields.name,\n baseFields.description,\n baseFields.context,\n baseFields.activeGoals,\n baseFields.activeTasks,\n baseFields.thoughtForks,\n baseFields.metadata,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n } else {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, name, description, context, activeGoals, activeTasks, thoughtForks, metadata, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n baseFields.name,\n baseFields.description,\n baseFields.context,\n baseFields.activeGoals,\n baseFields.activeTasks,\n baseFields.thoughtForks,\n baseFields.metadata,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n }\n\n return {\n ...baseFields,\n context: parseJSON(baseFields.context),\n activeGoals: parseJSON(baseFields.activeGoals),\n activeTasks: parseJSON(baseFields.activeTasks),\n thoughtForks: parseJSON(baseFields.thoughtForks),\n metadata: parseJSON(baseFields.metadata),\n };\n}\n\nexport async function getCognitiveState(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.COGNITIVE_STATES, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `SELECT * FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `SELECT * FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n if (result.length === 0) return null;\n\n const dbState = result.rows[0] as any;\n return {\n ...dbState,\n context: parseJSON(dbState.context),\n activeGoals: parseJSON(dbState.activeGoals),\n activeTasks: parseJSON(dbState.activeTasks),\n thoughtForks: parseJSON(dbState.thoughtForks),\n metadata: parseJSON(dbState.metadata),\n };\n}\n\nexport async function updateCognitiveState(\n id: string,\n updates: Partial,\n userId?: string | null\n): Promise {\n const existing = await getCognitiveState(id, userId);\n if (!existing) return null;\n\n const updatedState = { ...existing, ...updates, updatedAt: new Date().toISOString() };\n const tableName = getTableName(TABLES.COGNITIVE_STATES, userId);\n\n let query: string;\n let params: any[];\n\n if (userId) {\n query = `UPDATE ${tableName} SET name = ?, description = ?, context = ?, activeGoals = ?, activeTasks = ?, thoughtForks = ?, metadata = ?, updatedAt = ? WHERE id = ? AND userId = ?`;\n params = [\n updatedState.name,\n updatedState.description,\n serializeJSON(updatedState.context),\n serializeJSON(updatedState.activeGoals),\n serializeJSON(updatedState.activeTasks),\n serializeJSON(updatedState.thoughtForks),\n serializeJSON(updatedState.metadata),\n updatedState.updatedAt,\n id,\n userId,\n ];\n } else {\n query = `UPDATE ${tableName} SET name = ?, description = ?, context = ?, activeGoals = ?, activeTasks = ?, thoughtForks = ?, metadata = ?, updatedAt = ? WHERE id = ?`;\n params = [\n updatedState.name,\n updatedState.description,\n serializeJSON(updatedState.context),\n serializeJSON(updatedState.activeGoals),\n serializeJSON(updatedState.activeTasks),\n serializeJSON(updatedState.thoughtForks),\n serializeJSON(updatedState.metadata),\n updatedState.updatedAt,\n id,\n ];\n }\n\n await sqlite.execute(query, params);\n return updatedState;\n}\n\nexport async function listCognitiveStates(userId?: string | null): Promise {\n const tableName = getTableName(TABLES.COGNITIVE_STATES, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `SELECT * FROM ${tableName} WHERE userId = ? ORDER BY updatedAt DESC`;\n params = [userId];\n } else {\n query = `SELECT * FROM ${tableName} ORDER BY updatedAt DESC`;\n params = [];\n }\n\n const result = await sqlite.execute(query, params);\n\n return result.rows.map((row: any) => ({\n ...row,\n context: parseJSON(row.context),\n activeGoals: parseJSON(row.activeGoals),\n activeTasks: parseJSON(row.activeTasks),\n thoughtForks: parseJSON(row.thoughtForks),\n metadata: parseJSON(row.metadata),\n }));\n}\n\nexport async function deleteCognitiveState(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.COGNITIVE_STATES, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `DELETE FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `DELETE FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n return result.changes > 0;\n}\n\n// Skill Queries\nexport async function createSkill(\n skill: Omit,\n userId?: string | null\n): Promise {\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n const tableName = getTableName(TABLES.SKILLS, userId);\n\n const baseFields = {\n id,\n name: skill.name,\n description: skill.description,\n code: skill.code,\n inputSchema: serializeJSON(skill.inputSchema),\n outputSchema: skill.outputSchema ? serializeJSON(skill.outputSchema) : null,\n tags: serializeJSON(skill.tags),\n version: skill.version,\n isActive: skill.isActive ? 1 : 0,\n createdAt: now,\n updatedAt: now,\n };\n\n if (userId) {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, userId, name, description, code, inputSchema, outputSchema, tags, version, isActive, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n userId,\n baseFields.name,\n baseFields.description,\n baseFields.code,\n baseFields.inputSchema,\n baseFields.outputSchema,\n baseFields.tags,\n baseFields.version,\n baseFields.isActive,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n } else {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, name, description, code, inputSchema, outputSchema, tags, version, isActive, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n baseFields.name,\n baseFields.description,\n baseFields.code,\n baseFields.inputSchema,\n baseFields.outputSchema,\n baseFields.tags,\n baseFields.version,\n baseFields.isActive,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n }\n\n return {\n ...baseFields,\n inputSchema: parseJSON(baseFields.inputSchema),\n outputSchema: baseFields.outputSchema ? parseJSON(baseFields.outputSchema) : undefined,\n tags: parseJSON(baseFields.tags),\n isActive: Boolean(baseFields.isActive),\n };\n}\n\nexport async function getSkill(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.SKILLS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `SELECT * FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `SELECT * FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n if (result.length === 0) return null;\n\n const dbSkill = result.rows[0] as any;\n return {\n ...dbSkill,\n inputSchema: parseJSON(dbSkill.inputSchema),\n outputSchema: dbSkill.outputSchema ? parseJSON(dbSkill.outputSchema) : undefined,\n tags: parseJSON(dbSkill.tags),\n isActive: Boolean(dbSkill.isActive),\n };\n}\n\nexport async function getSkillByName(name: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.SKILLS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `SELECT * FROM ${tableName} WHERE name = ? AND userId = ?`;\n params = [name, userId];\n } else {\n query = `SELECT * FROM ${tableName} WHERE name = ?`;\n params = [name];\n }\n\n const result = await sqlite.execute(query, params);\n if (result.length === 0) return null;\n\n const dbSkill = result.rows[0] as any;\n return {\n ...dbSkill,\n inputSchema: parseJSON(dbSkill.inputSchema),\n outputSchema: dbSkill.outputSchema ? parseJSON(dbSkill.outputSchema) : undefined,\n tags: parseJSON(dbSkill.tags),\n isActive: Boolean(dbSkill.isActive),\n };\n}\n\nexport async function updateSkill(\n id: string,\n updates: Partial,\n userId?: string | null\n): Promise {\n const existing = await getSkill(id, userId);\n if (!existing) return null;\n\n const updatedSkill = { ...existing, ...updates, updatedAt: new Date().toISOString() };\n const tableName = getTableName(TABLES.SKILLS, userId);\n\n let query: string;\n let params: any[];\n\n if (userId) {\n query = `UPDATE ${tableName} SET name = ?, description = ?, code = ?, inputSchema = ?, outputSchema = ?, tags = ?, version = ?, isActive = ?, updatedAt = ? WHERE id = ? AND userId = ?`;\n params = [\n updatedSkill.name,\n updatedSkill.description,\n updatedSkill.code,\n serializeJSON(updatedSkill.inputSchema),\n updatedSkill.outputSchema ? serializeJSON(updatedSkill.outputSchema) : null,\n serializeJSON(updatedSkill.tags),\n updatedSkill.version,\n updatedSkill.isActive ? 1 : 0,\n updatedSkill.updatedAt,\n id,\n userId,\n ];\n } else {\n query = `UPDATE ${tableName} SET name = ?, description = ?, code = ?, inputSchema = ?, outputSchema = ?, tags = ?, version = ?, isActive = ?, updatedAt = ? WHERE id = ?`;\n params = [\n updatedSkill.name,\n updatedSkill.description,\n updatedSkill.code,\n serializeJSON(updatedSkill.inputSchema),\n updatedSkill.outputSchema ? serializeJSON(updatedSkill.outputSchema) : null,\n serializeJSON(updatedSkill.tags),\n updatedSkill.version,\n updatedSkill.isActive ? 1 : 0,\n updatedSkill.updatedAt,\n id,\n ];\n }\n\n await sqlite.execute(query, params);\n return updatedSkill;\n}\n\nexport async function listSkills(\n activeOnly: boolean = false,\n userId?: string | null\n): Promise {\n const tableName = getTableName(TABLES.SKILLS, userId);\n \n let query = `SELECT * FROM ${tableName}`;\n const params: any[] = [];\n const conditions: string[] = [];\n\n if (userId) {\n conditions.push(\"userId = ?\");\n params.push(userId);\n }\n\n if (activeOnly) {\n conditions.push(\"isActive = 1\");\n }\n\n if (conditions.length > 0) {\n query += ` WHERE ${conditions.join(\" AND \")}`;\n }\n\n query += ` ORDER BY name ASC`;\n\n const result = await sqlite.execute(query, params);\n\n return result.rows.map((row: any) => ({\n ...row,\n inputSchema: parseJSON(row.inputSchema),\n outputSchema: row.outputSchema ? parseJSON(row.outputSchema) : undefined,\n tags: parseJSON(row.tags),\n isActive: Boolean(row.isActive),\n }));\n}\n\nexport async function deleteSkill(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.SKILLS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `DELETE FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `DELETE FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n return result.changes > 0;\n}\n\n// Skill Execution Queries\nexport async function createSkillExecution(\n execution: Omit,\n userId?: string | null\n): Promise {\n const id = crypto.randomUUID();\n const tableName = getTableName(TABLES.SKILL_EXECUTIONS, userId);\n\n const newExecution: SkillExecution = {\n id,\n ...execution,\n };\n\n if (userId) {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, userId, skillId, input, output, error, duration, executedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n id,\n userId,\n execution.skillId,\n serializeJSON(execution.input),\n execution.output ? serializeJSON(execution.output) : null,\n execution.error || null,\n execution.duration,\n execution.executedAt,\n ]\n );\n } else {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, skillId, input, output, error, duration, executedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?)`,\n [\n id,\n execution.skillId,\n serializeJSON(execution.input),\n execution.output ? serializeJSON(execution.output) : null,\n execution.error || null,\n execution.duration,\n execution.executedAt,\n ]\n );\n }\n\n return newExecution;\n}\n\nexport async function getSkillExecutions(\n skillId: string,\n limit: number = 50,\n userId?: string | null\n): Promise {\n const tableName = getTableName(TABLES.SKILL_EXECUTIONS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `SELECT * FROM ${tableName} WHERE skillId = ? AND userId = ? ORDER BY executedAt DESC LIMIT ?`;\n params = [skillId, userId, limit];\n } else {\n query = `SELECT * FROM ${tableName} WHERE skillId = ? ORDER BY executedAt DESC LIMIT ?`;\n params = [skillId, limit];\n }\n\n const result = await sqlite.execute(query, params);\n\n return result.rows.map((row: any) => ({\n ...row,\n input: parseJSON(row.input),\n output: row.output ? parseJSON(row.output) : undefined,\n }));\n}\n\nexport async function deleteSkillExecution(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.SKILL_EXECUTIONS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `DELETE FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `DELETE FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n return result.changes > 0;\n}",["D",1748707489109],47,{"_103":397,"_159":138,"_156":191,"_95":190,"_166":398,"_164":184,"_100":298,"_158":174,"_105":399,"_160":400,"_168":-5},"c60e4e74-3e38-11f0-9d42-76b3cceeab13","import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport type {\n CognitiveState,\n DBCognitiveState,\n DBGoal,\n DBSkill,\n DBTask,\n DBThoughtFork,\n Goal,\n Skill,\n SkillExecution,\n Task,\n ThoughtExploration,\n ThoughtFork,\n UserScopedThoughtFork,\n UserScopedGoal,\n UserScopedTask,\n UserScopedCognitiveState,\n UserScopedSkill,\n DBUserScopedThoughtFork,\n DBUserScopedGoal,\n DBUserScopedTask,\n DBUserScopedCognitiveState,\n DBUserScopedSkill,\n} from \"../../shared/types.ts\";\nimport { TABLES } from \"./migrations.ts\";\n\n// Utility functions for JSON serialization\nfunction serializeJSON(obj: any): string {\n return JSON.stringify(obj);\n}\n\nfunction parseJSON(str: string): T {\n try {\n return JSON.parse(str);\n } catch {\n return [] as T;\n }\n}\n\n// Helper function to determine which table to use based on user context\nfunction getTableName(baseTable: string, userId?: string | null): string {\n if (userId === null || userId === undefined) {\n // Admin context - use legacy tables\n return baseTable;\n }\n // User context - use user-scoped tables\n switch (baseTable) {\n case TABLES.THOUGHT_FORKS:\n return TABLES.USER_THOUGHT_FORKS;\n case TABLES.THOUGHT_EXPLORATIONS:\n return TABLES.USER_THOUGHT_EXPLORATIONS;\n case TABLES.GOALS:\n return TABLES.USER_GOALS;\n case TABLES.TASKS:\n return TABLES.USER_TASKS;\n case TABLES.COGNITIVE_STATES:\n return TABLES.USER_COGNITIVE_STATES;\n case TABLES.SKILLS:\n return TABLES.USER_SKILLS;\n case TABLES.SKILL_EXECUTIONS:\n return TABLES.USER_SKILL_EXECUTIONS;\n default:\n return baseTable;\n }\n}\n\n// Thought Fork Queries\nexport async function createThoughtFork(\n fork: Omit,\n userId?: string | null\n): Promise {\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n const tableName = getTableName(TABLES.THOUGHT_FORKS, userId);\n\n const baseFields = {\n id,\n parentId: fork.parentId || null,\n title: fork.title,\n description: fork.description,\n explorations: serializeJSON([]), // Start with empty explorations\n mergedInsights: fork.mergedInsights || null,\n status: fork.status,\n createdAt: now,\n updatedAt: now,\n };\n\n if (userId) {\n // User-scoped table\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, userId, parentId, title, description, explorations, mergedInsights, status, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n userId,\n baseFields.parentId,\n baseFields.title,\n baseFields.description,\n baseFields.explorations,\n baseFields.mergedInsights,\n baseFields.status,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n } else {\n // Admin table\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, parentId, title, description, explorations, mergedInsights, status, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n baseFields.parentId,\n baseFields.title,\n baseFields.description,\n baseFields.explorations,\n baseFields.mergedInsights,\n baseFields.status,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n }\n\n return {\n ...baseFields,\n explorations: [],\n };\n}\n\nexport async function getThoughtFork(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.THOUGHT_FORKS, userId);\n const explorationTableName = getTableName(TABLES.THOUGHT_EXPLORATIONS, userId);\n \n let query: string;\n let params: any[];\n \n if (userId) {\n query = `SELECT * FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `SELECT * FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n if (result.length === 0) return null;\n\n const dbFork = result.rows[0] as any;\n \n // Get explorations for this fork\n let explorationQuery: string;\n let explorationParams: any[];\n \n if (userId) {\n explorationQuery = `SELECT * FROM ${explorationTableName} WHERE forkId = ? AND userId = ? ORDER BY createdAt ASC`;\n explorationParams = [id, userId];\n } else {\n explorationQuery = `SELECT * FROM ${explorationTableName} WHERE forkId = ? ORDER BY createdAt ASC`;\n explorationParams = [id];\n }\n\n const explorationResult = await sqlite.execute(explorationQuery, explorationParams);\n const explorations = explorationResult.map((row: any) => ({\n ...row,\n insights: parseJSON(row.insights),\n }));\n\n return {\n id: dbFork.id,\n parentId: dbFork.parentId,\n title: dbFork.title,\n description: dbFork.description,\n explorations,\n mergedInsights: dbFork.mergedInsights,\n status: dbFork.status,\n createdAt: dbFork.createdAt,\n updatedAt: dbFork.updatedAt,\n };\n}\n\nexport async function updateThoughtFork(\n id: string,\n updates: Partial,\n userId?: string | null\n): Promise {\n const existing = await getThoughtFork(id, userId);\n if (!existing) return null;\n\n const updatedFork = { ...existing, ...updates, updatedAt: new Date().toISOString() };\n const tableName = getTableName(TABLES.THOUGHT_FORKS, userId);\n\n let query: string;\n let params: any[];\n\n if (userId) {\n query = `UPDATE ${tableName} SET title = ?, description = ?, mergedInsights = ?, status = ?, updatedAt = ? WHERE id = ? AND userId = ?`;\n params = [\n updatedFork.title,\n updatedFork.description,\n updatedFork.mergedInsights,\n updatedFork.status,\n updatedFork.updatedAt,\n id,\n userId,\n ];\n } else {\n query = `UPDATE ${tableName} SET title = ?, description = ?, mergedInsights = ?, status = ?, updatedAt = ? WHERE id = ?`;\n params = [\n updatedFork.title,\n updatedFork.description,\n updatedFork.mergedInsights,\n updatedFork.status,\n updatedFork.updatedAt,\n id,\n ];\n }\n\n await sqlite.execute(query, params);\n return updatedFork;\n}\n\nexport async function listThoughtForks(\n filters: { status?: string; parentId?: string } = {},\n userId?: string | null\n): Promise {\n const tableName = getTableName(TABLES.THOUGHT_FORKS, userId);\n const { status, parentId } = filters;\n\n let query = `SELECT * FROM ${tableName}`;\n const params: any[] = [];\n const conditions: string[] = [];\n\n if (userId) {\n conditions.push(\"userId = ?\");\n params.push(userId);\n }\n\n if (status) {\n conditions.push(\"status = ?\");\n params.push(status);\n }\n\n if (parentId) {\n conditions.push(\"parentId = ?\");\n params.push(parentId);\n }\n\n if (conditions.length > 0) {\n query += ` WHERE ${conditions.join(\" AND \")}`;\n }\n\n query += ` ORDER BY createdAt DESC`;\n\n const result = await sqlite.execute(query, params);\n\n // Get explorations for each fork\n const forks = await Promise.all(\n result.rows.map(async (row: any) => {\n const fork = await getThoughtFork(row.id, userId);\n return fork!;\n })\n );\n\n return forks;\n}\n\nexport async function deleteThoughtFork(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.THOUGHT_FORKS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `DELETE FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `DELETE FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n return result.changes > 0;\n}\n\n// Thought Exploration Queries\nexport async function createThoughtExploration(\n exploration: Omit,\n userId?: string | null\n): Promise {\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n const tableName = getTableName(TABLES.THOUGHT_EXPLORATIONS, userId);\n\n const newExploration: ThoughtExploration = {\n id,\n ...exploration,\n createdAt: now,\n };\n\n if (userId) {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, userId, forkId, branch, content, insights, confidence, createdAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n id,\n userId,\n exploration.forkId,\n exploration.branch,\n exploration.content,\n serializeJSON(exploration.insights),\n exploration.confidence,\n now,\n ]\n );\n } else {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, forkId, branch, content, insights, confidence, createdAt)\n VALUES (?, ?, ?, ?, ?, ?, ?)`,\n [\n id,\n exploration.forkId,\n exploration.branch,\n exploration.content,\n serializeJSON(exploration.insights),\n exploration.confidence,\n now,\n ]\n );\n }\n\n return newExploration;\n}\n\nexport async function deleteThoughtExploration(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.THOUGHT_EXPLORATIONS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `DELETE FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `DELETE FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n return result.changes > 0;\n}\n\n// Goal Queries\nexport async function createGoal(\n goal: Omit,\n userId?: string | null\n): Promise {\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n const tableName = getTableName(TABLES.GOALS, userId);\n\n const baseFields = {\n id,\n parentId: goal.parentId || null,\n title: goal.title,\n description: goal.description,\n priority: goal.priority,\n status: goal.status,\n progress: goal.progress,\n deadline: goal.deadline || null,\n tags: serializeJSON(goal.tags),\n subGoals: serializeJSON(goal.subGoals),\n tasks: serializeJSON(goal.tasks),\n createdAt: now,\n updatedAt: now,\n };\n\n if (userId) {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, userId, parentId, title, description, priority, status, progress, deadline, tags, subGoals, tasks, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n userId,\n baseFields.parentId,\n baseFields.title,\n baseFields.description,\n baseFields.priority,\n baseFields.status,\n baseFields.progress,\n baseFields.deadline,\n baseFields.tags,\n baseFields.subGoals,\n baseFields.tasks,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n } else {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, parentId, title, description, priority, status, progress, deadline, tags, subGoals, tasks, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n baseFields.parentId,\n baseFields.title,\n baseFields.description,\n baseFields.priority,\n baseFields.status,\n baseFields.progress,\n baseFields.deadline,\n baseFields.tags,\n baseFields.subGoals,\n baseFields.tasks,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n }\n\n return {\n ...baseFields,\n tags: parseJSON(baseFields.tags),\n subGoals: parseJSON(baseFields.subGoals),\n tasks: parseJSON(baseFields.tasks),\n };\n}\n\nexport async function getGoal(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.GOALS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `SELECT * FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `SELECT * FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n if (result.length === 0) return null;\n\n const dbGoal = result.rows[0] as any;\n return {\n ...dbGoal,\n tags: parseJSON(dbGoal.tags),\n subGoals: parseJSON(dbGoal.subGoals),\n tasks: parseJSON(dbGoal.tasks),\n };\n}\n\nexport async function updateGoal(\n id: string,\n updates: Partial,\n userId?: string | null\n): Promise {\n const existing = await getGoal(id, userId);\n if (!existing) return null;\n\n const updatedGoal = { ...existing, ...updates, updatedAt: new Date().toISOString() };\n const tableName = getTableName(TABLES.GOALS, userId);\n\n let query: string;\n let params: any[];\n\n if (userId) {\n query = `UPDATE ${tableName} SET title = ?, description = ?, priority = ?, status = ?, progress = ?, deadline = ?, tags = ?, subGoals = ?, tasks = ?, updatedAt = ? WHERE id = ? AND userId = ?`;\n params = [\n updatedGoal.title,\n updatedGoal.description,\n updatedGoal.priority,\n updatedGoal.status,\n updatedGoal.progress,\n updatedGoal.deadline,\n serializeJSON(updatedGoal.tags),\n serializeJSON(updatedGoal.subGoals),\n serializeJSON(updatedGoal.tasks),\n updatedGoal.updatedAt,\n id,\n userId,\n ];\n } else {\n query = `UPDATE ${tableName} SET title = ?, description = ?, priority = ?, status = ?, progress = ?, deadline = ?, tags = ?, subGoals = ?, tasks = ?, updatedAt = ? WHERE id = ?`;\n params = [\n updatedGoal.title,\n updatedGoal.description,\n updatedGoal.priority,\n updatedGoal.status,\n updatedGoal.progress,\n updatedGoal.deadline,\n serializeJSON(updatedGoal.tags),\n serializeJSON(updatedGoal.subGoals),\n serializeJSON(updatedGoal.tasks),\n updatedGoal.updatedAt,\n id,\n ];\n }\n\n await sqlite.execute(query, params);\n return updatedGoal;\n}\n\nexport async function listGoals(\n filters: { status?: string; parentId?: string } = {},\n userId?: string | null\n): Promise {\n const tableName = getTableName(TABLES.GOALS, userId);\n const { status, parentId } = filters;\n\n let query = `SELECT * FROM ${tableName}`;\n const params: any[] = [];\n const conditions: string[] = [];\n\n if (userId) {\n conditions.push(\"userId = ?\");\n params.push(userId);\n }\n\n if (status) {\n conditions.push(\"status = ?\");\n params.push(status);\n }\n\n if (parentId) {\n conditions.push(\"parentId = ?\");\n params.push(parentId);\n }\n\n if (conditions.length > 0) {\n query += ` WHERE ${conditions.join(\" AND \")}`;\n }\n\n query += ` ORDER BY priority DESC, createdAt DESC`;\n\n const result = await sqlite.execute(query, params);\n\n return result.rows.map((row: any) => ({\n ...row,\n tags: parseJSON(row.tags),\n subGoals: parseJSON(row.subGoals),\n tasks: parseJSON(row.tasks),\n }));\n}\n\nexport async function deleteGoal(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.GOALS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `DELETE FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `DELETE FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n return result.changes > 0;\n}\n\n// Task Queries\nexport async function createTask(\n task: Omit,\n userId?: string | null\n): Promise {\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n const tableName = getTableName(TABLES.TASKS, userId);\n\n const baseFields = {\n id,\n goalId: task.goalId || null,\n title: task.title,\n description: task.description,\n status: task.status,\n priority: task.priority,\n estimatedHours: task.estimatedHours || null,\n actualHours: task.actualHours || null,\n dependencies: serializeJSON(task.dependencies),\n assignee: task.assignee || null,\n dueDate: task.dueDate || null,\n tags: serializeJSON(task.tags),\n createdAt: now,\n updatedAt: now,\n };\n\n if (userId) {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, userId, goalId, title, description, status, priority, estimatedHours, actualHours, dependencies, assignee, dueDate, tags, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n userId,\n baseFields.goalId,\n baseFields.title,\n baseFields.description,\n baseFields.status,\n baseFields.priority,\n baseFields.estimatedHours,\n baseFields.actualHours,\n baseFields.dependencies,\n baseFields.assignee,\n baseFields.dueDate,\n baseFields.tags,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n } else {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, goalId, title, description, status, priority, estimatedHours, actualHours, dependencies, assignee, dueDate, tags, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n baseFields.goalId,\n baseFields.title,\n baseFields.description,\n baseFields.status,\n baseFields.priority,\n baseFields.estimatedHours,\n baseFields.actualHours,\n baseFields.dependencies,\n baseFields.assignee,\n baseFields.dueDate,\n baseFields.tags,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n }\n\n return {\n ...baseFields,\n dependencies: parseJSON(baseFields.dependencies),\n tags: parseJSON(baseFields.tags),\n };\n}\n\nexport async function getTask(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.TASKS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `SELECT * FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `SELECT * FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n if (result.length === 0) return null;\n\n const dbTask = result.rows[0] as any;\n return {\n ...dbTask,\n dependencies: parseJSON(dbTask.dependencies),\n tags: parseJSON(dbTask.tags),\n };\n}\n\nexport async function updateTask(\n id: string,\n updates: Partial,\n userId?: string | null\n): Promise {\n const existing = await getTask(id, userId);\n if (!existing) return null;\n\n const updatedTask = { ...existing, ...updates, updatedAt: new Date().toISOString() };\n const tableName = getTableName(TABLES.TASKS, userId);\n\n let query: string;\n let params: any[];\n\n if (userId) {\n query = `UPDATE ${tableName} SET title = ?, description = ?, status = ?, priority = ?, estimatedHours = ?, actualHours = ?, dependencies = ?, assignee = ?, dueDate = ?, tags = ?, updatedAt = ? WHERE id = ? AND userId = ?`;\n params = [\n updatedTask.title,\n updatedTask.description,\n updatedTask.status,\n updatedTask.priority,\n updatedTask.estimatedHours,\n updatedTask.actualHours,\n serializeJSON(updatedTask.dependencies),\n updatedTask.assignee,\n updatedTask.dueDate,\n serializeJSON(updatedTask.tags),\n updatedTask.updatedAt,\n id,\n userId,\n ];\n } else {\n query = `UPDATE ${tableName} SET title = ?, description = ?, status = ?, priority = ?, estimatedHours = ?, actualHours = ?, dependencies = ?, assignee = ?, dueDate = ?, tags = ?, updatedAt = ? WHERE id = ?`;\n params = [\n updatedTask.title,\n updatedTask.description,\n updatedTask.status,\n updatedTask.priority,\n updatedTask.estimatedHours,\n updatedTask.actualHours,\n serializeJSON(updatedTask.dependencies),\n updatedTask.assignee,\n updatedTask.dueDate,\n serializeJSON(updatedTask.tags),\n updatedTask.updatedAt,\n id,\n ];\n }\n\n await sqlite.execute(query, params);\n return updatedTask;\n}\n\nexport async function listTasks(\n filters: { goalId?: string; status?: string } = {},\n userId?: string | null\n): Promise {\n const tableName = getTableName(TABLES.TASKS, userId);\n const { goalId, status } = filters;\n\n let query = `SELECT * FROM ${tableName}`;\n const params: any[] = [];\n const conditions: string[] = [];\n\n if (userId) {\n conditions.push(\"userId = ?\");\n params.push(userId);\n }\n\n if (goalId) {\n conditions.push(\"goalId = ?\");\n params.push(goalId);\n }\n\n if (status) {\n conditions.push(\"status = ?\");\n params.push(status);\n }\n\n if (conditions.length > 0) {\n query += ` WHERE ${conditions.join(\" AND \")}`;\n }\n\n query += ` ORDER BY priority DESC, createdAt DESC`;\n\n const result = await sqlite.execute(query, params);\n\n return result.rows.map((row: any) => ({\n ...row,\n dependencies: parseJSON(row.dependencies),\n tags: parseJSON(row.tags),\n }));\n}\n\nexport async function deleteTask(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.TASKS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `DELETE FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `DELETE FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n return result.changes > 0;\n}\n\n// Cognitive State Queries\nexport async function createCognitiveState(\n state: Omit,\n userId?: string | null\n): Promise {\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n const tableName = getTableName(TABLES.COGNITIVE_STATES, userId);\n\n const baseFields = {\n id,\n name: state.name,\n description: state.description,\n context: serializeJSON(state.context),\n activeGoals: serializeJSON(state.activeGoals),\n activeTasks: serializeJSON(state.activeTasks),\n thoughtForks: serializeJSON(state.thoughtForks),\n metadata: serializeJSON(state.metadata),\n createdAt: now,\n updatedAt: now,\n };\n\n if (userId) {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, userId, name, description, context, activeGoals, activeTasks, thoughtForks, metadata, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n userId,\n baseFields.name,\n baseFields.description,\n baseFields.context,\n baseFields.activeGoals,\n baseFields.activeTasks,\n baseFields.thoughtForks,\n baseFields.metadata,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n } else {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, name, description, context, activeGoals, activeTasks, thoughtForks, metadata, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n baseFields.name,\n baseFields.description,\n baseFields.context,\n baseFields.activeGoals,\n baseFields.activeTasks,\n baseFields.thoughtForks,\n baseFields.metadata,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n }\n\n return {\n ...baseFields,\n context: parseJSON(baseFields.context),\n activeGoals: parseJSON(baseFields.activeGoals),\n activeTasks: parseJSON(baseFields.activeTasks),\n thoughtForks: parseJSON(baseFields.thoughtForks),\n metadata: parseJSON(baseFields.metadata),\n };\n}\n\nexport async function getCognitiveState(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.COGNITIVE_STATES, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `SELECT * FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `SELECT * FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n if (result.length === 0) return null;\n\n const dbState = result.rows[0] as any;\n return {\n ...dbState,\n context: parseJSON(dbState.context),\n activeGoals: parseJSON(dbState.activeGoals),\n activeTasks: parseJSON(dbState.activeTasks),\n thoughtForks: parseJSON(dbState.thoughtForks),\n metadata: parseJSON(dbState.metadata),\n };\n}\n\nexport async function updateCognitiveState(\n id: string,\n updates: Partial,\n userId?: string | null\n): Promise {\n const existing = await getCognitiveState(id, userId);\n if (!existing) return null;\n\n const updatedState = { ...existing, ...updates, updatedAt: new Date().toISOString() };\n const tableName = getTableName(TABLES.COGNITIVE_STATES, userId);\n\n let query: string;\n let params: any[];\n\n if (userId) {\n query = `UPDATE ${tableName} SET name = ?, description = ?, context = ?, activeGoals = ?, activeTasks = ?, thoughtForks = ?, metadata = ?, updatedAt = ? WHERE id = ? AND userId = ?`;\n params = [\n updatedState.name,\n updatedState.description,\n serializeJSON(updatedState.context),\n serializeJSON(updatedState.activeGoals),\n serializeJSON(updatedState.activeTasks),\n serializeJSON(updatedState.thoughtForks),\n serializeJSON(updatedState.metadata),\n updatedState.updatedAt,\n id,\n userId,\n ];\n } else {\n query = `UPDATE ${tableName} SET name = ?, description = ?, context = ?, activeGoals = ?, activeTasks = ?, thoughtForks = ?, metadata = ?, updatedAt = ? WHERE id = ?`;\n params = [\n updatedState.name,\n updatedState.description,\n serializeJSON(updatedState.context),\n serializeJSON(updatedState.activeGoals),\n serializeJSON(updatedState.activeTasks),\n serializeJSON(updatedState.thoughtForks),\n serializeJSON(updatedState.metadata),\n updatedState.updatedAt,\n id,\n ];\n }\n\n await sqlite.execute(query, params);\n return updatedState;\n}\n\nexport async function listCognitiveStates(userId?: string | null): Promise {\n const tableName = getTableName(TABLES.COGNITIVE_STATES, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `SELECT * FROM ${tableName} WHERE userId = ? ORDER BY updatedAt DESC`;\n params = [userId];\n } else {\n query = `SELECT * FROM ${tableName} ORDER BY updatedAt DESC`;\n params = [];\n }\n\n const result = await sqlite.execute(query, params);\n\n return result.rows.map((row: any) => ({\n ...row,\n context: parseJSON(row.context),\n activeGoals: parseJSON(row.activeGoals),\n activeTasks: parseJSON(row.activeTasks),\n thoughtForks: parseJSON(row.thoughtForks),\n metadata: parseJSON(row.metadata),\n }));\n}\n\nexport async function deleteCognitiveState(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.COGNITIVE_STATES, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `DELETE FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `DELETE FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n return result.changes > 0;\n}\n\n// Skill Queries\nexport async function createSkill(\n skill: Omit,\n userId?: string | null\n): Promise {\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n const tableName = getTableName(TABLES.SKILLS, userId);\n\n const baseFields = {\n id,\n name: skill.name,\n description: skill.description,\n code: skill.code,\n inputSchema: serializeJSON(skill.inputSchema),\n outputSchema: skill.outputSchema ? serializeJSON(skill.outputSchema) : null,\n tags: serializeJSON(skill.tags),\n version: skill.version,\n isActive: skill.isActive ? 1 : 0,\n createdAt: now,\n updatedAt: now,\n };\n\n if (userId) {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, userId, name, description, code, inputSchema, outputSchema, tags, version, isActive, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n userId,\n baseFields.name,\n baseFields.description,\n baseFields.code,\n baseFields.inputSchema,\n baseFields.outputSchema,\n baseFields.tags,\n baseFields.version,\n baseFields.isActive,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n } else {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, name, description, code, inputSchema, outputSchema, tags, version, isActive, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n baseFields.name,\n baseFields.description,\n baseFields.code,\n baseFields.inputSchema,\n baseFields.outputSchema,\n baseFields.tags,\n baseFields.version,\n baseFields.isActive,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n }\n\n return {\n ...baseFields,\n inputSchema: parseJSON(baseFields.inputSchema),\n outputSchema: baseFields.outputSchema ? parseJSON(baseFields.outputSchema) : undefined,\n tags: parseJSON(baseFields.tags),\n isActive: Boolean(baseFields.isActive),\n };\n}\n\nexport async function getSkill(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.SKILLS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `SELECT * FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `SELECT * FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n if (result.length === 0) return null;\n\n const dbSkill = result.rows[0] as any;\n return {\n ...dbSkill,\n inputSchema: parseJSON(dbSkill.inputSchema),\n outputSchema: dbSkill.outputSchema ? parseJSON(dbSkill.outputSchema) : undefined,\n tags: parseJSON(dbSkill.tags),\n isActive: Boolean(dbSkill.isActive),\n };\n}\n\nexport async function getSkillByName(name: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.SKILLS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `SELECT * FROM ${tableName} WHERE name = ? AND userId = ?`;\n params = [name, userId];\n } else {\n query = `SELECT * FROM ${tableName} WHERE name = ?`;\n params = [name];\n }\n\n const result = await sqlite.execute(query, params);\n if (result.length === 0) return null;\n\n const dbSkill = result.rows[0] as any;\n return {\n ...dbSkill,\n inputSchema: parseJSON(dbSkill.inputSchema),\n outputSchema: dbSkill.outputSchema ? parseJSON(dbSkill.outputSchema) : undefined,\n tags: parseJSON(dbSkill.tags),\n isActive: Boolean(dbSkill.isActive),\n };\n}\n\nexport async function updateSkill(\n id: string,\n updates: Partial,\n userId?: string | null\n): Promise {\n const existing = await getSkill(id, userId);\n if (!existing) return null;\n\n const updatedSkill = { ...existing, ...updates, updatedAt: new Date().toISOString() };\n const tableName = getTableName(TABLES.SKILLS, userId);\n\n let query: string;\n let params: any[];\n\n if (userId) {\n query = `UPDATE ${tableName} SET name = ?, description = ?, code = ?, inputSchema = ?, outputSchema = ?, tags = ?, version = ?, isActive = ?, updatedAt = ? WHERE id = ? AND userId = ?`;\n params = [\n updatedSkill.name,\n updatedSkill.description,\n updatedSkill.code,\n serializeJSON(updatedSkill.inputSchema),\n updatedSkill.outputSchema ? serializeJSON(updatedSkill.outputSchema) : null,\n serializeJSON(updatedSkill.tags),\n updatedSkill.version,\n updatedSkill.isActive ? 1 : 0,\n updatedSkill.updatedAt,\n id,\n userId,\n ];\n } else {\n query = `UPDATE ${tableName} SET name = ?, description = ?, code = ?, inputSchema = ?, outputSchema = ?, tags = ?, version = ?, isActive = ?, updatedAt = ? WHERE id = ?`;\n params = [\n updatedSkill.name,\n updatedSkill.description,\n updatedSkill.code,\n serializeJSON(updatedSkill.inputSchema),\n updatedSkill.outputSchema ? serializeJSON(updatedSkill.outputSchema) : null,\n serializeJSON(updatedSkill.tags),\n updatedSkill.version,\n updatedSkill.isActive ? 1 : 0,\n updatedSkill.updatedAt,\n id,\n ];\n }\n\n await sqlite.execute(query, params);\n return updatedSkill;\n}\n\nexport async function listSkills(\n activeOnly: boolean = false,\n userId?: string | null\n): Promise {\n const tableName = getTableName(TABLES.SKILLS, userId);\n \n let query = `SELECT * FROM ${tableName}`;\n const params: any[] = [];\n const conditions: string[] = [];\n\n if (userId) {\n conditions.push(\"userId = ?\");\n params.push(userId);\n }\n\n if (activeOnly) {\n conditions.push(\"isActive = 1\");\n }\n\n if (conditions.length > 0) {\n query += ` WHERE ${conditions.join(\" AND \")}`;\n }\n\n query += ` ORDER BY name ASC`;\n\n const result = await sqlite.execute(query, params);\n\n return result.rows.map((row: any) => ({\n ...row,\n inputSchema: parseJSON(row.inputSchema),\n outputSchema: row.outputSchema ? parseJSON(row.outputSchema) : undefined,\n tags: parseJSON(row.tags),\n isActive: Boolean(row.isActive),\n }));\n}\n\nexport async function deleteSkill(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.SKILLS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `DELETE FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `DELETE FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n return result.changes > 0;\n}\n\n// Skill Execution Queries\nexport async function createSkillExecution(\n execution: Omit,\n userId?: string | null\n): Promise {\n const id = crypto.randomUUID();\n const tableName = getTableName(TABLES.SKILL_EXECUTIONS, userId);\n\n const newExecution: SkillExecution = {\n id,\n ...execution,\n };\n\n if (userId) {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, userId, skillId, input, output, error, duration, executedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n id,\n userId,\n execution.skillId,\n serializeJSON(execution.input),\n execution.output ? serializeJSON(execution.output) : null,\n execution.error || null,\n execution.duration,\n execution.executedAt,\n ]\n );\n } else {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, skillId, input, output, error, duration, executedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?)`,\n [\n id,\n execution.skillId,\n serializeJSON(execution.input),\n execution.output ? serializeJSON(execution.output) : null,\n execution.error || null,\n execution.duration,\n execution.executedAt,\n ]\n );\n }\n\n return newExecution;\n}\n\nexport async function getSkillExecutions(\n skillId: string,\n limit: number = 50,\n userId?: string | null\n): Promise {\n const tableName = getTableName(TABLES.SKILL_EXECUTIONS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `SELECT * FROM ${tableName} WHERE skillId = ? AND userId = ? ORDER BY executedAt DESC LIMIT ?`;\n params = [skillId, userId, limit];\n } else {\n query = `SELECT * FROM ${tableName} WHERE skillId = ? ORDER BY executedAt DESC LIMIT ?`;\n params = [skillId, limit];\n }\n\n const result = await sqlite.execute(query, params);\n\n return result.rows.map((row: any) => ({\n ...row,\n input: parseJSON(row.input),\n output: row.output ? parseJSON(row.output) : undefined,\n }));\n}\n\nexport async function deleteSkillExecution(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.SKILL_EXECUTIONS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `DELETE FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `DELETE FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n return result.changes > 0;\n}",["D",1748707401030],46,{"_103":402,"_159":138,"_156":191,"_95":190,"_166":403,"_164":184,"_100":183,"_158":174,"_105":404,"_160":405,"_168":-5},"b614de02-3e38-11f0-a9e5-76b3cceeab13","import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport type {\n CognitiveState,\n DBCognitiveState,\n DBGoal,\n DBSkill,\n DBTask,\n DBThoughtFork,\n Goal,\n Skill,\n SkillExecution,\n Task,\n ThoughtExploration,\n ThoughtFork,\n UserScopedThoughtFork,\n UserScopedGoal,\n UserScopedTask,\n UserScopedCognitiveState,\n UserScopedSkill,\n DBUserScopedThoughtFork,\n DBUserScopedGoal,\n DBUserScopedTask,\n DBUserScopedCognitiveState,\n DBUserScopedSkill,\n} from \"../../shared/types.ts\";\nimport { TABLES } from \"./migrations.ts\";\n\n// Utility functions for JSON serialization\nfunction serializeJSON(obj: any): string {\n return JSON.stringify(obj);\n}\n\nfunction parseJSON(str: string): T {\n try {\n return JSON.parse(str);\n } catch {\n return [] as T;\n }\n}\n\n// Helper function to determine which table to use based on user context\nfunction getTableName(baseTable: string, userId?: string | null): string {\n if (userId === null || userId === undefined) {\n // Admin context - use legacy tables\n return baseTable;\n }\n // User context - use user-scoped tables\n switch (baseTable) {\n case TABLES.THOUGHT_FORKS:\n return TABLES.USER_THOUGHT_FORKS;\n case TABLES.THOUGHT_EXPLORATIONS:\n return TABLES.USER_THOUGHT_EXPLORATIONS;\n case TABLES.GOALS:\n return TABLES.USER_GOALS;\n case TABLES.TASKS:\n return TABLES.USER_TASKS;\n case TABLES.COGNITIVE_STATES:\n return TABLES.USER_COGNITIVE_STATES;\n case TABLES.SKILLS:\n return TABLES.USER_SKILLS;\n case TABLES.SKILL_EXECUTIONS:\n return TABLES.USER_SKILL_EXECUTIONS;\n default:\n return baseTable;\n }\n}\n\n// Thought Fork Queries\nexport async function createThoughtFork(\n fork: Omit,\n userId?: string | null\n): Promise {\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n const tableName = getTableName(TABLES.THOUGHT_FORKS, userId);\n\n const baseFields = {\n id,\n parentId: fork.parentId || null,\n title: fork.title,\n description: fork.description,\n explorations: serializeJSON([]), // Start with empty explorations\n mergedInsights: fork.mergedInsights || null,\n status: fork.status,\n createdAt: now,\n updatedAt: now,\n };\n\n if (userId) {\n // User-scoped table\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, userId, parentId, title, description, explorations, mergedInsights, status, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n userId,\n baseFields.parentId,\n baseFields.title,\n baseFields.description,\n baseFields.explorations,\n baseFields.mergedInsights,\n baseFields.status,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n } else {\n // Admin table\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, parentId, title, description, explorations, mergedInsights, status, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n baseFields.parentId,\n baseFields.title,\n baseFields.description,\n baseFields.explorations,\n baseFields.mergedInsights,\n baseFields.status,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n }\n\n return {\n ...baseFields,\n explorations: [],\n };\n}\n\nexport async function getThoughtFork(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.THOUGHT_FORKS, userId);\n const explorationTableName = getTableName(TABLES.THOUGHT_EXPLORATIONS, userId);\n \n let query: string;\n let params: any[];\n \n if (userId) {\n query = `SELECT * FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `SELECT * FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n if (result.length === 0) return null;\n\n const dbFork = result.rows[0] as any;\n \n // Get explorations for this fork\n let explorationQuery: string;\n let explorationParams: any[];\n \n if (userId) {\n explorationQuery = `SELECT * FROM ${explorationTableName} WHERE forkId = ? AND userId = ? ORDER BY createdAt ASC`;\n explorationParams = [id, userId];\n } else {\n explorationQuery = `SELECT * FROM ${explorationTableName} WHERE forkId = ? ORDER BY createdAt ASC`;\n explorationParams = [id];\n }\n\n const explorationResult = await sqlite.execute(explorationQuery, explorationParams);\n const explorations = explorationResult.map((row: any) => ({\n ...row,\n insights: parseJSON(row.insights),\n }));\n\n return {\n id: dbFork.id,\n parentId: dbFork.parentId,\n title: dbFork.title,\n description: dbFork.description,\n explorations,\n mergedInsights: dbFork.mergedInsights,\n status: dbFork.status,\n createdAt: dbFork.createdAt,\n updatedAt: dbFork.updatedAt,\n };\n}\n\nexport async function updateThoughtFork(\n id: string,\n updates: Partial,\n userId?: string | null\n): Promise {\n const existing = await getThoughtFork(id, userId);\n if (!existing) return null;\n\n const updatedFork = { ...existing, ...updates, updatedAt: new Date().toISOString() };\n const tableName = getTableName(TABLES.THOUGHT_FORKS, userId);\n\n let query: string;\n let params: any[];\n\n if (userId) {\n query = `UPDATE ${tableName} SET title = ?, description = ?, mergedInsights = ?, status = ?, updatedAt = ? WHERE id = ? AND userId = ?`;\n params = [\n updatedFork.title,\n updatedFork.description,\n updatedFork.mergedInsights,\n updatedFork.status,\n updatedFork.updatedAt,\n id,\n userId,\n ];\n } else {\n query = `UPDATE ${tableName} SET title = ?, description = ?, mergedInsights = ?, status = ?, updatedAt = ? WHERE id = ?`;\n params = [\n updatedFork.title,\n updatedFork.description,\n updatedFork.mergedInsights,\n updatedFork.status,\n updatedFork.updatedAt,\n id,\n ];\n }\n\n await sqlite.execute(query, params);\n return updatedFork;\n}\n\nexport async function listThoughtForks(\n filters: { status?: string; parentId?: string } = {},\n userId?: string | null\n): Promise {\n const tableName = getTableName(TABLES.THOUGHT_FORKS, userId);\n const { status, parentId } = filters;\n\n let query = `SELECT * FROM ${tableName}`;\n const params: any[] = [];\n const conditions: string[] = [];\n\n if (userId) {\n conditions.push(\"userId = ?\");\n params.push(userId);\n }\n\n if (status) {\n conditions.push(\"status = ?\");\n params.push(status);\n }\n\n if (parentId) {\n conditions.push(\"parentId = ?\");\n params.push(parentId);\n }\n\n if (conditions.length > 0) {\n query += ` WHERE ${conditions.join(\" AND \")}`;\n }\n\n query += ` ORDER BY createdAt DESC`;\n\n const result = await sqlite.execute(query, params);\n\n // Get explorations for each fork\n const forks = await Promise.all(\n result.map(async (row: any) => {\n const fork = await getThoughtFork(row.id, userId);\n return fork!;\n })\n );\n\n return forks;\n}\n\nexport async function deleteThoughtFork(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.THOUGHT_FORKS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `DELETE FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `DELETE FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n return result.changes > 0;\n}\n\n// Thought Exploration Queries\nexport async function createThoughtExploration(\n exploration: Omit,\n userId?: string | null\n): Promise {\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n const tableName = getTableName(TABLES.THOUGHT_EXPLORATIONS, userId);\n\n const newExploration: ThoughtExploration = {\n id,\n ...exploration,\n createdAt: now,\n };\n\n if (userId) {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, userId, forkId, branch, content, insights, confidence, createdAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n id,\n userId,\n exploration.forkId,\n exploration.branch,\n exploration.content,\n serializeJSON(exploration.insights),\n exploration.confidence,\n now,\n ]\n );\n } else {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, forkId, branch, content, insights, confidence, createdAt)\n VALUES (?, ?, ?, ?, ?, ?, ?)`,\n [\n id,\n exploration.forkId,\n exploration.branch,\n exploration.content,\n serializeJSON(exploration.insights),\n exploration.confidence,\n now,\n ]\n );\n }\n\n return newExploration;\n}\n\nexport async function deleteThoughtExploration(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.THOUGHT_EXPLORATIONS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `DELETE FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `DELETE FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n return result.changes > 0;\n}\n\n// Goal Queries\nexport async function createGoal(\n goal: Omit,\n userId?: string | null\n): Promise {\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n const tableName = getTableName(TABLES.GOALS, userId);\n\n const baseFields = {\n id,\n parentId: goal.parentId || null,\n title: goal.title,\n description: goal.description,\n priority: goal.priority,\n status: goal.status,\n progress: goal.progress,\n deadline: goal.deadline || null,\n tags: serializeJSON(goal.tags),\n subGoals: serializeJSON(goal.subGoals),\n tasks: serializeJSON(goal.tasks),\n createdAt: now,\n updatedAt: now,\n };\n\n if (userId) {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, userId, parentId, title, description, priority, status, progress, deadline, tags, subGoals, tasks, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n userId,\n baseFields.parentId,\n baseFields.title,\n baseFields.description,\n baseFields.priority,\n baseFields.status,\n baseFields.progress,\n baseFields.deadline,\n baseFields.tags,\n baseFields.subGoals,\n baseFields.tasks,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n } else {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, parentId, title, description, priority, status, progress, deadline, tags, subGoals, tasks, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n baseFields.parentId,\n baseFields.title,\n baseFields.description,\n baseFields.priority,\n baseFields.status,\n baseFields.progress,\n baseFields.deadline,\n baseFields.tags,\n baseFields.subGoals,\n baseFields.tasks,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n }\n\n return {\n ...baseFields,\n tags: parseJSON(baseFields.tags),\n subGoals: parseJSON(baseFields.subGoals),\n tasks: parseJSON(baseFields.tasks),\n };\n}\n\nexport async function getGoal(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.GOALS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `SELECT * FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `SELECT * FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n if (result.length === 0) return null;\n\n const dbGoal = result.rows[0] as any;\n return {\n ...dbGoal,\n tags: parseJSON(dbGoal.tags),\n subGoals: parseJSON(dbGoal.subGoals),\n tasks: parseJSON(dbGoal.tasks),\n };\n}\n\nexport async function updateGoal(\n id: string,\n updates: Partial,\n userId?: string | null\n): Promise {\n const existing = await getGoal(id, userId);\n if (!existing) return null;\n\n const updatedGoal = { ...existing, ...updates, updatedAt: new Date().toISOString() };\n const tableName = getTableName(TABLES.GOALS, userId);\n\n let query: string;\n let params: any[];\n\n if (userId) {\n query = `UPDATE ${tableName} SET title = ?, description = ?, priority = ?, status = ?, progress = ?, deadline = ?, tags = ?, subGoals = ?, tasks = ?, updatedAt = ? WHERE id = ? AND userId = ?`;\n params = [\n updatedGoal.title,\n updatedGoal.description,\n updatedGoal.priority,\n updatedGoal.status,\n updatedGoal.progress,\n updatedGoal.deadline,\n serializeJSON(updatedGoal.tags),\n serializeJSON(updatedGoal.subGoals),\n serializeJSON(updatedGoal.tasks),\n updatedGoal.updatedAt,\n id,\n userId,\n ];\n } else {\n query = `UPDATE ${tableName} SET title = ?, description = ?, priority = ?, status = ?, progress = ?, deadline = ?, tags = ?, subGoals = ?, tasks = ?, updatedAt = ? WHERE id = ?`;\n params = [\n updatedGoal.title,\n updatedGoal.description,\n updatedGoal.priority,\n updatedGoal.status,\n updatedGoal.progress,\n updatedGoal.deadline,\n serializeJSON(updatedGoal.tags),\n serializeJSON(updatedGoal.subGoals),\n serializeJSON(updatedGoal.tasks),\n updatedGoal.updatedAt,\n id,\n ];\n }\n\n await sqlite.execute(query, params);\n return updatedGoal;\n}\n\nexport async function listGoals(\n filters: { status?: string; parentId?: string } = {},\n userId?: string | null\n): Promise {\n const tableName = getTableName(TABLES.GOALS, userId);\n const { status, parentId } = filters;\n\n let query = `SELECT * FROM ${tableName}`;\n const params: any[] = [];\n const conditions: string[] = [];\n\n if (userId) {\n conditions.push(\"userId = ?\");\n params.push(userId);\n }\n\n if (status) {\n conditions.push(\"status = ?\");\n params.push(status);\n }\n\n if (parentId) {\n conditions.push(\"parentId = ?\");\n params.push(parentId);\n }\n\n if (conditions.length > 0) {\n query += ` WHERE ${conditions.join(\" AND \")}`;\n }\n\n query += ` ORDER BY priority DESC, createdAt DESC`;\n\n const result = await sqlite.execute(query, params);\n\n return result.map((row: any) => ({\n ...row,\n tags: parseJSON(row.tags),\n subGoals: parseJSON(row.subGoals),\n tasks: parseJSON(row.tasks),\n }));\n}\n\nexport async function deleteGoal(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.GOALS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `DELETE FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `DELETE FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n return result.changes > 0;\n}\n\n// Task Queries\nexport async function createTask(\n task: Omit,\n userId?: string | null\n): Promise {\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n const tableName = getTableName(TABLES.TASKS, userId);\n\n const baseFields = {\n id,\n goalId: task.goalId || null,\n title: task.title,\n description: task.description,\n status: task.status,\n priority: task.priority,\n estimatedHours: task.estimatedHours || null,\n actualHours: task.actualHours || null,\n dependencies: serializeJSON(task.dependencies),\n assignee: task.assignee || null,\n dueDate: task.dueDate || null,\n tags: serializeJSON(task.tags),\n createdAt: now,\n updatedAt: now,\n };\n\n if (userId) {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, userId, goalId, title, description, status, priority, estimatedHours, actualHours, dependencies, assignee, dueDate, tags, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n userId,\n baseFields.goalId,\n baseFields.title,\n baseFields.description,\n baseFields.status,\n baseFields.priority,\n baseFields.estimatedHours,\n baseFields.actualHours,\n baseFields.dependencies,\n baseFields.assignee,\n baseFields.dueDate,\n baseFields.tags,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n } else {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, goalId, title, description, status, priority, estimatedHours, actualHours, dependencies, assignee, dueDate, tags, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n baseFields.goalId,\n baseFields.title,\n baseFields.description,\n baseFields.status,\n baseFields.priority,\n baseFields.estimatedHours,\n baseFields.actualHours,\n baseFields.dependencies,\n baseFields.assignee,\n baseFields.dueDate,\n baseFields.tags,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n }\n\n return {\n ...baseFields,\n dependencies: parseJSON(baseFields.dependencies),\n tags: parseJSON(baseFields.tags),\n };\n}\n\nexport async function getTask(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.TASKS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `SELECT * FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `SELECT * FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n if (result.length === 0) return null;\n\n const dbTask = result.rows[0] as any;\n return {\n ...dbTask,\n dependencies: parseJSON(dbTask.dependencies),\n tags: parseJSON(dbTask.tags),\n };\n}\n\nexport async function updateTask(\n id: string,\n updates: Partial,\n userId?: string | null\n): Promise {\n const existing = await getTask(id, userId);\n if (!existing) return null;\n\n const updatedTask = { ...existing, ...updates, updatedAt: new Date().toISOString() };\n const tableName = getTableName(TABLES.TASKS, userId);\n\n let query: string;\n let params: any[];\n\n if (userId) {\n query = `UPDATE ${tableName} SET title = ?, description = ?, status = ?, priority = ?, estimatedHours = ?, actualHours = ?, dependencies = ?, assignee = ?, dueDate = ?, tags = ?, updatedAt = ? WHERE id = ? AND userId = ?`;\n params = [\n updatedTask.title,\n updatedTask.description,\n updatedTask.status,\n updatedTask.priority,\n updatedTask.estimatedHours,\n updatedTask.actualHours,\n serializeJSON(updatedTask.dependencies),\n updatedTask.assignee,\n updatedTask.dueDate,\n serializeJSON(updatedTask.tags),\n updatedTask.updatedAt,\n id,\n userId,\n ];\n } else {\n query = `UPDATE ${tableName} SET title = ?, description = ?, status = ?, priority = ?, estimatedHours = ?, actualHours = ?, dependencies = ?, assignee = ?, dueDate = ?, tags = ?, updatedAt = ? WHERE id = ?`;\n params = [\n updatedTask.title,\n updatedTask.description,\n updatedTask.status,\n updatedTask.priority,\n updatedTask.estimatedHours,\n updatedTask.actualHours,\n serializeJSON(updatedTask.dependencies),\n updatedTask.assignee,\n updatedTask.dueDate,\n serializeJSON(updatedTask.tags),\n updatedTask.updatedAt,\n id,\n ];\n }\n\n await sqlite.execute(query, params);\n return updatedTask;\n}\n\nexport async function listTasks(\n filters: { goalId?: string; status?: string } = {},\n userId?: string | null\n): Promise {\n const tableName = getTableName(TABLES.TASKS, userId);\n const { goalId, status } = filters;\n\n let query = `SELECT * FROM ${tableName}`;\n const params: any[] = [];\n const conditions: string[] = [];\n\n if (userId) {\n conditions.push(\"userId = ?\");\n params.push(userId);\n }\n\n if (goalId) {\n conditions.push(\"goalId = ?\");\n params.push(goalId);\n }\n\n if (status) {\n conditions.push(\"status = ?\");\n params.push(status);\n }\n\n if (conditions.length > 0) {\n query += ` WHERE ${conditions.join(\" AND \")}`;\n }\n\n query += ` ORDER BY priority DESC, createdAt DESC`;\n\n const result = await sqlite.execute(query, params);\n\n return result.map((row: any) => ({\n ...row,\n dependencies: parseJSON(row.dependencies),\n tags: parseJSON(row.tags),\n }));\n}\n\nexport async function deleteTask(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.TASKS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `DELETE FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `DELETE FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n return result.changes > 0;\n}\n\n// Cognitive State Queries\nexport async function createCognitiveState(\n state: Omit,\n userId?: string | null\n): Promise {\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n const tableName = getTableName(TABLES.COGNITIVE_STATES, userId);\n\n const baseFields = {\n id,\n name: state.name,\n description: state.description,\n context: serializeJSON(state.context),\n activeGoals: serializeJSON(state.activeGoals),\n activeTasks: serializeJSON(state.activeTasks),\n thoughtForks: serializeJSON(state.thoughtForks),\n metadata: serializeJSON(state.metadata),\n createdAt: now,\n updatedAt: now,\n };\n\n if (userId) {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, userId, name, description, context, activeGoals, activeTasks, thoughtForks, metadata, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n userId,\n baseFields.name,\n baseFields.description,\n baseFields.context,\n baseFields.activeGoals,\n baseFields.activeTasks,\n baseFields.thoughtForks,\n baseFields.metadata,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n } else {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, name, description, context, activeGoals, activeTasks, thoughtForks, metadata, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n baseFields.name,\n baseFields.description,\n baseFields.context,\n baseFields.activeGoals,\n baseFields.activeTasks,\n baseFields.thoughtForks,\n baseFields.metadata,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n }\n\n return {\n ...baseFields,\n context: parseJSON(baseFields.context),\n activeGoals: parseJSON(baseFields.activeGoals),\n activeTasks: parseJSON(baseFields.activeTasks),\n thoughtForks: parseJSON(baseFields.thoughtForks),\n metadata: parseJSON(baseFields.metadata),\n };\n}\n\nexport async function getCognitiveState(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.COGNITIVE_STATES, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `SELECT * FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `SELECT * FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n if (result.length === 0) return null;\n\n const dbState = result.rows[0] as any;\n return {\n ...dbState,\n context: parseJSON(dbState.context),\n activeGoals: parseJSON(dbState.activeGoals),\n activeTasks: parseJSON(dbState.activeTasks),\n thoughtForks: parseJSON(dbState.thoughtForks),\n metadata: parseJSON(dbState.metadata),\n };\n}\n\nexport async function updateCognitiveState(\n id: string,\n updates: Partial,\n userId?: string | null\n): Promise {\n const existing = await getCognitiveState(id, userId);\n if (!existing) return null;\n\n const updatedState = { ...existing, ...updates, updatedAt: new Date().toISOString() };\n const tableName = getTableName(TABLES.COGNITIVE_STATES, userId);\n\n let query: string;\n let params: any[];\n\n if (userId) {\n query = `UPDATE ${tableName} SET name = ?, description = ?, context = ?, activeGoals = ?, activeTasks = ?, thoughtForks = ?, metadata = ?, updatedAt = ? WHERE id = ? AND userId = ?`;\n params = [\n updatedState.name,\n updatedState.description,\n serializeJSON(updatedState.context),\n serializeJSON(updatedState.activeGoals),\n serializeJSON(updatedState.activeTasks),\n serializeJSON(updatedState.thoughtForks),\n serializeJSON(updatedState.metadata),\n updatedState.updatedAt,\n id,\n userId,\n ];\n } else {\n query = `UPDATE ${tableName} SET name = ?, description = ?, context = ?, activeGoals = ?, activeTasks = ?, thoughtForks = ?, metadata = ?, updatedAt = ? WHERE id = ?`;\n params = [\n updatedState.name,\n updatedState.description,\n serializeJSON(updatedState.context),\n serializeJSON(updatedState.activeGoals),\n serializeJSON(updatedState.activeTasks),\n serializeJSON(updatedState.thoughtForks),\n serializeJSON(updatedState.metadata),\n updatedState.updatedAt,\n id,\n ];\n }\n\n await sqlite.execute(query, params);\n return updatedState;\n}\n\nexport async function listCognitiveStates(userId?: string | null): Promise {\n const tableName = getTableName(TABLES.COGNITIVE_STATES, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `SELECT * FROM ${tableName} WHERE userId = ? ORDER BY updatedAt DESC`;\n params = [userId];\n } else {\n query = `SELECT * FROM ${tableName} ORDER BY updatedAt DESC`;\n params = [];\n }\n\n const result = await sqlite.execute(query, params);\n\n return result.map((row: any) => ({\n ...row,\n context: parseJSON(row.context),\n activeGoals: parseJSON(row.activeGoals),\n activeTasks: parseJSON(row.activeTasks),\n thoughtForks: parseJSON(row.thoughtForks),\n metadata: parseJSON(row.metadata),\n }));\n}\n\nexport async function deleteCognitiveState(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.COGNITIVE_STATES, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `DELETE FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `DELETE FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n return result.changes > 0;\n}\n\n// Skill Queries\nexport async function createSkill(\n skill: Omit,\n userId?: string | null\n): Promise {\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n const tableName = getTableName(TABLES.SKILLS, userId);\n\n const baseFields = {\n id,\n name: skill.name,\n description: skill.description,\n code: skill.code,\n inputSchema: serializeJSON(skill.inputSchema),\n outputSchema: skill.outputSchema ? serializeJSON(skill.outputSchema) : null,\n tags: serializeJSON(skill.tags),\n version: skill.version,\n isActive: skill.isActive ? 1 : 0,\n createdAt: now,\n updatedAt: now,\n };\n\n if (userId) {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, userId, name, description, code, inputSchema, outputSchema, tags, version, isActive, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n userId,\n baseFields.name,\n baseFields.description,\n baseFields.code,\n baseFields.inputSchema,\n baseFields.outputSchema,\n baseFields.tags,\n baseFields.version,\n baseFields.isActive,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n } else {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, name, description, code, inputSchema, outputSchema, tags, version, isActive, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n baseFields.name,\n baseFields.description,\n baseFields.code,\n baseFields.inputSchema,\n baseFields.outputSchema,\n baseFields.tags,\n baseFields.version,\n baseFields.isActive,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n }\n\n return {\n ...baseFields,\n inputSchema: parseJSON(baseFields.inputSchema),\n outputSchema: baseFields.outputSchema ? parseJSON(baseFields.outputSchema) : undefined,\n tags: parseJSON(baseFields.tags),\n isActive: Boolean(baseFields.isActive),\n };\n}\n\nexport async function getSkill(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.SKILLS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `SELECT * FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `SELECT * FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n if (result.length === 0) return null;\n\n const dbSkill = result.rows[0] as any;\n return {\n ...dbSkill,\n inputSchema: parseJSON(dbSkill.inputSchema),\n outputSchema: dbSkill.outputSchema ? parseJSON(dbSkill.outputSchema) : undefined,\n tags: parseJSON(dbSkill.tags),\n isActive: Boolean(dbSkill.isActive),\n };\n}\n\nexport async function getSkillByName(name: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.SKILLS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `SELECT * FROM ${tableName} WHERE name = ? AND userId = ?`;\n params = [name, userId];\n } else {\n query = `SELECT * FROM ${tableName} WHERE name = ?`;\n params = [name];\n }\n\n const result = await sqlite.execute(query, params);\n if (result.length === 0) return null;\n\n const dbSkill = result.rows[0] as any;\n return {\n ...dbSkill,\n inputSchema: parseJSON(dbSkill.inputSchema),\n outputSchema: dbSkill.outputSchema ? parseJSON(dbSkill.outputSchema) : undefined,\n tags: parseJSON(dbSkill.tags),\n isActive: Boolean(dbSkill.isActive),\n };\n}\n\nexport async function updateSkill(\n id: string,\n updates: Partial,\n userId?: string | null\n): Promise {\n const existing = await getSkill(id, userId);\n if (!existing) return null;\n\n const updatedSkill = { ...existing, ...updates, updatedAt: new Date().toISOString() };\n const tableName = getTableName(TABLES.SKILLS, userId);\n\n let query: string;\n let params: any[];\n\n if (userId) {\n query = `UPDATE ${tableName} SET name = ?, description = ?, code = ?, inputSchema = ?, outputSchema = ?, tags = ?, version = ?, isActive = ?, updatedAt = ? WHERE id = ? AND userId = ?`;\n params = [\n updatedSkill.name,\n updatedSkill.description,\n updatedSkill.code,\n serializeJSON(updatedSkill.inputSchema),\n updatedSkill.outputSchema ? serializeJSON(updatedSkill.outputSchema) : null,\n serializeJSON(updatedSkill.tags),\n updatedSkill.version,\n updatedSkill.isActive ? 1 : 0,\n updatedSkill.updatedAt,\n id,\n userId,\n ];\n } else {\n query = `UPDATE ${tableName} SET name = ?, description = ?, code = ?, inputSchema = ?, outputSchema = ?, tags = ?, version = ?, isActive = ?, updatedAt = ? WHERE id = ?`;\n params = [\n updatedSkill.name,\n updatedSkill.description,\n updatedSkill.code,\n serializeJSON(updatedSkill.inputSchema),\n updatedSkill.outputSchema ? serializeJSON(updatedSkill.outputSchema) : null,\n serializeJSON(updatedSkill.tags),\n updatedSkill.version,\n updatedSkill.isActive ? 1 : 0,\n updatedSkill.updatedAt,\n id,\n ];\n }\n\n await sqlite.execute(query, params);\n return updatedSkill;\n}\n\nexport async function listSkills(\n activeOnly: boolean = false,\n userId?: string | null\n): Promise {\n const tableName = getTableName(TABLES.SKILLS, userId);\n \n let query = `SELECT * FROM ${tableName}`;\n const params: any[] = [];\n const conditions: string[] = [];\n\n if (userId) {\n conditions.push(\"userId = ?\");\n params.push(userId);\n }\n\n if (activeOnly) {\n conditions.push(\"isActive = 1\");\n }\n\n if (conditions.length > 0) {\n query += ` WHERE ${conditions.join(\" AND \")}`;\n }\n\n query += ` ORDER BY name ASC`;\n\n const result = await sqlite.execute(query, params);\n\n return result.map((row: any) => ({\n ...row,\n inputSchema: parseJSON(row.inputSchema),\n outputSchema: row.outputSchema ? parseJSON(row.outputSchema) : undefined,\n tags: parseJSON(row.tags),\n isActive: Boolean(row.isActive),\n }));\n}\n\nexport async function deleteSkill(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.SKILLS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `DELETE FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `DELETE FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n return result.changes > 0;\n}\n\n// Skill Execution Queries\nexport async function createSkillExecution(\n execution: Omit,\n userId?: string | null\n): Promise {\n const id = crypto.randomUUID();\n const tableName = getTableName(TABLES.SKILL_EXECUTIONS, userId);\n\n const newExecution: SkillExecution = {\n id,\n ...execution,\n };\n\n if (userId) {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, userId, skillId, input, output, error, duration, executedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n id,\n userId,\n execution.skillId,\n serializeJSON(execution.input),\n execution.output ? serializeJSON(execution.output) : null,\n execution.error || null,\n execution.duration,\n execution.executedAt,\n ]\n );\n } else {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, skillId, input, output, error, duration, executedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?)`,\n [\n id,\n execution.skillId,\n serializeJSON(execution.input),\n execution.output ? serializeJSON(execution.output) : null,\n execution.error || null,\n execution.duration,\n execution.executedAt,\n ]\n );\n }\n\n return newExecution;\n}\n\nexport async function getSkillExecutions(\n skillId: string,\n limit: number = 50,\n userId?: string | null\n): Promise {\n const tableName = getTableName(TABLES.SKILL_EXECUTIONS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `SELECT * FROM ${tableName} WHERE skillId = ? AND userId = ? ORDER BY executedAt DESC LIMIT ?`;\n params = [skillId, userId, limit];\n } else {\n query = `SELECT * FROM ${tableName} WHERE skillId = ? ORDER BY executedAt DESC LIMIT ?`;\n params = [skillId, limit];\n }\n\n const result = await sqlite.execute(query, params);\n\n return result.map((row: any) => ({\n ...row,\n input: parseJSON(row.input),\n output: row.output ? parseJSON(row.output) : undefined,\n }));\n}\n\nexport async function deleteSkillExecution(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.SKILL_EXECUTIONS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `DELETE FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `DELETE FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n return result.changes > 0;\n}",["D",1748707374230],45,{"_103":407,"_159":138,"_156":191,"_95":190,"_166":408,"_164":184,"_100":118,"_158":174,"_105":409,"_160":410,"_168":-5},"7b60c6d2-3e23-11f0-a5a9-76b3cceeab13","import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport type {\n CognitiveState,\n DBCognitiveState,\n DBGoal,\n DBSkill,\n DBTask,\n DBThoughtFork,\n Goal,\n Skill,\n SkillExecution,\n Task,\n ThoughtExploration,\n ThoughtFork,\n UserScopedThoughtFork,\n UserScopedGoal,\n UserScopedTask,\n UserScopedCognitiveState,\n UserScopedSkill,\n DBUserScopedThoughtFork,\n DBUserScopedGoal,\n DBUserScopedTask,\n DBUserScopedCognitiveState,\n DBUserScopedSkill,\n} from \"../../shared/types.ts\";\nimport { TABLES } from \"./migrations.ts\";\n\n// Utility functions for JSON serialization\nfunction serializeJSON(obj: any): string {\n return JSON.stringify(obj);\n}\n\nfunction parseJSON(str: string): T {\n try {\n return JSON.parse(str);\n } catch {\n return [] as T;\n }\n}\n\n// Helper function to determine which table to use based on user context\nfunction getTableName(baseTable: string, userId?: string | null): string {\n if (userId === null || userId === undefined) {\n // Admin context - use legacy tables\n return baseTable;\n }\n // User context - use user-scoped tables\n switch (baseTable) {\n case TABLES.THOUGHT_FORKS:\n return TABLES.USER_THOUGHT_FORKS;\n case TABLES.THOUGHT_EXPLORATIONS:\n return TABLES.USER_THOUGHT_EXPLORATIONS;\n case TABLES.GOALS:\n return TABLES.USER_GOALS;\n case TABLES.TASKS:\n return TABLES.USER_TASKS;\n case TABLES.COGNITIVE_STATES:\n return TABLES.USER_COGNITIVE_STATES;\n case TABLES.SKILLS:\n return TABLES.USER_SKILLS;\n case TABLES.SKILL_EXECUTIONS:\n return TABLES.USER_SKILL_EXECUTIONS;\n default:\n return baseTable;\n }\n}\n\n// Thought Fork Queries\nexport async function createThoughtFork(\n fork: Omit,\n userId?: string | null\n): Promise {\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n const tableName = getTableName(TABLES.THOUGHT_FORKS, userId);\n\n const baseFields = {\n id,\n parentId: fork.parentId || null,\n title: fork.title,\n description: fork.description,\n explorations: serializeJSON([]), // Start with empty explorations\n mergedInsights: fork.mergedInsights || null,\n status: fork.status,\n createdAt: now,\n updatedAt: now,\n };\n\n if (userId) {\n // User-scoped table\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, userId, parentId, title, description, explorations, mergedInsights, status, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n userId,\n baseFields.parentId,\n baseFields.title,\n baseFields.description,\n baseFields.explorations,\n baseFields.mergedInsights,\n baseFields.status,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n } else {\n // Admin table\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, parentId, title, description, explorations, mergedInsights, status, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n baseFields.parentId,\n baseFields.title,\n baseFields.description,\n baseFields.explorations,\n baseFields.mergedInsights,\n baseFields.status,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n }\n\n return {\n ...baseFields,\n explorations: [],\n };\n}\n\nexport async function getThoughtFork(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.THOUGHT_FORKS, userId);\n const explorationTableName = getTableName(TABLES.THOUGHT_EXPLORATIONS, userId);\n \n let query: string;\n let params: any[];\n \n if (userId) {\n query = `SELECT * FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `SELECT * FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n if (result.length === 0) return null;\n\n const dbFork = result[0] as any;\n \n // Get explorations for this fork\n let explorationQuery: string;\n let explorationParams: any[];\n \n if (userId) {\n explorationQuery = `SELECT * FROM ${explorationTableName} WHERE forkId = ? AND userId = ? ORDER BY createdAt ASC`;\n explorationParams = [id, userId];\n } else {\n explorationQuery = `SELECT * FROM ${explorationTableName} WHERE forkId = ? ORDER BY createdAt ASC`;\n explorationParams = [id];\n }\n\n const explorationResult = await sqlite.execute(explorationQuery, explorationParams);\n const explorations = explorationResult.map((row: any) => ({\n ...row,\n insights: parseJSON(row.insights),\n }));\n\n return {\n id: dbFork.id,\n parentId: dbFork.parentId,\n title: dbFork.title,\n description: dbFork.description,\n explorations,\n mergedInsights: dbFork.mergedInsights,\n status: dbFork.status,\n createdAt: dbFork.createdAt,\n updatedAt: dbFork.updatedAt,\n };\n}\n\nexport async function updateThoughtFork(\n id: string,\n updates: Partial,\n userId?: string | null\n): Promise {\n const existing = await getThoughtFork(id, userId);\n if (!existing) return null;\n\n const updatedFork = { ...existing, ...updates, updatedAt: new Date().toISOString() };\n const tableName = getTableName(TABLES.THOUGHT_FORKS, userId);\n\n let query: string;\n let params: any[];\n\n if (userId) {\n query = `UPDATE ${tableName} SET title = ?, description = ?, mergedInsights = ?, status = ?, updatedAt = ? WHERE id = ? AND userId = ?`;\n params = [\n updatedFork.title,\n updatedFork.description,\n updatedFork.mergedInsights,\n updatedFork.status,\n updatedFork.updatedAt,\n id,\n userId,\n ];\n } else {\n query = `UPDATE ${tableName} SET title = ?, description = ?, mergedInsights = ?, status = ?, updatedAt = ? WHERE id = ?`;\n params = [\n updatedFork.title,\n updatedFork.description,\n updatedFork.mergedInsights,\n updatedFork.status,\n updatedFork.updatedAt,\n id,\n ];\n }\n\n await sqlite.execute(query, params);\n return updatedFork;\n}\n\nexport async function listThoughtForks(\n filters: { status?: string; parentId?: string } = {},\n userId?: string | null\n): Promise {\n const tableName = getTableName(TABLES.THOUGHT_FORKS, userId);\n const { status, parentId } = filters;\n\n let query = `SELECT * FROM ${tableName}`;\n const params: any[] = [];\n const conditions: string[] = [];\n\n if (userId) {\n conditions.push(\"userId = ?\");\n params.push(userId);\n }\n\n if (status) {\n conditions.push(\"status = ?\");\n params.push(status);\n }\n\n if (parentId) {\n conditions.push(\"parentId = ?\");\n params.push(parentId);\n }\n\n if (conditions.length > 0) {\n query += ` WHERE ${conditions.join(\" AND \")}`;\n }\n\n query += ` ORDER BY createdAt DESC`;\n\n const result = await sqlite.execute(query, params);\n\n // Get explorations for each fork\n const forks = await Promise.all(\n result.map(async (row: any) => {\n const fork = await getThoughtFork(row.id, userId);\n return fork!;\n })\n );\n\n return forks;\n}\n\nexport async function deleteThoughtFork(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.THOUGHT_FORKS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `DELETE FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `DELETE FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n return result.changes > 0;\n}\n\n// Thought Exploration Queries\nexport async function createThoughtExploration(\n exploration: Omit,\n userId?: string | null\n): Promise {\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n const tableName = getTableName(TABLES.THOUGHT_EXPLORATIONS, userId);\n\n const newExploration: ThoughtExploration = {\n id,\n ...exploration,\n createdAt: now,\n };\n\n if (userId) {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, userId, forkId, branch, content, insights, confidence, createdAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n id,\n userId,\n exploration.forkId,\n exploration.branch,\n exploration.content,\n serializeJSON(exploration.insights),\n exploration.confidence,\n now,\n ]\n );\n } else {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, forkId, branch, content, insights, confidence, createdAt)\n VALUES (?, ?, ?, ?, ?, ?, ?)`,\n [\n id,\n exploration.forkId,\n exploration.branch,\n exploration.content,\n serializeJSON(exploration.insights),\n exploration.confidence,\n now,\n ]\n );\n }\n\n return newExploration;\n}\n\nexport async function deleteThoughtExploration(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.THOUGHT_EXPLORATIONS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `DELETE FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `DELETE FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n return result.changes > 0;\n}\n\n// Goal Queries\nexport async function createGoal(\n goal: Omit,\n userId?: string | null\n): Promise {\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n const tableName = getTableName(TABLES.GOALS, userId);\n\n const baseFields = {\n id,\n parentId: goal.parentId || null,\n title: goal.title,\n description: goal.description,\n priority: goal.priority,\n status: goal.status,\n progress: goal.progress,\n deadline: goal.deadline || null,\n tags: serializeJSON(goal.tags),\n subGoals: serializeJSON(goal.subGoals),\n tasks: serializeJSON(goal.tasks),\n createdAt: now,\n updatedAt: now,\n };\n\n if (userId) {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, userId, parentId, title, description, priority, status, progress, deadline, tags, subGoals, tasks, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n userId,\n baseFields.parentId,\n baseFields.title,\n baseFields.description,\n baseFields.priority,\n baseFields.status,\n baseFields.progress,\n baseFields.deadline,\n baseFields.tags,\n baseFields.subGoals,\n baseFields.tasks,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n } else {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, parentId, title, description, priority, status, progress, deadline, tags, subGoals, tasks, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n baseFields.parentId,\n baseFields.title,\n baseFields.description,\n baseFields.priority,\n baseFields.status,\n baseFields.progress,\n baseFields.deadline,\n baseFields.tags,\n baseFields.subGoals,\n baseFields.tasks,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n }\n\n return {\n ...baseFields,\n tags: parseJSON(baseFields.tags),\n subGoals: parseJSON(baseFields.subGoals),\n tasks: parseJSON(baseFields.tasks),\n };\n}\n\nexport async function getGoal(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.GOALS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `SELECT * FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `SELECT * FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n if (result.length === 0) return null;\n\n const dbGoal = result[0] as any;\n return {\n ...dbGoal,\n tags: parseJSON(dbGoal.tags),\n subGoals: parseJSON(dbGoal.subGoals),\n tasks: parseJSON(dbGoal.tasks),\n };\n}\n\nexport async function updateGoal(\n id: string,\n updates: Partial,\n userId?: string | null\n): Promise {\n const existing = await getGoal(id, userId);\n if (!existing) return null;\n\n const updatedGoal = { ...existing, ...updates, updatedAt: new Date().toISOString() };\n const tableName = getTableName(TABLES.GOALS, userId);\n\n let query: string;\n let params: any[];\n\n if (userId) {\n query = `UPDATE ${tableName} SET title = ?, description = ?, priority = ?, status = ?, progress = ?, deadline = ?, tags = ?, subGoals = ?, tasks = ?, updatedAt = ? WHERE id = ? AND userId = ?`;\n params = [\n updatedGoal.title,\n updatedGoal.description,\n updatedGoal.priority,\n updatedGoal.status,\n updatedGoal.progress,\n updatedGoal.deadline,\n serializeJSON(updatedGoal.tags),\n serializeJSON(updatedGoal.subGoals),\n serializeJSON(updatedGoal.tasks),\n updatedGoal.updatedAt,\n id,\n userId,\n ];\n } else {\n query = `UPDATE ${tableName} SET title = ?, description = ?, priority = ?, status = ?, progress = ?, deadline = ?, tags = ?, subGoals = ?, tasks = ?, updatedAt = ? WHERE id = ?`;\n params = [\n updatedGoal.title,\n updatedGoal.description,\n updatedGoal.priority,\n updatedGoal.status,\n updatedGoal.progress,\n updatedGoal.deadline,\n serializeJSON(updatedGoal.tags),\n serializeJSON(updatedGoal.subGoals),\n serializeJSON(updatedGoal.tasks),\n updatedGoal.updatedAt,\n id,\n ];\n }\n\n await sqlite.execute(query, params);\n return updatedGoal;\n}\n\nexport async function listGoals(\n filters: { status?: string; parentId?: string } = {},\n userId?: string | null\n): Promise {\n const tableName = getTableName(TABLES.GOALS, userId);\n const { status, parentId } = filters;\n\n let query = `SELECT * FROM ${tableName}`;\n const params: any[] = [];\n const conditions: string[] = [];\n\n if (userId) {\n conditions.push(\"userId = ?\");\n params.push(userId);\n }\n\n if (status) {\n conditions.push(\"status = ?\");\n params.push(status);\n }\n\n if (parentId) {\n conditions.push(\"parentId = ?\");\n params.push(parentId);\n }\n\n if (conditions.length > 0) {\n query += ` WHERE ${conditions.join(\" AND \")}`;\n }\n\n query += ` ORDER BY priority DESC, createdAt DESC`;\n\n const result = await sqlite.execute(query, params);\n\n return result.map((row: any) => ({\n ...row,\n tags: parseJSON(row.tags),\n subGoals: parseJSON(row.subGoals),\n tasks: parseJSON(row.tasks),\n }));\n}\n\nexport async function deleteGoal(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.GOALS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `DELETE FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `DELETE FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n return result.changes > 0;\n}\n\n// Task Queries\nexport async function createTask(\n task: Omit,\n userId?: string | null\n): Promise {\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n const tableName = getTableName(TABLES.TASKS, userId);\n\n const baseFields = {\n id,\n goalId: task.goalId || null,\n title: task.title,\n description: task.description,\n status: task.status,\n priority: task.priority,\n estimatedHours: task.estimatedHours || null,\n actualHours: task.actualHours || null,\n dependencies: serializeJSON(task.dependencies),\n assignee: task.assignee || null,\n dueDate: task.dueDate || null,\n tags: serializeJSON(task.tags),\n createdAt: now,\n updatedAt: now,\n };\n\n if (userId) {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, userId, goalId, title, description, status, priority, estimatedHours, actualHours, dependencies, assignee, dueDate, tags, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n userId,\n baseFields.goalId,\n baseFields.title,\n baseFields.description,\n baseFields.status,\n baseFields.priority,\n baseFields.estimatedHours,\n baseFields.actualHours,\n baseFields.dependencies,\n baseFields.assignee,\n baseFields.dueDate,\n baseFields.tags,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n } else {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, goalId, title, description, status, priority, estimatedHours, actualHours, dependencies, assignee, dueDate, tags, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n baseFields.goalId,\n baseFields.title,\n baseFields.description,\n baseFields.status,\n baseFields.priority,\n baseFields.estimatedHours,\n baseFields.actualHours,\n baseFields.dependencies,\n baseFields.assignee,\n baseFields.dueDate,\n baseFields.tags,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n }\n\n return {\n ...baseFields,\n dependencies: parseJSON(baseFields.dependencies),\n tags: parseJSON(baseFields.tags),\n };\n}\n\nexport async function getTask(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.TASKS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `SELECT * FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `SELECT * FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n if (result.length === 0) return null;\n\n const dbTask = result[0] as any;\n return {\n ...dbTask,\n dependencies: parseJSON(dbTask.dependencies),\n tags: parseJSON(dbTask.tags),\n };\n}\n\nexport async function updateTask(\n id: string,\n updates: Partial,\n userId?: string | null\n): Promise {\n const existing = await getTask(id, userId);\n if (!existing) return null;\n\n const updatedTask = { ...existing, ...updates, updatedAt: new Date().toISOString() };\n const tableName = getTableName(TABLES.TASKS, userId);\n\n let query: string;\n let params: any[];\n\n if (userId) {\n query = `UPDATE ${tableName} SET title = ?, description = ?, status = ?, priority = ?, estimatedHours = ?, actualHours = ?, dependencies = ?, assignee = ?, dueDate = ?, tags = ?, updatedAt = ? WHERE id = ? AND userId = ?`;\n params = [\n updatedTask.title,\n updatedTask.description,\n updatedTask.status,\n updatedTask.priority,\n updatedTask.estimatedHours,\n updatedTask.actualHours,\n serializeJSON(updatedTask.dependencies),\n updatedTask.assignee,\n updatedTask.dueDate,\n serializeJSON(updatedTask.tags),\n updatedTask.updatedAt,\n id,\n userId,\n ];\n } else {\n query = `UPDATE ${tableName} SET title = ?, description = ?, status = ?, priority = ?, estimatedHours = ?, actualHours = ?, dependencies = ?, assignee = ?, dueDate = ?, tags = ?, updatedAt = ? WHERE id = ?`;\n params = [\n updatedTask.title,\n updatedTask.description,\n updatedTask.status,\n updatedTask.priority,\n updatedTask.estimatedHours,\n updatedTask.actualHours,\n serializeJSON(updatedTask.dependencies),\n updatedTask.assignee,\n updatedTask.dueDate,\n serializeJSON(updatedTask.tags),\n updatedTask.updatedAt,\n id,\n ];\n }\n\n await sqlite.execute(query, params);\n return updatedTask;\n}\n\nexport async function listTasks(\n filters: { goalId?: string; status?: string } = {},\n userId?: string | null\n): Promise {\n const tableName = getTableName(TABLES.TASKS, userId);\n const { goalId, status } = filters;\n\n let query = `SELECT * FROM ${tableName}`;\n const params: any[] = [];\n const conditions: string[] = [];\n\n if (userId) {\n conditions.push(\"userId = ?\");\n params.push(userId);\n }\n\n if (goalId) {\n conditions.push(\"goalId = ?\");\n params.push(goalId);\n }\n\n if (status) {\n conditions.push(\"status = ?\");\n params.push(status);\n }\n\n if (conditions.length > 0) {\n query += ` WHERE ${conditions.join(\" AND \")}`;\n }\n\n query += ` ORDER BY priority DESC, createdAt DESC`;\n\n const result = await sqlite.execute(query, params);\n\n return result.map((row: any) => ({\n ...row,\n dependencies: parseJSON(row.dependencies),\n tags: parseJSON(row.tags),\n }));\n}\n\nexport async function deleteTask(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.TASKS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `DELETE FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `DELETE FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n return result.changes > 0;\n}\n\n// Cognitive State Queries\nexport async function createCognitiveState(\n state: Omit,\n userId?: string | null\n): Promise {\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n const tableName = getTableName(TABLES.COGNITIVE_STATES, userId);\n\n const baseFields = {\n id,\n name: state.name,\n description: state.description,\n context: serializeJSON(state.context),\n activeGoals: serializeJSON(state.activeGoals),\n activeTasks: serializeJSON(state.activeTasks),\n thoughtForks: serializeJSON(state.thoughtForks),\n metadata: serializeJSON(state.metadata),\n createdAt: now,\n updatedAt: now,\n };\n\n if (userId) {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, userId, name, description, context, activeGoals, activeTasks, thoughtForks, metadata, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n userId,\n baseFields.name,\n baseFields.description,\n baseFields.context,\n baseFields.activeGoals,\n baseFields.activeTasks,\n baseFields.thoughtForks,\n baseFields.metadata,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n } else {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, name, description, context, activeGoals, activeTasks, thoughtForks, metadata, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n baseFields.name,\n baseFields.description,\n baseFields.context,\n baseFields.activeGoals,\n baseFields.activeTasks,\n baseFields.thoughtForks,\n baseFields.metadata,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n }\n\n return {\n ...baseFields,\n context: parseJSON(baseFields.context),\n activeGoals: parseJSON(baseFields.activeGoals),\n activeTasks: parseJSON(baseFields.activeTasks),\n thoughtForks: parseJSON(baseFields.thoughtForks),\n metadata: parseJSON(baseFields.metadata),\n };\n}\n\nexport async function getCognitiveState(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.COGNITIVE_STATES, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `SELECT * FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `SELECT * FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n if (result.length === 0) return null;\n\n const dbState = result[0] as any;\n return {\n ...dbState,\n context: parseJSON(dbState.context),\n activeGoals: parseJSON(dbState.activeGoals),\n activeTasks: parseJSON(dbState.activeTasks),\n thoughtForks: parseJSON(dbState.thoughtForks),\n metadata: parseJSON(dbState.metadata),\n };\n}\n\nexport async function updateCognitiveState(\n id: string,\n updates: Partial,\n userId?: string | null\n): Promise {\n const existing = await getCognitiveState(id, userId);\n if (!existing) return null;\n\n const updatedState = { ...existing, ...updates, updatedAt: new Date().toISOString() };\n const tableName = getTableName(TABLES.COGNITIVE_STATES, userId);\n\n let query: string;\n let params: any[];\n\n if (userId) {\n query = `UPDATE ${tableName} SET name = ?, description = ?, context = ?, activeGoals = ?, activeTasks = ?, thoughtForks = ?, metadata = ?, updatedAt = ? WHERE id = ? AND userId = ?`;\n params = [\n updatedState.name,\n updatedState.description,\n serializeJSON(updatedState.context),\n serializeJSON(updatedState.activeGoals),\n serializeJSON(updatedState.activeTasks),\n serializeJSON(updatedState.thoughtForks),\n serializeJSON(updatedState.metadata),\n updatedState.updatedAt,\n id,\n userId,\n ];\n } else {\n query = `UPDATE ${tableName} SET name = ?, description = ?, context = ?, activeGoals = ?, activeTasks = ?, thoughtForks = ?, metadata = ?, updatedAt = ? WHERE id = ?`;\n params = [\n updatedState.name,\n updatedState.description,\n serializeJSON(updatedState.context),\n serializeJSON(updatedState.activeGoals),\n serializeJSON(updatedState.activeTasks),\n serializeJSON(updatedState.thoughtForks),\n serializeJSON(updatedState.metadata),\n updatedState.updatedAt,\n id,\n ];\n }\n\n await sqlite.execute(query, params);\n return updatedState;\n}\n\nexport async function listCognitiveStates(userId?: string | null): Promise {\n const tableName = getTableName(TABLES.COGNITIVE_STATES, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `SELECT * FROM ${tableName} WHERE userId = ? ORDER BY updatedAt DESC`;\n params = [userId];\n } else {\n query = `SELECT * FROM ${tableName} ORDER BY updatedAt DESC`;\n params = [];\n }\n\n const result = await sqlite.execute(query, params);\n\n return result.map((row: any) => ({\n ...row,\n context: parseJSON(row.context),\n activeGoals: parseJSON(row.activeGoals),\n activeTasks: parseJSON(row.activeTasks),\n thoughtForks: parseJSON(row.thoughtForks),\n metadata: parseJSON(row.metadata),\n }));\n}\n\nexport async function deleteCognitiveState(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.COGNITIVE_STATES, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `DELETE FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `DELETE FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n return result.changes > 0;\n}\n\n// Skill Queries\nexport async function createSkill(\n skill: Omit,\n userId?: string | null\n): Promise {\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n const tableName = getTableName(TABLES.SKILLS, userId);\n\n const baseFields = {\n id,\n name: skill.name,\n description: skill.description,\n code: skill.code,\n inputSchema: serializeJSON(skill.inputSchema),\n outputSchema: skill.outputSchema ? serializeJSON(skill.outputSchema) : null,\n tags: serializeJSON(skill.tags),\n version: skill.version,\n isActive: skill.isActive ? 1 : 0,\n createdAt: now,\n updatedAt: now,\n };\n\n if (userId) {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, userId, name, description, code, inputSchema, outputSchema, tags, version, isActive, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n userId,\n baseFields.name,\n baseFields.description,\n baseFields.code,\n baseFields.inputSchema,\n baseFields.outputSchema,\n baseFields.tags,\n baseFields.version,\n baseFields.isActive,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n } else {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, name, description, code, inputSchema, outputSchema, tags, version, isActive, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n baseFields.id,\n baseFields.name,\n baseFields.description,\n baseFields.code,\n baseFields.inputSchema,\n baseFields.outputSchema,\n baseFields.tags,\n baseFields.version,\n baseFields.isActive,\n baseFields.createdAt,\n baseFields.updatedAt,\n ]\n );\n }\n\n return {\n ...baseFields,\n inputSchema: parseJSON(baseFields.inputSchema),\n outputSchema: baseFields.outputSchema ? parseJSON(baseFields.outputSchema) : undefined,\n tags: parseJSON(baseFields.tags),\n isActive: Boolean(baseFields.isActive),\n };\n}\n\nexport async function getSkill(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.SKILLS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `SELECT * FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `SELECT * FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n if (result.length === 0) return null;\n\n const dbSkill = result[0] as any;\n return {\n ...dbSkill,\n inputSchema: parseJSON(dbSkill.inputSchema),\n outputSchema: dbSkill.outputSchema ? parseJSON(dbSkill.outputSchema) : undefined,\n tags: parseJSON(dbSkill.tags),\n isActive: Boolean(dbSkill.isActive),\n };\n}\n\nexport async function getSkillByName(name: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.SKILLS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `SELECT * FROM ${tableName} WHERE name = ? AND userId = ?`;\n params = [name, userId];\n } else {\n query = `SELECT * FROM ${tableName} WHERE name = ?`;\n params = [name];\n }\n\n const result = await sqlite.execute(query, params);\n if (result.length === 0) return null;\n\n const dbSkill = result[0] as any;\n return {\n ...dbSkill,\n inputSchema: parseJSON(dbSkill.inputSchema),\n outputSchema: dbSkill.outputSchema ? parseJSON(dbSkill.outputSchema) : undefined,\n tags: parseJSON(dbSkill.tags),\n isActive: Boolean(dbSkill.isActive),\n };\n}\n\nexport async function updateSkill(\n id: string,\n updates: Partial,\n userId?: string | null\n): Promise {\n const existing = await getSkill(id, userId);\n if (!existing) return null;\n\n const updatedSkill = { ...existing, ...updates, updatedAt: new Date().toISOString() };\n const tableName = getTableName(TABLES.SKILLS, userId);\n\n let query: string;\n let params: any[];\n\n if (userId) {\n query = `UPDATE ${tableName} SET name = ?, description = ?, code = ?, inputSchema = ?, outputSchema = ?, tags = ?, version = ?, isActive = ?, updatedAt = ? WHERE id = ? AND userId = ?`;\n params = [\n updatedSkill.name,\n updatedSkill.description,\n updatedSkill.code,\n serializeJSON(updatedSkill.inputSchema),\n updatedSkill.outputSchema ? serializeJSON(updatedSkill.outputSchema) : null,\n serializeJSON(updatedSkill.tags),\n updatedSkill.version,\n updatedSkill.isActive ? 1 : 0,\n updatedSkill.updatedAt,\n id,\n userId,\n ];\n } else {\n query = `UPDATE ${tableName} SET name = ?, description = ?, code = ?, inputSchema = ?, outputSchema = ?, tags = ?, version = ?, isActive = ?, updatedAt = ? WHERE id = ?`;\n params = [\n updatedSkill.name,\n updatedSkill.description,\n updatedSkill.code,\n serializeJSON(updatedSkill.inputSchema),\n updatedSkill.outputSchema ? serializeJSON(updatedSkill.outputSchema) : null,\n serializeJSON(updatedSkill.tags),\n updatedSkill.version,\n updatedSkill.isActive ? 1 : 0,\n updatedSkill.updatedAt,\n id,\n ];\n }\n\n await sqlite.execute(query, params);\n return updatedSkill;\n}\n\nexport async function listSkills(\n activeOnly: boolean = false,\n userId?: string | null\n): Promise {\n const tableName = getTableName(TABLES.SKILLS, userId);\n \n let query = `SELECT * FROM ${tableName}`;\n const params: any[] = [];\n const conditions: string[] = [];\n\n if (userId) {\n conditions.push(\"userId = ?\");\n params.push(userId);\n }\n\n if (activeOnly) {\n conditions.push(\"isActive = 1\");\n }\n\n if (conditions.length > 0) {\n query += ` WHERE ${conditions.join(\" AND \")}`;\n }\n\n query += ` ORDER BY name ASC`;\n\n const result = await sqlite.execute(query, params);\n\n return result.map((row: any) => ({\n ...row,\n inputSchema: parseJSON(row.inputSchema),\n outputSchema: row.outputSchema ? parseJSON(row.outputSchema) : undefined,\n tags: parseJSON(row.tags),\n isActive: Boolean(row.isActive),\n }));\n}\n\nexport async function deleteSkill(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.SKILLS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `DELETE FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `DELETE FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n return result.changes > 0;\n}\n\n// Skill Execution Queries\nexport async function createSkillExecution(\n execution: Omit,\n userId?: string | null\n): Promise {\n const id = crypto.randomUUID();\n const tableName = getTableName(TABLES.SKILL_EXECUTIONS, userId);\n\n const newExecution: SkillExecution = {\n id,\n ...execution,\n };\n\n if (userId) {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, userId, skillId, input, output, error, duration, executedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n id,\n userId,\n execution.skillId,\n serializeJSON(execution.input),\n execution.output ? serializeJSON(execution.output) : null,\n execution.error || null,\n execution.duration,\n execution.executedAt,\n ]\n );\n } else {\n await sqlite.execute(\n `INSERT INTO ${tableName} (id, skillId, input, output, error, duration, executedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?)`,\n [\n id,\n execution.skillId,\n serializeJSON(execution.input),\n execution.output ? serializeJSON(execution.output) : null,\n execution.error || null,\n execution.duration,\n execution.executedAt,\n ]\n );\n }\n\n return newExecution;\n}\n\nexport async function getSkillExecutions(\n skillId: string,\n limit: number = 50,\n userId?: string | null\n): Promise {\n const tableName = getTableName(TABLES.SKILL_EXECUTIONS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `SELECT * FROM ${tableName} WHERE skillId = ? AND userId = ? ORDER BY executedAt DESC LIMIT ?`;\n params = [skillId, userId, limit];\n } else {\n query = `SELECT * FROM ${tableName} WHERE skillId = ? ORDER BY executedAt DESC LIMIT ?`;\n params = [skillId, limit];\n }\n\n const result = await sqlite.execute(query, params);\n\n return result.map((row: any) => ({\n ...row,\n input: parseJSON(row.input),\n output: row.output ? parseJSON(row.output) : undefined,\n }));\n}\n\nexport async function deleteSkillExecution(id: string, userId?: string | null): Promise {\n const tableName = getTableName(TABLES.SKILL_EXECUTIONS, userId);\n \n let query: string;\n let params: any[];\n\n if (userId) {\n query = `DELETE FROM ${tableName} WHERE id = ? AND userId = ?`;\n params = [id, userId];\n } else {\n query = `DELETE FROM ${tableName} WHERE id = ?`;\n params = [id];\n }\n\n const result = await sqlite.execute(query, params);\n return result.changes > 0;\n}",["D",1748698256310],24,{"_103":412,"_159":138,"_156":191,"_95":190,"_166":413,"_164":184,"_100":32,"_158":174,"_105":414,"_160":118,"_168":-5},"48820d28-3e20-11f0-a873-76b3cceeab13","import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport type {\n CognitiveState,\n DBCognitiveState,\n DBGoal,\n DBSkill,\n DBTask,\n DBThoughtFork,\n Goal,\n Skill,\n SkillExecution,\n Task,\n ThoughtExploration,\n ThoughtFork,\n} from \"../../shared/types.ts\";\nimport { TABLES } from \"./migrations.ts\";\n\n// Utility functions for JSON serialization\nfunction serializeJSON(obj: any): string {\n return JSON.stringify(obj);\n}\n\nfunction parseJSON(str: string): T {\n try {\n return JSON.parse(str);\n } catch {\n return [] as T;\n }\n}\n\n// Thought Fork Queries\nexport async function createThoughtFork(\n fork: Omit,\n): Promise {\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n\n const dbFork: DBThoughtFork = {\n id,\n parentId: fork.parentId || null,\n title: fork.title,\n description: fork.description,\n explorations: serializeJSON(fork.explorations),\n mergedInsights: fork.mergedInsights || null,\n status: fork.status,\n createdAt: now,\n updatedAt: now,\n };\n\n await sqlite.execute(\n `INSERT INTO ${TABLES.THOUGHT_FORKS} (id, parentId, title, description, explorations, mergedInsights, status, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n dbFork.id,\n dbFork.parentId,\n dbFork.title,\n dbFork.description,\n dbFork.explorations,\n dbFork.mergedInsights,\n dbFork.status,\n dbFork.createdAt,\n dbFork.updatedAt,\n ],\n );\n\n return {\n ...dbFork,\n explorations: parseJSON(dbFork.explorations),\n };\n}\n\nexport async function getThoughtFork(id: string): Promise {\n const result = await sqlite.execute(`SELECT * FROM ${TABLES.THOUGHT_FORKS} WHERE id = ?`, [id]);\n if (result.rows.length === 0) return null;\n\n const dbFork = result.rows[0] as DBThoughtFork;\n return {\n ...dbFork,\n explorations: parseJSON(dbFork.explorations),\n };\n}\n\nexport async function updateThoughtFork(id: string, updates: Partial): Promise {\n const existing = await getThoughtFork(id);\n if (!existing) return null;\n\n const updatedFork = { ...existing, ...updates, updatedAt: new Date().toISOString() };\n const dbFork: DBThoughtFork = {\n ...updatedFork,\n explorations: serializeJSON(updatedFork.explorations),\n };\n\n await sqlite.execute(\n `UPDATE ${TABLES.THOUGHT_FORKS} SET title = ?, description = ?, explorations = ?, mergedInsights = ?, status = ?, updatedAt = ?\n WHERE id = ?`,\n [dbFork.title, dbFork.description, dbFork.explorations, dbFork.mergedInsights, dbFork.status, dbFork.updatedAt, id],\n );\n\n return updatedFork;\n}\n\nexport async function listThoughtForks(status?: string): Promise {\n const query = status\n ? `SELECT * FROM ${TABLES.THOUGHT_FORKS} WHERE status = ? ORDER BY createdAt DESC`\n : `SELECT * FROM ${TABLES.THOUGHT_FORKS} ORDER BY createdAt DESC`;\n\n const params = status ? [status] : [];\n const result = await sqlite.execute(query, params);\n\n return result.rows.map((row: DBThoughtFork) => ({\n ...row,\n explorations: parseJSON(row.explorations),\n }));\n}\n\n// Thought Exploration Queries\nexport async function createThoughtExploration(\n exploration: Omit,\n): Promise {\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n\n const newExploration: ThoughtExploration = {\n id,\n ...exploration,\n createdAt: now,\n };\n\n await sqlite.execute(\n `INSERT INTO ${TABLES.THOUGHT_EXPLORATIONS} (id, forkId, branch, content, insights, confidence, createdAt)\n VALUES (?, ?, ?, ?, ?, ?, ?)`,\n [\n id,\n exploration.forkId,\n exploration.branch,\n exploration.content,\n serializeJSON(exploration.insights),\n exploration.confidence,\n now,\n ],\n );\n\n return newExploration;\n}\n\nexport async function getThoughtExplorations(forkId: string): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLES.THOUGHT_EXPLORATIONS} WHERE forkId = ? ORDER BY createdAt ASC`,\n [forkId],\n );\n\n return result.rows.map((row: any) => ({\n ...row,\n insights: parseJSON(row.insights),\n }));\n}\n\n// Goal Queries\nexport async function createGoal(goal: Omit): Promise {\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n\n const dbGoal: DBGoal = {\n id,\n parentId: goal.parentId || null,\n title: goal.title,\n description: goal.description,\n priority: goal.priority,\n status: goal.status,\n progress: goal.progress,\n deadline: goal.deadline || null,\n tags: serializeJSON(goal.tags),\n subGoals: serializeJSON(goal.subGoals),\n tasks: serializeJSON(goal.tasks),\n createdAt: now,\n updatedAt: now,\n };\n\n await sqlite.execute(\n `INSERT INTO ${TABLES.GOALS} (id, parentId, title, description, priority, status, progress, deadline, tags, subGoals, tasks, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n dbGoal.id,\n dbGoal.parentId,\n dbGoal.title,\n dbGoal.description,\n dbGoal.priority,\n dbGoal.status,\n dbGoal.progress,\n dbGoal.deadline,\n dbGoal.tags,\n dbGoal.subGoals,\n dbGoal.tasks,\n dbGoal.createdAt,\n dbGoal.updatedAt,\n ],\n );\n\n return {\n ...dbGoal,\n tags: parseJSON(dbGoal.tags),\n subGoals: parseJSON(dbGoal.subGoals),\n tasks: parseJSON(dbGoal.tasks),\n };\n}\n\nexport async function getGoal(id: string): Promise {\n const result = await sqlite.execute(`SELECT * FROM ${TABLES.GOALS} WHERE id = ?`, [id]);\n if (result.rows.length === 0) return null;\n\n const dbGoal = result.rows[0] as DBGoal;\n return {\n ...dbGoal,\n tags: parseJSON(dbGoal.tags),\n subGoals: parseJSON(dbGoal.subGoals),\n tasks: parseJSON(dbGoal.tasks),\n };\n}\n\nexport async function updateGoal(id: string, updates: Partial): Promise {\n const existing = await getGoal(id);\n if (!existing) return null;\n\n const updatedGoal = { ...existing, ...updates, updatedAt: new Date().toISOString() };\n const dbGoal: DBGoal = {\n ...updatedGoal,\n tags: serializeJSON(updatedGoal.tags),\n subGoals: serializeJSON(updatedGoal.subGoals),\n tasks: serializeJSON(updatedGoal.tasks),\n };\n\n await sqlite.execute(\n `UPDATE ${TABLES.GOALS} SET title = ?, description = ?, priority = ?, status = ?, progress = ?, deadline = ?, tags = ?, subGoals = ?, tasks = ?, updatedAt = ?\n WHERE id = ?`,\n [\n dbGoal.title,\n dbGoal.description,\n dbGoal.priority,\n dbGoal.status,\n dbGoal.progress,\n dbGoal.deadline,\n dbGoal.tags,\n dbGoal.subGoals,\n dbGoal.tasks,\n dbGoal.updatedAt,\n id,\n ],\n );\n\n return updatedGoal;\n}\n\nexport async function listGoals(status?: string): Promise {\n const query = status\n ? `SELECT * FROM ${TABLES.GOALS} WHERE status = ? ORDER BY priority DESC, createdAt DESC`\n : `SELECT * FROM ${TABLES.GOALS} ORDER BY priority DESC, createdAt DESC`;\n\n const params = status ? [status] : [];\n const result = await sqlite.execute(query, params);\n\n return result.rows.map((row: DBGoal) => ({\n ...row,\n tags: parseJSON(row.tags),\n subGoals: parseJSON(row.subGoals),\n tasks: parseJSON(row.tasks),\n }));\n}\n\n// Task Queries\nexport async function createTask(task: Omit): Promise {\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n\n const dbTask: DBTask = {\n id,\n goalId: task.goalId || null,\n title: task.title,\n description: task.description,\n status: task.status,\n priority: task.priority,\n estimatedHours: task.estimatedHours || null,\n actualHours: task.actualHours || null,\n dependencies: serializeJSON(task.dependencies),\n assignee: task.assignee || null,\n dueDate: task.dueDate || null,\n tags: serializeJSON(task.tags),\n createdAt: now,\n updatedAt: now,\n };\n\n await sqlite.execute(\n `INSERT INTO ${TABLES.TASKS} (id, goalId, title, description, status, priority, estimatedHours, actualHours, dependencies, assignee, dueDate, tags, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n dbTask.id,\n dbTask.goalId,\n dbTask.title,\n dbTask.description,\n dbTask.status,\n dbTask.priority,\n dbTask.estimatedHours,\n dbTask.actualHours,\n dbTask.dependencies,\n dbTask.assignee,\n dbTask.dueDate,\n dbTask.tags,\n dbTask.createdAt,\n dbTask.updatedAt,\n ],\n );\n\n return {\n ...dbTask,\n dependencies: parseJSON(dbTask.dependencies),\n tags: parseJSON(dbTask.tags),\n };\n}\n\nexport async function getTask(id: string): Promise {\n const result = await sqlite.execute(`SELECT * FROM ${TABLES.TASKS} WHERE id = ?`, [id]);\n if (result.rows.length === 0) return null;\n\n const dbTask = result.rows[0] as DBTask;\n return {\n ...dbTask,\n dependencies: parseJSON(dbTask.dependencies),\n tags: parseJSON(dbTask.tags),\n };\n}\n\nexport async function updateTask(id: string, updates: Partial): Promise {\n const existing = await getTask(id);\n if (!existing) return null;\n\n const updatedTask = { ...existing, ...updates, updatedAt: new Date().toISOString() };\n const dbTask: DBTask = {\n ...updatedTask,\n dependencies: serializeJSON(updatedTask.dependencies),\n tags: serializeJSON(updatedTask.tags),\n };\n\n await sqlite.execute(\n `UPDATE ${TABLES.TASKS} SET title = ?, description = ?, status = ?, priority = ?, estimatedHours = ?, actualHours = ?, dependencies = ?, assignee = ?, dueDate = ?, tags = ?, updatedAt = ?\n WHERE id = ?`,\n [\n dbTask.title,\n dbTask.description,\n dbTask.status,\n dbTask.priority,\n dbTask.estimatedHours,\n dbTask.actualHours,\n dbTask.dependencies,\n dbTask.assignee,\n dbTask.dueDate,\n dbTask.tags,\n dbTask.updatedAt,\n id,\n ],\n );\n\n return updatedTask;\n}\n\nexport async function listTasks(goalId?: string, status?: string): Promise {\n let query = `SELECT * FROM ${TABLES.TASKS}`;\n const params: any[] = [];\n const conditions: string[] = [];\n\n if (goalId) {\n conditions.push(\"goalId = ?\");\n params.push(goalId);\n }\n\n if (status) {\n conditions.push(\"status = ?\");\n params.push(status);\n }\n\n if (conditions.length > 0) {\n query += ` WHERE ${conditions.join(\" AND \")}`;\n }\n\n query += ` ORDER BY priority DESC, createdAt DESC`;\n\n const result = await sqlite.execute(query, params);\n\n return result.rows.map((row: DBTask) => ({\n ...row,\n dependencies: parseJSON(row.dependencies),\n tags: parseJSON(row.tags),\n }));\n}\n\n// Cognitive State Queries\nexport async function createCognitiveState(\n state: Omit,\n): Promise {\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n\n const dbState: DBCognitiveState = {\n id,\n name: state.name,\n description: state.description,\n context: serializeJSON(state.context),\n activeGoals: serializeJSON(state.activeGoals),\n activeTasks: serializeJSON(state.activeTasks),\n thoughtForks: serializeJSON(state.thoughtForks),\n metadata: serializeJSON(state.metadata),\n createdAt: now,\n updatedAt: now,\n };\n\n await sqlite.execute(\n `INSERT INTO ${TABLES.COGNITIVE_STATES} (id, name, description, context, activeGoals, activeTasks, thoughtForks, metadata, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n dbState.id,\n dbState.name,\n dbState.description,\n dbState.context,\n dbState.activeGoals,\n dbState.activeTasks,\n dbState.thoughtForks,\n dbState.metadata,\n dbState.createdAt,\n dbState.updatedAt,\n ],\n );\n\n return {\n ...dbState,\n context: parseJSON(dbState.context),\n activeGoals: parseJSON(dbState.activeGoals),\n activeTasks: parseJSON(dbState.activeTasks),\n thoughtForks: parseJSON(dbState.thoughtForks),\n metadata: parseJSON(dbState.metadata),\n };\n}\n\nexport async function getCognitiveState(id: string): Promise {\n const result = await sqlite.execute(`SELECT * FROM ${TABLES.COGNITIVE_STATES} WHERE id = ?`, [id]);\n if (result.rows.length === 0) return null;\n\n const dbState = result.rows[0] as DBCognitiveState;\n return {\n ...dbState,\n context: parseJSON(dbState.context),\n activeGoals: parseJSON(dbState.activeGoals),\n activeTasks: parseJSON(dbState.activeTasks),\n thoughtForks: parseJSON(dbState.thoughtForks),\n metadata: parseJSON(dbState.metadata),\n };\n}\n\nexport async function updateCognitiveState(\n id: string,\n updates: Partial,\n): Promise {\n const existing = await getCognitiveState(id);\n if (!existing) return null;\n\n const updatedState = { ...existing, ...updates, updatedAt: new Date().toISOString() };\n const dbState: DBCognitiveState = {\n ...updatedState,\n context: serializeJSON(updatedState.context),\n activeGoals: serializeJSON(updatedState.activeGoals),\n activeTasks: serializeJSON(updatedState.activeTasks),\n thoughtForks: serializeJSON(updatedState.thoughtForks),\n metadata: serializeJSON(updatedState.metadata),\n };\n\n await sqlite.execute(\n `UPDATE ${TABLES.COGNITIVE_STATES} SET name = ?, description = ?, context = ?, activeGoals = ?, activeTasks = ?, thoughtForks = ?, metadata = ?, updatedAt = ?\n WHERE id = ?`,\n [\n dbState.name,\n dbState.description,\n dbState.context,\n dbState.activeGoals,\n dbState.activeTasks,\n dbState.thoughtForks,\n dbState.metadata,\n dbState.updatedAt,\n id,\n ],\n );\n\n return updatedState;\n}\n\nexport async function listCognitiveStates(): Promise {\n const result = await sqlite.execute(`SELECT * FROM ${TABLES.COGNITIVE_STATES} ORDER BY updatedAt DESC`);\n\n return result.rows.map((row: DBCognitiveState) => ({\n ...row,\n context: parseJSON(row.context),\n activeGoals: parseJSON(row.activeGoals),\n activeTasks: parseJSON(row.activeTasks),\n thoughtForks: parseJSON(row.thoughtForks),\n metadata: parseJSON(row.metadata),\n }));\n}\n\n// Skill Queries\nexport async function createSkill(skill: Omit): Promise {\n const id = crypto.randomUUID();\n const now = new Date().toISOString();\n\n const dbSkill: DBSkill = {\n id,\n name: skill.name,\n description: skill.description,\n code: skill.code,\n inputSchema: serializeJSON(skill.inputSchema),\n outputSchema: skill.outputSchema ? serializeJSON(skill.outputSchema) : null,\n tags: serializeJSON(skill.tags),\n version: skill.version,\n isActive: skill.isActive ? 1 : 0,\n createdAt: now,\n updatedAt: now,\n };\n\n await sqlite.execute(\n `INSERT INTO ${TABLES.SKILLS} (id, name, description, code, inputSchema, outputSchema, tags, version, isActive, createdAt, updatedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n dbSkill.id,\n dbSkill.name,\n dbSkill.description,\n dbSkill.code,\n dbSkill.inputSchema,\n dbSkill.outputSchema,\n dbSkill.tags,\n dbSkill.version,\n dbSkill.isActive,\n dbSkill.createdAt,\n dbSkill.updatedAt,\n ],\n );\n\n return {\n ...dbSkill,\n inputSchema: parseJSON(dbSkill.inputSchema),\n outputSchema: dbSkill.outputSchema ? parseJSON(dbSkill.outputSchema) : undefined,\n tags: parseJSON(dbSkill.tags),\n isActive: Boolean(dbSkill.isActive),\n };\n}\n\nexport async function getSkill(id: string): Promise {\n const result = await sqlite.execute(`SELECT * FROM ${TABLES.SKILLS} WHERE id = ?`, [id]);\n if (result.rows.length === 0) return null;\n\n const dbSkill = result.rows[0] as DBSkill;\n return {\n ...dbSkill,\n inputSchema: parseJSON(dbSkill.inputSchema),\n outputSchema: dbSkill.outputSchema ? parseJSON(dbSkill.outputSchema) : undefined,\n tags: parseJSON(dbSkill.tags),\n isActive: Boolean(dbSkill.isActive),\n };\n}\n\nexport async function getSkillByName(name: string): Promise {\n const result = await sqlite.execute(`SELECT * FROM ${TABLES.SKILLS} WHERE name = ?`, [name]);\n if (result.rows.length === 0) return null;\n\n const dbSkill = result.rows[0] as DBSkill;\n return {\n ...dbSkill,\n inputSchema: parseJSON(dbSkill.inputSchema),\n outputSchema: dbSkill.outputSchema ? parseJSON(dbSkill.outputSchema) : undefined,\n tags: parseJSON(dbSkill.tags),\n isActive: Boolean(dbSkill.isActive),\n };\n}\n\nexport async function updateSkill(id: string, updates: Partial): Promise {\n const existing = await getSkill(id);\n if (!existing) return null;\n\n const updatedSkill = { ...existing, ...updates, updatedAt: new Date().toISOString() };\n const dbSkill: DBSkill = {\n ...updatedSkill,\n inputSchema: serializeJSON(updatedSkill.inputSchema),\n outputSchema: updatedSkill.outputSchema ? serializeJSON(updatedSkill.outputSchema) : null,\n tags: serializeJSON(updatedSkill.tags),\n isActive: updatedSkill.isActive ? 1 : 0,\n };\n\n await sqlite.execute(\n `UPDATE ${TABLES.SKILLS} SET name = ?, description = ?, code = ?, inputSchema = ?, outputSchema = ?, tags = ?, version = ?, isActive = ?, updatedAt = ?\n WHERE id = ?`,\n [\n dbSkill.name,\n dbSkill.description,\n dbSkill.code,\n dbSkill.inputSchema,\n dbSkill.outputSchema,\n dbSkill.tags,\n dbSkill.version,\n dbSkill.isActive,\n dbSkill.updatedAt,\n id,\n ],\n );\n\n return updatedSkill;\n}\n\nexport async function listSkills(activeOnly: boolean = false): Promise {\n const query = activeOnly\n ? `SELECT * FROM ${TABLES.SKILLS} WHERE isActive = 1 ORDER BY name ASC`\n : `SELECT * FROM ${TABLES.SKILLS} ORDER BY name ASC`;\n\n const result = await sqlite.execute(query);\n\n return result.rows.map((row: DBSkill) => ({\n ...row,\n inputSchema: parseJSON(row.inputSchema),\n outputSchema: row.outputSchema ? parseJSON(row.outputSchema) : undefined,\n tags: parseJSON(row.tags),\n isActive: Boolean(row.isActive),\n }));\n}\n\nexport async function deleteSkill(id: string): Promise {\n const result = await sqlite.execute(`DELETE FROM ${TABLES.SKILLS} WHERE id = ?`, [id]);\n return result.changes > 0;\n}\n\n// Skill Execution Queries\nexport async function createSkillExecution(execution: Omit): Promise {\n const id = crypto.randomUUID();\n\n const newExecution: SkillExecution = {\n id,\n ...execution,\n };\n\n await sqlite.execute(\n `INSERT INTO ${TABLES.SKILL_EXECUTIONS} (id, skillId, input, output, error, duration, executedAt)\n VALUES (?, ?, ?, ?, ?, ?, ?)`,\n [\n id,\n execution.skillId,\n serializeJSON(execution.input),\n execution.output ? serializeJSON(execution.output) : null,\n execution.error || null,\n execution.duration,\n execution.executedAt,\n ],\n );\n\n return newExecution;\n}\n\nexport async function getSkillExecutions(skillId: string, limit: number = 50): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM ${TABLES.SKILL_EXECUTIONS} WHERE skillId = ? ORDER BY executedAt DESC LIMIT ?`,\n [skillId, limit],\n );\n\n return result.rows.map((row: any) => ({\n ...row,\n input: parseJSON(row.input),\n output: row.output ? parseJSON(row.output) : undefined,\n }));\n}",["D",1748696882441],"versions",[417,419,420,421,422,423],{"_348":389,"_418":391},"previous",{"_348":391,"_418":396},{"_348":396,"_418":401},{"_348":401,"_418":406},{"_348":406,"_418":411},{"_348":411,"_418":-5},"versionNumber","page","hasNext","actionData","errors"]

History for queries.ts