Ki'<&dZddlZddlmZmZddlmZmZddlm Z m Z ddl m Z m Z ddlmZddlmZmZmZmZmZmZmZmZmZmZ dd lmZmZmZdd lm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(dd l)m*Z*dd l+m,Z,GddZ/y#e-$rZ.e-d e.dZ.[.wwxYw)z$OpenAI sampling handler for FastMCP.N)IteratorSequence)Anyget_args) ClientSession ServerSession)LifespanContextTRequestContext)CreateMessageRequestParams) CreateMessageResultCreateMessageResultWithToolsModelPreferencesSamplingMessage StopReason TextContentTool ToolChoiceToolResultContentToolUseContent) NOT_GIVEN AsyncOpenAINotGiven) ChatCompletion#ChatCompletionAssistantMessageParamChatCompletionMessageParam"ChatCompletionMessageToolCallParam ChatCompletionSystemMessageParam#ChatCompletionToolChoiceOptionParamChatCompletionToolMessageParamChatCompletionToolParamChatCompletionUserMessageParam) ChatModel)FunctionDefinitionzvThe `openai` package is not installed. Please install `fastmcp[openai]` or add `openai` to your dependencies manually.c peZdZdZ ddededzddfdZdeede d e e e fe e e fzdeezfd Zed eezeezdzdeefd Zed edzdeedeefdZededefdZd eezeezdzdefdZedeedeefdZedede fdZ!ededefdZ"y)OpenAISamplingHandlerz*Sampling handler that uses the OpenAI API.N default_modelclientreturnc8|xs t|_||_yN)rr'r&)selfr&r's s/home/jay/workspace/scripts/.codegraph-venv/lib/python3.12/site-packages/fastmcp/client/sampling/handlers/openai.py__init__zOpenAISamplingHandler.__init__0s $*#:[] (5messagesparamscontextc K|j|j|}|j|j}t}|j r|j |j }t}|jr|j|j}|jjjj|||j |jnt|j|jr |jnt||d{}|j r|j!|S|j#|S72w)N) system_promptr/)modelr/ temperature max_tokensstoptools tool_choice)_convert_to_openai_messages systemPrompt_select_model_from_preferencesmodelPreferencesrr8_convert_tools_to_openai toolChoice_convert_tool_choice_to_openair'chat completionscreater5 maxTokens stopSequences%_chat_completion_to_result_with_tools)_chat_completion_to_create_message_result) r+r/r0r1openai_messagesr4 openai_toolsopenai_tool_choiceresponses r,__call__zOpenAISamplingHandler.__call__8s*  , ,$11! -   >>v?V?VWBK <<88FLNW   !%!D!DVEVEV!W ))55<<$&,&8&8&D"")'')/)=)=%%9*=    <<==hG G==hGG  sDEE3Emodel_preferencesc# K|yt|tr|ttvr|yt|tr |Ed{yt|t r*|j x}sy|D]}|jx}s|yy7@wr*) isinstancestrrr"listrhintsname)rMrRhintrSs r,_iter_models_from_preferencesz3OpenAISamplingHandler._iter_models_from_preferencescs  $  ' -2Cx H 3 $ # )4 0( ( ( )+; <.444E4  $ ))   = )s?BBABr3cVg}|r|jtd||D]}|j}t|trg}g}g}|D]'}t|t rR|jt |jd|jtj|jdft|tr|j|jt|tsd} |jrPg} |jD].} t| ts| j| j0dj| } |jt!d|j"| *|s|r|rdj|nd} |r/|jt%d | | |j'|n^| r\|j(d k(r|jt+d | n0|jt%d | n|r|j'|t|t r_|jt%d t |jd|jtj|jdg mt|trg} |jr=|jD].}t|ts| j|j0|jt!d|j"dj|  t|tr^|j(d k(r'|jt+d |jn&|jt%d |jnt-dt/||S)Nsystem)rolecontentfunction)rS arguments)idtyperZ tool)rX tool_call_idrY assistant)rXrY tool_callsuser)rXrczUnsupported content type: )appendrrYrOrQrrr\rSjsondumpsinputrtextrjoinr toolUseIdrextendrXr! ValueErrorr]) r3r/rHmessagerYrc text_parts tool_messagesitem content_text result_textssub_item msg_contents r,r:z1OpenAISamplingHandler._convert_to_openai_messages|sY=?   " "0!)  B KGooG'4(GI (* FH #D!$7"))>#'77%/,0II15DJJ1G*" $D+6"))$))4#D*;<') <<+-L,0LLG#-h #D$0$7$7 $FG,099\+BL%,,:%+-1^^(4/B;E$))J"74K!'..?%0(3+5(..}=$"<<61+22 >)/,7!",22 C)4,7!" ##**=9'>2&&7(>#*::%/,3LL15GMM1J*" $ '#45*, ?? ';%dK8(// :; &&2#%,%6%6 $ , 7';/<<6)#**6!'$+LL$**;!,$+LL 9$w-IJ JEB KHr.chat_completionct|jdk(r td|jd}|jjx}r#t t d|d|jStd)NrNo response for completionrir]rirb)rYrXr4&No content in response from completion)lenchoicesrmrnrYr rr4)rv first_choicerYs r,rGz?OpenAISamplingHandler._chat_completion_to_create_message_results{ && '1 ,9: :&..q1 "**22 27 2&#g> %++  ABBr.ct|j|D]}|ttvs|}|cS|jSr*)rUrr"r&)r+rM model_option chosen_models r,r<z4OpenAISamplingHandler._select_model_from_preferences"sE!>>?PQ $Lx 22*6 ## $ !!!r.r8c g}|D]`}t|j}d|vrd|d<|jtdt |j |j xsd|b|S)z(Convert MCP tools to OpenAI tool format.r]objectrZr^)rS description parameters)r]rZ)dict inputSchemarer r#rSr)r8rIr`rs r,r>z.OpenAISamplingHandler._convert_tools_to_openai,s{79  D)-d.>.>)?JZ'%- 6"   '#/!YY$($4$4$:#-    r.r9c|jdk(ry|jdk(ry|jdk(rytd|j)z)Convert MCP tool_choice to OpenAI format.autorequirednonezUnsupported tool_choice mode: )moderm)r9s r,r@z4OpenAISamplingHandler._convert_tool_choice_to_openaiBsQ   v %    +    '=k>N>N=QRS Sr.c 4t|jdk(r td|jd}|j}|jdk(rd}n&|jdk(rd}n|jdk(rd}nd}g}|j r&|j td |j |jr||jD]m}t|d s|j} tj|j}|j t!d|j"|j|o|s tdt%|d|j&|S#tj$r+}td |jd |j|d}~wwxYw)z8Convert OpenAI response to CreateMessageResultWithTools.rrxrctoolUser7endTurnlengthrDriryrZz$Invalid JSON in tool arguments for 'z': Ntool_use)r]r\rSrhrzrb)rYrXr4 stopReason)r{r|rmrn finish_reasonrYrerrchasattrrZrfloadsr[JSONDecodeErrorrSrr\r r4) rvr}rn stop_reasonrY tool_callfuncr[es r,rFz;OpenAISamplingHandler._chat_completion_to_result_with_toolsPs && '1 ,9: :&..q1 &&  % % 5#K  ' '6 1#K  ' '8 3%K#K79 ?? NN;FI J   $//  y*5 )) $ 4>> :I"'$<<!YY'  0EF F+!''"   '++$ II;c$..)9;s EF,&FFr*)#__name__ __module__ __qualname____doc__r"rr-rQrSamplingParamsr rr rr r rL staticmethodrrPrrUrrr:rrGr<rr r>rrr@rFr.r,r%r%-s4 &*6 6d"6  6)H')H)H /? ?@ (88 9: )H ; ; )HV+c1DI=D #0QTzQ-5o-FQ ( )QQfC'C CC""!1C!7$s)!Cd!J" "T t '> %> > r.r%)0rrfcollections.abcrrtypingrrmcprrmcp.shared.contextr r mcp.typesr rr r rrrrrrrropenairrropenai.types.chatrrrrrrrr r!openai.types.shared.chat_modelr"openai.types.shared_paramsr# ImportErrorrr%rr.r,rs* . ,?B    77   9=b b   Z    s,A==B B  B