diff options
| author | Benedikt Peetz <benedikt.peetz@b-peetz.de> | 2026-06-11 00:54:30 +0200 |
|---|---|---|
| committer | Benedikt Peetz <benedikt.peetz@b-peetz.de> | 2026-06-11 00:54:30 +0200 |
| commit | 5c39e7cf284a1f6e9a1657f2deb44e359fc47eb8 (patch) | |
| tree | c64baa8d5866c8e339eaf660dd3f94f30a3f7d8a /crates/atuin-daemon/src/components | |
| parent | chore: Somewhat simplify sync code (diff) | |
| download | atuin-5c39e7cf284a1f6e9a1657f2deb44e359fc47eb8.zip | |
chore: Move everything into one big crate
That helps remove duplicated code and rustc/cargo will now also show
dead code correctly.
Diffstat (limited to '')
| -rw-r--r-- | crates/turtle/src/atuin_daemon/components/history.rs (renamed from crates/atuin-daemon/src/components/history.rs) | 4 | ||||
| -rw-r--r-- | crates/turtle/src/atuin_daemon/components/mod.rs (renamed from crates/atuin-daemon/src/components/mod.rs) | 0 | ||||
| -rw-r--r-- | crates/turtle/src/atuin_daemon/components/search.rs (renamed from crates/atuin-daemon/src/components/search.rs) | 6 | ||||
| -rw-r--r-- | crates/turtle/src/atuin_daemon/components/semantic.rs (renamed from crates/atuin-daemon/src/components/semantic.rs) | 29 | ||||
| -rw-r--r-- | crates/turtle/src/atuin_daemon/components/sync.rs (renamed from crates/atuin-daemon/src/components/sync.rs) | 4 |
5 files changed, 23 insertions, 20 deletions
diff --git a/crates/atuin-daemon/src/components/history.rs b/crates/turtle/src/atuin_daemon/components/history.rs index c82c8f94..95d34b69 100644 --- a/crates/atuin-daemon/src/components/history.rs +++ b/crates/turtle/src/atuin_daemon/components/history.rs @@ -4,7 +4,7 @@ use std::{pin::Pin, sync::Arc}; -use atuin_client::{ +use crate::atuin_client::{ database::Database, history::{History, HistoryId, store::HistoryStore}, settings::Settings, @@ -16,7 +16,7 @@ use tokio_stream::Stream; use tonic::{Request, Response, Status}; use tracing::{Level, instrument}; -use crate::{ +use crate::atuin_daemon::{ daemon::{Component, DaemonHandle}, events::DaemonEvent, history::{ diff --git a/crates/atuin-daemon/src/components/mod.rs b/crates/turtle/src/atuin_daemon/components/mod.rs index 447e31df..447e31df 100644 --- a/crates/atuin-daemon/src/components/mod.rs +++ b/crates/turtle/src/atuin_daemon/components/mod.rs diff --git a/crates/atuin-daemon/src/components/search.rs b/crates/turtle/src/atuin_daemon/components/search.rs index 9fc87fae..85191cff 100644 --- a/crates/atuin-daemon/src/components/search.rs +++ b/crates/turtle/src/atuin_daemon/components/search.rs @@ -5,7 +5,7 @@ use std::{pin::Pin, sync::Arc}; -use atuin_client::database::Database; +use crate::atuin_client::database::Database; use eyre::Result; use tokio::sync::RwLock; use tokio_stream::Stream; @@ -13,7 +13,7 @@ use tonic::{Request, Response, Status, Streaming}; use tracing::{Level, debug, info, instrument, span, trace}; use uuid::Uuid; -use crate::{ +use crate::atuin_daemon::{ daemon::{Component, DaemonHandle}, events::DaemonEvent, search::{ @@ -368,7 +368,7 @@ impl SearchSvc for SearchGrpcService { /// Convert proto FilterMode and context to IndexFilterMode. fn convert_filter_mode( mode: FilterMode, - context: &Option<crate::search::SearchContext>, + context: &Option<crate::atuin_daemon::search::SearchContext>, ) -> IndexFilterMode { match (mode, context) { (FilterMode::Global, _) => IndexFilterMode::Global, diff --git a/crates/atuin-daemon/src/components/semantic.rs b/crates/turtle/src/atuin_daemon/components/semantic.rs index dff38fd3..a42fd5cb 100644 --- a/crates/atuin-daemon/src/components/semantic.rs +++ b/crates/turtle/src/atuin_daemon/components/semantic.rs @@ -8,13 +8,13 @@ use std::collections::{HashMap, VecDeque}; use std::fmt::{Display, Formatter}; use std::sync::Arc; -use atuin_client::history::{History, HistoryId}; +use crate::atuin_client::history::{History, HistoryId}; use eyre::Result; use tokio::sync::Mutex; use tonic::{Request, Response, Status, Streaming}; use tracing::{Level, instrument}; -use crate::{ +use crate::atuin_daemon::{ daemon::{Component, DaemonHandle}, events::DaemonEvent, semantic::{ @@ -244,7 +244,7 @@ impl SemanticState { fn command_output_for_ref( &self, capture_ref: &CaptureRef, - ranges: &[crate::semantic::OutputRange], + ranges: &[crate::atuin_daemon::semantic::OutputRange], ) -> Option<CommandOutputReply> { let stored = self .sessions @@ -534,14 +534,17 @@ fn command_output_not_found() -> CommandOutputReply { } } -fn select_output_ranges(output: &str, ranges: &[crate::semantic::OutputRange]) -> Vec<OutputLine> { +fn select_output_ranges( + output: &str, + ranges: &[crate::atuin_daemon::semantic::OutputRange], +) -> Vec<OutputLine> { let lines: Vec<&str> = output.lines().collect(); if lines.is_empty() { return Vec::new(); } let ranges = if ranges.is_empty() { - vec![crate::semantic::OutputRange { start: 0, end: 999 }] + vec![crate::atuin_daemon::semantic::OutputRange { start: 0, end: 999 }] } else { ranges.to_vec() }; @@ -816,8 +819,8 @@ mod tests { fn output_ranges_are_line_based_inclusive_and_support_negative_offsets() { let output = "zero\none\ntwo\nthree\nfour"; let ranges = vec![ - crate::semantic::OutputRange { start: 1, end: 2 }, - crate::semantic::OutputRange { start: -2, end: -1 }, + crate::atuin_daemon::semantic::OutputRange { start: 1, end: 2 }, + crate::atuin_daemon::semantic::OutputRange { start: -2, end: -1 }, ]; assert_eq!( @@ -838,8 +841,8 @@ mod tests { .collect::<Vec<_>>() .join("\n"); let ranges = vec![ - crate::semantic::OutputRange { start: 0, end: 100 }, - crate::semantic::OutputRange { + crate::atuin_daemon::semantic::OutputRange { start: 0, end: 100 }, + crate::atuin_daemon::semantic::OutputRange { start: -100, end: -1, }, @@ -856,8 +859,8 @@ mod tests { fn output_ranges_can_leave_gaps_for_client_formatting() { let output = "zero\none\ntwo\nthree\nfour"; let ranges = vec![ - crate::semantic::OutputRange { start: 0, end: 1 }, - crate::semantic::OutputRange { start: 4, end: 4 }, + crate::atuin_daemon::semantic::OutputRange { start: 0, end: 1 }, + crate::atuin_daemon::semantic::OutputRange { start: 4, end: 4 }, ]; assert_eq!( @@ -888,8 +891,8 @@ mod tests { fn output_ranges_skip_ranges_fully_outside_output() { let output = "zero\none\ntwo"; let ranges = vec