oh-my-opencode/src/agents/atlas/atlas-prompt.test.ts

import { describe, test, expect } from "bun:test"
import { getAtlasPrompt } from "./agent"

const ALL_VARIANTS: Array<[string, string]> = [
  ["default", getAtlasPrompt("anthropic/claude-sonnet-4-6")],
  ["gpt", getAtlasPrompt("openai/gpt-5.5")],
  ["gemini", getAtlasPrompt("google/gemini-3.1-pro")],
  ["kimi", getAtlasPrompt("moonshotai/kimi-k2.6")],
  ["opus-4-7", getAtlasPrompt("anthropic/claude-opus-4-7")],
]

describe("Atlas prompts auto-continue policy", () => {
  for (const [name, prompt] of ALL_VARIANTS) {
    test(`${name} variant should forbid asking user for continuation confirmation`, () => {
      const lowerPrompt = prompt.toLowerCase()

      expect(lowerPrompt).toContain("auto-continue policy")
      expect(lowerPrompt).toContain("never ask the user")
      expect(lowerPrompt).toContain("should i continue")
      expect(lowerPrompt).toContain("proceed to next task")
      expect(lowerPrompt).toContain("approval-style")
      expect(lowerPrompt).toContain("auto-continue immediately")
    })
  }

  test("all variants should require immediate continuation after verification passes", () => {
    for (const [, prompt] of ALL_VARIANTS) {
      const lowerPrompt = prompt.toLowerCase()
      expect(lowerPrompt).toMatch(/auto-continue immediately after verification/)
      expect(lowerPrompt).toMatch(/immediately delegate next task/)
    }
  })

  test("all variants should define when user interaction is actually needed", () => {
    for (const [, prompt] of ALL_VARIANTS) {
      const lowerPrompt = prompt.toLowerCase()
      expect(lowerPrompt).toMatch(/only pause.*truly blocked/)
      expect(lowerPrompt).toMatch(/plan needs clarification|blocked by external/)
    }
  })
})

describe("Atlas prompts anti-duplication coverage", () => {
  test("all variants should include anti-duplication rules for delegated exploration", () => {
    for (const [, prompt] of ALL_VARIANTS) {
      expect(prompt).toContain("<Anti_Duplication>")
      expect(prompt).toContain("Anti-Duplication Rule")
      expect(prompt).toContain("DO NOT perform the same search yourself")
      expect(prompt).toContain("non-overlapping work")
    }
  })
})

