mirror of
				https://github.com/ansible-collections/community.general.git
				synced 2025-10-26 13:56:09 -07:00 
			
		
		
		
	* [WIP] become plugins
Move from hardcoded method to plugins for ease of use, expansion and overrides
  - load into connection as it is going to be the main consumer
  - play_context will also use to keep backwards compat API
  - ensure shell is used to construct commands when needed
  - migrate settings remove from base config in favor of plugin specific configs
  - cleanup ansible-doc
  - add become plugin docs
  - remove deprecated sudo/su code and keywords
  - adjust become options for cli
  - set plugin options from context
  - ensure config defs are avaialbe before instance
  - refactored getting the shell plugin, fixed tests
     - changed into regex as they were string matching, which does not work with random string generation
     - explicitly set flags for play context tests
 - moved plugin loading up front
 - now loads for basedir also
 - allow pyc/o for non m modules
 - fixes to tests and some plugins
 - migrate to play objects fro play_context
 - simiplify gathering
 -  added utf8 headers
 - moved option setting
 - add fail msg to dzdo
 - use tuple for multiple options on fail/missing
 - fix relative plugin paths
 - shift from play context to play
 - all tasks already inherit this from play directly
 - remove obsolete 'set play'
 - correct environment handling
 - add wrap_exe option to pfexec
 - fix runas to noop
 - fixed setting play context
 - added password configs
 - removed required false
 - remove from doc building till they are ready
future development:
  - deal with 'enable' and 'runas' which are not 'command wrappers' but 'state flags' and currently hardcoded in diff subsystems
* cleanup
  remove callers to removed func
  removed --sudo cli doc refs
  remove runas become_exe
  ensure keyerorr on plugin
  also fix backwards compat, missing method is attributeerror, not ansible error
  get remote_user consistently
  ignore missing system_tmpdirs on plugin load
  correct config precedence
  add deprecation
  fix networking imports
  backwards compat for plugins using BECOME_METHODS
* Port become_plugins to context.CLIARGS
This is a work in progress:
* Stop passing options around everywhere as we can use context.CLIARGS
  instead
* Refactor make_become_commands as asked for by alikins
* Typo in comment fix
* Stop loading values from the cli in more than one place
Both play and play_context were saving default values from the cli
arguments directly.  This changes things so that the default values are
loaded into the play and then play_context takes them from there.
* Rename BECOME_PLUGIN_PATH to DEFAULT_BECOME_PLUGIN_PATH
As alikins said, all other plugin paths are named
DEFAULT_plugintype_PLUGIN_PATH.  If we're going to rename these, that
should be done all at one time rather than piecemeal.
* One to throw away
This is a set of hacks to get setting FieldAttribute defaults to command
line args to work.  It's not fully done yet.
After talking it over with sivel and jimi-c this should be done by
fixing FieldAttributeBase and _get_parent_attribute() calls to do the
right thing when there is a non-None default.
What we want to be able to do ideally is something like this:
class Base(FieldAttributeBase):
    _check_mode = FieldAttribute([..] default=lambda: context.CLIARGS['check'])
class Play(Base):
    # lambda so that we have a chance to parse the command line args
    # before we get here.  In the future we might be able to restructure
    # this so that the cli parsing code runs before these classes are
    # defined.
class Task(Base):
    pass
And still have a playbook like this function:
---
- hosts:
  tasks:
  - command: whoami
    check_mode: True
(The check_mode test that is added as a separate commit in this PR will
let you test variations on this case).
There's a few separate reasons that the code doesn't let us do this or
a non-ugly workaround for this as written right now.  The fix that
jimi-c, sivel, and I talked about may let us do this or it may still
require a workaround (but less ugly) (having one class that has the
FieldAttributes with default values and one class that inherits from
that but just overrides the FieldAttributes which now have defaults)
* Revert "One to throw away"
This reverts commit 23aa883cbed11429ef1be2a2d0ed18f83a3b8064.
* Set FieldAttr defaults directly from CLIARGS
* Remove dead code
* Move timeout directly to PlayContext, it's never needed on Play
* just for backwards compat, add a static version of BECOME_METHODS to constants
* Make the become attr on the connection public, since it's used outside of the connection
* Logic fix
* Nuke connection testing if it supports specific become methods
* Remove unused vars
* Address rebase issues
* Fix path encoding issue
* Remove unused import
* Various cleanups
* Restore network_cli check in _low_level_execute_command
* type improvements for cliargs_deferred_get and swap shallowcopy to default to False
* minor cleanups
* Allow the su plugin to work, since it doesn't define a prompt the same way
* Fix up ksu become plugin
* Only set prompt if build_become_command was called
* Add helper to assist connection plugins in knowing they need to wait for a prompt
* Fix tests and code expectations
* Doc updates
* Various additional minor cleanups
* Make doas functional
* Don't change connection signature, load become plugin from TaskExecutor
* Remove unused imports
* Add comment about setting the become plugin on the playcontext
* Fix up tests for recent changes
* Support 'Password:' natively for the doas plugin
* Make default prompts raw
* wording cleanups. ci_complete
* Remove unrelated changes
* Address spelling mistake
* Restore removed test, and udpate to use new functionality
* Add changelog fragment
* Don't hard fail in set_attributes_from_cli on missing CLI keys
* Remove unrelated change to loader
* Remove internal deprecated FieldAttributes now
* Emit deprecation warnings now
		
	
			
		
			
				
	
	
		
			79 lines
		
	
	
	
		
			3.9 KiB
		
	
	
	
		
			Python
		
	
	
	
	
	
			
		
		
	
	
			79 lines
		
	
	
	
		
			3.9 KiB
		
	
	
	
		
			Python
		
	
	
	
	
	
