http_server name_refactoring

src/db_transactions/json_parser/parser.rs

@@ -3,7 +3,7 @@ use my_no_sql_sdk::core::my_json::json_reader::JsonArrayIterator;
 use crate::{
     db_operations::transactions::TransactionOperationError,
     db_transactions::steps::TransactionalOperationStep,
-    http::controllers::transactions::models::JsonBaseTransaction,
+    http_server::controllers::transactions::models::JsonBaseTransaction,
 };
 
 use super::models::{

src/grpc/writer_grpc.rs

@@ -1,7 +1,7 @@
 use super::server::MyNoSqlServerWriterGrpcSerice;
 use crate::db_operations::UpdateStatistics;
 use crate::db_sync::EventSource;
-use crate::http::controllers::ToSetExpirationTime;
+use crate::http_server::controllers::ToSetExpirationTime;
 use crate::mynosqlserver_grpc::writer_server::Writer;
 use crate::mynosqlserver_grpc::*;
 use futures_core::Stream;

src/http/controllers/bulk/models.rs → src/http_server/controllers/bulk/models.rs

@@ -5,7 +5,7 @@ use my_http_server::types::RawDataTyped;
 
 use crate::{
     db_sync::DataSynchronizationPeriod,
-    http::controllers::row_controller::models::BaseDbRowContract,
+    http_server::controllers::row_controller::models::BaseDbRowContract,
 };
 
 #[derive(MyHttpInput)]

src/http/controllers/data_reader_controller/get_changes_action.rs → src/http_server/controllers/data_reader_controller/get_changes_action.rs

@@ -6,7 +6,7 @@ use crate::{
     app::AppContext,
     data_readers::{http_connection::HttpPayload, DataReaderConnection},
     db_operations::DbOperationError,
-    http::{controllers::mappers::ToSetExpirationTime, http_sessions::HttpSessionsSupport},
+    http_server::{controllers::mappers::ToSetExpirationTime, http_sessions::HttpSessionsSupport},
 };
 
 use super::models::{GetChangesInputModel, UpdateExpirationDateTime};

src/http/controllers/data_reader_controller/models.rs → src/http_server/controllers/data_reader_controller/models.rs

@@ -2,7 +2,7 @@ use my_http_server::macros::*;
 use my_http_server::types::RawDataTyped;
 use serde::{Deserialize, Serialize};
 
-use crate::http::controllers::row_controller::models::BaseDbRowContract;
+use crate::http_server::controllers::row_controller::models::BaseDbRowContract;
 
 #[derive(MyHttpInput)]
 pub struct DataReaderGreetingInputModel {

src/http/controllers/data_reader_controller/ping_action.rs → src/http_server/controllers/data_reader_controller/ping_action.rs

@@ -2,7 +2,7 @@ use my_http_server::macros::*;
 use my_http_server::{HttpContext, HttpFailResult, HttpOkResult, HttpOutput};
 use std::sync::Arc;
 
-use crate::{app::AppContext, http::http_sessions::HttpSessionsSupport};
+use crate::{app::AppContext, http_server::http_sessions::HttpSessionsSupport};
 
 use super::models::PingInputModel;
 

src/http/controllers/data_reader_controller/subscribe_action.rs → src/http_server/controllers/data_reader_controller/subscribe_action.rs

@@ -1,4 +1,4 @@
-use crate::{app::AppContext, http::http_sessions::*};
+use crate::{app::AppContext, http_server::http_sessions::*};
 use my_http_server::macros::*;
 use my_http_server::{HttpContext, HttpFailResult, HttpOkResult, HttpOutput};
 use std::sync::Arc;

src/http/controllers/multipart/next.rs → src/http_server/controllers/multipart/next.rs

@@ -2,7 +2,7 @@ use my_http_server::macros::*;
 use my_http_server::{HttpContext, HttpFailResult, HttpOkResult};
 use std::sync::Arc;
 
-use crate::{app::AppContext, http::controllers::row_controller::models::BaseDbRowContract};
+use crate::{app::AppContext, http_server::controllers::row_controller::models::BaseDbRowContract};
 
 use super::models::NextMultipartRequestInputContract;
 

src/http/controllers/row_controller/models.rs → src/http_server/controllers/row_controller/models.rs

@@ -5,7 +5,7 @@ use serde::{Deserialize, Serialize};
 
 use crate::{
     db_operations::UpdateStatistics, db_sync::DataSynchronizationPeriod,
-    http::controllers::mappers::ToSetExpirationTime,
+    http_server::controllers::mappers::ToSetExpirationTime,
 };
 
 #[derive(MyHttpInput)]

src/http/controllers/rows_controller/get_highest_row_and_below.rs → src/http_server/controllers/rows_controller/get_highest_row_and_below.rs

@@ -3,7 +3,7 @@ use my_http_server::{HttpContext, HttpFailResult, HttpOkResult};
 use my_no_sql_sdk::core::rust_extensions::date_time::DateTimeAsMicroseconds;
 use std::sync::Arc;
 
-use crate::{app::AppContext, http::controllers::row_controller::models::BaseDbRowContract};
+use crate::{app::AppContext, http_server::controllers::row_controller::models::BaseDbRowContract};
 
 use super::models::GetHighestRowsAndBelowInputContract;
 

src/http/controllers/rows_controller/get_single_partition_multiple_rows.rs → src/http_server/controllers/rows_controller/get_single_partition_multiple_rows.rs

@@ -3,7 +3,7 @@ use my_http_server::{HttpContext, HttpFailResult, HttpOkResult};
 use my_no_sql_sdk::core::rust_extensions::date_time::DateTimeAsMicroseconds;
 use std::sync::Arc;
 
-use crate::{app::AppContext, http::controllers::row_controller::models::BaseDbRowContract};
+use crate::{app::AppContext, http_server::controllers::row_controller::models::BaseDbRowContract};
 
 use super::models::GetSinglePartitionMultipleRowsActionInputContract;
 

src/http/controllers/rows_controller/models.rs → src/http_server/controllers/rows_controller/models.rs

@@ -4,7 +4,7 @@ use serde::{Deserialize, Serialize};
 
 use crate::{
     db_operations::UpdateStatistics, db_sync::DataSynchronizationPeriod,
-    http::controllers::mappers::ToSetExpirationTime,
+    http_server::controllers::mappers::ToSetExpirationTime,
 };
 #[derive(MyHttpInput)]
 pub struct GetHighestRowsAndBelowInputContract {

src/http/controllers/tables_controller/get_partitions_count_action.rs → src/http_server/controllers/tables_controller/get_partitions_count_action.rs

@@ -1,4 +1,4 @@
-use crate::{app::AppContext, http::controllers::partitions::GetPartitionsAmountContract};
+use crate::{app::AppContext, http_server::controllers::partitions::GetPartitionsAmountContract};
 use my_http_server::macros::*;
 use my_http_server::{HttpContext, HttpFailResult, HttpOkResult, HttpOutput};
 use std::{result::Result, sync::Arc};

src/http/controllers/tables_controller/migration_action.rs → src/http_server/controllers/tables_controller/migration_action.rs

@@ -4,7 +4,7 @@ use my_http_server::{HttpContext, HttpFailResult, HttpOkResult, HttpOutput, WebC
 use my_no_sql_sdk::core::db_json_entity::JsonTimeStamp;
 use std::sync::Arc;
 
-use crate::{app::AppContext, db_sync::EventSource, http::contracts::input_params};
+use crate::{app::AppContext, db_sync::EventSource, http_server::contracts::input_params};
 
 use super::models::TableMigrationInputContract;
 

src/http/get_table.rs → src/http_server/get_table.rs

@@ -1,6 +1,6 @@
 use my_http_server::{HttpFailResult, WebContentType};
 
-use crate::http::mappers::db_operation_error::OPERATION_FAIL_HTTP_STATUS_CODE;
+use crate::http_server::mappers::db_operation_error::OPERATION_FAIL_HTTP_STATUS_CODE;
 
 use super::mappers::{OperationFailHttpContract, OperationFailReason};
 

src/http/start_up.rs → src/http_server/start_up.rs

@@ -8,7 +8,7 @@ use crate::app::AppContext;
 pub fn setup_server(app: &Arc<AppContext>) -> HttpConnectionsCounter {
     let mut http_server = MyHttpServer::new(SocketAddr::from(([0, 0, 0, 0], 5123)));
 
-    let controllers = Arc::new(crate::http::controllers::builder::build(app));
+    let controllers = Arc::new(crate::http_server::controllers::builder::build(app));
 
     let swagger_middleware = SwaggerMiddleware::new(
         controllers.clone(),

src/main.rs

@@ -19,7 +19,7 @@ mod sqlite_repo;
 mod db_operations;
 mod db_sync;
 mod db_transactions;
-mod http;
+mod http_server;
 mod scripts;
 mod tcp;
 
@@ -49,7 +49,7 @@ async fn main() {
 
     tokio::spawn(crate::operations::init::load_tables(app.clone()));
 
-    let http_connections_counter = crate::http::start_up::setup_server(&app);
+    let http_connections_counter = crate::http_server::start_up::setup_server(&app);
 
     app.sync
         .register_event_loop(Arc::new(SyncEventLoop::new(app.clone())))

src/operations/backup/restore.rs

@@ -73,7 +73,6 @@ pub async fn restore(
             }
         }
     }
-
     Ok(())
 }