133 lines
4.1 KiB
Python
133 lines
4.1 KiB
Python
import mock
|
|
from mock import patch
|
|
|
|
from test_utils import CharmTestCase
|
|
|
|
with patch('actions.hooks.keystone_utils.is_paused') as is_paused:
|
|
with patch('actions.hooks.keystone_utils.register_configs') as configs:
|
|
import actions.actions
|
|
|
|
|
|
class PauseTestCase(CharmTestCase):
|
|
|
|
def setUp(self):
|
|
super(PauseTestCase, self).setUp(
|
|
actions.actions, ["service_pause", "HookData", "kv",
|
|
"assess_status"])
|
|
|
|
def test_pauses_services(self):
|
|
"""Pause action pauses all Keystone services."""
|
|
pause_calls = []
|
|
|
|
def fake_service_pause(svc):
|
|
pause_calls.append(svc)
|
|
return True
|
|
|
|
self.service_pause.side_effect = fake_service_pause
|
|
|
|
actions.actions.pause([])
|
|
self.assertItemsEqual(
|
|
pause_calls, ['haproxy', 'keystone', 'apache2'])
|
|
|
|
def test_bails_out_early_on_error(self):
|
|
"""Pause action fails early if there are errors stopping a service."""
|
|
pause_calls = []
|
|
|
|
def maybe_kill(svc):
|
|
if svc == "keystone":
|
|
return False
|
|
else:
|
|
pause_calls.append(svc)
|
|
return True
|
|
|
|
self.service_pause.side_effect = maybe_kill
|
|
self.assertRaisesRegexp(
|
|
Exception, "keystone didn't stop cleanly.",
|
|
actions.actions.pause, [])
|
|
self.assertEqual(pause_calls, ['haproxy'])
|
|
|
|
def test_pause_sets_value(self):
|
|
"""Pause action sets the unit-paused value to True."""
|
|
self.HookData()().return_value = True
|
|
|
|
actions.actions.pause([])
|
|
self.kv().set.assert_called_with('unit-paused', True)
|
|
|
|
|
|
class ResumeTestCase(CharmTestCase):
|
|
|
|
def setUp(self):
|
|
super(ResumeTestCase, self).setUp(
|
|
actions.actions, ["service_resume", "HookData", "kv",
|
|
"assess_status"])
|
|
|
|
def test_resumes_services(self):
|
|
"""Resume action resumes all Keystone services."""
|
|
resume_calls = []
|
|
|
|
def fake_service_resume(svc):
|
|
resume_calls.append(svc)
|
|
return True
|
|
|
|
self.service_resume.side_effect = fake_service_resume
|
|
actions.actions.resume([])
|
|
self.assertEqual(resume_calls, ['haproxy', 'keystone', 'apache2'])
|
|
|
|
def test_bails_out_early_on_error(self):
|
|
"""Resume action fails early if there are errors starting a service."""
|
|
resume_calls = []
|
|
|
|
def maybe_kill(svc):
|
|
if svc == "keystone":
|
|
return False
|
|
else:
|
|
resume_calls.append(svc)
|
|
return True
|
|
|
|
self.service_resume.side_effect = maybe_kill
|
|
self.assertRaisesRegexp(
|
|
Exception, "keystone didn't start cleanly.",
|
|
actions.actions.resume, [])
|
|
self.assertEqual(resume_calls, ['haproxy'])
|
|
|
|
def test_resume_sets_value(self):
|
|
"""Resume action sets the unit-paused value to False."""
|
|
self.HookData()().return_value = True
|
|
|
|
actions.actions.resume([])
|
|
self.kv().set.assert_called_with('unit-paused', False)
|
|
|
|
|
|
class MainTestCase(CharmTestCase):
|
|
|
|
def setUp(self):
|
|
super(MainTestCase, self).setUp(actions.actions, ["action_fail"])
|
|
|
|
def test_invokes_action(self):
|
|
dummy_calls = []
|
|
|
|
def dummy_action(args):
|
|
dummy_calls.append(True)
|
|
|
|
with mock.patch.dict(actions.actions.ACTIONS, {"foo": dummy_action}):
|
|
actions.actions.main(["foo"])
|
|
self.assertEqual(dummy_calls, [True])
|
|
|
|
def test_unknown_action(self):
|
|
"""Unknown actions aren't a traceback."""
|
|
exit_string = actions.actions.main(["foo"])
|
|
self.assertEqual("Action foo undefined", exit_string)
|
|
|
|
def test_failing_action(self):
|
|
"""Actions which traceback trigger action_fail() calls."""
|
|
dummy_calls = []
|
|
|
|
self.action_fail.side_effect = dummy_calls.append
|
|
|
|
def dummy_action(args):
|
|
raise ValueError("uh oh")
|
|
|
|
with mock.patch.dict(actions.actions.ACTIONS, {"foo": dummy_action}):
|
|
actions.actions.main(["foo"])
|
|
self.assertEqual(dummy_calls, ["uh oh"])
|