# Copyright 2018 Canonical Ltd # # 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. from __future__ import absolute_import from __future__ import print_function import mock import reactive.octavia_handlers as handlers import charms_openstack.test_utils as test_utils class TestRegisteredHooks(test_utils.TestRegisteredHooks): def test_hooks(self): defaults = [ 'charm.installed', 'amqp.connected', 'shared-db.connected', 'identity-service.connected', 'identity-service.available', 'config.changed', 'update-status'] hook_set = { 'when': { 'render': ('shared-db.available', 'identity-service.available', 'amqp.available'), 'init_db': ('config.rendered'), }, 'when_not': { 'init_db': ('db.synced'), }, } # test that the hooks were registered via the # reactive.octavia_handlers self.registered_hooks_test_helper(handlers, hook_set, defaults) class TestRender(test_utils.PatchHelper): def test_render(self): octavia_charm = mock.MagicMock() self.patch_object(handlers.charm, 'provide_charm_instance', new=mock.MagicMock()) self.provide_charm_instance().__enter__.return_value = octavia_charm self.provide_charm_instance().__exit__.return_value = None self.patch_object(handlers.charm, 'optional_interfaces') def _optional_interfaces(args, *interfaces): self.assertEqual(interfaces, ('tls-certificates.available', )) return args + ('tls-certificates', ) self.optional_interfaces.side_effect = _optional_interfaces handlers.render('arg1', 'arg2') octavia_charm.render_with_interfaces.assert_called_once_with( ('arg1', 'arg2', 'tls-certificates')) octavia_charm.assess_status.assert_called_once_with()