chore: refomatted with black due to precommit failures

Author: lempira

examples/payments/payments.py

@@ -59,7 +59,9 @@ def print_payment(transaction: SubscribedTransaction, filter_name: str) -> None:
     Here we are only using this EventListener callback for one filter, but if we had multiple filters we could use the filter name to determine which filter the transaction matched.
     """
     pay = transaction["payment-transaction"]
-    print(f"{filter_name}: {transaction['sender']} sent {pay['receiver']} {pay['amount'] * 1e-6} ALGO")
+    print(
+        f"{filter_name}: {transaction['sender']} sent {pay['receiver']} {pay['amount'] * 1e-6} ALGO"
+    )
 
 
 # Attach our callback to the 'pay txns' filter

examples/usdc/usdc.py

@@ -55,7 +55,9 @@ def print_usdc(transaction: SubscribedTransaction, filter_name: str) -> None:
     Here we are only using this EventListener callback for one filter, but if we had multiple filters we could use the filter name to determine which filter the transaction matched.
     """
     axfer = transaction["asset-transfer-transaction"]
-    print(f"{filter_name}: {transaction['sender']} sent {axfer['receiver']} {axfer['amount'] * 1e-6} USDC")
+    print(
+        f"{filter_name}: {transaction['sender']} sent {axfer['receiver']} {axfer['amount'] * 1e-6} USDC"
+    )
 
 
 subscriber.on("usdc", print_usdc)

src/algokit_subscriber/block.py

@@ -11,7 +11,9 @@
 def block_response_to_block_data(response: bytes) -> BlockData:
     return cast(
         "BlockData",
-        msgpack.unpackb(response, strict_map_key=False, unicode_errors="surrogateescape"),
+        msgpack.unpackb(
+            response, strict_map_key=False, unicode_errors="surrogateescape"
+        ),
     )
 
 
