Function addServer

packages/plugins/mcp/src/sdk/plugin.ts:970–1055

(input: McpServerInput)

        );

      const addServer = (input: McpServerInput) =>
        Effect.gen(function* () {
          const slug = normalizeSlug(input);
          const config = toIntegrationConfig(input);

          // Block re-adding an existing slug. The core `integrations.register`
          // primitive upserts (so boot re-registration is idempotent), but an
          // explicit add must NOT silently clobber an existing integration's
          // tools, connections, and policies. To add more auth, update the
          // existing integration instead.
          const existing = yield* ctx.core.integrations.get(slugFrom(slug));
          if (existing) {
            return yield* new IntegrationAlreadyExistsError({ slug: slugFrom(slug) });
          }

          yield* ctx.core.integrations
            .register({
              slug: slugFrom(slug),
              name: input.name,
              description: input.description?.trim() || input.name,
              config,
              canRemove: true,
              canRefresh: true,
            })
            .pipe(
              Effect.withSpan("mcp.plugin.register_integration", {
                attributes: { "mcp.integration.slug": slug },
              }),
            );

          // Auto-create the stdio server's default connection so its tools are
          // discovered immediately (without it the integration lands with zero
          // connections and therefore zero tools — the fresh-install "no tools
          // detected" report). Two cases connect on add:
          //   • one-shot `env` VALUES were supplied (agent path) → bind them as
          //     the connection's secrets.
          //   • the server needs NO secret env at all → a no-auth connection.
          // When the server only DECLARES env var names (the UI path), the
          // secrets are still missing, so we leave the connection to the connect
          // step where the user enters one masked value per declared var.
          if (input.transport === "stdio") {
            const hasValues = input.env != null && Object.keys(input.env).length > 0;
            const declaresSecrets = stdioEnvVarNames(input).length > 0;
            if (hasValues || !declaresSecrets) {
              yield* ctx.connections
                .create({
                  owner: "org",
                  name: ConnectionName.make("default"),
                  integration: slugFrom(slug),
                  template: AuthTemplateSlug.make(hasValues ? STDIO_ENV_TEMPLATE : "none"),
                  values: hasValues ? { ...input.env } : {},
                })
                .pipe(
                  // These can't arise right after a successful register with
                  // valid inputs, but the channel must stay within
                  // McpExtensionFailure; surface them as a connection error
                  // rather than swallow a real failure.
                  Effect.catchTags({