o Tj0.@s8ddlmZddlZddlZddlZddlZddlmZddlm Z m Z m Z m Z ddl mZddlmZddlmZmZmZdd lmZmZdd lmZd d lmZd d lmZddlmZe dZ GdddeZ!eGdddZ"Gdddee Z#d%dd Z$Gd!d"d"e#dZ%Gd#d$d$e#de dBZ&dS)&) annotationsN) TracebackType)TypeVarCallableSequence Awaitable)deque) dataclass)SelfProtocoloverride)GroupingUpdateTranscriptGrouperOptions)TranscriptListeners) ServerEvent) OpenAIError)TranscriptState_ReturnTc@seZdZdddZdS)_TimerreturnNonecCsdSNselfrrf/home/dinkstrade/pdmp-scanner/venv/lib/python3.10/site-packages/openai/lib/live/_transcript_grouper.pycancelsz _Timer.cancelNrr)__name__ __module__ __qualname__rrrrrrsrc@s2eZdZUdZded<dZded<dZded <dS) _DispatchRunNzasyncio.Task[None] | NonetaskrintwaitersFboolobserved)r r!r"r$__annotations__r&r(rrrrr#s  r#csPeZdZdfdd Zddd Zdd d Zdd d ZdddZdddZZ S)_BaseTranscriptGrouperoptionsrrrcs0tt||j|_t|_d|_d|_dS)Nr) super__init__r_now_stater_updates_timer_timer_generation)rr+ __class__rrr-"s  z_BaseTranscriptGrouper.__init__floatcCs tdSN)time monotonicrrrrr.)s z_BaseTranscriptGrouper._nowcCs0|jd7_|jdur|jd|_dSdS)Nr )r2r1rrrrr _clear_timer,s    z#_BaseTranscriptGrouper._clear_timercs@j}|durj|fdd_dSdS)Ncs Sr) _timer_firedr generationrrr7s z2_BaseTranscriptGrouper._schedule..)r:r/delayr2 _call_laterr1)rr?rr<r _schedule2s  z _BaseTranscriptGrouper._scheduledelay_msr%callbackCallable[[], None]rcCtrNotImplementedErrorrrBrCrrrr@9z"_BaseTranscriptGrouper._call_laterr=cCrErrFrr=rrrr;<rIz#_BaseTranscriptGrouper._timer_fired)r+rrr)rr5rrBr%rCrDrrr=r%rr) r r!r"r-r.r:rAr@r; __classcell__rrr3rr*!s    r*min_turn_separation_ms float | Noneassistant_silence_msbackchannel_max_duration_msbackchannel_isolation_msadditional_acknowledgmentsSequence[str] | NonerrcCsHt|durdn||durdn||durdn||durdn|t|p!dS)Niir7r)rtuplerNrPrQrRrSrrr_options@s rWcs~eZdZdZddddddd,fd dZd-ddZd.ddZd/ddZd0ddZe d1d%d&Z e d2d(d)Z d.d*d+Z Z S)3TranscriptGrouperaXGroup public Live transcript events into immutable display segments. This is the TypeScript SDK's speaker/backchannel policy: only transcript additions and session.closed are consumed. It is not VAD, playback tracking, or a lossless transcript; brief overlapping acknowledgments may be suppressed. Set backchannel_max_duration_ms=0 to disable suppression. additional_acknowledgments extends the built-in phrases using the same timing thresholds. Phrases are copied at construction and normalized like transcript text: case, hyphens, whitespace, and surrounding punctuation are normalized. Use one instance per session. Call close() on disconnect or use a with block; the grouper never owns, closes or reconnects your transport. Delayed delivery can change grouping because monotonic local time supplies inactivity fallback. Callbacks are serialized and run outside the state lock. A timer-triggered callback may run on a daemon timer thread. Callback exceptions propagate to push/close callers, or to threading.excepthook for timer-triggered callbacks. NrVrNrOrPrQrRrSrTrrcs,tt|||||t|_d|_dS)NF)r,r-rW threadingLock_lock _dispatchingrrNrPrQrRrSr3rrr-ds  zTranscriptGrouper.__init__eventrcCsl|j%|j|}|dur WddS|j||Wdn1s+wY|dS)zConsume one typed Live event; duplicates and unrelated events are ignored. Invalid transcript fields or use after close raise OpenAIError before changing state. Empty text does not restart inactivity. N)r[r/pushr0extendrA _dispatchrr^updatesrrrr_ys    zTranscriptGrouper.pushcCsN|j|j|jd|Wdn1swY|dS)zFlush/finalize once and cancel timers, without closing the transport. Already-running callbacks finish in order, including when close is called from a callback. Further push calls fail. manualN)r[r0r`r/finishr:rarrrrcloses   zTranscriptGrouper.closer cCs|Srrrrrr __enter__rIzTranscriptGrouper.__enter__exc_typetype[BaseException] | NoneexcBaseException | None tracebackTracebackType | NonecCs |dSrrfrrhrjrlrrr__exit__s zTranscriptGrouper.__exit__rBr%rCrDrcCs"t|d|}d|_||S)Nr7T)rYTimerdaemonstart)rrBrCtimerrrrr@szTranscriptGrouper._call_laterr=cCsv|j*||jks |jjr WddSd|_|j|j|Wdn1s0wY| dSr) r[r2r/closedr1r0r`tickrArarJrrrr;s  zTranscriptGrouper._timer_firedc Cs|j|jr WddSd|_Wdn1swYz6 |j|js8d|_ WdWdS|j}Wdn1sGwY||D]}||qQq$tyv|j d|_Wd1spwYw)NTF)r[r\r0popleft _handlers BaseException)rupdatehandlerrrrras4    zTranscriptGrouper._dispatch rNrOrPrOrQrOrRrOrSrTrrr^rrrrrr rhrirjrkrlrmrrrKrL)r r!r"__doc__r-r_rfrgrpr r@r;rarMrrr3rrXPs"      rXcseZdZdZddddddd:fd dZd;ddZdddZd?d!d"Z e d@d(d)Z e dAd+d,Z dBd1d2Z dCd4d5Zd=d6d7ZdDd8d9ZZS)EAsyncTranscriptGrouperaAsyncio counterpart of TranscriptGrouper, sharing exactly the same policy. additional_acknowledgments extends the built-in phrases with the same normalization and timing thresholds as TranscriptGrouper. Use async with, await push(event), and await close(). Register synchronous or asynchronous callbacks with on/once. Handlers run sequentially on the owning event loop; timer callbacks never run on a worker thread. Exceptions from timer-triggered handlers go to the event loop's exception handler. NrVrNrOrPrQrRrSrTrrcs(tt|||||d|_d|_dSr)r,r-rW_loop _dispatch_runr]r3rrr-s  zAsyncTranscriptGrouper.__init__asyncio.AbstractEventLoopcCs2t}|jdur||_|S|j|urtd|S)NzBThe async transcript grouper must be used on its owning event loop)asyncioget_running_looprr)rlooprrr _get_loops  z AsyncTranscriptGrouper._get_loopr^rcsH||j|}|durdS|j|||IdHdS)zJConsume one event and dispatch its updates; await async handlers in order.N)rr/r_r0r`rArarbrrrr_s  zAsyncTranscriptGrouper.pushcs8||j|jd||IdHdS)zIFinalize the projection and cancel timers. Idempotent; owns no transport.rdN)rr0r`r/rer:rarrrrrfs zAsyncTranscriptGrouper.closer cs||Sr)rrrrr __aenter__sz!AsyncTranscriptGrouper.__aenter__rhrirjrkrlrmcs|IdHdSrrnrorrr __aexit__sz AsyncTranscriptGrouper.__aexit__rBr%rCrDrcCs||d|Sr6)r call_laterrHrrrr@sz"AsyncTranscriptGrouper._call_laterr=cCsB||jks |jjr dSd|_|j|j||dSr) r2r/rur1r0r`rvrA_start_dispatchrJrrrr;s  z#AsyncTranscriptGrouper._timer_firedrunr#r$asyncio.Task[None]cCs^|j|urd|_|rdS|}|dur)|js+|js-|d||ddSdSdSdS)NzLive transcript callback failed)message exceptionr$)r cancelledrr&r(rcall_exception_handler)rrr$errorrrr_dispatch_finisheds   z)AsyncTranscriptGrouper._dispatch_finished_DispatchRun | NonecsljdurjdurjsSjsdSt__jfddS)Ncs |Sr)r)r$rrrrr>#s z8AsyncTranscriptGrouper._start_dispatch..) rr$doner0r#r create_task_dispatch_updatesadd_done_callbackrrrrrsz&AsyncTranscriptGrouper._start_dispatchc s|j}|dur|jturdS|}|durdS|jdus"J|jd7_z,z t|jIdHWntjy>tyHd|_ wd|_ W|jd8_dS|jd8_w)Nr T) rr$r current_taskrr&shieldCancelledErrorryr()rrrrrra&s& "z AsyncTranscriptGrouper._dispatchcsVt|_|jr)|j}||D]}||}t|r#|IdHq|js dSdSr)rrr$r0rwrxinspect isawaitable)rrrzr{resultrrrr=s    z(AsyncTranscriptGrouper._dispatch_updatesr|)rrr}rr~rrKrL)rr#r$rrr)rr)rr#rr)r r!r"rr-rr_rfrrr r@r;rrrarrMrrr3rrs*        r) rNrOrPrOrQrOrRrOrSrTrr)' __future__rr8rrrYtypesrtypingrrrr collectionsr dataclassesr typing_extensionsr r r _typesrr _listenersr types.liver _exceptionsr_transcript_staterrrr#r*rWrXrrrrrs.          o