Function createWorkflowService

src/cli/workflow.ts:349–395

(input: {
  ctx: WorkflowContext;
  opts: WorkflowCLIOptions;
  model: string;
  thinkingLevel: ParsedThinkingInput;
})

}

function createWorkflowService(input: {
  ctx: WorkflowContext;
  opts: WorkflowCLIOptions;
  model: string;
  thinkingLevel: ParsedThinkingInput;
}): WorkflowService {
  const experiments = buildExperimentsObject(input.opts.experiment);
  const runtime = createRuntime(input.ctx.runtimeConfig, {
    projectPath: input.ctx.projectDir,
    workspaceName: input.ctx.workspaceId,
    workspacePath: input.ctx.workspacePath,
  });
  const workspaceSessionDir = input.ctx.config.getSessionDir(input.ctx.workspaceId);

  return new WorkflowService({
    runStore: new WorkflowRunStore({ sessionDir: workspaceSessionDir }),
    runtimeFactory: new QuickJSRuntimeFactory(),
    taskAdapterFactory: (runId) =>
      new WorkflowTaskServiceAdapter({
        taskService: input.ctx.services.taskService,
        parentWorkspaceId: input.ctx.workspaceId,
        workflowRunId: runId,
        defaultAgentId: DEFAULT_WORKFLOW_AGENT_ID,
        experiments,
        modelString: input.model,
        thinkingLevel: input.thinkingLevel,
        getProjectTrusted: () => input.ctx.projectTrusted,
        patchToolConfig: {
          workspaceId: input.ctx.workspaceId,
          cwd: input.ctx.workspacePath,
          runtime,
          runtimeTempDir: runtime.normalizePath(".mux/tmp", input.ctx.workspacePath),
          workspaceSessionDir,
          trusted: input.ctx.projectTrusted,
        },
      }),
    resolveWorkflowScript: (scriptPath) =>
      resolveWorkflowScript({
        scriptPath,
        runtime,
        workspacePath: input.ctx.workspacePath,
        projectTrusted: input.ctx.projectTrusted,
      }),
    getCurrentProjectTrusted: () => input.ctx.projectTrusted,
    runnerId: input.ctx.workspaceId,
  });
}

async function runWorkflow(scriptPath: string, options: WorkflowCLIOptions): Promise<number> {
  const projectDir = await resolveProjectDir({