1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
|
from mock import (
ANY,
patch
)
from unittest import TestCase
from jujupy import (
EnvJujuClient,
SimpleEnvironment,
)
from quickstart_deploy import QuickstartTest
class TestQuickstartTest(TestCase):
def test_from_args(self):
side_effect = lambda x, y=None, debug=False: (x, y)
with patch('jujupy.EnvJujuClient.by_version', side_effect=side_effect):
with patch('jujupy.SimpleEnvironment.from_config',
side_effect=lambda x: SimpleEnvironment(x, {})):
quickstart = QuickstartTest.from_args(
'base_env', 'temp_env_name', '/foo/bin/juju', '/tmp/tmp',
'/tmp/bundle.yaml', 2
)
self.assertIs(type(quickstart), QuickstartTest)
self.assertEqual(quickstart.client[0].environment, 'temp_env_name')
self.assertIs(quickstart.client[1], '/foo/bin/juju')
self.assertEqual(quickstart.bundle_path, '/tmp/bundle.yaml')
self.assertEqual(quickstart.log_dir, '/tmp/tmp')
self.assertEqual(quickstart.service_count, 2)
def test_from_args_agent_url(self):
side_effect = lambda x, y=None, debug=False: (x, y)
with patch('jujupy.EnvJujuClient.by_version', side_effect=side_effect):
with patch('jujupy.SimpleEnvironment.from_config',
side_effect=lambda x: SimpleEnvironment(x, {})):
quickstart = QuickstartTest.from_args(
'base_env', 'temp_env_name', '/foo/bin/juju', '/tmp/tmp',
'/tmp/bundle.yaml', 2, agent_url='http://agent_url.com'
)
self.assertEqual(quickstart.client[0].config['agent_url'],
'http://agent_url.com')
def test_from_args_series(self):
side_effect = lambda x, y=None, debug=False: (x, y)
with patch('jujupy.EnvJujuClient.by_version', side_effect=side_effect):
with patch('jujupy.SimpleEnvironment.from_config',
side_effect=lambda x: SimpleEnvironment(x, {})):
quickstart = QuickstartTest.from_args(
'base_env', 'temp_env_name', '/foo/bin/juju', '/tmp/tmp',
'/tmp/bundle.yaml', 2, series='precise'
)
self.assertEqual(quickstart.client[0].config['series'],
'precise')
def test_from_args_debug(self):
with patch('jujupy.EnvJujuClient.get_version',
side_effect=lambda x, juju_path=None: ''):
with patch('jujupy.SimpleEnvironment.from_config',
side_effect=lambda x: SimpleEnvironment(x, {})):
quickstart = QuickstartTest.from_args(
'base_env', 'temp_env_name', '/foo/bin/juju', '/tmp/tmp',
'/tmp/bundle.yaml', 2, debug_flag=True
)
self.assertEqual(quickstart.client.debug, True)
def test_run_finally(self):
def fake_iter_steps():
yield {'bootstrap_host': 'foo'}
client = EnvJujuClient(
SimpleEnvironment('foo', {'type': 'local'}), '1.234-76', None)
quickstart = QuickstartTest(client, '/tmp/bundle.yaml', '/tmp/logs', 2)
with patch.object(client, 'destroy_environment') as qs_mock:
with patch('quickstart_deploy.safe_print_status') as ps_mock:
with patch.object(quickstart, 'iter_steps',
side_effect=fake_iter_steps):
quickstart.run()
qs_mock.assert_called_once_with(delete_jenv=True)
ps_mock.assert_called_once_with(client)
def test_run_exception(self):
def fake_iter_steps():
yield {'bootstrap_host': 'foo'}
raise Exception()
client = EnvJujuClient(
SimpleEnvironment('foo', {'type': 'local'}), '1.234-76', None)
quickstart = QuickstartTest(client, '/tmp/bundle.yaml', '/tmp/logs', 2)
with patch.object(client, 'destroy_environment') as qs_mock:
with patch('quickstart_deploy.safe_print_status') as ps_mock:
with patch('quickstart_deploy.dump_env_logs') as dl_mock:
with patch.object(quickstart, 'iter_steps',
side_effect=fake_iter_steps):
with self.assertRaises(BaseException):
quickstart.run()
dl_mock.assert_called_once_with(client, 'foo', '/tmp/logs')
qs_mock.assert_called_once_with(delete_jenv=True)
ps_mock.assert_called_once_with(client)
def test_iter_steps(self):
client = EnvJujuClient(
SimpleEnvironment('foo', {'type': 'local'}), '1.234-76', None)
quickstart = QuickstartTest(client, '/tmp/bundle.yaml', '/tmp/logs', 2)
steps = quickstart.iter_steps()
with patch.object(client, 'quickstart') as qs_mock:
# Test first yield
step = steps.next()
qs_mock.assert_called_once_with('/tmp/bundle.yaml')
expected = {'juju-quickstart': 'Returned from quickstart'}
self.assertEqual(expected, step)
with patch('quickstart_deploy.get_machine_dns_name',
return_value='mocked_name') as dns_mock:
# Test second yield
step = steps.next()
dns_mock.assert_called_once_with(client, 0)
self.assertEqual('mocked_name', step['bootstrap_host'])
with patch.object(client, 'wait_for_deploy_started') as wds_mock:
# Test third yield
step = steps.next()
wds_mock.assert_called_once_with(2)
self.assertEqual('Deploy stated', step['deploy_started'])
with patch.object(client, 'wait_for_started') as ws_mock:
# Test forth yield
step = steps.next()
ws_mock.assert_called_once_with(ANY)
self.assertEqual('All Agents started', step['agents_started'])
|