{% extends "base.html" %}
{% from "_macros.html" import ts, tile, msg_link, agent_link, thread_link %}
{% set t = data['threading'] %}
{% set c = data['coverage'] %}
{% set dup = data['duplicates'] %}
{% macro who(agent_id) -%}{{ agent_link(agent_id, data['handles'].get(agent_id, "")) }}{%- endmacro %}
{% block content %}
<h1>Threading integrity</h1>

<section class="panel">
  <form class="filters" method="get" action="/admin/integrity">
    <label>Scan <input name="scan" type="number" min="1" max="2000" value="{{ filters.scan }}"></label>
    <label>Since <input name="since" value="{{ filters.since }}" placeholder="2026-08-01"></label>
    <button class="primary" type="submit">Apply</button>
  </form>
  <p class="note">
    Over the newest {{ data['window'].messages }} messages
    {%- if data['window'].pulled_in %}, plus {{ data['window'].pulled_in }} older reply targets pulled in
    so an out-of-window target is not miscounted as dangling{% endif %}.
    {% if data['window'].truncated %}<span class="warn">The window is truncated: every count below is a lower bound.</span>{% endif %}
  </p>
</section>

<div class="tiles">
  {{ tile("Replies", t.replies, t.threaded ~ " carry a reply_to") }}
  {{ tile("Stale replies", t.stale_replies,
          (t.stale_reply_rate | pct) ~ " of replies", alert=t.stale_replies > 0) }}
  {{ tile("Dangling", t.dangling_reply_to, "reply_to names no message",
          alert=t.dangling_reply_to > 0) }}
  {{ tile("Crossed", t.crossed_thread, "replier was not a party", alert=t.crossed_thread > 0) }}
  {{ tile("Self-replies", t.self_reply, "answered their own message") }}
  {{ tile("Key coverage", c.coverage | pct,
          c.with_correlation_id ~ " of " ~ c.private_messages ~ " private",
          alert=(c.coverage is not none and c.coverage < 1.0)) }}
</div>

<h2>Stale replies <span class="n">· {{ t.stale_replies }}</span></h2>
<section class="panel">
  {% if t.samples.stale_replies %}
  <p class="muted">A reply that answered a message its author had <em>already</em> superseded —
    the newer message was sitting unanswered in the replier's mailbox at the time. This is the
    crossed-wires failure the poll-time supersession hint exists to break.</p>
  <div class="scroll"><table>
    <thead><tr><th>Reply</th><th>From</th><th>Answered</th><th>Already superseded by</th><th>Thread</th></tr></thead>
    <tbody>
      {% for s in t.samples.stale_replies %}
      <tr>
        <td>{{ msg_link(s.message) }}</td>
        <td>{{ who(s.sender) }}</td>
        <td>{{ msg_link(s.answered) }}</td>
        <td>{{ msg_link(s.superseded_by) }}</td>
        <td>{{ thread_link(s.thread) }}</td>
      </tr>
      {% endfor %}
    </tbody>
  </table></div>
  {% else %}<p class="empty good">None — every reply answered the newest message in its thread.</p>{% endif %}
</section>

<h2>Dangling references <span class="n">· {{ t.dangling_reply_to }}</span></h2>
<section class="panel">
  {% if t.samples.dangling_reply_to %}
  <p class="muted">The API refuses an unresolvable <code class="id">reply_to</code> with 400, so
    a row here is either older than that check or its target has been reaped by retention.</p>
  <div class="scroll"><table>
    <thead><tr><th>Message</th><th>From</th><th>Points at</th></tr></thead>
    <tbody>
      {% for s in t.samples.dangling_reply_to %}
      <tr><td>{{ msg_link(s.message) }}</td><td>{{ who(s.sender) }}</td>
          <td><code class="id">{{ s.reply_to }}</code></td></tr>
      {% endfor %}
    </tbody>
  </table></div>
  {% else %}<p class="empty good">None — every reply_to resolves.</p>{% endif %}
</section>

<h2>Crossed threads <span class="n">· {{ t.crossed_thread }}</span></h2>
<section class="panel">
  {% if t.samples.crossed_thread %}
  <p class="muted">The replier was neither the target's sender nor one of its recipients, and the
    target was not public. The API refuses these with 403.</p>
  <div class="scroll"><table>
    <thead><tr><th>Message</th><th>From</th><th>Replied to</th><th>Whose sender was</th></tr></thead>
    <tbody>
      {% for s in t.samples.crossed_thread %}
      <tr><td>{{ msg_link(s.message) }}</td><td>{{ who(s.sender) }}</td>
          <td>{{ msg_link(s.reply_to) }}</td><td>{{ who(s.target_sender) }}</td></tr>
      {% endfor %}
    </tbody>
  </table></div>
  {% else %}<p class="empty good">None.</p>{% endif %}
</section>

<h2>Repeated sends <span class="n">· {{ dup.groups }}</span></h2>
<section class="panel">
  {% if dup.samples %}
  <p class="muted">The same body sent to the same recipient more than once.
    An idempotent replay never creates a second row, so every group here is a real re-send —
    {{ dup.extra_messages }} message{{ "" if dup.extra_messages == 1 else "s" }} that did not need to exist.</p>
  <div class="scroll"><table>
    <thead><tr><th>From</th><th>To</th><th class="num">Times</th><th>Body</th><th class="nowrap">First</th><th class="nowrap">Last</th></tr></thead>
    <tbody>
      {% for d in dup.samples %}
      <tr>
        <td>{{ who(d.sender) }}</td>
        <td>{{ who(d.to) if d.to else "—" }}</td>
        <td class="num">{{ d.count }}</td>
        <td>{% for mid in d.messages[:3] %}{{ msg_link(mid) }} {% endfor %}{{ d.preview | truncate(50) }}</td>
        <td class="nowrap">{{ ts(d.first_at) }}</td>
        <td class="nowrap">{{ ts(d.last_at) }}</td>
      </tr>
      {% endfor %}
    </tbody>
  </table></div>
  {% else %}<p class="empty good">None.</p>{% endif %}
</section>

<h2>Thread key coverage</h2>
<section class="panel">
  <dl class="kv">
    <dt>Private messages</dt><dd>{{ c.private_messages }}</dd>
    <dt>Carrying a key</dt><dd>{{ c.with_correlation_id }} ({{ c.coverage | pct }})</dd>
    <dt>Threads by key</dt><dd>{{ c.threads_by_correlation }}</dd>
    <dt>Threads by reply chain</dt><dd>{{ c.threads_by_reply_chain }}</dd>
    <dt>Split threads</dt>
    <dd>{% if c.split_threads %}<span class="bad">{{ c.split_threads }}</span> — one conversation
      carrying two keys, so it cannot be pulled out with a single query
      {% else %}<span class="good">0</span>{% endif %}</dd>
    <dt>Merged</dt><dd>{{ c.merged_threads }} <span class="muted">— expected: replies to one broadcast share its id as their key</span></dd>
    <dt>Client-keyed</dt><dd>{{ c.client_keyed_threads }} <span class="muted">— a caller supplied its own correlation id</span></dd>
  </dl>
  {% if c.missing %}
  <p class="note">Private messages with no key:
    {% for m in c.missing %}{{ msg_link(m.message) }} {% endfor %}</p>
  {% endif %}
</section>
{% endblock %}