import { B as BrowserDeliveryPayload, R as RunResultPayload } from './index-DnJqGDij.js'; export { O as OAuthCallbackTunnelPayload, e as OAuthTokensTunnelPayload, P as ProcessCorsairOptions, f as ProcessCorsairRequest, a as RunStepResult, b as RunTriggerType, c as RunTunnelPayload, T as TunnelAck, i as TunnelEnvelope, j as TunnelType, W as WebhookTunnelPayload, d as applyPermissionDecision, p as processCorsair, r as resolveAccountFromWebhookLink, g as resolveTenantFromWebhookLink, h as resolveTenantIdFromWebhookLink, s as setWebhookTenantLink } from './index-DnJqGDij.js'; export { v as verifyBrowserDeliveryToken } from './browser-delivery-B7lsTRG3.js'; import './types-Bsv_KdHs.js'; import './index-eydqYIn0.js'; import 'zod'; import './index-bq7b_mHy.js'; import './db.js'; import 'kysely'; import 'pg'; import 'postgres'; import './orm.js'; declare function isAuthCredentialsBrowserDelivery(payload: BrowserDeliveryPayload): boolean; declare function isPermissionBrowserDelivery(payload: BrowserDeliveryPayload): boolean; declare function isManagedBrowserDelivery(payload: BrowserDeliveryPayload): boolean; declare function isByoOAuthBrowserDelivery(payload: BrowserDeliveryPayload): boolean; /** * The step primitive handed to workflow code. Callable for normal work * (`step(name, fn)`) with a `.sleep` method for durable pauses — mirroring * Inngest's `step.run` / `step.sleep`. */ interface WorkflowStep { /** Runs `fn` once, memoizing its result so retries replay it instead of re-running. */ (name: string, fn: () => Promise): Promise; /** Durably pauses the workflow for `ms`. Survives restarts; resumes after the delay. */ sleep(name: string, ms: number): Promise; } type ExecuteWorkflowRunInput = { /** The tenant-scoped Corsair client passed as the first arg to `main`. */ corsair: unknown; /** CJS module source that assigns `module.exports.main`. */ code: string; /** Webhook body (or null for schedule/manual triggers). */ payload: unknown; /** Outputs of steps that already completed on prior attempts, keyed by name. */ memoizedSteps?: Record; /** Max run time (sync + wall-clock) in ms. Defaults to {@link WORKFLOW_TIMEOUT_MS}. */ timeoutMs?: number; }; /** * Executes one workflow attempt. Never throws for workflow-level failures — the * outcome (including which step failed) is returned in {@link RunResultPayload}. */ declare function executeWorkflowRun(input: ExecuteWorkflowRunInput): Promise; export { BrowserDeliveryPayload, type ExecuteWorkflowRunInput, RunResultPayload, type WorkflowStep, executeWorkflowRun, isAuthCredentialsBrowserDelivery, isByoOAuthBrowserDelivery, isManagedBrowserDelivery, isPermissionBrowserDelivery };