暾jBdZddlmZddlZddlZddlZddlZddlm Z m Z m Z ddl m Z mZmZmZmZddlZerddlmZej,eZdZ dZd ZGd d eZdd Zdd ZddZddZ ddZ!ddddeddf ddZ"y)z Implements I/O streams over FTP.) annotationsN)FTPFTP_TLS error_reply)IO TYPE_CHECKINGAny TypedDictcast)TransportParams)ftpftps)zftp://username@host/path/filez&ftp://username:password@host/path/filez+ftp://username:password@host:port/path/filezftps://username@host/path/filez'ftps://username:password@host/path/filez,ftps://username:password@host:port/path/filecJeZdZUded<ded<ded<ded<ded<ded <y ) _FTPUristrscheme str | Noneuri_pathuserhostintportpasswordN)__name__ __module__ __qualname____annotations__X/home/spazio/kingdom_calls/work5/transenv/lib/python3.12/site-packages/smart_open/ftp.pyrr*s$ K   Ir rcH|xrtjj|SN)urllibparseunquote)texts r!_unquoter(3s  .FLL((..r cJtjj|}|jtvsJ|jt |j t |j|jt|jxstt |jdS)zBParse an ``ftp://`` or ``ftps://`` URI into connection components.)rrrrrr) r$r%urlsplitrSCHEMESr(pathusernamehostnamerr DEFAULT_PORTr) uri_as_string split_uris r! parse_urir27s %%m4I   w && &""Y^^,++,""INN2l3Y//0  r ctjjt|t t |}|j d}|j d}|dk(}t||f||d|S)z?Open an FTP/FTPS URI using the given mode and transport params.rrr)secure_connectiontransport_params) smart_openutils check_kwargsopendictr2pop)urimoder5 parsed_urirr secure_conns r!open_urir@Esw!!$(89!%in!5J~~j)H ^^H %FF"K   &)     r cgd}|Dcgc] }||vs| }}|jDcic] \}}||vs ||}}}|rtjd||Scc}wcc}}w)zDReturn the subset of `transport_params` that the FTP client accepts.)timeoutsource_addressencodingz.ignoring unsupported ftp keyword arguments: %r)itemsloggerwarning)r5supported_keywordskunsupported_keywordsvkwargss r! convert_transport_params_to_argsrMUsu (8W!1DV;VAWW!1!7!7!9 Uv1QBT=Tad UF UGI]^ M X Us AA A A ct|}|r ?F009P9PQ 4k4V4mFm Hd# $uh'eX)>?#w J [\  ab sB1)&C1 C C4rbFc|s d}t||s d}t||si}t||||||} dddd} | |\} } | |\} } | jd | j | d |}|j t d | }d d }|j|_||_ | |_ tj|||_|S#t$r} d|}t|| d} ~ wwxYw)aOpen a file for reading or writing via FTP/FTPS. Args: path: The path on the remote server. mode: Must be "rb" or "wb". host: The host to connect to. user: The username to use for the connection. password: The password for the specified username. port: The port to connect to. secure_connection: True for FTPS, False for FTP. transport_params: Additional parameters for the FTP connection. Currently supported parameters: timeout, source_address, encoding. Returns: A file-like object for the remote FTP/FTPS file. Raises: ValueError: If `host` or `user` is not specified, or if `mode` is unsupported. z'you must specify the host to connect tozyou must specify the user)RETRr])STORwb)APPEra)r]raabzunsupported mode: NzTYPE I r c|j|jj|jjyr#) orig_closesocketcloseconn)selfs r! full_closezopen..full_closes*   r )rjr returnNone) ValueErrorr\KeyErrorvoidcmd transfercmdmakefiler rhrfrgritypes MethodType)r,r=rrrrr4r5msgrimode_to_ftp_cmdsftp_mode file_obj_modeerrrgfobjrks r!r9r9s: 7o )o  D$h0ACS TD '"24"8-/t4HmLL    !D62 3FUM :;D jjDODKDI!!*d3DJ K# '"4(+o3&'sC C+C&&C+)r'rrlr)r0rrlr)r<rr=rr5r rlIO[Any])r5r rlzdict[str, Any])r.rr-rrrrrr4boolr5r rlz FTP | FTP_TLS)r,rr=rrrrrrrrrr4r|r5zTransportParams | Nonerlr{)#__doc__ __future__rloggingrQrs urllib.parser$ftplibrrrtypingrrr r r smart_open.utilsr6smart_open._typingr getLoggerrrFr+r/ URI_EXAMPLESrr(r2r@rMr\r9rr r!rs.'" ,,::2   8 $   i/         & @#/3> > > >  >  >  >>-> >r