~iRddlmZddlZddlZddlmZmZddlmZddl Z ddl m Z ddl m Z mZmZmZddlmZmZmZmZdd lmZmZmZmZdd lmZdd lmZmZdd l m!Z!m"Z"dd l#m$Z$m%Z%ddl&m'Z'm(Z(ddl)m*Z*ddl+m,Z,ddgZ-GddeZ.GddeZ/GddZ0GddZ1GddZ2GddZ3dS)) annotationsN)Mappingcast)Literal)_legacy_response) FilePurposePreprocessConfigsfile_list_paramsfile_create_params)BodyQueryHeaders FileTypes) extract_filesmaybe_transformdeepcopy_minimalasync_maybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)to_streamed_response_wrapper"async_to_streamed_response_wrapper)SyncCursorPageAsyncCursorPage)AsyncPaginatormake_request_options) FileObject) FileDeletedFiles AsyncFilesc eZdZed2dZed3dZdddddddd4dZdddddd5dZdddddddddd6d'Zdddddd7d)Z d*d+d,d8d1Z dS)9r returnFilesWithRawResponsec t|S)a This property can be used as a prefix for any HTTP method call to return the raw response object instead of the parsed content. For more information, see https://www.github.com/openai/openai-python#accessing-raw-response-data-eg-headers )r$selfs p/root/.openclaw/workspace/.venvs/ark-sdk/lib/python3.11/site-packages/volcenginesdkarkruntime/resources/files.pywith_raw_responsezFiles.with_raw_response,s$D)))FilesWithStreamingResponsec t|S)z An alternative to `.with_raw_response` that doesn't eagerly read the response body. For more information, see https://www.github.com/openai/openai-python#with_streaming_response )r+r&s r(with_streaming_responsezFiles.with_streaming_response6s*$///r*N expire_atpreprocess_configs extra_headers extra_query extra_bodytimeoutfilerpurposer r/datetime.datetime | int | Noner0PreprocessConfigs | Noner1Headers | Noner2 Query | Noner3 Body | Noner4float | httpx.Timeout | Nonerc :t||||d} ttttt f| dgg} ddi|pi}|dt| tj | t||||tS) aUpload a file that can be used across various endpoints. Individual files can be up to 512 MB. Args: file: The File object (not file name) to be uploaded. purpose: The intended purpose of the uploaded file. Only `user_data` is supported. expire_at: The expiration time for a file in Unix timestamp format. By default, files expires after 7 days. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds r5r6r/r0r5paths Content-Typemultipart/form-data/filesr1r2r3r4bodyfilesoptionscast_to) rrrrstrobject_postrr FileCreateParamsrr r'r5r6r/r0r1r2r3r4rFrGs r(createz Files.create?sB "&&8     d73;#7>>xjQQQ()>X=CVTVX zz  '9'JKK(+'%     r*rDfile_idrJc |std||d|t||||tS)a Returns information about a specific file. Args: file_id: The ID of the file to use for this request. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds 6Expected a non-empty value for `file_id` but received /files/rDrHrI ValueError_getrrr'rPr1r2r3r4s r(retrievezFiles.retrievezst2 TTT yy g  (+'%     r*afterlimitorderr6r1r2r3r4r[ str | Noner\ int | Noner]Literal['asc', 'desc'] | NoneFilePurpose | NoneSyncCursorPage[FileObject]c|dttt||||t ||||dt jtS)aReturns a list of files. Args: after: A cursor for use in pagination. `after` is an object ID that defines your place in the list. For instance, if you make a list request and receive 100 objects, ending with obj_foo, your subsequent call can include after=obj_foo in order to fetch the next page of the list. limit: A limit on the number of objects to be returned. Limit can range between 1 and 1000, and the default is 100 order: Sort order by the `created_at` timestamp of the objects. `asc` for ascending order and `desc` for descending order. purpose: Only return files with the given purpose. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds rCr[r\r]r6r1r2r3r4querypagerHmodel) _get_api_listrrrrr FileListParams r'r[r\r]r6r1r2r3r4s r(listz Files.lists{P!!  +(+'%%!&!&!&#*  %3 %"   r*rc |std||d|t||||tS)a Delete a file and remove it from all vector stores. Args: file_id: The ID of the file to use for this request. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds rRrSrDrTrV_deleterrrXs r(deletez Files.deletest2 TTT || g  (+'%      r*@X poll_intervalmax_wait_secondsidrufloatrvc6ddh}tj}||}|j|vrc||||}tj|z |krt d|d|d|j|vc|S)EWaits for the given file to be processed, default timeout is 10 mins.activefailedGiving up on waiting for file  to finish processing after seconds.timerYstatus_sleep RuntimeErrorr'rwrurvTERMINAL_STATESstartr5s r(wait_for_processingzFiles.wait_for_processings$X. }}R  k00 KK & & &==$$Dy{{U"%555"pRppUeppp k00 r*)r#r$)r#r+)r5rr6r r/r7r0r8r1r9r2r:r3r;r4r<r#r rPrJr1r9r2r:r3r;r4r<r#r)r[r^r\r_r]r`r6rar1r9r2r:r3r;r4r<r#rb rPrJr1r9r2r:r3r;r4r<r#rrwrJrurxrvrxr#r __name__ __module__ __qualname__rr)r-rOrYrmrqrr*r(r r +sB***_*000_0597;)-$("&049 9 9 9 9 9 B)-$("&04& & & & & & V! /3&*)-$("&04; ; ; ; ; ; F)-$("&04& & & & & & X #") r*c eZdZed1dZed2dZdddddddd3dZdddddd4dZdddddddddd5d&Zdddddd6d(Z d)d*d+d7d0Z dS)8r!r#AsyncFilesWithRawResponsec t|S)z This property can be used as a prefix for any HTTP method call to return the raw response object instead of the parsed content. )rr&s r(r)zAsyncFiles.with_raw_response s )...r*AsyncFilesWithStreamingResponsec t|S)ze An alternative to `.with_raw_response` that doesn't eagerly read the response body. )rr&s r(r-z"AsyncFiles.with_streaming_response(s /t444r*Nr.r5rr6r r/r_r0r8r1r9r2r:r3r;r4r<rc VKt||||d} ttttt f| dgg} ddi|pi}|dt| tj d{V| t||||t d{VS) aUpload a file that can be used across various endpoints. Individual files can be up to 512 MB. Args: file: The File object (not file name) to be uploaded. purpose: The intended purpose of the uploaded file. expire_at: The Unix timestamp in seconds after which the file will be deleted. Defaults to 7 days. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds r>r5r?rArBrCNrDrE) rrrrrJrKrLrr rMrrrNs r(rOzAsyncFiles.create/sB "&&8     d73;#7>>xjQQQ()>X=CVTVX ZZ ,T3E3VWWWWWWWW(+'%           r*rDrPrJc K|std||d|t||||td{VS)a^ Returns information about a specific file. Args: extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds rRrSrDrTNrUrXs r(rYzAsyncFiles.retrievejs. TTT YY g  (+'%           r*rZr[r^r\r]r`ra7AsyncPaginator[FileObject, AsyncCursorPage[FileObject]]c|dttt||||t ||||dt jtS)aReturns a list of files. Args: after: A cursor for use in pagination. `after` is an object ID that defines your place in the list. For instance, if you make a list request and receive 100 objects, ending with obj_foo, your subsequent call can include after=obj_foo in order to fetch the next page of the list. limit: A limit on the number of objects to be returned. Limit can range between 1 and 10,000, and the default is 10,000. order: Sort order by the `created_at` timestamp of the objects. `asc` for ascending order and `desc` for descending order. purpose: Only return files with the given purpose. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds rCrdrerg)rjrrrrr rkrls r(rmzAsyncFiles.lists{P!!  ,(+'%%!&!&!&#*  %3 %"   r*rc K|std||d|t||||td{VS)ag Delete a file and remove it from all vector stores. Args: extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds rRrSrDrTNrorXs r(rqzAsyncFiles.deletes. TTT \\ g  (+'%   "         r*rrrsrtrwrurxrvc^Kddh}tj}||d{V}|j|vro||d{V||d{V}tj|z |krt d|d|d|j|vo|S)rzr{r|Nr}r~rrrs r(rzAsyncFiles.wait_for_processings$X. ]]2&&&&&&&&k00++m,, , , , , , , ,r********Dy{{U"%555"pRppUeppp k00 r*)r#r)r#r)r5rr6r r/r_r0r8r1r9r2r:r3r;r4r<r#rr)r[r^r\r_r]r`r6rar1r9r2r:r3r;r4r<r#rrrrrr*r(r!r!sB///_/555_5!%7;)-$("&049 9 9 9 9 9 B)-$("&04$ $ $ $ $ $ R! /3&*)-$("&04; ; ; ; ; ; F)-$("&04$ $ $ $ $ $ T #") r*ceZdZddZdS)r$rGr r#Nonec||_tj|j|_tj|j|_tj|j|_tj|j|_dSN)_filesrto_raw_response_wrapperrOrYrmrqr'rGs r(__init__zFilesWithRawResponse.__init__ sw &> L   )@ N   %< J   '> L   r*NrGr r#rrrrrrr*r(r$r$ (      r*r$ceZdZddZdS)rrGr!r#rc||_tj|j|_tj|j|_tj|j|_tj|j|_dSr)rrasync_to_raw_response_wrapperrOrYrmrqrs r(rz"AsyncFilesWithRawResponse.__init__sw &D L   )F N   %B J   'D L   r*NrGr!r#rrrr*r(rrrr*rceZdZddZdS)r+rGr r#rc||_t|j|_t|j|_t|j|_t|j|_dSr)rrrOrYrmrqrs r(rz#FilesWithStreamingResponse.__init__0sk 2 L   5 N   1 J   3 L   r*Nrrrr*r(r+r+/rr*r+ceZdZddZdS)rrGr!r#rc||_t|j|_t|j|_t|j|_t|j|_dSr)rrrOrYrmrqrs r(rz(AsyncFilesWithStreamingResponse.__init__Bsk 8 L   ; N   7 J   9 L   r*Nrrrr*r(rrArr*r)4 __future__rdatetimertypingrrtyping_extensionsrhttpxrtypesr r r r _typesr rrr_utilsrrrr_compatr _resourcerr _responserr paginationrr _base_clientrrtypes.file_objectrtypes.file_deletedr__all__r r!r$rr+rrr*r(rs#""""" %%%%%% XXXXXXXXXXXX444444444444 &%%%%%9999999998888888????????******,,,,,, L !qqqqqOqqqhiiiii!iiiX        $        $        $          r*