From 7df357c4e241e62ca261ec41bdc40c6c1914be3b Mon Sep 17 00:00:00 2001 From: ppom Date: Mon, 10 Feb 2025 12:00:00 +0100 Subject: [PATCH] add db flush on quit --- src/daemon/mod.rs | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/src/daemon/mod.rs b/src/daemon/mod.rs index 5ab3784..161477c 100644 --- a/src/daemon/mod.rs +++ b/src/daemon/mod.rs @@ -87,9 +87,13 @@ pub async fn daemon( let _ = socket_manager_task_handle.await; + let db_ok = db.flush(); + let stop_ok = config.stop(); - if !signal_received.load(Ordering::SeqCst) { + if let Err(err) = db_ok { + Err(format!("database was not saved, unrecoverable error: {}", err).into()) + } else if !signal_received.load(Ordering::SeqCst) { Err("quitting because all streams finished".into()) } else if !stop_ok { Err("while executing stop command".into())