{% extends "base.html" %}
{% block title %}{{ config.name }} - engineer_kit{% endblock %}
{% block content %}
<div class="page-heading">
    <div><h1>{{ config.name }}</h1><p class="subtitle">{{ config.connector.method }} {{ config.connector.base_url }}</p></div>
    <div><a href="/pipelines/{{ config.name }}/profile" class="btn">Data Profile</a> <form method="post" action="/pipelines/{{ config.name }}/run" style="display:inline"><button type="submit" class="btn btn-primary">▶ Rodar agora</button></form> <a href="/pipelines/{{ config.name }}/edit" class="btn">Editar</a></div>
</div>

<h2>Fluxo</h2>
<div class="flow-strip">
    <div class="flow-node active"><strong>REST API</strong><span>RestConnector</span><small>{{ config.connector.pagination.type }} pagination</small></div>
    <div class="flow-arrow">→</div>
    <div class="flow-node active"><strong>Profile</strong><span>opcional</span><small>quality antes da Bronze</small></div>
    <div class="flow-arrow">→</div>
    <div class="flow-node active"><strong>Watermark</strong><span>StateStore</span><small>{{ config.state.type if config.state.type != 'auto' else config.destination.type ~ ' (auto)' }}</small></div>
    <div class="flow-arrow">→</div>
    <div class="flow-node active"><strong>Bronze</strong><span>Destination</span><small>{{ config.destination.type }} / {{ config.destination.schema }}</small></div>
    {% if config.transform.type == 'dbt' %}
    <div class="flow-arrow">→</div>
    <div class="flow-node active"><strong>dbt</strong><span>Transform</span><small>staging → silver → gold</small></div>
    {% endif %}
</div>
<div class="architecture-note">O Pipeline trabalha com contratos. O profile é somente leitura: não grava Bronze nem avança checkpoint. Retries de uma mesma janela usam uma <code>ingestion_key</code> determinística nos destinations oficiais.</div>

<div class="grid-2">
    <div class="card">
        <h3>Ingestão</h3>
        <dl class="facts">
            <dt>Paginação</dt><dd>{{ config.connector.pagination.type }}</dd>
            <dt>Incremental</dt><dd>{{ config.connector.incremental.mode }}{% if config.connector.incremental.date_field %}<br><code>{{ config.connector.incremental.date_field }}</code>{% endif %}</dd>
            <dt>Primary key</dt><dd>{% if config.connector.primary_key %}<code>{{ config.connector.primary_key | join(', ') }}</code>{% else %}não declarada{% endif %}</dd>
            <dt>Deduplicação</dt><dd>{% if config.connector.dedup %}ativa · keep first · remove registro inteiro repetido por PK{% else %}desligada{% endif %}</dd>
            <dt>Autenticação</dt><dd>{{ config.connector.auth.type }}</dd>
            <dt>Destination</dt><dd>{{ config.destination.type }}</dd>
            <dt>Schema Bronze</dt><dd>{{ config.destination.schema }}</dd>
            <dt>Write mode</dt><dd>{{ config.destination.write_mode }}</dd>
            <dt>Batch</dt><dd>{{ config.destination.batch_size }}</dd>
            {% if config.destination.partition_by %}<dt>Partições</dt><dd>{{ config.destination.partition_by | join(', ') }}</dd>{% endif %}
        </dl>
    </div>
    <div class="card">
        <h3>Estado e pós-ingestão</h3>
        <dl class="facts">
            <dt>StateStore</dt><dd>{{ config.state.type if config.state.type != 'auto' else 'auto → ' ~ config.destination.type }}</dd>
            <dt>Run log</dt><dd>{% if config.run_log %}{{ config.run_log.type if config.run_log.type != 'auto' else 'auto → ' ~ config.destination.type }}{% else %}desligado{% endif %}</dd>
            <dt>Transformação</dt><dd>{{ config.transform.type }}</dd>
            {% if config.transform.type == 'dbt' %}<dt>dbt select</dt><dd>{{ config.transform.select or "todos os modelos" }}</dd><dt>Projeto local</dt><dd>{{ "encontrado" if dbt_available else "não encontrado" }}</dd>{% endif %}
        </dl>
        {% if config.transform.type == 'dbt' %}<a href="/dbt" class="btn">Ver modelos dbt</a>{% endif %}
        <a href="/architecture" class="btn">Entender abstrações</a>
    </div>
</div>

<h2>Contrato de schema</h2>
<div class="card">
    <p>Bronze persiste os campos declarados como strings e preserva campos inesperados em <code>_extra</code>. Os tipos abaixo são o contrato lógico usado por staging/transformação.</p>
    {% if config.columns %}<table><thead><tr><th>Coluna</th><th>Tipo lógico</th></tr></thead><tbody>{% for col in config.columns %}<tr><td>{{ col.name }}</td><td><code>{{ col.dtype }}</code></td></tr>{% endfor %}</tbody></table>{% else %}<div class="empty">Nenhuma coluna declarada.</div>{% endif %}
</div>

<h2>Histórico de execuções</h2>
{% if history %}
<table><thead><tr><th>Início</th><th>Fim</th><th>Status</th><th>Registros</th><th>Erro</th></tr></thead><tbody>{% for run in history %}<tr><td>{{ run.started_at }}</td><td>{{ run.finished_at }}</td><td><span class="badge badge-{{ run.status }}">{{ run.status }}</span></td><td>{{ run.rows_loaded }}</td><td>{{ run.error_message or "" }}</td></tr>{% endfor %}</tbody></table>
{% else %}<div class="empty">Ainda não rodou.</div>{% endif %}
{% endblock %}