tPj7dZddlmZddlmZddlmZdedefdZ dede fdZ d eed ede efd Z d eded zfdZy )aShared content-part helpers for compression guardrails (headroom, compresr). Compression services only transform plain-string message content: every transform in the service pipeline gates on ``isinstance(content, str)`` and silently skips the OpenAI list-of-parts shape. Guardrails that send messages to such a service collapse text-bearing part lists to strings here, and write the rewritten text back through ``merge_rewritten_text_parts``. Anthropic ``cache_control`` breakpoints are positional: each one caches the prefix ending at the part that carries it. A single compressed string can therefore only be written back over a run of text parts, never across a non-text part, which is what ``is_all_text_parts`` gates. )Sequence)Final)get_attribute_or_keycontentreturnc.t|tr|St|trsg}|D][}t|ts|j ddk(s)|j d}t|tsK|j |]dj |Sy)zCollapse a message ``content`` (str or list-of-parts) to plain text. For the multimodal list shape, joins ``{type: "text", text: ...}`` parts with blank-line separators; non-text parts are ignored. typetextz ) isinstancestrlistdictgetappendjoin)rpartspartr s z/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/litellm/proxy/guardrails/guardrail_hooks/content_text.pycontent_to_textrs '3'4 "$ 'D$%$((6*:f*Dxx'dC(LL&  ' {{5!! cLt|tr|sytd|DS)zGTrue when ``content`` is a non-empty part list holding only text parts.Fc3hK|]*}t|txr|jddk(,yw)r r N)r rr.0rs r z$is_all_text_parts..,s-Yz$%D$((6*:f*DDYs02)r rall)rs ris_all_text_partsr(s# gt $G YQXY YYrrnew_textctd|D}td|D}|r i|dd|ind|d}|r i|d|digS|gS)aCollapse a rewritten all-text part list into one part carrying ``new_text``. Only all-text rows are ever flattened, so the merged part IS the whole row: it keeps the first part's fields and the LAST declared cache_control breakpoint. A breakpoint caches the prefix ending at its part, so after the merge the last one (and its TTL) is the one that still describes the row. c3BK|]}t|ts|yw)N)r rrs rrz-merge_rewritten_text_parts..7sOt 48NdOsc3JK|]}|jd|dyw) cache_controlN)rrs rrz-merge_rewritten_text_parts..8s$utxxXgOhOttO4us# #rr )r r r#)tuple)rr dict_parts breakpointsbases rmerge_rewritten_text_partsr)/siOuOOJuuuK9C5Z]5FH5RXbjIkD:E 6t 6_k"o 6 PP4 PPrresponseNc t|dd}t|tr.|r,t|ddd}|tt|dd}|r|St|dd}t|trS|Dcgc]3}t|dddk(r!t|dd}t|tr|r|5}}}|rdj |St|d d}t|tr{|D cgc]Y}t|dddk(rGt|ddxsd D]3} t| ddd k(r!t| dd}t|tr|r|5[} } }}| rdj | Sycc}}wcc}} }w) zThe assistant's natural-language text from a model response, across chat, Anthropic, and Responses shapes. Preserved when the turn is rebuilt for the retrieval follow-up so the model's reasoning is not lost.choicesNrmessagerr r r output output_text)rr rrr r) r*r,r-r rblockrr.itemchunk output_partss rassistant_text_from_responser5=s*(ItDG'4 W-gaj)TJ  )*>w SW*XYD )(ItDG'4 ! #E648FB-eVTB$$    775> !(8TBF&$  #D&$79D.tYEK  #E648MI-eVTB$$     77<( ( -  s .8EAE)__doc__collections.abcrtypingr3litellm.litellm_core_utils.prompt_templates.factoryrobjectr rboolrrr)r5r/rrr<s| %TV&ZvZ$Z Qhv&6 Q# Q$v, Q#6#cDj#r