| # Copyright (c) 2014, Chris Church <chris@ninemoreminutes.com>
 | |
| # Copyright (c) 2017 Ansible Project
 | |
| # GNU General Public License v3.0+ (see COPYING or https://www.gnu.org/licenses/gpl-3.0.txt)
 | |
| from __future__ import (absolute_import, division, print_function)
 | |
| __metaclass__ = type
 | |
| 
 | |
| DOCUMENTATION = '''
 | |
| name: sh
 | |
| plugin_type: shell
 | |
| short_description: "POSIX shell (/bin/sh)"
 | |
| version_added: historical
 | |
| description:
 | |
|   - This shell plugin is the one you want to use on most Unix systems, it is the most compatible and widely installed shell.
 | |
| extends_documentation_fragment:
 | |
|   - shell_common
 | |
| '''
 | |
| 
 | |
| from ansible.module_utils.six.moves import shlex_quote
 | |
| from ansible.plugins.shell import ShellBase
 | |
| 
 | |
| 
 | |
| class ShellModule(ShellBase):
 | |
| 
 | |
|     # Common shell filenames that this plugin handles.
 | |
|     # Note: sh is the default shell plugin so this plugin may also be selected
 | |
|     # This code needs to be SH-compliant. BASH-isms will not work if /bin/sh points to a non-BASH shell.
 | |
| 
 | |
|     # if the filename is not listed in any Shell plugin.
 | |
|     COMPATIBLE_SHELLS = frozenset(('sh', 'zsh', 'bash', 'dash', 'ksh'))
 | |
|     # Family of shells this has.  Must match the filename without extension
 | |
|     SHELL_FAMILY = 'sh'
 | |
| 
 | |
|     # commonly used
 | |
|     ECHO = 'echo'
 | |
|     COMMAND_SEP = ';'
 | |
| 
 | |
|     # How to end lines in a python script one-liner
 | |
|     _SHELL_EMBEDDED_PY_EOL = '\n'
 | |
|     _SHELL_REDIRECT_ALLNULL = '> /dev/null 2>&1'
 | |
|     _SHELL_AND = '&&'
 | |
|     _SHELL_OR = '||'
 | |
|     _SHELL_SUB_LEFT = '"`'
 | |
|     _SHELL_SUB_RIGHT = '`"'
 | |
|     _SHELL_GROUP_LEFT = '('
 | |
|     _SHELL_GROUP_RIGHT = ')'
 | |
| 
 | |
|     def checksum(self, path, python_interp):
 | |
|         # In the following test, each condition is a check and logical
 | |
|         # comparison (|| or &&) that sets the rc value.  Every check is run so
 | |
|         # the last check in the series to fail will be the rc that is returned.
 | |
|         #
 | |
|         # If a check fails we error before invoking the hash functions because
 | |
|         # hash functions may successfully take the hash of a directory on BSDs
 | |
|         # (UFS filesystem?) which is not what the rest of the ansible code expects
 | |
|         #
 | |
|         # If all of the available hashing methods fail we fail with an rc of 0.
 | |
|         # This logic is added to the end of the cmd at the bottom of this function.
 | |
| 
 | |
|         # Return codes:
 | |
|         # checksum: success!
 | |
|         # 0: Unknown error
 | |
|         # 1: Remote file does not exist
 | |
|         # 2: No read permissions on the file
 | |
|         # 3: File is a directory
 | |
|         # 4: No python interpreter
 | |
| 
 | |
|         # Quoting gets complex here.  We're writing a python string that's
 | |
|         # used by a variety of shells on the remote host to invoke a python
 | |
|         # "one-liner".
 | |
|         shell_escaped_path = shlex_quote(path)
 | |
|         test = "rc=flag; [ -r %(p)s ] %(shell_or)s rc=2; [ -f %(p)s ] %(shell_or)s rc=1; [ -d %(p)s ] %(shell_and)s rc=3; %(i)s -V 2>/dev/null %(shell_or)s rc=4; [ x\"$rc\" != \"xflag\" ] %(shell_and)s echo \"${rc}  \"%(p)s %(shell_and)s exit 0" % dict(p=shell_escaped_path, i=python_interp, shell_and=self._SHELL_AND, shell_or=self._SHELL_OR)  # NOQA
 | |
|         csums = [
 | |
|             u"({0} -c 'import hashlib; BLOCKSIZE = 65536; hasher = hashlib.sha1();{2}afile = open(\"'{1}'\", \"rb\"){2}buf = afile.read(BLOCKSIZE){2}while len(buf) > 0:{2}\thasher.update(buf){2}\tbuf = afile.read(BLOCKSIZE){2}afile.close(){2}print(hasher.hexdigest())' 2>/dev/null)".format(python_interp, shell_escaped_path, self._SHELL_EMBEDDED_PY_EOL),  # NOQA  Python > 2.4 (including python3)
 | |
|             u"({0} -c 'import sha; BLOCKSIZE = 65536; hasher = sha.sha();{2}afile = open(\"'{1}'\", \"rb\"){2}buf = afile.read(BLOCKSIZE){2}while len(buf) > 0:{2}\thasher.update(buf){2}\tbuf = afile.read(BLOCKSIZE){2}afile.close(){2}print(hasher.hexdigest())' 2>/dev/null)".format(python_interp, shell_escaped_path, self._SHELL_EMBEDDED_PY_EOL),  # NOQA  Python == 2.4
 | |
|         ]
 | |
| 
 | |
|         cmd = (" %s " % self._SHELL_OR).join(csums)
 | |
|         cmd = "%s; %s %s (echo \'0  \'%s)" % (test, cmd, self._SHELL_OR, shell_escaped_path)
 | |
|         return cmd
 |