Corpus Quality Cycle

flowchart TD
    classDef phase fill:#b5762a,color:#fff,stroke:none,font-weight:700
    classDef gate_auto fill:#2e7d6e,color:#fff,stroke:none,font-weight:700
    classDef gate_manual fill:#a8505a,color:#fff,stroke:none,font-weight:700
    classDef skill fill:#fff,color:#2a2520,stroke:#d8d4ce,stroke-width:1px
    classDef output fill:#fdf6ed,color:#2a2520,stroke:#d4943a,stroke-width:1px
    classDef decision fill:#fdf0f1,color:#2a2520,stroke:#a8505a,stroke-width:1px
    classDef checkpoint fill:#edf7f5,color:#2a2520,stroke:#2e7d6e,stroke-width:1px

    START(["corpus:cycle orchestrator"]):::phase

    subgraph W1 ["Workflow 1 — Ingest"]
        WIPE["Wipe PG / MinIO / Redis"]:::skill
        RESTART["Restart workers + server"]:::skill
        INGEST["preprocess_client.py\n25-doc batch"]:::skill
    end
    START --> WIPE --> RESTART --> INGEST

    G0{"G0 — All 25 docs\nterminal state\n▸ Haiku · auto"}:::gate_auto
    INGEST --> G0

    subgraph W2 ["Workflow 2 — Score + Diff"]
        SCORE["corpus:score\nHybrid verdict\n▸ pipeline: Haiku fetch\n+ Sonnet judge"]:::skill
        DIFF["corpus:diff\nRun N vs N-1 delta\n▸ Haiku"]:::skill
        REPORT["Write audit report\n▸ Haiku"]:::skill
        AUDIT_FILE[/"audit/CORPUS_REINGESTION\n_AUDIT_RUN-N.md"/]:::output
    end
    G0 --> SCORE --> DIFF --> REPORT --> AUDIT_FILE

    G1{"G1 — Human reviews\nscorecard + convergence\n▸ manual"}:::gate_manual
    AUDIT_FILE --> G1

    CONVERGED{{"Converged?\n0 FAIL + 0 ERROR\n+ 0 regressions"}}:::decision
    G1 --> CONVERGED
    CONVERGED -- "Yes → stop" --> DONE(["Cycle complete"])

    subgraph W3 ["Workflow 3 — Diagnose + Plan"]
        TRIAGE["Triage\nCategorize by domain\n▸ Sonnet"]:::skill
        CLUSTER["Cluster Trace\nOne Opus agent per\ndomain cluster"]:::skill
        DRILLDOWN["Document Drill-down\nPer-doc investigation\n▸ Sonnet / Haiku"]:::skill
        CKPT_W3["Checkpoint\nPersist to disk\n▸ Haiku"]:::checkpoint
        RFC_DRAFT["corpus:plan\nOpus drafts RFC\nD-numbered decisions"]:::skill
        RFC_VERIFY{"Fable verifies\nmax 2 rounds"}:::skill
        RFC_REDRAFT["Opus re-drafts\nvia Serena MCP"]:::skill
        RFC_OK[/"RFC approved\n.agents/rfcs/NNN-slug.md"/]:::output
        ARTIFACT_BUILD["rfc-artifact-build\nGenerates design + tasks"]:::skill
        DESIGN_OUT[/".agents/designs/\ndesign-rfcNNN-slug.md"/]:::output
        TASKS_OUT[/".agents/tasks/\ntasks-rfcNNN-slug.md"/]:::output
    end
    CONVERGED -- "No → continue" --> TRIAGE
    TRIAGE --> CLUSTER
    CLUSTER -- "all explained" --> CKPT_W3
    CLUSTER -- "ambiguous docs" --> DRILLDOWN --> CKPT_W3
    CKPT_W3 --> RFC_DRAFT --> RFC_VERIFY
    RFC_VERIFY -- "rejected" --> RFC_REDRAFT --> RFC_VERIFY
    RFC_VERIFY -- "approved" --> RFC_OK
    RFC_OK --> ARTIFACT_BUILD
    ARTIFACT_BUILD --> DESIGN_OUT
    ARTIFACT_BUILD --> TASKS_OUT

    G2{"G2 — Human approves\nRFC + design + tasks\n▸ manual"}:::gate_manual
    DESIGN_OUT --> G2
    TASKS_OUT --> G2

    subgraph W4 ["Workflow 4 — Build"]
        direction TB
        WAVE["swarm-builder\nWave execution\n▸ pipeline: Sonnet build\n+ Fable/Opus review"]:::skill
        CHECK["Between-wave checkpoint\nL1: pytest · Haiku\nL2: review vs design · Fable/Opus\nL3: task acceptance · Fable/Opus\n+ Serena MCP task update"]:::skill
        MEND["corpus:mend\nTest repair if needed\n▸ Sonnet"]:::skill
    end
    G2 --> WAVE --> CHECK
    CHECK -- "pass + more waves" --> WAVE
    CHECK -- "tests broken" --> MEND --> WAVE
    CHECK -- "all waves done" --> G3

    G3{"G3 — Full suite green\nAll tasks marked done\n▸ Haiku · auto"}:::gate_auto

    subgraph W5 ["Workflow 5 — Sync + Commit"]
        SYNC["make confluence-local-sync\nNo LLM needed"]:::skill
        BATCH1["Batch 1: docs · .agents/\nRFC + design + tasks"]:::skill
        BATCH2["Batch 2: feat · src/\nImplementation"]:::skill
        BATCH3["Batch 3: test · tests/\nTest coverage"]:::skill
        BATCH4["Batch 4: docs · audit/\nScoring artifacts"]:::skill
        PUSH["git push\nall batches together\nno co-author trailers"]:::skill
    end
    G3 --> SYNC --> BATCH1 --> BATCH2 --> BATCH3 --> BATCH4 --> PUSH

    G4{"G4 — Clean tree\nCommit verified\n▸ Haiku · auto"}:::gate_auto
    PUSH --> G4

    G4 -- "Loop back\nwith fixes applied" --> WIPE