From 73bcd9cc66ec8a32a7edf6db8291ed5ffeee22e1 Mon Sep 17 00:00:00 2001 From: Petar Radovic Date: Thu, 29 Jan 2026 19:19:00 +0100 Subject: [PATCH 1/2] Updated logos-blockchain node api url path and deserialization --- node.rest | 2 +- src/node/api/http.py | 9 ++++++--- 2 files changed, 7 insertions(+), 4 deletions(-) diff --git a/node.rest b/node.rest index b0b4a41..2edfe2c 100644 --- a/node.rest +++ b/node.rest @@ -21,4 +21,4 @@ GET {{host}}/cryptarchia/blocks?slot_from=0&slot_to=10 ### -GET {{host}}/cryptarchia/blocks/stream +GET {{host}}/cryptarchia/events/blocks/stream diff --git a/src/node/api/http.py b/src/node/api/http.py index cd55992..6fdd52e 100644 --- a/src/node/api/http.py +++ b/src/node/api/http.py @@ -24,7 +24,7 @@ class HttpNodeApi(NodeApi): ENDPOINT_INFO = "cryptarchia/info" ENDPOINT_TRANSACTIONS = "cryptarchia/transactions" ENDPOINT_BLOCKS = "cryptarchia/blocks" - ENDPOINT_BLOCKS_STREAM = "cryptarchia/blocks/stream" + ENDPOINT_BLOCKS_STREAM = "cryptarchia/events/blocks/stream" def __init__(self, settings: "NBESettings"): self.host: str = settings.node_api_host @@ -89,8 +89,11 @@ class HttpNodeApi(NodeApi): if not line: continue try: - block = BlockSerializer.model_validate_json(line) - except ValidationError as error: + import json + + event = json.loads(line) + block = BlockSerializer.model_validate(event["block"]) + except (ValidationError, KeyError, json.JSONDecodeError) as error: logger.exception(error) continue From 864ae0cc8760d2fab545c9780a7d15629d275b2c Mon Sep 17 00:00:00 2001 From: Petar Radovic Date: Thu, 29 Jan 2026 20:48:49 +0100 Subject: [PATCH 2/2] import --- src/node/api/http.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/src/node/api/http.py b/src/node/api/http.py index 6fdd52e..aa317cc 100644 --- a/src/node/api/http.py +++ b/src/node/api/http.py @@ -1,3 +1,4 @@ +import json import logging from typing import TYPE_CHECKING, AsyncIterator, List, Optional from urllib.parse import urljoin, urlunparse @@ -89,8 +90,6 @@ class HttpNodeApi(NodeApi): if not line: continue try: - import json - event = json.loads(line) block = BlockSerializer.model_validate(event["block"]) except (ValidationError, KeyError, json.JSONDecodeError) as error: