Function makeService

src/workflow/service.ts:122–318

(
  ports: WorkflowPorts,
  store: ProgressStore,
  cwdOverride?: string,
  runsDirProvider: () => string = getRunsDir,
)

 * @param runsDirProvider For tests only: inject a tmpdir (Bun ESM module namespace is read-only, cannot monkey-patch getRunsDir).
 */
export function makeService(
  ports: WorkflowPorts,
  store: ProgressStore,
  cwdOverride?: string,
  runsDirProvider: () => string = getRunsDir,
): WorkflowService {
  const buildHost = (
    toolUseContext: ToolUseContext,
    canUseTool: CanUseToolFn,
  ): WorkflowHostContext => ({
    handle: makeHostHandle(buildHostBundle(toolUseContext, canUseTool)),
    // Use projectRoot to stay in sync with ports.ts hostFactory / journalStore;
    // entering a worktree/subdirectory will not desync named workflow resolution from journal persistence.
    // cwdOverride is for tests only: inject a temp directory (avoids inline persistence writing to the real project directory).
    cwd: cwdOverride ?? getProjectRoot(),
    budgetTotal: null, // turn-level budget injection point (in future read from settings)
    toolUseId: toolUseContext.toolUseId,
  })

  async function resolveSource(input: {
    script?: string
    name?: string
    scriptPath?: string
    title?: string
  }): Promise<{
    script: string
    workflowFile?: string
    workflowName: string
  }> {
    // Mirrors WorkflowTool.ts: name takes priority over title; only fall back to the literal
    // 'workflow' when neither is supplied (so /workflows tabs don't pile up under a same default name).
    const workflowName = input.name ?? input.title ?? 'workflow'
    if (input.script) {
      return { script: input.script, workflowName }
    }
    if (input.scriptPath) {
      return {
        script: await readFile(input.scriptPath, 'utf-8'),
        workflowFile: input.scriptPath,
        workflowName,
      }
    }
    if (input.name) {
      const dir = join(getProjectRoot(), WORKFLOW_DIR_NAME)
      const found = await resolveNamedWorkflow(dir, input.name)
      if (!found) {
        throw new Error(
          `Named workflow "${input.name}" not found (looked in ${WORKFLOW_DIR_NAME}/)`,
        )
      }
      return {
        script: found.content,
        workflowFile: found.path,
        workflowName: input.name,
      }
    }
    throw new Error('One of script, name, or scriptPath must be provided')
  }