fix: stop skipping events

Author: andreabadesso

packages/event-downloader/src/event-parser.ts

@@ -9,21 +9,23 @@ import { FullNodeEvent, FullNodeEventTypes } from './types';
 
 /**
  * Extracts the transaction hash from a fullnode event.
+ * Now handles ALL event types, not just predefined ones.
  *
  * @param event - The fullnode event to extract the hash from
  * @returns The transaction hash if the event contains one, null otherwise
  */
 export function extractTxHash(event: FullNodeEvent): string | null {
   const eventType = event.event.type;
+  const eventData = event.event.data as any;
 
   switch (eventType) {
     case FullNodeEventTypes.NEW_VERTEX_ACCEPTED:
     case FullNodeEventTypes.VERTEX_METADATA_CHANGED:
     case FullNodeEventTypes.VERTEX_REMOVED:
-      return event.event.data.hash;
+      return eventData?.hash ?? null;
 
     case FullNodeEventTypes.NC_EVENT:
-      return event.event.data.vertex_id;
+      return eventData?.vertex_id ?? null;
 
     case FullNodeEventTypes.LOAD_STARTED:
     case FullNodeEventTypes.LOAD_FINISHED:
@@ -33,6 +35,30 @@ export function extractTxHash(event: FullNodeEvent): string | null {
       return null;
 
     default:
+      // Handle unknown event types by trying common patterns
+      // TOKEN_CREATED and other events might have different structures
+
+      // Try standard hash field
+      if (eventData?.hash) {
+        return eventData.hash;
+      }
+
+      // Try vertex_id (for vertex-related events)
+      if (eventData?.vertex_id) {
+        return eventData.vertex_id;
+      }
+
+      // Try token_uid (for TOKEN_CREATED events)
+      if (eventData?.token_uid) {
+        return eventData.token_uid;
+      }
+
+      // Try nc_exec_info.nc_tx (for nano contract events)
+      if (eventData?.nc_exec_info?.nc_tx) {
+        return eventData.nc_exec_info.nc_tx;
+      }
+
+      // No recognizable hash found
       return null;
   }
 }

packages/event-downloader/src/worker.ts

@@ -7,7 +7,7 @@
 
 import { WebSocket, MessageEvent, ErrorEvent } from 'ws';
 import { bigIntUtils } from '@hathor/wallet-lib';
-import { FullNodeEvent, FullNodeEventSchema, WebSocketSendEvent } from './types';
+import { FullNodeEvent, WebSocketSendEvent } from './types';
 import { FULLNODE_HOST, USE_SSL, WINDOW_SIZE, CONNECTION_TIMEOUT_MS } from './config';
 
 export interface BatchConfig {
@@ -103,16 +103,18 @@ export function createWorker(config: BatchConfig, callbacks: WorkerCallbacks): W
       resetActivityTimeout();
       try {
         const rawData = bigIntUtils.JSONBigInt.parse(socketEvent.data.toString());
-        const parseResult = FullNodeEventSchema.safeParse(rawData);
 
-        if (!parseResult.success) {
-          // Skip messages that don't conform to event schema (e.g., handshake messages)
-          // These are expected at the start of a connection
+        // Check if this is an event message (not a handshake or control message)
+        // Event messages have: event.id, event.type, event.timestamp
+        if (!rawData.event || typeof rawData.event.id !== 'number' || typeof rawData.event.type !== 'string') {
+          // Skip non-event messages (handshake, control messages, etc.)
           console.log(`Skipping non-event message: ${JSON.stringify(rawData).substring(0, 100)}...`);
           return;
         }
 
-        const event = parseResult.data;
+        // Accept ALL events regardless of type - store them as-is
+        // TypeScript requires us to cast, but we're intentionally accepting any event structure
+        const event = rawData as any;
         const eventId = event.event.id;
 
         // Call the event callback