feat(core): Add support for cards bin update (#7194)

Co-authored-by: Mrudul Vajpayee <[email protected]>
Co-authored-by: Mrudul Vajpayee <[email protected]>

Author: 3 people

crates/api_models/src/cards_info.rs

@@ -1,7 +1,10 @@
 use std::fmt::Debug;
 
+use common_utils::events::ApiEventMetric;
 use utoipa::ToSchema;
 
+use crate::enums;
+
 #[derive(serde::Deserialize, ToSchema)]
 pub struct CardsInfoRequestParams {
     #[schema(example = "pay_OSERgeV9qAy7tlK7aKpc_secret_TuDUoh11Msxh12sXn3Yp")]
@@ -29,3 +32,97 @@ pub struct CardInfoResponse {
     #[schema(example = "INDIA")]
     pub card_issuing_country: Option<String>,
 }
+
+#[derive(serde::Serialize, Debug, ToSchema)]
+pub struct CardInfoMigrateResponseRecord {
+    pub card_iin: Option<String>,
+    pub card_issuer: Option<String>,
+    pub card_network: Option<String>,
+    pub card_type: Option<String>,
+    pub card_sub_type: Option<String>,
+    pub card_issuing_country: Option<String>,
+}
+
+#[derive(Debug, serde::Deserialize, serde::Serialize, ToSchema)]
+pub struct CardInfoCreateRequest {
+    pub card_iin: String,
+    pub card_issuer: Option<String>,
+    pub card_network: Option<enums::CardNetwork>,
+    pub card_type: Option<String>,
+    pub card_subtype: Option<String>,
+    pub card_issuing_country: Option<String>,
+    pub bank_code_id: Option<String>,
+    pub bank_code: Option<String>,
+    pub country_code: Option<String>,
+    pub last_updated_provider: Option<String>,
+}
+
+impl ApiEventMetric for CardInfoCreateRequest {}
+
+#[derive(Debug, Clone, serde::Deserialize, serde::Serialize, ToSchema)]
+pub struct CardInfoUpdateRequest {
+    pub card_iin: String,
+    pub card_issuer: Option<String>,
+    pub card_network: Option<enums::CardNetwork>,
+    pub card_type: Option<String>,
+    pub card_subtype: Option<String>,
+    pub card_issuing_country: Option<String>,
+    pub bank_code_id: Option<String>,
+    pub bank_code: Option<String>,
+    pub country_code: Option<String>,
+    pub last_updated_provider: Option<String>,
+    pub line_number: Option<i64>,
+}
+
+impl ApiEventMetric for CardInfoUpdateRequest {}
+
+#[derive(Debug, Default, serde::Serialize)]
+pub enum CardInfoMigrationStatus {
+    Success,
+    #[default]
+    Failed,
+}
+#[derive(Debug, Default, serde::Serialize)]
+pub struct CardInfoMigrationResponse {
+    pub line_number: Option<i64>,
+    pub card_iin: String,
+    pub card_issuer: Option<String>,
+    pub card_network: Option<String>,
+    pub card_type: Option<String>,
+    pub card_sub_type: Option<String>,
+    pub card_issuing_country: Option<String>,
+    #[serde(skip_serializing_if = "Option::is_none")]
+    pub migration_error: Option<String>,
+    pub migration_status: CardInfoMigrationStatus,
+}
+impl ApiEventMetric for CardInfoMigrationResponse {}
+
+type CardInfoMigrationResponseType = (
+    Result<CardInfoMigrateResponseRecord, String>,
+    CardInfoUpdateRequest,
+);
+
+impl From<CardInfoMigrationResponseType> for CardInfoMigrationResponse {
+    fn from((response, record): CardInfoMigrationResponseType) -> Self {
+        match response {
+            Ok(res) => Self {
+                card_iin: record.card_iin,
+                line_number: record.line_number,
+                card_issuer: res.card_issuer,
+                card_network: res.card_network,
+                card_type: res.card_type,
+                card_sub_type: res.card_sub_type,
+                card_issuing_country: res.card_issuing_country,
+                migration_status: CardInfoMigrationStatus::Success,
+                migration_error: None,
+            },
+            Err(e) => Self {
+                card_iin: record.card_iin,
+                migration_status: CardInfoMigrationStatus::Failed,
+                migration_error: Some(e),
+                line_number: record.line_number,
+                ..Self::default()
+            },
+        }
+    }
+}

crates/diesel_models/src/cards_info.rs

@@ -1,10 +1,17 @@
-use diesel::{Identifiable, Queryable, Selectable};
+use diesel::{AsChangeset, Identifiable, Insertable, Queryable, Selectable};
 use time::PrimitiveDateTime;
 
 use crate::{enums as storage_enums, schema::cards_info};
 
 #[derive(
-    Clone, Debug, Queryable, Identifiable, Selectable, serde::Deserialize, serde::Serialize,
+    Clone,
+    Debug,
+    Queryable,
+    Identifiable,
+    Selectable,
+    serde::Deserialize,
+    serde::Serialize,
+    Insertable,
 )]
 #[diesel(table_name = cards_info, primary_key(card_iin), check_for_backend(diesel::pg::Pg))]
 pub struct CardInfo {
@@ -21,3 +28,20 @@ pub struct CardInfo {
     pub last_updated: Option<PrimitiveDateTime>,
     pub last_updated_provider: Option<String>,
 }
+
+#[derive(
+    Clone, Debug, PartialEq, Eq, AsChangeset, router_derive::DebugAsDisplay, serde::Deserialize,
+)]
+#[diesel(table_name = cards_info)]
+pub struct UpdateCardInfo {
+    pub card_issuer: Option<String>,
+    pub card_network: Option<storage_enums::CardNetwork>,
+    pub card_type: Option<String>,
+    pub card_subtype: Option<String>,
+    pub card_issuing_country: Option<String>,
+    pub bank_code_id: Option<String>,
+    pub bank_code: Option<String>,
+    pub country_code: Option<String>,
+    pub last_updated: Option<PrimitiveDateTime>,
+    pub last_updated_provider: Option<String>,
+}

crates/diesel_models/src/query/cards_info.rs

@@ -1,6 +1,13 @@
-use diesel::associations::HasTable;
+use diesel::{associations::HasTable, ExpressionMethods};
+use error_stack::report;
 
-use crate::{cards_info::CardInfo, query::generics, PgPooledConn, StorageResult};
+use crate::{
+    cards_info::{CardInfo, UpdateCardInfo},
+    errors,
+    query::generics,
+    schema::cards_info::dsl,
+    PgPooledConn, StorageResult,
+};
 
 impl CardInfo {
     pub async fn find_by_iin(conn: &PgPooledConn, card_iin: &str) -> StorageResult<Option<Self>> {
@@ -10,4 +17,25 @@ impl CardInfo {
         )
         .await
     }
+    pub async fn insert(self, conn: &PgPooledConn) -> StorageResult<Self> {
+        generics::generic_insert(conn, self).await
+    }
+    pub async fn update(
+        conn: &PgPooledConn,
+        card_iin: String,
+        data: UpdateCardInfo,
+    ) -> StorageResult<Self> {
+        generics::generic_update_with_results::<<Self as HasTable>::Table, UpdateCardInfo, _, _>(
+            conn,
+            dsl::card_iin.eq(card_iin),
+            data,
+        )
+        .await?
+        .first()
+        .cloned()
+        .ok_or_else(|| {
+            report!(errors::DatabaseError::NotFound)
+                .attach_printable("Error while updating card_info entry")
+        })
+    }
 }