Oj0.ddlmZddlZddlZddlZddlZddlmZddlm Z m Z m Z m Z ddl mZddlmZddlmZmZmZdd lmZmZdd lmZd d lmZd d lmZddlmZe dZ GddeZ!eGddZ"Gddee Z# ddZ$Gdde#dZ%Gdde#de dzZ&y)) annotationsN) TracebackType)TypeVarCallableSequence Awaitable)deque) dataclass)SelfProtocoloverride)GroupingUpdateTranscriptGrouperOptions)TranscriptListeners) ServerEvent) OpenAIError)TranscriptState_ReturnTceZdZddZy)_TimercyNselfs z/var/www/origus_pro_usr/data/www/origus.pro/core/.venv/lib/python3.12/site-packages/openai/lib/live/_transcript_grouper.pycancelz _Timer.cancelsNreturnNone)__name__ __module__ __qualname__rrr rrrs!r rc8eZdZUdZded<dZded<dZded <y) _DispatchRunNzasyncio.Task[None] | NonetaskrintwaitersFboolobserved)r$r%r&r)__annotations__r+r-rr rr(r(s!&*D #*GSHdr r(cHeZdZdfd ZddZd dZd dZd dZd dZxZ S) _BaseTranscriptGrouperct|t||j|_t |_d|_d|_y)Nr) super__init__r_now_stater _updates_timer_timer_generation)roptions __class__s rr3z_BaseTranscriptGrouper.__init__"s8 %gtyy9 /4w %) !"r c0tjdzSN)time monotonicrs rr4z_BaseTranscriptGrouper._now)s~~$&&r c|xjdz c_|j"|jjd|_yy)Nr)r8r7rrs r _clear_timerz#_BaseTranscriptGrouper._clear_timer,s9 !# ;; " KK   DK #r cjjj}|(jj |fd_yy)Nc&jSr) _timer_fired) generationrsrz2_BaseTranscriptGrouper._schedule..7s$:K:KJ:Wr )rAr5delayr8 _call_laterr7)rrGrEs` @r _schedulez _BaseTranscriptGrouper._schedule2sL  !!#  //J**52WXDK r ctrNotImplementedErrorrdelay_mscallbacks rrHz"_BaseTranscriptGrouper._call_later9!!r ctrrKrrEs rrDz#_BaseTranscriptGrouper._timer_fired<rPr )r9rr"r#)r"floatr!rNr*rOzCallable[[], None]r"rrEr*r"r#) r$r%r&r3r4rArIrHrD __classcell__r:s@rr0r0!s"#' Y""r r0c Zt|dn||dn||dn||dn|t|xsdS)Niir=r)rtuplemin_turn_separation_msassistant_silence_msbackchannel_max_duration_msbackchannel_isolation_msadditional_acknowledgmentss r_optionsr`@sK $%-3I$,2F+39T(06N (.B/  r ceZdZdZdddddd d fdZd dZddZddZ ddZe dd Z e dd Z dd Z xZ S)TranscriptGrouperaXGroup 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. NrZc ~t|t|||||tj|_d|_y)NF)r2r3r` threadingLock_lock _dispatchingrr[r\r]r^r_r:s rr3zTranscriptGrouper.__init__dsA  &$+(*   ^^% !r c |j5|jj|}| dddy|jj ||j ddd|j y#1swYxYw)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)rfr5pushr6extendrI _dispatchreventupdatess rrjzTranscriptGrouper.pushysp ZZ kk&&u-G   MM  ) NN       sA9+A99Bc|j5|jj|jj d|j ddd|j y#1swYxYw)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)rfr6rkr5finishrArlrs rclosezTranscriptGrouper.closesY ZZ MM !3!3H!= >        s AA++A4c|Srrrs r __enter__zTranscriptGrouper.__enter__s r c$|jyrrsrexc_typeexc tracebacks r__exit__zTranscriptGrouper.__exit__s  r cftj|dz |}d|_|j|S)Nr=T)rdTimerdaemonstart)rrNrOtimers rrHzTranscriptGrouper._call_laters+4:   r cX|j5||jk7s|jjr dddyd|_|j j |jj|jddd|jy#1swYxYwr) rfr8r5closedr7r6rktickrIrlrRs rrDzTranscriptGrouper._timer_fireds ZZ T333t{{7I7I  DK MM !1!1!3 4 NN       s'B A B  B)c|j5|jr dddyd|_ddd |j5|jsd|_ dddy|jj}ddd|j D] }|| k#1swYvxYw#1swY4xYw#t $r*|j5d|_ddd#1swYxYwwxYw)NTF)rfrgr6popleft _handlers BaseException)rupdatehandlers rrlzTranscriptGrouper._dispatchs ZZ %   % %!%D  % ZZ5==,1)55"]]224F 5 $~~f5$GFO$   % % 55  *$)! *  *  sWB B  B8B,B8B,9'B8 B),B51B88C+ C C+C' #C+ r[ float | Noner\rr]rr^rr_Sequence[str] | Noner"r#rnrr"r#r!r"r ryztype[BaseException] | NonerzzBaseException | Noner{zTracebackType | Noner"r#rTrU)r$r%r&__doc__r3rjrsrur|r rHrDrlrVrWs@rrbrbPs,04-14815;?"!-"+ " &2 " #/ "%9" "*  29MZn   r rbceZdZdZdddddd dfdZddZddZddZddZ dd Z e dd Z e dd Z dd Z dd ZddZddZxZS)AsyncTranscriptGrouperaAsyncio 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. NrZc Zt|t|||||d|_d|_yr)r2r3r`_loop _dispatch_runrhs rr3zAsyncTranscriptGrouper.__init__s:  &$+(*   8< 26r ctj}|j ||_|S|j|ur td|S)NzBThe async transcript grouper must be used on its owning event loop)asyncioget_running_looprr)rloops r _get_loopz AsyncTranscriptGrouper._get_loopsG'') :: DJ ZZt #bc c r cK|j|jj|}|y|jj ||j |j d{y7w)zJConsume one event and dispatch its updates; await async handlers in order.N)rr5rjr6rkrIrlrms rrjzAsyncTranscriptGrouper.pushsX ++""5) ?  W% nnsA-A7/A50A7cK|j|jj|jj d|j |j d{y7w)zIFinalize the projection and cancel timers. Idempotent; owns no transport.rqN)rr6rkr5rrrArlrs rrszAsyncTranscriptGrouper.closesM  T[[//9: nnsA(A2*A0+A2c.K|j|Swr)rrs r __aenter__z!AsyncTranscriptGrouper.__aenter__s  sc@K|jd{y7wrrwrxs r __aexit__z AsyncTranscriptGrouper.__aexit__sjjls cH|jj|dz |Sr<)r call_laterrMs rrHz"AsyncTranscriptGrouper._call_laters ~~**8d?HEEr c||jk7s|jjryd|_|jj |jj |j|jyr) r8r5rr7r6rkrrI_start_dispatchrRs rrDz#AsyncTranscriptGrouper._timer_fireds[ // /4;;3E3E   T[[--/0  r c|j|urd|_|jry|j}|>|js1|js$|j j d||dyyyy)NzLive transcript callback failed)message exceptionr))r cancelledrr+r-rcall_exception_handler)rrunr)errors r_dispatch_finishedz)AsyncTranscriptGrouper._dispatch_finishedsn    $!%D  >>     S[[ NN  3 3=E[_` :F[ r cVj(jjjsSjsyt _j j j_jjfdS)Nc(j|Sr)r)r)rrs rrFz8AsyncTranscriptGrouper._start_dispatch..#s0G0GT0Rr ) rr)doner6r(r create_task_dispatch_updatesadd_done_callbackrrs`@rrz&AsyncTranscriptGrouper._start_dispatchs   ?sxx3CHHMMOJ}}n >>#//0F0Fs0KL ""#RS r cK|j}|!|jtjury|j }|y|jJ|xj dz c_ tj |jd{d|_ |xj dzc_y7"#tj$rt$r d|_wxYw#|xj dzc_wxYww)NrT) rr)r current_taskrr+shieldr-CancelledErrorrrs rrlz AsyncTranscriptGrouper._dispatch&s   ?sxx7+?+?+AA ""$ ; xx### q  ..* * * CL KK1 K +%%   CL   KK1 KsBA&C2)"B0 B. B0CC2.B00%CCC//C2c&Ktj|_|jrf|jj }|j |D]*}||}t j|s!|d{,|jreyy7wr)rrr)r6rrinspect isawaitable)rrrrresults rrz(AsyncTranscriptGrouper._dispatch_updates=ss'')mm]]**,F>>&1 ! &&v. LL !mm !sA1B4B9B:B Br)r"zasyncio.AbstractEventLooprr!rrrTrU)rr(r)zasyncio.Task[None]r"r#)r"z_DispatchRun | None)rr(r"r#)r$r%r&rr3rrjrsrrr rHrDrrrlrrVrWs@rrrs 04-14815;?7!-7+ 7 &2 7 #/ 7%97 7*29MZn  FF  .!r r) r[rr\rr]rr^rr_rr"r)' __future__rr>rrrdtypesrtypingrrrr collectionsr dataclassesr typing_extensionsr r r _typesrr _listenersr types.liver _exceptionsr_transcript_staterrrr(r0r`rbrrr rrs" 99!66<+%&. : "X"   "0:"> ( & ". +  !5    l.t4l^F!3D9T?4JKF!r