Function registerPassthroughTools

packages/hosts/mcp/src/tool-server.ts:1271–1516

(
  server: McpServer,
  tools: McpToolsPort,
  connections: McpConnectionsPort,
  integrations: McpIntegrationsPort,
  run: (
    address: ToolAddress,
    args: unknown,
    extra: McpRequestJoinKeys,
  ) => Effect.Effect<McpToolResult, E>,
)

/** Register discovery over the existing APIs, with no catalog work at connection time. */
const registerPassthroughTools = <E extends Cause.YieldableError>(
  server: McpServer,
  tools: McpToolsPort,
  connections: McpConnectionsPort,
  integrations: McpIntegrationsPort,
  run: (
    address: ToolAddress,
    args: unknown,
    extra: McpRequestJoinKeys,
  ) => Effect.Effect<McpToolResult, E>,
): Effect.Effect<void> =>
  Effect.gen(function* () {
    const context = yield* Effect.context<never>();
    const validator = new CfWorkerJsonSchemaValidator();
    const boundary = <A extends McpToolResult, F>(
      effect: Effect.Effect<A, F>,
      extra: McpRequestJoinKeys,
    ) =>
      Effect.runPromiseWith(context)(
        effect.pipe(
          Effect.provideService(
            CurrentOrgWriteAccess,
            makeOrgWriteAccessState(requestOrgWriteAccess(extra)),
          ),
          Effect.catchCause((cause) => Effect.succeed(toMcpFailureResult(cause))),
        ),
      );
    yield* Effect.sync(() => {
      server.registerTool(
        "integrations",
        {
          description:
            "List connected integrations and accounts visible to you. Returns integration descriptions, account labels, exact search filters, and last recorded health (null means unchecked). One item per account; use nextOffset for more. Does not load tool schemas or check credentials.",
          inputSchema: {
            integration: z.string().trim().min(1).optional().describe("Exact integration slug."),
            owner: z.enum(["org", "user"]).optional(),
            limit: z.number().int().min(1).max(50).default(20),
            offset: z.number().int().min(0).default(0),
          },
          annotations: { readOnlyHint: true, destructiveHint: false, openWorldHint: false },
        },
        ({ integration, owner, limit, offset }, extra) =>
          boundary(
            Effect.gen(function* () {
              const [accounts, catalog] = yield* Effect.all([
                connections.list(),
                integrations.list(),
              ]);
              const metadata = new Map(catalog.map((item) => [String(item.slug), item]));
              const visible = accounts
                .flatMap((account) => {
                  const item = metadata.get(account.integration);
                  if (
                    !item ||
                    (integration !== undefined && account.integration !== integration) ||
                    (owner !== undefined && account.owner !== owner)
                  )
                    return [];