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

fix: added hget lookup for all updated_by existing cases (#4716)

Browse Source 
Co-authored-by: Akshay S <akshay.s@Akshay-Subramanian-D66TQ6D97K.local>
Co-authored-by: hyperswitch-bot[bot] <148525504+hyperswitch-bot[bot]@users.noreply.github.com>
This commit is contained in:
akshay-97
2024-05-22 14:59:18 +05:30
committed by GitHub
parent 431560b7fb
commit fabf80c2b1
1 changed files with 5 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
crates/storage_impl/src/redis/kv_store.rs
View File

@ -249,7 +249,9 @@ impl<'a> std::fmt::Display for Op<'a> {
match self { match self {
Op::Insert => f.write_str("insert"), Op::Insert => f.write_str("insert"),
Op::Find => f.write_str("find"), Op::Find => f.write_str("find"),
Op::Update(p_key, _, _) => f.write_str(&format!("update_{}", p_key)), Op::Update(p_key, _, updated_by) => {
f.write_str(&format!("update_{} for updated_by_{:?}", p_key, updated_by))
}
} }
} }
} }
@ -273,7 +275,8 @@ where
let updated_scheme = match operation { let updated_scheme = match operation {
Op::Insert => MerchantStorageScheme::PostgresOnly, Op::Insert => MerchantStorageScheme::PostgresOnly,
Op::Find => MerchantStorageScheme::RedisKv, Op::Find => MerchantStorageScheme::RedisKv,
Op::Update(partition_key, field, Some("redis_kv")) => { Op::Update(_, _, Some("postgres_only")) => MerchantStorageScheme::PostgresOnly,
Op::Update(partition_key, field, Some(_updated_by)) => {
match kv_wrapper::<D, _, _>(store, KvOperation::<D>::HGet(field), partition_key) match kv_wrapper::<D, _, _>(store, KvOperation::<D>::HGet(field), partition_key)
.await .await
{ {
@ -286,11 +289,6 @@ where
} }
Op::Update(_, _, None) => MerchantStorageScheme::PostgresOnly, Op::Update(_, _, None) => MerchantStorageScheme::PostgresOnly,
Op::Update(_, _, Some("postgres_only")) => MerchantStorageScheme::PostgresOnly,
_ => {
logger::debug!("soft_kill_mode - using default storage scheme");
storage_scheme
}
}; };
let type_name = std::any::type_name::<D>(); let type_name = std::any::type_name::<D>();