refresh mcp

Author: RhysSullivan

.executor/executor.jsonc

@@ -29,18 +29,6 @@
       },
       "kind": "openapi"
     },
-    "github-graphql": {
-      "name": "GitHub GraphQL",
-      "namespace": "github.graphql",
-      "config": {
-        "endpoint": "https://api.github.com/graphql",
-        "defaultHeaders": null,
-        "auth": {
-          "kind": "none"
-        }
-      },
-      "kind": "graphql"
-    },
     "github-graphql-2": {
       "name": "GitHub GraphQL",
       "namespace": "github.graphql",
@@ -61,7 +49,6 @@
     "axiom-mcp": {
       "name": "Axiom MCP",
       "namespace": "axiom.mcp",
-      "kind": "mcp",
       "config": {
         "endpoint": "https://mcp.axiom.co/mcp",
         "transport": "auto",
@@ -129,6 +116,19 @@
             "client_id_issued_at": 1774829875
           }
         }
+      },
+      "kind": "mcp"
+    },
+    "linear-graphql": {
+      "name": "Linear GraphQL",
+      "namespace": "linear.graphql",
+      "kind": "graphql",
+      "config": {
+        "endpoint": "https://api.linear.app/graphql",
+        "defaultHeaders": null,
+        "auth": {
+          "kind": "none"
+        }
       }
     }
   }

packages/platform/server/src/index.test.ts

