Enhance event source validation

src/snap-points.ts

@@ -19,6 +19,7 @@ import {
   processNewOpen,
   processNewClosed,
   processNewOpenClosed,
+  validateLogs,
 } from "./utils";
 import {
   IActive,
@@ -100,22 +101,11 @@ export const createSnapshotForNetwork = async (network: Network) => {
     MAX_SIGNATURES_PER_CALL
   );
 
-  const finalLogs = txLogs.flat();
   const eventsObject: Record<string, IPositions> = JSON.parse(
     fs.readFileSync(eventsSnapFilename, "utf-8")
   );
 
-  const eventLogs: string[] = [];
-
-  finalLogs.map((log, index) => {
-    if (
-      log.startsWith("Program data:") &&
-      finalLogs[index + 1].startsWith(
-        `Program ${market.program.programId.toBase58()}`
-      )
-    )
-      eventLogs.push(log.split("Program data: ")[1]);
-  });
+  const eventLogs = validateLogs(txLogs, market.program.programId);
 
   const decodedEvents = eventLogs
     .map((log) => market.eventDecoder.decode(log))

src/utils.ts

@@ -265,3 +265,29 @@ export const processNewOpenClosed = (
 
   return updatedNewOpenClosed;
 };
+
+export const validateLogs = (logs: string[][], programId: PublicKey) => {
+  const rawEvents: string[] = [];
+  for (const txLog of logs) {
+    txLog.map((log, index) => {
+      if (
+        log.slice(0, -4) === `Program ${programId.toBase58()} invoke` &&
+        (txLog[index + 1] === "Program log: Instruction: CreatePosition" ||
+          txLog[index + 1] === "Program log: Instruction: RemovePosition")
+      ) {
+        for (let i = index; i < txLog.length; i++) {
+          if (txLog[i] === `Program ${programId.toBase58()} success`) {
+            const associatedSlice = txLog.slice(index, i + 1);
+            const event = associatedSlice.find((log) =>
+              log.startsWith("Program data:")
+            );
+            if (event) {
+              rawEvents.push(event);
+            }
+          }
+        }
+      }
+    });
+  }
+  return rawEvents;
+};