rust/hyperswitch
1
0
Fork 0
mirror of https://github.com/juspay/hyperswitch.git synced 2025-10-29 00:49:42 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat(router): add payment failed webhook event (#305)

Browse Source
This commit is contained in:
ItsMeShashank
2023-01-06 14:02:39 +05:30
committed by GitHub
parent 2f65459d9e
commit f2b88350a6
4 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
crates/api_models/src/webhooks.rs
View File

@ -7,6 +7,7 @@ use crate::{enums as api_enums, payments};
#[derive(Clone, Debug, PartialEq, Eq, Hash, Serialize, Deserialize)]
#[serde(rename_all = "snake_case")]
pub enum IncomingWebhookEvent {
PaymentIntentFailure,
PaymentIntentSuccess,
}
@ -19,6 +20,7 @@ pub enum WebhookFlow {
impl From<IncomingWebhookEvent> for WebhookFlow {
fn from(evt: IncomingWebhookEvent) -> Self {
match evt {
IncomingWebhookEvent::PaymentIntentFailure => Self::Payment,
IncomingWebhookEvent::PaymentIntentSuccess => Self::Payment,
}
}

2
crates/common_utils/src/pii.rs
View File

@ -17,7 +17,7 @@ where
fn fmt(val: &T, f: &mut fmt::Formatter<'_>) -> fmt::Result {
let val_str: &str = val.as_ref();
if val_str.len() < 15 && val_str.len() > 19 {
if val_str.len() < 15 || val_str.len() > 19 {
return WithType::fmt(val, f);
}

1
crates/router/src/connector/stripe.rs
View File

@ -935,6 +935,7 @@ impl api::IncomingWebhook for Stripe {
.change_context(errors::ConnectorError::WebhookEventTypeNotFound)?;
Ok(match details.event_type.as_str() {
"payment_intent.payment_failed" => api::IncomingWebhookEvent::PaymentIntentFailure,
"payment_intent.succeeded" => api::IncomingWebhookEvent::PaymentIntentSuccess,
_ => Err(errors::ConnectorError::WebhookEventTypeNotFound).into_report()?,
})

7
crates/router/src/core/payments/helpers.rs
View File

@ -31,7 +31,7 @@ use crate::{
utils::{
self,
crypto::{self, SignMessage},
OptionExt, ValueExt,
OptionExt,
},
};
@ -658,8 +658,9 @@ pub async fn get_connector_default(
.parse_value("CustomRoutingRulesVec")
.change_context(errors::ConnectorError::RoutingRulesParsingError)
.change_context(errors::ApiErrorResponse::InternalServerError)?;
let custom_routing_rules: api::CustomRoutingRules = vec_val[0]
.clone()
let custom_routing_rules: api::CustomRoutingRules = vec_val
.first()
.cloned()
.parse_value("CustomRoutingRules")
.change_context(errors::ConnectorError::RoutingRulesParsingError)
.change_context(errors::ApiErrorResponse::InternalServerError)?;