o ưi @sVdZddlZddlZddlZddlmZddlmZmZddl m Z GdddZ dS)z Router utilities for Search API integration. Handles search tool selection, load balancing, and fallback logic for search requests. N)partial)AnyCallable)verbose_router_loggerc@speZdZdZededefddZedededefdd Z eded e fd d Z eded ede fddZ dS)SearchAPIRouterz Static utility class for routing search API calls through the LiteLLM router. Provides methods for search tool selection, load balancing, and fallback handling. router_instance search_toolsc szBddlm}tdt|dg}|D]}|d|d|di|dd }||q||_td t|d Wd St y[}z t d t ||d }~ww)aF Update the router with search tools from the database. This method is called by a cron job to sync search tools from DB to router. Args: router_instance: The Router instance to update search_tools: List of search tool configurations from the database r)SearchToolTypedDictzAdding z search tools to routersearch_tool_idsearch_tool_namelitellm_paramssearch_tool_info)r r r r z!Successfully updated router with z search tool(s)z)Error updating router with search tools: N) Zlitellm.types.routerr rdebuglengetappendrinfo Exception exceptionstr)rrr Zrouter_search_toolstoolZrouter_search_tooler]/home/app/Keep/.python/lib/python3.10/site-packages/litellm/router_utils/search_api_router.pyupdate_router_search_toolss.     z*SearchAPIRouter.update_router_search_toolsr returncs,fdd|jD}|stdd|S)av Get all search tools matching the given name. Args: router_instance: The Router instance search_tool_name: Name of the search tool to find Returns: List of matching search tool configurations Raises: ValueError: If no matching search tools are found csg|] }|dkr|qSr r.0rrrr Rs z=SearchAPIRouter.get_matching_search_tools..z Search tool 'z"' not found in router.search_tools)r ValueError)rr matching_toolsrrrget_matching_search_tools@s z)SearchAPIRouter.get_matching_search_toolsoriginal_functionc szL|d|d}|std||d<||d<ttj|d|d<|j||ddd d |jD}td |d |d ||j di|IdH}|WSt yn}zddl m }t |||t|d|d}~ww)a Helper function to make a search API call through the router with load balancing and fallbacks. Reuses the router's retry/fallback infrastructure. Args: router_instance: The Router instance original_function: The original litellm.asearch function **kwargs: Search parameters including search_tool_name, query, etc. Returns: SearchResponse from the search API r modelz:search_tool_name or model parameter is required for searchoriginal_generic_function)rr$Zlitellm_metadata)r%kwargsZmetadata_variable_namecSsg|]}|dqSrrrrrrr sz?SearchAPIRouter.async_search_with_fallbacks..zIInside SearchAPIRouter.async_search_with_fallbacks() - search_tool_name: z, Available Search Tools: z , kwargs: Nr)send_llm_exception_alert)Zlitellm_router_instanceZrequest_kwargsZerror_traceback_strZoriginal_exceptionr)rr!rr"async_search_with_fallbacks_helperZ_update_kwargs_before_fallbacksrrrZasync_function_with_fallbacksrZ!litellm.router_utils.handle_errorr(asyncio create_task traceback format_exc)rr$r'r Zavailable_search_tool_namesresponserr(rrrasync_search_with_fallbacks\sB  z+SearchAPIRouter.async_search_with_fallbacksr%r&c s|}zDtj||d}t|}|di}|d}|d} |d} |s/td|dtd||d || | d |Id H} | WStyb} zt d |d t | | d } ~ ww)a Helper function for search API calls - selects a search tool and calls the original function. Called by async_function_with_fallbacks for each retry attempt. Args: router_instance: The Router instance model: The search tool name (passed as model for compatibility) original_generic_function: The original litellm.asearch function **kwargs: Search parameters Returns: SearchResponse from the selected search provider )rr r search_providerapi_keyapi_basez=search_provider not found in litellm_params for search tool ''z$Selected search tool with provider: )r0r1r2Nz@Error in SearchAPIRouter.async_search_with_fallbacks_helper for z: r) rr#randomchoicerr!rrrerrorr) rr%r&r'r r"Z selected_toolr r0r1r2r.rrrrr)s@      z2SearchAPIRouter.async_search_with_fallbacks_helperN) __name__ __module__ __qualname____doc__ staticmethodrlistrrr#rr/r)rrrrrs4(  ;r) r:r*r4r, functoolsrtypingrrZlitellm._loggingrrrrrrs