fix: parse only stderr

Author: vasil-cf

lib/ContainerLogger.js

@@ -135,7 +135,6 @@ class ContainerLogger extends EventEmitter {
         // { end = false } on the stepLoggerWritableStream because there is only one instance of it for all the steps.
         this.handledStreams++;
         let stdoutStream = stdout
-            .pipe(new DeprecatedImagesInterceptorStream())
             .pipe(this._logSizeLimitStream())
             .pipe(this.stepLogger.createMaskingStream());
 
@@ -186,37 +185,47 @@ class ContainerLogger extends EventEmitter {
 
     _handleTtyStream(stream, isError) {
         this.handledStreams++;
-        const deprecatedImagesInterceptor = new DeprecatedImagesInterceptorStream(true);
+        const deprecatedImagesInterceptor = isError && new DeprecatedImagesInterceptorStream(true);
         stream.on('end', () => {
             this._handleFinished();
-            deprecatedImagesInterceptor.end();
+            if (isError) {
+                deprecatedImagesInterceptor.end();
+            }
         });
         stream.on('data', (chunk) => {
-            deprecatedImagesInterceptor.write(chunk);
+            if (isError) {
+                deprecatedImagesInterceptor.write(chunk);
+            }
             this._logMessage(Buffer.from(chunk).toString('utf-8'), isError);
         });
         logger.info(`Listening on stream 'data' event for container: ${this.containerId}`);
     }
 
     _handleNonTtyStream(stream, isError) {
         this.handledStreams++;
-        const deprecatedImagesInterceptor = new DeprecatedImagesInterceptorStream(true);
+        const deprecatedImagesInterceptor = isError && new DeprecatedImagesInterceptorStream(true);
         stream.on('readable', () => {
             let header = stream.read(8);
             while (header !== null) {
-                deprecatedImagesInterceptor.write(header);
+                if (isError) {
+                    deprecatedImagesInterceptor.write(header);
+                }
                 const payload = stream.read(header.readUInt32BE(4));
                 if (payload === null) {
                     break;
                 }
-                deprecatedImagesInterceptor.write(payload);
+                if (isError) {
+                    deprecatedImagesInterceptor.write(payload);
+                }
                 this._logMessage(Buffer.from(payload).toString('utf8'), isError);
                 header = stream.read(8);
             }
         });
         stream.on('end', () => {
             this._handleFinished();
-            deprecatedImagesInterceptor.end();
+            if (isError) {
+                deprecatedImagesInterceptor.end();
+            }
         });
         logger.info(`Listening on stream 'readable' event for container: ${this.containerId}`);
     }