From 1c89546b619929b196b9ea6b3b1f97d298e687b8 Mon Sep 17 00:00:00 2001
From: Benoit <benoit.91800@hotmail.fr>
Date: Tue, 26 May 2026 15:36:00 +0200
Subject: [PATCH] fix: crash EPIPE lors ecriture dans sox stdin ferme

- Ajout error handler sur playbackProcess.stdin (capture EPIPE)
- Verification stdin.writable avant write
- Stop playback loop si stdin non disponible
- Evite crash serveur lors stop/reload AudioBridge
---
 server/bridge/backends/CoreAudioBackend.js | 26 +++++++++++++++++++---
 server/config/config.yaml                  |  2 +-
 2 files changed, 24 insertions(+), 4 deletions(-)

diff --git a/server/bridge/backends/CoreAudioBackend.js b/server/bridge/backends/CoreAudioBackend.js
index 7758830..0ce6947 100644
--- a/server/bridge/backends/CoreAudioBackend.js
+++ b/server/bridge/backends/CoreAudioBackend.js
@@ -282,6 +282,16 @@ export class CoreAudioBackend extends EventEmitter {
 
       this.playbackProcess = spawn('sox', args);
 
+      // Gérer l'erreur EPIPE sur stdin (si processus se ferme)
+      this.playbackProcess.stdin.on('error', (error) => {
+        if (error.code === 'EPIPE') {
+          console.warn('⚠️  Sox playback stdin fermé (EPIPE)');
+          this.isPlaying = false;
+        } else {
+          console.error('Erreur stdin sox playback:', error);
+        }
+      });
+
       this.playbackProcess.stderr.on('data', (data) => {
         const msg = data.toString();
         if (!msg.includes('sox WARN')) {
@@ -347,22 +357,32 @@ export class CoreAudioBackend extends EventEmitter {
    */
   _startPlaybackLoop() {
     const playNextChunk = () => {
-      if (!this.isPlaying || !this.playbackProcess) return;
+      if (!this.isPlaying || !this.playbackProcess || !this.playbackProcess.stdin) {
+        return;
+      }
 
       if (this.playbackBuffer.length > 0) {
         const chunk = this.playbackBuffer.shift();
         try {
-          this.playbackProcess.stdin.write(chunk);
+          if (this.playbackProcess.stdin.writable) {
+            this.playbackProcess.stdin.write(chunk);
+          }
         } catch (error) {
           console.error('Erreur écriture stdin sox:', error);
+          this.isPlaying = false;
+          return;
         }
       } else {
         // Buffer vide : underrun (silence)
         const silenceBuffer = Buffer.alloc(this.options.framesPerBuffer * 2 * this.options.channels);
         try {
-          this.playbackProcess.stdin.write(silenceBuffer);
+          if (this.playbackProcess.stdin.writable) {
+            this.playbackProcess.stdin.write(silenceBuffer);
+          }
         } catch (error) {
           // Ignore si process fermé
+          this.isPlaying = false;
+          return;
         }
         this.emit('bufferUnderrun');
       }
diff --git a/server/config/config.yaml b/server/config/config.yaml
index 671b8c9..f03b287 100644
--- a/server/config/config.yaml
+++ b/server/config/config.yaml
@@ -5,7 +5,7 @@ audio:
   jitterBufferMs: 40
   device:
     inputDeviceId: 1
-    outputDeviceId: 2
+    outputDeviceId: 0
     sampleRate: 48000
   routing:
     inputToGroup: