feat(core): diesel models, domain models and db interface changes for callback_mapper table

crates/diesel_models/src/callback_mapper.rs

@@ -0,0 +1,27 @@
+use common_utils::pii;
+use diesel::{Identifiable, Insertable, Queryable, Selectable};
+use serde::{self, Deserialize, Serialize};
+
+use crate::schema::callback_mapper;
+
+#[derive(
+    Clone, Debug, Eq, PartialEq, Identifiable, Queryable, Selectable, Serialize, Deserialize,
+)]
+#[diesel(table_name = callback_mapper,  primary_key(id), check_for_backend(diesel::pg::Pg))]
+pub struct CallBackMapper {
+    pub id: String,
+    #[serde(rename = "type")]
+    pub type_: String,
+    pub data: pii::SecretSerdeValue,
+    pub created_at: time::PrimitiveDateTime,
+    pub last_modified_at: time::PrimitiveDateTime,
+}
+
+#[derive(Clone, Debug, Eq, PartialEq, Serialize, Deserialize, Insertable)]
+#[diesel(table_name = callback_mapper)]
+pub struct CallBackMapperNew {
+    pub id: String,
+    #[serde(rename = "type")]
+    pub type_: String,
+    pub data: pii::SecretSerdeValue,
+}

crates/diesel_models/src/lib.rs

@@ -10,6 +10,7 @@ pub mod authentication;
 pub mod authorization;
 pub mod blocklist;
 pub mod blocklist_fingerprint;
+pub mod callback_mapper;
 pub mod customers;
 pub mod dispute;
 pub mod enums;
@@ -59,11 +60,11 @@ use diesel_impl::{DieselArray, OptionalDieselArray};
 pub type StorageResult<T> = error_stack::Result<T, errors::DatabaseError>;
 pub type PgPooledConn = async_bb8_diesel::Connection<diesel::PgConnection>;
 pub use self::{
-    address::*, api_keys::*, cards_info::*, configs::*, customers::*, dispute::*, ephemeral_key::*,
-    events::*, file::*, generic_link::*, locker_mock_up::*, mandate::*, merchant_account::*,
-    merchant_connector_account::*, payment_attempt::*, payment_intent::*, payment_method::*,
-    payout_attempt::*, payouts::*, process_tracker::*, refund::*, reverse_lookup::*,
-    user_authentication_method::*,
+    address::*, api_keys::*, callback_mapper::*, cards_info::*, configs::*, customers::*,
+    dispute::*, ephemeral_key::*, events::*, file::*, generic_link::*, locker_mock_up::*,
+    mandate::*, merchant_account::*, merchant_connector_account::*, payment_attempt::*,
+    payment_intent::*, payment_method::*, payout_attempt::*, payouts::*, process_tracker::*,
+    refund::*, reverse_lookup::*, user_authentication_method::*,
 };
 
 /// The types and implementations provided by this module are required for the schema generated by

crates/diesel_models/src/query.rs

@@ -10,6 +10,7 @@ pub mod authentication;
 pub mod authorization;
 pub mod blocklist;
 pub mod blocklist_fingerprint;
+pub mod callback_mapper;
 pub mod customers;
 pub mod dashboard_metadata;
 pub mod dispute;

crates/diesel_models/src/query/callback_mapper.rs

@@ -0,0 +1,24 @@
+use diesel::{associations::HasTable, ExpressionMethods};
+
+use super::generics;
+use crate::{
+    callback_mapper::{CallBackMapper, CallBackMapperNew},
+    schema::callback_mapper::dsl,
+    PgPooledConn, StorageResult,
+};
+
+impl CallBackMapperNew {
+    pub async fn insert(self, conn: &PgPooledConn) -> StorageResult<CallBackMapper> {
+        generics::generic_insert(conn, self).await
+    }
+}
+
+impl CallBackMapper {
+    pub async fn find_by_id(conn: &PgPooledConn, id: String) -> StorageResult<Self> {
+        generics::generic_find_one::<<Self as HasTable>::Table, _, _>(
+            conn,
+            dsl::id.eq(id.to_owned()),
+        )
+        .await
+    }
+}

