logos-blockchain/logos-blockchain-specs
1
0
Fork 0
mirror of https://github.com/logos-blockchain/logos-blockchain-specs.git synced 2026-07-29 10:03:14 +00:00
Code Issues Packages Projects Releases Wiki Activity

More wrong imports

Browse Source
This commit is contained in:
Daniel 2025-06-04 15:26:48 +02:00
parent 85afceb5ad
commit c3172895f4
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
da/test_full_flow.py
View File

@ -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)