Merge pull request #131 from thieren/next

Fix aborted streaming

.gitignore

@@ -125,4 +125,6 @@ dist
 
 .github/workflows/
 
-.angular
+.angular
+
+homebridge-ui/

CHANGELOG.md

@@ -2,28 +2,13 @@
 
 You can find the complete detailled changelog for every beta release [here](https://github.com/homebridge-eufy-security/plugin/releases).
 
-## 2.1.0-beta.14 (01/08/2022) - latest changes
-
-### Added
-
-- Presets (`copy`, `performance`) for advanced video config
-- Setting to choose audio sample rate
-
-### Changed
-
-- Refactored ffmpeg processing
-- Updated eufy-security-client to 2.1.2
-- Deprecated options `forcerefreshsnap` and `useEnhancedSnapshotBehaviour` were removed and will no longer be evaluated
-- Removed `mapvideo`, `mapaudio`, `maxDelay` and `forceMax` options from advanced VideoConfig since they are deprecated
-- By default the plugin will now use one ffmpeg process for video and audio - this can be controlled via an option (`useSeparateProcesses` is now used instead of `useOneProcess`)
+## 2.1.0-rc.1 - latest changes
 
 ### Fixed
 
-- Fix issue that streams were only rendered in 640x480 - see #46
-- Fixed smartlocks - see #110
-- Fixed occasional EPIPE Error when streaming - see #14
+- Streams might have been aborted after 30-60 seconds due to stream backpressuring
 
-## 2.1.0 (beta) - complete changes of the beta so far (19/07/2022)
+## 2.1.0 (RC)
 
 ### Added
 

src/plugin/utils/ffmpeg.ts

@@ -593,11 +593,11 @@ export class FFmpeg extends EventEmitter {
     this.stdin = this.process.stdin;
     this.stdout = this.process.stdout;
 
-    if (this.parameters[0].debug) {
-      this.process.stderr.on('data', (chunk) => {
+    this.process.stderr.on('data', (chunk) => {
+      if (this.parameters[0].debug) {
         this.log.debug(this.name, 'ffmpeg log message:\n' + chunk.toString());
-      });
-    }
+      }
+    });
 
     this.process.on('error', this.onProcessError.bind(this));
     this.process.on('exit', this.onProcessExit.bind(this));
@@ -615,11 +615,11 @@ export class FFmpeg extends EventEmitter {
     return new Promise((resolve, reject) => {
       this.process = spawn(this.ffmpegExec, processArgs.join(' ').split(/\s+/), { env: process.env });
 
-      if (this.parameters[0].debug) {
-        this.process.stderr.on('data', (chunk) => {
+      this.process.stderr.on('data', (chunk) => {
+        if (this.parameters[0].debug) {
           this.log.debug(this.name, 'ffmpeg log message:\n' + chunk.toString());
-        });
-      }
+        }
+      });
 
       const killTimeout = setTimeout(() => {
         this.stop();