rp_launch_id` property handling moved completely on Client side, by @HardNorth

Author: HardNorth

CHANGELOG.md

@@ -3,6 +3,7 @@
 ## [Unreleased]
 ### Changed
 - Client version updated on [5.5.4](https://github.com/reportportal/client-Python/releases/tag/5.5.4), by @HardNorth
+- `rp_launch_id` property handling moved completely on Client side, by @HardNorth
 
 ## [5.3.0]
 ### Added

pytest_reportportal/plugin.py

@@ -53,8 +53,7 @@ def pytest_configure_node(node):
     if not node.config._rp_enabled:
         # Stop now if the plugin is not properly configured
         return
-    node.workerinput['py_test_service'] = pickle.dumps(
-        node.config.py_test_service)
+    node.workerinput['py_test_service'] = pickle.dumps(node.config.py_test_service)
 
 
 def is_control(config):
@@ -102,7 +101,7 @@ def pytest_sessionstart(session):
         config._rp_enabled = False
         return
 
-    if is_control(config) and not config._reporter_config.rp_launch_id:
+    if is_control(config):
         config.py_test_service.start_launch()
         if config.pluginmanager.hasplugin('xdist') \
                 or config.pluginmanager.hasplugin('pytest-parallel'):
@@ -137,8 +136,7 @@ def pytest_sessionfinish(session):
         return
 
     config.py_test_service.finish_suites()
-    if is_control(config) \
-            and not config._reporter_config.rp_launch_id:
+    if is_control(config):
         config.py_test_service.finish_launch()
 
     config.py_test_service.stop()
@@ -224,8 +222,7 @@ def pytest_configure(config):
         config.py_test_service = PyTestServiceClass(agent_config)
     else:
         # noinspection PyUnresolvedReferences
-        config.py_test_service = pickle.loads(
-            config.workerinput['py_test_service'])
+        config.py_test_service = pickle.loads(config.workerinput['py_test_service'])
 
 
 # noinspection PyProtectedMember

pytest_reportportal/service.py

@@ -184,8 +184,7 @@ def _get_launch_attributes(self, ini_attrs):
 
     def _build_start_launch_rq(self):
         rp_launch_attributes = self._config.rp_launch_attributes
-        attributes = gen_attributes(rp_launch_attributes) \
-            if rp_launch_attributes else None
+        attributes = gen_attributes(rp_launch_attributes) if rp_launch_attributes else None
 
         start_rq = {
             'attributes': self._get_launch_attributes(attributes),
@@ -909,7 +908,7 @@ def start(self) -> None:
             log_batch_size=self._config.rp_log_batch_size,
             retries=self._config.rp_api_retries,
             verify_ssl=self._config.rp_verify_ssl,
-            launch_id=launch_id,
+            launch_uuid=launch_id,
             log_batch_payload_size=self._config.rp_log_batch_payload_size,
             launch_uuid_print=self._config.rp_launch_uuid_print,
             print_output=self._config.rp_launch_uuid_print_output,

tests/__init__.py

@@ -14,3 +14,4 @@
 """This package contains tests for the project."""
 
 REPORT_PORTAL_SERVICE = 'reportportal_client.RPClient'
+REQUESTS_SERVICE = 'reportportal_client.client.requests.Session'

tests/integration/test_config_handling.py

@@ -22,40 +22,29 @@
 from reportportal_client import OutputType
 
 from examples.test_rp_logging import LOG_MESSAGE
-from tests import REPORT_PORTAL_SERVICE
+from tests import REPORT_PORTAL_SERVICE, REQUESTS_SERVICE
 from tests.helpers import utils
 
 TEST_LAUNCH_ID = 'test_launch_id'
 
 
-@mock.patch(REPORT_PORTAL_SERVICE)
-def test_rp_launch_id(mock_client_init):
+@mock.patch(REQUESTS_SERVICE)
+def test_rp_launch_id(mock_requests_init):
     """Verify that RP plugin does not start/stop launch if 'rp_launch_id' set.
 
-    :param mock_client_init: Pytest fixture
+    :param mock_requests_init: mocked requests lib
     """
     variables = dict()
     variables['rp_launch_id'] = TEST_LAUNCH_ID
     variables.update(utils.DEFAULT_VARIABLES.items())
-    result = utils.run_pytest_tests(tests=['examples/test_simple.py'],
-                                    variables=variables)
-
+    result = utils.run_pytest_tests(tests=['examples/test_simple.py'], variables=variables)
     assert int(result) == 0, 'Exit code should be 0 (no errors)'
 
-    expect(
-        mock_client_init.call_args_list[0][1]['launch_id'] == TEST_LAUNCH_ID)
-
-    mock_client = mock_client_init.return_value
-    expect(mock_client.start_launch.call_count == 0,
-           '"start_launch" method was called')
-    expect(mock_client.finish_launch.call_count == 0,
-           '"finish_launch" method was called')
-
-    start_call_args = mock_client.start_test_item.call_args_list
-    finish_call_args = mock_client.finish_test_item.call_args_list
-
-    expect(len(start_call_args) == len(finish_call_args))
-    assert_expectations()
+    mock_requests = mock_requests_init.return_value
+    assert mock_requests.post.call_count == 1
+    item_start = mock_requests.post.call_args_list[0]
+    assert item_start[0][0].endswith('/item')
+    assert item_start[1]['json']['launchUuid'] == TEST_LAUNCH_ID
 
 
 @mock.patch(REPORT_PORTAL_SERVICE)
@@ -68,8 +57,7 @@ def test_rp_parent_item_id(mock_client_init):
     variables = dict()
     variables['rp_parent_item_id'] = parent_id
     variables.update(utils.DEFAULT_VARIABLES.items())
-    result = utils.run_pytest_tests(tests=['examples/test_simple.py'],
-                                    variables=variables)
+    result = utils.run_pytest_tests(tests=['examples/test_simple.py'], variables=variables)
 
     assert int(result) == 0, 'Exit code should be 0 (no errors)'
 
@@ -87,34 +75,26 @@ def test_rp_parent_item_id(mock_client_init):
     assert_expectations()
 
 
-@mock.patch(REPORT_PORTAL_SERVICE)
-def test_rp_parent_item_id_and_rp_launch_id(mock_client_init):
+@mock.patch(REQUESTS_SERVICE)
+def test_rp_parent_item_id_and_rp_launch_id(mock_requests_init):
     """Verify RP handles both conf props 'rp_parent_item_id' & 'rp_launch_id'.
 
-    :param mock_client_init: Pytest fixture
+    :param mock_requests_init: mocked requests lib
     """
     parent_id = "parent_id"
     variables = dict()
     variables['rp_parent_item_id'] = parent_id
-    variables['rp_launch_id'] = "test_launch_id"
+    variables['rp_launch_id'] = TEST_LAUNCH_ID
     variables.update(utils.DEFAULT_VARIABLES.items())
-    result = utils.run_pytest_tests(tests=['examples/test_simple.py'],
-                                    variables=variables)
-
+    result = utils.run_pytest_tests(tests=['examples/test_simple.py'],variables=variables)
     assert int(result) == 0, 'Exit code should be 0 (no errors)'
 
-    mock_client = mock_client_init.return_value
-    expect(mock_client.start_launch.call_count == 0,
-           '"start_launch" method was called')
-    expect(mock_client.finish_launch.call_count == 0,
-           '"finish_launch" method was called')
-
-    start_call_args = mock_client.start_test_item.call_args_list
-    finish_call_args = mock_client.finish_test_item.call_args_list
+    mock_requests = mock_requests_init.return_value
+    assert mock_requests.post.call_count == 1
+    item_start = mock_requests.post.call_args_list[0]
+    assert item_start[0][0].endswith(f'/item/{parent_id}')
+    assert item_start[1]['json']['launchUuid'] == TEST_LAUNCH_ID
 
-    expect(len(start_call_args) == len(finish_call_args))
-    expect(start_call_args[0][1]["parent_item_id"] == parent_id)
-    assert_expectations()
 
 
 @mock.patch(REPORT_PORTAL_SERVICE)