logos-blockchain/logos-blockchain-e2e-tests
1
0
Fork 0
mirror of https://github.com/logos-blockchain/logos-blockchain-e2e-tests.git synced 2026-01-03 21:53:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: refactor run for NomosCli

Browse Source
This commit is contained in:
Roman 2025-02-13 10:29:18 +08:00
parent ebd56ce282
commit d340256605
No known key found for this signature in database
GPG Key ID: B8FE070B54E11B75
2 changed files with 37 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

60
src/cli/nomos_cli.py
View File

@ -1,6 +1,7 @@
import json import json
import os import os
import re import re
from enum import Enum
from src.data_storage import DS from src.data_storage import DS
from src.libs.common import generate_log_prefix from src.libs.common import generate_log_prefix
@ -61,33 +62,18 @@ class NomosCli:
DS.nomos_nodes.append(self) DS.nomos_nodes.append(self)
@retry(stop=stop_after_delay(5), wait=wait_fixed(0.1), reraise=True) match self._command:
def stop(self): case "reconstruct":
if self._container: if "decode_only" in kwargs:
logger.debug(f"Stopping container with id {self._container.short_id}") decode_only = kwargs["decode_only"]
self._container.stop() else:
try: decode_only = False
self._container.remove() return self.reconstruct(input_values=input_values, decode_only=decode_only)
except: case _:
pass return
self._container = None
logger.debug("Container stopped.")
@retry(stop=stop_after_delay(5), wait=wait_fixed(0.1), reraise=True) def reconstruct(self, input_values=None, decode_only=False):
def kill(self):
if self._container:
logger.debug(f"Killing container with id {self._container.short_id}")
self._container.kill()
try:
self._container.remove()
except:
pass
self._container = None
logger.debug("Container killed.")
def run_reconstruct(self, input_values=None, decode_only=False):
keywords = ["Reconstructed data"] keywords = ["Reconstructed data"]
self.run(input_values)
log_stream = self._container.logs(stream=True) log_stream = self._container.logs(stream=True)
@ -112,3 +98,27 @@ class NomosCli:
DS.nomos_nodes.remove(self) DS.nomos_nodes.remove(self)
return result return result
@retry(stop=stop_after_delay(5), wait=wait_fixed(0.1), reraise=True)
def stop(self):
if self._container:
logger.debug(f"Stopping container with id {self._container.short_id}")
self._container.stop()
try:
self._container.remove()
except:
pass
self._container = None
logger.debug("Container stopped.")
@retry(stop=stop_after_delay(5), wait=wait_fixed(0.1), reraise=True)
def kill(self):
if self._container:
logger.debug(f"Killing container with id {self._container.short_id}")
self._container.kill()
try:
self._container.remove()
except:
pass
self._container = None
logger.debug("Container killed.")

6
tests/data_integrity/test_data_integrity.py
View File

@ -25,8 +25,7 @@ class TestDataIntegrity(StepsDataAvailability):
rcv_data = self.get_data_range(selected_node, [0] * 31 + [1], [0] * 8, [0] * 7 + [5]) rcv_data = self.get_data_range(selected_node, [0] * 31 + [1], [0] * 8, [0] * 7 + [5])
rcv_data_json = json.dumps(rcv_data) rcv_data_json = json.dumps(rcv_data)
cli = NomosCli(command="reconstruct") reconstructed_data = NomosCli(command="reconstruct").run(input_values=[rcv_data_json])
reconstructed_data = cli.run_reconstruct(input_values=[rcv_data_json])
assert DATA_TO_DISPERSE[0] == reconstructed_data, "Reconstructed data are not same with original data" assert DATA_TO_DISPERSE[0] == reconstructed_data, "Reconstructed data are not same with original data"
@ -38,7 +37,6 @@ class TestDataIntegrity(StepsDataAvailability):
rcv_data = self.get_data_range(self.node2, [0] * 31 + [1], [0] * 8, [0] * 7 + [5]) rcv_data = self.get_data_range(self.node2, [0] * 31 + [1], [0] * 8, [0] * 7 + [5])
rcv_data_json = json.dumps(rcv_data) rcv_data_json = json.dumps(rcv_data)
cli = NomosCli(command="reconstruct") decoded_data = NomosCli(command="reconstruct").run(input_values=[rcv_data_json], decode_only=True)
decoded_data = cli.run_reconstruct(input_values=[rcv_data_json], decode_only=True)
assert DATA_TO_DISPERSE[0] == decoded_data, "Retrieved data are not same with original data" assert DATA_TO_DISPERSE[0] == decoded_data, "Retrieved data are not same with original data"