feat(connector): Add refund and dispute webhooks for Rapyd

crates/router/src/connector/rapyd.rs

@@ -810,10 +810,8 @@ impl api::IncomingWebhook for Rapyd {
             .parse_struct("RapydIncomingWebhook")
             .change_context(errors::ConnectorError::WebhookEventTypeNotFound)?;
         Ok(match webhook.webhook_type {
-            rapyd::RapydWebhookObjectEventType::PaymentCompleted => {
-                api::IncomingWebhookEvent::PaymentIntentFailure
-            }
-            rapyd::RapydWebhookObjectEventType::PaymentCaptured => {
+            rapyd::RapydWebhookObjectEventType::PaymentCompleted
+            | rapyd::RapydWebhookObjectEventType::PaymentCaptured => {
                 api::IncomingWebhookEvent::PaymentIntentSuccess
             }
             rapyd::RapydWebhookObjectEventType::PaymentFailed => {
@@ -881,7 +879,7 @@ impl api::IncomingWebhook for Rapyd {
         }?;
         Ok(api::disputes::DisputePayload {
             amount: webhook_dispute_data.amount.to_string(),
-            currency: webhook_dispute_data.currency,
+            currency: webhook_dispute_data.currency.to_string(),
             dispute_stage: api_models::enums::DisputeStage::Dispute,
             connector_dispute_id: webhook_dispute_data.token,
             connector_reason: Some(webhook_dispute_data.dispute_reason_description),

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

@@ -250,7 +250,7 @@ pub struct ResponseData {
 pub struct DisputeResponseData {
     pub id: String,
     pub amount: i64,
-    pub currency: String,
+    pub currency: api_models::enums::Currency,
     pub token: String,
     pub dispute_reason_description: String,
     #[serde(with = "common_utils::custom_serde::timestamp")]
@@ -486,21 +486,24 @@ pub enum RapydWebhookObjectEventType {
 }
 
 #[derive(Debug, Clone, Deserialize, Serialize, PartialEq, strum::Display)]
-#[serde(rename_all = "UPPERCASE")]
 pub enum RapydWebhookDisputeStatus {
-    Act,
-    Rvw,
-    Los,
+    #[serde(rename = "ACT")]
+    Active,
+    #[serde(rename = "RVW")]
+    Review,
+    #[serde(rename = "LOS")]
+    Lose,
+    #[serde(rename = "WIN")]
     Win,
 }
 
 impl TryFrom<RapydWebhookDisputeStatus> for api_models::webhooks::IncomingWebhookEvent {
     type Error = errors::ConnectorError;
     fn try_from(value: RapydWebhookDisputeStatus) -> Result<Self, Self::Error> {
         Ok(match value {
-            RapydWebhookDisputeStatus::Act => Self::DisputeOpened,
-            RapydWebhookDisputeStatus::Rvw => Self::DisputeChallenged,
-            RapydWebhookDisputeStatus::Los => Self::DisputeLost,
+            RapydWebhookDisputeStatus::Active => Self::DisputeOpened,
+            RapydWebhookDisputeStatus::Review => Self::DisputeChallenged,
+            RapydWebhookDisputeStatus::Lose => Self::DisputeLost,
             RapydWebhookDisputeStatus::Win => Self::DisputeWon,
         })
     }