tPj\ RUdZddlZddlZddlmZmZddlmZddlm Z ddl m Z ddl m Z mZmZe dd d d d d dgdddd Zeed<ee\ZZdadaeej.dddz Zeed<dedefdZ ddeezeezeezdzfdZdZy)a) Mock HTTP client for Braintrust integration testing. This module intercepts Braintrust API calls and returns successful mock responses, allowing full code execution without making actual network calls. Usage: Set BRAINTRUST_MOCK=true in environment variables or config to enable mock mode. N) AsyncIterableIterable)Final)urlparse)verbose_logger)MockClientConfig MockResponsecreate_mock_client_factory BRAINTRUSTBRAINTRUST_MOCKdzmock-project-idsuccess)idstatus).braintrustdata.combraintrustdata.com.braintrust.devbraintrust.devTF)default_latency_msdefault_status_codedefault_json_data url_matcherspatch_async_handlerpatch_sync_clientpatch_http_handler_configBRAINTRUST_MOCK_LATENCY_MS100g@@_MOCK_LATENCY_SECONDSurlreturnct|tsyt|}|jxsdj }|sy|dk(xs+|j dxs|dk(xs|j dS)z%Check if URL is a Braintrust API URL.Frrrr) isinstancestrrhostnamelowerendswith)r!parsedhosts p/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/litellm/integrations/braintrust_mock_client.py_is_braintrust_urlr-;sy c3 SMF??(b//1D  $$ , ==. / , # # , ==* + contentc t|trt|rtjd|t j td|vr|r|jddnd} d| | d} nd|vrdd i} ntj} ttj| |t Stt|||||||||| | Std ) zbMonkey-patched HTTPHandler.post that intercepts Braintrust calls with endpoint-specific responses.z[BRAINTRUST MOCK] POST to %sz/projectnamelitellmzmock-project-id-)rr1z /project_logsrr) status_code json_datar!elapsed_seconds) r!datajsonparamsheaderstimeoutstreamfilesr/ logging_objz'Original HTTPHandler.post not available)r%r&r-rinfotimesleepr getrrr r_original_http_handler_post RuntimeError) selfr!r6r7r8r9r:r;r<r/r= project_name mock_datas r,_mock_http_handler_postrGNs#s 23 7:C@ ()  AE$((69"=9L!1,@,WI  #!9-I11I331   #.* #   @ AAr.c0trytjdddlm}t ,|j at|_tjdttjdtdzdd tjd d ay) a\ Monkey-patch HTTPHandler.post to intercept Braintrust sync calls. Braintrust uses HTTPHandler for sync calls and AsyncHTTPHandler for async calls. HTTPHandler.post uses self.client.send(), not self.client.post(), so we need custom patching for sync (similar to Helicone). AsyncHTTPHandler.post is patched by the factory. We use custom patching instead of factory's patch_http_handler because we need endpoint-specific responses (different for /project vs /project_logs). This function is idempotent - it only initializes mocks once, even if called multiple times. Nz8[BRAINTRUST MOCK] Initializing Braintrust mock client...r HTTPHandlerz*[BRAINTRUST MOCK] Patched HTTPHandler.postz&[BRAINTRUST MOCK] Mock latency set to iz.0fmsz@[BRAINTRUST MOCK] Braintrust mock client initialization completeT) _mocks_initializedrdebug&litellm.llms.custom_httpx.http_handlerrJrBpostrG%create_mock_braintrust_factory_clientr rIs r,create_mock_braintrust_clientrQs STB"*&1&6&6#2 IJ*+ABWZ^B^_bAccefg[\r.) NNNNNFNNN)__doc__osr?collections.abcrrtypingr urllib.parserlitellm._loggingr(litellm.integrations.mock_client_factoryrr r r__annotations__rPshould_use_braintrust_mockrBrLfloatgetenvr r&boolr-bytesrGrQr.r,r`s  3!+".)D ,w')# %YRYY/KU%STW]]u]CD,      KO0B5[8E? *]5-A AD H0Bf#r.