fix(core): add fix for stopping multiple event locking idempotent logs (#8034)

Co-authored-by: Debarati Ghatak <[email protected]>
Co-authored-by: hyperswitch-bot[bot] <148525504+hyperswitch-bot[bot]@users.noreply.github.com>

Author: 3 people

crates/diesel_models/src/query/events.rs

@@ -32,6 +32,20 @@ impl Event {
         .await
     }
 
+    pub async fn find_by_merchant_id_idempotent_event_id(
+        conn: &PgPooledConn,
+        merchant_id: &common_utils::id_type::MerchantId,
+        idempotent_event_id: &str,
+    ) -> StorageResult<Self> {
+        generics::generic_find_one::<<Self as HasTable>::Table, _, _>(
+            conn,
+            dsl::merchant_id
+                .eq(merchant_id.to_owned())
+                .and(dsl::idempotent_event_id.eq(idempotent_event_id.to_owned())),
+        )
+        .await
+    }
+
     pub async fn list_initial_attempts_by_merchant_id_primary_object_id(
         conn: &PgPooledConn,
         merchant_id: &common_utils::id_type::MerchantId,

crates/router/src/core/webhooks/outgoing.rs

@@ -155,10 +155,10 @@ pub(crate) async fn create_event_and_trigger_outgoing_webhook(
 
     if (state
         .store
-        .find_event_by_merchant_id_event_id(
+        .find_event_by_merchant_id_idempotent_event_id(
             key_manager_state,
             &merchant_id,
-            &event_id,
+            &idempotent_event_id,
             merchant_context.get_merchant_key_store(),
         )
         .await)