mirror of
https://github.com/ansible-collections/community.general.git
synced 2024-09-14 20:13:21 +02:00
Merge remote-tracking branch 'pib/unarchive_remote' into pull_5136
This commit is contained in:
commit
e6c9705058
2 changed files with 27 additions and 11 deletions
|
@ -50,12 +50,14 @@ class ActionModule(object):
|
|||
options.update(utils.parse_kv(module_args))
|
||||
source = options.get('src', None)
|
||||
dest = options.get('dest', None)
|
||||
copy = utils.boolean(options.get('copy', 'yes'))
|
||||
|
||||
if source is None or dest is None:
|
||||
result=dict(failed=True, msg="src (or content) and dest are required")
|
||||
return ReturnData(conn=conn, result=result)
|
||||
|
||||
source = template.template(self.runner.basedir, source, inject)
|
||||
if copy:
|
||||
if '_original_file' in inject:
|
||||
source = utils.path_dwim_relative(inject['_original_file'], 'files', source, self.runner.basedir)
|
||||
else:
|
||||
|
@ -66,6 +68,7 @@ class ActionModule(object):
|
|||
result = dict(failed=True, msg="dest must be an existing dir")
|
||||
return ReturnData(conn=conn, result=result)
|
||||
|
||||
if copy:
|
||||
# transfer the file to a remote tmp location
|
||||
tmp_src = tmp + 'source'
|
||||
conn.put_file(source, tmp_src)
|
||||
|
@ -73,7 +76,10 @@ class ActionModule(object):
|
|||
# handle diff mode client side
|
||||
# handle check mode client side
|
||||
# fix file permissions when the copy is done as a different user
|
||||
if copy:
|
||||
if self.runner.sudo and self.runner.sudo_user != 'root':
|
||||
self.runner._low_level_exec_command(conn, "chmod a+r %s" % tmp_src, tmp)
|
||||
module_args = "%s src=%s original_basename=%s" % (module_args, pipes.quote(tmp_src), pipes.quote(os.path.basename(source)))
|
||||
else:
|
||||
module_args = "%s original_basename=%s" % (module_args, pipes.quote(os.path.basename(source)))
|
||||
return self.runner._execute_module(conn, tmp, 'unarchive', module_args, inject=inject, complex_args=complex_args)
|
||||
|
|
|
@ -37,6 +37,12 @@ options:
|
|||
- Remote absolute path where the archive should be unpacked
|
||||
required: true
|
||||
default: null
|
||||
copy:
|
||||
description:
|
||||
- Should the file be copied from the local to the remote machine?
|
||||
required: false
|
||||
choices: [ "yes", "no" ]
|
||||
default: "yes"
|
||||
author: Dylan Martin
|
||||
todo:
|
||||
- detect changed/unchanged for .zip files
|
||||
|
@ -153,6 +159,7 @@ def main():
|
|||
src = dict(required=True),
|
||||
original_basename = dict(required=False), # used to handle 'dest is a directory' via template, a slight hack
|
||||
dest = dict(required=True),
|
||||
copy = dict(default=True, type='bool'),
|
||||
),
|
||||
add_file_common_args=True,
|
||||
)
|
||||
|
@ -162,7 +169,10 @@ def main():
|
|||
|
||||
# did tar file arrive?
|
||||
if not os.path.exists(src):
|
||||
if copy:
|
||||
module.fail_json(msg="Source '%s' failed to transfer" % (src))
|
||||
else:
|
||||
module.fail_json(msg="Source '%s' does not exist" % (src))
|
||||
if not os.access(src, os.R_OK):
|
||||
module.fail_json(msg="Source '%s' not readable" % (src))
|
||||
|
||||
|
|
Loading…
Reference in a new issue