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

fix(webhooks): fix database queries in webhook (#2139)

Browse Source
This commit is contained in:
Narayan Bhat
2023-09-12 20:12:42 +05:30
committed by GitHub
parent 341163b481
commit eff280f2fb
3 changed files with 18 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
crates/router/src/types/api/webhooks.rs
View File

@ -103,7 +103,7 @@ pub trait IncomingWebhook: ConnectorCommon + Sync {
let merchant_connector_account_result = db
.find_merchant_connector_account_by_profile_id_connector_name(
&profile_id,
&merchant_account.merchant_id,
connector_name,
key_store,
)
.await;

25
crates/router/src/utils.rs
View File

@ -27,7 +27,10 @@ use uuid::Uuid;
pub use self::ext_traits::{OptionExt, ValidateCall};
use crate::{
consts,
core::errors::{self, CustomResult, RouterResult, StorageErrorExt},
core::{
errors::{self, CustomResult, RouterResult, StorageErrorExt},
utils,
},
db::StorageInterface,
logger,
routes::metrics,
@ -305,14 +308,18 @@ pub async fn get_profile_id_using_object_reference_id(
.await?
}
};
let profile_id = payment_intent
.profile_id
.ok_or(errors::ApiErrorResponse::MissingRequiredField {
field_name: "business_profile",
})
.into_report()
.change_context(errors::ApiErrorResponse::InternalServerError)
.attach_printable("profile_id is not set in payment_intent")?;
let profile_id = utils::get_profile_id_from_business_details(
payment_intent.business_country,
payment_intent.business_label.as_ref(),
merchant_account,
payment_intent.profile_id.as_ref(),
db,
)
.await
.change_context(errors::ApiErrorResponse::InternalServerError)
.attach_printable("profile_id is not set in payment_intent")?;
Ok(profile_id)
}
}

2
crates/storage_impl/src/payments/payment_attempt.rs
View File

@ -226,8 +226,8 @@ impl<T: DatabaseStore> PaymentAttemptInterface for RouterStore<T> {
async fn find_payment_attempt_by_attempt_id_merchant_id(
&self,
merchant_id: &str,
attempt_id: &str,
merchant_id: &str,
_storage_scheme: MerchantStorageScheme,
) -> CustomResult<PaymentAttempt, errors::StorageError> {
let conn = pg_connection_read(self).await?;