crates/diesel_models/src/schema.rs

@@ -216,6 +216,22 @@ diesel::table! {
     }
 }
 
+diesel::table! {
+    use diesel::sql_types::*;
+    use crate::enums::diesel_exports::*;
+
+    callback_mapper (id) {
+        #[max_length = 128]
+        id -> Varchar,
+        #[sql_name = "type"]
+        #[max_length = 64]
+        type_ -> Varchar,
+        data -> Jsonb,
+        created_at -> Timestamp,
+        last_modified_at -> Timestamp,
+    }
+}
+
 diesel::table! {
     use diesel::sql_types::*;
     use crate::enums::diesel_exports::*;
@@ -1399,6 +1415,7 @@ diesel::allow_tables_to_appear_in_same_query!(
     blocklist_fingerprint,
     blocklist_lookup,
     business_profile,
+    callback_mapper,
     captures,
     cards_info,
     configs,

crates/diesel_models/src/schema_v2.rs

@@ -224,6 +224,22 @@ diesel::table! {
     }
 }
 
+diesel::table! {
+    use diesel::sql_types::*;
+    use crate::enums::diesel_exports::*;
+
+    callback_mapper (id) {
+        #[max_length = 128]
+        id -> Varchar,
+        #[sql_name = "type"]
+        #[max_length = 64]
+        type_ -> Varchar,
+        data -> Jsonb,
+        created_at -> Timestamp,
+        last_modified_at -> Timestamp,
+    }
+}
+
 diesel::table! {
     use diesel::sql_types::*;
     use crate::enums::diesel_exports::*;
@@ -1346,6 +1362,7 @@ diesel::allow_tables_to_appear_in_same_query!(
     blocklist_fingerprint,
     blocklist_lookup,
     business_profile,
+    callback_mapper,
     captures,
     cards_info,
     configs,

crates/hyperswitch_domain_models/src/callback_mapper.rs

@@ -0,0 +1,20 @@
+use common_utils::pii;
+use serde::{self, Deserialize, Serialize};
+
+#[derive(Clone, Debug, Eq, PartialEq, Serialize, Deserialize)]
+pub struct CallBackMapper {
+    pub id: String,
+    #[serde(rename = "type")]
+    pub type_: String,
+    pub data: pii::SecretSerdeValue,
+    pub created_at: time::PrimitiveDateTime,
+    pub last_modified_at: time::PrimitiveDateTime,
+}
+
+#[derive(Clone, Debug, Eq, PartialEq, Serialize, Deserialize)]
+pub struct CallBackMapperNew {
+    pub id: String,
+    #[serde(rename = "type")]
+    pub type_: String,
+    pub data: pii::SecretSerdeValue,
+}

crates/hyperswitch_domain_models/src/lib.rs

@@ -1,6 +1,7 @@
 pub mod api;
 pub mod behaviour;
 pub mod business_profile;
+pub mod callback_mapper;
 pub mod consts;
 pub mod customer;
 pub mod disputes;

crates/router/src/db.rs

@@ -6,6 +6,7 @@ pub mod blocklist;
 pub mod blocklist_fingerprint;
 pub mod blocklist_lookup;
 pub mod business_profile;
+pub mod callback_mapper;
 pub mod capture;
 pub mod cards_info;
 pub mod configs;

crates/router/src/db/callback_mapper.rs

@@ -0,0 +1,52 @@
+use error_stack::report;
+use hyperswitch_domain_models::callback_mapper::{self as DomainCallBackMapper};
+use router_env::{instrument, tracing};
+use storage_impl::DataModelExt;
+
+use super::Store;
+use crate::{
+    connection,
+    core::errors::{self, CustomResult},
+    types::storage,
+};
+
+#[async_trait::async_trait]
+pub trait CallBackMapperInterface {
+    async fn insert_call_back_mapper(
+        &self,
+        call_back_mapper: DomainCallBackMapper::CallBackMapperNew,
+    ) -> CustomResult<DomainCallBackMapper::CallBackMapper, errors::StorageError>;
+
+    async fn find_call_back_mapper_by_id(
+        &self,
+        id: String,
+    ) -> CustomResult<DomainCallBackMapper::CallBackMapper, errors::StorageError>;
+}
+
+#[async_trait::async_trait]
+impl CallBackMapperInterface for Store {
+    #[instrument(skip_all)]
+    async fn insert_call_back_mapper(
+        &self,
+        call_back_mapper: DomainCallBackMapper::CallBackMapperNew,
+    ) -> CustomResult<DomainCallBackMapper::CallBackMapper, errors::StorageError> {
+        let conn = connection::pg_connection_write(self).await?;
+        call_back_mapper
+            .to_storage_model()
+            .insert(&conn)
+            .await
+            .map_err(|error| report!(errors::StorageError::from(error)))
+            .map(DomainCallBackMapper::CallBackMapper::from_storage_model)
+    }
+
+    async fn find_call_back_mapper_by_id(
+        &self,
+        id: String,
+    ) -> CustomResult<DomainCallBackMapper::CallBackMapper, errors::StorageError> {
+        let conn = connection::pg_connection_read(self).await?;
+        storage::CallBackMapper::find_by_id(&conn, id)
+            .await
+            .map_err(|error| report!(errors::StorageError::from(error)))
+            .map(DomainCallBackMapper::CallBackMapper::from_storage_model)
+    }
+}

crates/router/src/db/kafka_store.rs

@@ -53,6 +53,7 @@ use crate::{
         authentication::AuthenticationInterface,
         authorization::AuthorizationInterface,
         business_profile::ProfileInterface,
+        callback_mapper::CallBackMapperInterface,
         capture::CaptureInterface,
         cards_info::CardsInfoInterface,
         configs::ConfigInterface,
@@ -3714,3 +3715,22 @@ impl ThemeInterface for KafkaStore {
             .await
     }
 }
+
+#[async_trait::async_trait]
+impl CallBackMapperInterface for KafkaStore {
+    async fn insert_call_back_mapper(
+        &self,
+        call_back_mapper: domain::CallBackMapperNew,
+    ) -> CustomResult<domain::CallBackMapper, errors::StorageError> {
+        self.diesel_store
+            .insert_call_back_mapper(call_back_mapper)
+            .await
+    }
+
+    async fn find_call_back_mapper_by_id(
+        &self,
+        id: String,
+    ) -> CustomResult<domain::CallBackMapper, errors::StorageError> {
+        self.diesel_store.find_call_back_mapper_by_id(id).await
+    }
+}

crates/router/src/types/domain.rs

@@ -16,6 +16,10 @@ mod customers {
     pub use hyperswitch_domain_models::customer::*;
 }
 
+mod callback_mapper {
+    pub use hyperswitch_domain_models::callback_mapper::{CallBackMapper, CallBackMapperNew};
+}
+
 pub use customers::*;
 pub use merchant_account::*;
 
@@ -39,6 +43,7 @@ pub mod user_key_store;
 
 pub use address::*;
 pub use business_profile::*;
+pub use callback_mapper::*;
 pub use consts::*;
 pub use event::*;
 pub use merchant_connector_account::*;

crates/router/src/types/storage.rs

@@ -6,6 +6,7 @@ pub mod blocklist;
 pub mod blocklist_fingerprint;
 pub mod blocklist_lookup;
 pub mod business_profile;
+pub mod callback_mapper;
 pub mod capture;
 pub mod cards_info;
 pub mod configs;
@@ -62,13 +63,13 @@ pub use scheduler::db::process_tracker;
 
 pub use self::{
     address::*, api_keys::*, authentication::*, authorization::*, blocklist::*,
-    blocklist_fingerprint::*, blocklist_lookup::*, business_profile::*, capture::*, cards_info::*,
-    configs::*, customers::*, dashboard_metadata::*, dispute::*, ephemeral_key::*, events::*,
-    file::*, fraud_check::*, generic_link::*, gsm::*, locker_mock_up::*, mandate::*,
-    merchant_account::*, merchant_connector_account::*, merchant_key_store::*, payment_link::*,
-    payment_method::*, process_tracker::*, refund::*, reverse_lookup::*, role::*,
-    routing_algorithm::*, unified_translations::*, user::*, user_authentication_method::*,
-    user_role::*,
+    blocklist_fingerprint::*, blocklist_lookup::*, business_profile::*, callback_mapper::*,
+    capture::*, cards_info::*, configs::*, customers::*, dashboard_metadata::*, dispute::*,
+    ephemeral_key::*, events::*, file::*, fraud_check::*, generic_link::*, gsm::*,
+    locker_mock_up::*, mandate::*, merchant_account::*, merchant_connector_account::*,
+    merchant_key_store::*, payment_link::*, payment_method::*, process_tracker::*, refund::*,
+    reverse_lookup::*, role::*, routing_algorithm::*, unified_translations::*, user::*,
+    user_authentication_method::*, user_role::*,
 };
 use crate::types::api::routing;
 

crates/router/src/types/storage/callback_mapper.rs

@@ -0,0 +1 @@
+pub use diesel_models::callback_mapper::{CallBackMapper, CallBackMapperNew};

crates/storage_impl/src/callback_mapper.rs

@@ -0,0 +1,50 @@
+use diesel_models::callback_mapper::{
+    CallBackMapper as DieselCallBackMapper, CallBackMapperNew as DieselCallBackMapperNew,
+};
+use hyperswitch_domain_models::callback_mapper::{CallBackMapper, CallBackMapperNew};
+
+use crate::DataModelExt;
+
+impl DataModelExt for CallBackMapper {
+    type StorageModel = DieselCallBackMapper;
+
+    fn to_storage_model(self) -> Self::StorageModel {
+        DieselCallBackMapper {
+            id: self.id,
+            type_: self.type_,
+            data: self.data,
+            created_at: self.created_at,
+            last_modified_at: self.last_modified_at,
+        }
+    }
+
+    fn from_storage_model(storage_model: Self::StorageModel) -> Self {
+        Self {
+            id: storage_model.id,
+            type_: storage_model.type_,
+            data: storage_model.data,
+            created_at: storage_model.created_at,
+            last_modified_at: storage_model.last_modified_at,
+        }
+    }
+}
+
+impl DataModelExt for CallBackMapperNew {
+    type StorageModel = DieselCallBackMapperNew;
+
+    fn to_storage_model(self) -> Self::StorageModel {
+        DieselCallBackMapperNew {
+            id: self.id,
+            type_: self.type_,
+            data: self.data,
+        }
+    }
+
+    fn from_storage_model(storage_model: Self::StorageModel) -> Self {
+        Self {
+            id: storage_model.id,
+            type_: storage_model.type_,
+            data: storage_model.data,
+        }
+    }
+}

crates/storage_impl/src/lib.rs

@@ -6,6 +6,7 @@ use hyperswitch_domain_models::errors::{StorageError, StorageResult};
 use masking::StrongSecret;
 use redis::{kv_store::RedisConnInterface, pub_sub::PubSubInterface, RedisStore};
 mod address;
+pub mod callback_mapper;
 pub mod config;
 pub mod connection;
 pub mod customers;

migrations/2024-11-13-105952_add_call-back-mapper_table/down.sql

@@ -0,0 +1,2 @@
+-- This file should undo anything in `up.sql`
+DROP TABLE IF EXISTS callback_mapper;

migrations/2024-11-13-105952_add_call-back-mapper_table/up.sql

@@ -0,0 +1,8 @@
+-- Your SQL goes here
+CREATE TABLE IF NOT EXISTS callback_mapper (
+    id VARCHAR(128) NOT NULL PRIMARY KEY,
+    type VARCHAR(64) NOT NULL,
+    data JSONB NOT NULL,
+    created_at TIMESTAMP NOT NULL DEFAULT now()::TIMESTAMP,
+    last_modified_at TIMESTAMP NOT NULL DEFAULT now()::TIMESTAMP
+);