[{"_1":2,"_174":-5,"_175":-5},"loaderData",{"_3":4,"_91":92},"root",{"_5":6,"_34":35,"_64":65},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","notificationCount",0,"flagDenols","ENV",{"_36":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","f81bf4353089432cd96664c549e58fb071329db3","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","API_URL","https://api.val.town","clerkState",{"_66":67},"__internal_clerk_state",{"_68":69,"_70":45,"_71":72,"_73":72,"_74":20,"_75":72,"_76":72,"_77":72,"_78":72,"_79":80,"_89":20,"_90":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_81":20,"_19":20,"_82":72,"_83":84,"_85":72,"_86":45,"_87":20,"_88":72},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_93":94,"_95":96,"_97":98,"_99":100,"_146":147,"_171":172,"_173":-5},"handle","c15r","name","ContextualLite","path","src/tools/handlers/code-tools.ts","project",{"_101":102,"_95":96,"_103":104,"_105":-5,"_106":20,"_107":108,"_109":-5,"_110":-5,"_12":111,"_112":-5,"_113":20,"_114":-5,"_115":32,"_14":116,"_117":118,"_119":118,"_120":121,"_122":121,"_123":121,"_124":118,"_125":118,"_23":126,"_129":130,"_132":133,"_145":20},"id","c5961c8a-4557-11f0-999b-76b3cceeab13","createdAt",["D",1749490372788],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","21f2e37e-8066-4730-9dc7-d27cf8d3c9f3","pinnedFileId","pinPreview","screenshotVersion","likeCount","0630d977-f678-453e-926c-52043293f59f","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_127":128},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yb2RJNlc1czZ1NlpZRmoxdGJ2eFVNNVhmeTYifQ","org",{"_93":94,"_131":128},"avatar","branch",{"_134":135,"_95":43,"_101":136,"_137":102,"_138":-5,"_139":-5,"_140":-5,"_141":-5,"_142":-5,"_143":96,"_144":94},"version",560,"c5966aa0-4557-11f0-999b-76b3cceeab13","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_101":148,"_95":149,"_150":151,"_152":153,"_154":136,"_155":156,"_157":158,"_103":159,"_134":160,"_161":162,"_163":164,"_165":20,"_166":-5,"_97":167},"d7735388-5ea6-11f0-b85a-0224a6c84d84","code-tools.ts","fileId","6a58110a-482e-11f0-a3ea-76b3cceeab13","parentId","c4074bc4-47df-472c-97b7-7eec60d9dc23","branchId","branchVersion",557,"latest",true,["D",1752273112065],48,"fileType","script","content","/**\n * Code execution tool handlers\n */\n\nimport { DynamoDBDocumentClient } from \"https://esm.sh/@aws-sdk/lib-dynamodb@3.490.0\";\nimport { AuthContext } from \"../../storage/kv-store.ts\";\nimport { SkillRegistry } from \"../../storage/skill-registry.ts\";\nimport { FilesToolHandlers } from \"./files-tools.ts\";\n\n// Import Node.js VM module for better code execution\nimport { createContext, runInNewContext } from \"node:vm\";\n\nexport class CodeToolHandlers {\n private filesHandler: FilesToolHandlers;\n private toolsContext: Record;\n private skillRegistry: SkillRegistry;\n\n constructor(\n filesHandler: FilesToolHandlers,\n toolsContext: Record,\n docClient: DynamoDBDocumentClient,\n tableName: string,\n ) {\n this.filesHandler = filesHandler;\n this.toolsContext = toolsContext;\n this.skillRegistry = new SkillRegistry(docClient, tableName);\n }\n\n /**\n * Execute ES6 module using dynamic import with blob URL\n */\n private async executeWithModule(codeSource: string, input: any, authContext: AuthContext): Promise {\n // Create blob URL for dynamic import\n const blob = new Blob([codeSource], { type: \"application/javascript\" });\n const url = URL.createObjectURL(blob);\n \n try {\n // Dynamic import the module\n const module = await import(url);\n \n // Check if module exports execute function\n if (typeof module.execute !== 'function') {\n throw new Error('ES6 module must export an execute function');\n }\n \n // Execute the module's execute function\n const result = await module.execute(input, this.toolsContext);\n \n return result;\n } catch (error) {\n // Re-throw with enhanced error information\n if (error instanceof Error) {\n throw error;\n }\n throw new Error(`ES6 module execution failed: ${String(error)}`);\n } finally {\n // Always clean up the blob URL\n URL.revokeObjectURL(url);\n }\n }\n\n /**\n * Extract metadata from ES6 module exports without executing\n */\n private async extractModuleMetadata(codeSource: string): Promise<{\n inputSchema?: any;\n hasGetPrompts?: boolean;\n metadata?: any;\n }> {\n const blob = new Blob([codeSource], { type: \"application/javascript\" });\n const url = URL.createObjectURL(blob);\n \n try {\n const module = await import(url);\n \n return {\n inputSchema: module.inputSchema,\n hasGetPrompts: typeof module.getPrompts === 'function',\n metadata: module.metadata,\n };\n } catch (error) {\n console.warn('Failed to extract module metadata:', error);\n return {};\n } finally {\n URL.revokeObjectURL(url);\n }\n }\n private async executeWithVM(codeSource: string, input: any, authContext: AuthContext): Promise {\n // Create execution context with tools and input\n const context = createContext({\n input,\n tools: this.toolsContext,\n console: {\n log: console.log,\n error: console.error,\n warn: console.warn,\n info: console.info,\n },\n // Restricted environment - no access to dangerous globals\n setTimeout,\n clearTimeout,\n setInterval,\n clearInterval,\n Promise,\n JSON,\n Math,\n Date,\n Array,\n Object,\n String,\n Number,\n Boolean,\n RegExp,\n Error,\n TypeError,\n ReferenceError,\n SyntaxError,\n fetch,\n URL,\n Blob,\n });\n\n // Build the execution script:\n // 1. User code first (preserves line numbers)\n // 2. Execution logic appended\n const executionScript = `${codeSource}\n\n// === EXECUTION LOGIC (appended to preserve user code line numbers) ===\n(async () => {\n if (typeof execute !== 'function') {\n throw new Error('Code must define an execute function');\n }\n \n return await execute(input, tools);\n})();`;\n\n try {\n // Execute in VM context with proper filename for stack traces\n const result = runInNewContext(executionScript, context, {\n filename: \"user-code.js\", // This provides proper filenames in stack traces\n timeout: 60000, // 60 second timeout\n displayErrors: true,\n });\n\n // Handle promise results\n if (result instanceof Promise) {\n return await result;\n }\n\n return result;\n } catch (error) {\n // Re-throw with enhanced error information\n if (error instanceof Error) {\n // The VM module preserves original line numbers and provides better stack traces\n throw error;\n }\n throw new Error(`Code execution failed: ${String(error)}`);\n }\n }\n\n /**\n * Validate code syntax before execution using VM\n */\n private async validateCodeSyntax(code: string): Promise<{ valid: boolean; error?: string }> {\n try {\n // Try to create a VM context and compile the code\n const context = createContext({});\n\n // Test compilation without execution\n runInNewContext(\n `\n ${code}\n // Check if execute function exists\n if (typeof execute !== 'function') {\n throw new Error('Code must define an execute function');\n }\n `,\n context,\n {\n filename: \"syntax-check.js\",\n timeout: 1000,\n displayErrors: true,\n },\n );\n\n return { valid: true };\n } catch (error) {\n return {\n valid: false,\n error: error instanceof Error ? error.message : String(error),\n };\n }\n }\n\n async handleCodeExec(args: any, authContext: AuthContext) {\n const { code, key, input, moduleType = 'legacy' } = args;\n let codeSource: string;\n\n try {\n // Determine code source: either direct code string or fetch from Files Store key\n if (code && key) {\n throw new Error(\"Cannot specify both 'code' and 'key' parameters. Use either direct code or Files Store key.\");\n }\n\n if (!code && !key) {\n throw new Error(\n \"Must specify either 'code' (direct code string) or 'key' (Files Store object key containing code).\",\n );\n }\n\n if (key) {\n // Fetch code from Files Store (namespaced)\n console.log(`[CodeExec] Fetching code from files key: ${key}`);\n const filesResponse = await this.filesHandler.handleFilesGet({ key }, authContext);\n codeSource = filesResponse.content[0].text;\n console.log(`[CodeExec] Retrieved code from files store (${codeSource.length} characters)`);\n } else {\n // Use direct code string\n codeSource = code;\n console.log(`[CodeExec] Using direct code string (${codeSource.length} characters)`);\n }\n\n console.log(`[CodeExec] Executing code with ${moduleType} mode`);\n\n // Execute code based on module type\n let result;\n if (moduleType === 'es6') {\n result = await this.executeWithModule(codeSource, input, authContext);\n } else {\n result = await this.executeWithVM(codeSource, input, authContext);\n }\n\n console.log(\"[MCP] Code execution result\", result);\n\n return {\n content: [\n {\n type: \"text\",\n text: JSON.stringify(result, null, 2),\n },\n ],\n };\n } catch (error) {\n console.error(\"Error executing code\", error);\n\n // Format error with better stack trace information\n let errorText = `❌ **Code Execution Error**\\n\\n**Message:** ${error.message}\\n\\n`;\n\n if (error.stack) {\n errorText += `**Stack Trace:**\\n\\`\\`\\`\\n${error.stack}\\n\\`\\`\\`\\n`;\n }\n\n return {\n content: [\n {\n type: \"text\",\n text: errorText,\n },\n ],\n };\n }\n }\n\n async handleRegisterSkill(args: any, authContext: AuthContext) {\n const { name, description, fileKey, inputSchema, moduleType = 'es6' } = args;\n\n try {\n // Validate skill name format\n if (!/^[a-zA-Z][a-zA-Z0-9_-]*$/.test(name)) {\n throw new Error(\n \"Skill name must start with a letter and contain only letters, numbers, underscores, and hyphens\",\n );\n }\n\n // Validate moduleType\n if (moduleType !== 'legacy' && moduleType !== 'es6') {\n throw new Error(\"moduleType must be either 'legacy' or 'es6'\");\n }\n\n // Check if skill already exists\n const existingSkill = await this.skillRegistry.getSkill(authContext, name);\n if (existingSkill) {\n throw new Error(`Skill '${name}' already exists. Use unregister-skill first to replace it.`);\n }\n\n // Verify the file exists and validate its syntax\n let skillCode: string;\n try {\n const filesResponse = await this.filesHandler.handleFilesGet({ key: fileKey }, authContext);\n skillCode = filesResponse.content[0].text;\n } catch (error) {\n throw new Error(`File '${fileKey}' not found in your file store: ${error.message}`);\n }\n\n // Extract metadata and validate based on module type\n let extractedInputSchema = inputSchema;\n let hasGetPrompts = false;\n let extractedMetadata: any = {};\n\n if (moduleType === 'es6') {\n // For ES6 modules, try to extract metadata from exports\n try {\n const moduleInfo = await this.extractModuleMetadata(skillCode);\n \n // Use exported inputSchema if available and no inputSchema provided in args\n if (!inputSchema && moduleInfo.inputSchema) {\n extractedInputSchema = moduleInfo.inputSchema;\n }\n \n // Check if module has getPrompts function and extract metadata\n hasGetPrompts = moduleInfo.hasGetPrompts || false;\n extractedMetadata = moduleInfo.metadata || {};\n \n console.log(`[RegisterSkill] Extracted ES6 module metadata:`, {\n hasInputSchema: !!moduleInfo.inputSchema,\n hasGetPrompts: hasGetPrompts,\n hasMetadata: !!moduleInfo.metadata\n });\n } catch (error) {\n console.warn(`[RegisterSkill] Failed to extract ES6 module metadata: ${error.message}`);\n }\n } else {\n // For legacy modules, validate the execute function syntax\n const syntaxCheck = await this.validateCodeSyntax(skillCode);\n if (!syntaxCheck.valid) {\n throw new Error(`Legacy skill code has syntax errors:\\n${syntaxCheck.error}`);\n }\n }\n\n // Validate input schema is provided or extracted\n if (!extractedInputSchema) {\n throw new Error(\"inputSchema must be provided either as parameter or exported from ES6 module\");\n }\n\n if (typeof extractedInputSchema !== \"object\" || extractedInputSchema === null) {\n throw new Error(\"inputSchema must be a valid JSON Schema object\");\n }\n\n // Register the skill with enhanced information\n await this.skillRegistry.registerSkill(\n authContext, \n name, \n description, \n fileKey, \n extractedInputSchema,\n moduleType,\n hasGetPrompts,\n extractedMetadata\n );\n\n const moduleTypeText = moduleType === 'es6' ? 'ES6 Module' : 'Legacy Function';\n const promptsText = hasGetPrompts ? ' with dynamic prompts' : '';\n \n return {\n content: [\n {\n type: \"text\",\n text: `✅ Skill '${name}' registered successfully as ${moduleTypeText}${promptsText}. It is now available as a tool.`,\n },\n ],\n };\n } catch (error) {\n console.error(\"Error registering skill\", error);\n return {\n content: [\n {\n type: \"text\",\n text: `❌ Error registering skill: ${error.message}`,\n },\n ],\n };\n }\n }\n\n async handleUnregisterSkill(args: any, authContext: AuthContext) {\n const { name } = args;\n\n try {\n const success = await this.skillRegistry.unregisterSkill(authContext, name);\n\n if (success) {\n return {\n content: [\n {\n type: \"text\",\n text: `✅ Skill '${name}' unregistered successfully.`,\n },\n ],\n };\n } else {\n return {\n content: [\n {\n type: \"text\",\n text: `⚠️ Skill '${name}' not found.`,\n },\n ],\n };\n }\n } catch (error) {\n console.error(\"Error unregistering skill\", error);\n return {\n content: [\n {\n type: \"text\",\n text: `❌ Error unregistering skill: ${error.message}`,\n },\n ],\n };\n }\n }\n\n async handleListSkills(args: any, authContext: AuthContext) {\n try {\n const skills = await this.skillRegistry.listSkills(authContext);\n\n if (skills.length === 0) {\n return {\n content: [\n {\n type: \"text\",\n text: \"No skills registered.\",\n },\n ],\n };\n }\n\n const skillsList = skills.map(skill => `- **${skill.name}**: ${skill.description} (file: ${skill.fileKey})`).join(\n \"\\n\",\n );\n\n return {\n content: [\n {\n type: \"text\",\n text: `📋 **Registered Skills:**\\n\\n${skillsList}`,\n },\n ],\n };\n } catch (error) {\n console.error(\"Error listing skills\", error);\n return {\n content: [\n {\n type: \"text\",\n text: `❌ Error listing skills: ${error.message}`,\n },\n ],\n };\n }\n }\n\n async handleSkillExecution(skillName: string, args: any, authContext: AuthContext) {\n try {\n // Get the skill definition using enhanced resolution (user skills override system skills)\n const skill = await this.skillRegistry.resolveSkill(authContext, skillName);\n if (!skill) {\n throw new Error(`Skill '${skillName}' not found`);\n }\n\n // Determine execution mode based on skill's module type (default to legacy for backward compatibility)\n const moduleType = skill.moduleType || 'legacy';\n \n console.log(`[SkillExecution] Executing skill '${skillName}' with ${moduleType} mode`);\n\n // Execute the skill using the appropriate execution method\n return await this.handleCodeExec({\n key: skill.fileKey,\n input: args,\n moduleType: moduleType\n }, authContext);\n } catch (error) {\n console.error(`Error executing skill ${skillName}`, error);\n return {\n content: [\n {\n type: \"text\",\n text: `❌ Error executing skill '${skillName}': ${error.message}`,\n },\n ],\n };\n }\n }\n\n /**\n * Dynamically evaluate prompts from an ES6 skill module at runtime\n */\n private async evaluateSkillPrompts(codeSource: string, authContext: AuthContext): Promise {\n const blob = new Blob([codeSource], { type: \"application/javascript\" });\n const url = URL.createObjectURL(blob);\n \n try {\n const module = await import(url);\n \n if (typeof module.getPrompts === 'function') {\n // Call getPrompts with tools context for dynamic evaluation\n const prompts = await module.getPrompts(this.toolsContext);\n \n // Validate that prompts is an array\n if (!Array.isArray(prompts)) {\n console.warn('getPrompts() must return an array');\n return [];\n }\n \n // Validate each prompt structure to match base prompt format\n return prompts.filter(prompt => {\n if (!prompt || typeof prompt !== 'object') {\n console.warn('Invalid prompt: must be an object');\n return false;\n }\n \n if (!prompt.name || typeof prompt.name !== 'string') {\n console.warn('Invalid prompt: must have a string name');\n return false;\n }\n \n if (!prompt.description || typeof prompt.description !== 'string') {\n console.warn('Invalid prompt: must have a string description');\n return false;\n }\n \n // Validate arguments array structure (should match base prompts format)\n if (prompt.arguments !== undefined) {\n if (!Array.isArray(prompt.arguments)) {\n console.warn('Invalid prompt: arguments must be an array');\n return false;\n }\n \n // Validate each argument structure\n for (const arg of prompt.arguments) {\n if (!arg || typeof arg !== 'object') {\n console.warn('Invalid prompt argument: must be an object');\n return false;\n }\n \n if (!arg.name || typeof arg.name !== 'string') {\n console.warn('Invalid prompt argument: must have a string name');\n return false;\n }\n \n if (!arg.description || typeof arg.description !== 'string') {\n console.warn('Invalid prompt argument: must have a string description');\n return false;\n }\n \n if (arg.required !== undefined && typeof arg.required !== 'boolean') {\n console.warn('Invalid prompt argument: required must be a boolean');\n return false;\n }\n }\n }\n \n // content can be a string or function\n if (prompt.content && typeof prompt.content !== 'string' && typeof prompt.content !== 'function') {\n console.warn('Invalid prompt: content must be a string or function');\n return false;\n }\n \n return true;\n });\n }\n \n return [];\n } catch (error) {\n console.warn('Failed to evaluate skill prompts:', error);\n return [];\n } finally {\n URL.revokeObjectURL(url);\n }\n }\n\n /**\n * Get prompts from a specific skill at runtime\n */\n async getSkillPrompts(skillName: string, authContext: AuthContext): Promise {\n try {\n // Get the skill definition\n const skill = await this.skillRegistry.resolveSkill(authContext, skillName);\n if (!skill) {\n return [];\n }\n\n // Only ES6 modules with getPrompts function can provide dynamic prompts\n if (skill.moduleType !== 'es6' || !skill.hasGetPrompts) {\n return [];\n }\n\n // Get the skill code\n let skillCode: string;\n try {\n const filesResponse = await this.filesHandler.handleFilesGet({ key: skill.fileKey }, authContext);\n skillCode = filesResponse.content[0].text;\n } catch (error) {\n console.warn(`Failed to load skill code for prompts: ${error.message}`);\n return [];\n }\n\n // Evaluate prompts dynamically\n return await this.evaluateSkillPrompts(skillCode, authContext);\n } catch (error) {\n console.error(`Error getting prompts for skill ${skillName}:`, error);\n return [];\n }\n }\n\n /**\n * Execute a specific prompt from a skill\n */\n async executeSkillPrompt(skillName: string, promptName: string, args: any, authContext: AuthContext): Promise {\n try {\n // Get the skill prompts\n const prompts = await this.getSkillPrompts(skillName, authContext);\n \n // Find the specific prompt\n const prompt = prompts.find(p => p.name === promptName);\n if (!prompt) {\n throw new Error(`Prompt '${promptName}' not found in skill '${skillName}'`);\n }\n\n // Execute the prompt content\n if (typeof prompt.content === 'function') {\n return await prompt.content(args);\n } else if (typeof prompt.content === 'string') {\n return prompt.content;\n } else {\n throw new Error(`Invalid prompt content type for '${promptName}' in skill '${skillName}'`);\n }\n } catch (error) {\n console.error(`Error executing prompt ${promptName} from skill ${skillName}:`, error);\n throw error;\n }\n }\n\n async getRegisteredSkills(authContext: AuthContext) {\n return await this.skillRegistry.listAllAvailableSkills(authContext);\n }\n\n /**\n * Get all prompts from all registered skills at runtime\n */\n async getAllSkillPrompts(authContext: AuthContext): Promise {\n try {\n const skills = await this.skillRegistry.listAllAvailableSkills(authContext);\n const allPrompts: any[] = [];\n\n for (const skill of skills) {\n if (skill.moduleType === 'es6' && skill.hasGetPrompts) {\n try {\n const skillPrompts = await this.getSkillPrompts(skill.name, authContext);\n \n // Prefix prompt names with skill name to avoid conflicts\n const prefixedPrompts = skillPrompts.map(prompt => ({\n ...prompt,\n name: `${skill.name}-${prompt.name}`,\n description: `${prompt.description} (from skill: ${skill.name})`,\n skillName: skill.name,\n originalName: prompt.name,\n }));\n \n allPrompts.push(...prefixedPrompts);\n } catch (error) {\n console.warn(`Failed to get prompts from skill ${skill.name}:`, error);\n }\n }\n }\n\n return allPrompts;\n } catch (error) {\n console.error('Error getting all skill prompts:', error);\n return [];\n }\n }\n}","deleted","label",[168,169,170,149],"src","tools","handlers","permalink","https://www.val.town/x/c15r/ContextualLite/code/src/tools/handlers/code-tools.ts","extension","actionData","errors"]