Feat[IT]: FSM fixtures (#818)

Signed-off-by: JEAN-LOUIS "JL" LEROY <JLEROY9@bloomberg.net>

Author: jll63

src/integration-tests/conftest.py

@@ -31,7 +31,14 @@
 from blazingmq.dev.it.testhooks import PHASE_REPORT_KEY
 
 # pylint: disable=unused-import, wrong-import-position
-from blazingmq.dev.it.fixtures import cluster, multi_node, single_node
+from blazingmq.dev.it.fixtures import (
+    single_node,
+    multi_node,
+    cluster,
+    fsm_single_node,
+    fsm_multi_node,
+    fsm_cluster,
+)
 
 
 @pytest.hookimpl(hookwrapper=True, tryfirst=True)

src/python/blazingmq/dev/it/fixtures.py

@@ -830,3 +830,50 @@ def cluster_config(request, config):
 @pytest.fixture(params=cartesian_product_cluster_params)
 def cartesian_product_cluster(request):
     yield from cluster_fixture(request, request.param)
+
+
+###############################################################################
+# FSM
+
+
+@pytest.fixture
+def fsm_single_node(request):
+    yield from cluster_fixture(
+        request, functools.partial(single_node_cluster_config, mode=Mode.FSM)
+    )
+
+
+@pytest.fixture
+def fsm_multi_node(request):
+    yield from cluster_fixture(
+        request, functools.partial(multi_node_cluster_config, mode=Mode.FSM)
+    )
+
+
+fsm_cluster_params = [
+    pytest.param(
+        functools.partial(single_node_cluster_config, mode=Mode.FSM),
+        id="fsm_single_node",
+        marks=[
+            pytest.mark.integrationtest,
+            pytest.mark.pr_integrationtest,
+            pytest.mark.single,
+            *Mode.FSM.marks,
+        ],
+    ),
+    pytest.param(
+        functools.partial(multi_node_cluster_config, mode=Mode.FSM),
+        id="fsm_multi_node",
+        marks=[
+            pytest.mark.integrationtest,
+            pytest.mark.pr_integrationtest,
+            pytest.mark.multi,
+            *Mode.FSM.marks,
+        ],
+    ),
+]
+
+
+@pytest.fixture(params=fsm_cluster_params)
+def fsm_cluster(request):
+    yield from cluster_fixture(request, request.param)