Start implementing server

Cargo.lock

@@ -135,6 +135,7 @@ version = "14.0.1"
 dependencies = [
  "async-trait",
  "atuin-common",
+ "axum",
  "base64 0.21.0",
  "chrono",
  "clap",

atuin-client/Cargo.toml

@@ -64,5 +64,8 @@ semver = { workspace = true }
 xsalsa20poly1305 = { version = "0.9.0", optional = true }
 generic-array = { version = "0.14", optional = true, features = ["serde"] }
 
+# daemon
+axum = "0.6.4"
+
 [dev-dependencies]
 tokio = { version = "1", features = ["full"] }

atuin-client/src/daemon/handlers/mod.rs

@@ -0,0 +1,8 @@
+
+const VERSION: &str = env!("CARGO_PKG_VERSION");
+
+pub async fn index() -> Json<IndexResponse> {
+    Json(IndexResponse {
+        version: VERSION.to_string(),
+    })
+}

atuin-client/src/daemon/mod.rs

@@ -0,0 +1 @@
+pub mod router;

atuin-client/src/daemon/router.rs

@@ -0,0 +1,44 @@
+use std::net::{IpAddr, SocketAddr};
+
+use axum::{
+    response::IntoResponse,
+    routing::{get},
+    Router,
+    Server,
+};
+use eyre::{Result};
+
+use crate::settings::Settings;
+
+async fn teapot() -> impl IntoResponse {
+    (http::StatusCode::IM_A_TEAPOT, "☕")
+}
+
+fn router(
+    settings: Settings,
+) -> Router {
+    let routes = Router::new()
+        .route("/", get(handlers::index));
+
+    let path = settings.path.as_str();
+    if path.is_empty() {
+        routes
+    } else {
+        Router::new().nest(path, routes)
+    }
+    .fallback(teapot)
+    .with_state(AppState { database, settings })
+    .layer(ServiceBuilder::new().layer(TraceLayer::new_for_http()))
+}
+
+pub async fn listen(settings: Settings, host: String, port: u16) -> Result<()> {
+    let host = host.parse::<IpAddr>()?;
+
+    let r = router(settings);
+
+    Server::bind(&SocketAddr::new(host, port))
+        .serve(r.into_make_service())
+        .await?;
+
+    Ok(())
+}

atuin-client/src/lib.rs

@@ -10,6 +10,7 @@ pub mod encryption;
 #[cfg(feature = "sync")]
 pub mod sync;
 
+pub mod daemon;
 pub mod database;
 pub mod history;
 pub mod import;

atuin/src/command/client/daemon.rs

@@ -6,7 +6,7 @@ use tracing_subscriber::FmtSubscriber;
 
 use daemonize::Daemonize;
 
-use atuin_client::settings::Settings;
+use atuin_client::{daemon, settings::Settings};
 use tracing::{error, info, Level};
 
 pub fn start(settings: Settings) -> Result<()> {