ecb204230f
ARA was originally licensed as Apache 2.0 software to align with the license used by the larger community of OpenStack software. However, ARA is fairly coupled with Ansible, which is GPLv3. By maintaining two licenses simultaneously, we may unknowingly infringe on the incompatibility of the licenses by importing or linking code to and from Ansible software. In order to avoid the headaches involved in maintaining two licenses side by side, remove the ambiguity as to what is the effective license, we are relicensing ARA to be fully GPLv3. Since ARA is not an official OpenStack project, it does not have an impact on it's status within the OpenStack community [1] and will remain as a hosted project. We are doing this license change now rather than later as doing this change later becomes increasingly complicated as the project gains more code contributors. [1]: http://lists.openstack.org/pipermail/legal-discuss/2017-July/000474.html Change-Id: I2ec1e0a1d1b38fc74dcb6af2b4f81226d1faa0df
140 lines
5.1 KiB
Python
140 lines
5.1 KiB
Python
# Copyright (c) 2017 Red Hat, Inc.
|
|
#
|
|
# This file is part of ARA: Ansible Run Analysis.
|
|
#
|
|
# ARA is free software: you can redistribute it and/or modify
|
|
# it under the terms of the GNU General Public License as published by
|
|
# the Free Software Foundation, either version 3 of the License, or
|
|
# (at your option) any later version.
|
|
#
|
|
# ARA is distributed in the hope that it will be useful,
|
|
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
# GNU General Public License for more details.
|
|
#
|
|
# You should have received a copy of the GNU General Public License
|
|
# along with ARA. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
import random
|
|
import os
|
|
|
|
import ara.models as m
|
|
import ara.utils as u
|
|
import ara.plugins.callbacks.log_ara as l
|
|
|
|
from ara.tests.unit.common import TestAra
|
|
from ara.tests.unit import fakes
|
|
from collections import defaultdict
|
|
from oslo_serialization import jsonutils
|
|
|
|
|
|
class TestCallback(TestAra):
|
|
""" Tests for the Ansible callback module """
|
|
def setUp(self):
|
|
super(TestCallback, self).setUp()
|
|
|
|
self.cb = l.CallbackModule()
|
|
self.tag = '%04d' % random.randint(0, 9999)
|
|
|
|
self.ansible_run()
|
|
|
|
def tearDown(self):
|
|
super(TestCallback, self).tearDown()
|
|
|
|
def ansible_run(self):
|
|
""" Simulates an ansible run by creating stub versions of the
|
|
information that Ansible passes to the callback, and then
|
|
calling the various callback methods. """
|
|
|
|
self.playbook = fakes.Playbook(path='/playbook-%s.yml' % self.tag)
|
|
self.cb.v2_playbook_on_start(self.playbook)
|
|
|
|
self.play = fakes.Play(playbook=self.playbook.model)
|
|
self.cb.v2_playbook_on_play_start(self.play)
|
|
|
|
self.task = fakes.Task(name='task-%s' % self.tag,
|
|
playbook=self.playbook.model,
|
|
path='/task-%s.yml')
|
|
self.cb.v2_playbook_on_task_start(self.task, False)
|
|
|
|
self.host_one = fakes.Host(name='host1', playbook=self.playbook.model)
|
|
self.host_two = fakes.Host(name='host2', playbook=self.playbook.model)
|
|
self.results = [
|
|
self._test_result(self.host_one, 'ok', changed=True),
|
|
self._test_result(self.host_two, 'failed'),
|
|
]
|
|
|
|
processed_stats = {
|
|
self.host_one.name: defaultdict(int, ok=1, changed=1),
|
|
self.host_two.name: defaultdict(int, failed=1)
|
|
}
|
|
self.stats = fakes.Stats(playbook=self.playbook.model,
|
|
processed=processed_stats)
|
|
self.cb.v2_playbook_on_stats(self.stats)
|
|
|
|
def _test_result(self, host, status='ok', changed=False):
|
|
result = fakes.TaskResult(task=self.task.model,
|
|
host=host.model.name,
|
|
status=status,
|
|
changed=changed)
|
|
func = getattr(self.cb, 'v2_runner_on_%s' % status)
|
|
func(result)
|
|
return result
|
|
|
|
def test_callback_playbook(self):
|
|
r_playbook = m.Playbook.query.first()
|
|
self.assertIsNotNone(r_playbook)
|
|
self.assertEqual(r_playbook.path, self.playbook.path)
|
|
|
|
def test_playbook_persistence(self):
|
|
r_playbook = m.Playbook.query.first()
|
|
tmpfile = os.path.join(self.app.config['ARA_TMP_DIR'], 'ara.json')
|
|
|
|
with open(tmpfile, 'rb') as file:
|
|
data = jsonutils.load(file)
|
|
self.assertEqual(r_playbook.id, data['playbook']['id'])
|
|
|
|
def test_callback_play(self):
|
|
r_play = m.Play.query.first()
|
|
self.assertIsNotNone(r_play)
|
|
|
|
self.assertEqual(r_play.name, self.play.name)
|
|
self.assertEqual(r_play.playbook.path, self.playbook.path)
|
|
|
|
def test_callback_task(self):
|
|
r_task = m.Task.query.first()
|
|
self.assertIsNotNone(r_task)
|
|
|
|
self.assertEqual(r_task.name, self.task.name)
|
|
self.assertEqual(r_task.play.name, self.play.name)
|
|
self.assertEqual(r_task.playbook.path, self.playbook.path)
|
|
|
|
def test_callback_result(self):
|
|
r_results = m.TaskResult.query.all()
|
|
self.assertIsNotNone(r_results)
|
|
|
|
for res in r_results:
|
|
self.assertIn(res.host.name, [self.host_one.name,
|
|
self.host_two.name])
|
|
self.assertEqual(res.task.name, self.task.name)
|
|
|
|
def test_callback_stats(self):
|
|
r_stats = m.Stats.query.all()
|
|
self.assertIsNotNone(r_stats)
|
|
|
|
for stat in r_stats:
|
|
self.assertEqual(stat.playbook.path, self.playbook.path)
|
|
for status in ['ok', 'changed', 'failed',
|
|
'skipped', 'unreachable']:
|
|
self.assertEqual(getattr(stat, status),
|
|
self.stats.processed[stat.host.name][status])
|
|
|
|
def test_summary_stats(self):
|
|
r_hosts = m.Host.query.all()
|
|
summary = u.get_summary_stats(r_hosts, 'host_id')
|
|
for host in r_hosts:
|
|
for status in ['ok', 'changed', 'failed',
|
|
'skipped', 'unreachable']:
|
|
self.assertEqual(summary[host.id][status],
|
|
self.stats.processed[host.name][status])
|