clean up runroot unit test
This commit is contained in:
parent
f7f8b046ce
commit
81711cb8ac
2 changed files with 31 additions and 36 deletions
|
|
@ -8,30 +8,39 @@ from . import load_plugin
|
|||
|
||||
runroot = load_plugin.load_plugin('cli', 'runroot')
|
||||
|
||||
|
||||
class ParserError(Exception):
|
||||
pass
|
||||
|
||||
|
||||
class TestListCommands(unittest.TestCase):
|
||||
|
||||
def setUp(self):
|
||||
self.options = mock.MagicMock()
|
||||
self.options.debug = False
|
||||
self.session = mock.MagicMock()
|
||||
self.session.getAPIVersion.return_value = koji.API_VERSION
|
||||
self.args = mock.MagicMock()
|
||||
runroot.OptionParser = mock.MagicMock()
|
||||
self.parser = runroot.OptionParser.return_value
|
||||
self.args = ['TAG', 'ARCH', 'COMMAND']
|
||||
self.old_OptionParser = runroot.OptionParser
|
||||
runroot.OptionParser = mock.MagicMock(side_effect=self.get_parser)
|
||||
self.old_watch_tasks = runroot.watch_tasks
|
||||
runroot.watch_tasks = mock.MagicMock(name='watch_tasks')
|
||||
|
||||
def tearDown(self):
|
||||
runroot.OptionParser = self.old_OptionParser
|
||||
runroot.watch_tasks = self.old_watch_tasks
|
||||
|
||||
def get_parser(self, *a, **kw):
|
||||
# we don't want parser.error to exit
|
||||
parser = self.old_OptionParser(*a, **kw)
|
||||
parser.error = mock.MagicMock(side_effect=ParserError)
|
||||
return parser
|
||||
|
||||
# Show long diffs in error output...
|
||||
maxDiff = None
|
||||
|
||||
@mock.patch('sys.stdout', new_callable=six.StringIO)
|
||||
def test_handle_runroot(self, stdout):
|
||||
tag = 'tag'
|
||||
arch = 'arch'
|
||||
command = 'command'
|
||||
arguments = [tag, arch, command]
|
||||
options = mock.MagicMock()
|
||||
options.new_chroot = False
|
||||
options.watch = False
|
||||
self.parser.parse_args.return_value = [options, arguments]
|
||||
|
||||
# Mock out the xmlrpc server
|
||||
self.session.getTaskInfo.return_value = {'state': 1}
|
||||
self.session.downloadTaskOutput.return_value = 'task output'
|
||||
|
|
@ -42,7 +51,7 @@ class TestListCommands(unittest.TestCase):
|
|||
runroot.handle_runroot(self.options, self.session, self.args)
|
||||
actual = stdout.getvalue()
|
||||
actual = actual.replace('nosetests', 'koji')
|
||||
expected = 'successfully connected to hub\n1\ntask output'
|
||||
expected = 'task output'
|
||||
self.assertMultiLineEqual(actual, expected)
|
||||
|
||||
# Finally, assert that things were called as we expected.
|
||||
|
|
@ -51,25 +60,19 @@ class TestListCommands(unittest.TestCase):
|
|||
self.session.downloadTaskOutput.assert_called_once_with(
|
||||
1, 'runroot.log', volume='DEFAULT')
|
||||
self.session.runroot.assert_called_once_with(
|
||||
tag, arch, command, repo_id=mock.ANY, weight=mock.ANY,
|
||||
'TAG', 'ARCH', ['COMMAND'], repo_id=mock.ANY, weight=mock.ANY,
|
||||
mounts=mock.ANY, packages=mock.ANY, skip_setarch=mock.ANY,
|
||||
channel=mock.ANY,
|
||||
)
|
||||
|
||||
def test_handle_runroot_watch(self):
|
||||
arguments = ['tag', 'arch', 'command']
|
||||
options = mock.MagicMock()
|
||||
options.new_chroot = True
|
||||
options.watch = True
|
||||
options.use_shell = False
|
||||
self.parser.parse_args.return_value = [options, arguments]
|
||||
runroot.watch_tasks = mock.MagicMock(name='watch_tasks')
|
||||
args = ['--watch', 'TAG', 'ARCH', 'COMMAND']
|
||||
|
||||
# Mock out the xmlrpc server
|
||||
self.session.runroot.return_value = 1
|
||||
|
||||
# Run it and check immediate output
|
||||
runroot.handle_runroot(self.options, self.session, self.args)
|
||||
runroot.handle_runroot(self.options, self.session, args)
|
||||
|
||||
# Finally, assert that things were called as we expected.
|
||||
runroot.watch_tasks.assert_called_once()
|
||||
|
|
@ -79,15 +82,11 @@ class TestListCommands(unittest.TestCase):
|
|||
self.session.runroot.assert_called_once()
|
||||
|
||||
def test_invalid_arguments(self):
|
||||
arguments = ['tag', 'arch'] # just two
|
||||
options = mock.MagicMock()
|
||||
options.new_chroot = False
|
||||
options.watch = True
|
||||
options.use_shell = False
|
||||
self.parser.parse_args.return_value = [options, arguments]
|
||||
args = ['TAG', 'COMMAND'] # no arch
|
||||
|
||||
# Run it and check immediate output
|
||||
runroot.handle_runroot(self.options, self.session, self.args)
|
||||
with self.assertRaises(ParserError):
|
||||
runroot.handle_runroot(self.options, self.session, args)
|
||||
|
||||
# Finally, assert that things were called as we expected.
|
||||
self.session.getTaskInfo.assert_not_called()
|
||||
|
|
@ -96,17 +95,13 @@ class TestListCommands(unittest.TestCase):
|
|||
self.session.runroot.assert_not_called()
|
||||
|
||||
def test_nowait(self):
|
||||
arguments = ['tag', 'arch', 'command']
|
||||
options = mock.MagicMock()
|
||||
options.wait = False
|
||||
self.parser.parse_args.return_value = [options, arguments]
|
||||
runroot.watch_tasks = mock.MagicMock(name='watch_tasks')
|
||||
args = ['--nowait', 'TAG', 'ARCH', 'COMMAND']
|
||||
|
||||
# Mock out the xmlrpc server
|
||||
self.session.runroot.return_value = 1
|
||||
|
||||
# Run it and check immediate output
|
||||
runroot.handle_runroot(self.options, self.session, self.args)
|
||||
runroot.handle_runroot(self.options, self.session, args)
|
||||
|
||||
# Finally, assert that things were called as we expected.
|
||||
runroot.watch_tasks.assert_not_called()
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue