Aditya/base routes

src/config/mod.rs

@@ -1 +1 @@
-pub mod parameters;
+pub mod parameters;

src/handlers/mod.rs

@@ -1,2 +1,2 @@
 pub mod namespace_handler;
-pub mod table_handler;
+pub mod table_handler;

src/handlers/namespace_handler.rs

@@ -4,17 +4,16 @@ use axum::{
     response::IntoResponse,
 };
 
-
-
 #[derive(Debug, serde::Serialize, serde::Deserialize)]
-pub struct Namespace {
-
-}
-
+pub struct Namespace {}
 
 pub async fn list_namespaces() -> Json<Vec<String>> {
     // Logic to list namespaces
-    let namespaces: Vec<String> = vec!["accounting".to_string(), "tax".to_string(), "paid".to_string()];
+    let namespaces: Vec<String> = vec![
+        "accounting".to_string(),
+        "tax".to_string(),
+        "paid".to_string(),
+    ];
     Json(namespaces)
 }
 
@@ -69,6 +68,6 @@ pub async fn set_namespace_properties(Path(namespace): Path<String>) -> Json<Nam
     let prop = NamespaceProperties {
         data: "namespace properties".to_string(),
     };
-    
+
     Json(prop)
 }

src/handlers/table_handler.rs

@@ -4,12 +4,14 @@ use axum::{
     response::IntoResponse,
 };
 
-
 pub async fn list_tables(Path(namespace): Path<String>) -> Json<Vec<String>> {
     // Dummy response for demonstration
-    let tables: Vec<String> = vec!["accounting".to_string(), "tax".to_string(), "paid".to_string()];
+    let tables: Vec<String> = vec![
+        "accounting".to_string(),
+        "tax".to_string(),
+        "paid".to_string(),
+    ];
     Json(tables)
-
 }
 
 pub async fn create_table(Path(namespace): Path<String>) -> impl IntoResponse {
@@ -34,13 +36,11 @@ pub async fn delete_table(Path((namespace, table)): Path<(String, String)>) -> i
 
 pub async fn table_exists(Path((namespace, table)): Path<(String, String)>) -> impl IntoResponse {
     // Logic to check if a table exists within a given namespace
-    StatusCode::OK 
+    StatusCode::OK
 }
 
 #[derive(Debug, serde::Serialize, serde::Deserialize)]
-pub struct MetricsReport {
-
-}
+pub struct MetricsReport {}
 
 // Handler functions
 pub async fn rename_table(table_rename: String) -> impl IntoResponse {
@@ -53,7 +53,12 @@ pub async fn report_metrics(Path((namespace, table)): Path<(String, String)>) ->
     Json(table)
 }
 
-pub async fn find_tuple_location(Path((namespace, table, tuple_id)): Path<(String, String, String)>) -> impl IntoResponse {
+pub async fn find_tuple_location(
+    Path((namespace, table, tuple_id)): Path<(String, String, String)>,
+) -> impl IntoResponse {
     // Logic to return the physical file location for a given tuple ID
-    format!("Physical file location for tuple ID {} of table {} in namespace {}.", tuple_id, table, namespace)
+    format!(
+        "Physical file location for tuple ID {} of table {} in namespace {}.",
+        tuple_id, table, namespace
+    )
 }

src/main.rs

@@ -1,7 +1,7 @@
-mod routes;
+mod config;
 mod dto;
 mod handlers;
-mod config;
+mod routes;
 mod tests;
 
 use crate::config::parameters;

src/routes/mod.rs

@@ -1,3 +1,3 @@
 pub mod namespace;
+pub mod root;
 pub mod table;
-pub mod root;

src/routes/namespace.rs

@@ -1,13 +1,28 @@
-use axum::{ routing::{get, post, head, delete}, Router};
 use crate::handlers::namespace_handler;
+use axum::{
+    routing::{delete, get, head, post},
+    Router,
+};
 
-pub fn routes() -> Router<> {
+pub fn routes() -> Router {
     let router = Router::new()
         .route("/namespaces", get(namespace_handler::list_namespaces))
         .route("/namespaces", post(namespace_handler::create_namespace))
-        .route("/namespace/:namespace", get(namespace_handler::load_namespace_metadata))
-        .route("/namespace/:namespace", head(namespace_handler::namespace_exists))
-        .route("/namespace/:namespace", delete(namespace_handler::drop_namespace))
-        .route("/namespace/:namespace/properties", post(namespace_handler::set_namespace_properties));
+        .route(
+            "/namespace/:namespace",
+            get(namespace_handler::load_namespace_metadata),
+        )
+        .route(
+            "/namespace/:namespace",
+            head(namespace_handler::namespace_exists),
+        )
+        .route(
+            "/namespace/:namespace",
+            delete(namespace_handler::drop_namespace),
+        )
+        .route(
+            "/namespace/:namespace/properties",
+            post(namespace_handler::set_namespace_properties),
+        );
     return router;
 }

src/routes/root.rs

@@ -4,11 +4,10 @@ use axum::Router;
 use tower_http::trace::TraceLayer;
 
 pub fn routes() -> Router {
-
     // merge the 2 routes
     let app_router = Router::new()
-    .nest("/", table::routes())
-    .nest("/", namespace::routes());
+        .nest("/", table::routes())
+        .nest("/", namespace::routes());
 
     app_router
 }

src/routes/table.rs

@@ -1,18 +1,44 @@
-use axum::{ routing::{get, post, head, delete}, Router};
 use crate::handlers::table_handler;
+use axum::{
+    routing::{delete, get, head, post},
+    Router,
+};
 
-
-pub fn routes() -> Router<> {
+pub fn routes() -> Router {
     let router = Router::new()
-        .route("/namespaces/:namespace/tables", get(table_handler::list_tables))
-        .route("/namespaces/:namespace/tables", post(table_handler::create_table))
-        .route("/namespaces/:namespace/register", post(table_handler::register_table))
-        .route("/namespaces/:namespace/tables/:table", get(table_handler::load_table))
-        .route("/namespaces/:namespace/tables/:table", delete(table_handler::delete_table))
-        .route("/namespaces/:namespace/tables/:table", head(table_handler::table_exists))
+        .route(
+            "/namespaces/:namespace/tables",
+            get(table_handler::list_tables),
+        )
+        .route(
+            "/namespaces/:namespace/tables",
+            post(table_handler::create_table),
+        )
+        .route(
+            "/namespaces/:namespace/register",
+            post(table_handler::register_table),
+        )
+        .route(
+            "/namespaces/:namespace/tables/:table",
+            get(table_handler::load_table),
+        )
+        .route(
+            "/namespaces/:namespace/tables/:table",
+            delete(table_handler::delete_table),
+        )
+        .route(
+            "/namespaces/:namespace/tables/:table",
+            head(table_handler::table_exists),
+        )
         .route("/tables/rename", post(table_handler::rename_table))
-        .route("/namespaces/:namespace/tables/:table/metrics", post(table_handler::report_metrics))
-    .route("/namespaces/:namespace/tables/:table/find/:tuple_id", get(table_handler::find_tuple_location));
-
+        .route(
+            "/namespaces/:namespace/tables/:table/metrics",
+            post(table_handler::report_metrics),
+        )
+        .route(
+            "/namespaces/:namespace/tables/:table/find/:tuple_id",
+            get(table_handler::find_tuple_location),
+        );
+
     return router;
 }

src/tests/mod.rs

@@ -0,0 +1 @@
+