Sign Up
Log In
Log In
or
Sign Up
Places
All Projects
Status Monitor
Collapse sidebar
SUSE:SLE-12-SP1:GA
salt.2353
0016-write-a-zypper-command-builder-function.patch
Overview
Repositories
Revisions
Requests
Users
Attributes
Meta
File 0016-write-a-zypper-command-builder-function.patch of Package salt.2353
From 8d25c4c8906581fa44380f72f0f754b56f5e30c3 Mon Sep 17 00:00:00 2001 From: Michael Calmer <mc@suse.de> Date: Fri, 19 Feb 2016 11:50:31 +0100 Subject: [PATCH 16/22] write a zypper command builder function --- salt/modules/zypper.py | 62 +++++++++++++++++++++++--------------------------- 1 file changed, 29 insertions(+), 33 deletions(-) diff --git a/salt/modules/zypper.py b/salt/modules/zypper.py index cb26b51..f878c95 100644 --- a/salt/modules/zypper.py +++ b/salt/modules/zypper.py @@ -56,19 +56,18 @@ def __virtual__(): return __virtualname__ -def _zypper(as_list=False): +def _zypper(*opts): ''' - Return zypper command with default options as a string. + Return zypper command with default options as a list. - CMD: zypper --non-interactive + opts + additional options for zypper command - as_list: - if set to True, the command and the default options - are returned as a list ''' - if as_list: - return ['zypper', '--non-interactive'] - return "zypper --non-interactive " + cmd = ['zypper', '--non-interactive'] + cmd.extend(opts) + + return cmd def list_upgrades(refresh=True): @@ -85,7 +84,7 @@ def list_upgrades(refresh=True): refresh_db() ret = {} call = __salt__['cmd.run_all']( - _zypper() + 'list-updates', output_loglevel='trace' + _zypper('list-updates'), output_loglevel='trace' ) if call['retcode'] != 0: comment = '' @@ -200,7 +199,7 @@ def info_available(*names, **kwargs): # Run in batches while batch: - cmd = '{0} info -t package {1}'.format(_zypper(), ' '.join(batch[:batch_size])) + cmd = _zypper('info', '-t', 'package', *batch[:batch_size]) pkg_info.extend(re.split(r"Information for package*", __salt__['cmd.run_stdout'](cmd, output_loglevel='trace'))) batch = batch[batch_size:] @@ -509,7 +508,7 @@ def del_repo(repo): repos_cfg = _get_configured_repos() for alias in repos_cfg.sections(): if alias == repo: - cmd = ('{0} -x rr --loose-auth --loose-query {1}'.format(_zypper(), alias)) + cmd = _zypper('-x', 'rr', '--loose-auth', '--loose-query', alias) doc = dom.parseString(__salt__['cmd.run'](cmd, output_loglevel='trace')) msg = doc.getElementsByTagName('message') if doc.getElementsByTagName('progress') and msg: @@ -598,8 +597,8 @@ def mod_repo(repo, **kwargs): try: # Try to parse the output and find the error, # but this not always working (depends on Zypper version) - doc = dom.parseString(__salt__['cmd.run'](('{0} -x ar {1} \'{2}\''.format(_zypper(), url, repo)), - output_loglevel='trace')) + doc = dom.parseString(__salt__['cmd.run']( + _zypper('-x', 'ar', url, repo), output_loglevel='trace')) except Exception: # No XML out available, but it is still unknown the state of the result. pass @@ -644,7 +643,8 @@ def mod_repo(repo, **kwargs): cmd_opt.append("--name='{0}'".format(kwargs.get('humanname'))) if cmd_opt: - __salt__['cmd.run'](('{0} -x mr {1} \'{2}\''.format(_zypper(), ' '.join(cmd_opt), repo)), + cmd_opt.append(repo) + __salt__['cmd.run'](_zypper('-x', 'mr', *cmd_opt), output_loglevel='trace') # If repo nor added neither modified, error should be thrown @@ -667,7 +667,7 @@ def refresh_db(): salt '*' pkg.refresh_db ''' - cmd = _zypper() + 'refresh' + cmd = _zypper('refresh') ret = {} call = __salt__['cmd.run_all'](cmd, output_loglevel='trace') if call['retcode'] != 0: @@ -814,7 +814,7 @@ def install(name=None, log.info('Targeting repo {0!r}'.format(fromrepo)) else: fromrepoopt = '' - cmd_install = _zypper(as_list=True) + cmd_install = _zypper() if not refresh: cmd_install.append('--no-refresh') cmd_install += ['install', '--name', '--auto-agree-with-licenses'] @@ -870,7 +870,7 @@ def upgrade(refresh=True): if salt.utils.is_true(refresh): refresh_db() old = list_pkgs() - cmd = _zypper() + 'update --auto-agree-with-licenses' + cmd = _zypper('update', '--auto-agree-with-licenses') call = __salt__['cmd.run_all'](cmd, output_loglevel='trace') if call['retcode'] != 0: ret['result'] = False @@ -901,10 +901,7 @@ def _uninstall(action='remove', name=None, pkgs=None): if not targets: return {} while targets: - cmd = ( - '{0} remove {1} {2}' - .format(_zypper(), purge_arg, ' '.join(targets[:500])) - ) + cmd = _zypper('remove', purge_arg, *targets[:500]) __salt__['cmd.run'](cmd, output_loglevel='trace') targets = targets[500:] __context__.pop('pkg.list_pkgs', None) @@ -1018,7 +1015,7 @@ def clean_locks(): if not os.path.exists("/etc/zypp/locks"): return out - doc = dom.parseString(__salt__['cmd.run'](_zypper() + '-x cl', output_loglevel='trace')) + doc = dom.parseString(__salt__['cmd.run'](_zypper('-x', 'cl'), output_loglevel='trace')) for node in doc.getElementsByTagName("message"): text = node.childNodes[0].nodeValue.lower() if text.startswith(LCK): @@ -1056,8 +1053,7 @@ def remove_lock(packages, **kwargs): # pylint: disable=unused-argument missing.append(pkg) if removed: - __salt__['cmd.run'](('{0} rl {1}'.format(_zypper(), ' '.join(removed))), - output_loglevel='trace') + __salt__['cmd.run'](_zypper('rl', *removed), output_loglevel='trace') return {'removed': len(removed), 'not_found': missing} @@ -1086,8 +1082,7 @@ def add_lock(packages, **kwargs): # pylint: disable=unused-argument added.append(pkg) if added: - __salt__['cmd.run'](('{0} al {1}'.format(_zypper(), ' '.join(added))), - output_loglevel='trace') + __salt__['cmd.run'](_zypper('al', *added), output_loglevel='trace') return {'added': len(added), 'packages': added} @@ -1219,7 +1214,7 @@ def _get_patterns(installed_only=None): List all known patterns in repos. ''' patterns = {} - doc = dom.parseString(__salt__['cmd.run']((_zypper() + '--xmlout se -t pattern'), + doc = dom.parseString(__salt__['cmd.run'](_zypper('--xmlout', 'se', '-t', 'pattern'), output_loglevel='trace')) for element in doc.getElementsByTagName('solvable'): installed = element.getAttribute('status') == 'installed' @@ -1268,7 +1263,7 @@ def search(criteria): salt '*' pkg.search <criteria> ''' - doc = dom.parseString(__salt__['cmd.run'](('{0} --xmlout se {1}'.format(_zypper(), criteria)), + doc = dom.parseString(__salt__['cmd.run'](_zypper('--xmlout', 'se', criteria), output_loglevel='trace')) solvables = doc.getElementsByTagName('solvable') if not solvables: @@ -1317,8 +1312,10 @@ def list_products(all=False): ''' ret = list() OEM_PATH = "/var/lib/suseRegister/OEM" - doc = dom.parseString(__salt__['cmd.run'](("{0} -x products{1}".format(_zypper(), not all and ' -i' or '')), - output_loglevel='trace')) + cmd = _zypper('-x', 'products') + if not all: + cmd.append('-i') + doc = dom.parseString(__salt__['cmd.run'](cmd, output_loglevel='trace')) for prd in doc.getElementsByTagName('product-list')[0].getElementsByTagName('product'): p_nfo = dict() for k_p_nfo, v_p_nfo in prd.attributes.items(): @@ -1357,8 +1354,7 @@ def download(*packages): raise CommandExecutionError("No packages has been specified.") doc = dom.parseString(__salt__['cmd.run']( - ('{0} -x download {1}'.format(_zypper(), ' '.join(packages))), - output_loglevel='trace')) + _zypper('-x', 'download', *packages), output_loglevel='trace')) pkg_ret = {} for dld_result in doc.getElementsByTagName("download-result"): repo = dld_result.getElementsByTagName("repository")[0] -- 2.1.4
Locations
Projects
Search
Status Monitor
Help
OpenBuildService.org
Documentation
API Documentation
Code of Conduct
Contact
Support
@OBShq
Terms
openSUSE Build Service is sponsored by
The Open Build Service is an
openSUSE project
.
Sign Up
Log In
Places
Places
All Projects
Status Monitor