a!vdZddlmZddlZddlZddlZddlZddlZddlZddl m Z m Z m Z m Z ddlmZmZmZmZmZddlmZddZere ndZere ndZdd Zd d Zd Zd Zd ZdZdZdZ dZ!dZ"dZ#ia$da%ejLa'dZ(e fdZ)Gdde*Z+e+Z,dZ-dZ.dZ/Gdde*Z0dZ1y)!z0 Useful functions used by the rest of paramiko. ) generatorsN)DEBUG zero_byte xffffffffmax_byte)PY2longbyte_chrbyte_ordb) SSHConfigc td}d}|s!t|dkDrt|ddk\rd}t|dzr%t}|rt}|dt|dzz z|z}t dt|dD]'}|dzt jd|||dzdz})|r|tddt|zzz}|S)zTturns a normalized byte string into a long-int (adapted from Crypto.Util.number)r >I)r lenr rrrangestructunpack)salways_positiveoutnegativefilleris -lib/python3.12/site-packages/paramiko/util.py inflate_longr %s q'CH A !A$41G 1vz F a#a&1*n % ) 1c!fa AbyFMM$!a!e =a@@A tAw1s1v:&& Jct}t|}|dk7r5|dk7r0tjd|tz|z}|dz}|dk7r|dk7r0t |D])}|dk(r|dt k7rn*|dk(s|dtk7s)nd}|dk(rt}nt}||dd}|r>|dk(rt|ddk\r t|z}|dk(rt|ddkr t|z}|S) zTturns a long-int into a normalized byte string (adapted from Crypto.Util.number)rrrr)rNr) bytesr rpackr enumerate deflate_zero deflate_ffrrr )nadd_sign_paddingrrs r deflate_longr,>s A QA 6R KKa)m ,q 0 b 6Rq\  F1-  G!A$*,    6AA !A$& A F!A$4/A A G(1Q4.4/1 A Hr!c d}g}t||dzkDr7|jt|||dz|dz }t||dzkDr7|t|kr|jt||d|Dcgc]}||z c}Scc}w)Nr)rappendformat_binary_line)dataprefixxrlines r format_binaryr5]s A C d)a"f  %d1q2v&678 R d)a"f  3t9} %d12h/0&) *dFTM ** *s< B c :dj|Dcgc]}djt|c}}dj|Dcgc].}djt|t|dzdz0c}}dj||Scc}wcc}w)N z{:02X}z.{:c}..?_z {:50s} {})joinformatr )r1cleftrights rr0r0hs 884@aX__Xa[1@ AD GGJNOQ  (1+ & b(8R'? @O E   dE ** AOs !B3Bcd}|D]G}t|}d|cxkrdkrnn|t|z }+|tdj|z }I|S)Nr!rz%{:02X})r r r r<)rrr=rs r safe_stringrBpsY C * QK >c> 8A; C 1Y%%a() )C * Jr!c |jS#t$rIt|d}t|d}|dk(rYyt |dz}|dzs|dz}|dz}|dzs|cYSwxYw)NFrrrr) bit_lengthAttributeErrorr,r r)r*normhbytebitlens rrDrD{s| ||~  Au%a! A:TQ4< aKE aKF4<  s(A$"A$A$#A$cdjtjtjj dS)Nr8 )r; tracebackformat_exceptionsysexc_infosplitr!r tb_stringsrQs- 779--s||~> ? E Ed KKr!cpt}t}t|dkDr|dd}|dkDr|}t|dkDr|j||jt||j||j }t |t|}||d|z }||z}|dkDr|S)a Given a password, passphrase, or other human-source key, scramble it through a secure hash into some keyworthy bytes. This specific algorithm is used for encrypting/decrypting private key files. :param function hash_alg: A function which creates a new hash object, such as ``hashlib.sha256``. :param salt: data to salt the hash with. :type salt: byte string :param str key: human-entered password or passphrase. :param int nbytes: number of bytes to generate. :return: Key data `str` rNr)r%rupdater digestmin)hash_algsaltkeynbyteskeydatarThash_objsizes rgenerate_key_bytesr]sgG WF 4y1}BQx 1*: v;? OOF ##"63v;'6%4= $ 1* Nr!cddlm}||S)a Read a file of known SSH host keys, in the format used by openssh, and return a compound dict of ``hostname -> keytype ->`` `PKey `. The hostname may be an IP address or DNS name. The keytype will be either ``"ssh-rsa"`` or ``"ssh-dss"``. This type of file unfortunately doesn't exist on Windows, but on posix, it will usually be stored in ``os.path.expanduser("~/.ssh/known_hosts")``. Since 1.5.3, this is just a wrapper around `.HostKeys`. :param str filename: name of the file to read host keys from :return: nested dict of `.PKey` objects, indexed by hostname and then keytype r)HostKeys)paramiko.hostkeysr_)filenamer_s rload_host_keysrbs + H r!c<t}|j||S)z Provided only as a backward-compatible wrapper around `.SSHConfig`. .. deprecated:: 2.7 Use `SSHConfig.from_file` instead. )r parse)file_objconfigs rparse_ssh_configrgs[F LL Mr!c$|j|S)zM Provided only as a backward-compatible wrapper around `.SSHConfig`. )lookup)hostnamerfs rlookup_ssh_host_configrks == ""r!cdd|}}}dd|}}}|dkDr)||z}||||zz }}||||zz }}||||zz }}|dkDr)|dkr||z }|S)NrrrP) r3mu1u2u3v1v2v3qs r mod_inverserusAqBBAqBB q& "HR"q&[BR"q&[BR"q&[B q&  Av a Ir!c(ttj} t|S#t$r`t j  tdz atx}t|<t jn#t jwxYw|cYSwxYw)Nr) id threading currentThread _g_thread_idsKeyError_g_thread_lockacquire_g_thread_counterrelease)tidrets r get_thread_idrs} Y $ $ & 'C S!!   %  " '8 8C-$  " " $N " " $ s'(BA3B3B  BBc>tjd}t|jdkDry|j |t |d}tj |}d}|dz }|jtj|d|j|y)zKsend paramiko logs to a logfile, if they're not already going somewhereparamikorNaz>%(levelname)-.3s [%(asctime)s.%(msecs)03d] thr=%(_threadid)-3dz %(name)s: %(message)sz%Y%m%d-%H:%M:%S) logging getLoggerrhandlerssetLevelopen StreamHandler setFormatter Formatter addHandler)ralevelloggerfhandlerfrms r log_to_filers  z *F 6??a OOE XsA##A&G JC ##C **30ABC gr!ceZdZdZy)PFilterc"t|_y)NT)r _threadid)selfrecords rfilterzPFilter.filter s(?r!N)__name__ __module__ __qualname__rrPr!rrrsr!rcZtj|}|jt|SN)rr addFilter_pfilter)namers r get_loggerrs%   t $F X Mr!c~ |S#t$r(}|jtjk7rYd}~nd}~wwxYw=)z6Retries function until it doesn't raise an EINTR errorN)EnvironmentErrorerrnoEINTR)functiones rretry_on_signalrs?  :  ww%++%&  s ;6;ct|t|k7ryd}trtntt|D]"}|t ||t ||z z}$|dk(S)NFr)rrxrangerr )rr resrs rconstant_time_bytes_eqr!s^ 1vQ CfA // x!~1../ !8Or!ceZdZdZdZy)ClosingContextManagerc|SrrP)rs r __enter__zClosingContextManager.__enter__,s r!c$|jyr)close)rtypevaluerKs r__exit__zClosingContextManager.__exit__/s  r!N)rrrrrrPr!rrr+s r!rc.t|t||Sr)maxrU)minimumvalmaximums r clamp_valuer3s wC) **r!)F)T)r8)2__doc__ __future__rrrMrrKrxrparamiko.commonrrrrparamiko.py3compatrr r r r paramiko.configr r r(r)r,r5r0rBrDrQr]rbrgrkrurzr~Lockr|rrobjectrrrrrrrrPr!rrs&" AA??%* yQ X$  >++ L>* #  ! !&  f 9 F+r!