1 files changed, 3 insertions, 19 deletions

diff --git a/src/sync/mod.rs b/src/sync/mod.rs
index 21f31df..c62b478 100644
--- a/src/sync/mod.rs
+++ b/src/sync/mod.rs
@@ -39,7 +39,6 @@ use std::sync::Arc;
 use std::time::Duration;
 
 use nostr_sdk::prelude::*;
-use prometheus::Registry;
 use tokio::sync::{broadcast, Mutex, RwLock};
 
 use crate::config::Config;
@@ -355,7 +354,7 @@ impl SyncManager {
     /// * `write_policy` - Policy for validating events before storage
     /// * `local_relay` - Local relay for submitting synced events (enables WebSocket broadcast)
     /// * `config` - Configuration for sync settings
-    /// * `registry` - Optional Prometheus registry for metrics (metrics only created if config.metrics_enabled is true)
+    /// * `sync_metrics` - Optional pre-registered SyncMetrics (passed from Metrics if metrics are enabled)
     pub fn new(
         bootstrap_relay_url: Option<String>,
         service_domain: String,
@@ -363,23 +362,8 @@ impl SyncManager {
         write_policy: Nip34WritePolicy,
         local_relay: LocalRelay,
         config: &Config,
-        registry: Option<&Registry>,
+        sync_metrics: Option<SyncMetrics>,
     ) -> Self {
-        // Create metrics only if metrics are enabled AND a registry is provided
-        let metrics = if config.metrics_enabled {
-            registry.and_then(|r| {
-                match SyncMetrics::register(r) {
-                    Ok(m) => Some(m),
-                    Err(e) => {
-                        tracing::warn!("Failed to register sync metrics: {}", e);
-                        None
-                    }
-                }
-            })
-        } else {
-            None
-        };
-
         Self {
             bootstrap_relay_url,
             service_domain,
@@ -397,7 +381,7 @@ impl SyncManager {
             eose_tx: None,
             connect_tx: None,
             shutdown_tx: None,
-            metrics,
+            metrics: sync_metrics,
         }
     }