Function recordCredentialLaunch

packages/core/sdk/src/executor.test.ts:1070–1091

(maxOps?: number)

/** Same, for the post-approval half: credential resolution vs the
 *  integration-row read. */
const recordCredentialLaunch = (maxOps?: number) =>
  Effect.gen(function* () {
    const recorder = makeReadOrderRecorder();
    const calls = { count: 0 };
    const provider = countingProvider(calls, (run) => recorder.record("credential.get", run));
    const config = makeTestConfig({
      plugins: [invokeConcurrencyPlugin(provider)] as const,
    });
    const executor = yield* createExecutor({
      ...config,
      db: withRecordedReads(config.db, recorder.record),
    });
    yield* seedRunConnection(executor);

    recorder.arm(["credential.get", "integration.findFirst"]);
    const execute = executor.execute(addr("run"), {});
    const out = yield* maxOps === undefined
      ? execute
      : execute.pipe(Effect.provideService(Scheduler.MaxOpsBeforeYield, maxOps));
    expect(out).toEqual({ ran: "run" });
    return recorder;
  });

/** Assert every armed read genuinely ran to completion — `start:` and
 *  `end:` present for each key — carrying the budget and full event log into