mirror of
https://github.com/ansible-collections/community.general.git
synced 2025-07-22 21:00:22 -07:00
Fix up modules that have python24 syntax error
This commit is contained in:
parent
a03da8d592
commit
8bd5757720
17 changed files with 104 additions and 58 deletions
|
@ -132,7 +132,7 @@ def main():
|
|||
)
|
||||
|
||||
module.exit_json(changed=True)
|
||||
except subprocess.CalledProcessError as cpe:
|
||||
except subprocess.CalledProcessError, cpe:
|
||||
module.fail_json(msg=str(dir(cpe)))
|
||||
else:
|
||||
module.exit_json(changed=False)
|
||||
|
|
|
@ -155,8 +155,9 @@ def main():
|
|||
|
||||
|
||||
if changed and not module.check_mode:
|
||||
with open(path, 'wb') as f:
|
||||
f.write(str(crypttab))
|
||||
f = open(path, 'wb')
|
||||
f.write(str(crypttab))
|
||||
f.close()
|
||||
|
||||
module.exit_json(changed=changed, msg=reason, **module.params)
|
||||
|
||||
|
@ -172,9 +173,10 @@ class Crypttab(object):
|
|||
os.makedirs(os.path.dirname(path))
|
||||
open(path,'a').close()
|
||||
|
||||
with open(path, 'r') as f:
|
||||
for line in f.readlines():
|
||||
self._lines.append(Line(line))
|
||||
f = open(path, 'r')
|
||||
for line in f.readlines():
|
||||
self._lines.append(Line(line))
|
||||
f.close()
|
||||
|
||||
def add(self, line):
|
||||
self._lines.append(line)
|
||||
|
@ -242,10 +244,19 @@ class Line(object):
|
|||
|
||||
def _split_line(self, line):
|
||||
fields = line.split()
|
||||
try:
|
||||
field2 = field[2]
|
||||
except IndexError:
|
||||
field2 = None
|
||||
try:
|
||||
field3 = field[3]
|
||||
except IndexError:
|
||||
field3 = None
|
||||
|
||||
return (fields[0],
|
||||
fields[1],
|
||||
fields[2] if len(fields) >= 3 else None,
|
||||
fields[3] if len(fields) >= 4 else None)
|
||||
field2,
|
||||
fields3)
|
||||
|
||||
def remove(self):
|
||||
self.line, self.name, self.backing_device = '', None, None
|
||||
|
@ -260,7 +271,10 @@ class Line(object):
|
|||
if self.valid():
|
||||
fields = [self.name, self.backing_device]
|
||||
if self.password is not None or self.opts:
|
||||
fields.append(self.password if self.password is not None else 'none')
|
||||
if self.password is not None:
|
||||
fields.append(self.password)
|
||||
else:
|
||||
self.password('none')
|
||||
if self.opts:
|
||||
fields.append(str(self.opts))
|
||||
return ' '.join(fields)
|
||||
|
@ -276,7 +290,10 @@ class Options(dict):
|
|||
if opts_string is not None:
|
||||
for opt in opts_string.split(','):
|
||||
kv = opt.split('=')
|
||||
k, v = (kv[0], kv[1]) if len(kv) > 1 else (kv[0], None)
|
||||
if len(kv) > 1:
|
||||
k, v = (kv[0], kv[1])
|
||||
else:
|
||||
k, v = (kv[0], None)
|
||||
self[k] = v
|
||||
|
||||
def add(self, opts_string):
|
||||
|
@ -324,8 +341,13 @@ class Options(dict):
|
|||
and sorted(self.items()) == sorted(obj.items()))
|
||||
|
||||
def __str__(self):
|
||||
return ','.join([k if v is None else '%s=%s' % (k, v)
|
||||
for k, v in self.items()])
|
||||
ret = []
|
||||
for k, v in self.items():
|
||||
if v is None:
|
||||
ret.append(k)
|
||||
else:
|
||||
ret.append('%s=%s' % (k, v))
|
||||
return ','.join(ret)
|
||||
|
||||
# import module snippets
|
||||
from ansible.module_utils.basic import *
|
||||
|
|
|
@ -145,7 +145,7 @@ def run_gluster(gargs, **kwargs):
|
|||
try:
|
||||
rc, out, err = module.run_command(args, **kwargs)
|
||||
if rc != 0:
|
||||
module.fail_json(msg='error running gluster (%s) command (rc=%d): %s' % (' '.join(args), rc, out if out != '' else err))
|
||||
module.fail_json(msg='error running gluster (%s) command (rc=%d): %s' % (' '.join(args), rc, out or err))
|
||||
except Exception, e:
|
||||
module.fail_json(msg='error running gluster (%s) command: %s' % (' '.join(args), str(e)))
|
||||
return out
|
||||
|
@ -167,7 +167,7 @@ def run_gluster_yes(gargs):
|
|||
args.extend(gargs)
|
||||
rc, out, err = module.run_command(args, data='y\n')
|
||||
if rc != 0:
|
||||
module.fail_json(msg='error running gluster (%s) command (rc=%d): %s' % (' '.join(args), rc, out if out != '' else err))
|
||||
module.fail_json(msg='error running gluster (%s) command (rc=%d): %s' % (' '.join(args), rc, out or err))
|
||||
return out
|
||||
|
||||
def get_peers():
|
||||
|
|
|
@ -55,11 +55,12 @@ def is_available(name, ubuntuMode):
|
|||
__locales_available = '/etc/locale.gen'
|
||||
|
||||
re_compiled = re.compile(__regexp)
|
||||
with open(__locales_available, 'r') as fd:
|
||||
for line in fd:
|
||||
result = re_compiled.match(line)
|
||||
if result and result.group('locale') == name:
|
||||
return True
|
||||
fd = open(__locales_available, 'r')
|
||||
for line in fd:
|
||||
result = re_compiled.match(line)
|
||||
if result and result.group('locale') == name:
|
||||
return True
|
||||
fd.close()
|
||||
return False
|
||||
|
||||
def is_present(name):
|
||||
|
@ -76,10 +77,12 @@ def fix_case(name):
|
|||
|
||||
def replace_line(existing_line, new_line):
|
||||
"""Replaces lines in /etc/locale.gen"""
|
||||
with open("/etc/locale.gen", "r") as f:
|
||||
lines = [line.replace(existing_line, new_line) for line in f]
|
||||
with open("/etc/locale.gen", "w") as f:
|
||||
f.write("".join(lines))
|
||||
f = open("/etc/locale.gen", "r")
|
||||
lines = [line.replace(existing_line, new_line) for line in f]
|
||||
f.close()
|
||||
f = open("/etc/locale.gen", "w")
|
||||
f.write("".join(lines))
|
||||
f.close()
|
||||
|
||||
def set_locale(name, enabled=True):
|
||||
""" Sets the state of the locale. Defaults to enabled. """
|
||||
|
@ -88,10 +91,12 @@ def set_locale(name, enabled=True):
|
|||
new_string = '%s \g<charset>' % (name)
|
||||
else:
|
||||
new_string = '# %s \g<charset>' % (name)
|
||||
with open("/etc/locale.gen", "r") as f:
|
||||
lines = [re.sub(search_string, new_string, line) for line in f]
|
||||
with open("/etc/locale.gen", "w") as f:
|
||||
f.write("".join(lines))
|
||||
f = open("/etc/locale.gen", "r")
|
||||
lines = [re.sub(search_string, new_string, line) for line in f]
|
||||
f.close()
|
||||
f = open("/etc/locale.gen", "w")
|
||||
f.write("".join(lines))
|
||||
f.close()
|
||||
|
||||
def apply_change(targetState, name):
|
||||
"""Create or remove locale.
|
||||
|
@ -124,13 +129,15 @@ def apply_change_ubuntu(targetState, name):
|
|||
localeGenExitValue = call(["locale-gen", name])
|
||||
else:
|
||||
# Delete locale involves discarding the locale from /var/lib/locales/supported.d/local and regenerating all locales.
|
||||
with open("/var/lib/locales/supported.d/local", "r") as f:
|
||||
content = f.readlines()
|
||||
with open("/var/lib/locales/supported.d/local", "w") as f:
|
||||
for line in content:
|
||||
locale, charset = line.split(' ')
|
||||
if locale != name:
|
||||
f.write(line)
|
||||
f = open("/var/lib/locales/supported.d/local", "r")
|
||||
content = f.readlines()
|
||||
f.close()
|
||||
f = open("/var/lib/locales/supported.d/local", "w")
|
||||
for line in content:
|
||||
locale, charset = line.split(' ')
|
||||
if locale != name:
|
||||
f.write(line)
|
||||
f.close()
|
||||
# Purge locales and regenerate.
|
||||
# Please provide a patch if you know how to avoid regenerating the locales to keep!
|
||||
localeGenExitValue = call(["locale-gen", "--purge"])
|
||||
|
@ -168,7 +175,10 @@ def main():
|
|||
module.fail_json(msg="The locales you've entered is not available "
|
||||
"on your system.")
|
||||
|
||||
prev_state = "present" if is_present(name) else "absent"
|
||||
if is_present(name):
|
||||
prev_state = "present"
|
||||
else:
|
||||
prev_state = "absent"
|
||||
changed = (prev_state!=state)
|
||||
|
||||
if module.check_mode:
|
||||
|
@ -180,7 +190,7 @@ def main():
|
|||
apply_change(state, name)
|
||||
else:
|
||||
apply_change_ubuntu(state, name)
|
||||
except EnvironmentError as e:
|
||||
except EnvironmentError, e:
|
||||
module.fail_json(msg=e.strerror, exitValue=e.errno)
|
||||
|
||||
module.exit_json(name=name, changed=changed, msg="OK")
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue