Function apiCall

e2e/scripts/cli.ts:389–431

(targetName: string, endpoint: string | undefined, json?: string)

};

const apiCall = async (targetName: string, endpoint: string | undefined, json?: string) => {
  if (!endpoint?.includes(".")) {
    throw new Error("usage: api <target> <group.endpoint> [json] — e.g. api selfhost tools.list");
  }
  const { target } = await loadTarget(targetName);
  const [group, method] = endpoint.split(".", 2) as [string, string];
  // No-arg endpoints (tools.list) reject a spurious {}; only pass what was given.
  const args = json === undefined ? undefined : (JSON.parse(json) as Record<string, unknown>);

  const { Effect } = await import("effect");
  const { FetchHttpClient } = await import("effect/unstable/http");
  const { composePluginApi } = await import("@executor-js/api/server");
  const { openApiHttpPlugin } = await import("@executor-js/plugin-openapi/api");
  const { graphqlHttpPlugin } = await import("@executor-js/plugin-graphql/api");
  const { mcpHttpPlugin } = await import("@executor-js/plugin-mcp/api");
  const { makeApiSurface } = await import("../src/surfaces/api");

  const apiDef = composePluginApi([
    openApiHttpPlugin(),
    graphqlHttpPlugin(),
    mcpHttpPlugin(),
  ] as const);
  const surface = makeApiSurface(target);

  // The endpoint is picked at runtime, so the client is driven untyped here —
  // the full static typing lives in scenarios; this is the interactive probe.
  const program = Effect.gen(function* () {
    const who = yield* target.newIdentity();
    // eslint-disable-next-line @typescript-eslint/no-explicit-any
    const client: any = yield* surface.client(apiDef as any, who);
    if (typeof client[group]?.[method] !== "function") {
      const groups = Object.keys(client).filter((k) => typeof client[k] === "object");
      throw new Error(`no endpoint ${endpoint}; groups: ${groups.join(", ")}`);
    }
    return yield* client[group][method](args);
  }) as import("effect").Effect.Effect<
    unknown,
    unknown,
    import("effect/unstable/http").HttpClient.HttpClient
  >;
  const result = await Effect.runPromise(program.pipe(Effect.provide(FetchHttpClient.layer)));
  console.log(JSON.stringify(result, null, 2));
};

const mcpCall = async (
  targetName: string,