Function driveOpenApiWork

apps/local/src/db/v1-v2-boot-drive.test.ts:171–215

(
  stack: Awaited<ReturnType<typeof bootRealStack>>,
  server: { readonly specJson: string },
  slug: string,
)

/** addSpec + connection + live invocation through the booted executor. */
const driveOpenApiWork = (
  stack: Awaited<ReturnType<typeof bootRealStack>>,
  server: { readonly specJson: string },
  slug: string,
) =>
  Effect.gen(function* () {
    const added = yield* stack.executor.openapi.addSpec({
      spec: { kind: "blob", value: server.specJson },
      slug,
      authenticationTemplate: [
        {
          slug: AuthTemplateSlug.make("apiKey"),
          type: "apiKey",
          headers: { "x-api-key": [{ type: "variable" as const, name: "token" }] },
        },
      ],
    });
    expect(added.toolCount).toBeGreaterThanOrEqual(2);

    yield* stack.executor.connections.create({
      owner: "org",
      name: ConnectionName.make("main"),
      integration: IntegrationSlug.make(slug),
      template: AuthTemplateSlug.make("apiKey"),
      value: "test-key-123",
    });

    const list = yield* stack.executor.execute(
      ToolAddress.make(`tools.${slug}.org.main.widgets.listWidgets`),
      {},
    );
    expect(isToolResult(list) && list.ok).toBe(true);
    if (!isToolResult(list) || !list.ok) return;
    // Payload-first contract holds through a migrated database too.
    expect(list.data).toEqual(WIDGETS);
    expect((list as { http?: { status: number } }).http?.status).toBe(200);

    const created = yield* stack.executor.execute(
      ToolAddress.make(`tools.${slug}.org.main.widgets.createWidget`),
      { body: { name: "doodad" } },
    );
    expect(isToolResult(created) && created.ok).toBe(true);
    if (!isToolResult(created) || !created.ok) return;
    expect(created.data).toEqual({ id: 3, name: "doodad" });
  });

const expectToolRows = async (dbPath: string, slug: string, minCount: number) => {
  const client = await openLocalLibsql(dbPath);