~i&<ddlmZddlmZddlmZmZmZddlZddl Z ddl m Z ddl m Z mZddlmZmZmZdd lmZmZdd lmZdd lmZmZdd lmZdd lmZddlm Z m!Z!m"Z"m#Z#ddl$m%Z%m&Z&ddl'm(Z(ddl)m*Z*ddl+m,Z,ddl-m.Z.m/Z/ddl0m1Z1ddl2m3Z3ddl4m5Z5ddl6m7Z7ddl8m9Z9ddl:m;Z;ddgZ d3d4d(Z?Gd)deZ@Gd*deZAGd+d,ZBGd-d.ZCGd/d0ZDGd1d2ZEdS)5) annotations)Path)UnionIterableOptionalN)Literal)urlparse unquote_plus)BodyQueryHeaders)with_sts_tokenasync_with_sts_token)make_request_options)SyncAPIResourceAsyncAPIResource)cached_property) ArkAPIError)to_raw_response_wrapperasync_to_raw_response_wrapperto_streamed_response_wrapper"async_to_streamed_response_wrapper)Stream AsyncStream) ToolChoice)Response) ToolParam)ResponseInputParamResponseInputItemParam)ResponseInputContentParam)ResponseStreamEvent)ResponseTextConfigParam)ResponseCaching) Reasoning)Thinking ResponsesAsyncResponses image_url video_urlfile_url) input_image input_video input_filefile extra_headersHeaders | NonetoolsIterable[ToolParam] | Nonereturnrcv||S|D]}|dddkr |i}d|d<|dddkr |i}d|d<|dddkr |i}d|d <|ddd kr |i}d|d <|ddd kr |i}d|d <|S)Ntype web_searchtruezark-beta-web-searchmcpz ark-beta-mcpknowledge_searchzark-beta-knowledge-search doubao_appzark-beta-doubao-app image_processzark-beta-image-process)get)r1r3 tool_params ~/root/.openclaw/workspace/.venvs/ark-sdk/lib/python3.11/site-packages/volcenginesdkarkruntime/resources/responses/responses.py_add_beta_headersrB@s }== >>&" % % 5 5$ " 39M/ 0 >>&" % % . .$ " ,2M. ) >>&" % %); ; ;$ " 9?M5 6 >>&" % % 5 5$ " 39M/ 0 >>&" % % 8 8$ " 6dZedddddddddddddddddddddd?d0Zddddd1d@d5Zddddd1dAd7Z dBd9Z dCd<Z dS)Dr(r5AsyncResponsesWithRawResponsec t|SrG)rrHs rArJz AsyncResponses.with_raw_responses,T222rC#AsyncResponsesWithStreamingResponsec t|SrG)rrHs rArMz&AsyncResponses.with_streaming_responses24888rCNrNrarbrcrdrOrerPrfrQrgrRrSrhrTrUrirVrjrWrkrXrlrYrmr3r4rZr[r\r1r2r]rnr^ror_rpr`rq+Response | AsyncStream[ResponseStreamEvent]c bKt||}||d{V|did|d|d|d|d|d|d |d |d | d | d | d| d| d|d|d|d|d|it||||t| pdt t d{V}|S)N)rartrarcrOrPrQrRrSrTrUrVrWrXrYr3rZr[r\r`ruFrv)rB_prepare_responses_inputr{rrrr"r|s rAr~zAsyncResponses.creates6*-?? ++%+888888888ZZ  $%6  &':  '(< H7&{{ !.!"Y#$Y%()+'%  ?U"#67=         B rCrurrrc K|std||d|t||||tdtt d{VSrrrs rArzAsyncResponses.retrieve"s \[\\ YY '+ ' '(+'%  12         rCrc K|std|ddi|pi}|d|t||||tdd{VSrrrs rArzAsyncResponses.delete<s \[\\ "5B]-@bB \\ '+ ' '(+'%  JJ"         rCrcKg}|D]S}d|vr|d}t|ts%|D]+}|||,Tt j|d{VdS)Ncontent)r) isinstancelistappend_prepare_responses_input_fileasynciogather)rIratasks input_item content_listrs rArz'AsyncResponses._prepare_responses_inputUs R RJ **%i0LlD11 ' R R T???PPQQQQ Rne$$$$$$$$$$rCrr!c fKd|vrdS|d}|tvrdSt|}||vrdS||}t|}|jtkrdSt |j}|jr |j|}n|}t|}|j j |dd{V} |j j | j d{V} | jdkr#td|d| j d| jd d||<| j |d <dS) Nr7 user_data)r/purpose)idactivez File path: z,id: z processing failed with status .file_id)&RESPONSES_MULTIMODAL_CONTENT_DATA_KEYSkeysr schemeFILE_PATH_SCHEMEr pathnetlocr_clientfilesr~wait_for_processingrstatusr) rIr content_typecontent_data_key content_dataparsed decoded_path full_path file_pathr/s rArz,AsyncResponses._prepare_responses_input_fileds  Fv  F K K M M M M FA,O 7 * * F#$45 ,'' =, , , F$FK00 = %"=8,88II$IOO \'..I{.SSSSSSSS\';;tw;GGGGGGGG ;( " "didddgddVZVaddd  %) !!W rC)r5r)r5r).rarbrcrdrOrerPrfrQrgrRrerSrhrTrgrUrirVrjrWrkrXrlrYrmr3r4rZrkr[rfr\rfr1r2r]rnr^ror_rpr`rqr5rrr)rar)rr!) rrrrrJrMrr~rrrrr0rCrAr(r(s<333_3999_9 .2265959.2'+48BF.2/3)-,0(,/3*.(,$("&7;041>>>>>>H)-$("&04      <)-$("&04      2 % % % %%%%%%%%%%%%%rCceZdZddZdS)rE responsesr'r5rcF||_t|j|_dSrG) _responsesrr~rIrs rA__init__z!ResponsesWithRawResponse.__init__s$#-     rCNrr'r5rrrrrr0rCrArErE(      rCrEceZdZddZdS)rrr(r5rcF||_t|j|_dSrG)rrr~rs rArz&AsyncResponsesWithRawResponse.__init__s$#3     rCNrr(r5rrr0rCrArrrrCrceZdZddZdS)rKrr'r5rcF||_t|j|_dSrG)rrr~rs rArz'ResponsesWithStreamingResponse.__init__s$#2     rCNrrr0rCrArKrKrrCrKceZdZddZdS)rrr(r5rcF||_t|j|_dSrG)rrr~rs rArz,AsyncResponsesWithStreamingResponse.__init__s$#8     rCNrrr0rCrArrrrCr)Nr0)r1r2r3r4r5r)F __future__rpathlibrtypingrrrhttpxrtyping_extensionsr urllib.parser r _typesr r r _utils._utilsrr _base_clientr _resourcerr_compatr _exceptionsr _responserrrr _streamingrr&types.responses.response_create_paramsrtypes.responses.responsertypes.responses.tool_paramr$types.responses.response_input_paramrr 9types.responses.response_input_message_content_list_paramr!%types.responses.response_stream_eventr"*types.responses.response_text_config_paramr#&types.responses.response_caching_paramr$types.shared_paramsr%4volcenginesdkarkruntime.types.shared_params.thinkingr&__all__rrrBr'r(rErrKrr0rCrArs#"""""  %%%%%%////////**********AAAAAAAA000000::::::::&&&&&&&&&&&& .-------@@@@@@000000333333IHHHHHQQQQQQEEEEEE,,,,,,IIIIII ( )**& OQ:x x x x x x x x vq%q%q%q%q%%q%q%q%h                                  rC