Oj lUdZddlmZddlZddlZdZdZdZdZ ddZ Gd d Z da d e d <d addZy)uSemantic end-of-turn detection — Smart Turn v3 (pipecat-ai, BSD-2). A fixed silence timeout is a bad proxy for "done talking": it cuts Ahmed off mid-thought when he pauses to think, and wastes 400ms when he clearly finished. Smart Turn listens to the ACTUAL speech (grammar, tone, pace — a Whisper-Tiny encoder + classifier head, 8M params) and returns the probability that the turn is complete. ~12ms per call on CPU. main.py uses it like this: once a SHORT pause is detected, ask the model — "did he finish the sentence?" If yes → respond immediately (snappier than the old fixed wait). If no → keep listening through the pause, up to a hard cap. SMART_TURN=0 disables (falls back to the fixed timeout). Model: huggingface.co/pipecat-ai/smart-turn-v3 (auto-downloaded, ~30MB). Preprocessing per the reference inference.py: last 8s of 16kHz audio, front-padded, Whisper log-mel features, normalized. ) annotationsNzpipecat-ai/smart-turn-v3zsmart-turn-v3.2-cpu.onnxi>cHtjjdddk7S)N SMART_TURN10)osenvironget8/Users/ahmed/devFolder/Ultron/claude-voice/voice/turn.pyenabledrs ::>>, , 33r ceZdZddZddZy) TurnDetectorcrddl}ddlm}ddlm}|t t }|j}d|_|jj|_ |j||dg|_ |t|_|j!t#j$t&t"j(y) Nr)hf_hub_download)WhisperFeatureExtractorCPUExecutionProvider) sess_options providers) chunk_length)dtype) onnxruntimehuggingface_hubr transformersr _MODEL_REPO _MODEL_FILESessionOptionsinter_op_num_threadsGraphOptimizationLevelORT_ENABLE_ALLgraph_optimization_levelInferenceSession_session _WINDOW_S_fxcompletion_probnpzeros _SAMPLE_RATEfloat32)selfortrrpathsos r__init__zTurnDetector.__init__$s!38{K8    !"#&)&@&@&O&O#,, r.D-E-G * B RXXl"**EFr c ttz}t||kDr|| d}|j|tdd|ddjj dj tjd}|jjdd|i}ttj|djd dS) z@P(turn is complete) for 16kHz mono float32 audio (uses last 8s).Nr* max_lengthT) sampling_ratereturn_tensorspaddingr4 truncation do_normalizer)N.input_features)r'r,lenr(r:squeezeastyper*r-r&runfloatasarrayreshape)r.audionfeatsouts rr)zTurnDetector.completion_prob3s  $ u:>1"#JE d Q4  .FF2::$6y B mm'7&?@RZZA'//3A677r N)returnNone)rCz np.ndarrayrGr@)__name__ __module__ __qualname__r2r)r r rrr#s  G 8r rTurnDetector | None _detectorFctrtryt tatStS#t$r }dat d|dYd}~tSd}~wwxYw)zLazy singleton; None when disabled or unavailable (fixed timeout is the fallback, so a download/model failure can never break listening).NTz smart-turn unavailable (u) — fixed-timeout turns)r_failedrMr Exceptionprint)es r get_detectorrSFsc 9 M$I 9 MG .qc1JK L L  Ms / AAA)rGbool)rGrL)__doc__ __future__rr numpyr*rrr,r'rrrM__annotations__rOrSr r rrYsO$# ( (  488>"& %  r