better separation of concerns

This commit is contained in:
filipriec
2025-03-03 16:38:26 +01:00
parent 43031ea933
commit f46b52a8dc
2 changed files with 5 additions and 5 deletions

View File

@@ -17,7 +17,7 @@ impl TablesData for TablesDataService {
request: Request<PostTableDataRequest>, request: Request<PostTableDataRequest>,
) -> Result<Response<PostTableDataResponse>, Status> { ) -> Result<Response<PostTableDataResponse>, Status> {
let request = request.into_inner(); let request = request.into_inner();
// Just pass through the response instead of creating a new one let response = post_table_data(&self.db_pool, request).await?;
post_table_data(&self.db_pool, request).await Ok(Response::new(response)) // Wrap the response in a Response
} }
} }

View File

@@ -9,7 +9,7 @@ use common::proto::multieko2::tables_data::{PostTableDataRequest, PostTableDataR
pub async fn post_table_data( pub async fn post_table_data(
db_pool: &PgPool, db_pool: &PgPool,
request: PostTableDataRequest, request: PostTableDataRequest,
) -> Result<Response<PostTableDataResponse>, Status> { ) -> Result<PostTableDataResponse, Status> { // Return PostTableDataResponse directly
let profile_name = request.profile_name; let profile_name = request.profile_name;
let table_name = request.table_name; let table_name = request.table_name;
let data = request.data; let data = request.data;
@@ -143,9 +143,9 @@ pub async fn post_table_data(
.await .await
.map_err(|e| Status::internal(format!("Insert failed: {}", e)))?; .map_err(|e| Status::internal(format!("Insert failed: {}", e)))?;
Ok(Response::new(PostTableDataResponse { Ok(PostTableDataResponse { // Return PostTableDataResponse directly
success: true, success: true,
message: "Data inserted successfully".into(), message: "Data inserted successfully".into(),
inserted_id, inserted_id,
})) })
} }