[BGYSC0822E][1308][Zos_Operator]Console_parallel (#1553)

* Probe solution

* Add fragment

* Fix comment

* Update conftest.py

Delete imports

* Test all times

* Avoid uses of users

* Add fix

* Update test_zos_operator_func.py

Author: AndreMarcel99

changelogs/fragments/1553-Console_parallel.yml

@@ -0,0 +1,3 @@
+trivial:
+  - zos_operator - Validate the use of two terminals with a parallel call of zos_operator.
+    (https://github.com/ansible-collections/ibm_zos_core/pull/1553).

tests/conftest.py

@@ -128,4 +128,11 @@ def perform_imports(imports):
             newimp = [importlib.import_module(x) for x in imports]
         return newimp
 
-    yield (mocker, perform_imports)
+    yield (mocker, perform_imports)
+
+
+@pytest.fixture(scope="function")
+def get_config(request):
+    """ Call the pytest-ansible plugin to check volumes on the system and work properly a list by session."""
+    path = request.config.getoption("--zinventory")
+    yield path

tests/functional/modules/test_zos_operator_func.py

@@ -16,6 +16,9 @@
 __metaclass__ = type
 
 import pytest
+import yaml
+import os
+from shellescape import quote
 
 from ansible_collections.ibm.ibm_zos_core.plugins.module_utils import (
     zoau_version_checker,
@@ -24,6 +27,44 @@
 
 __metaclass__ = type
 
+PARALLEL_RUNNING = """- hosts : zvm
+  collections :
+    - ibm.ibm_zos_core
+  gather_facts: False
+  vars:
+    ZOAU: "{0}"
+    PYZ: "{1}"
+  environment:
+    _BPXK_AUTOCVT: "ON"
+    ZOAU_HOME: "{0}"
+    PYTHONPATH: "{0}/lib"
+    LIBPATH: "{0}/lib:{1}/lib:/lib:/usr/lib:."
+    PATH: "{0}/bin:/bin:/usr/lpp/rsusr/ported/bin:/var/bin:/usr/lpp/rsusr/ported/bin:/usr/lpp/java/java180/J8.0_64/bin:{1}/bin:"
+    _CEE_RUNOPTS: "FILETAG(AUTOCVT,AUTOTAG) POSIX(ON)"
+    _TAG_REDIR_ERR: "txt"
+    _TAG_REDIR_IN: "txt"
+    _TAG_REDIR_OUT: "txt"
+    LANG: "C"
+  tasks:
+      - name: zos_operator
+        zos_operator:
+          cmd: 'd a,all'
+          wait_time_s: 3
+          verbose: true
+        register: output
+
+      - name: print output
+        debug:
+          var: output"""
+
+INVENTORY = """all:
+  hosts:
+    zvm:
+      ansible_host: {0}
+      ansible_ssh_private_key_file: {1}
+      ansible_user: {2}
+      ansible_python_interpreter: /allpython/3.9/usr/lpp/IBM/cyp/v3r9/pyz/bin/python3.9"""
+
 
 def test_zos_operator_various_command(ansible_zos_module):
     test_data = [
@@ -141,3 +182,34 @@ def test_response_come_back_complete(ansible_zos_module):
         # HASP646 Only appears in the last line that before did not appears
         last_line = len(stdout)
         assert "HASP646" in stdout[last_line - 1]
+
+
+def test_zos_operator_parallel_terminal(get_config):
+        path = get_config
+        with open(path, 'r') as file:
+            enviroment = yaml.safe_load(file)
+        ssh_key = enviroment["ssh_key"]
+        hosts = enviroment["host"].upper()
+        user = enviroment["user"].upper()
+        python_path = enviroment["python_path"]
+        cut_python_path = python_path[:python_path.find('/bin')].strip()
+        zoau = enviroment["environment"]["ZOAU_ROOT"]
+        try:
+            playbook = "playbook.yml"
+            inventory = "inventory.yml"
+            os.system("echo {0} > {1}".format(quote(PARALLEL_RUNNING.format(
+                zoau,
+                cut_python_path,
+            )), playbook))
+            os.system("echo {0} > {1}".format(quote(INVENTORY.format(
+                hosts,
+                ssh_key,
+                user,
+            )), inventory))
+            command = "(ansible-playbook -i {0} {1}) & (ansible-playbook -i {0} {1})".format(inventory, playbook)
+            stdout = os.system(command)
+            assert stdout == 0
+        finally:
+            os.remove("inventory.yml")
+            os.remove("playbook.yml")
+