New Json Architecture

Cargo.toml

@@ -13,27 +13,21 @@ my-http-server = { tag = "0.7.0", git = "https://github.com/MyJetTools/my-http-s
     "static-files",
 ] }
 
-my-no-sql-sdk = { branch = "main", git = "https://github.com/MyJetTools/my-no-sql-sdk.git", features = [
+my-no-sql-sdk = { tag = "0.3.1", git = "https://github.com/MyJetTools/my-no-sql-sdk.git", features = [
     "master-node",
     "tcp-contracts",
 ] }
 
-my-no-sql-server-core = { branch = "main", git = "https://github.com/MyJetTools/my-no-sql-server-core.git", features = [
+my-no-sql-server-core = { tag = "0.3.2", git = "https://github.com/MyJetTools/my-no-sql-server-core.git", features = [
     "master-node",
 ] }
 
 my-azure-storage-sdk = { tag = "0.5.0", git = "https://github.com/MyJetTools/my-azure-storage.git" }
 flurl = { tag = "0.5.0", git = "https://github.com/MyJetTools/fl-url" }
 
-rust-extensions = { tag = "0.1.4", git = "https://github.com/MyJetTools/rust-extensions.git", features = [
-    "with-tokio",
-    "base64",
-] }
-
 my-logger = { tag = "1.1.0", git = "https://github.com/MyJetTools/my-logger.git" }
-my-json = { tag = "0.2.2", git = "https://github.com/MyJetTools/my-json.git" }
 
-my-tcp-sockets = { branch = "main", git = "https://github.com/MyJetTools/my-tcp-sockets.git" }
+my-tcp-sockets = { tag = "0.1.9", git = "https://github.com/MyJetTools/my-tcp-sockets.git" }
 
 hyper-tls = "*"
 tonic = { version = "*", features = ["tls", "tls-roots", "prost"] }

src/app/app_ctx.rs

@@ -3,8 +3,8 @@ use std::{
     time::Duration,
 };
 
+use my_no_sql_sdk::core::rust_extensions::{date_time::DateTimeAsMicroseconds, AppStates};
 use my_no_sql_server_core::DbInstance;
-use rust_extensions::{date_time::DateTimeAsMicroseconds, AppStates};
 
 use crate::{
     data_readers::DataReadersList,

src/app/events_sync.rs

@@ -1,6 +1,6 @@
 use std::sync::Arc;
 
-use rust_extensions::{
+use my_no_sql_sdk::core::rust_extensions::{
     events_loop::{EventsLoop, EventsLoopPublisher, EventsLoopTick},
     ApplicationStates,
 };

src/background/backup_timer.rs

@@ -1,6 +1,6 @@
 use std::sync::Arc;
 
-use rust_extensions::MyTimerTick;
+use my_no_sql_sdk::core::rust_extensions::MyTimerTick;
 
 use crate::app::AppContext;
 

src/background/gc_db_rows.rs

@@ -1,7 +1,7 @@
 use std::{collections::HashMap, sync::Arc};
 
 use my_logger::LogEventCtx;
-use rust_extensions::{date_time::DateTimeAsMicroseconds, MyTimerTick};
+use my_no_sql_sdk::core::rust_extensions::{date_time::DateTimeAsMicroseconds, MyTimerTick};
 
 use crate::{app::AppContext, db_sync::EventSource};
 

src/background/gc_http_sessions.rs

@@ -1,6 +1,6 @@
 use std::sync::Arc;
 
-use rust_extensions::{date_time::DateTimeAsMicroseconds, MyTimerTick};
+use my_no_sql_sdk::core::rust_extensions::{date_time::DateTimeAsMicroseconds, MyTimerTick};
 
 use crate::app::AppContext;
 

src/background/gc_multipart.rs

@@ -1,6 +1,6 @@
 use std::{sync::Arc, time::Duration};
 
-use rust_extensions::{date_time::DateTimeAsMicroseconds, MyTimerTick};
+use my_no_sql_sdk::core::rust_extensions::{date_time::DateTimeAsMicroseconds, MyTimerTick};
 
 use crate::app::AppContext;
 

src/background/metrics_updater.rs

@@ -1,8 +1,8 @@
 use std::sync::Arc;
 
 use my_http_server::HttpConnectionsCounter;
+use my_no_sql_sdk::core::rust_extensions::MyTimerTick;
 use my_tcp_sockets::ThreadsStatistics;
-use rust_extensions::MyTimerTick;
 
 use crate::app::AppContext;
 

src/background/persist.rs

@@ -1,6 +1,6 @@
 use std::sync::Arc;
 
-use rust_extensions::MyTimerTick;
+use my_no_sql_sdk::core::rust_extensions::MyTimerTick;
 
 use crate::app::AppContext;
 

src/background/sync.rs

@@ -1,5 +1,5 @@
 use crate::{app::AppContext, db_sync::SyncEvent};
-use rust_extensions::events_loop::EventsLoopTick;
+use my_no_sql_sdk::core::rust_extensions::events_loop::EventsLoopTick;
 use std::sync::Arc;
 
 pub struct SyncEventLoop {

src/data_readers/data_reader.rs

@@ -3,8 +3,8 @@ use std::sync::{
     Arc,
 };
 
+use my_no_sql_sdk::core::rust_extensions::date_time::DateTimeAsMicroseconds;
 use my_no_sql_server_core::DbTableWrapper;
-use rust_extensions::date_time::DateTimeAsMicroseconds;
 use tokio::sync::RwLock;
 
 use super::{DataReaderConnection, DataReaderUpdatableData};

src/data_readers/data_readers_data.rs

@@ -1,6 +1,6 @@
 use std::{collections::BTreeMap, sync::Arc, time::Duration};
 
-use rust_extensions::date_time::DateTimeAsMicroseconds;
+use my_no_sql_sdk::core::rust_extensions::date_time::DateTimeAsMicroseconds;
 
 use super::{DataReader, DataReaderConnection};
 

src/data_readers/data_readers_list.rs

@@ -1,6 +1,6 @@
 use std::{sync::Arc, time::Duration};
 
-use rust_extensions::date_time::DateTimeAsMicroseconds;
+use my_no_sql_sdk::core::rust_extensions::date_time::DateTimeAsMicroseconds;
 use tokio::sync::RwLock;
 
 use crate::tcp::MyNoSqlTcpConnection;

src/data_readers/http_connection/connection_delivery_info.rs

@@ -1,7 +1,9 @@
 use std::{collections::VecDeque, time::Duration};
 
 use my_http_server::HttpFailResult;
-use rust_extensions::{date_time::DateTimeAsMicroseconds, TaskCompletion, TaskCompletionAwaiter};
+use my_no_sql_sdk::core::rust_extensions::{
+    date_time::DateTimeAsMicroseconds, TaskCompletion, TaskCompletionAwaiter,
+};
 
 pub enum HttpPayload {
     Ping,

src/data_readers/http_connection/http_connection_info.rs

@@ -1,7 +1,9 @@
 use std::sync::atomic::AtomicUsize;
 
 use my_http_server::HttpFailResult;
-use rust_extensions::date_time::{AtomicDateTimeAsMicroseconds, DateTimeAsMicroseconds};
+use my_no_sql_sdk::core::rust_extensions::date_time::{
+    AtomicDateTimeAsMicroseconds, DateTimeAsMicroseconds,
+};
 use tokio::sync::Mutex;
 
 use crate::{

src/data_readers/http_connection/into_http_payload.rs

@@ -1,4 +1,4 @@
-use my_json::json_writer::{JsonArrayWriter, JsonObjectWriter};
+use my_no_sql_sdk::core::my_json::json_writer::{JsonArrayWriter, JsonObjectWriter};
 
 use crate::db_sync::{
     states::{DeleteRowsEventSyncData, InitPartitionsSyncEventData, UpdateRowsSyncData},

src/data_readers/tcp_connection/tcp_payload_to_send.rs

@@ -1,7 +1,7 @@
 use my_no_sql_sdk::tcp_contracts::{DeleteRowTcpContract, MyNoSqlTcpContract};
 
 use crate::db_sync::SyncEvent;
-use my_json::json_reader::consts::EMPTY_ARRAY;
+use my_no_sql_sdk::core::my_json::json_reader::consts::EMPTY_ARRAY;
 
 pub async fn serialize(sync_event: &SyncEvent, compress: bool) -> Vec<MyNoSqlTcpContract> {
     match sync_event {

src/db_operations/gc/keep_max_partitions_amount.rs

@@ -1,7 +1,7 @@
 use std::sync::Arc;
 
+use my_no_sql_sdk::core::rust_extensions::date_time::DateTimeAsMicroseconds;
 use my_no_sql_server_core::DbTableWrapper;
-use rust_extensions::date_time::DateTimeAsMicroseconds;
 
 use crate::{app::AppContext, db_operations::DbOperationError, db_sync::EventSource};
 

src/db_operations/gc/keep_partition_max_records.rs

@@ -1,6 +1,6 @@
 use my_no_sql_sdk::core::db::PartitionKeyParameter;
+use my_no_sql_sdk::core::rust_extensions::date_time::DateTimeAsMicroseconds;
 use my_no_sql_server_core::DbTableWrapper;
-use rust_extensions::date_time::DateTimeAsMicroseconds;
 
 use crate::{app::AppContext, db_operations::DbOperationError, db_sync::EventSource};
 

src/db_operations/multipart/multipart.rs

@@ -1,7 +1,7 @@
 use std::{collections::VecDeque, sync::Arc};
 
 use my_no_sql_sdk::core::db::DbRow;
-use rust_extensions::date_time::DateTimeAsMicroseconds;
+use my_no_sql_sdk::core::rust_extensions::date_time::DateTimeAsMicroseconds;
 
 pub struct Multipart {
     pub created: DateTimeAsMicroseconds,

src/db_operations/multipart/multipart_list.rs

@@ -5,8 +5,8 @@ use std::{
 };
 
 use my_no_sql_sdk::core::db::DbRow;
+use my_no_sql_sdk::core::rust_extensions::date_time::DateTimeAsMicroseconds;
 use my_no_sql_server_core::db_snapshots::DbRowsSnapshot;
-use rust_extensions::date_time::DateTimeAsMicroseconds;
 use tokio::sync::Mutex;
 
 use super::Multipart;

src/db_operations/read/get_highest_row_and_below.rs

@@ -1,8 +1,8 @@
 use std::sync::Arc;
 
-use my_json::json_writer::JsonArrayWriter;
+use my_no_sql_sdk::core::my_json::json_writer::JsonArrayWriter;
+use my_no_sql_sdk::core::rust_extensions::date_time::DateTimeAsMicroseconds;
 use my_no_sql_server_core::DbTableWrapper;
-use rust_extensions::date_time::DateTimeAsMicroseconds;
 
 use crate::{
     app::AppContext,

src/db_operations/read/read_filter.rs

@@ -1,8 +1,8 @@
 use std::sync::Arc;
 
-use my_json::json_writer::JsonArrayWriter;
 use my_no_sql_sdk::core::db::DbRow;
-use rust_extensions::date_time::DateTimeAsMicroseconds;
+use my_no_sql_sdk::core::my_json::json_writer::JsonArrayWriter;
+use my_no_sql_sdk::core::rust_extensions::date_time::DateTimeAsMicroseconds;
 
 pub fn filter_and_compile_json<'s>(
     iterator: impl Iterator<Item = &'s Arc<DbRow>>,

src/db_operations/read/rows/get_all.rs

@@ -1,8 +1,8 @@
 use std::sync::Arc;
 
-use my_json::json_writer::JsonArrayWriter;
+use my_no_sql_sdk::core::my_json::json_writer::JsonArrayWriter;
+use my_no_sql_sdk::core::rust_extensions::date_time::DateTimeAsMicroseconds;
 use my_no_sql_server_core::DbTableWrapper;
-use rust_extensions::date_time::DateTimeAsMicroseconds;
 
 use crate::{
     app::AppContext,

src/db_operations/read/rows/get_all_by_partition_key.rs

@@ -1,7 +1,7 @@
 use std::sync::Arc;
 
+use my_no_sql_sdk::core::rust_extensions::date_time::DateTimeAsMicroseconds;
 use my_no_sql_server_core::DbTableWrapper;
-use rust_extensions::date_time::DateTimeAsMicroseconds;
 
 use crate::{
     app::AppContext,

src/db_operations/read/rows/get_all_by_row_key.rs

@@ -1,8 +1,8 @@
 use std::sync::Arc;
 
-use my_json::json_writer::JsonArrayWriter;
+use my_no_sql_sdk::core::my_json::json_writer::JsonArrayWriter;
+use my_no_sql_sdk::core::rust_extensions::date_time::DateTimeAsMicroseconds;
 use my_no_sql_server_core::DbTableWrapper;
-use rust_extensions::date_time::DateTimeAsMicroseconds;
 
 use crate::{
     app::AppContext,

src/db_operations/read/rows/get_single.rs

@@ -1,7 +1,7 @@
 use std::sync::Arc;
 
+use my_no_sql_sdk::core::rust_extensions::date_time::DateTimeAsMicroseconds;
 use my_no_sql_server_core::DbTableWrapper;
-use rust_extensions::date_time::DateTimeAsMicroseconds;
 
 use crate::{
     app::AppContext,

src/db_operations/read/rows/get_single_partition_multiple_rows.rs

@@ -1,8 +1,8 @@
 use std::sync::Arc;
 
-use my_json::json_writer::JsonArrayWriter;
+use my_no_sql_sdk::core::my_json::json_writer::JsonArrayWriter;
+use my_no_sql_sdk::core::rust_extensions::date_time::DateTimeAsMicroseconds;
 use my_no_sql_server_core::DbTableWrapper;
-use rust_extensions::date_time::DateTimeAsMicroseconds;
 
 use crate::{
     app::AppContext,

src/db_operations/transactions/commit.rs

@@ -1,6 +1,6 @@
 use std::collections::HashMap;
 
-use rust_extensions::date_time::DateTimeAsMicroseconds;
+use my_no_sql_sdk::core::rust_extensions::date_time::DateTimeAsMicroseconds;
 
 use crate::{
     app::AppContext, db_sync::EventSource, db_transactions::steps::TransactionalOperationStep,

src/db_operations/update_statistics/update_partition_expiration_time.rs

@@ -1,7 +1,7 @@
 use std::sync::Arc;
 
+use my_no_sql_sdk::core::rust_extensions::date_time::DateTimeAsMicroseconds;
 use my_no_sql_server_core::DbTableWrapper;
-use rust_extensions::date_time::DateTimeAsMicroseconds;
 
 use crate::app::AppContext;
 

src/db_operations/update_statistics/update_partitions_last_read_time.rs

@@ -1,5 +1,5 @@
+use my_no_sql_sdk::core::rust_extensions::date_time::DateTimeAsMicroseconds;
 use my_no_sql_server_core::DbTableWrapper;
-use rust_extensions::date_time::DateTimeAsMicroseconds;
 
 pub async fn update_partitions_last_read_time<'s, TPartitions: Iterator<Item = &'s str>>(
     table: &DbTableWrapper,

src/db_operations/update_statistics/update_rows_expiration_time.rs

@@ -1,7 +1,7 @@
 use std::sync::Arc;
 
+use my_no_sql_sdk::core::rust_extensions::date_time::DateTimeAsMicroseconds;
 use my_no_sql_server_core::DbTableWrapper;
-use rust_extensions::date_time::DateTimeAsMicroseconds;
 
 use crate::app::AppContext;
 

src/db_operations/update_statistics/update_rows_last_read_time.rs

@@ -1,7 +1,7 @@
 use std::sync::Arc;
 
+use my_no_sql_sdk::core::rust_extensions::date_time::DateTimeAsMicroseconds;
 use my_no_sql_server_core::DbTableWrapper;
-use rust_extensions::date_time::DateTimeAsMicroseconds;
 
 pub async fn update_row_keys_last_read_access_time<'s, TRowKeys: Iterator<Item = &'s str>>(
     db_table: &Arc<DbTableWrapper>,

src/db_operations/update_statistics/update_statistics.rs

@@ -1,7 +1,7 @@
 use std::sync::Arc;
 
 use my_no_sql_sdk::core::db::{DbPartition, DbRow};
-use rust_extensions::date_time::DateTimeAsMicroseconds;
+use my_no_sql_sdk::core::rust_extensions::date_time::DateTimeAsMicroseconds;
 
 #[derive(Clone, Debug)]
 pub struct UpdateStatistics {

src/db_operations/write/bulk_delete.rs

@@ -1,6 +1,6 @@
 use my_no_sql_sdk::core::db::{PartitionKeyParameter, RowKeyParameter};
+use my_no_sql_sdk::core::rust_extensions::date_time::DateTimeAsMicroseconds;
 use my_no_sql_server_core::DbTableWrapper;
-use rust_extensions::date_time::DateTimeAsMicroseconds;
 
 use crate::{
     app::AppContext,

src/db_operations/write/bulk_insert_or_update.rs

@@ -1,8 +1,8 @@
 use std::sync::Arc;
 
 use my_no_sql_sdk::core::db::{DbRow, PartitionKeyParameter};
+use my_no_sql_sdk::core::rust_extensions::date_time::DateTimeAsMicroseconds;
 use my_no_sql_server_core::DbTableWrapper;
-use rust_extensions::date_time::DateTimeAsMicroseconds;
 
 use crate::{
     app::AppContext,

src/db_operations/write/clean_partition_and_bulk_insert.rs

@@ -1,8 +1,8 @@
 use std::sync::Arc;
 
 use my_no_sql_sdk::core::db::DbRow;
+use my_no_sql_sdk::core::rust_extensions::date_time::DateTimeAsMicroseconds;
 use my_no_sql_server_core::DbTableWrapper;
-use rust_extensions::date_time::DateTimeAsMicroseconds;
 
 use crate::{
     app::AppContext,

src/db_operations/write/clean_table.rs

@@ -1,7 +1,7 @@
 use std::sync::Arc;
 
+use my_no_sql_sdk::core::rust_extensions::date_time::DateTimeAsMicroseconds;
 use my_no_sql_server_core::DbTableWrapper;
-use rust_extensions::date_time::DateTimeAsMicroseconds;
 
 use crate::{
     app::AppContext,

src/db_operations/write/clean_table_and_bulk_insert.rs

@@ -1,8 +1,8 @@
 use std::sync::Arc;
 
 use my_no_sql_sdk::core::db::DbRow;
+use my_no_sql_sdk::core::rust_extensions::date_time::DateTimeAsMicroseconds;
 use my_no_sql_server_core::DbTableWrapper;
-use rust_extensions::date_time::DateTimeAsMicroseconds;
 
 use crate::{
     app::AppContext,

src/db_operations/write/delete_partitions.rs

@@ -1,8 +1,8 @@
 use std::sync::Arc;
 
 use my_no_sql_sdk::core::db::PartitionKeyParameter;
+use my_no_sql_sdk::core::rust_extensions::date_time::DateTimeAsMicroseconds;
 use my_no_sql_server_core::DbTableWrapper;
-use rust_extensions::date_time::DateTimeAsMicroseconds;
 
 use crate::{
     app::AppContext,

src/db_operations/write/delete_row.rs

@@ -1,8 +1,8 @@
 use std::sync::Arc;
 
 use my_no_sql_sdk::core::db::{PartitionKeyParameter, RowKeyParameter};
+use my_no_sql_sdk::core::rust_extensions::date_time::DateTimeAsMicroseconds;
 use my_no_sql_server_core::DbTableWrapper;
-use rust_extensions::date_time::DateTimeAsMicroseconds;
 
 use crate::{
     app::AppContext,