feat(core): diesel models and db interface changes for call_back_mapper table

crates/diesel_models/src/callback_mapper.rs

@@ -0,0 +1,28 @@
+use diesel::{Identifiable, Insertable, Queryable, Selectable};
+use serde::{self, Deserialize, Serialize};
+use serde_json;
+
+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: serde_json::Value,
+    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: serde_json::Value,
+}

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;

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/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,47 @@
+use error_stack::report;
+use router_env::{instrument, tracing};
+
+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: storage::CallBackMapperNew,
+    ) -> CustomResult<storage::CallBackMapper, errors::StorageError>;
+
+    async fn find_call_back_mapper_by_id(
+        &self,
+        id: String,
+    ) -> CustomResult<storage::CallBackMapper, errors::StorageError>;
+}
+
+#[async_trait::async_trait]
+impl CallBackMapperInterface for Store {
+    #[instrument(skip_all)]
+    async fn insert_call_back_mapper(
+        &self,
+        call_back_mapper: storage::CallBackMapperNew,
+    ) -> CustomResult<storage::CallBackMapper, errors::StorageError> {
+        let conn = connection::pg_connection_write(self).await?;
+        call_back_mapper
+            .insert(&conn)
+            .await
+            .map_err(|error| report!(errors::StorageError::from(error)))
+    }
+
+    async fn find_call_back_mapper_by_id(
+        &self,
+        id: String,
+    ) -> CustomResult<storage::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)))
+    }
+}

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};

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
+);