Desenhar o pipeline de vídeo do briefing à publicação

video-ia/
├── CLAUDE.md, AGENTS.md, .mcp.json   regras dos agentes
├── .env, .env.example, .gitignore    chaves e exclusões do Git
├── .claude/ e .agents/               configuração do Claude Code e do Codex
├── config/                           catalogo.json, pipeline.json, modelos.toml
│   └── schemas/                      formatos de resposta do Codex
├── briefing/                         um briefing por vídeo
├── marca/                            paleta e fontes/
├── roteiro/                          roteiro.md aprovado
├── storyboard/                       cenas.json, quadros, cenas_video.json
│   └── prompts/                      prompt de vídeo por cena
├── audio/                            narração, trilha e efeitos
├── transcricoes/                     JSON do Scribe com tempo por palavra
├── legendas/                         SRT e JSON por palavra
├── edicao/                           lista de cortes aprovada
├── midia/
│   ├── raw/                          brutos, nunca sobrescritos
│   └── gerados/                      b-roll gerado, frames e clipes
├── composicoes/<nome>/               projetos Remotion e HyperFrames
├── renders/                          MP4 de revisão e de entrega
├── qa/                               frames/, parecer, aprovação e auditoria
├── publicacao/                       recibo de cada envio
├── estado/                           estado do pipeline e das tarefas
├── custos/                           custo de cada chamada paga
├── privado/                          vozes autorizadas e tokens, fora do Git
├── logs/                             saída de comandos e relatórios
└── scripts/                          todos os scripts do curso

"""Desenha o pipeline do P1: grava config/pipeline.json e fluxograma.md.

Não gera mídia nem chama APIs. Rode na pasta video-ia:
    python scripts/desenhar_pipeline.py
    python scripts/desenhar_pipeline.py --falhar voz
"""
import argparse
import json
from pathlib import Path

raiz = Path(__file__).resolve().parents[1]
catalogo = json.loads((raiz / "config/catalogo.json").read_text(encoding="utf-8"))

# Ordem do P1: cada etapa só depende de etapas que vêm antes dela.
etapas = [
    {"id": "roteiro", "depende_de": [], "responsavel": catalogo["direcao"]["modelo"],
     "entradas": ["briefing/receita.md"], "saidas": ["roteiro/roteiro.md", "storyboard/cenas.json"],
     "aprovacao_humana": True},
    {"id": "imagens", "depende_de": ["roteiro"], "responsavel": catalogo["storyboard"]["modelo"],
     "entradas": ["storyboard/cenas.json"], "saidas": ["storyboard/quadros.json"],
     "aprovacao_humana": True},
    {"id": "voz", "depende_de": ["roteiro"], "responsavel": catalogo["narracao"]["modelo"],
     "entradas": ["roteiro/roteiro.md"], "saidas": ["audio/narracao.mp3"],
     "aprovacao_humana": True},
    {"id": "transcricao", "depende_de": ["voz"], "responsavel": catalogo["transcricao"]["modelo"],
     "entradas": ["audio/narracao.mp3"], "saidas": ["transcricoes/narracao.json"],
     "aprovacao_humana": False},
    {"id": "legendas", "depende_de": ["transcricao"], "responsavel": "script local",
     "entradas": ["transcricoes/narracao.json"], "saidas": ["legendas/narracao.srt"],
     "aprovacao_humana": False},
    {"id": "montagem", "depende_de": ["imagens", "voz", "legendas"], "responsavel": "FFmpeg",
     "entradas": ["storyboard/quadros.json", "audio/narracao.mp3", "legendas/narracao.srt"],
     "saidas": ["renders/revisao.mp4"], "aprovacao_humana": False},
    {"id": "qa", "depende_de": ["montagem"], "responsavel": "Claude sobre frames e revisão humana",
     "entradas": ["renders/revisao.mp4"], "saidas": ["qa/parecer.md", "qa/aprovacao.json"],
     "aprovacao_humana": True},
    {"id": "publicacao", "depende_de": ["qa"], "responsavel": "script da plataforma",
     "entradas": ["renders/revisao.mp4", "qa/aprovacao.json"], "saidas": ["publicacao/recibo.json"],
     "aprovacao_humana": True},
]

# Quatro regras do contrato, conferidas antes de gravar qualquer arquivo.
vistos, saidas = set(), set()
for etapa in etapas:
    if etapa["id"] in vistos:
        raise SystemExit(f"Id de etapa repetido: {etapa['id']}")
    if not set(etapa["depende_de"]) <= vistos:
        raise SystemExit(f"Dependência fora de ordem em: {etapa['id']}")
    for caminho in etapa["entradas"] + etapa["saidas"]:
        p = Path(caminho)
        if p.is_absolute() or ".." in p.parts:
            raise SystemExit(f"Use caminho relativo dentro do projeto: {caminho}")
    for saida in etapa["saidas"]:
        if saida in saidas:
            raise SystemExit(f"Duas etapas escrevem o mesmo arquivo: {saida}")
        saidas.add(saida)
    vistos.add(etapa["id"])

parser = argparse.ArgumentParser()
parser.add_argument("--falhar", metavar="ETAPA", help="simula a falha de uma etapa")
args = parser.parse_args()

if args.falhar:
    if args.falhar not in vistos:
        raise SystemExit(f"Etapa desconhecida. Use uma destas: {', '.join(e['id'] for e in etapas)}")
    paradas = {args.falhar}
    for etapa in etapas:  # a lista já está em ordem de dependência
        if paradas & set(etapa["depende_de"]):
            paradas.add(etapa["id"])
    livres = [e["id"] for e in etapas if e["id"] not in paradas]
    print(f"Falha simulada em: {args.falhar}")
    print("Ficam paradas:", ", ".join(e["id"] for e in etapas if e["id"] in paradas - {args.falhar}) or "nenhuma")
    print("Seguem livres:", ", ".join(livres) or "nenhuma")
    raise SystemExit(0)

manifesto = {"data_referencia": "2026-10-12", "projeto": "P1", "duracao_alvo_s": 60,
             "formato": "9:16", "etapas": etapas}
(raiz / "config/pipeline.json").write_text(
    json.dumps(manifesto, ensure_ascii=False, indent=2) + "\n", encoding="utf-8")

linhas = ["# Fluxograma do P1", "", "Plano de produção; não comprova execução.", ""]
for etapa in etapas:
    linhas += [
        f"## {etapa['id']}",
        f"- Recebe de: {', '.join(etapa['depende_de']) or 'briefing'}",
        f"- Responsável: {etapa['responsavel']}",
        f"- Entradas: {', '.join(etapa['entradas'])}",
        f"- Saídas: {', '.join(etapa['saidas'])}",
        f"- Aprovação humana: {'sim' if etapa['aprovacao_humana'] else 'não'}",
        "",
    ]
(raiz / "fluxograma.md").write_text("\n".join(linhas), encoding="utf-8")
print(f"OK: {len(etapas)} etapas conferidas; config/pipeline.json e fluxograma.md gravados.")

# Ensaio de falha: o que para se a narração falhar? (Windows: troque python3 por python)
python3 scripts/desenhar_pipeline.py --falhar voz
# Falha simulada em: voz
# Ficam paradas: transcricao, legendas, montagem, qa, publicacao
# Seguem livres: roteiro, imagens

python3 scripts/desenhar_pipeline.py --falhar imagens
# Falha simulada em: imagens
# Ficam paradas: montagem, qa, publicacao
# Seguem livres: roteiro, voz, transcricao, legendas