Function removeServer

packages/plugins/mcp/src/sdk/plugin.ts:1021–1094

(slug: string)

        }).pipe(Effect.withSpan("mcp.plugin.reconcile_stdio_connections"));

      const removeServer = (slug: string) =>
        Effect.gen(function* () {
          const integration = slugFrom(slug);
          const record = yield* ctx.core.integrations.get(integration);
          const config = record ? parseMcpIntegrationConfig(record.config) : null;
          const legacyCandidates = legacyOAuthClientSlugCandidates(slug, record);
          const connections = yield* ctx.connections.list({ integration });
          const allConnections = yield* ctx.connections.list();
          const oauthClientSummaries = yield* ctx.oauth.listClients();
          const usedElsewhere = new Set(
            allConnections
              .filter((connection) => String(connection.integration) !== String(integration))
              .flatMap((connection) =>
                connection.oauthClient == null
                  ? []
                  : [
                      oauthClientKey(
                        connection.oauthClientOwner ?? connection.owner,
                        connection.oauthClient,
                      ),
                    ],
              ),
          );
          const oauthClientsByKey = new Map(
            oauthClientSummaries.map((client) => [
              oauthClientKey(client.owner, client.slug),
              client,
            ]),
          );
          const clientsToRemove = new Map<
            string,
            { readonly owner: Owner; readonly slug: OAuthClientSlug }
          >();

          for (const connection of connections) {
            if (connection.oauthClient == null) continue;
            const owner = connection.oauthClientOwner ?? connection.owner;
            const key = oauthClientKey(owner, connection.oauthClient);
            const client = oauthClientsByKey.get(key);
            if (client?.origin.kind !== "dynamic_client_registration") continue;
            clientsToRemove.set(key, {
              owner,
              slug: connection.oauthClient,
            });
          }
          for (const client of oauthClientSummaries) {
            const key = oauthClientKey(client.owner, client.slug);
            if (usedElsewhere.has(key)) continue;
            if (
              client.origin.kind === "dynamic_client_registration" &&
              (client.origin.integration == null || String(client.origin.integration) === slug)
            ) {
              clientsToRemove.set(key, { owner: client.owner, slug: client.slug });
              continue;
            }
            if (legacyMcpClientMatches(client, legacyCandidates, config)) {
              clientsToRemove.set(key, { owner: client.owner, slug: client.slug });
            }