VhddlmZddlZddlZddlZddlZddlZddlZddlZddl m Z ddl m Z m Z ddlmZddlmZdZdZd Zd Zd ZGd d eZGddeZy)) annotationsN)partial)to_bytesto_text)AnsibleJSONEncoder) iteritemsctj|}|jdt|z|j|y)z;Write a length+newline-prefixed pickled object to a stream.s%d N)pickledumpswritelen)streamobjsrcs O/home/dcms/DCMS/lib/python3.12/site-packages/ansible/module_utils/connection.pywrite_to_streamr-s1 ,,s C LL3s8#$ LLchtjdt|}|j||zS)N!Q)structpackr sendall)sdata packed_lens r send_datar5s*T3t9-J 99Z$& ''rcjd}td}t||kr4|j|t|z }|sy||z }t||kr4tjd|d|d}||d}t||kr4|j|t|z }|sy||z }t||kr4|S)Nrr)rr recvrunpack)r header_lenrddata_lens r recv_datar%:sJ B? ?&rc |j|S#t$rP|jdr&td|jj d|dt |j|cYSwxYw)N_'z' object has no attribute ')__dict__KeyError startswithAttributeErrorrNrOr__rpc__)rKnames r __getattr__zConnection.__getattr__ns] /==& & /s#$DNNLcLcei%jkk4<<. . /sAA*)A*c  t|g|i|}|d}tjj|jst d|jz t j|td} |j|} t j |} | d|k7r t dd| vr&t/j t1| dd| d<| S#t$r}t dt|zd}~wwxYw#tj$r=} t d|jzt| dtj d} ~ wwxYw#t"$r|j%d rt d j'|||D cgc] } t)| ncc} wc} t+|D cgc]\} } d j'| | ncc} } wc} } z}d j-|}t dj'|||wxYw)Nr;zsocket path %s does not exist or cannot be found. See Troubleshooting socket path issues in the Network Debug and Troubleshooting GuideT)cls vault_to_textzFailed to encode some variables as JSON for communication with the persistent connection helper. The original exception was: %szuunable to connect to socket %s. See Troubleshooting socket path issues in the Network Debug and Troubleshooting Guider*r+r) exception set_optionz;Unable to decode JSON from response to {0}. Received '{1}'.z {0}={1!r}z, z@Unable to decode JSON from response to {0}({1}). Received '{2}'.zinvalid json-rpc id received result_typeresultsurrogateescape)rEospathexistsrVr0jsonr r TypeErrorrsendsocketerror traceback format_excloads ValueErrorr\formatreprrjoinr r)rKr_rArBrDrCrr6r5eresponseargrLrMr<s r _exec_jsonrpczConnection._exec_jsonrpcvs d4T4V4D ww~~d../!MOSO_O_`   ::c'9ND ))D/C zz#H D>U "!"@A A H $!'hx7IRc.d!eHX E !13:3<@  || !ACGCSCSTA&>?9K_K_Ka   |,%QXXY]_bc,00Cd3i00YbciYj3kQUQRTUK4F4Fq!4L3k3kkFYYv&F!RYYZ^`fhkl  sTC4DE C?#C::C?E8E  E9H F! H 6G ;H c|j|g|i|}d|vrF|jd}|jdxs|d}|d}tt|d||dS) aExecutes the json-rpc and returns the output received from remote device. :name: rpc method to be executed over connection plugin that implements jsonrpc 2.0 :args: Ordered list of params passed as arguments to rpc method :kwargs: Dict of valid key, value pairs passed as arguments to rpc method For usage refer the respective connection plugin docs. rqrr7r'r*r+)r'rh)r|getr0r)rKr_rArBrzr)msgr's rr^zConnection.__rpc__sv&4%%d>||  HHJ!:<@?9K_K_Ka  sA-B C,AC''C,N)rOrPrQrIr`r|r^rorrr-r-gs' //b"(?rr-) __future__rrjrmr rprrrr> functoolsr+ansible.module_utils.common.text.convertersrr ansible.module_utils.common.jsonransible.module_utils.sixrrrr%r/rE Exceptionr0objectr-rrrrs^:#  I?.( $ i f?f?r