diff options
| author | Ellie Huxtable <ellie@elliehuxtable.com> | 2024-05-08 17:28:52 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-05-08 17:28:52 +0100 |
| commit | 0da534d5249a9111f8e1af0ff517526e2c66cdb0 (patch) | |
| tree | 0da2b5ac39a7231e421870e1723fad27b03785e4 /crates/atuin-daemon/src/server.rs | |
| parent | fix: add protobuf compiler to docker image (#2009) (diff) | |
| download | atuin-0da534d5249a9111f8e1af0ff517526e2c66cdb0.zip | |
fix: add incremental rebuild to daemon loop (#2010)
Diffstat (limited to 'crates/atuin-daemon/src/server.rs')
| -rw-r--r-- | crates/atuin-daemon/src/server.rs | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/crates/atuin-daemon/src/server.rs b/crates/atuin-daemon/src/server.rs index 42ef1701..72305737 100644 --- a/crates/atuin-daemon/src/server.rs +++ b/crates/atuin-daemon/src/server.rs @@ -166,7 +166,7 @@ pub async fn listen( let host_id = Settings::host_id().expect("failed to get host_id"); let history_store = HistoryStore::new(store.clone(), host_id, encryption_key); - let history = HistoryService::new(history_store, history_db); + let history = HistoryService::new(history_store.clone(), history_db.clone()); let socket = settings.daemon.socket_path.clone(); let uds = UnixListener::bind(socket.clone())?; @@ -175,7 +175,12 @@ pub async fn listen( tracing::info!("listening on unix socket {:?}", socket); // start services - tokio::spawn(sync::worker(settings.clone(), store)); + tokio::spawn(sync::worker( + settings.clone(), + store, + history_store, + history_db, + )); Server::builder() .add_service(HistoryServer::new(history)) |