fix(connector): send valid sdk information in authentication flow netcetera (#4474)

Author: hrithikesh026

crates/diesel_models/src/schema.rs

@@ -82,8 +82,7 @@ diesel::table! {
         authentication_lifecycle_status -> Varchar,
         created_at -> Timestamp,
         modified_at -> Timestamp,
-        #[max_length = 64]
-        error_message -> Nullable<Varchar>,
+        error_message -> Nullable<Text>,
         #[max_length = 64]
         error_code -> Nullable<Varchar>,
         connector_metadata -> Nullable<Jsonb>,

crates/router/src/connector/netcetera/netcetera_types.rs

@@ -3,7 +3,11 @@ use std::collections::HashMap;
 use common_utils::pii::Email;
 use serde::{Deserialize, Serialize};
 
-use crate::types::api::MessageCategory;
+use crate::{
+    connector::utils::{AddressDetailsData, PhoneDetailsData},
+    errors,
+    types::api::MessageCategory,
+};
 
 #[derive(Debug, Deserialize, Serialize, Clone)]
 #[serde(untagged)]
@@ -679,18 +683,19 @@ pub struct Cardholder {
 }
 
 impl
-    From<(
+    TryFrom<(
         api_models::payments::Address,
         Option<api_models::payments::Address>,
     )> for Cardholder
 {
-    fn from(
+    type Error = error_stack::Report<errors::ConnectorError>;
+    fn try_from(
         (billing_address, shipping_address): (
             api_models::payments::Address,
             Option<api_models::payments::Address>,
         ),
-    ) -> Self {
-        Self {
+    ) -> Result<Self, Self::Error> {
+        Ok(Self {
             addr_match: None,
             bill_addr_city: billing_address
                 .address
@@ -716,11 +721,24 @@ impl
             bill_addr_state: billing_address
                 .address
                 .as_ref()
-                .and_then(|add| add.state.clone()),
+                .and_then(|add| add.to_state_code_as_optional().transpose())
+                .transpose()?,
             email: billing_address.email,
-            home_phone: billing_address.phone.clone().map(Into::into),
-            mobile_phone: billing_address.phone.clone().map(Into::into),
-            work_phone: billing_address.phone.clone().map(Into::into),
+            home_phone: billing_address
+                .phone
+                .clone()
+                .map(PhoneNumber::try_from)
+                .transpose()?,
+            mobile_phone: billing_address
+                .phone
+                .clone()
+                .map(PhoneNumber::try_from)
+                .transpose()?,
+            work_phone: billing_address
+                .phone
+                .clone()
+                .map(PhoneNumber::try_from)
+                .transpose()?,
             cardholder_name: billing_address
                 .address
                 .as_ref()
@@ -749,9 +767,10 @@ impl
             ship_addr_state: shipping_address
                 .as_ref()
                 .and_then(|shipping_add| shipping_add.address.as_ref())
-                .and_then(|add| add.state.clone()),
+                .and_then(|add| add.to_state_code_as_optional().transpose())
+                .transpose()?,
             tax_id: None,
-        }
+        })
     }
 }
 
@@ -764,12 +783,13 @@ pub struct PhoneNumber {
     subscriber: Option<masking::Secret<String>>,
 }
 
-impl From<api_models::payments::PhoneDetails> for PhoneNumber {
-    fn from(value: api_models::payments::PhoneDetails) -> Self {
-        Self {
-            country_code: value.country_code,
+impl TryFrom<api_models::payments::PhoneDetails> for PhoneNumber {
+    type Error = error_stack::Report<errors::ConnectorError>;
+    fn try_from(value: api_models::payments::PhoneDetails) -> Result<Self, Self::Error> {
+        Ok(Self {
+            country_code: Some(value.extract_country_code()?),
             subscriber: value.number,
-        }
+        })
     }
 }
 
@@ -1377,6 +1397,7 @@ pub struct Sdk {
     ///
     /// Starting from EMV 3DS 2.3.1:
     /// In case of Browser-SDK, the SDK App ID value is not reliable, and may change for each transaction.
+    #[serde(rename = "sdkAppID")]
     sdk_app_id: Option<String>,
 
     /// JWE Object as defined Section 6.2.2.1 containing data encrypted by the SDK for the DS to decrypt. This element is
@@ -1404,6 +1425,7 @@ pub struct Sdk {
     /// Universally unique transaction identifier assigned by the 3DS SDK to identify a single transaction. The field is
     /// limited to 36 characters and it shall be in a canonical format as defined in IETF RFC 4122. This may utilize any of
     /// the specified versions as long as the output meets specific requirements.
+    #[serde(rename = "sdkTransID")]
     sdk_trans_id: Option<String>,
 
     /// Contains the JWS object(represented as a string) created by the Split-SDK Server for the AReq message. A
@@ -1587,3 +1609,35 @@ pub enum ThreeDSReqAuthMethod {
     #[serde(untagged)]
     PsSpecificValue(String),
 }
+
+#[derive(Serialize, Deserialize, Debug, Clone)]
+#[serde(rename_all = "camelCase")]
+pub struct DeviceRenderingOptionsSupported {
+    pub sdk_interface: SdkInterface,
+    /// For Native UI SDK Interface accepted values are 01-04 and for HTML UI accepted values are 01-05.
+    pub sdk_ui_type: Vec<SdkUiType>,
+}
+
+#[derive(Serialize, Deserialize, Debug, Clone)]
+pub enum SdkInterface {
+    #[serde(rename = "01")]
+    Native,
+    #[serde(rename = "02")]
+    Html,
+    #[serde(rename = "03")]
+    Both,
+}
+
+#[derive(Serialize, Deserialize, Debug, Clone)]
+pub enum SdkUiType {
+    #[serde(rename = "01")]
+    Text,
+    #[serde(rename = "02")]
+    SingleSelect,
+    #[serde(rename = "03")]
+    MultiSelect,
+    #[serde(rename = "04")]
+    Oob,
+    #[serde(rename = "05")]
+    HtmlOther,
+}

crates/router/src/connector/netcetera/transformers.rs

@@ -154,7 +154,9 @@ impl
                                     .acs_reference_number,
                                 acs_trans_id: response.authentication_response.acs_trans_id,
                                 three_dsserver_trans_id: Some(response.three_ds_server_trans_id),
-                                acs_signed_content: None,
+                                acs_signed_content: response
+                                    .authentication_response
+                                    .acs_signed_content,
                             },
                         ))
                     }
@@ -430,7 +432,7 @@ pub struct NetceteraAuthenticationRequest {
     pub acquirer: Option<netcetera_types::AcquirerData>,
     pub merchant: Option<netcetera_types::MerchantData>,
     pub broad_info: Option<String>,
-    pub device_render_options: Option<String>,
+    pub device_render_options: Option<netcetera_types::DeviceRenderingOptionsSupported>,
     pub message_extension: Option<Vec<netcetera_types::MessageExtensionAttribute>>,
     pub challenge_message_extension: Option<Vec<netcetera_types::MessageExtensionAttribute>>,
     pub browser_information: Option<netcetera_types::Browser>,
@@ -552,6 +554,22 @@ impl TryFrom<&NetceteraRouterData<&types::authentication::ConnectorAuthenticatio
         };
         let browser_information = request.browser_details.map(netcetera_types::Browser::from);
         let sdk_information = request.sdk_information.map(netcetera_types::Sdk::from);
+        let device_render_options = match request.device_channel {
+            api_models::payments::DeviceChannel::App => {
+                Some(netcetera_types::DeviceRenderingOptionsSupported {
+                    // hard-coded until core provides these values.
+                    sdk_interface: netcetera_types::SdkInterface::Both,
+                    sdk_ui_type: vec![
+                        netcetera_types::SdkUiType::Text,
+                        netcetera_types::SdkUiType::SingleSelect,
+                        netcetera_types::SdkUiType::MultiSelect,
+                        netcetera_types::SdkUiType::Oob,
+                        netcetera_types::SdkUiType::HtmlOther,
+                    ],
+                })
+            }
+            api_models::payments::DeviceChannel::Browser => None,
+        };
         Ok(Self {
             preferred_protocol_version: Some(pre_authn_data.message_version),
             enforce_preferred_protocol_version: None,
@@ -567,15 +585,15 @@ impl TryFrom<&NetceteraRouterData<&types::authentication::ConnectorAuthenticatio
             three_ds_server_trans_id: pre_authn_data.threeds_server_transaction_id,
             three_ds_requestor_url: Some(request.three_ds_requestor_url),
             cardholder_account,
-            cardholder: Some(netcetera_types::Cardholder::from((
+            cardholder: Some(netcetera_types::Cardholder::try_from((
                 request.billing_address,
                 request.shipping_address,
-            ))),
+            ))?),
             purchase: Some(purchase),
             acquirer: Some(acquirer_details),
             merchant: Some(merchant_data),
             broad_info: None,
-            device_render_options: None,
+            device_render_options,
             message_extension: None,
             challenge_message_extension: None,
             browser_information,
@@ -625,6 +643,7 @@ pub struct AuthenticationResponse {
     pub acs_reference_number: Option<String>,
     #[serde(rename = "acsTransID")]
     pub acs_trans_id: Option<String>,
+    pub acs_signed_content: Option<String>,
 }
 
 #[derive(Debug, Deserialize, Serialize, Clone)]

crates/router/src/connector/utils.rs

@@ -1216,6 +1216,7 @@ pub trait PhoneDetailsData {
     fn get_country_code(&self) -> Result<String, Error>;
     fn get_number_with_country_code(&self) -> Result<Secret<String>, Error>;
     fn get_number_with_hash_country_code(&self) -> Result<Secret<String>, Error>;
+    fn extract_country_code(&self) -> Result<String, Error>;
 }
 
 impl PhoneDetailsData for api::PhoneDetails {
@@ -1224,6 +1225,10 @@ impl PhoneDetailsData for api::PhoneDetails {
             .clone()
             .ok_or_else(missing_field_err("billing.phone.country_code"))
     }
+    fn extract_country_code(&self) -> Result<String, Error> {
+        self.get_country_code()
+            .map(|cc| cc.trim_start_matches('+').to_string())
+    }
     fn get_number(&self) -> Result<Secret<String>, Error> {
         self.number
             .clone()
@@ -1258,6 +1263,7 @@ pub trait AddressDetailsData {
     fn get_country(&self) -> Result<&api_models::enums::CountryAlpha2, Error>;
     fn get_combined_address_line(&self) -> Result<Secret<String>, Error>;
     fn to_state_code(&self) -> Result<Secret<String>, Error>;
+    fn to_state_code_as_optional(&self) -> Result<Option<Secret<String>>, Error>;
 }
 
 impl AddressDetailsData for api::AddressDetails {
@@ -1341,6 +1347,18 @@ impl AddressDetailsData for api::AddressDetails {
             _ => Ok(state.clone()),
         }
     }
+    fn to_state_code_as_optional(&self) -> Result<Option<Secret<String>>, Error> {
+        self.state
+            .as_ref()
+            .map(|state| {
+                if state.peek().len() == 2 {
+                    Ok(state.to_owned())
+                } else {
+                    self.to_state_code()
+                }
+            })
+            .transpose()
+    }
 }
 
 pub trait BankRedirectBillingData {

migrations/2024-04-28-095920_make_error_message_field_text/down.sql

@@ -0,0 +1,2 @@
+-- This file should undo anything in `up.sql`
+ALTER TABLE authentication ALTER COLUMN error_message TYPE VARCHAR(64);

migrations/2024-04-28-095920_make_error_message_field_text/up.sql

@@ -0,0 +1,2 @@
+-- Your SQL goes here
+ALTER TABLE authentication ALTER COLUMN error_message TYPE TEXT;