describe("Atlas prompts plan path consistency", () => {
  for (const [name, prompt] of ALL_VARIANTS) {
    test(`${name} variant should use .omo/plans/{plan-name}.md path`, () => {
      expect(prompt).toContain(".omo/plans/{plan-name}.md")
      expect(prompt).not.toContain(".omo/tasks/{plan-name}.yaml")
      expect(prompt).not.toContain(".omo/tasks/")
    })
  }

  test("all variants should read plan file after verification", () => {
    for (const [, prompt] of ALL_VARIANTS) {
      expect(prompt).toMatch(/read[\s\S]*?\.omo\/plans\//i)
    }
  })

  test("all variants should distinguish top-level plan tasks from nested checkboxes", () => {
    for (const [, prompt] of ALL_VARIANTS) {
      const lowerPrompt = prompt.toLowerCase()
      expect(lowerPrompt).toMatch(/top-level.*checkbox/)
      expect(lowerPrompt).toMatch(/ignore nested.*checkbox/)
    }
  })
})

describe("Atlas prompts parallel-by-default mandate", () => {
  test("all variants should mandate parallel as the default delegation mode", () => {
    for (const [, prompt] of ALL_VARIANTS) {
      const lowerPrompt = prompt.toLowerCase()
      expect(lowerPrompt).toContain("parallel delegation")
      expect(lowerPrompt).toMatch(/default.*parallel|parallel.*default/)
      expect(lowerPrompt).toMatch(/sequential.*exception|exception.*sequential/)
    }
  })

  test("all variants should require named blocking dependency to justify sequential ordering", () => {
    for (const [, prompt] of ALL_VARIANTS) {
      const lowerPrompt = prompt.toLowerCase()
      expect(lowerPrompt).toMatch(/named.*depend|named.*block/)
    }
  })

  test("all variants should require parallel dispatch in ONE response", () => {
    for (const [, prompt] of ALL_VARIANTS) {
      const lowerPrompt = prompt.toLowerCase()
      expect(lowerPrompt).toMatch(/one (message|response)/)
    }
  })

  test("parallel mandate should appear BEFORE the workflow section in every variant", () => {
    for (const [name, prompt] of ALL_VARIANTS) {
      const mandateIdx = prompt.indexOf("<parallel_by_default>")
      const workflowIdx = prompt.indexOf("<workflow>")
      expect(mandateIdx, `${name}: mandate marker missing`).toBeGreaterThan(-1)
      expect(workflowIdx, `${name}: workflow marker missing`).toBeGreaterThan(-1)
      expect(mandateIdx, `${name}: mandate must precede workflow so "mandate above" references resolve`).toBeLessThan(workflowIdx)
    }
  })
})

describe("Atlas prompts use task_id (not session_id) for retries", () => {
  test("no variant should reference session_id (use task_id instead)", () => {
    for (const [name, prompt] of ALL_VARIANTS) {
      expect(prompt, `${name}: leaks session_id; should be task_id`).not.toMatch(/session_id/)
    }
  })

  test("all variants should mention task_id for retries", () => {
    for (const [name, prompt] of ALL_VARIANTS) {
      expect(prompt, `${name}: missing task_id retry reference`).toMatch(/task_id/)
    }
  })

  test("all variants should separate background ids from continuation task ids", () => {
    for (const [name, prompt] of ALL_VARIANTS) {
      expect(prompt, `${name}: missing bg result collection contract`).toContain('background_output(task_id="bg_...")')
      expect(prompt, `${name}: missing ses continuation contract`).toContain('task(task_id="ses_..."')
    }
  })
})

describe("Atlas prompts no-excuses retry policy", () => {
  test("no variant contains a numeric retry cap", () => {
    for (const [name, prompt] of ALL_VARIANTS) {
      expect(prompt, `${name}: must not impose Maximum N retries`).not.toMatch(/maximum\s+\d+\s+retr/i)
      expect(prompt, `${name}: must not impose N retries per task`).not.toMatch(/\d+\s+retries\s+per\s+task/i)
      expect(prompt, `${name}: must not impose N retry attempts`).not.toMatch(/\d+\s+retry\s+attempts/i)
    }
  })

  test("no variant tells Atlas to move on after failure", () => {
    for (const [name, prompt] of ALL_VARIANTS) {
      const lower = prompt.toLowerCase()
      expect(lower, `${name}: must not tell Atlas to skip failed tasks`).not.toContain("document and continue to independent tasks")
      expect(lower, `${name}: must not tell Atlas to move to next independent task`).not.toContain("document and move to next independent task")
      expect(lower, `${name}: must not tell Atlas to move on`).not.toContain("then document and move on")
    }
  })

  test("all variants forbid the false-positive excuse explicitly", () => {
    for (const [name, prompt] of ALL_VARIANTS) {
      const lower = prompt.toLowerCase()
      expect(lower, `${name}: missing false positive prohibition`).toContain("false positive")
      expect(lower, `${name}: missing no-retry-cap statement`).toContain("no retry cap")
    }
  })

  test("all variants instruct subagent re-call with different angle when looping", () => {
    for (const [name, prompt] of ALL_VARIANTS) {
      const lower = prompt.toLowerCase()
      expect(lower, `${name}: missing different-angle subagent instruction`).toMatch(/different angle|new subagent/)
    }
  })
})

describe("Atlas prompts boulder-completion response", () => {
  test("all variants document the boulder-complete nudge response", () => {
    for (const [name, prompt] of ALL_VARIANTS) {
      expect(prompt, `${name}: missing boulder_completion_response section`).toContain("<boulder_completion_response>")
      expect(prompt, `${name}: missing BOULDER COMPLETE recognition phrase`).toContain("BOULDER COMPLETE")
      expect(prompt, `${name}: missing TOTAL ELAPSED summary field`).toContain("TOTAL ELAPSED")
      expect(prompt, `${name}: missing PER-TASK ELAPSED summary field`).toContain("PER-TASK ELAPSED")
    }
  })

  test("all variants explain the one-shot nudge guarantee", () => {
    for (const [name, prompt] of ALL_VARIANTS) {
      const lower = prompt.toLowerCase()
      expect(lower, `${name}: missing one-shot nudge guarantee`).toMatch(/at most once|fires.*once/)
    }
  })

  test("boulder completion section appears after the workflow", () => {
    for (const [name, prompt] of ALL_VARIANTS) {
      const workflowIdx = prompt.indexOf("<workflow>")
      const completionIdx = prompt.indexOf("<boulder_completion_response>")
      expect(workflowIdx, `${name}: missing workflow section`).toBeGreaterThan(-1)
      expect(completionIdx, `${name}: missing boulder completion section`).toBeGreaterThan(-1)
      expect(
        completionIdx,
        `${name}: boulder completion must come AFTER the workflow so the agent reads the failure rules first`,
      ).toBeGreaterThan(workflowIdx)
    }
  })
})