[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_112":113,"_114":115},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","nbbaier","name","townie-slackbot","path","connectors/registry.ts","project",{"_22":48,"_11":12,"_35":49,"_50":-5,"_51":44,"_52":53,"_54":53,"_55":56,"_57":58,"_59":60,"_61":62,"_63":34,"_64":-5,"_65":-5,"_66":38,"_67":68,"_69":70,"_71":72,"_73":74,"_75":-5,"_76":77,"_78":77,"_79":80,"_81":80,"_82":80,"_83":77,"_84":77,"_85":86,"_87":88,"_89":90,"_91":44},"file",{"_22":23,"_11":24,"_25":26,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":-5,"_13":46},"permalink","https://www.val.town/x/nbbaier/townie-slackbot/code/connectors/registry.ts","extension","id","18ea94be-5afe-4fce-bf6c-ebdeb0f02422","registry.ts","fileId","01a026ee-4ccb-7558-abd5-0b53cb4265a1","parentId","01a026ee-4ccb-7558-abd5-0f8e5bde6d2b","branchId","c98fe62e-e4a5-4985-a211-8127f69af2d1","branchVersion",1,"latest",true,"createdAt",["D",1787359546508],"version",0,"fileType","script","content","/**\n * MCP Connector Registry + tool loader.\n *\n * Each entry in CONNECTORS defines an external MCP service that can be\n * connected via OAuth. Add or remove services here — the setup page,\n * OAuth routes, and tool loader all read from this single registry.\n *\n * Tools are loaded on-demand using each service's OAuth access token.\n * If a service isn't connected (no valid token), its tools are simply\n * omitted — nothing breaks.\n */\n\nimport { createMCPClient } from \"npm:@ai-sdk/mcp@1.0.21\";\nimport { getValidAccessToken } from \"./oauth.ts\";\n\n// ── Connector config ─────────────────────────────────────────────────────────\n\nexport type ConnectorConfig = {\n name: string; // Human-readable name (e.g. \"Notion\")\n mcpUrl: string; // MCP server endpoint\n description: string; // Shown in system prompt when disconnected\n scopes?: string[]; // OAuth scopes to request (if any)\n};\n\n/**\n * Register external MCP services here. Each key is a URL-safe identifier\n * used in OAuth routes (/auth/) and token storage.\n */\nexport const CONNECTORS: Record = {\n // ── Notion connector DISABLED 2026-07-31 (security review) ──────────────\n // Commented out because the /auth/* OAuth routes are unauthenticated (the\n // ADMIN_SECRET gate was never wired up), so a registered connector's\n // shared, team-wide token could be hijacked or overwritten by anyone who\n // reached the val origin. Not connected in prod anyway. This registry is\n // the single source of truth — the setup page, OAuth routes, and tool\n // loader all read from it, so leaving CONNECTORS empty disables the whole\n // connector surface. Re-enable by uncommenting (and wire ADMIN_SECRET\n // first).\n // notion: {\n // name: \"Notion\",\n // mcpUrl: \"https://mcp.notion.com/mcp\",\n // description:\n // \"Search, read, and edit Notion pages and databases in the team workspace\",\n // },\n // ── Add more connectors here ────────────────────────────────────────────\n // github: {\n // name: \"GitHub\",\n // mcpUrl: \"https://api.github.com/mcp\",\n // description: \"Manage repos, issues, PRs, and code\",\n // scopes: [\"repo\", \"read:org\"],\n // },\n};\n\n// ── Tool loader ──────────────────────────────────────────────────────────────\n\ntype McpTools = Awaited>[\"tools\"]>>;\n\n// Cache per service — cleared when tokens rotate so we reconnect\nconst toolsCache: Record = {};\n\n/**\n * Load MCP tools for a given service. Returns empty object if not connected.\n * Tools are cached for 50 minutes (tokens last 60 min).\n */\nexport async function getServiceTools(service: string): Promise {\n const config = CONNECTORS[service];\n if (!config) {\n console.warn(`[Connectors] Unknown service: ${service}`);\n return {} as McpTools;\n }\n\n // Check cache\n const cached = toolsCache[service];\n if (cached && cached.expiresAt > Date.now()) {\n return cached.tools;\n }\n\n const accessToken = await getValidAccessToken(service);\n if (!accessToken) {\n // Not connected — just skip, nothing breaks\n delete toolsCache[service];\n return {} as McpTools;\n }\n\n try {\n console.log(`[Connectors] Connecting to ${config.name} MCP...`);\n const client = await createMCPClient({\n transport: {\n type: \"http\",\n url: config.mcpUrl,\n headers: {\n Authorization: `Bearer ${accessToken}`,\n },\n },\n });\n\n const tools = await client.tools();\n const toolNames = Object.keys(tools);\n console.log(`[Connectors] ${config.name} tools loaded: ${toolNames.join(\", \")}`);\n\n // Cache for 50 minutes\n toolsCache[service] = { tools, expiresAt: Date.now() + 50 * 60 * 1000 };\n\n return tools;\n } catch (err) {\n console.error(`[Connectors] ${config.name} connection failed:`, err);\n delete toolsCache[service];\n return {} as McpTools;\n }\n}\n\n/**\n * Load tools for ALL registered connectors. Returns merged tool set.\n * Disconnected services are silently skipped (empty tools).\n */\nexport async function getAllConnectorTools(): Promise {\n const all: McpTools = {} as McpTools;\n for (const service of Object.keys(CONNECTORS)) {\n const tools = await getServiceTools(service);\n Object.assign(all, tools);\n }\n return all;\n}\n\n/**\n * Get list of services that are NOT connected (no valid token).\n */\nexport async function getDisconnectedServices(): Promise {\n const disconnected: string[] = [];\n for (const service of Object.keys(CONNECTORS)) {\n const token = await getValidAccessToken(service);\n if (!token) disconnected.push(service);\n }\n return disconnected;\n}\n","deleted",false,"label",[47,24],"connectors","721185aa-9345-4fa6-a7de-8fce15275464",["D",1787359546508],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","BYOA Slack agent powered by Claude + Val Town MCP","imageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/9d7c45b4-38a8-441c-1ffb-cc9c79a0f000/square512?exp=1789666005&sig=1c0c2b2d65499d92293fa91584c3378573846f957602ed324bcff2de8c11c94b","userId","5d1042a9-7b0b-499d-8a72-3a8ac7a4e185","pinnedFileId","01a026ee-4ccc-72a8-897e-b050402a80c5","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","5f80108f-7ca4-4327-b77b-089dbe4b5a82","tursoName","721185aa93454fa6a7de8fce15275464","tursoHostname","721185aa93454fa6a7de8fce15275464-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789618867318],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_111":107},"org",{"_9":10,"_105":-5,"_106":107,"_59":60,"_108":109,"_110":44},"branch",{"_37":32,"_11":92,"_22":30,"_93":48,"_94":95,"_96":97,"_98":53,"_99":100,"_101":102,"_103":12,"_104":10},"isOwned","main","projectId","forkedBranchId","22878860-7ef2-46a5-b121-c919b4589b8d","forkedBranchVersion",229,"forkedProjectPrivacy","forkedProjectId","c15ce0c4-49b2-4207-bd81-70dcc91daf31","forkedProjectOrgId","019aa807-52c2-709c-928b-2029bae9a558","projectName","userHandle","displayName","avatar","https://secure.gravatar.com/avatar/0129a541b7b3574e92c4afd06c5e32da&d=identicon","tier","pro","canRestrictVals","profileImageUrl","ctx",{"_85":-5,"_145":146,"_147":148,"_149":150,"_151":44,"_152":44,"_153":44,"_154":34,"_155":-5,"_156":-7,"_157":-7,"_158":38,"_159":44,"_160":44,"_161":-5,"_162":44,"_163":44,"_164":44,"_165":-5},"ENV",{"_116":117,"_118":119,"_120":92,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138,"_139":140,"_141":142,"_143":144},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","a3e067d4463eea85f6334f8e583e8516ae58c4f6","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]