feat: Implement UCS granular flows with gateway context refactoring

crates/external_services/Cargo.toml

@@ -69,7 +69,7 @@ reqwest = { version = "0.11.27", features = ["rustls-tls"] }
 http = "0.2.12"
 url = { version = "2.5.4", features = ["serde"] }
 quick-xml = { version = "0.31.0", features = ["serialize"] }
-unified-connector-service-client = { git = "https://github.com/juspay/connector-service", rev = "b5a367c1c775c32503feb00cdc6cd063cc97ea3b", package = "rust-grpc-client" }
+unified-connector-service-client = { git = "https://github.com/juspay/connector-service", rev = "7f28be871568f5937975a99bde14ce47736fd81e", package = "rust-grpc-client" }
 open-feature = { version = "0.2.5", optional = true }
 superposition_provider = { version = "0.88.1", optional = true }
 

crates/hyperswitch_connectors/src/connectors/nuvei.rs

@@ -1585,4 +1585,8 @@ impl ConnectorSpecifications for Nuvei {
     fn get_supported_webhook_flows(&self) -> Option<&'static [enums::EventClass]> {
         Some(&NUVEI_SUPPORTED_WEBHOOK_FLOWS)
     }
+
+    fn is_authorize_session_token_call_required(&self) -> bool {
+        true
+    }
 }

crates/hyperswitch_connectors/src/connectors/paytm.rs

@@ -643,4 +643,8 @@ impl ConnectorSpecifications for Paytm {
     fn get_supported_webhook_flows(&self) -> Option<&'static [enums::EventClass]> {
         Some(&*PAYTM_SUPPORTED_WEBHOOK_FLOWS)
     }
+
+    fn is_authorize_session_token_call_required(&self) -> bool {
+        true
+    }
 }

crates/hyperswitch_connectors/src/connectors/square.rs

@@ -1000,4 +1000,7 @@ impl ConnectorSpecifications for Square {
     fn get_supported_webhook_flows(&self) -> Option<&'static [enums::EventClass]> {
         Some(&*SQUARE_SUPPORTED_WEBHOOK_FLOWS)
     }
+    fn is_authorize_session_token_call_required(&self) -> bool {
+        true
+    }
 }

crates/hyperswitch_domain_models/src/router_flow_types/access_token_auth.rs

@@ -1,5 +1,6 @@
+use serde;
 #[derive(Clone, Debug)]
 pub struct AccessTokenAuthentication;
 
-#[derive(Clone, Debug)]
+#[derive(Clone, Debug, serde::Serialize)]
 pub struct AccessTokenAuth;

crates/hyperswitch_domain_models/src/router_request_types.rs

@@ -1190,7 +1190,7 @@ impl TryFrom<router_data::ConnectorAuthType> for AccessTokenAuthenticationReques
     }
 }
 
-#[derive(Debug, Clone)]
+#[derive(Debug, Clone, Serialize)]
 pub struct AccessTokenRequestData {
     pub app_id: Secret<String>,
     pub id: Option<Secret<String>>,

crates/hyperswitch_interfaces/Cargo.toml

@@ -29,8 +29,8 @@ serde_json = "1.0.140"
 strum = { version = "0.26", features = ["derive"] }
 thiserror = "1.0.69"
 time = "0.3.41"
-unified-connector-service-client = { git = "https://github.com/juspay/connector-service", rev = "b5a367c1c775c32503feb00cdc6cd063cc97ea3b", package = "rust-grpc-client" }
-unified-connector-service-masking = { git = "https://github.com/juspay/hyperswitch", tag = "2025.09.24.0", package = "masking" }
+unified-connector-service-client = { git = "https://github.com/juspay/connector-service", rev = "7f28be871568f5937975a99bde14ce47736fd81e", package = "rust-grpc-client" }
+unified-connector-service-masking = { git = "https://github.com/juspay/hyperswitch", tag = "2025.11.24.0", package = "masking" }
 tokio = { version = "1.45.1", features = ["macros", "rt-multi-thread"] }
 # First party crates
 hyperswitch_domain_models = { version = "0.1.0", path = "../hyperswitch_domain_models", default-features = false }

crates/hyperswitch_interfaces/src/api.rs

@@ -542,6 +542,11 @@ pub trait ConnectorSpecifications {
             .unwrap_or_else(|| payment_attempt.id.get_string_repr().to_owned())
     }
 
+    /// Is Authorize session token required before authorize
+    fn is_authorize_session_token_call_required(&self) -> bool {
+        false
+    }
+
     #[cfg(feature = "v1")]
     /// Generate connector customer reference ID for payments
     fn generate_connector_customer_id(

crates/hyperswitch_interfaces/src/connector_integration_interface.rs

@@ -636,6 +636,14 @@ impl ConnectorSpecifications for ConnectorEnum {
         }
     }
 
+    /// Check if the connector needs authorize session token call
+    fn is_authorize_session_token_call_required(&self) -> bool {
+        match self {
+            Self::Old(connector) => connector.is_authorize_session_token_call_required(),
+            Self::New(connector) => connector.is_authorize_session_token_call_required(),
+        }
+    }
+
     #[cfg(feature = "v1")]
     fn generate_connector_request_reference_id(
         &self,

crates/router/Cargo.toml

@@ -89,9 +89,9 @@ reqwest = { version = "0.11.27", features = ["json", "rustls-tls", "gzip", "mult
 ring = "0.17.14"
 rust_decimal = { version = "1.37.1", features = ["serde-with-float", "serde-with-str"] }
 rust-i18n = { git = "https://github.com/kashif-m/rust-i18n", rev = "f2d8096aaaff7a87a847c35a5394c269f75e077a" }
-unified-connector-service-client = { git = "https://github.com/juspay/connector-service", rev = "b5a367c1c775c32503feb00cdc6cd063cc97ea3b", package = "rust-grpc-client" }
-unified-connector-service-cards = { git = "https://github.com/juspay/connector-service", rev = "b5a367c1c775c32503feb00cdc6cd063cc97ea3b", package = "ucs_cards" }
-unified-connector-service-masking = { git = "https://github.com/juspay/hyperswitch", tag = "2025.09.24.0", package = "masking" }
+unified-connector-service-client = { git = "https://github.com/juspay/connector-service", rev = "7f28be871568f5937975a99bde14ce47736fd81e", package = "rust-grpc-client" }
+unified-connector-service-cards = { git = "https://github.com/juspay/connector-service", rev = "7f28be871568f5937975a99bde14ce47736fd81e", package = "ucs_cards" }
+unified-connector-service-masking = { git = "https://github.com/juspay/hyperswitch", tag = "2025.11.24.0", package = "masking" }
 rustc-hash = "1.1.0"
 rustls = "0.22"
 rustls-pemfile = "2"