Merge pull request #3603 from eest/openbsd_pkg-run_command

openbsd_pkg: Use ansible run_command().
This commit is contained in:
Michael DeHaan 2013-07-20 09:14:29 -07:00
commit c7866cd472

View file

@ -19,6 +19,7 @@
# along with Ansible. If not, see <http://www.gnu.org/licenses/>. # along with Ansible. If not, see <http://www.gnu.org/licenses/>.
import re import re
import shlex
DOCUMENTATION = ''' DOCUMENTATION = '''
--- ---
@ -53,24 +54,18 @@ EXAMPLES = '''
- openbsd_pkg: name=nmap state=absent - openbsd_pkg: name=nmap state=absent
''' '''
# select whether we dump additional debug info through syslog
syslogging = False
# Function used for executing commands. # Function used for executing commands.
def execute_command(cmd, syslogging): def execute_command(cmd, module):
if syslogging: # Break command line into arguments.
syslog.openlog('ansible-%s' % os.path.basename(__file__)) # This makes run_command() use shell=False which we need to not cause shell
syslog.syslog(syslog.LOG_NOTICE, 'Command %s' % '|'.join(cmd)) # expansion of special characters like '*'.
cmd_args = shlex.split(cmd)
p = subprocess.Popen(cmd, shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE) return module.run_command(cmd_args)
(out, err) = p.communicate()
rc = p.returncode
return (rc, out, err)
# Function used for getting the name of a currently installed package. # Function used for getting the name of a currently installed package.
def get_current_name(name, specific_version): def get_current_name(name, specific_version, module):
info_cmd = 'pkg_info' info_cmd = 'pkg_info'
(rc, stdout, stderr) = execute_command("%s" % (info_cmd), syslogging) (rc, stdout, stderr) = execute_command("%s" % (info_cmd), module)
if rc != 0: if rc != 0:
return (rc, stdout, stderr) return (rc, stdout, stderr)
@ -86,7 +81,7 @@ def get_current_name(name, specific_version):
return current_name return current_name
# Function used to find out if a package is currently installed. # Function used to find out if a package is currently installed.
def get_package_state(name, specific_version): def get_package_state(name, specific_version, module):
info_cmd = 'pkg_info -e' info_cmd = 'pkg_info -e'
if specific_version: if specific_version:
@ -94,7 +89,7 @@ def get_package_state(name, specific_version):
else: else:
syntax = "%s %s-*" syntax = "%s %s-*"
rc, stdout, stderr = execute_command(syntax % (info_cmd, name), syslogging) rc, stdout, stderr = execute_command(syntax % (info_cmd, name), module)
if rc == 0: if rc == 0:
return True return True
@ -111,7 +106,7 @@ def package_present(name, installed_state, specific_version, module):
if installed_state is False: if installed_state is False:
# Attempt to install the package # Attempt to install the package
(rc, stdout, stderr) = execute_command("%s %s" % (install_cmd, name), syslogging) (rc, stdout, stderr) = execute_command("%s %s" % (install_cmd, name), module)
# The behaviour of pkg_add is a bit different depending on if a # The behaviour of pkg_add is a bit different depending on if a
# specific version is supplied or not. # specific version is supplied or not.
@ -166,10 +161,10 @@ def package_latest(name, installed_state, specific_version, module):
if installed_state is True: if installed_state is True:
# Fetch name of currently installed package # Fetch name of currently installed package
pre_upgrade_name = get_current_name(name, specific_version) pre_upgrade_name = get_current_name(name, specific_version, module)
# Attempt to upgrade the package # Attempt to upgrade the package
(rc, stdout, stderr) = execute_command("%s %s" % (upgrade_cmd, name), syslogging) (rc, stdout, stderr) = execute_command("%s %s" % (upgrade_cmd, name), module)
# Look for output looking something like "nmap-6.01->6.25: ok" to see if # Look for output looking something like "nmap-6.01->6.25: ok" to see if
# something changed (or would have changed). Use \W to delimit the match # something changed (or would have changed). Use \W to delimit the match
@ -212,7 +207,7 @@ def package_absent(name, installed_state, module):
if installed_state is True: if installed_state is True:
# Attempt to remove the package # Attempt to remove the package
rc, stdout, stderr = execute_command("%s %s" % (remove_cmd, name), syslogging) rc, stdout, stderr = execute_command("%s %s" % (remove_cmd, name), module)
if rc == 0: if rc == 0:
if module.check_mode: if module.check_mode:
@ -261,7 +256,7 @@ def main():
specific_version = False specific_version = False
# Get package state # Get package state
installed_state = get_package_state(name, specific_version) installed_state = get_package_state(name, specific_version, module)
# Perform requested action # Perform requested action
if state in ['installed', 'present']: if state in ['installed', 'present']: