jb tdZddlmZddlZddlmZmZejeZ gdZ dZ d dZ d dZ d d Zy) 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_safelyicb ||y#t$rtjddYywxYw)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)observeevents k/var/www/html/Fitness-lenito-AI-main/venv/lib/python3.12/site-packages/langsmith/_internal/voice/helpers.pyrrs3     Dt   s  ..ct|trdt|dSt|tr4t|tkDr |dtdt|tz dzS|St|t r-|j Dcic]\}}|t|c}}St|ttfr|Dcgc] }t|c}S|Scc}}wcc}w)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>) isinstancebyteslenstrMAX_STRdictitemsrlisttuple)objkvs rrr(s#u3s8*G$$#s s8g x=VCHw,>+?w#GG G #t(+ 4 158 44#e}%"%&#Qa#&& J5&s C;Cct|dr |jSt|tr|Sdt |iS#t$rY*wxYw)z:Best-effort conversion of an event object to a plain dict. model_dumprepr)hasattrr r rrr!)rs rrr=sTul# ##% %% DK     s= A A )rzCallable[[Any], None]rrreturnNone)rrr#r)rrr#zdict[str, Any])__doc__ __future__rloggingtypingrr getLogger__name__r __all__rrrrrr.sB #   8 $ 3   * !r-