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}",[],[156,211,217,276],[156,211,217],{"_104":285,"_95":286,"_157":287,"_159":212,"_160":139,"_161":288,"_162":22,"_106":289,"_100":119,"_165":185,"_167":290,"_168":22,"_169":-5,"_170":291,"_98":292},"9620fcaa-3e21-11f0-bf99-76b3cceeab13","auth.ts","32241a1e-3e63-4ab7-816c-124f12a2dc13",7,["D",1748697442195],"import type { Context } from \"https://esm.sh/hono@3.11.7\";\nimport { getUserByAccessToken } from \"../database/user-queries.ts\";\nimport type { User } from \"../../shared/types.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 \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 return { isAdmin: true };\n }\n\n // Check if it's a user token\n try {\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}",[],[156,211,286],{"_104":294,"_95":295,"_157":296,"_159":212,"_160":139,"_161":297,"_162":22,"_106":298,"_100":299,"_165":185,"_167":300,"_168":22,"_169":-5,"_170":301,"_98":302},"242ba8fc-4218-11f0-b600-76b3cceeab13","server.ts","445cbf12-a201-4a93-84b3-35ae889dcab9",97,["D",1749133190186],30,"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 { handleStateTool, stateTools } from \"./tools/states.ts\";\nimport { handleTaskTool, taskTools } from \"./tools/tasks.ts\";\nimport { handleUserRegistrationTool, userRegistrationTools } from \"./tools/user-registration.ts\";\n\nexport class MCPCognitiveServer {\n private tools: MCPTool[] = [];\n private authRequiredTools: MCPTool[] = [];\n\n constructor() {\n this.initializeTools();\n }\n\n private async initializeTools() {\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 ];\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 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 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 return {\n jsonrpc: \"2.0\",\n id: request.id,\n result: {\n protocolVersion: \"2024-11-05\",\n capabilities: {\n tools: {},\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 // Refresh dynamic tools\n await this.initializeTools();\n\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 });\n } else {\n prompts.push({\n name: \"server-test\",\n description: \"Test system functionality\",\n });\n }\n return {\n jsonrpc: \"2.0\",\n id: request.id,\n result: {\n prompts: prompts,\n },\n };\n }\n\n private async handleToolCall(request: MCPRequest, authContext?: AuthContext): 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: -32001,\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,\n );\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,\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 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}",[],[156,211,295],[156,211],{"_104":305,"_95":306,"_157":307,"_159":158,"_160":139,"_161":308,"_162":22,"_106":309,"_100":310,"_165":311,"_167":312,"_168":22,"_169":-5,"_170":313,"_98":314},"fe8cb052-4120-11f0-9ea7-76b3cceeab13","index.ts","1564b217-248f-4a97-a4d3-7bfe82cb8b19",84,["D",1749027041377],14,"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 ------------------------------------------------------\napp.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// Initialize on startup\nawait initializeServer();\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 try {\n console.log(\"/mcp\");\n const request: MCPRequest = await c.req.json();\n console.log(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\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;",[],[156,306],[156],{"_104":317,"_95":318,"_157":319,"_159":-5,"_160":139,"_161":119,"_162":163,"_106":320,"_100":32,"_165":166,"_167":-5,"_168":22,"_169":-5,"_170":321,"_98":332},"4882579c-3e20-11f0-a873-76b3cceeab13","shared","a60cd0e8-5948-484f-b608-47d0c2420cfd",["D",1748696882441],[322],{"_104":323,"_95":324,"_157":325,"_159":319,"_160":139,"_161":326,"_162":163,"_106":327,"_100":328,"_165":185,"_167":329,"_168":22,"_169":-5,"_170":330,"_98":331},"11a6c0fc-3fc2-11f0-824e-76b3cceeab13","types.ts","a9d743ae-ae8d-4e45-a661-0208f4594b98",77,["D",1748876320069],3,"// 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}",[],[318,324],[318],{"_104":334,"_95":335,"_157":336,"_159":-5,"_160":139,"_161":337,"_162":22,"_106":338,"_100":339,"_165":340,"_167":341,"_168":22,"_169":-5,"_170":342,"_98":343},"f4cc1970-3f2e-11f0-889b-76b3cceeab13","README.md","86d62dae-b3b8-4bc3-853a-700ff753f99a",59,["D",1748813135642],8,"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- **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│ │ └── 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## 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- **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 Goal**: Use `create_goal` to set objectives\n5. **Fork Thoughts**: Use `create_thought_fork` for AI-assisted analysis\n6. **Merge Insights**: Use `merge_thought_fork` for AI synthesis\n7. **Create Tasks**: Break down goals with `create_task`\n8. **Build Skills**: Create reusable tools with `create_skill`\n9. **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- 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*",[],[335],"files",[154,172,178,189,199,209,215,221,230,238,247,256,265,274,284,293,304,316,322,333],"counts",{"_348":32,"_349":119,"_350":32,"_351":119},"pulls","branches","forks","envVars","contents",[354,357,360],{"_104":216,"_95":217,"_157":218,"_159":212,"_160":139,"_161":119,"_162":163,"_106":355,"_100":32,"_165":166,"_167":-5,"_168":22,"_169":-5,"_98":356},["D",1748696882441],[156,211,217],{"_104":285,"_95":286,"_157":287,"_159":212,"_160":139,"_161":288,"_162":22,"_106":358,"_100":119,"_165":185,"_167":290,"_168":22,"_169":-5,"_98":359},["D",1748697442195],[156,211,286],{"_104":294,"_95":295,"_157":296,"_159":212,"_160":139,"_161":297,"_162":22,"_106":361,"_100":299,"_165":185,"_167":300,"_168":22,"_169":-5,"_98":362},["D",1749133190186],[156,211,295],{"_104":210,"_95":211,"_157":212,"_159":158,"_160":139,"_161":119,"_162":163,"_106":364,"_100":32,"_165":166,"_167":-5,"_168":22,"_169":-5,"_98":365},["D",1748696882441],[156,211],"upstreamProject","upstreamBranch",{"_104":142,"_106":369,"_370":371,"_95":43,"_140":147,"_100":144,"_141":-5,"_143":-5,"_372":-5,"_108":-5,"_151":22,"_110":111,"_150":94,"_16":120,"_149":373},["D",1748556642802],"updatedAt",["D",1748620785935],"lockfileKey","ContextualMCP","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.version.$version.code.$",{"_93":94,"_95":96,"_97":43,"_100":101,"_98":99,"_102":380,"_152":385,"_344":446,"_340":447,"_352":449,"_456":457,"_460":163,"_461":-5,"_462":463,"_464":32,"_465":466},{"_104":105,"_95":96,"_106":381,"_108":-5,"_109":22,"_110":111,"_112":-5,"_113":-5,"_14":114,"_115":-5,"_116":22,"_117":-5,"_118":119,"_16":120,"_121":122,"_123":122,"_124":125,"_126":125,"_127":125,"_128":122,"_129":122,"_23":382,"_133":383,"_136":384,"_151":22},["D",1748696882441],{"_93":94,"_131":132},{"_93":94,"_135":132},{"_100":138,"_95":43,"_104":139,"_140":105,"_141":142,"_143":144,"_145":111,"_146":147,"_148":120,"_149":96,"_150":94},[386,437,443],{"_104":155,"_95":156,"_157":158,"_159":-5,"_160":139,"_161":119,"_162":163,"_106":164,"_100":32,"_165":166,"_167":-5,"_168":22,"_169":-5,"_170":387,"_98":436},[388,400,433],{"_104":173,"_95":174,"_157":175,"_159":158,"_160":139,"_161":119,"_162":163,"_106":176,"_100":32,"_165":166,"_167":-5,"_168":22,"_169":-5,"_170":389,"_98":399},[390,393,396],{"_104":179,"_95":180,"_157":181,"_159":175,"_160":139,"_161":182,"_162":163,"_106":183,"_100":184,"_165":185,"_167":186,"_168":22,"_169":-5,"_170":391,"_98":392},[],[156,174,180],{"_104":190,"_95":191,"_157":192,"_159":175,"_160":139,"_161":193,"_162":163,"_106":194,"_100":195,"_165":185,"_167":196,"_168":22,"_169":-5,"_170":394,"_98":395},[],[156,174,191],{"_104":200,"_95":201,"_157":202,"_159":175,"_160":139,"_161":203,"_162":22,"_106":204,"_100":184,"_165":185,"_167":205,"_168":22,"_169":-5,"_170":397,"_98":398},[],[156,174,201],[156,174],{"_104":210,"_95":211,"_157":212,"_159":158,"_160":139,"_161":119,"_162":163,"_106":213,"_100":32,"_165":166,"_167":-5,"_168":22,"_169":-5,"_170":401,"_98":432},[402,426,429],{"_104":216,"_95":217,"_157":218,"_159":212,"_160":139,"_161":119,"_162":163,"_106":219,"_100":32,"_165":166,"_167":-5,"_168":22,"_169":-5,"_170":403,"_98":425},[404,407,410,413,416,419,422],{"_104":222,"_95":223,"_157":224,"_159":218,"_160":139,"_161":225,"_162":22,"_106":226,"_100":184,"_165":185,"_167":227,"_168":22,"_169":-5,"_170":405,"_98":406},[],[156,211,217,223],{"_104":231,"_95":232,"_157":233,"_159":218,"_160":139,"_161":144,"_162":163,"_106":234,"_100":119,"_165":185,"_167":235,"_168":22,"_169":-5,"_170":408,"_98":409},[],[156,211,217,232],{"_104":239,"_95":240,"_157":241,"_159":218,"_160":139,"_161":242,"_162":163,"_106":243,"_100":119,"_165":185,"_167":244,"_168":22,"_169":-5,"_170":411,"_98":412},[],[156,211,217,240],{"_104":248,"_95":249,"_157":250,"_159":218,"_160":139,"_161":101,"_162":22,"_106":251,"_100":252,"_165":185,"_167":253,"_168":22,"_169":-5,"_170":414,"_98":415},[],[156,211,217,249],{"_104":257,"_95":258,"_157":259,"_159":218,"_160":139,"_161":260,"_162":163,"_106":261,"_100":119,"_165":185,"_167":262,"_168":22,"_169":-5,"_170":417,"_98":418},[],[156,211,217,258],{"_104":266,"_95":267,"_157":268,"_159":218,"_160":139,"_161":269,"_162":163,"_106":270,"_100":184,"_165":185,"_167":271,"_168":22,"_169":-5,"_170":420,"_98":421},[],[156,211,217,267],{"_104":275,"_95":276,"_157":277,"_159":218,"_160":139,"_161":278,"_162":163,"_106":279,"_100":119,"_165":185,"_167":280,"_168":22,"_169":-5,"_170":423,"_98":424},[],[156,211,217,276],[156,211,217],{"_104":285,"_95":286,"_157":287,"_159":212,"_160":139,"_161":288,"_162":22,"_106":289,"_100":119,"_165":185,"_167":290,"_168":22,"_169":-5,"_170":427,"_98":428},[],[156,211,286],{"_104":294,"_95":295,"_157":296,"_159":212,"_160":139,"_161":297,"_162":22,"_106":298,"_100":299,"_165":185,"_167":300,"_168":22,"_169":-5,"_170":430,"_98":431},[],[156,211,295],[156,211],{"_104":305,"_95":306,"_157":307,"_159":158,"_160":139,"_161":308,"_162":22,"_106":309,"_100":310,"_165":311,"_167":312,"_168":22,"_169":-5,"_170":434,"_98":435},[],[156,306],[156],{"_104":317,"_95":318,"_157":319,"_159":-5,"_160":139,"_161":119,"_162":163,"_106":320,"_100":32,"_165":166,"_167":-5,"_168":22,"_169":-5,"_170":438,"_98":442},[439],{"_104":323,"_95":324,"_157":325,"_159":319,"_160":139,"_161":326,"_162":163,"_106":327,"_100":328,"_165":185,"_167":329,"_168":22,"_169":-5,"_170":440,"_98":441},[],[318,324],[318],{"_104":334,"_95":335,"_157":336,"_159":-5,"_160":139,"_161":337,"_162":22,"_106":338,"_100":339,"_165":340,"_167":341,"_168":22,"_169":-5,"_170":444,"_98":445},[],[335],[386,388,390,393,396,400,402,404,407,410,413,416,419,422,426,429,433,437,439,443],{"_104":210,"_95":211,"_157":212,"_159":158,"_160":139,"_161":119,"_162":163,"_106":364,"_100":32,"_165":166,"_167":-5,"_168":22,"_169":-5,"_98":448},[156,211],[450,452,454],{"_104":216,"_95":217,"_157":218,"_159":212,"_160":139,"_161":119,"_162":163,"_106":355,"_100":32,"_165":166,"_167":-5,"_168":22,"_169":-5,"_98":451},[156,211,217],{"_104":285,"_95":286,"_157":287,"_159":212,"_160":139,"_161":288,"_162":22,"_106":358,"_100":119,"_165":185,"_167":290,"_168":22,"_169":-5,"_98":453},[156,211,286],{"_104":294,"_95":295,"_157":296,"_159":212,"_160":139,"_161":297,"_162":22,"_106":361,"_100":299,"_165":185,"_167":300,"_168":22,"_169":-5,"_98":455},[156,211,295],"upstream",{"_104":142,"_106":458,"_370":459,"_95":43,"_140":147,"_100":144,"_141":-5,"_143":-5,"_372":-5,"_108":-5,"_151":22,"_110":111,"_150":94,"_16":120,"_149":373},["D",1748556642802],["D",1748620785935],"showCompareCallout","pull","ahead",159,"behind","templates",[],"actionData","errors"]