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

fix: add prefix to connector_transaction_id (#2981)

Browse Source
This commit is contained in:
Kartikeya Hegde
2023-11-24 19:25:19 +05:30
committed by GitHub
parent 03c0a772a9
commit 107c3b9941
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -553,7 +553,7 @@ impl<T: DatabaseStore> PaymentAttemptInterface for KVRouterStore<T> {
} }
MerchantStorageScheme::RedisKv => { MerchantStorageScheme::RedisKv => {
// We assume that PaymentAttempt <=> PaymentIntent is a one-to-one relation for now // We assume that PaymentAttempt <=> PaymentIntent is a one-to-one relation for now
let lookup_id = format!("{merchant_id}_{connector_transaction_id}"); let lookup_id = format!("conn_trans_{merchant_id}_{connector_transaction_id}");
let lookup = self let lookup = self
.get_lookup_by_lookup_id(&lookup_id, storage_scheme) .get_lookup_by_lookup_id(&lookup_id, storage_scheme)
.await?; .await?;
@ -774,7 +774,7 @@ impl<T: DatabaseStore> PaymentAttemptInterface for KVRouterStore<T> {
.await .await
} }
MerchantStorageScheme::RedisKv => { MerchantStorageScheme::RedisKv => {
let lookup_id = format!("{merchant_id}_{preprocessing_id}"); let lookup_id = format!("preprocessing_{merchant_id}_{preprocessing_id}");
let lookup = self let lookup = self
.get_lookup_by_lookup_id(&lookup_id, storage_scheme) .get_lookup_by_lookup_id(&lookup_id, storage_scheme)
.await?; .await?;
@ -1671,7 +1671,7 @@ async fn add_connector_txn_id_to_reverse_lookup<T: DatabaseStore>(
) -> CustomResult<ReverseLookup, errors::StorageError> { ) -> CustomResult<ReverseLookup, errors::StorageError> {
let field = format!("pa_{}", updated_attempt_attempt_id); let field = format!("pa_{}", updated_attempt_attempt_id);
let reverse_lookup_new = ReverseLookupNew { let reverse_lookup_new = ReverseLookupNew {
lookup_id: format!("{}_{}", merchant_id, connector_transaction_id), lookup_id: format!("conn_trans_{}_{}", merchant_id, connector_transaction_id),
pk_id: key.to_owned(), pk_id: key.to_owned(),
sk_id: field.clone(), sk_id: field.clone(),
source: "payment_attempt".to_string(), source: "payment_attempt".to_string(),
@ -1693,7 +1693,7 @@ async fn add_preprocessing_id_to_reverse_lookup<T: DatabaseStore>(
) -> CustomResult<ReverseLookup, errors::StorageError> { ) -> CustomResult<ReverseLookup, errors::StorageError> {
let field = format!("pa_{}", updated_attempt_attempt_id); let field = format!("pa_{}", updated_attempt_attempt_id);
let reverse_lookup_new = ReverseLookupNew { let reverse_lookup_new = ReverseLookupNew {
lookup_id: format!("{}_{}", merchant_id, preprocessing_id), lookup_id: format!("preprocessing_{}_{}", merchant_id, preprocessing_id),
pk_id: key.to_owned(), pk_id: key.to_owned(),
sk_id: field.clone(), sk_id: field.clone(),
source: "payment_attempt".to_string(), source: "payment_attempt".to_string(),