From c3172895f4b45748cdf9a6e2398da7d153804235 Mon Sep 17 00:00:00 2001 From: Daniel Date: Wed, 4 Jun 2025 15:26:48 +0200 Subject: [PATCH] More wrong imports --- da/test_full_flow.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/da/test_full_flow.py b/da/test_full_flow.py index 66ef032..9f9f6a4 100644 --- a/da/test_full_flow.py +++ b/da/test_full_flow.py @@ -4,7 +4,7 @@ from typing import List, Optional from da.common import NodeId, build_blob_id, NomosDaG2ProofOfPossession as bls_pop from da.api.common import DAApi, BlobMetadata, Metadata -from da.verifier import DAVerifier, DABlob +from da.verifier import DAVerifier, DAShare from da.api.test_flow import MockStore from da.dispersal import Dispersal, DispersalSettings from da.test_encoder import TestEncoder @@ -17,7 +17,7 @@ class DAVerifierWApi: self.api = DAApi(self.store) self.verifier = DAVerifier() - def receive_blob(self, blob: DABlob): + def receive_blob(self, blob: DAShare): if self.verifier.verify(blob): # Warning: If aggregated col commitment and row commitment are the same, # the build_attestation_message method will produce the same output. @@ -30,7 +30,7 @@ class DAVerifierWApi: # in which case all certificates had been already verified by the DA Node. self.api.write(blob_metadata.blob_id, blob_metadata.metadata) - def read(self, app_id, indexes) -> List[Optional[DABlob]]: + def read(self, app_id, indexes) -> List[Optional[DAShare]]: return self.api.read(app_id, indexes) @@ -59,7 +59,7 @@ class TestFullFlow(TestCase): encoded_data = DAEncoder(encoding_params).encode(data) # mock send and await method with local verifiers - def __send_and_await_response(node: int, blob: DABlob): + def __send_and_await_response(node: int, blob: DAShare): node = self.api_nodes[int.from_bytes(node)] node.receive_blob(blob) @@ -96,7 +96,7 @@ class TestFullFlow(TestCase): encoded_data = DAEncoder(encoding_params).encode(data) # mock send and await method with local verifiers - def __send_and_await_response(node: int, blob: DABlob): + def __send_and_await_response(node: int, blob: DAShare): node = self.api_nodes[int.from_bytes(node)] return node.receive_blob(blob)