fixes

proxy/indexer/indexer.py

@@ -86,9 +86,6 @@ def process_receipts(self):
             max_slot = max(max_slot, slot)
             counter += 1
 
-            if signature in self.db.sol_eth_trx:
-                continue
-
             if trx['transaction']['message']['instructions'] is not None:
                 for instruction in trx['transaction']['message']['instructions']:
 
@@ -416,6 +413,7 @@ def process_receipts(self):
                         pass
 
         for eth_signature, trx_struct in trx_table.items():
+            logger.debug(f"{eth_signature} {trx_struct.__dict__}")
             if trx_struct.got_result is not None:
                 seen_slots.difference_update(trx_struct.slot)
                 self.db.submit_transaction(
@@ -447,7 +445,6 @@ def process_receipts(self):
         logger.debug(f"process_receipts_ms: {process_receipts_ms} transaction_receipts.len: {self.transaction_receipts.size()} from {self.processed_slot} to {self.current_slot} slots")
 
 
-
     def gather_blocks(self):
         start_time = time.time()
         last_block_slot = self.db.get_last_block_slot()

proxy/indexer/indexer_db.py

@@ -2,12 +2,10 @@
 import logging
 
 try:
-    from indexer_base import logger, IndexerBase, PARALLEL_REQUESTS
-    from utils import check_error, get_trx_results, get_trx_receipts, LogDB, Canceller
+    from utils import LogDB
     from sql_dict import SQLDict
 except ImportError:
-    from .indexer_base import logger, IndexerBase, PARALLEL_REQUESTS
-    from .utils import check_error, get_trx_results, get_trx_receipts, LogDB, Canceller
+    from .utils import LogDB
     from .sql_dict import SQLDict
 
 logger = logging.getLogger(__name__)