feat(connector): implement authentication flow for netcetera

config/deployments/production.toml

@@ -85,6 +85,7 @@ zen.base_url = "https://api.zen.com/"
 zen.secondary_base_url = "https://secure.zen.com/"
 zsl.base_url = "https://api.sitoffalb.net/"
 threedsecureio.base_url = "https://service.3dsecure.io"
+netcetera.base_url = "https://{{merchant_endpoint_prefix}}.3ds-server.prev.netcetera-cloud-payment.ch"
 
 [delayed_session_response]
 connectors_with_delayed_session_response = "trustpay,payme"

crates/common_enums/src/enums.rs

@@ -1035,6 +1035,16 @@ impl Currency {
             | Self::ZMW => false,
         }
     }
+
+    pub fn number_of_digits_after_decimal_point(self) -> u8 {
+        if self.is_zero_decimal_currency() {
+            0
+        } else if self.is_three_decimal_currency() {
+            3
+        } else {
+            2
+        }
+    }
 }
 
 #[derive(

crates/common_utils/src/lib.rs

@@ -43,6 +43,8 @@ pub mod date_time {
         YYYYMMDDHHmmss,
         /// Format the date in 20191105 format
         YYYYMMDD,
+        /// Format the date in 201911050811 format
+        YYYYMMDDHHmm,
     }
 
     /// Create a new [`PrimitiveDateTime`] with the current date and time in UTC.
@@ -95,6 +97,7 @@ pub mod date_time {
             match format {
                 DateFormat::YYYYMMDDHHmmss => time::macros::format_description!("[year repr:full][month padding:zero repr:numerical][day padding:zero][hour padding:zero repr:24][minute padding:zero][second padding:zero]"),
                 DateFormat::YYYYMMDD => time::macros::format_description!("[year repr:full][month padding:zero repr:numerical][day padding:zero]"),
+                DateFormat::YYYYMMDDHHmm => time::macros::format_description!("[year repr:full][month padding:zero repr:numerical][day padding:zero][hour padding:zero repr:24][minute padding:zero]"),
             }
         }
     }

crates/router/src/connector/netcetera.rs

@@ -1,3 +1,4 @@
+pub mod netcetera_types;
 pub mod transformers;
 
 use std::fmt::Debug;
@@ -9,7 +10,6 @@ use transformers as netcetera;
 
 use crate::{
     configs::settings,
-    consts,
     core::errors::{self, CustomResult},
     events::connector_api_logs::ConnectorEvent,
     headers,
@@ -107,11 +107,8 @@ impl ConnectorCommon for Netcetera {
         Ok(ErrorResponse {
             status_code: res.status_code,
             code: response.error_details.error_code,
-            message: response
-                .error_details
-                .error_description
-                .unwrap_or(consts::NO_ERROR_MESSAGE.into()),
-            reason: response.error_details.error_detail,
+            message: response.error_details.error_description,
+            reason: Some(response.error_details.error_detail),
             attempt_status: None,
             connector_transaction_id: None,
         })
@@ -123,7 +120,6 @@ impl ConnectorValidation for Netcetera {}
 impl ConnectorIntegration<api::Session, types::PaymentsSessionData, types::PaymentsResponseData>
     for Netcetera
 {
-    //TODO: implement sessions flow
 }
 
 impl ConnectorIntegration<api::AccessTokenAuth, types::AccessTokenRequestData, types::AccessToken>
@@ -313,6 +309,110 @@ impl
         types::authentication::AuthenticationResponseData,
     > for Netcetera
 {
+    fn get_headers(
+        &self,
+        req: &types::authentication::ConnectorAuthenticationRouterData,
+        connectors: &settings::Connectors,
+    ) -> CustomResult<Vec<(String, request::Maskable<String>)>, errors::ConnectorError> {
+        self.build_headers(req, connectors)
+    }
+
+    fn get_content_type(&self) -> &'static str {
+        self.common_get_content_type()
+    }
+
+    fn get_url(
+        &self,
+        req: &types::authentication::ConnectorAuthenticationRouterData,
+        connectors: &settings::Connectors,
+    ) -> CustomResult<String, errors::ConnectorError> {
+        let base_url = build_endpoint(self.base_url(connectors), &req.connector_meta_data)?;
+        Ok(format!("{}/3ds/authentication", base_url,))
+    }
+
+    fn get_request_body(
+        &self,
+        req: &types::authentication::ConnectorAuthenticationRouterData,
+        _connectors: &settings::Connectors,
+    ) -> CustomResult<RequestContent, errors::ConnectorError> {
+        let connector_router_data = netcetera::NetceteraRouterData::try_from((
+            &self.get_currency_unit(),
+            req.request
+                .currency
+                .ok_or(errors::ConnectorError::MissingRequiredField {
+                    field_name: "currency",
+                })?,
+            req.request
+                .amount
+                .ok_or(errors::ConnectorError::MissingRequiredField {
+                    field_name: "amount",
+                })?,
+            req,
+        ))?;
+        let req_obj = netcetera::NetceteraAuthenticationRequest::try_from(&connector_router_data);
+        Ok(RequestContent::Json(Box::new(req_obj?)))
+    }
+
+    fn build_request(
+        &self,
+        req: &types::authentication::ConnectorAuthenticationRouterData,
+        connectors: &settings::Connectors,
+    ) -> CustomResult<Option<services::Request>, errors::ConnectorError> {
+        let netcetera_auth_type = netcetera::NetceteraAuthType::try_from(&req.connector_auth_type)?;
+        Ok(Some(
+            services::RequestBuilder::new()
+                .method(services::Method::Post)
+                .url(
+                    &types::authentication::ConnectorAuthenticationType::get_url(
+                        self, req, connectors,
+                    )?,
+                )
+                .attach_default_headers()
+                .headers(
+                    types::authentication::ConnectorAuthenticationType::get_headers(
+                        self, req, connectors,
+                    )?,
+                )
+                .set_body(
+                    types::authentication::ConnectorAuthenticationType::get_request_body(
+                        self, req, connectors,
+                    )?,
+                )
+                .add_certificate(Some(netcetera_auth_type.certificate.expose()))
+                .add_certificate_key(Some(netcetera_auth_type.private_key.expose()))
+                .build(),
+        ))
+    }
+
+    fn handle_response(
+        &self,
+        data: &types::authentication::ConnectorAuthenticationRouterData,
+        event_builder: Option<&mut ConnectorEvent>,
+        res: Response,
+    ) -> CustomResult<
+        types::authentication::ConnectorAuthenticationRouterData,
+        errors::ConnectorError,
+    > {
+        let response: netcetera::NetceteraAuthenticationResponse = res
+            .response
+            .parse_struct("NetceteraAuthenticationResponse")
+            .change_context(errors::ConnectorError::ResponseDeserializationFailed)?;
+        event_builder.map(|i| i.set_response_body(&response));
+        router_env::logger::info!(connector_response=?response);
+        types::RouterData::try_from(types::ResponseRouterData {
+            response,
+            data: data.clone(),
+            http_code: res.status_code,
+        })
+    }
+
+    fn get_error_response(
+        &self,
+        res: Response,
+        event_builder: Option<&mut ConnectorEvent>,
+    ) -> CustomResult<ErrorResponse, errors::ConnectorError> {
+        self.build_error_response(res, event_builder)
+    }
 }
 
 impl