@@ -1334,6 +1334,48 @@ describe("local-executor-server", () => {
     15_000,
   );
 
+  it.scoped("refreshes an MCP source through the API client", () =>
+    Effect.gen(function* () {
+      const demoServer = yield* Effect.acquireRelease(
+        Effect.promise(() => startMcpElicitationDemoServer()),
+        (server) => Effect.promise(() => server.close()).pipe(Effect.orDie),
+      );
+      const { installation, client } = yield* createApiClientHarness();
+
+      const created = yield* client.mcp.createSource({
+        path: {
+          workspaceId: installation.scopeId,
+        },
+        payload: {
+          name: "Demo",
+          endpoint: demoServer.endpoint,
+          transport: "streamable-http",
+          queryParams: null,
+          headers: null,
+          command: null,
+          args: null,
+          env: null,
+          cwd: null,
+          auth: {
+            kind: "none",
+          },
+        },
+      });
+
+      const refreshed = yield* client.mcp.refreshSource({
+        path: {
+          workspaceId: installation.scopeId,
+          sourceId: created.id,
+        },
+      });
+
+      expect(refreshed.id).toBe(created.id);
+      expect(refreshed.kind).toBe("mcp");
+      expect(refreshed.status).toBe("connected");
+    }),
+    15_000,
+  );
+
   it.scoped("can run the same MCP elicitation flow more than once without interaction id collisions", () =>
     Effect.gen(function* () {
       const demoServer = yield* Effect.acquireRelease(

plugins/mcp/http/index.ts

@@ -55,6 +55,9 @@ type McpExecutorExtension = {
     updateSource: (
       input: McpUpdateSourceInput,
     ) => Effect.Effect<Source, Error>;
+    refreshSource: (
+      sourceId: Source["id"],
+    ) => Effect.Effect<Source, Error>;
     removeSource: (
       sourceId: Source["id"],
     ) => Effect.Effect<boolean, Error>;
@@ -117,6 +120,14 @@ export const McpHttpGroup = HttpApiGroup.make("mcp")
       .addError(ControlPlaneNotFoundError)
       .addError(ControlPlaneStorageError),
   )
+  .add(
+    HttpApiEndpoint.post("refreshSource")`/workspaces/${workspaceIdParam}/plugins/mcp/sources/${sourceIdParam}/refresh`
+      .addSuccess(SourceSchema)
+      .addError(ControlPlaneBadRequestError)
+      .addError(ControlPlaneForbiddenError)
+      .addError(ControlPlaneNotFoundError)
+      .addError(ControlPlaneStorageError),
+  )
   .add(
     HttpApiEndpoint.del("removeSource")`/workspaces/${workspaceIdParam}/plugins/mcp/sources/${sourceIdParam}`
       .addSuccess(Schema.Struct({ removed: Schema.Boolean }))
@@ -284,6 +295,17 @@ export const mcpHttpPlugin = (): ExecutorHttpPlugin<
             ),
           )
         )
+        .handle("refreshSource", ({ path }) =>
+          resolveRequestedLocalWorkspace(
+            "mcp.refreshSource",
+            path.workspaceId,
+          ).pipe(
+            Effect.flatMap(() => executor.mcp.refreshSource(path.sourceId)),
+            Effect.mapError((cause) =>
+              mapPluginStorageError("mcp.refreshSource", cause)
+            ),
+          )
+        )
         .handle("removeSource", ({ path }) =>
           resolveRequestedLocalWorkspace(
             "mcp.removeSource",

plugins/mcp/react/components.tsx

@@ -733,6 +733,25 @@ export function McpDetailPage(props: {
     client.mutation("mcp", "removeSource"),
     { mode: "promise" },
   );
+  const refreshSource = useAtomSet(
+    client.mutation("mcp", "refreshSource"),
+    { mode: "promise" },
+  );
+  const refreshMutation = useExecutorMutation<Source["id"], Source>(async (sourceId) =>
+    refreshSource({
+      path: {
+        workspaceId: props.source.scopeId,
+        sourceId,
+      },
+      reactivityKeys: {
+        sources: [props.source.scopeId],
+        source: [props.source.scopeId, sourceId],
+        sourceInspection: [props.source.scopeId, sourceId],
+        sourceInspectionTool: [props.source.scopeId, sourceId],
+        sourceDiscovery: [props.source.scopeId, sourceId],
+      },
+    })
+  );
   const [confirmDelete, setConfirmDelete] = useState(false);
   const [isDeleting, setIsDeleting] = useState(false);
   const configResult = useAtomValue(
@@ -815,6 +834,19 @@ export function McpDetailPage(props: {
         <>
           <Button
             variant="outline"
+            size="sm"
+            type="button"
+            onClick={() => {
+              void refreshMutation.mutateAsync(props.source.id);
+            }}
+            disabled={refreshMutation.status === "pending"}
+          >
+            {refreshMutation.status === "pending" ? "Refreshing..." : "Refresh"}
+          </Button>
+          <Button
+            variant="outline"
+            size="sm"
+            type="button"
             onClick={() =>
               void navigation.edit(props.source.id)}
           >

plugins/mcp/sdk/index.ts

@@ -163,6 +163,9 @@ export type McpSdk = {
   updateSource: (
     input: McpUpdateSourceInput,
   ) => Effect.Effect<Source, Error>;
+  refreshSource: (
+    sourceId: Source["id"],
+  ) => Effect.Effect<Source, Error>;
   removeSource: (
     sourceId: Source["id"],
   ) => Effect.Effect<boolean, Error>;
@@ -948,6 +951,13 @@ export const mcpSdkPlugin = (
       outputSchema: SourceSchema,
       execute: ({ args, source }) => source.updateSource(args),
     },
+    {
+      name: "refreshSource",
+      description: "Refresh an MCP source and resync its catalog.",
+      inputSchema: McpSourceIdInputSchema,
+      outputSchema: SourceSchema,
+      execute: ({ args, source }) => source.refreshSource(args.sourceId),
+    },
     {
       name: "removeSource",
       description: "Remove an MCP source and its stored plugin data.",
@@ -1092,6 +1102,8 @@ export const mcpSdkPlugin = (
         provideRuntime(source.createSource(input)),
       updateSource: (input) =>
         provideRuntime(source.updateSource(input)),
+      refreshSource: (sourceId) =>
+        provideRuntime(source.refreshSource(sourceId)),
       removeSource: (sourceId) =>
         provideRuntime(source.removeSource(sourceId)),
       startOAuth: (input) =>