add tests for inventory cache

Author: evgeni

tests/inventory/inventory_plugin.foreman.yml

@@ -6,3 +6,7 @@ validate_certs: False
 want_params: True
 want_facts: True
 use_reports_api: False
+
+cache: true
+cache_plugin: jsonfile
+cache_timeout: 3600

tests/inventory/inventory_plugin_ansible.foreman.yml

@@ -8,3 +8,7 @@ want_facts: True
 want_content_facet_attributes: False
 want_hostcollections: False
 use_reports_api: True
+
+cache: true
+cache_plugin: jsonfile
+cache_timeout: 3600

tests/test_crud.py

@@ -58,7 +58,9 @@ def test_inventory(tmpdir, module):
     if LooseVersion(ansible_version) < LooseVersion('2.9'):
         pytest.skip("This module should not be tested on Ansible before 2.9")
     inventory = [os.path.join(os.getcwd(), 'tests', 'inventory', inv) for inv in ['hosts', "{}.foreman.yml".format(module)]]
-    run = run_playbook(module, inventory=inventory)
+    extra_env = {}
+    extra_env['ANSIBLE_INVENTORY_CACHE_CONNECTION'] = tmpdir.strpath
+    run = run_playbook(module, inventory=inventory, extra_env=extra_env)
     assert run.rc == 0
 
     _assert_no_warnings(run)

tests/test_playbooks/inventory_plugin.yml

@@ -23,3 +23,31 @@
   tasks:
     - name: test inventory
       include_tasks: tasks/inventory_plugin.yml
+
+    - name: Find cache file
+      find:
+        paths: "{{ lookup('env', 'ANSIBLE_INVENTORY_CACHE_CONNECTION') }}"
+        patterns: 'ansible_inventory_*'
+      register: cache_files
+
+    - name: Assert exactly one cache file was found
+      assert:
+        that: cache_files['files'] | length == 1
+
+    - name: Fetch cache file
+      slurp:
+        src: "{{ cache_files['files'][0]['path'] }}"
+      register: cache_slurp
+
+    - name: Assert cache content
+      assert:
+        that:
+          - cache_content_host['hostgroup_name'] == 'group_a'
+          - cache_content_host['all_parameters'] != []
+          - cache_content_facts['testhost1.example.com']['operatingsystem'] == 'CentOS'
+      vars:
+        cache_content_host: "{{ (cache_slurp['content'] | b64decode | from_json).get('http://localhost:3000//api/v2/hosts/1') }}"
+        cache_content_facts: "{{ (cache_slurp['content'] | b64decode | from_json).get('http://localhost:3000//api/v2/hosts/1/facts') }}"
+    - name: Decode cache content from JSON
+      set_fact:
+        cache_content: "{{ cache_slurp['content'] | b64decode | from_json }}"

tests/test_playbooks/inventory_plugin_ansible.yml

@@ -23,3 +23,26 @@
   tasks:
     - name: test inventory
       include_tasks: tasks/inventory_plugin.yml
+
+    - name: Find cache file
+      find:
+        paths: "{{ lookup('env', 'ANSIBLE_INVENTORY_CACHE_CONNECTION') }}"
+        patterns: 'ansible_inventory_*'
+      register: cache_files
+
+    - name: Assert exactly one cache file was found
+      assert:
+        that: cache_files['files'] | length == 1
+
+    - name: Fetch cache file
+      slurp:
+        src: "{{ cache_files['files'][0]['path'] }}"
+      register: cache_slurp
+
+    - name: Assert cache content
+      assert:
+        that:
+          - "{{ cache_content | selectattr('name', 'equalto', 'testhost1.example.com') | map(attribute='name') | list }} == ['testhost1.example.com']"
+          - "{{ cache_content | selectattr('name', 'equalto', 'testhost1.example.com') | map(attribute='facts', default=[]) | list | first }} != []"
+      vars:
+        cache_content: "{{ (cache_slurp['content'] | b64decode | from_json).get('http://localhost:3001//ansible/api/v2/ansible_inventories/schedule') }}"

tests/test_playbooks/tasks/inventory_plugin.yml

@@ -6,6 +6,8 @@
   block:
     - name: execute tests
       include_tasks: inventory_plugin_tests.yml
+    - name: execute tests again, now fed from cache
+      include_tasks: inventory_plugin_tests.yml
   always:
     - name: remove containers
       docker_container: