|
|
@ -47,25 +47,34 @@ class ShellBase(AnsiblePlugin):
|
|
|
|
|
|
|
|
|
|
|
|
self.tempdir = None
|
|
|
|
self.tempdir = None
|
|
|
|
|
|
|
|
|
|
|
|
def set_options(self, task_keys=None, var_options=None, direct=None):
|
|
|
|
def _normalize_system_temps(self):
|
|
|
|
|
|
|
|
|
|
|
|
super(ShellBase, self).set_options(task_keys=task_keys, var_options=var_options, direct=direct)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
# set env
|
|
|
|
|
|
|
|
self.env.update(self.get_option('environment'))
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
# Normalize the temp directory strings. We don't use expanduser/expandvars because those
|
|
|
|
# Normalize the temp directory strings. We don't use expanduser/expandvars because those
|
|
|
|
# can vary between remote user and become user. Therefore the safest practice will be for
|
|
|
|
# can vary between remote user and become user. Therefore the safest practice will be for
|
|
|
|
# this to always be specified as full paths)
|
|
|
|
# this to always be specified as full paths)
|
|
|
|
normalized_system_temps = [d.rstrip('/') for d in self.get_option('system_temps')]
|
|
|
|
normalized_paths = [d.rstrip('/') for d in self.get_option('system_temps')]
|
|
|
|
|
|
|
|
|
|
|
|
# Make sure all system_temps are absolute otherwise they'd be relative to the login dir
|
|
|
|
# Make sure all system_temps are absolute otherwise they'd be relative to the login dir
|
|
|
|
# which is almost certainly going to fail in a cornercase.
|
|
|
|
# which is almost certainly going to fail in a cornercase.
|
|
|
|
if not all(os.path.isabs(d) for d in normalized_system_temps):
|
|
|
|
if not all(os.path.isabs(d) for d in normalized_paths):
|
|
|
|
raise AnsibleError('The configured system_temps contains a relative path: {0}. All'
|
|
|
|
raise AnsibleError('The configured system_temps contains a relative path: {0}. All'
|
|
|
|
' system_temps must be absolute'.format(to_native(normalized_system_temps)))
|
|
|
|
' system_temps must be absolute'.format(to_native(normalized_paths)))
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
self.set_option('system_temps', normalized_paths)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def set_options(self, task_keys=None, var_options=None, direct=None):
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
super(ShellBase, self).set_options(task_keys=task_keys, var_options=var_options, direct=direct)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
# set env
|
|
|
|
|
|
|
|
self.env.update(self.get_option('environment'))
|
|
|
|
|
|
|
|
|
|
|
|
self.set_option('system_temps', normalized_system_temps)
|
|
|
|
# We can remove the try: except in the future when we make ShellBase a proper subset of
|
|
|
|
|
|
|
|
# *all* shells. Right now powershell and third party shells which do not use the
|
|
|
|
|
|
|
|
# shell_common documentation fragment (and so do not have system_temps) will fail
|
|
|
|
|
|
|
|
try:
|
|
|
|
|
|
|
|
self._normalize_system_temps()
|
|
|
|
|
|
|
|
except AnsibleError:
|
|
|
|
|
|
|
|
pass
|
|
|
|
|
|
|
|
|
|
|
|
def env_prefix(self, **kwargs):
|
|
|
|
def env_prefix(self, **kwargs):
|
|
|
|
return ' '.join(['%s=%s' % (k, shlex_quote(text_type(v))) for k, v in kwargs.items()])
|
|
|
|
return ' '.join(['%s=%s' % (k, shlex_quote(text_type(v))) for k, v in kwargs.items()])
|
|
|
|