feat(router): Add support for storing multiple surcharge configurations at profile level

api-reference-v2/openapi_spec.json

@@ -20707,6 +20707,14 @@
             "description": "Indicates if clear pan retries is enabled or not.",
             "nullable": true
           },
+          "active_surcharge_algorithm_id": {
+            "allOf": [
+              {
+                "$ref": "#/components/schemas/SurchargeRoutingId"
+              }
+            ],
+            "nullable": true
+          },
           "is_debit_routing_enabled": {
             "type": "boolean",
             "description": "Indicates if debit routing is enabled or not",
@@ -23769,6 +23777,10 @@
           "propertyName": "type"
         }
       },
+      "SurchargeRoutingId": {
+        "type": "string",
+        "description": "A wrapper type for `RoutingId` that can be used for surcharge routing ids"
+      },
       "SwishQrData": {
         "type": "object"
       },

api-reference/openapi_spec.json

@@ -25033,6 +25033,14 @@
             "description": "Indicates if 3ds challenge is forced",
             "nullable": true
           },
+          "active_surcharge_algorithm_id": {
+            "allOf": [
+              {
+                "$ref": "#/components/schemas/SurchargeRoutingId"
+              }
+            ],
+            "nullable": true
+          },
           "is_debit_routing_enabled": {
             "type": "boolean",
             "description": "Indicates if debit routing is enabled or not",
@@ -25321,6 +25329,14 @@
             "type": "boolean",
             "description": "Indicates if 3ds challenge is forced"
           },
+          "active_surcharge_algorithm_id": {
+            "allOf": [
+              {
+                "$ref": "#/components/schemas/SurchargeRoutingId"
+              }
+            ],
+            "nullable": true
+          },
           "is_debit_routing_enabled": {
             "type": "boolean",
             "description": "Indicates if debit routing is enabled or not",
@@ -28105,6 +28121,10 @@
           "propertyName": "type"
         }
       },
+      "SurchargeRoutingId": {
+        "type": "string",
+        "description": "A wrapper type for `RoutingId` that can be used for surcharge routing ids"
+      },
       "SwishQrData": {
         "type": "object"
       },

crates/api_models/src/admin.rs

