Function runBoundAction

packages/hosts/mcp/src/artifacts-tools.test.ts:1889–1929

(input: {
    readonly code: string;
    readonly available: readonly BindableConnection[];
    readonly connections?: Record<string, string>;
    readonly action: Record<string, unknown>;
    readonly artifactIdOverride?: string;
  })

  /** Saves a bound artifact, then runs one call from it and reports both the
   *  tool result and whatever code actually reached the engine. */
  const runBoundAction = async (input: {
    readonly code: string;
    readonly available: readonly BindableConnection[];
    readonly connections?: Record<string, string>;
    readonly action: Record<string, unknown>;
    readonly artifactIdOverride?: string;
  }) => {
    const store = makeArtifactStore();
    const executed: string[] = [];
    const engine = makeStubEngine({
      executeWithPause: (code: string) =>
        Effect.sync(() => {
          executed.push(code);
          return { status: "completed", result: { result: "ok" } };
        }),
    });

    let result: Awaited<ReturnType<Client["callTool"]>> | undefined;
    await withClient(
      engine,
      APPS_CAPS,
      async (client) => {
        const created = await client.callTool({
          name: "create-artifact",
          arguments: {
            code: input.code,
            title: "Bound",
            ...(input.connections === undefined ? {} : { connections: input.connections }),
          },
        });
        expect(created.isError, textOf(created)).toBeFalsy();
        const artifactId = input.artifactIdOverride ?? String(structuredOf(created).artifactId);
        result = await client.callTool({
          name: "execute-action",
          arguments: { ...input.action, artifactId },
        });
      },
      { artifacts: store.port, connections: connectionsPort(input.available) },
    );
    return { result: result!, executed };
  };

  it("expands a short path through the artifact's binding", async () => {
    const { result, executed } = await runBoundAction({