From 30e2cfa3566182086c0a8fc096458105344a077a Mon Sep 17 00:00:00 2001
From: Igor Sereda <sereda.igor.s@gmail.com>
Date: Mon, 10 Jul 2023 14:38:00 +0300
Subject: [PATCH] Transactions query fullscan fix

---
 src/dipdup/datasources/tzkt/datasource.py | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/src/dipdup/datasources/tzkt/datasource.py b/src/dipdup/datasources/tzkt/datasource.py
index 73aaf8939..54ac0a5bc 100644
--- a/src/dipdup/datasources/tzkt/datasource.py
+++ b/src/dipdup/datasources/tzkt/datasource.py
@@ -578,6 +578,7 @@ async def get_transactions(
             TRANSACTION_OPERATION_FIELDS,
             cursor=True,
             status='applied',
+            sort='level',
         )
         if addresses and not code_hashes:
             params[f'{field}.in'] = ','.join(addresses)
@@ -831,6 +832,7 @@ def _get_request_params(
         limit: int | None = None,
         select: tuple[str, ...] | None = None,
         cursor: bool = False,
+        sort: str | None = None,
         **kwargs: Any,
     ) -> dict[str, Any]:
         params: dict[str, Any] = {
@@ -847,6 +849,13 @@ def _get_request_params(
                 params['offset'] = offset
         if select:
             params['select'] = ','.join(select)
+        if sort:
+            if sort.startswith('-'):
+                sort_param_name = 'sort.desc'
+                sort = sort[1:]
+            else:
+                sort_param_name = 'sort'
+            params[sort_param_name] = sort
         return {
             **params,
             **kwargs,