6iMdZddlmZddlZddlmZddlmZmZddl m Z ddl m Z m Z dd lmZdd lmZdd lmZmZdd lmZd!d Zd"dZd#dZ d$ d%dZ d$ d%dZ d$ d%dZ d$ d%dZ d&dZ d'dZ d'dZ d'dZ! d'dZ" d'dZ# d'dZ$ d(dZ% d&dZ&ejNee!dejPee dejReedejTeddejVeddejXed dejZee$dej\eedej^ee"dej`ee#dejbee&di Z2y))zOpenAI-specific utilities. This module contains utilities specific to the OpenAI provider, including reask functions, response handlers, and message formatting. ) annotationsN)dedent)Anycastpydantic_function_tool) ParallelModelhandle_parallel_model)ConfigurationError)Mode) dump_messagemerge_consecutive_messagesgenerate_openai_schemac(|duxs t|d S)zCheck if response is a Stream object rather than a ChatCompletion. Stream objects don't have 'choices' attribute and can't be used for detailed reask messages that reference the response content. Nchoices)hasattr)responses l/root/.openclaw/workspace/visionaryfx/venv/lib/python3.12/site-packages/instructor/providers/openai/utils.py_is_stream_responsers t  ?78Y#???cg}|D]F}t|dd}|dvr|j|&|)t|ds6|j|H|S)z7Return response output items that represent tool calls.typeN> tool_call function_call arguments)getattrappendr) output_items tool_callsitem item_types r_filter_responses_tool_callsr$scJ$D&$/ 6 6   d #   {!;   d # $ rct|dd}t|ddxst|ddxs t|dd}g}|r|jd||r|jd||syd d j|d S) z4Format tool call name/id details for reask messages.nameNidcall_id tool_call_idzname=zid=z (tool call z, ))rrjoin)r tool_nametool_iddetailss r#_format_responses_tool_call_detailsr0,s 640I 4& 4 9i . 4 9nd 3 Gyk*+WI'  $))G,-Q //rc |j}t|r|djdd|dd|St|jdj g}|jdj j D]:}|jd|j|jjd|dd<|dj||S) z Handle reask for OpenAI tools mode when validation fails. Kwargs modifications: - Adds: "messages" (tool response messages indicating validation errors) messagesuserValidation Error found: . Recall the function correctly, fix the errorsrolecontentrtool)r7r)r&r8) copyrrrrmessager!r'functionr&extend)kwargsr exceptionfailed_attempts reask_msgsrs r reask_toolsrB>s[[]F8$z!!/ {;DD   x//2::;|j}| t|ds|djdd|dd|Sg}t|jD]3}t |}|jdd|d|j |d5|dj||S)z Handle reask for OpenAI responses tools mode when validation fails. Kwargs modifications: - Adds: "messages" (user messages with validation errors) outputr2r3r4r5r6z4 Recall the function correctly, fix the errors with )r:rrr$rDr0rr=)r>rr?r@reask_messagesrr/s rreask_responses_toolsrFjs[[]Fwx:z!!/ {;DD   N1(//B  5i@/ {;J **+G96     :n- Mrc|j}t|r|djdd|d|St|jdj g}|jdd|d|dj ||S)z Handle reask for OpenAI JSON modes when validation fails. Kwargs modifications: - Adds: "messages" (user message requesting JSON correction) r2r3z@Correct your JSON ONLY RESPONSE, based on the following errors: r6rr:rrrrr;r=r>rr?r@rAs r reask_md_jsonrJs[[]F8$z!!^_h^ij   x//2::;#J : %%rch|d|fSt|}d|dd<|g|d<dd|ddid|d<||fS) a  Handle OpenAI strict tools mode. Kwargs modifications: - When response_model is None: No modifications - When response_model is provided: - Adds: "tools" (list with strict function schema) - Adds: "tool_choice" (forced function call) NTr<strictrOr&rr<rQr)rUrVresponse_model_schemas rhandle_tools_strictr`'slZ2>B26*%h/01Jw2:>vFG!J} : %%rcf|d|fSdt|dg|d<ddt|did|d<||fS)z Handle OpenAI tools mode. Kwargs modifications: - When response_model is None: No modifications - When response_model is provided: - Adds: "tools" (list with function schema) - Adds: "tool_choice" (forced function call) Nr<r^rOr&rQrrTs r handle_toolsrb@sdZ.~> Jw3NCFKL!J} : %%rcF|jd|jd|d<|d|fSt|}|dd=d|dd|ddd}d |dvr |dd |d <nd |jd |d <d|dd|dddg|d <dt |dd |d<||fS)aF Handle OpenAI responses tools mode. Kwargs modifications: - When response_model is None: No modifications - When response_model is provided: - Adds: "tools" (list with function schema) - Adds: "tool_choice" (forced function call) - Adds: "max_output_tokens" (converted from max_tokens) max_tokensNmax_output_tokensr<r]r& parametersrr&rf descriptionCorrectly extracted `5` with all the required parameters with correct typesrOrr&rQ)rSpopr__name__rrUrVschematool_definitions rhandle_responses_toolsrq\s~~l#/*4..*F &'Z #N 3Fz8$z"6*Z(6O z**)/ );M)J &$N$;$;#<=9 :  &:&v. ,\: Jw&~6v>!J} : %%rcx|jd|jd|d<|d|fSt|}|dd=d|dd|ddd}d |dvr |dd |d <nd |jd |d <|jd s|g|d <dt |dd |d<||fS|d j |||fS)aY Handle OpenAI responses tools with inbuilt tools mode. Kwargs modifications: - When response_model is None: No modifications - When response_model is provided: - Adds: "tools" (list with function schema) - Adds: "tool_choice" (forced function call) - Adds: "max_output_tokens" (converted from max_tokens) rdNrer<r]r&rfrgrhrirjrOrkrQ)rSrlrrmrrrns r)handle_responses_tools_with_inbuilt_toolsrss"~~l#/*4..*F &'Z #N 3Fz8$z"6*Z(6O z**)/ );M)J &$N$;$;#<=9 :  & >>' "./ 7*>:6B% =! : %% 7""?3 : %%rc|jdgDcgc]}|d }}d|vr td|d|fStdtj|j dd d }|dj d |d ||fScc}w) a Handle OpenAI o1 JSON mode. Kwargs modifications: - When response_model is None: No modifications - When response_model is provided: - Modifies: "messages" (appends user message with JSON schema) - Validates: No system messages allowed for O1 models r2r7systemz3System messages are not supported For the O1 modelsNz Understand the content and provide the parsed objects in json that match the following json_schema: Findent ensure_asciiU Make sure to return an instance of the JSON, not the schema itself r3r6)rS ValueErrorrjsondumpsmodel_json_schemar)rUrVr;roless rhandle_json_o1rs-7NN:r,J KWV_ KE K5NOOZ  N446qu UVW   Gz!!  : %%1 Ls Bc|d|fStdtj|jddd}|tj k(rddi|d <nr|tj k(r$d |j|jd d |d <n;|tjk(r(|d jdddt|d |d <|tj k7r|d dddk7r|d jdd|d||fSt|d ddtr|d ddxxd|z cc<||fSt|d ddtr |d ddddxxd|z cc<||fStd||fS)a Handle OpenAI JSON modes (JSON, MD_JSON, JSON_SCHEMA). Kwargs modifications: - When response_model is None: No modifications - When response_model is provided: - Mode.JSON_SCHEMA: Adds "response_format" with json_schema - Mode.JSON: Adds "response_format" with type="json_object", modifies system message - Mode.MD_JSON: Appends user message for markdown JSON response Nz As a genius expert, your task is to understand the content and provide the parsed objects in json that match the following json_schema: rvFrwrzr json_objectresponse_format json_schema)r&rorrr2r3zPReturn the correct JSON response within a ```json codeblock. not the JSON_SCHEMAr6rr7rur8z textz>Invalid message format, must be a string or a list of messages)rr|r}r~r JSON JSON_SCHEMArmMD_JSONrrinsert isinstancestrlistr{)rUrVmoder;s rhandle_json_modesrsZ  N446qu UVW   G tyy)/(? $% !! !!&//(::<) $%  :%%m  "rTs#4RTYY#Grc8t||tjSr)rr rrs rrrXs#4RT\\#Jrc8t||tjSr)rr rrs rrr\s#4RT=M=M#Nr)rrreturnbool)r list[Any]rr)rrrrr)r>dict[str, Any]rrr? Exceptionr@zlist[Any] | None)rUz type[Any]rVrrz tuple[type[Any], dict[str, Any]])rUtype[Any] | NonerVrr'tuple[type[Any] | None, dict[str, Any]])rUrrVrrr rr)3__doc__ __future__rr|textwraprtypingrropenair dsl.parallelr r core.exceptionsr rr utils.corerrprocessing.schemarrr$r0rBrFrJrLrWr[r`rbrqrsrrrTOOLS TOOLS_STRICT FUNCTIONSrrrJSON_O1PARALLEL_TOOLSRESPONSES_TOOLS"RESPONSES_TOOLS_WITH_INBUILT_TOOLSOPENROUTER_STRUCTURED_OUTPUTSOPENAI_HANDLERSrrrs # )@1B7@ 0,)- ) )))& )`)- * ***& *b)- ! !!!& !P)- % %%%& %R(O(O+9(O%(OV&$&2@&,&0&$&2@&,&2&$&2@&,&83&$3&2@3&,3&l/&$/&2@/&,/&d$&$$&2@$&,$&N@&$@&2@@&HL@&,@&F&&+9&%&0 JJ  ' NN$ IIG LLJ N LL" ) &* ++&=. &&8)S-r