@@ -23,7 +25,9 @@ def get_blocks_bulk(context: dict[str, int], client: AlgodClient) -> list[BlockD
     :return: The blocks
     """
     # Grab 30 at a time to not overload the node
-    block_chunks = chunk_array(range_inclusive(context["start_round"], context["max_round"]), 30)
+    block_chunks = chunk_array(
+        range_inclusive(context["start_round"], context["max_round"]), 30
+    )
     blocks = []
 
     for chunk in block_chunks:
@@ -41,6 +45,8 @@ def get_blocks_bulk(context: dict[str, int], client: AlgodClient) -> list[BlockD
             blocks.append(decoded)
 
         elapsed_time = time.time() - start_time
-        logger.debug(f"Retrieved {len(chunk)} blocks from round {chunk[0]} via algod in {elapsed_time:.2f}s")
+        logger.debug(
+            f"Retrieved {len(chunk)} blocks from round {chunk[0]} via algod in {elapsed_time:.2f}s"
+        )
 
     return blocks

src/algokit_subscriber/indexer_lookup.py

@@ -26,7 +26,9 @@ def transaction(transaction_id: str, indexer: IndexerClient) -> TransactionLooku
     return indexer.transaction(txid=transaction_id)  # type: ignore[no-untyped-call, no-any-return]
 
 
-def lookup_account_by_address(account_address: str, indexer: IndexerClient) -> AccountLookupResult:
+def lookup_account_by_address(
+    account_address: str, indexer: IndexerClient
+) -> AccountLookupResult:
     """
     Looks up an account by address using Indexer.
     """
@@ -62,7 +64,9 @@ def build_request(next_token: str | None = None) -> dict[str, Any]:
 
         return args
 
-    return execute_paginated_request(indexer.lookup_account_application_by_creator, extract_items, build_request)
+    return execute_paginated_request(
+        indexer.lookup_account_application_by_creator, extract_items, build_request
+    )
 
 
 def lookup_asset_holdings(
@@ -84,17 +88,29 @@ def build_request(next_token: str | None = None) -> dict[str, Any]:
         args: dict[str, Any] = {
             "asset-id": asset_id,
             "limit": pagination_limit or DEFAULT_INDEXER_MAX_API_RESOURCES_PER_ACCOUNT,
-            "include-all": (options["include-all"] if options and "include-all" in options else None),
-            "currency-greater-than": (options["currency-greater-than"] if options and "currency-greater-than" in options else None),
-            "currency-less-than": (options["currency-less-than"] if options and "currency-less-than" in options else None),
+            "include-all": (
+                options["include-all"] if options and "include-all" in options else None
+            ),
+            "currency-greater-than": (
+                options["currency-greater-than"]
+                if options and "currency-greater-than" in options
+                else None
+            ),
+            "currency-less-than": (
+                options["currency-less-than"]
+                if options and "currency-less-than" in options
+                else None
+            ),
         }
 
         if next_token:
             args["next-token"] = next_token
 
         return args
 
-    return execute_paginated_request(indexer.lookup_account_assets, extract_items, build_request)
+    return execute_paginated_request(
+        indexer.lookup_account_assets, extract_items, build_request
+    )
 
 
 def search_transactions(
@@ -116,13 +132,17 @@ def extract_items(response: TransactionSearchResults) -> list[TransactionResult]
 
     def build_request(next_token: str | None = None) -> dict[str, Any]:
         args: dict[str, Any] = search_criteria
-        args["limit"] = pagination_limit or DEFAULT_INDEXER_MAX_API_RESOURCES_PER_ACCOUNT
+        args["limit"] = (
+            pagination_limit or DEFAULT_INDEXER_MAX_API_RESOURCES_PER_ACCOUNT
+        )
         if next_token:
             args["next_page"] = next_token
 
         return args
 
-    transactions = execute_paginated_request(indexer.search_transactions, extract_items, build_request)
+    transactions = execute_paginated_request(
+        indexer.search_transactions, extract_items, build_request
+    )
 
     return {
         "current-round": current_round,

src/algokit_subscriber/subscriber.py

@@ -42,7 +42,9 @@ def __init__(
         self.filter_names = [f["name"] for f in self.config["filters"]]
 
         if config["sync_behaviour"] == "catchup-with-indexer" and not indexer_client:
-            raise ValueError("Received sync behaviour of catchup-with-indexer, but didn't receive an indexer instance.")
+            raise ValueError(
+                "Received sync behaviour of catchup-with-indexer, but didn't receive an indexer instance."
+            )
 
     def default_error_handler(
         self,
@@ -58,7 +60,9 @@ def poll_once(self) -> TransactionSubscriptionResult:
         watermark = self.config["watermark_persistence"]["get"]() or 0
         current_round = cast("dict", self.algod.status())["last-round"]
 
-        self.event_emitter.emit("before:poll", {"watermark": watermark, "current_round": current_round})
+        self.event_emitter.emit(
+            "before:poll", {"watermark": watermark, "current_round": current_round}
+        )
 
         poll_result = get_subscribed_transactions(
             subscription=cast(
@@ -72,11 +76,21 @@ def poll_once(self) -> TransactionSubscriptionResult:
         try:
             for filter_name in self.filter_names:
                 mapper = next(
-                    (f.get("mapper") for f in self.config["filters"] if f["name"] == filter_name),
+                    (
+                        f.get("mapper")
+                        for f in self.config["filters"]
+                        if f["name"] == filter_name
+                    ),
                     None,
                 )
-                matched_transactions = [t for t in poll_result["subscribed_transactions"] if filter_name in (t.get("filters_matched") or [])]
-                mapped_transactions = mapper(matched_transactions) if mapper else matched_transactions
+                matched_transactions = [
+                    t
+                    for t in poll_result["subscribed_transactions"]
+                    if filter_name in (t.get("filters_matched") or [])
+                ]
+                mapped_transactions = (
+                    mapper(matched_transactions) if mapper else matched_transactions
+                )
 
                 self.event_emitter.emit(f"batch:{filter_name}", mapped_transactions)
                 for transaction in mapped_transactions:
@@ -112,12 +126,16 @@ def start(  # noqa: C901
                 duration_in_seconds = time.time() - start_time
 
                 if not suppress_log:
-                    logger.info(f"Subscription poll completed in {duration_in_seconds:.2f}s")
+                    logger.info(
+                        f"Subscription poll completed in {duration_in_seconds:.2f}s"
+                    )
                     logger.info(f"Current round: {result['current_round']}")
                     logger.info(f"Starting watermark: {result['starting_watermark']}")
                     logger.info(f"New watermark: {result['new_watermark']}")
                     logger.info(f"Synced round range: {result['synced_round_range']}")
-                    logger.info(f"Subscribed transactions: {len(result['subscribed_transactions'])}")
+                    logger.info(
+                        f"Subscribed transactions: {len(result['subscribed_transactions'])}"
+                    )
 
                 if inspect:
                     inspect(result)
@@ -126,7 +144,9 @@ def start(  # noqa: C901
                 if self.stop_requested:
                     break  # type: ignore[unreachable]
 
-                if result["current_round"] > result["new_watermark"] or not self.config.get("wait_for_block_when_at_tip", False):
+                if result["current_round"] > result[
+                    "new_watermark"
+                ] or not self.config.get("wait_for_block_when_at_tip", False):
                     sleep_time = self.config.get("frequency_in_seconds", 1)
                     if not suppress_log:
                         logger.info(f"Sleeping for {sleep_time}s")
@@ -138,7 +158,9 @@ def start(  # noqa: C901
                     wait_start = time.time()
                     self.algod.status_after_block(result["current_round"])
                     if not suppress_log:
-                        logger.info(f"Waited for {time.time() - wait_start:.2f}s until next block")
+                        logger.info(
+                            f"Waited for {time.time() - wait_start:.2f}s until next block"
+                        )
             except Exception as e:
                 self.event_emitter.emit("error", e)
         self.started = False
@@ -154,11 +176,15 @@ def on(self, filter_name: str, listener: EventListener) -> "AlgorandSubscriber":
         Register an event handler to run on every subscribed transaction matching the given filter name.
         """
         if filter_name == "error":
-            raise ValueError("'error' is reserved, please supply a different filter_name.")
+            raise ValueError(
+                "'error' is reserved, please supply a different filter_name."
+            )
         self.event_emitter.on(filter_name, listener)
         return self
 
-    def on_batch(self, filter_name: str, listener: EventListener) -> "AlgorandSubscriber":
+    def on_batch(
+        self, filter_name: str, listener: EventListener
+    ) -> "AlgorandSubscriber":
         """
         Register an event handler to run on all subscribed transactions matching the given filter name
         for each subscription poll.