@@ -2006,6 +2006,10 @@ pub struct ProfileCreate {
     /// Indicates if 3ds challenge is forced
     pub force_3ds_challenge: Option<bool>,
 
+    /// Active surcharge config id
+    #[schema(value_type = Option<SurchargeRoutingId>)]
+    pub active_surcharge_algorithm_id: Option<id_type::SurchargeRoutingId>,
+
     /// Indicates if debit routing is enabled or not
     #[schema(value_type = Option<bool>)]
     pub is_debit_routing_enabled: Option<bool>,
@@ -2144,6 +2148,10 @@ pub struct ProfileCreate {
     ///Indicates if clear pan retries is enabled or not.
     pub is_clear_pan_retries_enabled: Option<bool>,
 
+    /// Active surcharge algorithm id
+    #[schema(value_type = Option<SurchargeRoutingId>)]
+    pub active_surcharge_algorithm_id: Option<id_type::SurchargeRoutingId>,
+
     /// Indicates if debit routing is enabled or not
     #[schema(value_type = Option<bool>)]
     pub is_debit_routing_enabled: Option<bool>,
@@ -2312,6 +2320,10 @@ pub struct ProfileResponse {
     /// Indicates if 3ds challenge is forced
     pub force_3ds_challenge: bool,
 
+    /// Active surcharge config id
+    #[schema(value_type = Option<SurchargeRoutingId>)]
+    pub active_surcharge_algorithm_id: Option<id_type::SurchargeRoutingId>,
+
     /// Indicates if debit routing is enabled or not
     #[schema(value_type = Option<bool>)]
     pub is_debit_routing_enabled: Option<bool>,
@@ -2613,6 +2625,10 @@ pub struct ProfileUpdate {
     /// Indicates if 3ds challenge is forced
     pub force_3ds_challenge: Option<bool>,
 
+    /// Active surcharge config id
+    #[schema(value_type = Option<SurchargeRoutingId>)]
+    pub active_surcharge_algorithm_id: Option<id_type::SurchargeRoutingId>,
+
     /// Indicates if debit routing is enabled or not
     #[schema(value_type = Option<bool>)]
     pub is_debit_routing_enabled: Option<bool>,

crates/api_models/src/events/routing.rs

@@ -8,8 +8,8 @@ use crate::routing::{
     RoutingLinkWrapper, RoutingPayloadWrapper, RoutingRetrieveLinkQuery,
     RoutingRetrieveLinkQueryWrapper, RoutingRetrieveQuery, RoutingVolumeSplit,
     RoutingVolumeSplitResponse, RoutingVolumeSplitWrapper, SuccessBasedRoutingConfig,
-    SuccessBasedRoutingPayloadWrapper, ToggleDynamicRoutingPath, ToggleDynamicRoutingQuery,
-    ToggleDynamicRoutingWrapper,
+    SuccessBasedRoutingPayloadWrapper, SurchargeRetrieveLinkQuery, SurchargeRetrieveQuery,
+    ToggleDynamicRoutingPath, ToggleDynamicRoutingQuery, ToggleDynamicRoutingWrapper,
 };
 
 impl ApiEventMetric for RoutingKind {
@@ -59,6 +59,12 @@ impl ApiEventMetric for RoutingRetrieveQuery {
     }
 }
 
+impl ApiEventMetric for SurchargeRetrieveQuery {
+    fn get_api_event_type(&self) -> Option<ApiEventsType> {
+        Some(ApiEventsType::Routing)
+    }
+}
+
 impl ApiEventMetric for RoutingConfigRequest {
     fn get_api_event_type(&self) -> Option<ApiEventsType> {
         Some(ApiEventsType::Routing)
@@ -71,6 +77,12 @@ impl ApiEventMetric for RoutingRetrieveLinkQuery {
     }
 }
 
+impl ApiEventMetric for SurchargeRetrieveLinkQuery {
+    fn get_api_event_type(&self) -> Option<ApiEventsType> {
+        Some(ApiEventsType::Routing)
+    }
+}
+
 impl ApiEventMetric for RoutingLinkWrapper {
     fn get_api_event_type(&self) -> Option<ApiEventsType> {
         Some(ApiEventsType::Routing)

crates/api_models/src/routing.rs

@@ -86,12 +86,23 @@ pub struct RoutingActivatePayload {
     pub transaction_type: Option<TransactionType>,
 }
 
+#[derive(Clone, Debug, serde::Deserialize, serde::Serialize)]
+pub struct SurchargeRetrieveQuery {
+    pub limit: Option<i64>,
+    pub offset: Option<i64>,
+}
+
 #[derive(Clone, Debug, serde::Deserialize, serde::Serialize)]
 pub struct RoutingRetrieveLinkQuery {
     pub profile_id: Option<common_utils::id_type::ProfileId>,
     pub transaction_type: Option<TransactionType>,
 }
 
+#[derive(Clone, Debug, serde::Deserialize, serde::Serialize)]
+pub struct SurchargeRetrieveLinkQuery {
+    pub profile_id: common_utils::id_type::ProfileId,
+}
+
 #[derive(Clone, Debug, serde::Deserialize, serde::Serialize)]
 pub struct RoutingRetrieveLinkQueryWrapper {
     pub routing_query: RoutingRetrieveQuery,

crates/api_models/src/surcharge_decision_configs.rs

@@ -59,12 +59,32 @@ impl events::ApiEventMetric for SurchargeDecisionManagerRecord {
         Some(events::ApiEventsType::Routing)
     }
 }
+
+#[derive(Debug, Clone, serde::Serialize, serde::Deserialize)]
+pub struct SurchargeRecord {
+    pub name: String,
+    pub algorithm_id: common_utils::id_type::SurchargeRoutingId,
+    pub merchant_surcharge_configs: MerchantSurchargeConfigs,
+    pub algorithm: Program<SurchargeDecisionConfigs>,
+    pub description: Option<String>,
+    #[serde(with = "common_utils::custom_serde::iso8601")]
+    pub created_at: time::PrimitiveDateTime,
+    #[serde(with = "common_utils::custom_serde::iso8601")]
+    pub modified_at: time::PrimitiveDateTime,
+}
+
+impl events::ApiEventMetric for SurchargeRecord {
+    fn get_api_event_type(&self) -> Option<events::ApiEventsType> {
+        Some(events::ApiEventsType::Routing)
+    }
+}
 #[derive(Debug, Clone, serde::Serialize, serde::Deserialize)]
 #[serde(deny_unknown_fields)]
 pub struct SurchargeDecisionConfigReq {
     pub name: Option<String>,
     pub merchant_surcharge_configs: MerchantSurchargeConfigs,
     pub algorithm: Option<Program<SurchargeDecisionConfigs>>,
+    pub description: Option<String>,
 }
 
 impl events::ApiEventMetric for SurchargeDecisionConfigReq {
@@ -73,9 +93,38 @@ impl events::ApiEventMetric for SurchargeDecisionConfigReq {
     }
 }
 
+#[derive(Debug, Clone, serde::Serialize, serde::Deserialize)]
+#[serde(deny_unknown_fields)]
+pub struct SurchargeDecisionManagerReq {
+    pub name: String,
+    pub merchant_surcharge_configs: MerchantSurchargeConfigs,
+    pub algorithm: Program<SurchargeDecisionConfigs>,
+    pub description: Option<String>,
+}
+
+impl events::ApiEventMetric for SurchargeDecisionManagerReq {
+    fn get_api_event_type(&self) -> Option<events::ApiEventsType> {
+        Some(events::ApiEventsType::Routing)
+    }
+}
+
+#[derive(Debug, Clone, serde::Serialize, serde::Deserialize)]
+#[serde(deny_unknown_fields)]
+pub struct SurchargeDecisionManagerConfig {
+    pub merchant_surcharge_configs: MerchantSurchargeConfigs,
+    pub algorithm: Program<SurchargeDecisionConfigs>,
+}
+
+impl events::ApiEventMetric for SurchargeDecisionManagerConfig {
+    fn get_api_event_type(&self) -> Option<events::ApiEventsType> {
+        Some(events::ApiEventsType::Routing)
+    }
+}
 #[derive(Debug, Default, Clone, serde::Serialize, serde::Deserialize)]
 pub struct MerchantSurchargeConfigs {
     pub show_surcharge_breakup_screen: Option<bool>,
 }
 
 pub type SurchargeDecisionManagerResponse = SurchargeDecisionManagerRecord;
+
+pub type SurchargeConfigResponse = SurchargeRecord;

crates/common_enums/src/enums.rs

@@ -7263,6 +7263,29 @@ impl TransactionType {
     }
 }
 
+#[derive(
+    Clone,
+    Copy,
+    Debug,
+    Eq,
+    PartialEq,
+    strum::Display,
+    strum::EnumString,
+    serde::Deserialize,
+    serde::Serialize,
+    ToSchema,
+    Default,
+)]
+#[router_derive::diesel_enum(storage_type = "text")]
+#[strum(serialize_all = "snake_case")]
+#[serde(rename_all = "snake_case")]
+pub enum AlgorithmType {
+    #[default]
+    Routing,
+    Surcharge,
+    ThreeDs,
+}
+
 #[derive(
     Clone,
     Copy,

crates/common_utils/src/consts.rs

@@ -183,6 +183,14 @@ pub const SOAP_ENV_NAMESPACE: &str = "http://schemas.xmlsoap.org/soap/envelope/"
 /// Length of generated tokens
 pub const TOKEN_LENGTH: usize = 32;
 
+/// Algorithm type for Routing
+pub const ALGORITHM_TYPE_ROUTING: common_enums::AlgorithmType =
+    common_enums::AlgorithmType::Routing;
+
+/// Algorithm Type for Surcharge
+pub const ALGORITHM_TYPE_SURCHARGE: common_enums::AlgorithmType =
+    common_enums::AlgorithmType::Surcharge;
+
 /// The tag name used for identifying the host in metrics.
 pub const METRICS_HOST_TAG_NAME: &str = "host";
 

crates/common_utils/src/id_type.rs

@@ -48,7 +48,7 @@ pub use self::{
     profile::ProfileId,
     refunds::RefundReferenceId,
     relay::RelayId,
-    routing::RoutingId,
+    routing::{RoutingId, SurchargeRoutingId},
     tenant::TenantId,
 };
 use crate::{fp_utils::when, generate_id_with_default_len};

crates/common_utils/src/id_type/routing.rs

@@ -1,3 +1,7 @@
+use std::ops::Deref;
+
+use crate::events::ApiEventMetric;
+
 crate::id_type!(
     RoutingId,
     " A type for routing_id that can be used for routing ids"
@@ -14,8 +18,76 @@ crate::impl_serializable_secret_id_type!(RoutingId);
 crate::impl_queryable_id_type!(RoutingId);
 crate::impl_to_sql_from_sql_id_type!(RoutingId);
 
-impl crate::events::ApiEventMetric for RoutingId {
+impl ApiEventMetric for RoutingId {
     fn get_api_event_type(&self) -> Option<crate::events::ApiEventsType> {
         Some(crate::events::ApiEventsType::Routing)
     }
 }
+
+#[derive(
+    Clone,
+    Hash,
+    Debug,
+    PartialEq,
+    Eq,
+    serde::Serialize,
+    serde::Deserialize,
+    diesel::expression::AsExpression,
+    utoipa::ToSchema,
+)]
+#[diesel(sql_type = diesel::sql_types::Text,)]
+#[schema(value_type = String)]
+/// A wrapper type for `RoutingId` that can be used for surcharge routing ids
+pub struct SurchargeRoutingId(RoutingId);
+
+impl SurchargeRoutingId {
+    /// Creates a new `SurchargeRoutingId` from a `RoutingId`
+    pub fn new(routing_id: RoutingId) -> Self {
+        Self(routing_id)
+    }
+
+    /// Returns the inner `RoutingId`
+    pub fn inner(&self) -> &RoutingId {
+        &self.0
+    }
+}
+
+impl Deref for SurchargeRoutingId {
+    type Target = RoutingId;
+
+    fn deref(&self) -> &Self::Target {
+        &self.0
+    }
+}
+
+impl ApiEventMetric for SurchargeRoutingId {
+    fn get_api_event_type(&self) -> Option<crate::events::ApiEventsType> {
+        Some(crate::events::ApiEventsType::Routing)
+    }
+}
+crate::impl_serializable_secret_id_type!(SurchargeRoutingId);
+crate::impl_queryable_id_type!(SurchargeRoutingId);
+
+impl<DB> diesel::serialize::ToSql<diesel::sql_types::Text, DB> for SurchargeRoutingId
+where
+    DB: diesel::backend::Backend,
+    RoutingId: diesel::serialize::ToSql<diesel::sql_types::Text, DB>,
+{
+    fn to_sql<'b>(
+        &'b self,
+        out: &mut diesel::serialize::Output<'b, '_, DB>,
+    ) -> diesel::serialize::Result {
+        self.0.to_sql(out)
+    }
+}
+
+impl<DB> diesel::deserialize::FromSql<diesel::sql_types::Text, DB> for SurchargeRoutingId
+where
+    DB: diesel::backend::Backend,
+    RoutingId: diesel::deserialize::FromSql<diesel::sql_types::Text, DB>,
+{
+    fn from_sql(value: DB::RawValue<'_>) -> diesel::deserialize::Result<Self> {
+        let val = RoutingId::from_sql(value)?;
+        Ok(Self(val))
+    }
+}