Fix setting index state level, TzKT getters, single-level rollbacks (#320)

* Fix setting index state level, fix TzKT getters

* Fixed crash when no block with the same level arrived after a single-level rollback

* Remove useless check

Author: droserasprout

CHANGELOG.md

@@ -1,18 +1,26 @@
 # Changelog
 
+## [unreleased]
+
+### Fixed
+
+* tzkt: Fixed inconsistent behavior of `first_level`/`last_level` arguments in different getter methods.
+* index: Fixed crash when no block with the same level arrived after a single-level rollback.
+* index: Fixed setting initial index level when `IndexConfig.first_level` is set.
+
 ## 5.0.2 - 2022-04-21
 
 ### Fixed
 
 * context: Fixed reporting incorrect reindexing reason.
-* exceptions: Fixed crash with `FrozenInstanceError` when exception is raised from callback.
+* exceptions: Fixed crash with `FrozenInstanceError` when an exception is raised from a callback.
 * jobs: Fixed graceful shutdown of daemon jobs.
 
 ### Improved
 
 * codegen: Refined `on_rollback` hook template.
 * exceptions: Updated help messages for known exceptions.
-* tzkt: Do not request reindexing if missing subgroups matched no handlers.
+* tzkt: Do not request reindexing if missing subgroups have matched no handlers.
 
 ## 5.0.1 - 2022-04-12
 

src/dipdup/datasources/tzkt/datasource.py

@@ -483,7 +483,7 @@ async def get_migration_originations(
             url='v1/operations/migrations',
             params={
                 'kind': 'origination',
-                'level.gt': first_level,
+                'level.ge': first_level,
                 'select': ','.join(ORIGINATION_MIGRATION_FIELDS),
                 'offset.cr': offset,
                 'limit': limit,
@@ -519,7 +519,7 @@ async def get_originations(
                 url='v1/operations/originations',
                 params={
                     "originatedContract.in": ','.join(addresses_chunk),
-                    "level.gt": first_level,
+                    "level.ge": first_level,
                     "level.le": last_level,
                     "select": ','.join(ORIGINATION_OPERATION_FIELDS),
                     "status": "applied",
@@ -548,7 +548,7 @@ async def get_transactions(
                 f"{field}.in": ','.join(addresses),
                 "offset.cr": offset,
                 "limit": limit,
-                "level.gt": first_level,
+                "level.ge": first_level,
                 "level.le": last_level,
                 "select": ','.join(TRANSACTION_OPERATION_FIELDS),
                 "status": "applied",
@@ -594,7 +594,7 @@ async def get_big_maps(
             params={
                 "contract.in": ",".join(addresses),
                 "path.in": ",".join(paths),
-                "level.gt": first_level,
+                "level.ge": first_level,
                 "level.le": last_level,
                 "offset": offset,
                 "limit": limit,
@@ -635,20 +635,20 @@ async def get_quote(self, level: int) -> QuoteData:
 
     async def get_quotes(
         self,
-        from_level: int,
-        to_level: int,
+        first_level: int,
+        last_level: int,
         offset: Optional[int] = None,
         limit: Optional[int] = None,
     ) -> Tuple[QuoteData, ...]:
         """Get quotes for blocks"""
         offset, limit = offset or 0, limit or self.request_limit
-        self._logger.info('Fetching quotes for levels %s-%s', from_level, to_level)
+        self._logger.info('Fetching quotes for levels %s-%s', first_level, last_level)
         quotes_json = await self.request(
             'get',
             url='v1/quotes',
             params={
-                "level.ge": from_level,
-                "level.lt": to_level,
+                "level.ge": first_level,
+                "level.le": last_level,
                 "offset.cr": offset,
                 "limit": limit,
             },
@@ -658,14 +658,14 @@ async def get_quotes(
 
     async def iter_quotes(
         self,
-        from_level: int,
-        to_level: int,
+        first_level: int,
+        last_level: int,
     ) -> AsyncIterator[Tuple[QuoteData, ...]]:
         """Iterate quotes for blocks"""
         async for batch in self._iter_batches(
             self.get_quotes,
-            from_level,
-            to_level,
+            first_level,
+            last_level,
         ):
             yield batch