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

feat: Replace context error handling with map_err for ChargingError in RatingPlansRepo Postgres operations

Browse Source 
- Replace context with map_err for InternalError on Postgres connection
- Replace context with map_err for RedisOperation on schema migration/fetch/list/upsert/deactivate operations
This commit is contained in:
nutcas3
2026-04-25 00:51:27 +03:00
parent dd12518786
commit 2bd7e19f09
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
apps/charging-engine/src/charging/rating_plans_repo.rs
+6 -6
View File
@@ -24,7 +24,7 @@ impl RatingPlansRepo {
.max_connections(10)
.connect(database_url)
.await
.context("Failed to connect to Postgres")?;
.map_err(|e| crate::errors::ChargingError::InternalError(e.to_string()))?;
// Idempotent schema for rating plans. api-server's GORM migration also
// creates a compatible `rating_plans` table; the column set here is
@@ -49,7 +49,7 @@ impl RatingPlansRepo {
)
.execute(&pool)
.await
.context("Failed to migrate rating_plans table")?;
.map_err(|e| crate::errors::ChargingError::RedisOperation(e.to_string()))?;
Ok(Self { pool })
}
@@ -112,7 +112,7 @@ impl RatingPlansRepo {
.bind(plan_id)
.fetch_optional(&self.pool)
.await
.context("Failed to fetch rating plan")?;
.map_err(|e| crate::errors::ChargingError::RedisOperation(e.to_string()))?;
Ok(row.map(row_to_plan))
}
@@ -129,7 +129,7 @@ impl RatingPlansRepo {
)
.fetch_all(&self.pool)
.await
.context("Failed to list rating plans")?;
.map_err(|e| crate::errors::ChargingError::RedisOperation(e.to_string()))?;
let mut out = HashMap::with_capacity(rows.len());
for row in rows {
@@ -171,7 +171,7 @@ impl RatingPlansRepo {
.bind(plan.sms_limit as i64)
.execute(&self.pool)
.await
.context("Failed to upsert rating plan")?;
.map_err(|e| crate::errors::ChargingError::RedisOperation(e.to_string()))?;
Ok(())
}
@@ -183,7 +183,7 @@ impl RatingPlansRepo {
.bind(plan_id)
.execute(&self.pool)
.await
.context("Failed to deactivate rating plan")?;
.map_err(|e| crate::errors::ChargingError::RedisOperation(e.to_string()))?;
Ok(result.rows_affected() > 0)
}
}