~tjb rdZddlmZddlZddlmZmZejeZ gdZ dZ dd Z ddZ ddZdS)uShared helpers for the voice integration adapters. * ``dump_event`` — best-effort conversion of an event object to a plain dict (Pydantic ``model_dump`` → ``dict`` → ``repr`` fallback). * ``scrub`` — replace raw audio ``bytes`` with a ```` placeholder and truncate long strings, recursing through dicts and sequences, so a span never carries megabytes of audio or un-serializable junk. * ``observe_safely`` — run an adapter's per-event ``observe`` so a tracing error never escapes into the caller's live loop. ) annotationsN)AnyCallable) dump_eventscrubobserve_safelyiobserveCallable[[Any], None]eventrreturnNonecx ||dS#t$r tddYdSwxYw)zRun an adapter's ``observe`` over one event, swallowing any error. Tracing must never break the live voice loop, so a failure building the trace is logged and dropped and the caller still gets its event. z6voice tracing: failed to observe an event; skipping itT)exc_infoN) Exceptionloggerwarning)r r s _/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/langsmith/_internal/voice/helpers.pyrrsb       Dt        s &99objct|trdt|dSt|trEt|tkr+|dtdt|tz dzS|St|t rd|DSt|ttfr d|DS|S)a(Make an event payload safe and compact for a span. Replaces raw ``bytes`` (audio / base64 blobs) with a ```` placeholder and truncates very long strings, recursing through dicts and sequences, so a span never ships megabytes of payload or breaks JSON serialization. Nz... <+z chars>c4i|]\}}|t|Sr).0kvs r zscrub..7s$4441588444c,g|]}t|Srr)rrs r zscrub..9s&&&Qa&&&r) isinstancebyteslenstrMAX_STRdictitemslisttuple)rs rrr(s#u%$3s88$$$$#s s88g  xx=#GCHHw,>#G#G#GG G #t544 4444#e}%%'&&#&&&& Jrdict[str, Any]ct|dr% |S#t$rYnwxYwt|tr|Sdt |iS)z:Best-effort conversion of an event object to a plain dict. model_dumprepr)hasattrr,rr!r&r-)r s rrr=ssul## ##%% %    D % DKK  s & 33)r r r rr r )rrr r)r rr r*)__doc__ __future__rloggingtypingrr getLogger__name__r__all__r%rrrrrrr6s  #"""""  8 $ $ 3 3 3      * ! ! ! ! ! !r