Fix processing big map messages (#125)

Author: droserasprout

src/dipdup/datasources/datasource.py

@@ -73,8 +73,8 @@ def on_head(self, fn: HeadCallback) -> None:
     def emit_operations(self, operations: List[OperationData], block: HeadBlockData) -> None:
         super().emit(EventType.operations, datasource=self, operations=operations, block=block)
 
-    def emit_big_maps(self, big_maps: List[BigMapData]) -> None:
-        super().emit(EventType.big_maps, datasource=self, big_maps=big_maps)
+    def emit_big_maps(self, big_maps: List[BigMapData], block: HeadBlockData) -> None:
+        super().emit(EventType.big_maps, datasource=self, big_maps=big_maps, block=block)
 
     def emit_rollback(self, from_level: int, to_level: int) -> None:
         super().emit(EventType.rollback, datasource=self, from_level=from_level, to_level=to_level)

src/dipdup/datasources/tzkt/datasource.py

@@ -675,7 +675,7 @@ async def _on_big_map_message(self, message: List[Dict[str, Any]]) -> None:
             for big_map_json in data:
                 big_map = self.convert_big_map(big_map_json)
                 big_maps.append(big_map)
-            self.emit_big_maps(big_maps)
+            self.emit_big_maps(big_maps, self.block)
 
     async def _on_head_message(self, message: List[Dict[str, Any]]) -> None:
         async for data in self._extract_message_data('head', message):