tPj$dZddlmZmZddlmZddlmZddlmZddl m Z ddl m Z ddl mZdd lmZGd d Zy ) z? Search Tool Registry for managing search tool configurations. )datetimetimezone)Final)verbose_proxy_logger) safe_dumps)call_with_db_reconnect_retry) PrismaClient)SearchToolsRepository) SearchToolceZdZdZdZedefdZdede fdZ de de fd Z de dede fd Z ede deefd Zde de ded zfd Zde de ded zfdZy )SearchToolRegistryzO Handles adding, removing, and getting search tools in DB + in memory. cy)N)selfs x/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/litellm/proxy/search_endpoints/search_tool_registry.py__init__zSearchToolRegistry.__init__s returnct|}d|vr|dr|dj|d<d|vr|dr|dj|d<|S)z Convert Prisma result to dict with datetime objects as ISO format strings. Args: prisma_obj: Prisma model instance Returns: Dict with datetime fields converted to ISO strings created_at updated_at)dict isoformat) prisma_objresults r_convert_prisma_to_dictz*SearchToolRegistry._convert_prisma_to_dictsaZ( 6 !f\&:#),#7#A#A#CF< 6 !f\&:#),#7#A#A#CF<  r search_tool prisma_clientc K |jd}tt|jdi}t|jdi}t|jj |||t jtjt jtjdd{}t|}|j|d<|jj|d<|jj|d <|S7Z#t$r)}tj d |td |d}~wwxYww) z Add a search tool to the database. Args: search_tool: Search tool configuration prisma_client: Prisma client instance Returns: Dict with created search tool data search_tool_namelitellm_paramssearch_tool_info)r r!r"rr)dataNsearch_tool_idrrz"Error adding search tool to DB: %sz Error adding search tool to DB: )getrrr tablecreaternowrutcr$rrr Exceptionr exception) rrrr r!r"created_search_toolsearch_tool_dictes radd_search_tool_to_dbz(SearchToolRegistry.add_search_tool_to_db/s> D&1oo6H&I )3DIY[]9^4_)`N+5kooFXZ\6]+^ 0E]/S/Y/Y/`/`(8&4(8"*,,x||"<"*,,x||"< 0a0* '+;&7 1D1S1S - .-@-K-K-U-U-W \ *-@-K-K-U-U-W \ *# #!*" D * *+OQR S>qcBC C Ds<ECD!DAD!ED!! E*$EEEr$cK t|jjd|id{}|std|dt|jj d|id{d|d|j dS7W7#t$r)}t jd |td |d}~wwxYww) z Delete a search tool from the database. Args: search_tool_id: ID of search tool to delete prisma_client: Prisma client instance Returns: Dict with success message r$whereNzSearch tool with ID z not foundz Search tool z deleted successfully)messager z&Error deleting search tool from DB: %sz$Error deleting search tool from DB: )r r& find_uniquer*deleter rr+)rr$r existing_toolr.s rdelete_search_tool_from_dbz-SearchToolRegistry.delete_search_tool_from_dbUs H)>})M)S)S)_)_'8*`*$M!"6~6Fj QRR( 6<<CCK[]kJlCm m m*.)99NO$1$B$B $ n  H * *+SUV WB1#FG G HsJB?*B B?B .B/B B?B B B<$B77B<<B?c K |jd}tt|jdi}t|jdi}t|jj d|i|||t jtjdd{}|j|S7#t$r)}tjd|td |d}~wwxYww) a, Update a search tool in the database. Args: search_tool_id: ID of search tool to update search_tool: Updated search tool configuration prisma_client: Prisma client instance Returns: Dict with updated search tool data r r!r"r$)r r!r"r)r2r#Nz$Error updating search tool in DB: %sz"Error updating search tool in DB: )r%rrr r&updaterr(rr)rr*rr+) rr$rrr r!r"updated_search_toolr.s rupdate_search_tool_in_dbz+SearchToolRegistry.update_search_tool_in_dbts F&1oo6H&I )3DIY[]9^4_)`N+5kooFXZ\6]+^ 0E]/S/Y/Y/`/`'8(8&4(8"*,,x||"< 0a0* //0CD D* F * *+QST U@DE E Fs;C2B!B=%B;&B=:C2;B== C/$C**C//C2c"K tfddd{}g}|D]1}tj|}|jt di|3|S7>#t $r)}t jd|t d|d}~wwxYww)z Get all search tools from the database. Args: prisma_client: Prisma client instance Returns: List of search tool configurations cRtjjddiS)Nrdesc)order)r r& find_many)rsrzASearchToolRegistry.get_all_search_tools_from_db..s,-m<BBLL'0Mr+get_all_search_tools_from_db_lookup_failure)reasonNz&Error getting search tools from DB: %sz$Error getting search tools from DB: r)rr rappendr r*rr+)rsearch_tools_from_db search_toolsrr-r.s` rget_all_search_tools_from_dbz/SearchToolRegistry.get_all_search_tools_from_dbs H0LE 1+ 57L3 D #5#M#Mk#Z ##J$B1A$BC D  + H * *+SUV WB1#FG G Hs8BAA=ABA B #$BB  BNcK t|jjd|id{}|sy|j|}t di|S7##t $r)}t jd|t d|d}~wwxYww)a Get a search tool by its ID from the database. Args: search_tool_id: ID of search tool to retrieve prisma_client: Prisma client instance Returns: Search tool configuration or None if not found r$r1N%Error getting search tool from DB: %s#Error getting search tool from DB: rr r&r4rr r*rr+)rr$rrr-r.s rget_search_tool_by_id_from_dbz0SearchToolRegistry.get_search_tool_by_id_from_dbs G'<]'K'Q'Q']']'8(^("K'+&B&B;&O 1 01 1" G * *+RTU VA!EF F GBB *AAAB AB A B$BBB r cK t|jjd|id{}|sy|j|}t di|S7##t $r)}t jd|t d|d}~wwxYww)a Get a search tool by its name from the database. Args: search_tool_name: Name of search tool to retrieve prisma_client: Prisma client instance Returns: Search tool configuration or None if not found r r1NrIrJrrK)rr rrr-r.s rget_search_tool_by_name_from_dbz2SearchToolRegistry.get_search_tool_by_name_from_dbs G'<]'K'Q'Q']'])+;<(^("K'+&B&B;&O 1 01 1" G * *+RTU VA!EF F GrM)__name__ __module__ __qualname____doc__r staticmethodrrr r r/strr7r;listrGrLrOrrrr r s t,$Dz$DR^$DLHsHS_H> FS Fz Fjv FDH#H j HH@G!G2>G d G8G #G4@G d Grr N)rSrrtypingrlitellm._loggingr*litellm.litellm_core_utils.safe_json_dumpsr"litellm.proxy.db.exception_handlerrlitellm.proxy.utilsr 'litellm.repositories.table_repositoriesr litellm.types.searchr r rrrr^s2(1AK,I+]G]Gr