Search in a set should be done differently

polymerdao · Mar 12, 2024 · ed43a12 · ed43a12
1 parent bb9d318
commit ed43a12
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/app/api/cache/route.ts b/app/api/cache/route.ts
@@ -30,7 +30,7 @@ export async function GET(request: NextRequest) {
     // Set cache concurrently
     await Promise.all([
       cache.set('allChannels', channels, -1),
-      // cache.set('allPackets', packets, -1),
+      cache.set('allPackets', packets, -1),
     ]);
 
     console.log(`Fetched packets and channels in ${Date.now() - start}ms`);

diff --git a/app/api/packets/route.ts b/app/api/packets/route.ts
@@ -65,7 +65,7 @@ export async function getPackets() {
 
     let channel;
     try {
-      console.log(`Getting channel for port ${portId} and channel ${srcChannelId}`);
+      console.log(`Getting channel for port ${portId} and channel ${srcChannelId} and sequence ${sequence}`);
       channel = await tmClient.ibc.channel.channel(portId, srcChannelId);
     } catch (e) {
       console.log('Skipping packet for channel: ', srcChannelId);
@@ -201,7 +201,7 @@ export async function getPackets() {
     }
 
     const key = `${channel.channel.counterparty.portId}-${channel.channel.counterparty.channelId}-${sequence}`;
-    if (key in unprocessedPacketKeys) {
+    if (unprocessedPacketKeys.has(key)) {
       packets[key].state = PacketStates.WRITE_ACK;
       unprocessedPacketKeys.delete(key);
     }
@@ -249,7 +249,7 @@ export async function getPackets() {
         return;
       }
 
-      if (key in unprocessedPacketKeys) {
+      if (unprocessedPacketKeys.has(key)) {
         packets[key].state = PacketStates.RECV;
         unprocessedPacketKeys.delete(key);
       }