Function waitForCondition

test/core/bridge_coordinator.test.ts:1021–1031

(predicate, { timeoutMs = 1000, intervalMs = 10 } = {})

}

async function waitForCondition(predicate, { timeoutMs = 1000, intervalMs = 10 } = {}) {
  const deadline = Date.now() + timeoutMs;
  while (Date.now() < deadline) {
    const value = predicate();
    if (value) {
      return value;
    }
    await new Promise((resolve) => setTimeout(resolve, intervalMs));
  }
  throw new Error('Timed out waiting for condition');
}

async function fullyConfirmLatestAgentJob(runtime, externalScopeId: string) {
  const created = await runtime.services.bridgeCoordinator.handleInboundEvent({