tests: add ec tests (#1175)

Author: roman-khimov

neofs-testlib/neofs_testlib/cli/neofs_cli/object.py

@@ -415,3 +415,27 @@ def searchv2(
             "object searchv2",
             **{param: value for param, value in locals().items() if param not in ["self"]},
         )
+
+    def nodes(
+        self,
+        rpc_endpoint: str,
+        cid: str,
+        oid: Optional[str] = None,
+        shell_timeout: Optional[str] = None,
+    ) -> CommandResult:
+        """
+        Search object.
+
+        Args:
+            rpc_endpoint: Remote node address (as 'multiaddr' or '<host>:<port>').
+            cid: Container ID.
+            oid: Object ID.
+            shell_timeout: Shell timeout for the command.
+
+        Returns:
+            Command's result.
+        """
+        return self._execute(
+            "object nodes",
+            **{param: value for param, value in locals().items() if param not in ["self"]},
+        )

neofs-testlib/neofs_testlib/env/env.py

@@ -28,6 +28,7 @@
 import allure
 import jinja2
 import psutil
+import pytest
 import requests
 import yaml
 from helpers.common import (
@@ -43,6 +44,7 @@
     get_assets_dir_path,
 )
 from helpers.neofs_verbs import get_netmap_netinfo
+from helpers.utility import parse_version
 from tenacity import retry, stop_after_attempt, wait_fixed
 
 from neofs_testlib.cli import NeofsAdm, NeofsCli, NeofsLens, NeoGo
@@ -171,13 +173,16 @@ def generate_neo_go_config(self, wallet: NodeWallet):
         return neo_go_config_path
 
     @allure.step("Deploy inner ring nodes")
-    def deploy_inner_ring_nodes(self, count=1, with_main_chain=False, chain_meta_data=False, sn_validator_url=None):
+    def deploy_inner_ring_nodes(
+        self, count=1, with_main_chain=False, chain_meta_data=False, sn_validator_url=None, allow_ec=False
+    ):
         for _ in range(count):
             new_inner_ring_node = InnerRing(
                 self,
                 len(self.inner_ring_nodes) + 1,
                 chain_meta_data=chain_meta_data,
                 sn_validator_url=sn_validator_url,
+                allow_ec=allow_ec,
             )
             new_inner_ring_node.generate_network_config()
             self.inner_ring_nodes.append(new_inner_ring_node)
@@ -664,6 +669,7 @@ def deploy(
         request=None,
         chain_meta_data=False,
         sn_validator_url=None,
+        allow_ec=False,
         fschain_endpoints: Optional[list[str]] = None,
         shards_count=2,
         gc_remover_batch_size=200,
@@ -675,11 +681,17 @@ def deploy(
         neofs_env = NeoFSEnv(neofs_env_config=neofs_env_config)
         neofs_env.download_binaries()
         try:
+            if allow_ec and parse_version(neofs_env.get_binary_version(neofs_env.neofs_node_path)) <= parse_version(
+                "0.49.1"
+            ):
+                pytest.skip("EC is not supported in versions <= 0.49.1")
+
             neofs_env.deploy_inner_ring_nodes(
                 count=inner_ring_nodes_count,
                 with_main_chain=with_main_chain,
                 chain_meta_data=chain_meta_data,
                 sn_validator_url=sn_validator_url,
+                allow_ec=allow_ec,
             )
 
             if storage_nodes_count:
@@ -1052,11 +1064,7 @@ def _wait_until_ready(self):
 
 class InnerRing(ResurrectableProcess):
     def __init__(
-        self,
-        neofs_env: NeoFSEnv,
-        ir_number: int,
-        chain_meta_data=False,
-        sn_validator_url=None,
+        self, neofs_env: NeoFSEnv, ir_number: int, chain_meta_data=False, sn_validator_url=None, allow_ec=False
     ):
         self.neofs_env = neofs_env
         self.ir_number = ir_number
@@ -1083,6 +1091,7 @@ def __init__(
         self.ir_state_file = self.neofs_env._generate_temp_file(self.inner_ring_dir, prefix="ir_state_file")
         self.chain_meta_data = chain_meta_data
         self.sn_validator_url = sn_validator_url
+        self.allow_ec = allow_ec
         self.stdout = "Not initialized"
         self.stderr = "Not initialized"
         self.process = None
@@ -1178,6 +1187,7 @@ def start(
                 prometheus_address=self.prometheus_address,
                 chain_meta_data=self.chain_meta_data,
                 sn_validator_url=self.sn_validator_url,
+                allow_ec=self.allow_ec,
             )
         logger.info(f"Launching Inner Ring Node:{self}")
         self._launch_process()
@@ -1449,6 +1459,7 @@ def _wait_until_not_ready(self):
             result = neofs_cli.control.healthcheck(endpoint=self.control_endpoint)
         except Exception as e:
             with allure.step(f"Exception caught: {e}, node is not ready"):
+                time.sleep(2)
                 return
         assert "Health status: READY" not in result.stdout, "Health is ready"
         assert "Network status: ONLINE" not in result.stdout, "Network is online"

neofs-testlib/neofs_testlib/env/templates/ir.yaml

@@ -125,6 +125,9 @@ prometheus:
 
 experimental:
   chain_meta_data: {{ chain_meta_data }}
+{% if allow_ec %}
+  allow_ec: {{ allow_ec }}
+{% endif %}
 
 {% if sn_validator_url %}
 sn_validator:

pytest_tests/tests/conftest.py

@@ -38,6 +38,7 @@ def get_or_create_neofs_env(
     with_rest_gw=True,
     chain_meta_data=False,
     sn_validator_url=None,
+    allow_ec=False,
     shards_count=2,
     gc_remover_batch_size=200,
     gc_sleep_interval=STORAGE_GC_TIME,
@@ -56,6 +57,7 @@ def get_or_create_neofs_env(
             request=request,
             chain_meta_data=chain_meta_data,
             sn_validator_url=sn_validator_url,
+            allow_ec=allow_ec,
             shards_count=shards_count,
             gc_remover_batch_size=gc_remover_batch_size,
             gc_sleep_interval=gc_sleep_interval,
@@ -70,7 +72,11 @@ def neofs_env(temp_directory, artifacts_directory, request):
     else:
         params = {}
     neofs_env = get_or_create_neofs_env(
-        request, with_s3_gw=True, with_rest_gw=True, chain_meta_data=params.get("chain_meta_data", False)
+        request,
+        with_s3_gw=True,
+        with_rest_gw=True,
+        chain_meta_data=params.get("chain_meta_data", False),
+        allow_ec=params.get("allow_ec", False),
     )
     yield neofs_env
     neofs_env.finalize(request)