\jwdZddlZddlZddlZddlZddlmZm Z m Z ddl Z eje ZdZ dZdZdZdZd Zd Zd Zd ddded dfdZy)z Implements I/O streams over FTP.N)FTPFTP_TLS error_reply)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/filecH|xrtjj|SN)urllibparseunquote)texts 8/root/env/lib/python3.12/site-packages/smart_open/ftp.py_unquoter$s  .FLL((..c Ztjj|}|jtvsJt |jt |jt |j|jt|jxstt |jS)N)schemeuri_pathuserhostportpassword)r r urlsplitrSCHEMESdictrpathusernamehostnameintr DEFAULT_PORTr) uri_as_string split_uris r parse_urir#(s %%m4I   w && & )..) i(( )    /< 0),,-  rctjjt|t |}|j d}|j d}|dk(rdnd}t||f||d|S)NrrrTF)secure_connectiontransport_params) smart_openutils check_kwargsopenr#pop)urimoder& parsed_urirr secure_conns ropen_urir05sv!!$(893J~~j)H ^^H %F F*$K   &)     rcgd}|Dcgc] }||vs| }}|jDcic] \}}||vs ||}}}|rtjd||Scc}wcc}}w)N)timeoutsource_addressencodingz.ignoring unsupported ftp keyword arguments: %r)itemsloggerwarning)r&supported_keywordskunsupported_keywordsvkwargss r convert_transport_params_to_argsr=Dsy (8W!1DV;VAWW!1!7!7!9 Uv1QBT=Tad UF U <>R  MX Us AA A A ct|}|r ?F009P9PQ 4k4V4mFm Hd# (H%  J  WX  T  s0B)B7 B4B//B47 CCCrbFc|s td|s td|si}t||||||}dddd} | |\} } | |\} } |jd|j | d |} | j | } d }| j | _| | _|| _ tj|| | _| S#t$rtd|wxYw) aiOpen a file for reading or writing via FTP/FTPS. Parameters ---------- path: str The path on the remote server mode: str Must be "rb" or "wb" host: str The host to connect to user: str The username to use for the connection password: str The password for the specified username port: int The port to connect to secure_connection: bool True for FTPS, False for FTP transport_params: dict Additional parameters for the FTP connection. Currently supported parameters: timeout, source_address, encoding. z'you must specify the host to connect tozyou must specify the user)RETRrN)STORwb)APPErR)rNrRabzunsupported mode: zTYPE I c|j|jj|jjyr ) orig_closesocketcloseconn)selfs r full_closezopen..full_closes*   r) ValueErrorrMKeyErrorvoidcmd transfercmdmakefilerYrWrXrZtypes MethodType)rr-rrrrr%r&rZmode_to_ftp_cmdsftp_mode file_obj_moderXfobjr\s rr*r*ms @ BCC 455  D$h0ACS TD 8"24"8-/t4HmLL    !D62 3F ??= )D jjDODKDI!!*d3DJ K! 8-dX6778s B==C)__doc__loggingrB urllib.parser smart_open.utilsr'ftplibrrrrb getLogger__name__r6rr URI_EXAMPLESrr#r0r=rMr*rArrrpsz' ,,   8 $   /  "4   >r