{% extends base_template %}

{% 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_statuses %}
      <table class="table table-condensed table-bordered">
        <thead>
          <tr><th>conn_id</th><th>Status</th><th>Consumers</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 == 'connecting' %}
              <span class="label label-warning">○ connecting</span>
            {% else %}
              <span class="label label-default">○ {{ cs.status }}</span>
            {% endif %}
          </td>
          <td>{{ cs.consumer_count }}</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
        <a href="{{ url_for('RMQWatcherView.create') }}" class="btn btn-sm btn-primary pull-right">
          + Create subscription
        </a>
      </h4>
    </div>
    <div class="panel-body">
      {% if 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>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 }}</td>
            <td>
              {% for q in item.queue_names %}
                <span class="label label-default">{{ q }}</span>
              {% endfor %}
            </td>
            <td>{{ item.conn_id }}</td>
            <td>
              {% if item.cooldown %}
                <span class="text-info">{{ item.cooldown }}s</span>
              {% else %}
                —
              {% endif %}
            </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 }}</td>
            <td>{{ item.queue_name }}</td>
            <td>{{ item.conn_id }}</td>
            <td>
              {% if item.cooldown %}
                <span class="text-info">{{ item.cooldown }}s</span>
              {% else %}
                —
              {% endif %}
            </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>
              {% 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 %}