test

Author: vasil-cf

lib/ContainerLogger.js

@@ -131,6 +131,7 @@ 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(this._interceptDeprecatedImagesStream())
             .pipe(this._logSizeLimitStream())
             .pipe(this.stepLogger.createMaskingStream());
 
@@ -148,6 +149,7 @@ class ContainerLogger extends EventEmitter {
 
         this.handledStreams++;
         let stderrStream = stderr
+            .pipe(this._interceptDeprecatedImagesErrorStream())
             .pipe(this._logSizeLimitStream())
             .pipe(this._errorTransformerStream())
             .pipe(this.stepLogger.createMaskingStream());
@@ -182,7 +184,11 @@ class ContainerLogger extends EventEmitter {
         this.handledStreams++;
         stream.on('end', this._handleFinished.bind(this));
         stream.on('data', (chunk) => {
-            this._logMessage(Buffer.from(chunk).toString('utf-8'), isError);
+            const message = Buffer.from(chunk).toString('utf-8');
+            if (message.startsWith('[DEPRECATION NOTICE]')) {
+                logger.info(`VASIL, _handleTtyStream: ${message}`);
+            }
+            this._logMessage(message, isError);
         });
         logger.info(`Listening on stream 'data' event for container: ${this.containerId}`);
     }
@@ -233,6 +239,30 @@ class ContainerLogger extends EventEmitter {
         this.emit('message.logged', curLogSize);
     }
 
+    _interceptDeprecatedImagesStream() {
+        return new Transform({
+            transform: (data, encoding, done) => {
+                const message = data.toString('utf8');
+                if (message.startsWith('[DEPRECATION NOTICE]')) {
+                    logger.info(`VASIL: ${message}`);
+                }
+                done(null, data);
+            }
+        });
+    }
+
+    _interceptDeprecatedImagesErrorStream() {
+        return new Transform({
+            transform: (data, encoding, done) => {
+                const message = data.toString('utf8');
+                if (message.startsWith('[DEPRECATION NOTICE]')) {
+                    logger.info(`VASIL, stderr: ${message}`);
+                }
+                done(null, data);
+            }
+        });
+    }
+
     _errorTransformerStream() {
         return new Transform({
             transform: (data, encoding, done) => {