do not process same event twice

Author: alexcos20

src/components/Indexer/processor.ts

@@ -61,7 +61,6 @@ function getEventProcessor(
     INDEXER_LOGGER.debug(
       'Creating new Processor for event ' + eventType + 'with key ' + cacheKey
     )
-    console.log(config)
     processorInstances.set(cacheKey, new ProcessorClass(chainId, config))
   } else {
     INDEXER_LOGGER.debug('Reusing cached processor for key ' + cacheKey)

src/components/Indexer/processors/OrderReusedEventProcessor.ts

@@ -43,6 +43,13 @@ export class OrderReusedEventProcessor extends BaseEventProcessor {
         )
         return
       }
+      const existingOrder = await orderDatabase.retrieve(event.transactionHash)
+      if (existingOrder) {
+        INDEXER_LOGGER.logMessage(
+          `OrderReused already processed for tx ${event.transactionHash}, skipping duplicate`
+        )
+        return ddo
+      }
       const ddoInstance = DDOManager.getDDOClass(ddo)
       if (!ddoInstance.getAssetFields().indexedMetadata) {
         ddoInstance.updateFields({ indexedMetadata: {} })

src/components/Indexer/processors/OrderStartedEventProcessor.ts

@@ -41,6 +41,13 @@ export class OrderStartedEventProcessor extends BaseEventProcessor {
         )
         return
       }
+      const existingOrder = await orderDatabase.retrieve(event.transactionHash)
+      if (existingOrder) {
+        INDEXER_LOGGER.logMessage(
+          `OrderStarted already processed for tx ${event.transactionHash}, skipping duplicate`
+        )
+        return ddo
+      }
       const ddoInstance = DDOManager.getDDOClass(ddo)
       if (!ddoInstance.getAssetFields().indexedMetadata) {
         ddoInstance.updateFields({ indexedMetadata: {} })