Unify fourth-wall voice playback with TTS synth runtime

modules/fourth-wall/fw-voice-runtime.js

@@ -0,0 +1,132 @@
+// ════════════════════════════════════════════
+// 语音运行时 - 统一合成与互斥播放
+// ════════════════════════════════════════════
+
+import { normalizeEmotion } from '../tts/tts-text.js';
+
+let currentAudio = null;
+let currentObjectUrl = null;
+let currentAbort = null;
+let currentRequestId = null;
+
+/**
+ * 合成并播放语音（后播覆盖前播）
+ *
+ * @param {string} text - 要合成的文本
+ * @param {string} [emotion] - 原始情绪字符串（自动 normalize）
+ * @param {Object} [callbacks] - 状态回调
+ * @param {string} [callbacks.requestId] - 请求标识，用于防时序错乱
+ * @param {(state: string, info?: object) => void} [callbacks.onState] - 状态变化回调
+ *   state: 'loading' | 'playing' | 'ended' | 'error' | 'stopped'
+ *   info: { duration?, message? }
+ * @returns {{ stop: () => void }} 控制句柄
+ */
+export function synthesizeAndPlay(text, emotion, callbacks) {
+    const requestId = callbacks?.requestId || `vr_${Date.now()}_${Math.random().toString(36).slice(2, 8)}`;
+    const onState = callbacks?.onState;
+
+    // 停掉前一个（回传 stopped）
+    stopCurrent();
+
+    const abortController = new AbortController();
+    currentAbort = abortController;
+    currentRequestId = requestId;
+
+    const notify = (state, info) => {
+        if (currentRequestId !== requestId && state !== 'stopped') return;
+        onState?.(state, info);
+    };
+
+    notify('loading');
+
+    const run = async () => {
+        const synthesize = window.xiaobaixTts?.synthesize;
+        if (typeof synthesize !== 'function') {
+            throw new Error('请先启用 TTS 模块');
+        }
+
+        const blob = await synthesize(text, {
+            emotion: normalizeEmotion(emotion || ''),
+            signal: abortController.signal,
+        });
+
+        if (abortController.signal.aborted) return;
+        if (currentRequestId !== requestId) return;
+
+        const url = URL.createObjectURL(blob);
+        const audio = new Audio(url);
+
+        // 清理旧的（理论上 stopCurrent 已清理，防御性）
+        cleanup();
+
+        currentAudio = audio;
+        currentObjectUrl = url;
+
+        audio.onloadedmetadata = () => {
+            if (currentRequestId !== requestId) return;
+            notify('playing', { duration: audio.duration || 0 });
+        };
+
+        audio.onended = () => {
+            if (currentRequestId !== requestId) return;
+            notify('ended');
+            cleanup();
+        };
+
+        audio.onerror = () => {
+            if (currentRequestId !== requestId) return;
+            notify('error', { message: '播放失败' });
+            cleanup();
+        };
+
+        await audio.play();
+    };
+
+    run().catch(err => {
+        if (abortController.signal.aborted) return;
+        if (currentRequestId !== requestId) return;
+        notify('error', { message: err?.message || '合成失败' });
+        cleanup();
+    });
+
+    return {
+        stop() {
+            if (currentRequestId === requestId) {
+                stopCurrent();
+            }
+        },
+    };
+}
+
+/**
+ * 停止当前语音（合成中止 + 播放停止 + 资源回收）
+ */
+export function stopCurrent() {
+    if (currentAbort) {
+        try { currentAbort.abort(); } catch { }
+        currentAbort = null;
+    }
+
+    cleanup();
+
+    currentRequestId = null;
+}
+
+// ════════════════════════════════════════════════════════════════════════════
+// 内部
+// ════════════════════════════════════════════════════════════════════════════
+
+function cleanup() {
+    if (currentAudio) {
+        currentAudio.onloadedmetadata = null;
+        currentAudio.onended = null;
+        currentAudio.onerror = null;
+        try { currentAudio.pause(); } catch { }
+        currentAudio = null;
+    }
+
+    if (currentObjectUrl) {
+        URL.revokeObjectURL(currentObjectUrl);
+        currentObjectUrl = null;
+    }
+}