Fixes

src/data_readers/http_connection/into_http_payload.rs

@@ -33,17 +33,12 @@ fn write_init_table_result(table_name: &str, content: JsonArrayWriter) -> Vec<u8
     let mut header_json = JsonObjectWriter::new();
     header_json.write("tableName", table_name);
 
-    let header = unsafe {
-        format!(
-            "initTable:{}",
-            std::str::from_utf8_unchecked(header_json.build().as_slice())
-        )
-    };
+    let header = format!("initTable:{}", header_json.build());
 
     write_pascal_string(header.as_str(), &mut result);
 
     let content = content.build();
-    write_byte_array(content.as_slice(), &mut result);
+    write_byte_array(content.as_bytes(), &mut result);
     result
 }
 
@@ -53,17 +48,12 @@ fn write_init_partitions_result(sync_data: &InitPartitionsSyncEventData) -> Vec<
     let mut header_json = JsonObjectWriter::new();
     header_json.write("tableName", sync_data.table_data.table_name.as_str());
 
-    let header = unsafe {
-        format!(
-            "initPartitions:{}",
-            std::str::from_utf8_unchecked(header_json.build().as_slice())
-        )
-    };
+    let header = format!("initPartitions:{}", header_json.build());
 
     write_pascal_string(header.as_str(), &mut result);
 
     let content = sync_data.as_json().build();
-    write_byte_array(content.as_slice(), &mut result);
+    write_byte_array(content.as_bytes(), &mut result);
     result
 }
 
@@ -72,17 +62,12 @@ pub fn compile_update_rows_result(sync_data: &UpdateRowsSyncData) -> Vec<u8> {
     let mut header_json = JsonObjectWriter::new();
     header_json.write("tableName", sync_data.table_data.table_name.as_str());
 
-    let header = unsafe {
-        format!(
-            "updateRows:{}",
-            std::str::from_utf8_unchecked(header_json.build().as_slice())
-        )
-    };
+    let header = format!("updateRows:{}", header_json.build());
 
     write_pascal_string(header.as_str(), &mut result);
 
     let content = sync_data.rows_by_partition.as_json_array().build();
-    write_byte_array(content.as_slice(), &mut result);
+    write_byte_array(content.as_bytes(), &mut result);
     result
 }
 
@@ -92,12 +77,7 @@ pub fn compile_delete_rows_result(sync_data: &DeleteRowsEventSyncData) -> Vec<u8
 
     header_json.write("tableName", sync_data.table_data.table_name.as_str());
 
-    let header = unsafe {
-        format!(
-            "deleteRows:{}",
-            std::str::from_utf8_unchecked(header_json.build().as_slice())
-        )
-    };
+    let header = format!("deleteRows:{}", header_json.build());
 
     write_pascal_string(header.as_str(), &mut result);
 

src/data_readers/tcp_connection/tcp_payload_to_send.rs

