refactor: cargo hack

Author: kashif-m

crates/api_models/src/routing.rs

@@ -539,6 +539,7 @@ pub struct RoutingDictionaryRecord {
     pub description: String,
     pub created_at: i64,
     pub modified_at: i64,
+    pub algorithm_for: Option<TransactionType>,
 }
 
 #[derive(Debug, Clone, serde::Serialize, serde::Deserialize, ToSchema)]

crates/router/src/core/admin.rs

@@ -4,7 +4,6 @@ use api_models::{
     admin::{self as admin_types},
     enums as api_enums, routing as routing_types,
 };
-use common_enums::{ConnectorType, TransactionType};
 use common_utils::{
     crypto::{generate_cryptographically_secure_random_string, OptionalSecretValue},
     date_time,
@@ -949,8 +948,9 @@ pub async fn create_payment_connector(
     };
 
     let transaction_type = match req.connector_type {
-        ConnectorType::PayoutProcessor => TransactionType::Payout,
-        _ => TransactionType::Payment,
+        #[cfg(feature = "payouts")]
+        api_enums::ConnectorType::PayoutProcessor => api_enums::TransactionType::Payout,
+        _ => api_enums::TransactionType::Payment,
     };
 
     let mut default_routing_config =

crates/router/src/core/payments/routing.rs

@@ -637,6 +637,7 @@ pub async fn refresh_kgraph_cache(
                     && mca.connector_type != storage_enums::ConnectorType::PayoutProcessor
             });
         }
+        #[cfg(feature = "payouts")]
         api_enums::TransactionType::Payout => {
             merchant_connector_accounts
                 .retain(|mca| mca.connector_type == storage_enums::ConnectorType::PayoutProcessor);

crates/router/src/core/routing.rs

@@ -98,7 +98,7 @@ pub async fn create_routing_config(
     merchant_account: domain::MerchantAccount,
     key_store: domain::MerchantKeyStore,
     request: routing_types::RoutingConfigRequest,
-    #[cfg(feature = "business_profile_routing")] transaction_type: &enums::TransactionType,
+    transaction_type: &enums::TransactionType,
 ) -> RouterResponse<routing_types::RoutingDictionaryRecord> {
     metrics::ROUTING_CREATE_REQUEST_RECEIVED.add(&metrics::CONTEXT, 1, &[]);
     let db = state.store.as_ref();
@@ -217,6 +217,7 @@ pub async fn create_routing_config(
             description: description.clone(),
             created_at: timestamp,
             modified_at: timestamp,
+            algorithm_for: Some(*transaction_type),
         };
         merchant_dictionary.records.push(new_record.clone());
 
@@ -441,7 +442,9 @@ pub async fn retrieve_routing_config(
             algorithm,
             created_at: record.created_at,
             modified_at: record.modified_at,
-            algorithm_for: record.algorithm_for,
+            algorithm_for: record
+                .algorithm_for
+                .unwrap_or(enums::TransactionType::Payment),
         };
 
         metrics::ROUTING_RETRIEVE_CONFIG_SUCCESS_RESPONSE.add(&metrics::CONTEXT, 1, &[]);
@@ -799,7 +802,9 @@ pub async fn retrieve_linked_routing_config(
                 algorithm: the_algorithm,
                 created_at: record.created_at,
                 modified_at: record.modified_at,
-                algorithm_for: record.algorithm_for,
+                algorithm_for: record
+                    .algorithm_for
+                    .unwrap_or(enums::TransactionType::Payment),
             })
         } else {
             None

crates/router/src/core/routing/helpers.rs

@@ -476,7 +476,7 @@ pub fn get_default_config_key(
 ) -> String {
     match transaction_type {
         storage::enums::TransactionType::Payment => format!("routing_default_{merchant_id}"),
-
+        #[cfg(feature = "payouts")]
         storage::enums::TransactionType::Payout => format!("routing_default_po_{merchant_id}"),
     }
 }

crates/router/src/core/routing/transformers.rs

@@ -20,11 +20,11 @@ impl ForeignFrom<RoutingProfileMetadata> for RoutingDictionaryRecord {
             #[cfg(feature = "business_profile_routing")]
             profile_id: value.profile_id,
             name: value.name,
-
             kind: value.kind.foreign_into(),
             description: value.description.unwrap_or_default(),
             created_at: value.created_at.assume_utc().unix_timestamp(),
             modified_at: value.modified_at.assume_utc().unix_timestamp(),
+            algorithm_for: Some(value.algorithm_for),
         }
     }
 }
@@ -40,6 +40,7 @@ impl ForeignFrom<RoutingAlgorithm> for RoutingDictionaryRecord {
             description: value.description.unwrap_or_default(),
             created_at: value.created_at.assume_utc().unix_timestamp(),
             modified_at: value.modified_at.assume_utc().unix_timestamp(),
+            algorithm_for: Some(value.algorithm_for),
         }
     }
 }

crates/router/src/routes/app.rs

@@ -8,7 +8,7 @@ use actix_web::{web, Scope};
 use analytics::AnalyticsConfig;
 #[cfg(all(feature = "business_profile_routing", feature = "olap"))]
 use api_models::routing::RoutingRetrieveQuery;
-#[cfg(any(feature = "olap", feature = "payouts"))]
+#[cfg(feature = "olap")]
 use common_enums::TransactionType;
 #[cfg(feature = "aws_kms")]
 use external_services::aws_kms::{self, decrypt::AwsKmsDecrypt};
@@ -500,7 +500,6 @@ impl Routing {
                             state,
                             req,
                             payload,
-                            #[cfg(feature = "business_profile_routing")]
                             &TransactionType::Payment,
                         )
                     })),
@@ -596,7 +595,6 @@ impl Routing {
                                 state,
                                 req,
                                 payload,
-                                #[cfg(feature = "business_profile_routing")]
                                 &TransactionType::Payout,
                             )
                         })),

crates/router/src/routes/routing.rs

@@ -23,7 +23,7 @@ pub async fn routing_create_config(
     state: web::Data<AppState>,
     req: HttpRequest,
     json_payload: web::Json<routing_types::RoutingConfigRequest>,
-    #[cfg(feature = "business_profile_routing")] transaction_type: &enums::TransactionType,
+    transaction_type: &enums::TransactionType,
 ) -> impl Responder {
     let flow = Flow::RoutingCreateConfig;
     Box::pin(oss_api::server_wrap(
@@ -37,7 +37,6 @@ pub async fn routing_create_config(
                 auth.merchant_account,
                 auth.key_store,
                 payload,
-                #[cfg(feature = "business_profile_routing")]
                 transaction_type,
             )
         },

openapi/openapi_spec.json

@@ -15707,6 +15707,14 @@
           "modified_at": {
             "type": "integer",
             "format": "int64"
+          },
+          "algorithm_for": {
+            "allOf": [
+              {
+                "$ref": "#/components/schemas/TransactionType"
+              }
+            ],
+            "nullable": true
           }
         }
       },