Synched with RustExtensions

src/db_operations/read/get_highest_row_and_below.rs

@@ -49,15 +49,6 @@ pub async fn get_highest_row_and_below(
     return Ok(ReadOperationResult::RowsArray(
         json_array_writer.build().into_bytes(),
     ));
-    /*
-    let mut json_array_writer = JsonArrayWriter::new();
-
-    for db_row in db_rows {
-        json_array_writer.write_raw_element(db_row.data.as_ref());
-    }
-
-    return ReadOperationResult::RowsArray(json_array_writer.build());
-     */
 }
 
 /*

src/db_operations/read/rows/get_single.rs

@@ -12,15 +12,15 @@ use super::super::ReadOperationResult;
 
 pub async fn get_single(
     app: &Arc<AppContext>,
-    db_table: &Arc<DbTableWrapper>,
+    db_table_wrapper: &Arc<DbTableWrapper>,
     partition_key: &String,
     row_key: &String,
     update_statistics: UpdateStatistics,
     now: DateTimeAsMicroseconds,
 ) -> Result<ReadOperationResult, DbOperationError> {
     super::super::super::check_app_states(app)?;
 
-    let table_data = db_table.data.read().await;
+    let table_data = db_table_wrapper.data.read().await;
 
     let db_partition = table_data.get_partition(partition_key);
 
@@ -38,7 +38,7 @@ pub async fn get_single(
 
     let db_row = db_row.unwrap();
 
-    update_statistics.update(db_table, db_partition, Some(db_row), now);
+    update_statistics.update(db_table_wrapper, db_partition, Some(db_row), now);
 
     return Ok(ReadOperationResult::SingleRow(db_row.to_vec()));
 }

src/http_server/controllers/data_reader_controller/get_changes_action.rs

@@ -62,6 +62,7 @@ async fn handle_request(
                     headers: None,
                     content_type: None,
                     content: payload,
+                    set_cookies: None,
                 }
                 .into_ok_result(false)
                 .into();

src/http_server/controllers/home_controller/index_action.rs

@@ -35,6 +35,7 @@ async fn handle_request(
         headers: None,
         content_type: Some(WebContentType::Html),
         content: content.into_bytes(),
+        set_cookies: None,
     }
     .into_ok_result(true)
     .into()

src/http_server/controllers/prometheus_controller/metrics_action.rs

@@ -29,6 +29,7 @@ async fn handle_request(
         headers: None,
         content_type: None,
         content: result.into_bytes(),
+        set_cookies: None,
     }
     .into_ok_result(true)
     .into()

src/http_server/controllers/tables_controller/migration_action.rs

@@ -78,6 +78,7 @@ async fn handle_request(
         headers: None,
         content: format!("Migrated {} partitions", partitions_count).into_bytes(),
         content_type: Some(WebContentType::Text),
+        set_cookies: None,
     }
     .into_ok_result(true)
 }

src/http_server/mappers/read_result.rs

@@ -10,6 +10,7 @@ impl Into<HttpOkResult> for ReadOperationResult {
                     headers: None,
                     content,
                     content_type: Some(WebContentType::Json),
+                    set_cookies: None,
                 };
 
                 HttpOkResult {
@@ -22,6 +23,7 @@ impl Into<HttpOkResult> for ReadOperationResult {
                     headers: None,
                     content,
                     content_type: Some(WebContentType::Json),
+                    set_cookies: None,
                 };
 
                 HttpOkResult {
@@ -39,6 +41,7 @@ impl Into<HttpOkResult> for ReadOperationResult {
                     headers: None,
                     content: empty_array,
                     content_type: Some(WebContentType::Json),
+                    set_cookies: None,
                 };
 
                 HttpOkResult {

src/http_server/mappers/write_operation_result_mapper.rs

@@ -10,6 +10,7 @@ impl Into<Result<HttpOkResult, HttpFailResult>> for WriteOperationResult {
                     headers: None,
                     content_type: Some(WebContentType::Json),
                     content: db_row.to_vec(),
+                    set_cookies: None,
                 };
 
                 Ok(HttpOkResult {