@@ -12,7 +12,7 @@ pub async fn serialize(sync_event: &SyncEvent, compress: bool) -> Vec<MyNoSqlTcp
 
             let tcp_contract = MyNoSqlTcpContract::InitTable {
                 table_name: sync_data.db_table.name.to_string(),
-                data,
+                data: data.into_bytes(),
             };
 
             if compress {
@@ -27,7 +27,7 @@ pub async fn serialize(sync_event: &SyncEvent, compress: bool) -> Vec<MyNoSqlTcp
 
             let tcp_contract = MyNoSqlTcpContract::InitTable {
                 table_name: sync_data.table_data.table_name.to_string(),
-                data,
+                data: data.into_bytes(),
             };
 
             if compress {
@@ -47,6 +47,7 @@ pub async fn serialize(sync_event: &SyncEvent, compress: bool) -> Vec<MyNoSqlTcp
                             .db_rows_snapshot
                             .as_json_array()
                             .build()
+                            .into_bytes()
                     } else {
                         EMPTY_ARRAY.to_vec()
                     },
@@ -64,7 +65,7 @@ pub async fn serialize(sync_event: &SyncEvent, compress: bool) -> Vec<MyNoSqlTcp
         SyncEvent::UpdateRows(data) => {
             let tcp_contract = MyNoSqlTcpContract::UpdateRows {
                 table_name: data.table_data.table_name.to_string(),
-                data: data.rows_by_partition.as_json_array().build(),
+                data: data.rows_by_partition.as_json_array().build().into_bytes(),
             };
 
             if compress {

src/db_operations/read/get_highest_row_and_below.rs

@@ -46,7 +46,9 @@ pub async fn get_highest_row_and_below(
         count += 1;
     }
 
-    return Ok(ReadOperationResult::RowsArray(json_array_writer.build()));
+    return Ok(ReadOperationResult::RowsArray(
+        json_array_writer.build().into_bytes(),
+    ));
     /*
     let mut json_array_writer = JsonArrayWriter::new();
 

src/db_operations/read/multipart.rs

@@ -25,5 +25,5 @@ pub async fn get_next(
 ) -> Option<ReadOperationResult> {
     let db_rows = app.multipart_list.get(multipart_id, amount).await?;
 
-    ReadOperationResult::RowsArray(db_rows.as_json_array().build()).into()
+    ReadOperationResult::RowsArray(db_rows.as_json_array().build().into_bytes()).into()
 }

src/db_operations/read/rows/get_all.rs

@@ -29,7 +29,9 @@ pub async fn get_all(
         json_array_writer.write(db_row.as_ref());
     }
 
-    return Ok(ReadOperationResult::RowsArray(json_array_writer.build()));
+    return Ok(ReadOperationResult::RowsArray(
+        json_array_writer.build().into_bytes(),
+    ));
 }
 
 /*

src/db_operations/read/rows/get_all_by_partition_key.rs

@@ -40,5 +40,7 @@ pub async fn get_all_by_partition_key(
         },
     );
 
-    return Ok(ReadOperationResult::RowsArray(json_array_writer.build()));
+    return Ok(ReadOperationResult::RowsArray(
+        json_array_writer.build().into_bytes(),
+    ));
 }

src/db_operations/read/rows/get_all_by_row_key.rs

@@ -30,5 +30,7 @@ pub async fn get_all_by_row_key(
         json_array_writer.write(db_row.as_ref());
     }
 
-    return Ok(ReadOperationResult::RowsArray(json_array_writer.build()));
+    return Ok(ReadOperationResult::RowsArray(
+        json_array_writer.build().into_bytes(),
+    ));
 }

src/db_operations/read/rows/get_single_partition_multiple_rows.rs

@@ -39,7 +39,9 @@ pub async fn get_single_partition_multiple_rows(
             json_array_writer.write(db_row.as_ref());
         }
     }
-    return Ok(ReadOperationResult::RowsArray(json_array_writer.build()));
+    return Ok(ReadOperationResult::RowsArray(
+        json_array_writer.build().into_bytes(),
+    ));
 }
 
 /*

src/db_sync/states/delete_rows_event_sync_data.rs

@@ -140,6 +140,6 @@ impl DeleteRowsEventSyncData {
             }
         }
 
-        json_object_writer.build()
+        json_object_writer.build().into_bytes()
     }
 }

src/settings_reader.rs

@@ -55,7 +55,7 @@ impl SettingsModel {
         my_no_sql_sdk::core::rust_extensions::file_utils::format_path(self.backup_folder.as_str())
     }
 
-    pub fn get_init_from_other_server_url<'s>(&'s self) -> Option<&str> {
+    pub fn get_init_from_other_server_url(&self) -> Option<&str> {
         if let Some(url) = &self.init_from_other_server_url {
             return Some(url.as_str());
         }

src/zip/db_zip_builder.rs

@@ -47,7 +47,7 @@ impl DbZipBuilder {
 
             let payload = json.build();
 
-            write_to_zip_file(&mut self.zip_writer, &payload)?;
+            write_to_zip_file(&mut self.zip_writer, payload.as_bytes())?;
         }
 
         Ok(())