fix(frm): restrict enabled mca for frm connectors (#5499)

Signed-off-by: Chikke Srujan <chikke.srujan@Chikke-Srujan-N7WRTY72X7.local>
Co-authored-by: Chikke Srujan <chikke.srujan@Chikke-Srujan-N7WRTY72X7.local>
Co-authored-by: hyperswitch-bot[bot] <148525504+hyperswitch-bot[bot]@users.noreply.github.com>
This commit is contained in:
chikke srujan
2024-08-12 15:25:15 +05:30
committed by GitHub
parent 4e7db9d1ad
commit 7718800e1f

View File

@ -183,10 +183,26 @@ pub async fn should_call_frm<F: Send + Clone>(
&key_store, &key_store,
) )
.await .await
.change_context(errors::ApiErrorResponse::MerchantConnectorAccountNotFound { .map_err(|error| {
id: merchant_account.get_id().get_string_repr().to_owned(), logger::error!(
"{:?}",
error.change_context(
errors::ApiErrorResponse::MerchantConnectorAccountNotFound {
id: merchant_account.get_id().get_string_repr().to_owned(),
}
)
)
}) })
.ok(); .ok();
let enabled_merchant_connector_account_from_db_option =
merchant_connector_account_from_db_option.and_then(|mca| {
if mca.disabled.unwrap_or(false) {
logger::info!("No eligible connector found for FRM");
None
} else {
Some(mca)
}
});
#[cfg(all(feature = "v2", feature = "merchant_connector_account_v2"))] #[cfg(all(feature = "v2", feature = "merchant_connector_account_v2"))]
let merchant_connector_account_from_db_option: Option< let merchant_connector_account_from_db_option: Option<
@ -198,7 +214,7 @@ pub async fn should_call_frm<F: Send + Clone>(
todo!() todo!()
}; };
match merchant_connector_account_from_db_option { match enabled_merchant_connector_account_from_db_option {
Some(merchant_connector_account_from_db) => { Some(merchant_connector_account_from_db) => {
let frm_configs_option = merchant_connector_account_from_db let frm_configs_option = merchant_connector_account_from_db
.frm_configs .frm_configs