Ë tPêjÏãóŠ—UddlZddlmZmZmZddlmZddlmZddl m Z m Z erddl m Z dZeed<d Zeed <Gd „d «Zy) éN)Ú TYPE_CHECKINGÚAnyÚFinal)Úverbose_proxy_logger©Úget_last_user_message)Úget_async_httpx_clientÚhttpxSpecialProvider)ÚAllMessageValuesi'Ú$AZURE_CONTENT_SAFETY_MAX_TEXT_LENGTHièÚ'AZURE_CONTENT_SAFETY_TEXT_RECORD_LENGTHc󘇗eZdZdZdededefˆfd„ Zdedeeefdeeeffd „Ze d ed e de efd „«Z d e ddedzfd„Z ˆxZS)ÚAzureGuardrailBasezÕ Base class for Azure guardrails. Provides shared initialisation (API credentials, HTTP client) and utilities (text splitting, authenticated POST) used by all Azure Content Safety guardrails. Úapi_keyÚapi_baseÚkwargsc 󲕗t‰|di|¤Žttj¬«|_||_||_|jd«xsd|_ y)N)Ú llm_providerÚ api_versionz 2024-09-01©) ÚsuperÚ__init__r r ÚGuardrailCallbackÚ async_handlerrrÚgetr)ÚselfrrrÚ __class__s €úx/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/litellm/proxy/guardrails/guardrail_hooks/azure/base.pyrzAzureGuardrailBase.__init__!sMø€ô ‰ÑÑ"˜6Ò"ä3ÔAU×AgÑAgÔhˆÔ؈Œ Ø ˆŒ Ø &§ ¡ ¨=Ó 9Ò I¸\ˆÕóÚ endpoint_pathÚ request_bodyÚreturncƒó4K—|j›d|›d|j›}|jddœ}tjd||«|j j |||¬«ƒd{–—†}|j«}tjd||«|S7Œ-­w) aAPOST to an Azure Content Safety endpoint with standard auth headers. Args: endpoint_path: The API action, e.g. ``"text:shieldPrompt"`` or ``"text:analyze"``. request_body: JSON-serialisable request payload. Returns: Parsed JSON response dict. z/contentsafety/z ?api-version=zapplication/json)zOcp-Apim-Subscription-Keyz Content-Typez%Azure Content Safety request [%s]: %s)ÚurlÚheadersÚjsonNz&Azure Content Safety response [%s]: %s)rrrrÚdebugrÚpostr&)rr r!r$r%ÚresponseÚ response_jsons rÚ_post_to_content_safetyz*AzureGuardrailBase._post_to_content_safety0s¦èø€ðŸ ™  o°m°_ÀMÐRV×RbÑRbÐQcÐdˆà)-¯©Ø.ñ ˆô ×"Ñ"Ð#JÈMÐ[gÔhØ $× 2Ñ 2× 7Ñ 7ØØØð!8ó! ÷ ˆð 08¯}©}«ˆ Ü×"Ñ"Ð#KÈ]Ð\iÔjØÐð ús‚A&BÁ(BÁ).BÚtextÚ max_lengthcój—t|«|kr|gStjd|«}g}d}|D]o}t|«t|«z|kr||z }Œ#|r|j|«d}t|«|kDr(|j|d|«||d}t|«|kDrŒ(|}Œq|r|j|«|S)uÓ Split text into chunks at word boundaries without breaking words. Always returns at least one chunk. Short text (≤ max_length) is returned as a single-element list so callers can use a uniform loop without branching on length. Args: text: The text to split max_length: Maximum character length of each chunk Returns: List of text chunks, each not exceeding max_length z\S+|\s+ÚN)ÚlenÚreÚfindallÚappend)r,r-ÚtokensÚchunksÚ current_chunkÚtokens rÚsplit_text_by_wordsz&AzureGuardrailBase.split_text_by_wordsKsЀô ˆt‹9˜ Ò "Ø6ˆMô Ÿ ™  :¨tÓ4ˆà#%ˆØˆ àò &ˆEä=Ó!¤C¨£JÑ.°*Ò<Ø Ñ&‘ ñ!Ø—M‘M -Ô0Ø$&Mô˜%“j :Ò-Ø—M‘M %¨ ¨Ð"4Ô5Ø! * +Ð.Eô˜%“j :Ó-ð!&‘ ð &ñ" Ø M‰M˜-Ô (àˆ rÚmessagesr Ncó—t|«S)a‘ Get the last consecutive block of messages from the user. Example: messages = [ {"role": "user", "content": "Hello, how are you?"}, {"role": "assistant", "content": "I'm good, thank you!"}, {"role": "user", "content": "What is the weather in Tokyo?"}, ] get_user_prompt(messages) -> "What is the weather in Tokyo?" r)rr9s rÚget_user_promptz"AzureGuardrailBase.get_user_prompt|s€ô% XÓ.Ð.r)Ú__name__Ú __module__Ú __qualname__Ú__doc__ÚstrrrÚdictr+Ú staticmethodÚintÚlistr8r;Ú __classcell__)rs@rrrsªø„ñð Jàð Jðð Jðõ Jð¸3ðÈdÐSVÐX[ÐS[ÉnðÐaeÐfiÐknÐfnÑaoóð6ð. #ð.°3ð.¸4À¹9ò.óð.ð` /¨Ð-?Ñ(@ð /ÀSÈ4ÁZ÷ /rr)r1ÚtypingrrrÚlitellm._loggingrÚ8litellm.litellm_core_utils.prompt_templates.common_utilsrÚ&litellm.llms.custom_httpx.http_handlerr r Úlitellm.types.llms.openair r Ú__annotations__r rrrrúrLsIðÜ ß,Ñ,å1õ÷ñ Ý:ð/4Ð$ eÓ3ð26Ð'¨Ó5÷p/òp/r