\j$^UdZddlZddlZddlZddlZddlmZmZm Z  ddl Z ddl ZejeZiZdZ dZdZej,j/dgZd Zd Zd efd efd efdefdefdefdZeee eeffed<dZdZ dZ!ddZ" ddZ#y#e $rdZ YwxYw)aqImplements I/O streams over SSH. Examples -------- >>> with open('/proc/version_signature', host='1.2.3.4') as conn: ... print(conn.read()) b'Ubuntu 4.4.0-1061.70-aws 4.4.131' Similarly, from a command line:: $ python -c "from smart_open import ssh;print(ssh.open('/proc/version_signature', host='1.2.3.4').read())" b'Ubuntu 4.4.0-1061.70-aws 4.4.131' N)DictCallableTupleT)sshscpsftp)zssh://username@host/path/filezssh://username@host//path/filezscp://username@host/path/filezsftp://username@host/path/filez ~/.ssh/configcH|xrtjj|SN)urllibparseunquote)texts 8/root/env/lib/python3.12/site-packages/smart_open/ssh.py_unquoterDs  .FLL((..c8|dk(ry|dk(rytd|d)NnoFyesTzExpected 'yes' / 'no', got .) ValueError)strings r _str2boolrHs+ ~  26(!< ==rconnecttimeout compressiongssapiauthenticationgssapikeyexchangegssapidelegatecredentialsgssapitrustdns)timeoutcompressgss_authgss_kexgss_deleg_creds gss_trust_dns_PARAMIKO_CONFIG_MAPc ftjj|}|jtvsJt |jt |jt |j|j|jrt|jndt |jS)N)schemeuri_pathuserhostportpassword) r r urlsplitr(SCHEMESdictrpathusernamehostnamer,intr-) uri_as_string split_uris r parse_urir7ds %%m4I   w && & )..) i(( )   $-NNS ),,-  rctjjt|}t |}|j d}|j di||}t||fi|S)Nr)r() smart_openutils check_kwargsopenr7pop)urimodetransport_paramskwargs parsed_urir) final_paramss ropen_urirDqs_    * *41A BF3J~~j)HNN8+j+F+L $ /, //rc4tj}|j|jtj|xsij }d|vr|j d||j d||j||fi||S)N key_filenamer-r2)paramiko SSHClientload_system_host_keysset_missing_host_key_policy AutoAddPolicycopy setdefaultconnect)r3r2r,r-connect_kwargsrrAs r _connect_sshrPzs    C##H$:$:$<=" ( ( *FV#*h/ j(+CKK$)&) Jrcltd|||||fDs|||||fS|s td|xsij}tDcgc]$}tj j |s#|&}}d}|D]} tjj| } || jvr6| j|} || jdd}|s| d}| t| d}|jd"| jdg} t!| r| |d<t"j%D]-\} \} }|j| | | vs || | || </|t&}|st)j*}|r|}|||||fScc}w#t$rY&wxYw#ttf$rYwxYw) Nc3$K|]}|du ywr ).0args r z&_maybe_fetch_config..sWssd{Wsz'you must specify the host to connect tor*r3r,rF identityfile)anyrrL_SSH_CONFIG_FILESosr1existsrG SSHConfig from_pathPermissionError get_hostnameslookupgetr4KeyErrorlenr&items DEFAULT_PORTgetpassgetuser)r+r2r-r,rOconnect_paramsf config_filesactual_hostnameconfig_filenamecfgrX param_name sshcfg_namefrom_strs r_maybe_fetch_configrrs WtXx~&VW WXx~== BCC"%*002N0F!BGGNN14EAFLF O'%H $$..?C s((* * jj  wwvt,H!*oO < 3v;'   n - 577>26L< 1=~.3G3M3M3O H /J/h!!*-5+:L-5c+6F-Gz* HG%HX | ??$ 8T> 99yG    j)   s0$F -F ;FF! FF!F32F3c t|||||\}}}}}||f} d} t| D]p} t| } | jjs(| j t |||||x} t| < | j} | j}nj|||}||_ ||jdi||S#t$rt |||||x} t| <YxwxYw#tj$r=}|jxr|jddk(}| | dz k(s|st| =Yd}~d}~wwxYw)aOpen a file on a remote machine over SSH. Expects authentication to be already set up via existing keys on the local machine. Parameters ---------- path: str The path to the file to open on the remote machine. mode: str, optional The mode to use for opening the file. host: str, optional The hostname of the remote machine. May not be None. user: str, optional The username to use to login to the remote machine. If None, defaults to the name of the current user. password: str, optional The password to use to login to the remote machine. port: int, optional The port to connect to. connect_kwargs: dict, optional Any additional settings to be passed to paramiko.SSHClient.connect. prefetch_kwargs: dict, optional Any additional settings to be passed to paramiko.SFTPFile.prefetch. The presence of this dict (even if empty) triggers prefetching. buffer_size: int, optional Passed to the bufsize argument of paramiko.SFTPClient.open. Returns ------- A file-like object. Important --------- If you specify a previously unseen host, then its host key will be added to the local ~/.ssh/known_hosts *automatically*. If ``username`` or ``password`` are specified in *both* the uri and ``transport_params``, ``transport_params`` will take precedence rzSSH session not activeN)r?bufsizerS)rrrange_SSH get_transportactivecloserPrcopen_sftp_clientrG SSHExceptionargsr<nameprefetch)r1r?r+r*r-r,rOprefetch_kwargs buffer_sizekeyattemptsattemptr transport sftp_clientexconnection_timed_outfobjs rr<r<smd2E dHdN2.D$$ ,CH? Ws)C$$&-- ".tT4>"ZZd3i ))+I#446K 4   Dt[  ADDI" (( K- W*4tX~V VC$s) W$$ #%77#Urwwqz=U/U (Q,&.B S  s*A C 7 C2 !C/.C/2E2D==E)NNNN)rNNNNNN)$__doc__rgr[logging urllib.parser typingrrrrG ImportError MISSING_DEPSsmart_open.utilsr9 getLogger__name__loggerrxr/rf URI_EXAMPLESr1 expanduserrZrrfloatr&str__annotations__r7rDrPrrr<rSrrrs!      8 $     WW''89/>&!%( *'3#Y/3Y?& 2 9d3c8m 445 0 T:r  WoLsB""B,+B,