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