instroduce admin shell and client

Author: MarinPostma

Cargo.lock

@@ -95,6 +95,7 @@ tar = "0.4.41"
 aws-config = "1"
 aws-sdk-s3 = "1"
 aws-smithy-runtime = "1.6.2"
+dialoguer = { version = "0.11.0", features = ["history"] }
 
 [dev-dependencies]
 arbitrary = { version = "1.3.0", features = ["derive_arbitrary"] }

libsql-server/Cargo.toml

@@ -0,0 +1,4 @@
+use std::fmt::Display;
+use std::pin::Pin;
+
+use bytes::Bytes;

libsql-server/src/admin_shell.rs

@@ -31,7 +31,6 @@ use crate::net::Connector;
 use crate::LIBSQL_PAGE_SIZE;
 
 pub mod stats;
-mod admin_shell;
 
 #[derive(Clone)]
 struct Metrics {
@@ -169,7 +168,7 @@ where
         .route("/profile/heap/disable/:id", post(disable_profile_heap))
         .route("/profile/heap/:id", delete(delete_profile_heap))
         .with_state(Arc::new(AppState {
-            namespaces,
+            namespaces: namespaces.clone(),
             connector,
             user_http_server,
             metrics,
@@ -185,6 +184,14 @@ where
         )
         .layer(axum::middleware::from_fn_with_state(auth, auth_middleware));
 
+    let admin_shell = crate::admin_shell::make_svc(namespaces.clone());
+    let grpc_router = tonic::transport::Server::builder()
+        .accept_http1(true)
+        .add_service(tonic_web::enable(admin_shell))
+        .into_router();
+
+    let router = router.merge(grpc_router);
+
     hyper::server::Server::builder(acceptor)
         .serve(router.into_make_service())
         .with_graceful_shutdown(shutdown.notified())

libsql-server/src/http/admin/mod.rs

@@ -84,6 +84,7 @@ use self::net::AddrIncoming;
 use self::replication::script_backup_manager::{CommandHandler, ScriptBackupManager};
 use self::schema::SchedulerHandle;
 
+pub mod admin_shell;
 pub mod auth;
 mod broadcaster;
 pub mod config;