feat(connector): Add recovery support for stripebilling

api-reference-v2/openapi_spec.json

@@ -7677,6 +7677,7 @@
           "square",
           "stax",
           "stripe",
+          "stripebilling",
           "taxjar",
           "threedsecureio",
           "trustpay",
@@ -20583,6 +20584,7 @@
           "square",
           "stax",
           "stripe",
+          "stripebilling",
           "trustpay",
           "tsys",
           "volt",

api-reference/openapi_spec.json

@@ -9859,6 +9859,7 @@
           "square",
           "stax",
           "stripe",
+          "stripebilling",
           "taxjar",
           "threedsecureio",
           "trustpay",
@@ -25109,6 +25110,7 @@
           "square",
           "stax",
           "stripe",
+          "stripebilling",
           "trustpay",
           "tsys",
           "volt",

crates/api_models/src/webhooks.rs

@@ -253,6 +253,8 @@ pub enum ObjectReferenceId {
     PayoutId(PayoutIdType),
     #[cfg(all(feature = "revenue_recovery", feature = "v2"))]
     InvoiceId(InvoiceIdType),
+    #[cfg(all(feature = "revenue_recovery", feature = "v2"))]
+    AdditionalRevenueRecoveryId(AdditionalRevenueRecoveryIdType),
 }
 
 #[cfg(all(feature = "revenue_recovery", feature = "v2"))]
@@ -261,6 +263,61 @@ pub enum InvoiceIdType {
     ConnectorInvoiceId(String),
 }
 
