Limit get_txs output

proxy/environment.py

@@ -31,6 +31,7 @@
 HISTORY_START = "7BdwyUQ61RUZP63HABJkbW66beLk22tdXnP69KsvQBJekCPVaHoJY47Rw68b3VV1UbQNHxX3uxUSLfiJrfy2bTn"
 INDEXER_POLL_COUNT = int(os.environ.get("INDEXER_POLL_COUNT", "1000"))
 START_SLOT = os.environ.get('START_SLOT', 0)
+INDEXER_RECEIPTS_COUNT_LIMIT = int(os.environ.get("INDEXER_RECEIPTS_COUNT_LIMIT", "1000"))
 FINALIZED = os.environ.get('FINALIZED', 'finalized')
 CANCEL_TIMEOUT = int(os.environ.get("CANCEL_TIMEOUT", "60"))
 ACCOUNT_PERMISSION_UPDATE_INT = int(os.environ.get("ACCOUNT_PERMISSION_UPDATE_INT", 60 * 5))

proxy/indexer/trx_receipts_storage.py

@@ -1,3 +1,4 @@
+from proxy.environment import INDEXER_RECEIPTS_COUNT_LIMIT
 from proxy.indexer.pg_common import encode, decode
 from proxy.indexer.base_db import BaseDB
 
@@ -45,7 +46,8 @@ def contains(self, slot, signature):
     def get_txs(self, start_slot=0):
         with self._conn.cursor() as cur:
             cur.execute(f'SELECT slot, signature, tx FROM {self._table_name}' +
-                        f' WHERE slot >= {start_slot} ORDER BY slot ASC, tx_idx DESC')
+                        f' WHERE slot >= {start_slot} ORDER BY slot ASC, tx_idx DESC' +
+                        f' LIMIT {INDEXER_RECEIPTS_COUNT_LIMIT}')
             rows = cur.fetchall()
             for row in rows:
                 yield int(row[0]), row[1], decode(row[2])