Function mcpCall

e2e/scripts/cli.ts:428–453

(
  targetName: string,
  sub: string | undefined,
  rest: ReadonlyArray<string>,
)

};

const mcpCall = async (
  targetName: string,
  sub: string | undefined,
  rest: ReadonlyArray<string>,
) => {
  const { target } = await loadTarget(targetName);
  const { Effect } = await import("effect");
  const { FetchHttpClient } = await import("effect/unstable/http");
  const { makeMcpSurface } = await import("../src/surfaces/mcp");
  const surface = makeMcpSurface(target);

  const result = await Effect.runPromise(
    Effect.gen(function* () {
      const who = yield* target.newIdentity();
      const session = surface.session(who);
      if (sub === "tools") return yield* session.listTools();
      if (sub === "call") {
        const [tool, json] = rest;
        if (!tool) throw new Error("usage: mcp <target> call <tool> [json]");
        return yield* session.call(tool, json ? (JSON.parse(json) as Record<string, unknown>) : {});
      }
      throw new Error("usage: mcp <target> tools | call <tool> [json]");
    }).pipe(Effect.provide(FetchHttpClient.layer)),
  );
  console.log(JSON.stringify(result, null, 2));
};

const ledger = async (targetName: string, service = "workos") => {
  const state = readState(targetName);