feat(connector): [Authorizedotnet] Add Wallet support

crates/router/src/connector/authorizedotnet.rs

@@ -10,12 +10,15 @@ use transformers as authorizedotnet;
 use crate::{
  configs::settings,
  consts,
- core::errors::{self, CustomResult},
+ core::{
+ errors::{self, CustomResult},
+ payments,
+ },
  headers,
  services::{self, request, ConnectorIntegration},
  types::{
  self,
- api::{self, ConnectorCommon, ConnectorCommonExt},
+ api::{self, ConnectorCommon, ConnectorCommonExt, PaymentsCompleteAuthorize},
  },
  utils::{self, BytesExt},
 };
@@ -192,7 +195,7 @@ impl ConnectorIntegration<api::PSync, types::PaymentsSyncData, types::PaymentsRe
  }
 
  fn get_content_type(&self) -> &'static str {
- "application/json"
+ self.common_get_content_type()
  }
 
  fn get_url(
@@ -545,7 +548,7 @@ impl ConnectorIntegration<api::RSync, types::RefundsData, types::RefundsResponse
  }
 
  fn get_content_type(&self) -> &'static str {
- "application/json"
+ self.common_get_content_type()
  }
 
  fn get_url(
@@ -600,6 +603,100 @@ impl ConnectorIntegration<api::RSync, types::RefundsData, types::RefundsResponse
  let response: authorizedotnet::AuthorizedotnetSyncResponse = intermediate_response
  .parse_struct("AuthorizedotnetSyncResponse")
  .change_context(errors::ConnectorError::ResponseDeserializationFailed)?;
+ types::RouterData::try_from(types::ResponseRouterData {
+ response,
+ data: data.clone(),
+ http_code: res.status_code,
+ })
+ }
+
+ fn get_error_response(
+ &self,
+ res: types::Response,
+ ) -> CustomResult<types::ErrorResponse, errors::ConnectorError> {
+ get_error_response(res)
+ }
+}
+
+impl PaymentsCompleteAuthorize for Authorizedotnet {}
+
+impl
+ ConnectorIntegration<
+ api::CompleteAuthorize,
+ types::CompleteAuthorizeData,
+ types::PaymentsResponseData,
+ > for Authorizedotnet
+{
+ fn get_headers(
+ &self,
+ req: &types::PaymentsCompleteAuthorizeRouterData,
+ 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::PaymentsCompleteAuthorizeRouterData,
+ connectors: &settings::Connectors,
+ ) -> CustomResult<String, errors::ConnectorError> {
+ Ok(self.base_url(connectors).to_string())
+ }
+ fn get_request_body(
+ &self,
+ req: &types::PaymentsCompleteAuthorizeRouterData,
+ ) -> CustomResult<Option<types::RequestBody>, errors::ConnectorError> {
+ let connector_req = authorizedotnet::PaypalConfirmRequest::try_from(req)?;
+ let authorizedotnet_req = types::RequestBody::log_and_get_request_body(
+ &connector_req,
+ utils::Encode::<authorizedotnet::PaypalConfirmRequest>::encode_to_string_of_json,
+ )
+ .change_context(errors::ConnectorError::RequestEncodingFailed)?;
+ Ok(Some(authorizedotnet_req))
+ }
+
+ fn build_request(
+ &self,
+ req: &types::PaymentsCompleteAuthorizeRouterData,
+ connectors: &settings::Connectors,
+ ) -> CustomResult<Option<services::Request>, errors::ConnectorError> {
+ Ok(Some(
+ services::RequestBuilder::new()
+ .method(services::Method::Post)
+ .url(&types::PaymentsCompleteAuthorizeType::get_url(
+ self, req, connectors,
+ )?)
+ .attach_default_headers()
+ .headers(types::PaymentsCompleteAuthorizeType::get_headers(
+ self, req, connectors,
+ )?)
+ .body(types::PaymentsCompleteAuthorizeType::get_request_body(
+ self, req,
+ )?)
+ .build(),
+ ))
+ }
+
+ fn handle_response(
+ &self,
+ data: &types::PaymentsCompleteAuthorizeRouterData,
+ res: types::Response,
+ ) -> CustomResult<types::PaymentsCompleteAuthorizeRouterData, errors::ConnectorError> {
+ use bytes::Buf;
+
+ // Handle the case where response bytes contains U+FEFF (BOM) character sent by connector
+ let encoding = encoding_rs::UTF_8;
+ let intermediate_response = encoding.decode_with_bom_removal(res.response.chunk());
+ let intermediate_response =
+ bytes::Bytes::copy_from_slice(intermediate_response.0.as_bytes());
+
+ let response: authorizedotnet::AuthorizedotnetPaymentsResponse = intermediate_response
+ .parse_struct("AuthorizedotnetPaymentsResponse")
+ .change_context(errors::ConnectorError::ResponseDeserializationFailed)?;
 
  types::RouterData::try_from(types::ResponseRouterData {
  response,
@@ -754,3 +851,14 @@ fn get_error_response(
  }
  }
 }
+
+impl services::ConnectorRedirectResponse for Authorizedotnet {
+ fn get_flow_type(
+ &self,
+ _query_params: &str,
+ _json_payload: Option<serde_json::Value>,
+ _action: services::PaymentAction,
+ ) -> CustomResult<payments::CallConnectorAction, errors::ConnectorError> {
+ Ok(payments::CallConnectorAction::Trigger)
+ }
+}