+#[cfg(all(feature = "revenue_recovery", feature = "v2"))]
+#[derive(Clone)]
+pub enum AdditionalRevenueRecoveryIdType {
+    AdditionalRevenueRecoveryCallId(String),
+}
+
+#[cfg(all(feature = "revenue_recovery", feature = "v2"))]
+impl ObjectReferenceId {
+    pub fn get_additional_revenue_recovery_id_as_string(
+        self,
+    ) -> Result<String, common_utils::errors::ValidationError> {
+        match self {
+            Self::AdditionalRevenueRecoveryId(
+                AdditionalRevenueRecoveryIdType::AdditionalRevenueRecoveryCallId(data),
+            ) => Ok(data),
+            Self::PaymentId(_) => Err(
+                common_utils::errors::ValidationError::IncorrectValueProvided {
+                    field_name: "AdditionalRevenueRecoveryId is required but received PaymentId",
+                },
+            ),
+            Self::RefundId(_) => Err(
+                common_utils::errors::ValidationError::IncorrectValueProvided {
+                    field_name: "AdditionalRevenueRecoveryId is required but received RefundId",
+                },
+            ),
+            Self::MandateId(_) => Err(
+                common_utils::errors::ValidationError::IncorrectValueProvided {
+                    field_name: "AdditionalRevenueRecoveryId is required but received MandateId",
+                },
+            ),
+            Self::ExternalAuthenticationID(_) => Err(
+                common_utils::errors::ValidationError::IncorrectValueProvided {
+                    field_name: "AdditionalRevenueRecoveryId is required but received ExternalAuthenticationID",
+                },
+            ),
+            #[cfg(feature = "payouts")]
+            Self::PayoutId(_) => Err(
+                common_utils::errors::ValidationError::IncorrectValueProvided {
+                    field_name: "AdditionalRevenueRecoveryId is required but received PayoutId",
+                },
+            ),
+            Self::InvoiceId(_) => Err(
+                common_utils::errors::ValidationError::IncorrectValueProvided {
+                    field_name: "AdditionalRevenueRecoveryId is required but received InvoiceId",
+                },
+            ),
+            Self::AdditionalRevenueRecoveryId(_) => Err(
+                common_utils::errors::ValidationError::IncorrectValueProvided {
+                    field_name: "AdditionalRevenueRecoveryId of type AdditionalRevenueRecoveryCallId is required but received other variant",
+                },
+            )
+        }
+    }
+}
+
 pub struct IncomingWebhookDetails {
     pub object_reference_id: ObjectReferenceId,
     pub resource_object: Vec<u8>,

crates/common_enums/src/connector_enums.rs

@@ -128,7 +128,7 @@ pub enum RoutableConnectors {
     Square,
     Stax,
     Stripe,
-    //Stripebilling,
+    Stripebilling,
     // Taxjar,
     Trustpay,
     // Thunes
@@ -272,7 +272,7 @@ pub enum Connector {
     Square,
     Stax,
     Stripe,
-    // Stripebilling,
+    Stripebilling,
     Taxjar,
     Threedsecureio,
     //Thunes,
@@ -423,7 +423,7 @@ impl Connector {
             | Self::Shift4
             | Self::Square
             | Self::Stax
-            // | Self::Stripebilling
+            | Self::Stripebilling
             | Self::Taxjar
             // | Self::Thunes
             | Self::Trustpay
@@ -573,7 +573,7 @@ impl From<RoutableConnectors> for Connector {
             RoutableConnectors::Square => Self::Square,
             RoutableConnectors::Stax => Self::Stax,
             RoutableConnectors::Stripe => Self::Stripe,
-            // RoutableConnectors::Stripebilling => Self::Stripebilling,
+            RoutableConnectors::Stripebilling => Self::Stripebilling,
             RoutableConnectors::Trustpay => Self::Trustpay,
             RoutableConnectors::Tsys => Self::Tsys,
             RoutableConnectors::Volt => Self::Volt,

crates/connector_configs/src/connector.rs

@@ -238,7 +238,7 @@ pub struct ConnectorConfig {
     pub stripe: Option<ConnectorTomlConfig>,
     #[cfg(feature = "payouts")]
     pub stripe_payout: Option<ConnectorTomlConfig>,
-    // pub stripebilling : Option<ConnectorTomlConfig>,
+    pub stripebilling: Option<ConnectorTomlConfig>,
     pub signifyd: Option<ConnectorTomlConfig>,
     pub trustpay: Option<ConnectorTomlConfig>,
     pub threedsecureio: Option<ConnectorTomlConfig>,
@@ -411,7 +411,7 @@ impl ConnectorConfig {
             Connector::Square => Ok(connector_data.square),
             Connector::Stax => Ok(connector_data.stax),
             Connector::Stripe => Ok(connector_data.stripe),
-            // Connector::Stripebilling => Ok(connector_data.stripebilling),
+            Connector::Stripebilling => Ok(connector_data.stripebilling),
             Connector::Trustpay => Ok(connector_data.trustpay),
             Connector::Threedsecureio => Ok(connector_data.threedsecureio),
             Connector::Taxjar => Ok(connector_data.taxjar),

crates/hyperswitch_connectors/src/connectors/stripebilling.rs

@@ -9,6 +9,8 @@ use common_utils::{
     types::{AmountConvertor, StringMinorUnit, StringMinorUnitForConnector},
 };
 use error_stack::{report, ResultExt};
+#[cfg(all(feature = "v2", feature = "revenue_recovery"))]
+use hyperswitch_domain_models::revenue_recovery;
 use hyperswitch_domain_models::{
     router_data::{AccessToken, ConnectorAuthType, ErrorResponse, RouterData},
     router_flow_types::{
@@ -29,10 +31,16 @@ use hyperswitch_domain_models::{
 };
 #[cfg(all(feature = "v2", feature = "revenue_recovery"))]
 use hyperswitch_domain_models::{
-    router_flow_types::RecoveryRecordBack,
-    router_request_types::revenue_recovery::RevenueRecoveryRecordBackRequest,
-    router_response_types::revenue_recovery::RevenueRecoveryRecordBackResponse,
-    types::RevenueRecoveryRecordBackRouterData,
+    router_flow_types::revenue_recovery::{
+        GetAdditionalRevenueRecoveryDetails, RecoveryRecordBack,
+    },
+    router_request_types::revenue_recovery::{
+        GetAdditionalRevenueRecoveryRequestData, RevenueRecoveryRecordBackRequest,
+    },
+    router_response_types::revenue_recovery::{
+        GetAdditionalRevenueRecoveryResponseData, RevenueRecoveryRecordBackResponse,
+    },
+    types::{AdditionalRevenueRecoveryDetailsRouterData, RevenueRecoveryRecordBackRouterData},
 };
 use hyperswitch_interfaces::{
     api::{
@@ -45,7 +53,10 @@ use hyperswitch_interfaces::{
     types::{self, Response},
     webhooks,
 };
-use masking::{ExposeInterface, Mask};
+#[cfg(all(feature = "v2", feature = "revenue_recovery"))]
+use masking::ExposeInterface;
+use masking::{Mask, PeekInterface};
+use stripebilling::auth_headers;
 use transformers as stripebilling;
 
 use crate::{constants::headers, types::ResponseRouterData, utils};
@@ -77,6 +88,8 @@ impl api::RefundSync for Stripebilling {}
 impl api::PaymentToken for Stripebilling {}
 #[cfg(all(feature = "revenue_recovery", feature = "v2"))]
 impl api::revenue_recovery::RevenueRecoveryRecordBack for Stripebilling {}
+#[cfg(all(feature = "v2", feature = "revenue_recovery"))]
+impl api::AdditionalRevenueRecovery for Stripebilling {}
 
 impl ConnectorIntegration<PaymentMethodToken, PaymentMethodTokenizationData, PaymentsResponseData>
     for Stripebilling
@@ -126,10 +139,16 @@ impl ConnectorCommon for Stripebilling {
     ) -> CustomResult<Vec<(String, masking::Maskable<String>)>, errors::ConnectorError> {
         let auth = stripebilling::StripebillingAuthType::try_from(auth_type)
             .change_context(errors::ConnectorError::FailedToObtainAuthType)?;
-        Ok(vec![(
-            headers::AUTHORIZATION.to_string(),
-            auth.api_key.expose().into_masked(),
-        )])
+        Ok(vec![
+            (
+                headers::AUTHORIZATION.to_string(),
+                format!("Bearer {}", auth.api_key.peek()).into_masked(),
+            ),
+            (
+                auth_headers::STRIPE_API_VERSION.to_string(),
+                auth_headers::STRIPE_VERSION.to_string().into_masked(),
+            ),
+        ])
     }
 
     fn build_error_response(
@@ -559,6 +578,88 @@ impl ConnectorIntegration<RSync, RefundsData, RefundsResponseData> for Stripebil
     }
 }
 
+#[cfg(all(feature = "v2", feature = "revenue_recovery"))]
+impl
+    ConnectorIntegration<
+        GetAdditionalRevenueRecoveryDetails,
+        GetAdditionalRevenueRecoveryRequestData,
+        GetAdditionalRevenueRecoveryResponseData,
+    > for Stripebilling
+{
+    fn get_headers(
+        &self,
+        req: &AdditionalRevenueRecoveryDetailsRouterData,
+        connectors: &Connectors,
+    ) -> CustomResult<Vec<(String, masking::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: &AdditionalRevenueRecoveryDetailsRouterData,
+        connectors: &Connectors,
+    ) -> CustomResult<String, errors::ConnectorError> {
+        Ok(format!(
+            "{}v1/charges/{}",
+            self.base_url(connectors),
+            req.request.additional_revenue_recovery_id
+        ))
+    }
+
+    fn build_request(
+        &self,
+        req: &AdditionalRevenueRecoveryDetailsRouterData,
+        connectors: &Connectors,
+    ) -> CustomResult<Option<Request>, errors::ConnectorError> {
+        let request = RequestBuilder::new()
+            .method(Method::Get)
+            .url(&types::AdditionalRevenueRecoveryCallType::get_url(
+                self, req, connectors,
+            )?)
+            .attach_default_headers()
+            .headers(types::AdditionalRevenueRecoveryCallType::get_headers(
+                self, req, connectors,
+            )?)
+            .build();
+        Ok(Some(request))
+    }
+
+    fn handle_response(
+        &self,
+        data: &AdditionalRevenueRecoveryDetailsRouterData,
+        event_builder: Option<&mut ConnectorEvent>,
+        res: Response,
+    ) -> CustomResult<AdditionalRevenueRecoveryDetailsRouterData, errors::ConnectorError> {
+        let response: stripebilling::StripebillingRecoveryDetailsData = res
+            .response
+            .parse_struct::<stripebilling::StripebillingRecoveryDetailsData>(
+                "StripebillingRecoveryDetailsData",
+            )
+            .change_context(errors::ConnectorError::ResponseDeserializationFailed)?;
+
+        event_builder.map(|i| i.set_response_body(&response));
+        router_env::logger::info!(connector_response=?response);
+
+        AdditionalRevenueRecoveryDetailsRouterData::try_from(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)
+    }
+}
+
 #[cfg(all(feature = "v2", feature = "revenue_recovery"))]
 impl
     ConnectorIntegration<
@@ -700,8 +801,8 @@ impl webhooks::IncomingWebhook for Stripebilling {
         let webhook =
             stripebilling::StripebillingWebhookBody::get_webhook_object_from_body(request.body)
                 .change_context(errors::ConnectorError::WebhookReferenceIdNotFound)?;
-        Ok(api_models::webhooks::ObjectReferenceId::PaymentId(
-            api_models::payments::PaymentIdType::ConnectorTransactionId(webhook.data.object.charge),
+        Ok(api_models::webhooks::ObjectReferenceId::AdditionalRevenueRecoveryId(
+            api_models::webhooks::AdditionalRevenueRecoveryIdType::AdditionalRevenueRecoveryCallId(webhook.data.object.charge),
         ))
     }
 
@@ -712,6 +813,7 @@ impl webhooks::IncomingWebhook for Stripebilling {
     ) -> CustomResult<api_models::webhooks::ObjectReferenceId, errors::ConnectorError> {
         Err(report!(errors::ConnectorError::WebhooksNotImplemented))
     }
+
     #[cfg(all(feature = "revenue_recovery", feature = "v2"))]
     fn get_webhook_event_type(
         &self,
@@ -762,6 +864,25 @@ impl webhooks::IncomingWebhook for Stripebilling {
         .change_context(errors::ConnectorError::WebhookResourceObjectNotFound)?;
         Ok(Box::new(webhook))
     }
+
+    #[cfg(all(feature = "revenue_recovery", feature = "v2"))]
+    fn get_revenue_recovery_attempt_details(
+        &self,
+        _request: &webhooks::IncomingWebhookRequestDetails<'_>,
+    ) -> CustomResult<revenue_recovery::RevenueRecoveryAttemptData, errors::ConnectorError> {
+        // since stripe requires an additional call we dont need to implement this function because we get the recovery data from additional call itself
+        Err(report!(errors::ConnectorError::WebhooksNotImplemented))
+    }
+    #[cfg(all(feature = "revenue_recovery", feature = "v2"))]
+    fn get_revenue_recovery_invoice_details(
+        &self,
+        request: &webhooks::IncomingWebhookRequestDetails<'_>,
+    ) -> CustomResult<revenue_recovery::RevenueRecoveryInvoiceData, errors::ConnectorError> {
+        let webhook = stripebilling::StripebillingInvoiceBody::get_invoice_webhook_data_from_body(
+            request.body,
+        )?;
+        revenue_recovery::RevenueRecoveryInvoiceData::try_from(webhook)
+    }
 }
 
 fn get_signature_elements_from_header(