[{"_1":2,"_173":-5,"_174":-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","2f607f7b74b4e52529fb75176d403d8b5b284eb1","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,"_170":171,"_172":-5},"handle","c15r","name","ContextualLite","path","src/storage/skill-registry.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},"da8cb762-5ea6-11f0-a497-0224a6c84d84","skill-registry.ts","fileId","bf0810a2-4850-11f0-95df-76b3cceeab13","parentId","338c38a4-b6f8-498d-8466-5e15fa8a1559","branchId","branchVersion",558,"latest",true,["D",1752273117262],39,"fileType","script","content","/**\n * Enhanced Skill Registry for managing both user-registered and system-wide skills\n * Skills are stored in the KV store with special prefixes for different scopes\n */\n\nimport { AuthContext, NamespacedKVStore } from \"./kv-store.ts\";\nimport { ExtendedAuthContext } from \"../auth/auth-manager.ts\";\nimport { DynamoDBDocumentClient } from \"https://esm.sh/@aws-sdk/lib-dynamodb@3.490.0\";\n\ninterface SkillPrompt {\n name: string;\n description: string;\n arguments?: Array<{\n name: string;\n description: string;\n required?: boolean;\n }>;\n content: string | ((args: any) => Promise);\n}\n\nexport interface SkillDefinition {\n name: string;\n description: string;\n fileKey: string;\n inputSchema: any;\n createdAt: string;\n updatedAt: string;\n isSystemSkill?: boolean; // Flag to indicate if this is a system skill\n promotedFrom?: string; // Namespace of the original user who created this skill (for promoted skills)\n promotedAt?: string; // When this skill was promoted to system-wide\n promotedBy?: string; // Admin who promoted this skill\n \n // Enhanced fields for ES6 module support\n moduleType?: 'legacy' | 'es6'; // Type of skill module (defaults to 'es6' for new skills)\n hasGetPrompts?: boolean; // Whether the skill exports a getPrompts function (for runtime evaluation)\n metadata?: any; // Additional metadata from module exports\n}\n\nexport class SkillRegistry {\n private kvStore: NamespacedKVStore;\n private static readonly USER_SKILL_PREFIX = \"__skills__:\";\n private static readonly SYSTEM_SKILL_PREFIX = \"__system_skills__:\";\n\n constructor(docClient: DynamoDBDocumentClient, tableName: string) {\n // Create a dummy auth context for the KV store - we'll override the namespace\n const dummyAuthContext: AuthContext = { namespace: \"dummy\", isDemo: false };\n this.kvStore = new NamespacedKVStore(dummyAuthContext, docClient, tableName);\n }\n\n // User skill key methods\n private getUserSkillKey(userNamespace: string, skillName: string): string {\n return `${SkillRegistry.USER_SKILL_PREFIX}${userNamespace}:${skillName}`;\n }\n\n private getUserSkillsPrefix(userNamespace: string): string {\n return `${SkillRegistry.USER_SKILL_PREFIX}${userNamespace}:`;\n }\n\n // System skill key methods\n private getSystemSkillKey(skillName: string): string {\n return `${SkillRegistry.SYSTEM_SKILL_PREFIX}system:${skillName}`;\n }\n\n private getSystemSkillsPrefix(): string {\n return `${SkillRegistry.SYSTEM_SKILL_PREFIX}system:`;\n }\n\n // User skill management methods\n async registerSkill(\n authContext: AuthContext,\n skillName: string,\n description: string,\n fileKey: string,\n inputSchema: any,\n moduleType: 'legacy' | 'es6' = 'es6',\n hasGetPrompts?: boolean,\n metadata?: any\n ): Promise {\n console.log('[SkillRegistry] registerSkill', skillName, fileKey);\n const skillKey = this.getUserSkillKey(authContext.namespace, skillName);\n const now = new Date().toISOString();\n\n const skillDefinition: SkillDefinition = {\n name: skillName,\n description,\n fileKey,\n inputSchema,\n createdAt: now,\n updatedAt: now,\n isSystemSkill: false,\n moduleType,\n hasGetPrompts: hasGetPrompts || false,\n metadata: metadata || {},\n };\n\n console.log('[SkillRegistry] skillDefinition', skillKey, skillDefinition);\n // Store in KV with a special key structure that bypasses normal namespacing\n await this.kvStore.put(skillKey, skillDefinition, undefined, true); // true = bypass namespace\n }\n\n async getSkill(authContext: AuthContext, skillName: string): Promise {\n console.log('[SkillRegistry] getSkill', skillName);\n const skillKey = this.getUserSkillKey(authContext.namespace, skillName);\n console.log('[SkillRegistry] skillKey', skillKey);\n return await this.kvStore.get(skillKey, true); // true = bypass namespace\n }\n\n async listSkills(authContext: AuthContext): Promise {\n // For bypassed namespace queries, we need to provide pk:sk_pattern format\n // User skills are stored with pk=\"__skills__\" and sk=\"namespace:skillName\"\n const queryPattern = `__skills__:${authContext.namespace}:*`;\n const results = await this.kvStore.query(queryPattern, 1000, true); // true = bypass namespace\n \n return results.map(item => ({ \n ...item.value as SkillDefinition,\n isSystemSkill: false\n }));\n }\n\n async unregisterSkill(authContext: AuthContext, skillName: string): Promise {\n const skillKey = this.getUserSkillKey(authContext.namespace, skillName);\n return await this.kvStore.delete(skillKey, true); // true = bypass namespace\n }\n\n async skillExists(authContext: AuthContext, skillName: string): Promise {\n const skill = await this.getSkill(authContext, skillName);\n return skill !== null;\n }\n\n // System skill management methods (admin only) - PROMOTION BASED\n async promoteSkillToSystem(\n authContext: ExtendedAuthContext,\n userNamespace: string,\n skillName: string,\n filesStore?: any // FilesStore instance for copying file content\n ): Promise {\n if (!authContext.isSystemMode) {\n throw new Error(\"Skill promotion requires admin mode access\");\n }\n\n console.log('[SkillRegistry] promoteSkillToSystem', userNamespace, skillName);\n \n // Get the original user skill\n const userSkillKey = this.getUserSkillKey(userNamespace, skillName);\n const userSkill = await this.kvStore.get(userSkillKey, true);\n \n if (!userSkill) {\n throw new Error(`User skill '${skillName}' not found in namespace '${userNamespace}'`);\n }\n\n // Check if system skill already exists\n const existingSystemSkill = await this.getSystemSkill(skillName);\n if (existingSystemSkill) {\n throw new Error(`System skill '${skillName}' already exists. Use admin-update-promoted-skill to update it or admin-demote-skill to remove it first.`);\n }\n\n // Copy the skill file to system folder if filesStore is provided\n let systemFileKey = userSkill.fileKey;\n if (filesStore) {\n try {\n console.log(`[SkillRegistry] Copying skill file from user namespace ${userNamespace}`);\n \n // Create a temporary auth context for the original user to fetch their file\n const originalUserAuthContext = { namespace: userNamespace, isDemo: false };\n const originalUserFilesStore = new (filesStore.constructor)(originalUserAuthContext, filesStore.s3Client, filesStore.bucketName);\n \n // Get the file content from the original user's namespace\n const originalFile = await originalUserFilesStore.get(userSkill.fileKey);\n if (!originalFile) {\n throw new Error(`Original skill file '${userSkill.fileKey}' not found in user namespace '${userNamespace}'`);\n }\n\n // Define the system file key\n systemFileKey = `system/skills/${skillName}.js`;\n \n // Store the file content in the system folder using admin context\n await filesStore.putWithSystemFolder(\n systemFileKey,\n originalFile.content,\n originalFile.contentType || 'application/javascript',\n {\n originalFileKey: userSkill.fileKey,\n originalNamespace: userNamespace,\n promotedBy: authContext.namespace,\n promotedAt: new Date().toISOString(),\n skillName: skillName\n },\n authContext\n );\n \n console.log(`[SkillRegistry] Skill file copied to system folder: ${systemFileKey}`);\n } catch (error) {\n console.error('[SkillRegistry] Failed to copy skill file to system folder:', error);\n throw new Error(`Failed to copy skill file to system folder: ${error.message}`);\n }\n }\n\n const systemSkillKey = this.getSystemSkillKey(skillName);\n const now = new Date().toISOString();\n\n // Create promoted system skill based on user skill\n const promotedSkillDefinition: SkillDefinition = {\n ...userSkill,\n fileKey: systemFileKey, // Use the system file key instead of the original user file key\n isSystemSkill: true,\n promotedFrom: userNamespace,\n promotedAt: now,\n promotedBy: authContext.namespace, // Admin who promoted it\n updatedAt: now,\n };\n\n console.log('[SkillRegistry] promoted skillDefinition', systemSkillKey, promotedSkillDefinition);\n // Store in KV with a special key structure that bypasses normal namespacing\n await this.kvStore.put(systemSkillKey, promotedSkillDefinition, undefined, true); // true = bypass namespace\n }\n\n async demoteSkillFromSystem(authContext: ExtendedAuthContext, skillName: string, filesStore?: any): Promise {\n if (!authContext.isSystemMode) {\n throw new Error(\"Skill demotion requires admin mode access\");\n }\n\n console.log('[SkillRegistry] demoteSkillFromSystem', skillName);\n \n // Check if system skill exists and is promoted\n const systemSkill = await this.getSystemSkill(skillName);\n if (!systemSkill) {\n return false; // Skill doesn't exist\n }\n\n if (!systemSkill.promotedFrom) {\n throw new Error(`System skill '${skillName}' was not promoted from a user skill and cannot be demoted. Use admin-unregister-system-skill instead.`);\n }\n\n // Delete the system file if it exists in the system folder and filesStore is provided\n if (filesStore && systemSkill.fileKey.startsWith('system/')) {\n try {\n console.log(`[SkillRegistry] Checking if system skill file exists: ${systemSkill.fileKey}`);\n \n // Check if the file exists before trying to delete it\n const fileExists = await filesStore.getWithSystemFolder(systemSkill.fileKey, undefined, authContext);\n \n if (fileExists) {\n console.log(`[SkillRegistry] Deleting system skill file: ${systemSkill.fileKey}`);\n await filesStore.deleteWithSystemFolder(systemSkill.fileKey, undefined, authContext);\n console.log(`[SkillRegistry] System skill file deleted: ${systemSkill.fileKey}`);\n } else {\n console.log(`[SkillRegistry] System skill file does not exist (backward compatibility): ${systemSkill.fileKey}`);\n }\n } catch (error) {\n console.warn(`[SkillRegistry] Failed to delete system skill file ${systemSkill.fileKey}:`, error);\n // Don't fail the demotion if file deletion fails - this ensures backward compatibility\n // with skills that were promoted before the file copying feature was implemented\n }\n }\n\n const systemSkillKey = this.getSystemSkillKey(skillName);\n return await this.kvStore.delete(systemSkillKey, true); // true = bypass namespace\n }\n\n async updatePromotedSkill(authContext: ExtendedAuthContext, skillName: string, filesStore?: any): Promise {\n if (!authContext.isSystemMode) {\n throw new Error(\"Promoted skill update requires admin mode access\");\n }\n\n console.log('[SkillRegistry] updatePromotedSkill', skillName);\n \n // Get the current system skill\n const systemSkill = await this.getSystemSkill(skillName);\n if (!systemSkill) {\n throw new Error(`System skill '${skillName}' not found`);\n }\n\n if (!systemSkill.promotedFrom) {\n throw new Error(`System skill '${skillName}' was not promoted from a user skill and cannot be updated this way. Use admin-update-system-skill instead.`);\n }\n\n // Get the latest version of the original user skill\n const userSkillKey = this.getUserSkillKey(systemSkill.promotedFrom, skillName);\n const latestUserSkill = await this.kvStore.get(userSkillKey, true);\n \n if (!latestUserSkill) {\n throw new Error(`Original user skill '${skillName}' no longer exists in namespace '${systemSkill.promotedFrom}'. Cannot update promoted skill.`);\n }\n\n // Update the skill file in system folder if filesStore is provided\n let systemFileKey = systemSkill.fileKey;\n if (filesStore) {\n try {\n console.log(`[SkillRegistry] Updating skill file from user namespace ${systemSkill.promotedFrom}`);\n \n // Create a temporary auth context for the original user to fetch their file\n const originalUserAuthContext = { namespace: systemSkill.promotedFrom, isDemo: false };\n const originalUserFilesStore = new (filesStore.constructor)(originalUserAuthContext, filesStore.s3Client, filesStore.bucketName);\n \n // Get the latest file content from the original user's namespace\n const originalFile = await originalUserFilesStore.get(latestUserSkill.fileKey);\n if (!originalFile) {\n throw new Error(`Original skill file '${latestUserSkill.fileKey}' not found in user namespace '${systemSkill.promotedFrom}'`);\n }\n\n // If the current system skill doesn't have a system file key (backward compatibility),\n // create one now\n if (!systemSkill.fileKey.startsWith('system/')) {\n systemFileKey = `system/skills/${skillName}.js`;\n console.log(`[SkillRegistry] Migrating skill to system folder: ${systemFileKey}`);\n }\n\n // Update/create the file content in the system folder using admin context\n await filesStore.putWithSystemFolder(\n systemFileKey,\n originalFile.content,\n originalFile.contentType || 'application/javascript',\n {\n originalFileKey: latestUserSkill.fileKey,\n originalNamespace: systemSkill.promotedFrom,\n updatedBy: authContext.namespace,\n updatedAt: new Date().toISOString(),\n skillName: skillName\n },\n authContext\n );\n \n console.log(`[SkillRegistry] Skill file updated in system folder: ${systemFileKey}`);\n } catch (error) {\n console.error('[SkillRegistry] Failed to update skill file in system folder:', error);\n // For backward compatibility, don't fail the update if file operations fail\n // Just use the original fileKey\n console.warn('[SkillRegistry] Continuing with original fileKey for backward compatibility');\n systemFileKey = systemSkill.fileKey;\n }\n }\n\n const systemSkillKey = this.getSystemSkillKey(skillName);\n const now = new Date().toISOString();\n\n // Update promoted system skill with latest user skill data\n const updatedPromotedSkill: SkillDefinition = {\n ...latestUserSkill,\n fileKey: systemFileKey, // Use the system file key\n isSystemSkill: true,\n promotedFrom: systemSkill.promotedFrom,\n promotedAt: systemSkill.promotedAt,\n promotedBy: systemSkill.promotedBy,\n updatedAt: now,\n };\n\n console.log('[SkillRegistry] updated promoted skillDefinition', systemSkillKey, updatedPromotedSkill);\n await this.kvStore.put(systemSkillKey, updatedPromotedSkill, undefined, true); // true = bypass namespace\n }\n\n async listPromotedSkills(): Promise {\n const systemSkills = await this.listSystemSkills();\n return systemSkills.filter(skill => skill.promotedFrom);\n }\n\n async getSystemSkill(skillName: string): Promise {\n console.log('[SkillRegistry] getSystemSkill', skillName);\n const skillKey = this.getSystemSkillKey(skillName);\n console.log('[SkillRegistry] system skillKey', skillKey);\n const skill = await this.kvStore.get(skillKey, true); // true = bypass namespace\n if (skill) {\n return { ...skill, isSystemSkill: true };\n }\n return null;\n }\n\n async listSystemSkills(): Promise {\n // For bypassed namespace queries, we need to provide pk:sk_pattern format\n // System skills are stored with pk=\"__system_skills__\" and sk=\"system:skillName\"\n // So we query with \"__system_skills__:system:*\" to get all skills in that partition\n const queryPattern = `__system_skills__:system:*`;\n const results = await this.kvStore.query(queryPattern, 1000, true); // true = bypass namespace\n \n return results.map(item => ({ ...item.value as SkillDefinition, isSystemSkill: true }));\n }\n\n async deleteSystemSkill(authContext: ExtendedAuthContext, skillName: string): Promise {\n if (!authContext.isSystemMode) {\n throw new Error(\"System skill deletion requires admin mode access\");\n }\n\n const skillKey = this.getSystemSkillKey(skillName);\n return await this.kvStore.delete(skillKey, true); // true = bypass namespace\n }\n\n async systemSkillExists(skillName: string): Promise {\n const skill = await this.getSystemSkill(skillName);\n return skill !== null;\n }\n\n // Combined skill resolution (user skills take precedence over system skills)\n async resolveSkill(authContext: AuthContext, skillName: string): Promise {\n // 1. Check user skills first (user can override system skills)\n const userSkill = await this.getSkill(authContext, skillName);\n if (userSkill) {\n return userSkill;\n }\n\n // 2. Fall back to system skills\n const systemSkill = await this.getSystemSkill(skillName);\n if (systemSkill) {\n return systemSkill;\n }\n\n return null;\n }\n\n // List all available skills (user + system) for a user\n async listAllAvailableSkills(authContext: AuthContext): Promise {\n const userSkills = await this.listSkills(authContext);\n const systemSkills = await this.listSystemSkills();\n \n // Create a map to handle user skill overrides\n const skillMap = new Map();\n \n // Add system skills first\n systemSkills.forEach(skill => {\n skillMap.set(skill.name, {...skill});\n });\n \n // Add user skills (will override system skills with same name)\n userSkills.forEach(skill => {\n skillMap.set(skill.name, skill);\n });\n \n return Array.from(skillMap.values());\n }\n}","deleted","label",[168,169,149],"src","storage","permalink","https://www.val.town/x/c15r/ContextualLite/code/src/storage/skill-registry.ts","extension","actionData","errors"]