Search for write_acknowledgement instead of recv_packet to avoid duplicated ibc packets (#1490)

Author: M-Picco

wormhole-connect/src/routes/cosmosGateway/utils/getMessage.ts

@@ -321,11 +321,14 @@ function getIbcTransferLog(
   for (const log of logs) {
     for (const ev of log.events) {
       // find an ibc received packet event
-      if (ev.type !== 'recv_packet') continue;
+      if (ev.type !== 'write_acknowledgement') continue;
 
       // check that this packet is the one that matches the source ibc transfer
       // if not, skip this msg log entirely and proceed to the next one
-      const logIbcInfo = getIBCTransferInfoFromLogs([log], 'recv_packet');
+      const logIbcInfo = getIBCTransferInfoFromLogs(
+        [log],
+        'write_acknowledgement',
+      );
 
       if (
         logIbcInfo.sequence !== ibcTransfer.sequence ||

wormhole-connect/src/routes/cosmosGateway/utils/transaction.ts

@@ -9,15 +9,15 @@ import { IBCTransferInfo } from '../types';
 
 export function getTransactionIBCTransferInfo(
   tx: IndexedTx,
-  event: 'send_packet' | 'recv_packet',
+  event: 'send_packet' | 'write_acknowledgement',
 ): IBCTransferInfo {
   const logs = cosmosLogs.parseRawLog(tx.rawLog);
   return getIBCTransferInfoFromLogs(logs, event);
 }
 
 export function getIBCTransferInfoFromLogs(
   logs: readonly cosmosLogs.Log[],
-  event: 'send_packet' | 'recv_packet',
+  event: 'send_packet' | 'write_acknowledgement',
 ): IBCTransferInfo {
   const packetSeq = searchCosmosLogs(`${event}.packet_sequence`, logs);
   const packetTimeout = searchCosmosLogs(
@@ -57,10 +57,19 @@ export async function findDestinationIBCTransferTx(
 ): Promise<IndexedTx | undefined> {
   const wormchainClient = await getCosmWasmClient(destChain);
   const destTx = await wormchainClient.searchTx([
-    { key: 'recv_packet.packet_sequence', value: ibcInfo.sequence },
-    { key: 'recv_packet.packet_timeout_timestamp', value: ibcInfo.timeout },
-    { key: 'recv_packet.packet_src_channel', value: ibcInfo.srcChannel },
-    { key: 'recv_packet.packet_dst_channel', value: ibcInfo.dstChannel },
+    { key: 'write_acknowledgement.packet_sequence', value: ibcInfo.sequence },
+    {
+      key: 'write_acknowledgement.packet_timeout_timestamp',
+      value: ibcInfo.timeout,
+    },
+    {
+      key: 'write_acknowledgement.packet_src_channel',
+      value: ibcInfo.srcChannel,
+    },
+    {
+      key: 'write_acknowledgement.packet_dst_channel',
+      value: ibcInfo.dstChannel,
+    },
   ]);
   if (destTx.length === 0) {
     return undefined;