compose

compose<TResult>(operations, executor): Operation<TResult>

Defined in: packages/db/src/compose.ts:47

Merges multiple Operations into a single operation with combined, deduplicated permissions and an executor function for controlling data flow.

compose() itself does not check permissions — it only merges them. Each sub-operation’s .run() still performs its own permission check when the executor calls it. This enables data dependencies between operations (e.g., using an insert result’s ID in an audit log).

Type Parameters

TResult

TResult

The return type of the executor function.

Parameters

operations

Operation<unknown>[]

The operations to compose. Their permissions are merged and deduplicated.

executor

(…runs) => TResult | Promise<TResult>

A function that receives a run function for each operation (in order). You control execution order, data flow between operations, and the return value.

Returns

Operation<TResult>

A single Operation with combined permissions.

Example

import { compose } from "@cfast/db";

const publishWorkflow = compose(
  [updatePost, insertAuditLog],
  async (doUpdate, doAudit) => {
    const updated = await doUpdate({});
    await doAudit({});
    return { published: true };
  },
);

// Inspect combined permissions
publishWorkflow.permissions;
// => [{ action: "update", table: "posts" }, { action: "create", table: "audit_logs" }]

// Execute all sub-operations
await publishWorkflow.run({});