tests: remote_tmp test fixes.

docs/changelog.rst

@@ -194,7 +194,8 @@ the bug reports in this release contributed by
 `Pierre-Henry Muller <https://github.com/pierrehenrymuller>`_,
 `Pierre-Louis Bonicoli <https://github.com/jesteria>`_,
 `Prateek Jain <https://github.com/prateekj201>`_,
-`Rick Box <https://github.com/boxrick>`_, and
+`Rick Box <https://github.com/boxrick>`_,
+`Tawana Musewe <https://github.com/tbtmuse>`_, and
 `Timo Beckers <https://github.com/ti-mo>`_.
 
 

tests/ansible/integration/action/make_tmp_path.yml

@@ -23,27 +23,88 @@
         method: _make_tmp_path
       register: tmp_path
 
-    - name: "Write some junk in regular temp path"
+    - name: "Find regular temp path (new task)"
-      shell: hostname > {{tmp_path.result}}/hostname
+      action_passthrough:
+        method: _make_tmp_path
+      register: tmp_path2
 
-    - name: "Verify junk did not persist across tasks"
+    - name: "Find parent temp path"
-      stat: path={{tmp_path.result}}/hostname
+      set_fact:
-      register: junk_stat
+        parent_temp_path: "{{tmp_path.result|dirname}}"
 
-    - name: "Verify junk did not persist across tasks"
+    - name: "Find parent temp path (new task)"
+      set_fact:
+        parent_temp_path2: "{{tmp_path2.result|dirname}}"
+
+    - name: "Verify common base path for both tasks"
       assert:
         that:
-        - not junk_stat.stat.exists
+        - parent_temp_path == parent_temp_path2
 
-    - name: "Verify temp path hasn't changed since start"
+    - name: "Verify different subdir for both tasks"
-      action_passthrough:
+      assert:
-        method: _make_tmp_path
+        that:
-      register: tmp_path2
+        - tmp_path.result != tmp_path2.result
 
-    - name: "Verify temp path hasn't changed since start"
+    #
+    # Verify subdirectory removal.
+    #
+
+    - name: Stat temp path
+      stat:
+        path: "{{tmp_path.result}}"
+      register: stat1
+
+    - name: Stat temp path (new task)
+      stat:
+        path: "{{tmp_path2.result}}"
+      register: stat2
+
+    - name: "Verify neither subdir exists any more"
+      assert:
+        that:
+        - not stat1.stat.exists
+        - not stat2.stat.exists
+
+    #
+    # Verify parent directory persistence.
+    #
+
+    - name: Stat parent temp path (new task)
+      stat:
+        path: "{{parent_temp_path}}"
+      register: stat
+
+    - name: "Verify parent temp path is persistent"
       assert:
         that:
-        - tmp_path2.result == tmp_path.result
+        - stat.stat.exists
+
+    #
+    # Write some junk into the temp path.
+    #
+
+    - name: "Write junk to temp path and verify it disappears"
+      custom_python_run_script:
+        script: |
+          from ansible.module_utils.basic import get_module_path
+          path = get_module_path() + '/foo.txt'
+          result['path'] = path
+          open(path, 'w').write("bar")
+      register: out
+
+    - name: "Verify junk disappeared."
+      stat:
+        path: "{{out.path}}"
+      register: out
+
+    - assert:
+        that:
+        - not out.stat.exists
+
+    #
+    #
+    #
 
     - name: "Verify temp path changes across connection reset"
       mitogen_shutdown_all:
@@ -53,13 +114,17 @@
         method: _make_tmp_path
       register: tmp_path2
 
+    - name: "Verify temp path changes across connection reset"
+      set_fact:
+        parent_temp_path2: "{{tmp_path2.result|dirname}}"
+
     - name: "Verify temp path changes across connection reset"
       assert:
         that:
-        - tmp_path2.result != tmp_path.result
+        - parent_temp_path != parent_temp_path2
 
     - name: "Verify old path disappears across connection reset"
-      stat: path={{tmp_path.result}}
+      stat: path={{parent_temp_path}}
       register: junk_stat
 
     - name: "Verify old path disappears across connection reset"
@@ -89,24 +154,18 @@
     - name: "Try writing to temp directory for the readonly_homedir user"
       become: true
       become_user: mitogen__readonly_homedir
-      action_passthrough:
+      custom_python_run_script:
-        method: _make_tmp_path
+        script: |
+          from ansible.module_utils.basic import get_module_path
+          path = get_module_path() + '/foo.txt'
+          result['path'] = path
+          open(path, 'w').write("bar")
       register: tmp_path
 
-    - name: "Try writing to temp directory for the readonly_homedir user"
-      become: true
-      become_user: mitogen__readonly_homedir
-      shell: hostname > {{tmp_path.result}}/hostname
-
     #
-    # modules get the same temp dir
+    # modules get the same base dir
     #
 
-    - name: "Verify modules get the same tmpdir as the action plugin"
-      action_passthrough:
-        method: _make_tmp_path
-      register: tmp_path
-
     - name: "Verify modules get the same tmpdir as the action plugin"
       custom_python_detect_environment:
       register: out
@@ -116,12 +175,12 @@
       when: ansible_version.full < '2.5'
       assert:
         that:
-        - out.module_path == tmp_path.result
+        - out.module_path.startswith( == tmp_path.result
         - out.module_tmpdir == None
 
     - name: "Verify modules get the same tmpdir as the action plugin (>2.5)"
       when: ansible_version.full > '2.5'
       assert:
         that:
-        - out.module_path == tmp_path.result
+        - out.module_path.startswith(parent_temp_path2)
-        - out.module_tmpdir == tmp_path.result
+        - out.module_tmpdir.startswith(parent_temp_path2)

tests/ansible/lib/modules/custom_python_run_script.py

@@ -0,0 +1,39 @@
+#!/usr/bin/python
+# I am an Ansible new-style Python module. I run the script provided in the
+# parameter.
+
+from ansible.module_utils.basic import AnsibleModule
+from ansible.module_utils.basic import get_module_path
+from ansible.module_utils import six
+
+import os
+import pwd
+import socket
+import sys
+
+
+def execute(s, gbls, lcls):
+    if sys.version_info > (3,):
+        exec(s, gbls, lcls)
+    else:
+        exec('exec s in gbls, lcls')
+
+
+def main():
+    module = AnsibleModule(argument_spec={
+        'script': {
+            'type': str
+        }
+    })
+
+    lcls = {
+        'module': module,
+        'result': {}
+    }
+    execute(module.params['script'], globals(), lcls)
+    del lcls['module']
+    module.exit_json(**lcls['result'])
+
+
+if __name__ == '__main__':
+    main()