Nail/lang
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

v49: WS robust — onclose, readyState, setTimeout defer, settled guard

Browse Source
This commit is contained in:
“Naeel”
2026-05-22 17:06:47 +04:00
parent 8f8a21bbcc
commit f4ac9cf717
1 changed files with 37 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files
index.html
+37 -22
View File
@@ -53,7 +53,7 @@ let mediaRecorder, audioChunks = [], userAudioBlob = null, ttsText = '';
let isRecording = false, isAnalyzing = false, micAnalyser = null, micAnimId = null;
let recordStartTime = 0, recordDuration = 0;
// ---------- Версия ----------
const VERSION = 'v48';
const VERSION = 'v49';
document.getElementById('ver').textContent = VERSION;
// ---------- Перевод на русский (Groq) ----------
@@ -612,10 +612,13 @@ async function transcribe(blob) {
if (!GROQ_API_KEY) return { text: '', error: 'no_key' };
const tStart = performance.now();
// Кодируем blob в base64 (только текстовые WS-фреймы — DPI не режет)
const base64 = await new Promise((resolve, reject) => {
const reader = new FileReader();
reader.onload = () => resolve(reader.result.split(',')[1]);
reader.onload = () => {
const b64 = reader.result;
if (typeof b64 !== 'string') reject(new Error('not string'));
else resolve(b64.split(',')[1] || b64);
};
reader.onerror = reject;
reader.readAsDataURL(blob);
});
@@ -623,28 +626,40 @@ async function transcribe(blob) {
console.log('[WS] b64=' + (base64.length/1024).toFixed(1) + 'KB');
return new Promise((resolve) => {
try {
const ws = new WebSocket('wss://proxy.kube5s.ru/ws');
const timeout = setTimeout(() => {
console.log('[WS] timeout'); ws.close(); resolve({ text: '', error: 'timeout' });
}, 60000);
let settled = false;
const done = (result) => { if (settled) return; settled = true; ws.close(); resolve(result); };
ws.onopen = () => {
ws.send(JSON.stringify({ token: GROQ_API_KEY, audio_b64: base64, mime: blob.type || 'audio/webm' }));
console.log('[WS] sent');
};
const ws = new WebSocket('wss://proxy.kube5s.ru/ws');
const timeout = setTimeout(() => { console.log('[WS] timeout'); done({ text: '', error: 'timeout' }); }, 60000);
ws.onmessage = (e) => {
clearTimeout(timeout); ws.close();
const data = JSON.parse(e.data);
console.log('[WS] ← ' + ((performance.now()-tStart)/1000).toFixed(2) + 's → ' + (data.text||'(empty)'));
resolve(data.error ? { text: '', error: data.error } : { text: data.text || '', error: null });
};
ws.onopen = () => {
setTimeout(() => {
try {
if (ws.readyState === WebSocket.OPEN) {
ws.send(JSON.stringify({ token: GROQ_API_KEY, audio_b64: base64, mime: blob.type || 'audio/webm' }));
console.log('[WS] sent');
} else {
console.log('[WS] not open, state=' + ws.readyState);
clearTimeout(timeout);
done({ text: '', error: 'network' });
}
} catch (e) {
console.log('[WS] send error:', e);
clearTimeout(timeout);
done({ text: '', error: 'network' });
}
}, 0);
};
ws.onerror = () => { clearTimeout(timeout); resolve({ text: '', error: 'network' }); };
} catch (err) {
resolve({ text: '', error: 'network' });
}
ws.onmessage = (e) => {
clearTimeout(timeout);
const data = JSON.parse(e.data);
console.log('[WS] ← ' + ((performance.now()-tStart)/1000).toFixed(2) + 's → ' + (data.text||'(empty)'));
done(data.error ? { text: '', error: data.error } : { text: data.text || '', error: null });
};
ws.onerror = () => { console.log('[WS] error'); clearTimeout(timeout); done({ text: '', error: 'network' }); };
ws.onclose = (e) => { console.log('[WS] close code=' + e.code + ' reason=' + e.reason); clearTimeout(timeout); done({ text: '', error: 'network' }); };
});
}