diff --git a/src/db_operations/read/get_highest_row_and_below.rs b/src/db_operations/read/get_highest_row_and_below.rs index 33223f1..06c6d09 100644 --- a/src/db_operations/read/get_highest_row_and_below.rs +++ b/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()); - */ } /* diff --git a/src/db_operations/read/rows/get_single.rs b/src/db_operations/read/rows/get_single.rs index 62642f4..71fcfcb 100644 --- a/src/db_operations/read/rows/get_single.rs +++ b/src/db_operations/read/rows/get_single.rs @@ -12,7 +12,7 @@ use super::super::ReadOperationResult; pub async fn get_single( app: &Arc, - db_table: &Arc, + db_table_wrapper: &Arc, partition_key: &String, row_key: &String, update_statistics: UpdateStatistics, @@ -20,7 +20,7 @@ pub async fn get_single( ) -> Result { 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())); } diff --git a/src/http_server/controllers/data_reader_controller/get_changes_action.rs b/src/http_server/controllers/data_reader_controller/get_changes_action.rs index 90a7337..bac3ad1 100644 --- a/src/http_server/controllers/data_reader_controller/get_changes_action.rs +++ b/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(); diff --git a/src/http_server/controllers/home_controller/index_action.rs b/src/http_server/controllers/home_controller/index_action.rs index 51266b7..d58d17a 100644 --- a/src/http_server/controllers/home_controller/index_action.rs +++ b/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() diff --git a/src/http_server/controllers/prometheus_controller/metrics_action.rs b/src/http_server/controllers/prometheus_controller/metrics_action.rs index 7bc6c89..f9591a3 100644 --- a/src/http_server/controllers/prometheus_controller/metrics_action.rs +++ b/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() diff --git a/src/http_server/controllers/tables_controller/migration_action.rs b/src/http_server/controllers/tables_controller/migration_action.rs index 585fb95..2827923 100644 --- a/src/http_server/controllers/tables_controller/migration_action.rs +++ b/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) } diff --git a/src/http_server/mappers/read_result.rs b/src/http_server/mappers/read_result.rs index 8a1d7e6..d874c3c 100644 --- a/src/http_server/mappers/read_result.rs +++ b/src/http_server/mappers/read_result.rs @@ -10,6 +10,7 @@ impl Into for ReadOperationResult { headers: None, content, content_type: Some(WebContentType::Json), + set_cookies: None, }; HttpOkResult { @@ -22,6 +23,7 @@ impl Into for ReadOperationResult { headers: None, content, content_type: Some(WebContentType::Json), + set_cookies: None, }; HttpOkResult { @@ -39,6 +41,7 @@ impl Into for ReadOperationResult { headers: None, content: empty_array, content_type: Some(WebContentType::Json), + set_cookies: None, }; HttpOkResult { diff --git a/src/http_server/mappers/write_operation_result_mapper.rs b/src/http_server/mappers/write_operation_result_mapper.rs index 1968579..cd822ec 100644 --- a/src/http_server/mappers/write_operation_result_mapper.rs +++ b/src/http_server/mappers/write_operation_result_mapper.rs @@ -10,6 +10,7 @@ impl Into> for WriteOperationResult { headers: None, content_type: Some(WebContentType::Json), content: db_row.to_vec(), + set_cookies: None, }; Ok(HttpOkResult {