| """Actual loaded TYGER checks, never another model load; synthetic audio only.""" |
| import asyncio |
| from pathlib import Path |
| import subprocess |
| import time |
|
|
| import numpy as np |
|
|
|
|
| def read16(path,seconds=6): |
| p=subprocess.run(['ffmpeg','-nostdin','-v','error','-i',str(path),'-t',str(seconds), |
| '-ar','16000','-ac','1','-f','f32le','pipe:1'],capture_output=True,check=True) |
| x=np.frombuffer(p.stdout,'<f4').copy() |
| if not len(x):raise ValueError('Empty synthetic fixture') |
| return x |
|
|
|
|
| async def model_checks(ears): |
| root=Path(__file__).resolve().parents[1] |
| |
| |
| agent=read16(root/'demo_de.wav',8) |
| user=read16(root/'humaneness-small/full-ft-speaker-study/audio/diagnostic-idris-natural_duration-0.mp3',4) |
| n=16000*8;agent=np.pad(agent[:n],(0,max(0,n-len(agent)))) |
| rows=[] |
| for name in ['silence','normal_conversation','bot_echo','user_interrupts']: |
| for echo_db in ([-26,-40,-60,-90] if name in ('bot_echo','user_interrupts') else [None]): |
| for pairing in (['arrival_fixed_150ms','timestamps'] if name in ('bot_echo','user_interrupts') else ['timestamps']): |
| await asyncio.sleep(.1) |
| session=ears.open_session(ears.defaults) |
| if session is None:raise RuntimeError('Close the browser microphone session before synchronization checks') |
| mic=np.zeros(n,np.float32);reference=np.zeros(n,np.float32);mode='listen' |
| if name=='normal_conversation':mic[:len(user)]=user |
| if name in ('bot_echo','user_interrupts'): |
| mode='speaking';mic=agent*10**(echo_db/20);reference=agent.copy() |
| if name=='user_interrupts': |
| at=24000;length=min(len(user),n-at);mic[at:at+length]+=user[:length] |
| if pairing=='arrival_fixed_150ms': |
| |
| ahead=6400;reference=np.r_[reference[ahead:],np.zeros(ahead,np.float32)] |
| events=[];tick=time.perf_counter();peaks=[] |
| try: |
| for i in range(0,n,5120): |
| a=mic[i:i+5120];b=reference[i:i+5120] |
| if len(a)<5120:a=np.pad(a,(0,5120-len(a)));b=np.pad(b,(0,5120-len(b))) |
| out=await ears.feed(session,a,b,mode) |
| peaks.extend(e.get('yield_prob',0.) for e in out if e['kind']=='FRAME') |
| events.extend((e['kind'],(i+5120)/16000) for e in out if e['kind']!='FRAME') |
| finally:ears.close(session) |
| rows.append({'scenario':name,'pairing':pairing,'echo_db':echo_db,'seconds':time.perf_counter()-tick, |
| 'endpoint_count':sum(k=='ENDPOINT' for k,t in events),'barge_count':sum(k=='BARGE' for k,t in events), |
| 'barge_times_s':[t for k,t in events if k=='BARGE'], |
| 'max_yield':max(peaks,default=0.), |
| 'contains_transcripts':False}) |
| return {'conditions':rows,'note':'Running Nemotron/TYGER; synthetic fixtures, reconstructed arrival-order control, not a measured before-state on the lost machine. Hardware microphone accuracy requires physical testing.'} |
|
|
