Yash030/claude-code-proxy
2
1+
2 �E jM � �� � R t ^ RIHt ^ RIt^ RIHt ^ RIHtHt ^ RIH t ^ RI3H t ^ RI H
t
HtHtHtHt ^ RIHt ^R IHt ^R4IHt ^R IHtHt ^R IH t H t H t R
R lt RR/R R llt R# )zCSSE streaming for local web_search / web_fetch server tool results.)� annotationsN)�
AsyncIterator)�UTC�datetime)�Any)�MessagesRequest)�SERVER_TOOL_USE�WEB_FETCH_TOOL_ERROR�WEB_FETCH_TOOL_RESULT�WEB_SEARCH_TOOL_RESULT� WEB_SEARCH_TOOL_RESULT_ERROR)�format_sse_event)�_MAX_FETCH_CHARS)�WebFetchEgressPolicy)�
extract_query� extract_url)�forced_server_tool_name�forced_tool_turn_text�has_tool_namedc �$ � V ^8� d QhRRRRRR/# )� �query�str�resultszlist[dict[str, str]]�return� )�formats "�?C:\Users\yashw\.claude\temp-hf-clone\api\web_tools\streaming.py� __annotate__r s" � � � �3� �)=� �#� � c �� � V' g R V 2# RV 2.p\ V^R7 F, w r4VP V RVR, RVR, 24 K. RP V4 # )z!No web search results found for: zSearch results for: )�startz. �title�5�urlz6 7)� enumerate�append�join)r r �lines�index�results && r �_search_summaryr+ si � � �2�5�'�:�:�#�E�7�
+� ,�E�"�7�!�4�
��
� � ��w�b��� � 1��F�5�M�?�C�D� 5� �;�;�u� � r �verbose_client_errorsFc 8 �, � V ^8� d QhRRRRRRRRR R9/# ) r �requestr � input_tokens�int�web_fetch_egressr r, �boolr zAsyncIterator[str]r )r s "r r r ' sH � � gE� gE�
�gE��gE� +� gE�10 � gE� �
gEr c �� " � ^RI Hp \ V 4 pVe \ W4 ' g R# \ V 4 pR\11 P ! 4 2pR\12 P ! 4 P 2pVR8X d RMRp VR8X d R\ V4 /M R \ V4 /p13R\ R14\ /p R\ R15\ /p \ R R R R
RVR R
RRR. RV P RRRRRRVR^///4 5x � \ RR RR^ RR \ RVRVR V16//4 5x � \ R R R R^ /4 5x � VR8X dc \# V17R, 4 p
VP% V
4 G Rj x�L18 pV Uu. uF pR R R VR , R VR , /NK pp\' W�4 p\ pM�VP) \# V19R , 4 V4 G Rj x�L20 pR R R VR , RR R!R"R R#R$VR$, R%VR%, /R VR , R&R'R(//R)\* P, ! \. 4 P1 4 /pVR%, R\2 p\ p \; ^\= V4 ^, 4 p\ RR RR^RR VR.VRV//4 5x � \ R R R R^/4 5x � \ RR RR^RR R#R#R///4 5x � \ R0R R0R^R1R R2R#V//4 5x � \ R R R R^/4 5x � \ R3R R3R1RR4RR/RRVRVR5V ^///4 5x � \ R6R R6/4 5x � R# EL�u upi ELC \4 dc pTR218X d \# T22R , 4 MRpTP7 TTTR*7 Y�, pR Y�, R+R,/pTP9 TTTR-7 p Rp?EL6Rp?ii ; i5i)7u� Stream a minimal Anthropic-shaped turn for forced `web_search` / `web_fetch` (local fallback).23 24When `ENABLE_WEB_SERVER_TOOLS` is on, this is a proxy-side execution path — not a full25hosted Anthropic citation or encrypted-content pipeline.26)�outboundN�msg_� srvtoolu_�27web_search�web_search_requests�web_fetch_requestsr r$ � web_fetch�
message_start�type�message�id�role� assistant�content�model� stop_reason�
stop_sequence�usager/ �
output_tokens�content_block_startr) �
content_block�name�input�content_block_stop�web_search_resultr" �web_fetch_result�document�source�text�28media_type�data� citations�enabledT� retrieved_at)� fetch_url�29error_code� unavailable)�verbose� tool_use_id� �content_block_delta�delta�30text_delta�
message_delta�end_turn�server_tool_use� message_stop) r[ r4 r r r �uuid�uuid4�hexr r r r31 r r r
rB r r �_run_web_searchr+ �_run_web_fetchr �nowr � isoformatr � Exception�_log_web_tool_failure� _web_tool_client_error_summary�max�len)r. r/ r1 r, r4 � tool_namerP �32message_id�tool_id� usage_key�33tool_input�_result_block_for_tool� _error_payload_type_for_toolr r r* �result_content�summary�result_block_type�fetched�errorrV rF s &&$$ r � stream_web_server_tool_responser{ ' s~ � � � �'��0�I����w� B� B�� �� )�D���34�35� �~�&�J��$�*�*�,�*�*�+�,�G�!*�l�!:� �@T� �36 � � $� 37�-��%�&��[��&�
'� � �,��*� ��38 �2��)�$� �39 �� �O� ��j�� �� ��2��� � � �t� ���.�,���K� � 40� � � � � �)� �Q� ����g�� ��� � 41� � � � �v�';�W�a� H� � �-42� � � $��43�7�+�,�E� $� 4� 4�U� ;�;�G� &�
#� &�F� � /��V�G�_��6�%�=��44 &�
� #� &�e�5�G� 6� � $� 3� 3��J�u�%�&�(8� � �G� �*��w�u�~���J� � ��$�g�l�&;� ���� �45 �W�W� -� �)�T�!2� � �� � �S� 1� ;� ;� =� �N� �f�o�&7�'7�8�G� 5� � ��3�w�<�1�,�-�M�46� � �)� �Q� ��)� �w��>� � 47� � � � �v�';�W�a� H� � �48 � � �)� �Q� �f�f�f�b� 9� 49� � � � � �)� �Q� �f�l�F�G�<� 50� � � � �v�';�W�a� H� � � �� �O� �m�Z� �$�G� � � � � �!�I�q�>�� 51� � � �>�F�N�+C�52D�D�} <��#���( � 5354�.7�;�.F�C�55�5�)�*�D� ��&�&�y�%�9�&�M� 2� =�� �0�;� �-�56�� �9�9� �u�&;� :� 57���5859�so �DM"� -K2 � K'� K2 � K*�3K2 �M"�%K2 �,K/�-A6K2 �#CM"�'K2 �*K2 �2 M �=AM�M"�M � M")!�__doc__�60__future__r rc �collections.abcr r r �typingr �api.models.anthropicr � core.anthropic.server_tool_sser r r61 r r �core.anthropic.sser
� constantsr �egressr �parsersr r r. r r r r+ r{ r r r �<module>r� s[ �� I� "� � )� "� � 0�� � 0� '� (� /�� � �gE�62 #(� gE� gEr