diff options
| author | Benedikt Peetz <benedikt.peetz@b-peetz.de> | 2026-07-20 17:54:34 +0200 |
|---|---|---|
| committer | Benedikt Peetz <benedikt.peetz@b-peetz.de> | 2026-07-20 17:54:34 +0200 |
| commit | 6bd2b80be51a8623640fbd77afa1da09289e40cc (patch) | |
| tree | 8fa76fc78e27a4f3d6f57af07805a83e9877f0ad /crates/daemon/src/lib.rs | |
| parent | chore: Commit (diff) | |
| download | atuin-6bd2b80be51a8623640fbd77afa1da09289e40cc.zip | |
chore: All compiles
Diffstat (limited to 'crates/daemon/src/lib.rs')
| -rw-r--r-- | crates/daemon/src/lib.rs | 15 |
1 files changed, 4 insertions, 11 deletions
diff --git a/crates/daemon/src/lib.rs b/crates/daemon/src/lib.rs index 4f96e410..c6877096 100644 --- a/crates/daemon/src/lib.rs +++ b/crates/daemon/src/lib.rs @@ -12,10 +12,7 @@ use fs4::fs_std::FileExt; use tokio::time::sleep; use crate::{ - aclient::{ - database::ClientSqlite as HistoryDatabase, record::sqlite_store::SqliteStore, - settings::Settings, - }, + aclient::{database::ClientSqlite, record::sqlite_store::SqliteStore, settings::Settings}, api::{ DAEMON_VERSION, server::{control::ControlService, history::HistoryService}, @@ -34,17 +31,13 @@ pub(crate) mod server; /// /// This creates a daemon, /// starts the gRPC server with services, and runs the event loop. -pub async fn boot( - settings: Settings, - store: SqliteStore, - history_db: HistoryDatabase, -) -> Result<()> { +pub async fn boot(settings: Settings, store: SqliteStore, history_db: ClientSqlite) -> Result<()> { let pidfile_path = PathBuf::from(&settings.daemon.pidfile_path); let _pidfile_guard = PidfileGuard::acquire(&pidfile_path)?; let mut daemon = Daemon::builder(settings.clone()) .store(store) - .history_db(history_db) + .history_db(history_db.clone()) .build()?; let handle = { @@ -61,7 +54,7 @@ pub async fn boot( handle }; - let history_service = HistoryService::new(handle.clone()).await?; + let history_service = HistoryService::new(handle.clone(), history_db).await?; let control_service = ControlService::new(handle.clone()); server::run_grpc_server( |
