Vh &ddlmZmZmZeZdZddlmZddl m Z m Z ddl m Z  ddlmZmZmZddlmZdZ dd lmZdZGd d e Zy #e$rd ZYwxYw#e$rd ZY"wxYw))absolute_importdivisionprint_functiona author: - Ansible Networking Team (@ansible-network) name: grpc short_description: Provides a persistent connection using the gRPC protocol description: - This connection plugin provides a connection to remote devices over gRPC and is typically used with devices for sending and receiving RPC calls over gRPC framework. - Note this connection plugin requires the grpcio python library to be installed on the local Ansible controller. version_added: "3.1.0" requirements: - grpcio - protobuf extends_documentation_fragment: - ansible.netcommon.connection_persistent options: host: description: - Specifies the remote device FQDN or IP address to establish the gRPC connection to. default: inventory_hostname type: string vars: - name: ansible_host port: type: int description: - Specifies the port on the remote device that listens for connections when establishing the gRPC connection. If None only the C(host) part will be used. ini: - section: defaults key: remote_port env: - name: ANSIBLE_REMOTE_PORT vars: - name: ansible_port network_os: description: - Configures the device platform network operating system. This value is used to load a device specific grpc plugin to communicate with the remote device. type: string vars: - name: ansible_network_os remote_user: description: - The username used to authenticate to the remote device when the gRPC connection is first established. If the remote_user is not specified, the connection will use the username of the logged in user. - Can be configured from the CLI via the C(--user) or C(-u) options. type: string ini: - section: defaults key: remote_user env: - name: ANSIBLE_REMOTE_USER vars: - name: ansible_user password: description: - Configures the user password used to authenticate to the remote device when first establishing the gRPC connection. type: string vars: - name: ansible_password - name: ansible_ssh_pass private_key_file: description: - The PEM encoded private key file used to authenticate to the remote device when first establishing the grpc connection. type: string ini: - section: grpc_connection key: private_key_file env: - name: ANSIBLE_PRIVATE_KEY_FILE vars: - name: ansible_private_key_file root_certificates_file: description: - The PEM encoded root certificate file used to create a SSL-enabled channel, if the value is None it reads the root certificates from a default location chosen by gRPC at runtime. type: string ini: - section: grpc_connection key: root_certificates_file env: - name: ANSIBLE_ROOT_CERTIFICATES_FILE vars: - name: ansible_root_certificates_file certificate_chain_file: description: - The PEM encoded certificate chain file used to create a SSL-enabled channel. If the value is None, no certificate chain is used. type: string ini: - section: grpc_connection key: certificate_chain_file env: - name: ANSIBLE_CERTIFICATE_CHAIN_FILE vars: - name: ansible_certificate_chain_file ssl_target_name_override: description: - The option overrides SSL target name used for SSL host name checking. The name used for SSL host name checking will be the target parameter (assuming that the secure channel is an SSL channel). If this parameter is specified and the underlying is not an SSL channel, it will just be ignored. type: string ini: - section: grpc_connection key: ssl_target_name_override env: - name: ANSIBLE_GPRC_SSL_TARGET_NAME_OVERRIDE vars: - name: ansible_grpc_ssl_target_name_override grpc_type: description: - This option indicates the grpc type and it can be used in place of network_os. (example cisco.iosxr.iosxr) default: False ini: - section: grpc_connection key: type env: - name: ANSIBLE_GRPC_CONNECTION_TYPE vars: - name: ansible_grpc_connection_type ) import_module)AnsibleConnectionFailure AnsibleError)NetworkConnectionBase)insecure_channelsecure_channelssl_channel_credentials)implementationsTF)protobufc:eZdZdZdZdZfdZdZfdZxZ S) ConnectionzGRPC connectionszansible.netcommon.grpcFc tt| ||g|i||jxs|j d}|rt s t d|js||_ttgd|jd}djdi|}tt|d}||} | r6d|| d|_ |jd d |z|jd d |zytd |ztd )N grpc_typezWprotobuf is required to use the grpc connection type. Please run 'pip install protobuf')corgcnameplugin.zDansible_collections.{corg}.{cname}.plugins.sub_plugins.grpc.{plugin}Grpcgrpc)typenameobjlogzloaded gRPC plugin for type %szgrpc type is set to %sz+unable to load API plugin for network_os %szUnable to automatically determine gRPC implementation type. Please manually configure ansible_network_os value or grpc_type configuration for this host)superr__init__ _network_os get_option HAS_PROTOBUFrdictzipsplitformatgetattrr _sub_plugin queue_messager) self play_context new_stdinargskwargsrcrefgrpclibgrpcclsgrpc_obj __class__s m/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/ansible/netcommon/plugins/connection/grpc.pyrzConnection.__init__s  j$(yR4R6R$$D (D "m###, 79MNODc\ccGmG4f=Gt}H"%#$ ""5*JY*VW""5*BY*NO.AIM+o c ts td|jd}|jj}|j r|j dd|zy|jd}||nd||fz|_|jd|_d |jd fd |jd fg|_ |jd }|r d |fg|_ nd|_ i}|jd}|jd}|jd} |r(t|d5}|j|d<ddd|r(t|d5}|j|d<ddd|r(t|d5}|j|d<ddd|r.tdi|} t!|j| |j} n!t#|j|j} |j dd|jd d|d|t%j&| |_|j ddd|_y#1swY xYw#1swYxYw#1swYxYw#t$r} td| zd} ~ wwxYw)zM Create GRPC connection to target host :return: None zSgrpcio is required to use the gRPC connection type. Please run 'pip install grpcio'hostrz(gRPC connection to host %s already existNportz%s:%dpersistent_command_timeoutusername remote_userpasswordssl_target_name_overridezgrpc.ssl_target_name_overrideprivate_key_fileroot_certificates_filecertificate_chain_filerbroot_certificates private_keycertificate_chainz#Failed to read certificate keys: %s)optionsvvvz$ESTABLISH GRPC CONNECTION FOR USER: z on PORT z TO vvvvz*grpc connection has completed successfullyTr)HAS_GRPCrr! _play_context remote_addr connectedr)_target_timeout_login_credentials_channel_optionsopenread Exceptionrr r r r Channel_channel _connected) r*r7r8r=certsr>r?r@fecredschannels r4_connectzConnection._connects} e v&!!-- >>   u&PSW&W X v&#|tD$<1G (DE 7 8 4 5# $(??3M#N #02JK%D !%)D !??+=>!%1I!J!%1I!J V%0$7:112E-.:*D14Q+,668E-(4%0$7:112E-.: +4e4E$T\\5$BWBWXG&t||T=R=RSG  }-tT ; (//8  6#OP/::44:: V*+PST+TU U Vs`I*&I:I*I$I*:II*I I*II*I'#I** J3JJc|jr,|jdd|jjtt |y)zN Close the active session to the device :return: None rGz&closing gRPC connection to target hostN)rUr)rTcloserr)r*r3s r4r]zConnection.closes: ??   v'O P MM   ! j$%'r5) __name__ __module__ __qualname____doc__ transporthas_pipeliningrr[r] __classcell__)r3s@r4rrs&(IN"H<|((r5rN) __future__rrrr __metaclass__ DOCUMENTATION importlibransible.errorsrransible.plugins.connectionr rr r r grpc.betar rH ImportErrorgooglerr"rrr5r4rns A@ D L$A<NN)HL p(&p(HLs"A A AAA"!A"