| Server IP : 85.193.89.191 / Your IP : 3.133.151.199 Web Server : Apache System : Linux 956367-cx40159.tmweb.ru 3.10.0-1160.105.1.el7.x86_64 #1 SMP Thu Dec 7 15:39:45 UTC 2023 x86_64 User : bitrix ( 600) PHP Version : 8.1.27 Disable Function : NONE MySQL : OFF | cURL : OFF | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : ON Directory : /lib/python2.7/site-packages/ansible/plugins/connection/ |
Upload File : |
�
� �\c @` s� d d l m Z m Z m Z e Z d Z d d l Z d d l Z d d l Z d d l
m Z m Z d d l
m
Z
d d l m Z d d l m Z m Z m Z d d l m Z d d l m Z d d
l m Z d d l m Z e Z d Z y� d d l m! Z! m" Z" d d
l# m$ Z$ m% Z% d d l& m' Z' m( Z( d d l) m* Z* m+ Z+ d d l, m- Z- m. Z. m/ Z/ d d l0 m1 Z1 m2 Z2 Wn e3 k
r�Z4 e5 Z e4 Z n Xy d d l6 m7 Z7 Wn* e3 k
r�d d l8 m9 Z9 e9 � Z7 n Xd e f d � � YZ: d S( i ( t absolute_importt divisiont print_functions
author: Ansible Core Team
connection: psrp
short_description: Run tasks over Microsoft PowerShell Remoting Protocol
description:
- Run commands or put/fetch on a target via PSRP (WinRM plugin)
- This is similar to the I(winrm) connection plugin which uses the same
underlying transport but instead runs in a PowerShell interpreter.
version_added: "2.7"
requirements:
- pypsrp (Python library)
options:
# transport options
remote_addr:
description:
- The hostname or IP address of the remote host.
default: inventory_hostname
vars:
- name: ansible_host
- name: ansible_psrp_host
remote_user:
description:
- The user to log in as.
vars:
- name: ansible_user
- name: ansible_psrp_user
port:
description:
- The port for PSRP to connect on the remote target.
- Default is C(5986) if I(protocol) is not defined or is C(https),
otherwise the port is C(5985).
vars:
- name: ansible_port
- name: ansible_psrp_port
protocol:
description:
- Set the protocol to use for the connection.
- Default is C(https) if I(port) is not defined or I(port) is not C(5985).
choices:
- http
- https
vars:
- name: ansible_psrp_protocol
path:
description:
- The URI path to connect to.
vars:
- name: ansible_psrp_path
default: 'wsman'
auth:
description:
- The authentication protocol to use when authenticating the remote user.
- The default, C(negotiate), will attempt to use C(Kerberos) if it is
available and fall back to C(NTLM) if it isn't.
vars:
- name: ansible_psrp_auth
choices:
- basic
- certificate
- negotiate
- kerberos
- ntlm
- credssp
default: negotiate
cert_validation:
description:
- Whether to validate the remote server's certificate or not.
- Set to C(ignore) to not validate any certificates.
- I(cert_trust_path) can be set to the path of a PEM certificate chain to
use in the validation.
choices:
- validate
- ignore
default: validate
vars:
- name: ansible_psrp_cert_validation
cert_trust_path:
description:
- The path to a PEM certificate chain to use when validating the server's
certificate.
- This value is ignored if I(cert_validation) is set to C(ignore).
vars:
- name: ansible_psrp_cert_trust_path
connection_timeout:
description:
- The connection timeout for making the request to the remote host.
- This is measured in seconds.
vars:
- name: ansible_psrp_connection_timeout
default: 30
message_encryption:
description:
- Controls the message encryption settings, this is different from TLS
encryption when I(ansible_psrp_protocol) is C(https).
- Only the auth protocols C(negotiate), C(kerberos), C(ntlm), and
C(credssp) can do message encryption. The other authentication protocols
only support encryption when C(protocol) is set to C(https).
- C(auto) means means message encryption is only used when not using
TLS/HTTPS.
- C(always) is the same as C(auto) but message encryption is always used
even when running over TLS/HTTPS.
- C(never) disables any encryption checks that are in place when running
over HTTP and disables any authentication encryption processes.
vars:
- name: ansible_psrp_message_encryption
choices:
- auto
- always
- never
default: auto
proxy:
description:
- Set the proxy URL to use when connecting to the remote host.
vars:
- name: ansible_psrp_proxy
ignore_proxy:
description:
- Will disable any environment proxy settings and connect directly to the
remote host.
- This option is ignored if C(proxy) is set.
vars:
- name: ansible_psrp_ignore_proxy
type: bool
default: 'no'
# protocol options
operation_timeout:
description:
- Sets the WSMan timeout for each operation.
- This is measured in seconds.
- This should not exceed the value for C(connection_timeout).
vars:
- name: ansible_psrp_operation_timeout
default: 20
max_envelope_size:
description:
- Sets the maximum size of each WSMan message sent to the remote host.
- This is measured in bytes.
- Defaults to C(150KiB) for compatibility with older hosts.
vars:
- name: ansible_psrp_max_envelope_size
default: 153600
configuration_name:
description:
- The name of the PowerShell configuration endpoint to connect to.
vars:
- name: ansible_psrp_configuration_name
default: Microsoft.PowerShell
N( t AnsibleConnectionFailuret AnsibleError( t AnsibleFileNotFound( t boolean( t to_bytest to_nativet to_text( t ConnectionBase( t _common_args( t secure_hash( t
makedirs_safe( t GenericComplexObjectt RunspacePoolState( t AuthenticationErrort
WinRMError( t PSHostt PSHostUserInterface( t
PowerShellt RunspacePool( t Processt
SignalCodet WinRS( t WSMant AUTH_KWARGS( t display( t Displayt
Connectionc B` s� e Z d Z d Z d g Z e Z e Z e Z d � Z
d � Z d � Z d e d � Z d � Z d
� Z d � Z d � Z d e d
� Z d � Z RS( t psrps .ps1s .exet t runasc O` sJ t | _ t | _ d | _ d | _ d | _ t t | � j | | � d S( Nt
powershell(
t Truet always_pipeline_modulest has_native_asynct Nonet runspacet hostt _shell_typet superR t __init__( t selft argst kwargs( ( sC /usr/lib/python2.7/site-packages/ansible/plugins/connection/psrp.pyR* � s c C` so t s t d t t � � � n t t | � j � | j � t j d | j
| j | j f d | j �| j
skt | j � } t � } t d d t d d | d � | _ t | d | j d | j �| _
t j d | j | j | j j f d | j �y | j
j � WnQ t k
r6} t d t | � � � n) t k
r^} t d t | � � � n Xt | _ n | S( Ns, pypsrp or dependencies are not installed: %ss7 ESTABLISH PSRP CONNECTION FOR USER: %s ON PORT %s TO %sR' s Ansible PSRP Hostt configuration_names8 PSRP OPEN RUNSPACE: auth=%s configuration=%s endpoint=%ss* failed to authenticate with the server: %ss0 psrp connection failure during runspace open: %s(! t
HAS_PYPSRPR R t PYPSRP_IMP_ERRR) R t _connectt
_build_kwargsR t vvvt
_psrp_usert
_psrp_portt
_psrp_hostR& R t _psrp_conn_kwargsR R R% t FalseR' R t _psrp_configuration_namet vvvvvt
_psrp_autht transportt endpointt openR R R R" t
_connected( R+ t
connectiont host_uit e( ( sC /usr/lib/python2.7/site-packages/ansible/plugins/connection/psrp.pyR1 � s>
c C` s- t j d d | j �d | _ | j � d S( Ns PSRP: Reset ConnectionR' ( R R: R6 R% R& R1 ( R+ ( ( sC /usr/lib/python2.7/site-packages/ansible/plugins/connection/psrp.pyt reset� s c C` s\ t t | � j | d | d | �| j d j t � d � rt j | j d � d � } t | d � } t | d d d d
�} | r� | j d � r� t
| j � d d
� } t d | � � n | j
j d d d � } | | k r� t j d � q4t j d | d | j �n | } t j d | d | j �| j | | � \ } } }
| | |
f S( Nt in_datat sudoablet s -EncodedCommandi����s utf-16-let errorst surrogate_or_strictt nonstringt passthruu #!i i s= cannot run the interpreter '%s' on the psrp connection pluginR s! PSRP: EXEC (via pipeline wrapper)s
PSRP: EXEC %sR' ( R) R t exec_commandt
startswitht joinR t base64t b64decodet splitR R t
splitlinesR t _shellt build_module_commandR R3 R6 t _exec_psrp_script( R+ t cmdRD RE t b_commandt scriptt interpretert bootstrap_wrappert rct stdoutt stderr( ( sC /usr/lib/python2.7/site-packages/ansible/plugins/connection/psrp.pyRK � s$
c ` s� t t | � j | | � t j d | | f d | j �| j j | � } d | j j | � } | j j | d t
d t d t �} t | d d �} t
j j | � s� t d t | � � � n t
j j | � } t | j j j d
d � � t | j j d d
��} t | | d | d � } | j � d } t | d � �� � x� t � � f d � d � D]t }
| t |
� 7} t j d | | | t |
� f d | j �t j |
� d } | j | d � j! � | k �qdW| d k r�| j d d t
�n Wd QX| j" � | j# t$ j% � Wd QX| j& d k rKt' t | j( � � � n t) j* | j+ � } | j, d � }
|
s�t' d t | j+ � t | j( � f � � n t- | � } |
| k s�t' d t |
� t | � f � � n d S( Ns PUT %s TO %sR' uk begin {
$ErrorActionPreference = "Stop"
$path = '%s'
$fd = [System.IO.File]::Create($path)
$algo = [System.Security.Cryptography.SHA1CryptoServiceProvider]::Create()
$bytes = @()
} process {
$bytes = [System.Convert]::FromBase64String($input)
$algo.TransformBlock($bytes, 0, $bytes.Length, $bytes, 0) > $null
$fd.Write($bytes, 0, $bytes.Length)
} end {
$fd.Close()
$algo.TransformFinalBlock($bytes, 0, 0) > $null
$hash = [System.BitConverter]::ToString($algo.Hash)
$hash = $hash.Replace("-", "").ToLowerInvariant()
Write-Output -InputObject "{`"sha1`":`"$hash`"}"
}t as_listt strict_modet preserve_rcRG RH s# file or module does not exist: "%s"i i t codepagei� i i t rbc ` s
� j � � S( N( t read( ( t buffer_sizet src_file( sC /usr/lib/python2.7/site-packages/ansible/plugins/connection/psrp.pyt <lambda>Q s R s% PSRP PUT %s to %s (offset=%d, size=%ds
t endt sha1s8 Remote sha1 was not returned, stdout: '%s', stderr: '%s's0 Remote sha1 hash %s does not match local hash %s(. R) R t put_fileR R3 R6 RR t _unquotet _escapet _encode_scriptR" R8 R t ost patht existsR R t getsizet intR& R@ t max_payload_sizeR R t begin_invokeR> t itert lenR: RN t b64encodet sendt tellt
end_invoket signalR t CTRL_CRZ R R\ t jsont loadsR[ t getR ( R+ t in_patht out_pathRW t cmd_partst b_in_patht in_sizet shellt processt offsett datat b64_datat
put_outputt remote_sha1t
local_sha1( ( Rc Rd sC /usr/lib/python2.7/site-packages/ansible/plugins/connection/psrp.pyRh $ sT
"
#
c C` s] t t | � j | | � t j d | | f d | j �| j j | � } | j d d � } t | j
j j | j
j j d d � } | | d } d | j j
| � | f } d } | j | d
t �\ } } } | d k r t d | t | � f � � n | j � d
k r t | � d St | d d �}
t t j j |
� � d } t |
d � �� } x� t rt j d | | | f d | j �| j | | � \ } } } | d k r�t d | t | � f � � n t j | j � � }
| j |
� t |
� | k rcPqcqcW| j d � \ } } } | d k rSt j d | t | � f � n Wd QXd S( Ns FETCH %s TO %sR' s \t /i i i s� $ErrorActionPreference = "Stop"
$path = "%s"
if (Test-Path -Path $path -PathType Leaf) {
$fs = New-Object -TypeName System.IO.FileStream -ArgumentList @(
$path,
[System.IO.FileMode]::Open,
[System.IO.FileAccess]::Read,
[System.IO.FileShare]::Read
)
$buffer_size = %d
} elseif (Test-Path -Path $path -PathType Container) {
Write-Output -InputObject "[DIR]"
} else {
Write-Error -Message "$path does not exist"
$host.SetShouldExit(1)
}sU $ErrorActionPreference = "Stop"
$fs.Seek(%d, [System.IO.SeekOrigin]::Begin) > $null
$buffer = New-Object -TypeName byte[] -ArgumentList $buffer_size
$bytes_read = $fs.Read($buffer, 0, $buffer_size)
if ($bytes_read -gt 0) {
$bytes = $buffer[0..($bytes_read - 1)]
Write-Output -InputObject ([System.Convert]::ToBase64String($bytes))
}t use_local_scopei s. failed to setup file stream for fetch '%s': %ss [DIR]RG RH t wbs PSRP FETCH %s to %s (offset=%ds# failed to transfer file to '%s': %ss $fs.Close()s3 failed to close remote file stream of file '%s': %s( R) R t
fetch_fileR R3 R6 RR Ri t replaceRp R& R@ Rq Rj RT R8 R R t stripR
R Rl Rm t dirnameR> R" R: RN RO t writeRt t warning( R+ R~ R t max_b64_sizeRc t setup_scriptt read_scriptRZ R[ R\ t
b_out_pathR� t out_fileR� ( ( sC /usr/lib/python2.7/site-packages/ansible/plugins/connection/psrp.pyR� q sJ
c C` sd | j rN | j j t j k rN t j d | j j d | j �| j j � n d | _ t
| _ d S( Ns PSRP CLOSE RUNSPACE: %sR' ( R& t stateR t OPENEDR R: t idR6 t closeR% R8 R? ( R+ ( ( sC /usr/lib/python2.7/site-packages/ansible/plugins/connection/psrp.pyR� � s
c C` s� | j j | _ | j j | _ | j j | _ | j d � | _ | j d � | _ | j j
| _ | j d � } | j d � } | d k r� | d k r� d } d } nT | d k r� t
| � d k r� d n d } n' | d k r� | d k r� d n d } n | | _ t
| � | _ | j d � | _ | j d
� | _ | j d � } | j d � } | d
k rkt | _ n! | d k r�| | _ n t | _ t
| j d � � | _ | j d � | _ | j d � | _ t | j d � � | _ t
| j d � � | _ t
| j d � � | _ | j d � | _ g } x! t j � D] } | j | � q5Wt g | j d � D] } | j! d d � ^ q_� } | j" | � } x | D] }
t# j$ d |
� q�Wt% d | j d | j d | j d | j d | j d k d | j d
| j d | j d | j d | j d | j d | j d | j d | j � | _& x; | j' | � D]* }
| j d � d |
} | | j& |
<qQWd S( Nt remote_addrt remote_usert protocolt portt httpsib ia t httpRm t autht cert_validationt cert_trust_patht ignoret connection_timeoutt message_encryptiont proxyt ignore_proxyt operation_timeoutt max_envelope_sizeR. t _extrast
ansible_psrp_R sD ansible_psrp_%s is unsupported by the current psrp version installedt servert usernamet passwordt sslt
encryptiont no_proxys ansible_psrp_%s(( t
_play_contextt
become_methodt _become_methodt become_usert _become_usert become_passt _become_passt
get_optionR6 R4 R� t
_psrp_passR% Rp t _psrp_protocolR5 t
_psrp_pathR; R8 t _psrp_cert_validationR" t _psrp_connection_timeoutt _psrp_message_encryptiont _psrp_proxyR t _psrp_ignore_proxyt _psrp_operation_timeoutt _psrp_max_envelope_sizeR9 R t valuest extendt setR� t
differenceR R� t dictR7 t intersection( R+ R� R� R� R� t supported_argst
auth_kwargt vt
extra_argst unsupported_argst argt option( ( sC /usr/lib/python2.7/site-packages/ansible/plugins/connection/psrp.pyR2 � sn ! .
c C` sW t | j � } | j | d | �| j d | � | j | � \ } } } | | | f S( NR� t input( R R& t
add_scriptt invoket _parse_pipeline_result( R+ RW t
input_dataR� t psRZ R[ R\ ( ( sC /usr/lib/python2.7/site-packages/ansible/plugins/connection/psrp.pyRT
s
c C` s� | j j p | j r d n d } g } x� | j D]� } t | t � r� | j d k r� | j } x4 | j j
� D]# \ } } | j d | | f � qn Wx4 | j j
� D]# \ } } | j d | | f � q� Wd j
| � } n t | d d �} | j | � q1 Wd j
| � } t | j j j � d k rN| d d j
| j j j � 7} n g }
x� | j j D]v } d | j t | � | j | j | j f } | j }
| j j d
k r�|
d k r�| d |
7} n |
j | � qaWd j
|
� } t | j j j � d k r(| d d
j
| j j j � 7} n t j d | d | j �t j d | d | j �t j d | d | j �d | j _ g | j j _ g | j j _ | t | d d �t | d d �f S( s}
PSRP doesn't have the same concept as other protocols with its output.
We need some extra logic to convert the pipeline streams and host
output into the format that Ansible understands.
:param pipeline: The finished PowerShell pipeline that invoked our
commands
:return: rc, stdout, stderr based on the pipeline output
i i u %s: %su
RI t
simplerepru
u sO %s : %s
%s
+ CategoryInfo : %s
+ FullyQualifiedErrorId : %si s
StackTrace:
%ss
R s PSRP RC: %dR' s PSRP STDOUT: %ss PSRP STDERR: %st encodings utf-8N(! R' RZ t
had_errorst outputt
isinstanceR t to_stringR% t
property_setst adapted_propertiest itemst appendt extended_propertiesRM R Rt t uiR[ t streamst errort command_namet strt invocation_position_messaget messaget fq_errort script_stacktraceR� t verbosityR\ R R: R6 R ( R+ t pipelineRZ t stdout_listR� t obj_linest keyt valuet
output_msgR[ t stderr_listR� t error_msgt
stacktraceR\ ( ( sC /usr/lib/python2.7/site-packages/ansible/plugins/connection/psrp.pyR� sF
! #
# ( s .ps1s .exeR N( t __name__t
__module__R< t! module_implementation_preferencest become_methodsR8 t allow_executableR" t has_pipeliningt allow_extrasR* R1 RC R% RK Rh R� R� R2 RT R� ( ( ( sC /usr/lib/python2.7/site-packages/ansible/plugins/connection/psrp.pyR � s
( & M O E(; t
__future__R R R t typet
__metaclass__t
DOCUMENTATIONRN R{ Rl t ansible.errorsR R R t) ansible.module_utils.parsing.convert_boolR t ansible.module_utils._textR R R t ansible.plugins.connectionR
t ansible.plugins.shell.powershellR t ansible.utils.hashingR t ansible.utils.pathR
R" R/ R% R0 t pypsrp.complex_objectsR R t pypsrp.exceptionsR R t pypsrp.hostR R t pypsrp.powershellR R t pypsrp.shellR R R t pypsrp.wsmanR R t ImportErrort errR8 t __main__R t ansible.utils.displayR R ( ( ( sC /usr/lib/python2.7/site-packages/ansible/plugins/connection/psrp.pyt <module> s> �