fix: change gasket version

Author: MartinSchere

Cargo.lock

@@ -26,8 +26,8 @@ mithril = ["mithril-client"]
 # pallas = { path = "../pallas/pallas", features = ["hardano"] }
 pallas = { version = "0.32.0", features = ["hardano"] }
 
-gasket = { git = "https://github.com/construkts/gasket-rs.git", features = ["derive"] }
-gasket-prometheus = { git = "https://github.com/construkts/gasket-rs.git" }
+gasket = { git = "https://github.com/jpg-store/gasket-rs.git", features = ["derive"], branch="martin/fix-gauge-0.7.0" }
+gasket-prometheus = { git = "https://github.com/jpg-store/gasket-rs.git", branch="martin/fix-gauge-0.7.0"  }
 # gasket = { path = "../../construkts/gasket-rs/gasket", features = ["derive"] }
 # gasket = { git = "https://github.com/construkts/gasket-rs.git", features = ["derive"] }
 

Cargo.toml

@@ -60,17 +60,12 @@ pub fn run(args: &Args) -> Result<(), Error> {
     let prometheus = tokio_rt.spawn(serve_prometheus(daemon.clone(), metrics));
     let tui = tokio_rt.spawn(console::render(daemon.clone(), args.tui));
 
-    let daemon = Arc::try_unwrap(daemon).map_err(|daemon| {
-        Error::Custom(format!(
-            "daemon still has {} references",
-            Arc::strong_count(&daemon)
-        ))
-    })?;
-
     daemon.block();
 
     info!("oura is stopping");
 
+    daemon.teardown();
+
     prometheus.abort();
     tui.abort();
 

src/bin/oura/run_daemon.rs

@@ -90,7 +90,7 @@ fn connect_stages<S: Sink>(
     tethers.push(sink.spawn(policy.clone()));
     tethers.push(cursor.spawn(policy));
 
-    let runtime = Daemon::new(tethers);
+    let runtime = Daemon(tethers);
 
     Ok(runtime)
 }