Debugging new Architecture infrastructure

MyJetTools · Jan 18, 2024 · 8e015c8 · 8e015c8
1 parent 3f6305c
commit 8e015c8
Show file tree

Hide file tree

Showing 4 changed files with 12 additions and 7 deletions.
diff --git a/my-no-sql-core/Cargo.toml b/my-no-sql-core/Cargo.toml
@@ -4,7 +4,7 @@ version = "0.3.0"
 edition = "2021"
 
 [features]
-default = []
+default = ["master-node"]
 master-node = []
 debug_db_row = []
 

diff --git a/my-no-sql-tcp-reader/Cargo.toml b/my-no-sql-tcp-reader/Cargo.toml
@@ -14,7 +14,7 @@ my-no-sql-abstractions = { path = "../my-no-sql-abstractions" }
 my-no-sql-core = { path = "../my-no-sql-core" }
 
 rust-extensions = { tag = "0.1.4", git = "https://github.com/MyJetTools/rust-extensions.git" }
-my-tcp-sockets = { tag = "0.1.9", git = "https://github.com/MyJetTools/my-tcp-sockets.git" }
+my-tcp-sockets = { branch = "main", git = "https://github.com/MyJetTools/my-tcp-sockets.git" }
 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" }
 

diff --git a/my-no-sql-tcp-shared/Cargo.toml b/my-no-sql-tcp-shared/Cargo.toml
@@ -6,7 +6,7 @@ edition = "2021"
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
 [dependencies]
-my-tcp-sockets = { tag = "0.1.9", git = "https://github.com/MyJetTools/my-tcp-sockets.git" }
+my-tcp-sockets = { branch = "main", git = "https://github.com/MyJetTools/my-tcp-sockets.git" }
 rust-extensions = { tag = "0.1.4", git = "https://github.com/MyJetTools/rust-extensions.git" }
 
 tokio = { version = "*", features = ["full"] }

diff --git a/my-no-sql-tcp-shared/src/tcp_serializer.rs b/my-no-sql-tcp-shared/src/tcp_serializer.rs
@@ -1,6 +1,6 @@
 use my_tcp_sockets::{
     socket_reader::{ReadingTcpContractFail, SocketReader},
-    TcpSerializerMetadata, TcpSerializerMetadataFactory, TcpSocketSerializer, TcpWriteBuffer,
+    TcpSerializerFactory, TcpSerializerState, TcpSocketSerializer, TcpWriteBuffer,
 };
 
 use crate::MyNoSqlTcpContract;
@@ -38,7 +38,7 @@ impl TcpSocketSerializer<MyNoSqlTcpContract, ()> for MyNoSqlReaderTcpSerializer
     }
 }
 
-impl TcpSerializerMetadata<MyNoSqlTcpContract> for () {
+impl TcpSerializerState<MyNoSqlTcpContract> for () {
     fn is_tcp_contract_related_to_metadata(&self, _: &MyNoSqlTcpContract) -> bool {
         false
     }
@@ -48,8 +48,13 @@ impl TcpSerializerMetadata<MyNoSqlTcpContract> for () {
 pub struct MyNoSqlTcpSerializerFactory;
 
 #[async_trait::async_trait]
-impl TcpSerializerMetadataFactory<MyNoSqlTcpContract, ()> for MyNoSqlTcpSerializerFactory {
-    async fn create(&self) -> () {
+impl TcpSerializerFactory<MyNoSqlTcpContract, MyNoSqlReaderTcpSerializer, ()>
+    for MyNoSqlTcpSerializerFactory
+{
+    async fn create_serializer(&self) -> MyNoSqlReaderTcpSerializer {
+        MyNoSqlReaderTcpSerializer::new()
+    }
+    async fn create_serializer_state(&self) -> () {
         ()
     }
 }