h"jddlZddlmZmZddlZddlmZddlmZm Z m Z m Z ddl m Z GddeZy)N)BinaryIOList) BaseUTApi)DeleteFileResponseListFileResponse UploadResultUsageInfoResponse)snakifyc eZdZdZ ddedededzdedef dZd edefd Z dd e e e zd ed edzde efdZ ddee ezdedzde fdZ ddedzdedzdefdZdefdZy) AsyncUTApizAsynchronous UploadThing API client. This class provides asynchronous methods for interacting with the UploadThing API. Use this client for async/await operations. Nmethodpathdatatimeoutreturnc~K|j|||\}}}|xsi}|jd|i tj4d{}|jd|||d|d{} | j t | j} t| tr| cdddd{Std7y7]7#1d{7swYyxYw#tj$rtjd|d|ddtj$r} |j| d} ~ wwxYww) aMake an async HTTP request to the UploadThing API. Args: method: HTTP method to use path: API endpoint path data: Request data/parameters timeout: Request timeout in seconds Returns: dict: Parsed JSON response Raises: httpx.TimeoutException: If the request times out httpx.HTTPStatusError: If the server returns an error status rN)r urlheaderszExpected dict responsez Request to z timed out after z seconds)_prepare_requestupdatehttpx AsyncClientrequestraise_for_statusr json isinstancedict TypeErrorTimeoutExceptionHTTPStatusError_handle_error_response) selfr rrrrrrequest_kwargsclientresponseresultes U/var/www/Befach/backend/env/lib/python3.12/site-packages/upyloadthing/async_client.py_requestzAsyncUTApi._requestsU,(,'<'< D$( $Wn(-2y'23 ((* : :f!/"!sG"?M"))+ 1fd+! : : : 899 : : : : :%% ((cU"3G9HE $$   ' ' *  s1D=C! C C!C *C+>C ) C!5C 6C!:D=; C C!C  C! CC CC!D=C!!AD:#D55D::D= file_datac K|jd|dd|d|d|dfid{}td |d|d|d |dd |S7 w) zUpload a single file to UploadThing. Args: file_data: Dictionary containing file metadata and content Returns: UploadResult: Result of the upload operation PUT ingest_urlfilenametype)rNfile_keysize)r2r0r3r1r)r*r)r#r+r's r)_upload_single_filezAsyncUTApi._upload_single_fileEs}}  l #f%f%f%%    z*6"6"6"       s)AA !Afilescontent_dispositionaclcKt|ts|g}|Dcgc]}|j|||}}tj|Dcgc]}|j |c}d{}|Scc}wcc}w7w)aUpload one or more files to UploadThing asynchronously. Args: files: Single file or list of files to upload (file-like objects) content_disposition: Content disposition header value ('inline' or 'attachment') acl: Access control list setting for uploaded files Returns: List[UploadResult]: List of upload results containing file information N)rlist_prepare_file_dataasynciogatherr4)r#r5r6r7r/ files_datar+resultss r) upload_fileszAsyncUTApi.upload_filesbs %&GE   # #D*=s C   CM Nid&&y1 N   O s'A;A/A; A4!A;(A9)A;keyskey_typecKt|tr|gn|}|dk(rdnd|i}|jdd|d{}tdi|S7w)a8Delete one or more files from UploadThing asynchronously. Args: keys: Single key or list of keys identifying files to delete key_type: Type of key provided ('file_key' or 'custom_id') Returns: DeleteFileResponse: Response containing deletion results r2fileKeys customIdsPOSTz/v6/deleteFilesNr)rstrr*r)r#r@rA keys_listrr's r) delete_fileszAsyncUTApi.delete_filess[)s3TF "j0Jk9 }}V->EE!+F++Fs7A A A limitoffsetczKi}|r||d<|r||d<|jdd|d{}tdi|S7w)a List files stored in UploadThing asynchronously. Args: limit: Maximum number of files to return offset: Number of files to skip for pagination Returns: ListFileResponse: Response containing list of files rIrJrEz /v6/listFilesNr)r*r)r#rIrJparamsr&s r) list_fileszAsyncUTApi.list_filessO #F7O %F8 vGG+(++Hs ';9;cXK|jddd{}tdi|S7w)zGet usage information for the UploadThing account asynchronously. Returns: UsageInfoResponse: Response containing usage statistics rEz/v6/getUsageInfoNr)r*r )r#r's r)get_usage_infozAsyncUTApi.get_usage_infos0 }}V-?@@ *6**As *(*)Ng>@)inlinez public-read)r2)NN)__name__ __module__ __qualname____doc__rFrfloatr*rr4rrr?rrHintrrMr rOrr)r r s ! ,,,Tk ,  ,  ,\ 4 L @$,' $x.(!4Z  l  @=G,$s)O,/2Tz, ,(>B,4Z,03d , ,*+&7+rWr )r;typingrrrupyloadthing.base_clientrupyloadthing.schemasrrrr upyloadthing.utilsr r rrWr)r\s.! . '`+`+rW