{% extends "base.html" %}
{% from "_page_header.html" import page_header %}
{% from "_components.html" import badge, identifier, pagination, empty_state, kv, operations_journey %}
{% block content %}
{% call page_header(source.name, kind_labels.get(source.kind.value, source.kind.value) ~ " source feeding " ~ (overview.space_name or "an unknown space") ~ ".") %}
{% if can_manage %}
<div class="flex flex-wrap items-center gap-sm">
  {% if source.syncable and source.status.value == "active" %}
  <form method="post" action="/admin/sources/{{ source.id }}/sync" class="inline">
    <button type="submit" class="btn-primary inline-flex items-center gap-xs px-md py-sm rounded-DEFAULT text-body-sm font-headline-md">
      <span class="material-symbols-outlined text-[16px]" aria-hidden="true">sync</span> Sync now
    </button>
  </form>
  {% endif %}
  {% if not source.is_builtin_uploads %}
  {% if can_manage_filesystem or source.kind.value not in ("folder", "git") %}
  <a href="/admin/sources/{{ source.id }}/edit" class="btn-ghost inline-flex items-center gap-xs px-md py-sm rounded-DEFAULT text-body-sm font-headline-md">Edit</a>
  {% endif %}
  {% if source.status.value == "active" %}
  <form method="post" action="/admin/sources/{{ source.id }}/pause" class="inline" data-confirm="Pause '{{ source.name }}'? It will not be synced until resumed.">
    <button type="submit" class="btn-ghost px-md py-sm rounded-DEFAULT text-body-sm font-headline-md">Pause</button>
  </form>
  {% elif source.status.value == "paused" %}
  <form method="post" action="/admin/sources/{{ source.id }}/resume" class="inline">
    <button type="submit" class="btn-ghost px-md py-sm rounded-DEFAULT text-body-sm font-headline-md">Resume</button>
  </form>
  {% endif %}
  {% if source.status.value != "deleted" %}
  <form method="post" action="/admin/sources/{{ source.id }}/delete" class="inline" data-confirm="Delete '{{ source.name }}'? Its {{ overview.document_count }} document(s) will be retired and stop being searchable. This cannot be undone from the Control Plane.">
    <button type="submit" class="btn-ghost px-md py-sm rounded-DEFAULT text-body-sm font-headline-md text-error">Delete</button>
  </form>
  {% endif %}
  {% endif %}
</div>
{% endif %}
{% endcall %}

{% if notice %}
<p role="status" class="text-body-md font-body-md text-tertiary bg-tertiary-container/10 border-l-4 border-tertiary rounded-DEFAULT p-md mb-md">{{ notice }}</p>
{% endif %}

{{ operations_journey(source_url="/admin/sources/" ~ source.id, source_label=source.name, document_url="/admin/documents?source_id=" ~ source.id, current="source") }}

<nav aria-label="Source sections" class="flex flex-wrap gap-xs mb-md border-b border-[#1E293B]">
  {% for anchor, label in [("overview", "Overview"), ("configuration", "Configuration"), ("documents", "Documents"), ("sync-history", "Sync history")] %}
  <a href="#{{ anchor }}" class="px-md py-sm text-body-md font-headline-md text-on-surface-variant hover:text-primary border-b-2 border-transparent hover:border-primary">{{ label }}</a>
  {% endfor %}
</nav>

