import { $n as NodeActivationContinuation, $t as RunId, D as RunCurrentState, Et as Items, H as WorkflowExecutionRepository, I as RunStopCondition, Jt as ParentExecutionRef, Lr as WebhookInvocationMatch, N as RunResult, Nr as WorkflowSnapshotResolver, Nt as NodeActivationId, Pr as HttpMethod, Qi as NodeId, Rr as WebhookTriggerMatcher, Wt as NodeOutputs, Zn as LiveWorkflowRepository, cn as WorkflowDefinition, hr as ResumeContext, k as RunExecutionOptions, kr as WorkflowRepository, or as NodeExecutionRequest, p as NodeInputsByPort, s as CurrentStateExecutionRequest, sr as NodeExecutionRequestHandler, ta as WorkflowId, w as PersistedWorkflowTokenRegistryLike, z as WebhookRunResult, zr as WebhookTriggerResolution } from "./agentMcpTypes-BHX4RQCC.cjs";

//#region src/orchestration/Engine.d.ts
interface EngineTriggerRuntime {
  startTriggers(): Promise<void>;
  stop(): Promise<void>;
  syncWorkflowTriggersForActivation(workflowId: WorkflowId): Promise<void>;
  createTriggerTestItems(args: {
    workflow: WorkflowDefinition;
    nodeId: NodeId;
  }): Promise<Items | undefined>;
}
interface EngineRunStartService {
  runWorkflow(wf: WorkflowDefinition, startAt: NodeId, items: Items, parent?: ParentExecutionRef, executionOptions?: RunExecutionOptions, persistedStateOverrides?: Readonly<{
    workflowSnapshot?: NonNullable<Awaited<ReturnType<WorkflowExecutionRepository["load"]>>>["workflowSnapshot"];
    mutableState?: NonNullable<Awaited<ReturnType<WorkflowExecutionRepository["load"]>>>["mutableState"];
  }>): Promise<RunResult>;
  runWorkflowFromState(request: CurrentStateExecutionRequest): Promise<RunResult>;
}
interface EngineRunContinuationService {
  markNodeRunning(args: {
    runId: RunId;
    activationId: NodeActivationId;
    nodeId: NodeId;
    inputsByPort: NodeInputsByPort;
  }): Promise<void>;
  resumeFromNodeResult(args: {
    runId: RunId;
    activationId: NodeActivationId;
    nodeId: NodeId;
    outputs: NodeOutputs;
  }): Promise<RunResult>;
  resumeFromNodeError(args: {
    runId: RunId;
    activationId: NodeActivationId;
    nodeId: NodeId;
    error: Error;
  }): Promise<RunResult>;
  resumeFromStepResult(args: {
    runId: RunId;
    activationId: NodeActivationId;
    nodeId: NodeId;
    outputs: NodeOutputs;
  }): Promise<RunResult>;
  resumeFromStepError(args: {
    runId: RunId;
    activationId: NodeActivationId;
    nodeId: NodeId;
    error: Error;
  }): Promise<RunResult>;
  waitForCompletion(runId: RunId): Promise<Extract<RunResult, {
    status: "completed" | "failed" | "halted";
  }>>;
  waitForWebhookResponse(runId: RunId): Promise<WebhookRunResult>;
  resumeRun(args: {
    runId: RunId;
    taskId: string;
    resumeContext: ResumeContext;
  }): Promise<RunResult>;
}
interface EngineNodeExecutionRequestHandler {
  handleNodeExecutionRequest(request: NodeExecutionRequest): Promise<void>;
}
interface EngineFacadeDeps {
  liveWorkflowRepository: LiveWorkflowRepository;
  tokenRegistry: PersistedWorkflowTokenRegistryLike;
  webhookTriggerMatcher: WebhookTriggerMatcher;
  workflowSnapshotResolver: WorkflowSnapshotResolver;
  triggerRuntime: EngineTriggerRuntime;
  runStartService: EngineRunStartService;
  runContinuationService: EngineRunContinuationService;
  nodeExecutionRequestHandler: EngineNodeExecutionRequestHandler;
}
declare class Engine implements NodeActivationContinuation, NodeExecutionRequestHandler {
  private readonly deps;
  constructor(deps: EngineFacadeDeps);
  loadWorkflows(workflows: ReadonlyArray<WorkflowDefinition>): void;
  getTokenRegistry(): EngineFacadeDeps["tokenRegistry"];
  resolveWorkflowSnapshot(args: {
    workflowId: WorkflowId;
    workflowSnapshot?: NonNullable<Awaited<ReturnType<WorkflowExecutionRepository["load"]>>>["workflowSnapshot"];
  }): WorkflowDefinition | undefined;
  startTriggers(): Promise<void>;
  syncWorkflowTriggersForActivation(workflowId: WorkflowId): Promise<void>;
  start(workflows: WorkflowDefinition[]): Promise<void>;
  stop(): Promise<void>;
  resolveWebhookTrigger(args: {
    endpointPath: string;
    method: HttpMethod;
  }): WebhookTriggerResolution;
  createTriggerTestItems(args: {
    workflow: WorkflowDefinition;
    nodeId: NodeId;
  }): Promise<Items | undefined>;
  runWorkflow(wf: WorkflowDefinition, startAt: NodeId, items: Items, parent?: ParentExecutionRef, executionOptions?: RunExecutionOptions, persistedStateOverrides?: Readonly<{
    workflowSnapshot?: NonNullable<Awaited<ReturnType<WorkflowExecutionRepository["load"]>>>["workflowSnapshot"];
    mutableState?: NonNullable<Awaited<ReturnType<WorkflowExecutionRepository["load"]>>>["mutableState"];
  }>): Promise<RunResult>;
  runWorkflowFromState(request: CurrentStateExecutionRequest): Promise<RunResult>;
  markNodeRunning(args: {
    runId: RunId;
    activationId: NodeActivationId;
    nodeId: NodeId;
    inputsByPort: NodeInputsByPort;
  }): Promise<void>;
  resumeFromNodeResult(args: {
    runId: RunId;
    activationId: NodeActivationId;
    nodeId: NodeId;
    outputs: NodeOutputs;
  }): Promise<RunResult>;
  resumeFromNodeError(args: {
    runId: RunId;
    activationId: NodeActivationId;
    nodeId: NodeId;
    error: Error;
  }): Promise<RunResult>;
  resumeFromStepResult(args: {
    runId: RunId;
    activationId: NodeActivationId;
    nodeId: NodeId;
    outputs: NodeOutputs;
  }): Promise<RunResult>;
  resumeFromStepError(args: {
    runId: RunId;
    activationId: NodeActivationId;
    nodeId: NodeId;
    error: Error;
  }): Promise<RunResult>;
  waitForCompletion(runId: RunId): Promise<Extract<RunResult, {
    status: "completed" | "failed" | "halted";
  }>>;
  waitForWebhookResponse(runId: RunId): Promise<WebhookRunResult>;
  resumeRun(args: {
    runId: RunId;
    taskId: string;
    resumeContext: ResumeContext;
  }): Promise<RunResult>;
  handleNodeExecutionRequest(request: NodeExecutionRequest): Promise<void>;
}
//#endregion
//#region src/runtime/InMemoryLiveWorkflowRepository.d.ts
declare class InMemoryLiveWorkflowRepository implements LiveWorkflowRepository {
  private readonly workflowsById;
  setWorkflows(workflows: ReadonlyArray<WorkflowDefinition>): void;
  list(): ReadonlyArray<WorkflowDefinition>;
  get(workflowId: WorkflowId): WorkflowDefinition | undefined;
}
//#endregion
//#region src/runtime/RunIntentService.d.ts
type StartWorkflowIntent = {
  workflow: WorkflowDefinition;
  startAt?: string;
  items: Items;
  synthesizeTriggerItems?: boolean;
  parent?: CurrentStateExecutionRequest["parent"];
  executionOptions?: RunExecutionOptions;
  workflowSnapshot?: CurrentStateExecutionRequest["workflowSnapshot"];
  mutableState?: CurrentStateExecutionRequest["mutableState"];
  currentState?: RunCurrentState;
  stopCondition?: RunStopCondition;
  reset?: CurrentStateExecutionRequest["reset"];
};
type RerunFromNodeIntent = {
  workflow: WorkflowDefinition;
  nodeId: NodeId;
  currentState: RunCurrentState;
  items?: Items;
  synthesizeTriggerItems?: boolean;
  parent?: CurrentStateExecutionRequest["parent"];
  executionOptions?: RunExecutionOptions;
  workflowSnapshot?: CurrentStateExecutionRequest["workflowSnapshot"];
  mutableState?: CurrentStateExecutionRequest["mutableState"];
};
type MatchedWebhookRunIntent = {
  endpointPath: string;
  method: HttpMethod;
  requestItem: Items[number];
};
type WebhookMatchRunIntent = {
  match: WebhookInvocationMatch;
  requestItem: Items[number];
};
declare class RunIntentService {
  private readonly engine;
  private readonly workflowRepository;
  constructor(engine: Engine, workflowRepository: WorkflowRepository);
  startWorkflow(args: StartWorkflowIntent): Promise<RunResult>;
  rerunFromNode(args: RerunFromNodeIntent): Promise<RunResult>;
  private resolveStartWorkflowItems;
  private resolveRerunItems;
  private resolveStartWorkflowTriggerNodeId;
  private resolveRerunTriggerNodeId;
  private firstTriggerNodeId;
  private isTriggerNode;
  private hasNonEmptyItems;
  resolveWebhookTrigger(args: {
    endpointPath: string;
    method: HttpMethod;
  }): WebhookTriggerResolution;
  runMatchedWebhook(args: MatchedWebhookRunIntent): Promise<WebhookRunResult>;
  runWebhookMatch(args: WebhookMatchRunIntent): Promise<WebhookRunResult>;
  private createWebhookExecutionOptions;
}
//#endregion
export { InMemoryLiveWorkflowRepository as n, Engine as r, RunIntentService as t };
//# sourceMappingURL=RunIntentService-DKxuHTUz.d.cts.map