From 2c0c65ea6135bd81f39cfea4d249ec7eadd2b607 Mon Sep 17 00:00:00 2001 From: filipriec Date: Tue, 4 Mar 2025 16:47:46 +0100 Subject: [PATCH] fixed warnings --- .../src/tables_data/handlers/put_table_data.rs | 16 ++++++++++------ 1 file changed, 10 insertions(+), 6 deletions(-) diff --git a/server/src/tables_data/handlers/put_table_data.rs b/server/src/tables_data/handlers/put_table_data.rs index 16f0c6d..570b7be 100644 --- a/server/src/tables_data/handlers/put_table_data.rs +++ b/server/src/tables_data/handlers/put_table_data.rs @@ -56,7 +56,7 @@ pub async fn put_table_data( // Validate system columns let system_columns = ["firma", "deleted"]; let user_columns: Vec<&String> = columns.iter().map(|(name, _)| name).collect(); - + // Validate input columns for key in data.keys() { if !system_columns.contains(&key.as_str()) && !user_columns.contains(&key) { @@ -94,17 +94,20 @@ pub async fn put_table_data( return Err(Status::invalid_argument(format!("Value too long for {}", col))); } } - params.add(value); + params.add(value) + .map_err(|e| Status::internal(format!("Failed to add text parameter for {}: {}", col, e)))?; }, "BOOLEAN" => { let val = value.parse::() .map_err(|_| Status::invalid_argument(format!("Invalid boolean for {}", col)))?; - params.add(val); + params.add(val) + .map_err(|e| Status::internal(format!("Failed to add boolean parameter for {}: {}", col, e)))?; }, "TIMESTAMPTZ" => { let dt = DateTime::parse_from_rfc3339(value) .map_err(|_| Status::invalid_argument(format!("Invalid timestamp for {}", col)))?; - params.add(dt.with_timezone(&Utc)); + params.add(dt.with_timezone(&Utc)) + .map_err(|e| Status::internal(format!("Failed to add timestamp parameter for {}: {}", col, e)))?; }, _ => return Err(Status::invalid_argument(format!("Unsupported type {}", sql_type))), } @@ -114,8 +117,9 @@ pub async fn put_table_data( } // Add ID parameter at the end - params.add(record_id); - + params.add(record_id) + .map_err(|e| Status::internal(format!("Failed to add record_id parameter: {}", e)))?; + let set_clause = set_clauses.join(", "); let sql = format!( "UPDATE \"{}\" SET {} WHERE id = ${} AND deleted = FALSE RETURNING id",