<div class="grid grid-cols-1 xl:grid-cols-3 gap-md items-start">
  <section id="overview" aria-labelledby="overview-heading" class="glass-panel rounded-lg p-lg">
    <h2 id="overview-heading" class="text-headline-md font-headline-md text-on-surface mb-sm">Overview</h2>
    <dl>
      <div class="flex flex-col gap-xs py-sm border-b border-[#1E293B]">
        <dt class="text-label-caps font-label-caps text-on-surface-variant uppercase tracking-wider">Status</dt>
        <dd class="flex flex-wrap gap-xs">
          {% if source.status.value == "active" %}{{ badge("Active", "ok") }}{% elif source.status.value == "paused" %}{{ badge("Paused", "warn") }}{% else %}{{ badge("Deleted", "neutral") }}{% endif %}
          {% set sync_badge = sync_badges.get(source.sync_state.value) %}
          {% if sync_badge %}{{ badge(sync_badge[0], sync_badge[1]) }}{% endif %}
        </dd>
      </div>
      {{ kv("Type", kind_labels.get(source.kind.value, source.kind.value)) }}
      {{ kv("Knowledge space", overview.space_name or source.space_id) }}
      {{ kv("Documents (active)", overview.document_count) }}
      {{ kv("Created", source.created_at.strftime("%Y-%m-%d %H:%M") if source.created_at else None) }}
      {{ kv("Last sync", source.last_sync_at.strftime("%Y-%m-%d %H:%M") if source.last_sync_at else ("Never" if source.syncable else "Not applicable — fed by uploads")) }}
      {{ kv("Last successful sync", source.last_successful_sync_at.strftime("%Y-%m-%d %H:%M") if source.last_successful_sync_at else None) }}
      {{ kv("Sync schedule", ("Every " ~ (source.sync_interval_seconds // 60) ~ " minutes") if source.sync_interval_seconds else ("Manual — runs only when you press Sync now" if source.syncable else "Not applicable — fed by uploads")) }}
      {% if next_sync_due %}{{ kv("Next sync due", next_sync_due.strftime("%Y-%m-%d %H:%M")) }}{% endif %}
      {% if source.last_sync_error %}{{ kv("Last sync error", source.last_sync_error, mono=True) }}{% endif %}
      {% if source.last_revision %}{{ kv("Last revision", source.last_revision, mono=True) }}{% endif %}
      <div class="flex flex-col gap-xs py-sm">
        <dt class="text-label-caps font-label-caps text-on-surface-variant uppercase tracking-wider">Source ID</dt>
        <dd>{{ identifier(source.id, "source-id", short=36) }}</dd>
      </div>
    </dl>
    {% if source.kind.value == "upload" %}
    <p class="text-body-sm font-body-sm text-on-surface-variant mt-sm">Upload sources are fed by their callers (the Control Plane upload form, the upload API, sync clients); there is nothing for the worker to sync.</p>
    {% endif %}
  </section>

  <section id="configuration" aria-labelledby="configuration-heading" class="glass-panel rounded-lg p-lg">
    <h2 id="configuration-heading" class="text-headline-md font-headline-md text-on-surface mb-sm">Configuration</h2>
    {% if config_rows %}
    <dl>
      {% for label, value in config_rows %}{{ kv(label, value, mono=(label in ("root", "checkout root", "repository", "ref"))) }}{% endfor %}
    </dl>
    {% else %}
    <p class="text-body-md font-body-md text-on-surface-variant">No configuration.</p>
    {% endif %}
    <p class="text-body-sm font-body-sm text-on-surface-variant mt-sm">Configurations are stored secret-free; credentials never live in the registry.</p>
  </section>

  <section id="sync-history" aria-labelledby="sync-heading" class="glass-panel rounded-lg p-lg">
    <h2 id="sync-heading" class="text-headline-md font-headline-md text-on-surface mb-sm">Sync history</h2>
    {% if not runs %}
    <p class="text-body-md font-body-md text-on-surface-variant">{% if source.syncable %}No sync has run yet.{% else %}Upload sources are not synchronised.{% endif %}</p>
    {% else %}
    <ol class="flex flex-col divide-y divide-[#1E293B]">
      {% for run in runs %}
      <li class="py-sm">
        <div class="flex items-center justify-between gap-sm">
          <span class="text-body-md font-body-md text-on-surface">{{ run.started_at.strftime("%Y-%m-%d %H:%M") }}</span>
          {% set run_badge = run_badges.get(run.outcome.value, (run.outcome.value | replace("_", " ") | title, "neutral")) %}
          {{ badge(run_badge[0], run_badge[1]) }}
        </div>
        <p class="text-body-sm font-body-sm text-on-surface-variant mt-xs">
          {{ run.discovered }} discovered · {{ run.new }} new · {{ run.changed }} changed · {{ run.unchanged }} unchanged · {{ run.removed }} removed{% if run.failed %} · <span class="text-error">{{ run.failed }} failed</span>{% endif %}
        </p>
        {% if run.error_code %}<p class="text-code-sm font-code-sm text-error mt-xs">{{ run.error_code }}</p>{% endif %}
        {% if run.revision %}<p class="text-code-sm font-code-sm text-on-surface-variant mt-xs">revision {{ run.revision[:12] }}</p>{% endif %}
      </li>
      {% endfor %}
    </ol>
    {% endif %}
  </section>
</div>

{% if overview.failed_items %}
<section id="unconverged" aria-labelledby="unconverged-heading" class="glass-panel rounded-lg overflow-hidden mt-md border-l-4 border-error">
  <div class="px-md py-sm border-b border-[#1E293B]">
    <h2 id="unconverged-heading" class="text-headline-md font-headline-md text-error">Ingest failed</h2>
    <p class="text-body-sm font-body-sm text-on-surface-variant mt-xs" role="alert">
      These items were discovered but never made searchable. Their content has not changed since the failure, so syncing again will not retry them — retry the failed ingest job, or modify the source content.
    </p>
  </div>
  <div class="overflow-x-auto">
    <table class="w-full text-left border-collapse" data-mobile-records="source-failures">
      <caption class="sr-only">Items of {{ source.name }} that failed to ingest</caption>
      <thead class="bg-[#0F172A] border-b border-[#1E293B]">
        <tr>
          <th scope="col" class="py-sm px-md text-label-caps font-label-caps text-on-surface-variant uppercase tracking-wider">Item</th>
          <th scope="col" class="py-sm px-md text-label-caps font-label-caps text-on-surface-variant uppercase tracking-wider">Failure</th>
          <th scope="col" class="py-sm px-md text-label-caps font-label-caps text-on-surface-variant uppercase tracking-wider">Retryable</th>
          <th scope="col" class="py-sm px-md text-label-caps font-label-caps text-on-surface-variant uppercase tracking-wider">Recovery</th>
        </tr>
      </thead>
      <tbody class="divide-y divide-[#1E293B]">
        {% for entry in overview.failed_items %}
        <tr class="table-row-hover transition-colors">
          <th scope="row" class="py-sm px-md text-code-sm font-code-sm text-on-surface" data-label="Item">{{ entry.external_id }}</th>
          <td class="py-sm px-md text-code-sm font-code-sm text-error" data-label="Failure">{{ entry.last_failure_code }}</td>
          <td class="py-sm px-md text-body-md font-body-md text-on-surface-variant" data-label="Retryable">{% if entry.last_failure_retryable %}Yes{% elif entry.last_failure_retryable is none %}Unknown{% else %}No{% endif %}</td>
          <td class="py-sm px-md text-body-md font-body-md" data-label="Recovery">
            {% if entry.last_failure_job_id in reachable_job_ids %}<a href="/admin/jobs/{{ entry.last_failure_job_id }}" class="text-primary hover:underline">Open the failed ingest job</a>
            {% elif entry.last_failure_job_id %}<span class="text-on-surface-variant">The recorded job is unavailable; modify the source content, then sync again.</span>
            {% else %}<span class="text-on-surface-variant">Modify the source content, then sync again.</span>{% endif %}
          </td>
        </tr>
        {% endfor %}
      </tbody>
    </table>
  </div>
</section>
{% endif %}

<section id="documents" aria-labelledby="documents-heading" class="glass-panel rounded-lg overflow-hidden mt-md">
  <div class="flex items-center justify-between gap-md px-md py-sm border-b border-[#1E293B]">
    <h2 id="documents-heading" class="text-headline-md font-headline-md text-on-surface">Documents</h2>
    <a href="/admin/documents?source_id={{ source.id }}" class="text-body-sm font-body-sm text-primary hover:underline">Open in Documents</a>
  </div>
  {% if not documents.items %}
  <p class="p-lg text-body-md font-body-md text-on-surface-variant" role="status">No documents from this source yet.{% if source.syncable and can_manage %} Run a sync to discover and ingest its content.{% endif %}</p>
  {% else %}
  <div class="overflow-x-auto">
    <table class="w-full text-left border-collapse" data-mobile-records="source-documents">
      <caption class="sr-only">Documents of {{ source.name }}</caption>
      <thead class="bg-[#0F172A] border-b border-[#1E293B]">
        <tr>
          <th scope="col" class="py-sm px-md text-label-caps font-label-caps text-on-surface-variant uppercase tracking-wider">Document</th>
          <th scope="col" class="py-sm px-md text-label-caps font-label-caps text-on-surface-variant uppercase tracking-wider">Item</th>
          <th scope="col" class="py-sm px-md text-label-caps font-label-caps text-on-surface-variant uppercase tracking-wider">State</th>
          <th scope="col" class="py-sm px-md text-label-caps font-label-caps text-on-surface-variant uppercase tracking-wider">Updated</th>
        </tr>
      </thead>
      <tbody class="divide-y divide-[#1E293B]">
        {% for item in documents.items %}
        <tr class="table-row-hover transition-colors">
          <th scope="row" class="py-sm px-md" data-label="Document"><a href="/admin/documents/{{ item.document.id }}" class="text-body-md font-headline-md text-on-surface hover:text-primary">{{ item.document.title }}</a></th>
          <td class="py-sm px-md text-code-sm font-code-sm text-on-surface-variant" data-label="Item">{{ item.document.external_id }}</td>
          <td class="py-sm px-md" data-label="State">
            {% if item.document.source_deleted %}{{ badge("Retired", "neutral") }}
            {% elif item.searchable %}{{ badge("Searchable", "ok") }}
            {% elif item.failed %}{{ badge("Failed", "error") }}
            {% elif item.latest_state %}{{ badge("Processing", "info") }}
            {% else %}{{ badge("No version", "neutral") }}{% endif %}
          </td>
          <td class="py-sm px-md text-body-md font-body-md text-on-surface-variant" data-label="Updated">{{ item.updated_at.strftime("%Y-%m-%d %H:%M") if item.updated_at else "—" }}</td>
        </tr>
        {% endfor %}
      </tbody>
    </table>
  </div>
  {{ pagination(documents.total, documents.limit, documents.offset, "/admin/sources/" ~ source.id, "") }}
  {% endif %}
</section>
{% endblock %}