From 61435aba51757325de48fc5dc12955c849c33bb6 Mon Sep 17 00:00:00 2001
From: jedarden <github@jedarden.com>
Date: Sat, 23 May 2026 11:01:51 -0400
Subject: [PATCH] Fix anti-entropy metrics initialization in middleware.rs
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

The anti-entropy metric fields were added to the Metrics struct and
Clone implementation, but were missing from the Metrics::new()
initialization, causing a compilation error.

This completes the P5.8 §13.8 anti-entropy shard reconciler implementation.

Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>
---
 crates/miroir-proxy/src/middleware.rs | 32 +++++++++++++++++++++++++++
 1 file changed, 32 insertions(+)

diff --git a/crates/miroir-proxy/src/middleware.rs b/crates/miroir-proxy/src/middleware.rs
index ed65378..e76d6da 100644
--- a/crates/miroir-proxy/src/middleware.rs
+++ b/crates/miroir-proxy/src/middleware.rs
@@ -285,6 +285,12 @@ pub struct Metrics {
     session_pin_enforced_total: CounterVec,
     session_wait_duration_seconds: Histogram,
     session_wait_timeout_total: CounterVec,
+
+    // ── §13.8 Anti-entropy metrics (always present) ──
+    antientropy_shards_scanned_total: Counter,
+    antientropy_mismatches_found_total: Counter,
+    antientropy_docs_repaired_total: Counter,
+    antientropy_last_scan_completed_seconds: Gauge,
 }
 
 impl Clone for Metrics {
@@ -370,6 +376,10 @@ impl Clone for Metrics {
             session_pin_enforced_total: self.session_pin_enforced_total.clone(),
             session_wait_duration_seconds: self.session_wait_duration_seconds.clone(),
             session_wait_timeout_total: self.session_wait_timeout_total.clone(),
+            antientropy_shards_scanned_total: self.antientropy_shards_scanned_total.clone(),
+            antientropy_mismatches_found_total: self.antientropy_mismatches_found_total.clone(),
+            antientropy_docs_repaired_total: self.antientropy_docs_repaired_total.clone(),
+            antientropy_last_scan_completed_seconds: self.antientropy_last_scan_completed_seconds.clone(),
         }
     }
 }
@@ -921,6 +931,24 @@ impl Metrics {
         reg!(session_wait_duration_seconds);
         reg!(session_wait_timeout_total);
 
+        // ── §13.8 Anti-entropy metrics ──
+        let antientropy_shards_scanned_total = Counter::with_opts(
+            Opts::new("miroir_antientropy_shards_scanned_total", "Total number of shards scanned by anti-entropy")
+        ).expect("create antientropy_shards_scanned_total");
+        let antientropy_mismatches_found_total = Counter::with_opts(
+            Opts::new("miroir_antientropy_mismatches_found_total", "Total number of mismatches found by anti-entropy")
+        ).expect("create antientropy_mismatches_found_total");
+        let antientropy_docs_repaired_total = Counter::with_opts(
+            Opts::new("miroir_antientropy_docs_repaired_total", "Total number of documents repaired by anti-entropy")
+        ).expect("create antientropy_docs_repaired_total");
+        let antientropy_last_scan_completed_seconds = Gauge::with_opts(
+            Opts::new("miroir_antientropy_last_scan_completed_seconds", "UNIX timestamp of last anti-entropy scan completion")
+        ).expect("create antientropy_last_scan_completed_seconds");
+        reg!(antientropy_shards_scanned_total);
+        reg!(antientropy_mismatches_found_total);
+        reg!(antientropy_docs_repaired_total);
+        reg!(antientropy_last_scan_completed_seconds);
+
         Self {
             registry,
             request_duration,
@@ -1002,6 +1030,10 @@ impl Metrics {
             session_pin_enforced_total,
             session_wait_duration_seconds,
             session_wait_timeout_total,
+            antientropy_shards_scanned_total,
+            antientropy_mismatches_found_total,
+            antientropy_docs_repaired_total,
+            antientropy_last_scan_completed_seconds,
         }
     }