kolla-mesos/kolla_mesos/tests/test_commands.py

# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
#     http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

import mock
import os

from oslo_config import cfg
from zake import fake_client

from kolla_mesos import commands
from kolla_mesos.common import file_utils
from kolla_mesos.tests import base
from kolla_mesos.tests.fakes import mesos as fake_mesos

CONF = cfg.CONF
CONF.import_group('mesos', 'kolla_mesos.config.mesos')
CONF.import_group('kolla', 'kolla_mesos.config.kolla')


class CommandsTest(base.BaseTestCase):
    def setUp(self):
        super(CommandsTest, self).setUp()
        CONF.set_override('host', 'http://127.0.0.1:5050', group='mesos')
        CONF.set_override('deployment_id', 'test', group='kolla')
        self.client = fake_client.FakeClient()
        self.client.start()
        self.addCleanup(self.client.stop)
        self.addCleanup(self.client.close)

    @fake_mesos.FakeMesosStateTaggedSlaves()
    def test_get_tasks_sanity(self):
        var = '/kolla/test/status/global'
        exp = {'register': '%s/cinder-api/db_sync' % var,
               'requires': [
                   '%s/cinder_ansible_tasks/create_database' % var,
                   '%s/cinder_ansible_tasks/database_user_create' % var]}

        config_path = os.path.join(
            file_utils.find_base_dir(), 'services/cinder')
        tasks = commands.get_tasks(config_path)
        self.assertEqual(exp, tasks['cinder-api/db_sync'])

    @fake_mesos.FakeMesosStateTaggedSlaves()
    def test_get_service_tasks_sanity(self):
        var = '/kolla/test/status/global'
        exp = {'register': '%s/cinder-api/db_sync' % var,
               'requires': [
                   '%s/cinder_ansible_tasks/create_database' % var,
                   '%s/cinder_ansible_tasks/database_user_create' % var]}

        config_dir = os.path.join(
            file_utils.find_base_dir(), 'services')
        tasks = commands.get_service_tasks(
            'openstack/cinder/cinder-api', config_dir)
        self.assertEqual(exp, tasks['cinder-api/db_sync'])

    @fake_mesos.FakeMesosStateTaggedSlaves()
    @mock.patch.object(commands.zk_utils, 'connection')
    def test_get_status_waiting(self, m_zk_c):
        m_zk_c.return_value.__enter__.return_value = self.client
        config_path = os.path.join(
            file_utils.find_base_dir(), 'services/cinder')
        tasks = commands.get_tasks(config_path)
        # just get what we want for the test
        test_tasks = {'cinder-api/db_sync':
                      tasks['cinder-api/db_sync']}
        var = '/kolla/test/status/global'
        exp = {
            'register': ('%s/cinder-api/db_sync' % var, 'waiting'),
            'requirements': {
                '%s/cinder_ansible_tasks/create_database' % var: 'running',
                '%s/cinder_ansible_tasks/database_user_create' % var: 'done'}
        }
        self.client.create(
            '%s/cinder-api/db_sync' % var,
            'waiting'.encode('utf-8'), makepath=True)
        self.client.create(
            '%s/cinder_ansible_tasks/create_database' % var,
            'running'.encode('utf-8'), makepath=True)
        self.client.create(
            '%s/cinder_ansible_tasks/database_user_create' % var,
            'done'.encode('utf-8'), makepath=True)
        status = commands.get_status(test_tasks)
        self.assertEqual({'cinder-api/db_sync': exp}, status)

    @fake_mesos.FakeMesosStateTaggedSlaves()
    @mock.patch.object(commands.zk_utils, 'connection')
    def test_get_status_deps_done(self, m_zk_c):
        m_zk_c.return_value.__enter__.return_value = self.client
        config_path = os.path.join(
            file_utils.find_base_dir(), 'services/cinder')
        tasks = commands.get_tasks(config_path)
        # just get what we want for the test
        test_tasks = {'cinder-api/db_sync':
                      tasks['cinder-api/db_sync']}
        var = '/kolla/test/status/global'
        at = '%s/cinder_ansible_tasks' % var
        exp = {
            'register': ('%s/cinder-api/db_sync' % var, ''),
            'requirements': {
                '%s/create_database' % at: 'done',
                '%s/database_user_create' % at: 'done'}}

        # create the done states
        self.client.create(
            '%s/cinder_ansible_tasks/create_database' % var,
            'done'.encode('utf-8'), makepath=True)
        self.client.create(
            '%s/cinder_ansible_tasks/database_user_create' % var,
            'done'.encode('utf-8'), makepath=True)

        status = commands.get_status(test_tasks)
        self.assertEqual({'cinder-api/db_sync': exp}, status)

    @fake_mesos.FakeMesosStateTaggedSlaves()
    @mock.patch.object(commands.zk_utils, 'connection')
    def test_get_status_done(self, m_zk_c):
        m_zk_c.return_value.__enter__.return_value = self.client
        config_path = os.path.join(
            file_utils.find_base_dir(), 'services/cinder')
        tasks = commands.get_tasks(config_path)
        # just get what we want for the test
        test_tasks = {'cinder-api/db_sync':
                      tasks['cinder-api/db_sync']}
        var = '/kolla/test/status/global'
        at = '%s/cinder_ansible_tasks' % var
        exp = {
            'register': ('%s/cinder-api/db_sync' % var, 'done'),
            'requirements': {
                '%s/create_database' % at: 'done',
                '%s/database_user_create' % at: 'done'}}

        # create the done state
        self.client.create(
            '%s/cinder_ansible_tasks/create_database' % var,
            'done'.encode('utf-8'), makepath=True)
        self.client.create(
            '%s/cinder_ansible_tasks/database_user_create' % var,
            'done'.encode('utf-8'), makepath=True)
        self.client.create('%s/cinder-api/db_sync' % var,
                           'done'.encode('utf-8'),
                           makepath=True)

        status = commands.get_status(test_tasks)
        self.assertEqual({'cinder-api/db_sync': exp}, status)