TzktDatasource get_transactions() fix

dipdup-io · Oct 10, 2023 · dc85247 · dc85247
1 parent e3b6e64
commit dc85247
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/src/dipdup/datasources/tezos_tzkt.py b/src/dipdup/datasources/tezos_tzkt.py
@@ -713,14 +713,16 @@ async def get_transactions(
         params = self._get_request_params(
             first_level=first_level,
             last_level=last_level,
-            offset=offset,
             limit=limit,
             select=TRANSACTION_OPERATION_FIELDS,
             values=True,
-            cursor=True,
             sort='level',
             status='applied',
         )
+
+        if offset is not None:
+            params['id.gte'] = offset
+
         if addresses and not code_hashes:
             params[f'{field}.in'] = ','.join(addresses)
         elif code_hashes and not addresses:

diff --git a/src/dipdup/indexes/tezos_tzkt_operations/matcher.py b/src/dipdup/indexes/tezos_tzkt_operations/matcher.py
@@ -208,6 +208,8 @@ def match_operation_subgroup(
         transaction = handler[2][-1]
         if isinstance(transaction, TzktOperationData):
             id_list.append(transaction.id)
+        elif isinstance(transaction, TzktOrigination):
+            id_list.append(transaction.data.id)
         elif isinstance(transaction, TzktTransaction):
             id_list.append(transaction.data.id)
         else: