{% extends base_template %}

{# One wording per message. The badge and the flash of the same warning are the two
   constants of views.py, handed in as `shared_queue_warning` and
   `shared_queue_ack_warning`, so the page and the notice cannot drift apart. #}
{% macro shared_badge(names, acking, name_them=false) %}
  {%- if names -%}
    <span class="label label-warning"
          title="Another enabled subscription listens to this queue on the same conn_id. {{ shared_queue_warning }}{% if acking %} {{ shared_queue_ack_warning }}{% endif %}">
      ⚠ shared queue{% if name_them %}: {{ names | join(', ') }}{% endif %}{% if acking %} — messages deleted{% endif %}
    </span>
  {%- endif -%}
{% endmacro %}

{% macro ack_unmatched_cell(on) %}
  {%- if on -%}
    <span class="label label-info"
          title="A message this subscription's filter rejects is acknowledged and gone instead of being returned to the queue. Dead-lettering does not apply to an acknowledgement, so the message simply disappears.">on</span>
  {%- else -%}
    —
  {%- endif -%}
{% endmacro %}

{% block content %}
<div class="container-fluid">
  <div class="page-header">
    <h2>RMQ Watcher — Subscriptions</h2>
  </div>

  {# Flash messages #}
  {% with messages = get_flashed_messages(with_categories=true) %}
    {% for category, message in messages %}
    <div class="alert alert-{{ 'danger' if category == 'error' else category }}">{{ message }}</div>
    {% endfor %}
  {% endwith %}

  {# --- Connections block --- #}
  <div class="panel panel-default">
    <div class="panel-heading"><h4>Connections</h4></div>
    <div class="panel-body">
      {% if conn_status_error %}
      <p class="text-warning">⚠ {{ conn_status_error }}</p>
      {% elif conn_statuses %}
      <table class="table table-condensed table-bordered">
        <thead>
          <tr>
            <th>conn_id</th>
            <th>Status</th>
            <th>Consumers</th>
            <th>Broker consumers</th>
            <th>Last reconcile</th>
            <th>Last Error</th>
          </tr>
        </thead>
        <tbody>
        {% for cs in conn_statuses %}
        <tr>
          <td><strong>{{ cs.conn_id }}</strong></td>
          <td>
            {% if cs.status == 'connected' %}
              <span class="label label-success">● connected</span>
            {% elif cs.status == 'error' %}
              <span class="label label-danger">✕ error</span>
            {% elif cs.status == 'degraded' %}
              <span class="label label-warning" title="The broker did not confirm a consumer of this connection, but the connection was recreated too recently to be torn down again — the watcher is holding off rather than looping through recreations.">○ degraded</span>
            {% else %}
              <span class="label label-default">○ {{ cs.status }}</span>
            {% endif %}
          </td>
          <td>{{ cs.consumer_count }}</td>
          <td>
            {% if cs.broker_consumer_count is none %}
              —
            {% elif cs.counts_mismatch %}
              <span class="label label-warning"
                    title="The broker reports a different number of consumers than the watcher has started for this conn_id. A lower number means a subscription that has not attached yet — still connecting, or backing off after an error — and is therefore not probed; a higher number means another scheduler replica using the same credentials, or — on a monitoring/administrator account, which is what makes foreign channels visible at all — other clients consuming the same queues. A consumer the broker is asked about and does not confirm is restarted by the watchdog, and says so in the status of its own subscription.">
                ⚠ {{ cs.broker_consumer_count }}
              </span>
            {% else %}
              {{ cs.broker_consumer_count }}
            {% endif %}
          </td>
          <td>
            {% if cs.age_seconds is none %}
              —
            {% elif cs.is_stale %}
              <span class="label label-warning"
                    title="The last reconcile cycle for this conn_id is older than {{ stale_after_display }} — one reconcile interval plus the whole budget a cycle is given. Either the watcher loop is stuck, restarting or not running at all, or no enabled subscription names this conn_id any more, which leaves its row behind with the timestamp it had when the last one was turned off.">
                ⚠ {{ cs.age_display }} ago
              </span>
            {% else %}
              {{ cs.age_display }} ago
            {% endif %}
          </td>
          <td>{{ cs.last_error or '—' }}</td>
        </tr>
        {% endfor %}
        </tbody>
      </table>
      {% else %}
      <p class="text-muted">No connections established yet.</p>
      {% endif %}
    </div>
  </div>

  {# --- Subscriptions table --- #}
  <div class="panel panel-default">
    <div class="panel-heading">
      <h4>Subscriptions
        {# The form behind this button writes through the same mapping the notice
           below says could not be read, so it would answer with a 500 for as long
           as the notice stands. #}
        {% if not subscriptions_error %}
        <a href="{{ url_for('RMQWatcherView.create') }}" class="btn btn-sm btn-primary pull-right">
          + Create subscription
        </a>
        {% endif %}
      </h4>
    </div>
    <div class="panel-body">
      {% if subscriptions_error %}
      <p class="text-warning">⚠ {{ subscriptions_error }}</p>
      {% elif subscriptions %}
      <table class="table table-hover table-bordered">
        <thead>
          <tr>
            <th>DAG</th>
            <th>Queue(s)</th>
            <th>conn_id</th>
            <th>Cooldown</th>
            <th>Ack unmatched</th>
            <th>Source</th>
            <th>Status</th>
            <th>Last Error</th>
            <th>Actions</th>
          </tr>
        </thead>
        <tbody>
        {% for item in subscriptions %}
          {% if item.is_group is defined and item.is_group %}
          {# ---- Grouped row (multiple queues, shared cooldown) ---- #}
          <tr class="{{ 'text-muted' if not item.enabled else '' }}">
            <td>
              {{ item.dag_id }}
              {% if active_dag_ids is defined and active_dag_ids is not none and item.dag_id not in active_dag_ids %}
                <span class="label label-warning"
                      title="No active Airflow DAG found for this dag_id — a matching message will not trigger a real pipeline run. Check for a typo in dag_id, a renamed or deleted DAG, a DAG that is inactive (is_active=false), or a newly added DAG the Scheduler has not parsed yet.">
                  ⚠ dag not found
                </span>
              {% endif %}
            </td>
            <td>
              {% for q in item.queue_names %}
                <span class="label label-default">{{ q }}</span>
              {% endfor %}
              {{ shared_badge(item.shared_queue_names, item.shared_acking, name_them=true) }}
            </td>
            <td>{{ item.conn_id }}</td>
            <td>
              {% if item.cooldown %}
                <span class="text-info">{{ item.cooldown }}s</span>
              {% else %}
                —
              {% endif %}
            </td>
            <td>{{ ack_unmatched_cell(item.ack_unmatched) }}</td>
            <td>
              {% if item.source == 'dag_file' %}
                <span class="label label-info">dag_file</span>
              {% else %}
                <span class="label label-default">ui</span>
              {% endif %}
            </td>
            <td>
              {% if not item.enabled %}
                <span class="label label-default">disabled</span>
              {% else %}
                <span class="label label-{{ 'success' if item.listening_count == item.total_count else 'warning' }}">
                  {{ item.display_status }}
                </span>
              {% endif %}
            </td>
            <td>{{ item.last_error or '—' }}</td>
            <td>
              <form method="post" action="{{ url_for('RMQWatcherView.toggle_group', group_key=item.group_key) }}" style="display:inline">
                <input type="hidden" name="csrf_token" value="{{ csrf_token() }}">
                <button type="submit" class="btn btn-xs btn-default">
                  {% if item.enabled %}Disable{% else %}Enable{% endif %}
                </button>
              </form>
              <a href="{{ url_for('RMQWatcherView.edit_group', group_key=item.group_key) }}" class="btn btn-xs btn-info">Edit</a>
              {% if item.source == 'ui' %}
              <form method="post" action="{{ url_for('RMQWatcherView.delete_group', group_key=item.group_key) }}" style="display:inline"
                    onsubmit="return confirm('Delete all subscriptions in group ' + {{ item.group_key | tojson }} + '?')">
                <input type="hidden" name="csrf_token" value="{{ csrf_token() }}">
                <button type="submit" class="btn btn-xs btn-danger">Delete</button>
              </form>
              {% endif %}
            </td>
          </tr>
          {% else %}
          {# ---- Single-queue row (no group_key) ---- #}
          <tr class="{{ 'text-muted' if not item.enabled else '' }}">
            <td>
              {{ item.dag_id }}
              {% if active_dag_ids is defined and active_dag_ids is not none and item.dag_id not in active_dag_ids %}
                <span class="label label-warning"
                      title="No active Airflow DAG found for this dag_id — a matching message will not trigger a real pipeline run. Check for a typo in dag_id, a renamed or deleted DAG, a DAG that is inactive (is_active=false), or a newly added DAG the Scheduler has not parsed yet.">
                  ⚠ dag not found
                </span>
              {% endif %}
            </td>
            <td>
              {{ item.queue_name }}
              {{ shared_badge(item.shared_queue_names, item.shared_acking) }}
            </td>
            <td>{{ item.conn_id }}</td>
            <td>
              {% if item.cooldown %}
                <span class="text-info">{{ item.cooldown }}s</span>
              {% else %}
                —
              {% endif %}
            </td>
            <td>{{ ack_unmatched_cell(item.ack_unmatched) }}</td>
            <td>
              {% if item.source == 'dag_file' %}
                <span class="label label-info">dag_file</span>
              {% else %}
                <span class="label label-default">ui</span>
              {% endif %}
            </td>
            <td>
              {% if not item.enabled %}
                <span class="label label-default">disabled</span>
              {% elif item.consumer_status == 'listening' %}
                <span class="label label-success">listening</span>
              {% elif item.consumer_status == 'connecting' %}
                <span class="label label-warning">connecting</span>
              {% elif item.consumer_status == 'error' %}
                <span class="label label-danger">error</span>
              {% elif item.consumer_status == 'disconnected' %}
                <span class="label label-default"
                      title="No consumer task is running for this subscription — the watcher let it go and the next reconcile cycle starts it again. Unlike 'disabled', the subscription is still on.">○ disconnected</span>
              {% else %}
                <span class="label label-default">{{ item.consumer_status }}</span>
              {% endif %}
            </td>
            <td>{{ item.last_error or '—' }}</td>
            <td>
              <form method="post" action="{{ url_for('RMQWatcherView.toggle', sub_id=item.id) }}" style="display:inline">
                <input type="hidden" name="csrf_token" value="{{ csrf_token() }}">
                <button type="submit" class="btn btn-xs btn-default">
                  {% if item.enabled %}Disable{% else %}Enable{% endif %}
                </button>
              </form>
              <a href="{{ url_for('RMQWatcherView.edit', sub_id=item.id) }}" class="btn btn-xs btn-info">Edit</a>
              {% if item.source == 'ui' %}
              <form method="post" action="{{ url_for('RMQWatcherView.delete', sub_id=item.id) }}" style="display:inline"
                    onsubmit="return confirm('Delete subscription for DAG ' + {{ item.dag_id | tojson }} + '?')">
                <input type="hidden" name="csrf_token" value="{{ csrf_token() }}">
                <button type="submit" class="btn btn-xs btn-danger">Delete</button>
              </form>
              {% endif %}
            </td>
          </tr>
          {% endif %}
        {% endfor %}
        </tbody>
      </table>
      {% else %}
      <p class="text-muted">
        No subscriptions yet.
        <a href="{{ url_for('RMQWatcherView.create') }}">Create the first one</a>
        or add <code>@rmq_trigger</code> to a DAG file.
      </p>
      {% endif %}
    </div>
  </div>
</div>
{% endblock %}