andwati/telecom-platform
1
0
Fork 0
mirror of https://github.com/andwati/telecom-platform.git synced 2026-10-19 11:32:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: Replace RedisOperation with DatabaseError in rating_plans_repo error mapping

Browse Source 
- Replace RedisOperation error variant with DatabaseError in new/get/list_map/add/remove methods
- Update 5 map_err calls to use DatabaseError for SQLx operation failures
This commit is contained in:
nutcas3
2026-04-25 03:03:27 +03:00
parent 69a84d85e6
commit 7e47f09e54
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
apps/charging-engine/src/charging/rating_plans_repo.rs
+5 -5
View File
@@ -49,7 +49,7 @@ impl RatingPlansRepo {
)
.execute(&pool)
.await
.map_err(|e| crate::errors::ChargingError::RedisOperation(e.to_string()))?;
.map_err(|e| crate::errors::ChargingError::DatabaseError(e.to_string()))?;
Ok(Self { pool })
}
@@ -112,7 +112,7 @@ impl RatingPlansRepo {
.bind(plan_id)
.fetch_optional(&self.pool)
.await
.map_err(|e| crate::errors::ChargingError::RedisOperation(e.to_string()))?;
.map_err(|e| crate::errors::ChargingError::DatabaseError(e.to_string()))?;
Ok(row.map(row_to_plan))
}
@@ -129,7 +129,7 @@ impl RatingPlansRepo {
)
.fetch_all(&self.pool)
.await
.map_err(|e| crate::errors::ChargingError::RedisOperation(e.to_string()))?;
.map_err(|e| crate::errors::ChargingError::DatabaseError(e.to_string()))?;
let mut out = HashMap::with_capacity(rows.len());
for row in rows {
@@ -192,7 +192,7 @@ impl RatingPlansRepo {
.bind(plan.sms_limit as i64)
.execute(&self.pool)
.await
.map_err(|e| crate::errors::ChargingError::RedisOperation(e.to_string()))?;
.map_err(|e| crate::errors::ChargingError::DatabaseError(e.to_string()))?;
Ok(())
}
@@ -204,7 +204,7 @@ impl RatingPlansRepo {
.bind(plan_id)
.execute(&self.pool)
.await
.map_err(|e| crate::errors::ChargingError::RedisOperation(e.to_string()))?;
.map_err(|e| crate::errors::ChargingError::DatabaseError(e.to_string()))?;
Ok(result.rows_affected() > 0)
}
}