mirror of
https://github.com/ansible-collections/ansible.posix.git
synced 2026-03-10 03:25:22 +01:00
Compare commits
4 commits
3678cbda16
...
3f1ebbdb1c
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
3f1ebbdb1c | ||
|
|
7d219a7e05 | ||
|
|
6e7c537956 | ||
|
|
d0ea1143ee |
3 changed files with 32 additions and 9 deletions
11
README.md
11
README.md
|
|
@ -7,6 +7,17 @@ https://dev.azure.com/ansible/ansible.posix/_apis/build/status/CI?branchName=mai
|
||||||
<!-- Describe the collection and why a user would want to use it. What does the collection do? -->
|
<!-- Describe the collection and why a user would want to use it. What does the collection do? -->
|
||||||
An Ansible Collection of modules and plugins that target POSIX UNIX/Linux and derivative Operating Systems.
|
An Ansible Collection of modules and plugins that target POSIX UNIX/Linux and derivative Operating Systems.
|
||||||
|
|
||||||
|
## Communication
|
||||||
|
|
||||||
|
* Join the Ansible forum:
|
||||||
|
* [Get Help](https://forum.ansible.com/c/help/6): get help or help others.
|
||||||
|
* [Social Spaces](https://forum.ansible.com/c/chat/4): gather and interact with fellow enthusiasts.
|
||||||
|
* [News & Announcements](https://forum.ansible.com/c/news/5): track project-wide announcements including social events.
|
||||||
|
|
||||||
|
* The Ansible [Bullhorn newsletter](https://docs.ansible.com/ansible/devel/community/communication.html#the-bullhorn): used to announce releases and important changes.
|
||||||
|
|
||||||
|
For more information about communication, see the [Ansible communication guide](https://docs.ansible.com/ansible/devel/community/communication.html).
|
||||||
|
|
||||||
## Supported Versions of Ansible
|
## Supported Versions of Ansible
|
||||||
<!--start requires_ansible-->
|
<!--start requires_ansible-->
|
||||||
## Ansible version compatibility
|
## Ansible version compatibility
|
||||||
|
|
|
||||||
|
|
@ -332,6 +332,8 @@ class ActionModule(ActionBase):
|
||||||
dest = _tmp_args.get('dest', None)
|
dest = _tmp_args.get('dest', None)
|
||||||
if src is None or dest is None:
|
if src is None or dest is None:
|
||||||
return dict(failed=True, msg="synchronize requires both src and dest parameters are set")
|
return dict(failed=True, msg="synchronize requires both src and dest parameters are set")
|
||||||
|
if isinstance(src, str):
|
||||||
|
src = [src]
|
||||||
|
|
||||||
# Determine if we need a user@ and a password
|
# Determine if we need a user@ and a password
|
||||||
user = None
|
user = None
|
||||||
|
|
@ -358,11 +360,11 @@ class ActionModule(ActionBase):
|
||||||
# use the mode to define src and dest's url
|
# use the mode to define src and dest's url
|
||||||
if _tmp_args.get('mode', 'push') == 'pull':
|
if _tmp_args.get('mode', 'push') == 'pull':
|
||||||
# src is a remote path: <user>@<host>, dest is a local path
|
# src is a remote path: <user>@<host>, dest is a local path
|
||||||
src = self._process_remote(_tmp_args, src_host, src, user, inv_port in localhost_ports)
|
src = [self._process_remote(_tmp_args, src_host, e, user, inv_port in localhost_ports) for e in src]
|
||||||
dest = self._process_origin(dest_host, dest, user)
|
dest = self._process_origin(dest_host, dest, user)
|
||||||
else:
|
else:
|
||||||
# src is a local path, dest is a remote path: <user>@<host>
|
# src is a local path, dest is a remote path: <user>@<host>
|
||||||
src = self._process_origin(src_host, src, user)
|
src = [self._process_origin(src_host, e, user) for e in src]
|
||||||
dest = self._process_remote(_tmp_args, dest_host, dest, user, inv_port in localhost_ports)
|
dest = self._process_remote(_tmp_args, dest_host, dest, user, inv_port in localhost_ports)
|
||||||
|
|
||||||
password = dest_host_inventory_vars.get('ansible_ssh_pass', None) or dest_host_inventory_vars.get('ansible_password', None)
|
password = dest_host_inventory_vars.get('ansible_ssh_pass', None) or dest_host_inventory_vars.get('ansible_password', None)
|
||||||
|
|
@ -371,7 +373,7 @@ class ActionModule(ActionBase):
|
||||||
else:
|
else:
|
||||||
# Still need to munge paths (to account for roles) even if we aren't
|
# Still need to munge paths (to account for roles) even if we aren't
|
||||||
# copying files between hosts
|
# copying files between hosts
|
||||||
src = self._get_absolute_path(path=src)
|
src = [self._get_absolute_path(path=e) for e in src]
|
||||||
dest = self._get_absolute_path(path=dest)
|
dest = self._get_absolute_path(path=dest)
|
||||||
|
|
||||||
_tmp_args['_local_rsync_password'] = password
|
_tmp_args['_local_rsync_password'] = password
|
||||||
|
|
|
||||||
|
|
@ -361,6 +361,17 @@ EXAMPLES = r'''
|
||||||
src: /tmp/localpath/
|
src: /tmp/localpath/
|
||||||
dest: /tmp/remotepath
|
dest: /tmp/remotepath
|
||||||
rsync_path: /usr/gnu/bin/rsync
|
rsync_path: /usr/gnu/bin/rsync
|
||||||
|
|
||||||
|
# Source files from multiple folders and merge them on the remote
|
||||||
|
# Files of the same name in /tmp/path_c/ will take precedence over those in /tmp/path_b/, and same for path_b to path_a
|
||||||
|
- name: Copy files from multiple folders and merge them into dest
|
||||||
|
ansible.posix.synchronize:
|
||||||
|
src:
|
||||||
|
- /tmp/path_a/
|
||||||
|
- /tmp/path_b/
|
||||||
|
- /tmp/path_c/
|
||||||
|
dest: /tmp/dest/
|
||||||
|
recursive: True
|
||||||
'''
|
'''
|
||||||
|
|
||||||
|
|
||||||
|
|
@ -396,9 +407,9 @@ def substitute_controller(path):
|
||||||
|
|
||||||
|
|
||||||
def is_rsh_needed(source, dest):
|
def is_rsh_needed(source, dest):
|
||||||
if source.startswith('rsync://') or dest.startswith('rsync://'):
|
if all(e.startswith('rsync://') for e in source) or dest.startswith('rsync://'):
|
||||||
return False
|
return False
|
||||||
if ':' in source or ':' in dest:
|
if any(':' in e for e in source) or ':' in dest:
|
||||||
return True
|
return True
|
||||||
return False
|
return False
|
||||||
|
|
||||||
|
|
@ -406,7 +417,7 @@ def is_rsh_needed(source, dest):
|
||||||
def main():
|
def main():
|
||||||
module = AnsibleModule(
|
module = AnsibleModule(
|
||||||
argument_spec=dict(
|
argument_spec=dict(
|
||||||
src=dict(type='path', required=True),
|
src=dict(type='list', required=True),
|
||||||
dest=dict(type='path', required=True),
|
dest=dict(type='path', required=True),
|
||||||
dest_port=dict(type='int'),
|
dest_port=dict(type='int'),
|
||||||
delete=dict(type='bool', default=False),
|
delete=dict(type='bool', default=False),
|
||||||
|
|
@ -540,11 +551,10 @@ def main():
|
||||||
if dirs:
|
if dirs:
|
||||||
cmd.append('--dirs')
|
cmd.append('--dirs')
|
||||||
|
|
||||||
if source.startswith('rsync://') and dest.startswith('rsync://'):
|
if all(e.startswith('rsync://') for e in source) and dest.startswith('rsync://'):
|
||||||
module.fail_json(msg='either src or dest must be a localhost', rc=1)
|
module.fail_json(msg='either src or dest must be a localhost', rc=1)
|
||||||
|
|
||||||
if is_rsh_needed(source, dest):
|
if is_rsh_needed(source, dest):
|
||||||
|
|
||||||
# https://github.com/ansible/ansible/issues/15907
|
# https://github.com/ansible/ansible/issues/15907
|
||||||
has_rsh = False
|
has_rsh = False
|
||||||
for rsync_opt in rsync_opts:
|
for rsync_opt in rsync_opts:
|
||||||
|
|
@ -600,7 +610,7 @@ def main():
|
||||||
changed_marker = '<<CHANGED>>'
|
changed_marker = '<<CHANGED>>'
|
||||||
cmd.append('--out-format=%s' % shlex_quote(changed_marker + '%i %n%L'))
|
cmd.append('--out-format=%s' % shlex_quote(changed_marker + '%i %n%L'))
|
||||||
|
|
||||||
cmd.append(shlex_quote(source))
|
[cmd.append(shlex_quote(e)) for e in source]
|
||||||
cmd.append(shlex_quote(dest))
|
cmd.append(shlex_quote(dest))
|
||||||
cmdstr = ' '.join(cmd)
|
cmdstr = ' '.join(cmd)
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue