{% extends "base.html" %}
{% from "_page_header.html" import page_header %}
{% from "_components.html" import badge, identifier, empty_state, pagination, toolbar, operations_journey %}
{% block content %}
{% call page_header("Ingestion Jobs", "Background processing queue: document ingests and source syncs with their real states, attempts and timing.") %}{% endcall %}

{{ operations_journey(source_url="/admin/sources" if can_open_sources else None, document_url="/admin/documents" if can_open_documents else None, current="job") }}

<p class="text-body-sm font-body-sm text-on-surface-variant mb-md">Scope: <span class="font-headline-md text-on-surface">{{ scope_label }}</span> — counts and rows below cover this scope only. The counters summarise the whole queue in this scope; the table below shows the jobs matching the current filter.</p>

{% if ignored_filters %}
<p role="status" class="text-body-md font-body-md text-primary bg-primary-container/10 border-l-4 border-primary rounded-DEFAULT p-md mb-md">Unrecognised {{ ignored_filters | join(" and ") }} filter{{ "s" if ignored_filters | length > 1 else "" }} ignored; the list below is not narrowed by {{ "them" if ignored_filters | length > 1 else "it" }}.</p>
{% endif %}

{% 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 %}

{% if not available %}
{{ empty_state("Job queue unavailable", "The job store could not be reached. Check PostgreSQL connectivity and retry.", icon="cloud_off") }}
{% else %}
<div class="grid grid-cols-2 md:grid-cols-5 gap-md mb-lg">
  {% for key, label in [("queued", "Queued"), ("running", "Running"), ("retrying", "Retrying"), ("succeeded", "Succeeded"), ("failed", "Failed")] %}
  <a href="/admin/jobs?status={{ {'queued': 'ready', 'running': 'leased', 'retrying': 'retry_wait', 'succeeded': 'succeeded', 'failed': 'terminal'}[key] }}" class="glass-panel rounded-lg p-md hover:border-primary transition-colors">
    <p class="text-label-caps font-label-caps text-on-surface-variant uppercase tracking-wider mb-xs">{{ label }}</p>
    <p class="text-headline-lg font-headline-lg {{ 'text-error' if key == 'failed' and counts[key] else 'text-on-surface' }}">{{ counts[key] }}</p>
  </a>
  {% endfor %}
</div>

<div class="glass-panel rounded-lg overflow-hidden flex flex-col">
  {% call toolbar("/admin/jobs", label="Filter jobs") %}
    <div>
      <label for="status" class="block text-body-sm font-body-sm text-on-surface-variant mb-xs">Status</label>
      <select id="status" name="status" class="input-dark rounded-DEFAULT py-sm px-md text-body-md font-body-md">
        <option value="">Any status</option>
        {% for value, label in status_options %}<option value="{{ value }}" {{ "selected" if filters.status == value else "" }}>{{ label }}</option>{% endfor %}
      </select>
    </div>
    <div>
      <label for="operation" class="block text-body-sm font-body-sm text-on-surface-variant mb-xs">Type</label>
      <select id="operation" name="operation" class="input-dark rounded-DEFAULT py-sm px-md text-body-md font-body-md">
        <option value="">Any type</option>
        {% for value, label in operation_options %}<option value="{{ value }}" {{ "selected" if filters.operation == value else "" }}>{{ label }}</option>{% endfor %}
      </select>
    </div>
  {% endcall %}

  {% if not rows %}
  <div class="p-lg">
  {% if query or page.offset %}
  {{ empty_state("No jobs match this filter", "No job in this scope matches the selected status and type on this page. Clear the filter to see the whole queue.", "/admin/jobs", "Clear filter", icon="filter_alt_off") }}
  {% else %}
  {{ empty_state("No jobs yet", "Upload a document or sync a source to start ingestion; jobs appear here as soon as they are queued.", "/admin/sources", "Go to sources", icon="sync") }}
  {% endif %}
  </div>
  {% else %}
  <div class="overflow-x-auto">
    <table class="w-full text-left border-collapse" data-mobile-records="jobs">
      <caption class="sr-only">Recent ingestion jobs</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">Type</th>
          <th scope="col" class="py-sm px-md text-label-caps font-label-caps text-on-surface-variant uppercase tracking-wider">Source / Document</th>
          <th scope="col" class="py-sm px-md text-label-caps font-label-caps text-on-surface-variant uppercase tracking-wider">Queued</th>
          <th scope="col" class="py-sm px-md text-label-caps font-label-caps text-on-surface-variant uppercase tracking-wider">Attempt</th>
          <th scope="col" class="py-sm px-md text-label-caps font-label-caps text-on-surface-variant uppercase tracking-wider">Status</th>
          <th scope="col" class="py-sm px-md text-label-caps font-label-caps text-on-surface-variant uppercase tracking-wider">Failure</th>
        </tr>
      </thead>
      <tbody class="divide-y divide-[#1E293B]">
        {% for row in rows %}
        <tr class="table-row-hover transition-colors">
          <th scope="row" class="py-md px-md" data-label="Type">
            <a href="/admin/jobs/{{ row.job.id }}" class="flex items-center gap-sm text-body-md font-headline-md text-on-surface hover:text-primary">
              <span class="material-symbols-outlined text-primary text-[18px]" aria-hidden="true">{{ "sync" if row.job.operation == "sync_source" else "upload_file" }}</span>
              <span>{{ row.operation_label }}</span>
            </a>
            <div class="mt-xs">{{ identifier(row.job.id, "job-" ~ loop.index) }}</div>
          </th>
          <td class="py-md px-md text-body-md font-body-md text-on-surface" data-label="Source / Document">
            <p class="truncate max-w-xs" title="{{ row.subject }}">{{ row.subject }}</p>
            {% if row.source_linkable %}<a href="/admin/sources/{{ row.source_id }}" class="text-body-sm font-body-sm text-on-surface-variant hover:text-primary">{{ row.source_name }}</a>{% elif row.source_id %}<span class="text-body-sm font-body-sm text-on-surface-variant">{{ row.source_name or "Source " ~ (row.source_id | string)[:8] ~ "…" }}</span>{% endif %}
          </td>
          <td class="py-md px-md text-body-md font-body-md text-on-surface-variant whitespace-nowrap" title="{{ row.queued_at.strftime('%Y-%m-%d %H:%M:%S') }}" data-label="Queued">{{ row.age }}</td>
          <td class="py-md px-md text-body-md font-body-md text-on-surface-variant tabular-nums" data-label="Attempt">{{ row.job.attempt_count }} / {{ row.job.max_attempts }}</td>
          <td class="py-md px-md" data-label="Status">
            {% if row.status_label == "Succeeded" %}{{ badge(row.status_label, "ok") }}
            {% elif row.status_label == "Failed" %}{{ badge(row.status_label, "error") }}
            {% elif row.status_label == "Running" %}{{ badge(row.status_label, "info") }}
            {% elif row.status_label == "Retrying" %}{{ badge(row.status_label, "warn") }}
            {% else %}{{ badge(row.status_label, "neutral") }}{% endif %}
          </td>
          <td class="py-md px-md text-code-sm font-code-sm {{ 'text-error' if row.job.last_error_code else 'text-on-surface-variant' }}" data-label="Failure">{{ row.failure_code or row.job.last_error_code or "—" }}</td>
        </tr>
        {% endfor %}
      </tbody>
    </table>
  </div>
  {% endif %}
  {{ pagination(page.total, page.limit, page.offset, "/admin/jobs", query) }}
</div>
{% endif %}
{% endblock %}