update query to search inside archive files

Author: Matt Berther

daily-rotate-file.js

@@ -190,9 +190,16 @@ DailyRotateFile.prototype.query = function (options, callback) {
         var logFile = path.join(self.dirname, file);
         var buff = '';
 
-        var stream = fs.createReadStream(logFile, {
-            encoding: 'utf8'
-        });
+        var stream;
+
+        if (file.endsWith('.gz')) {
+            stream = new PassThrough();
+            fs.createReadStream(logFile).pipe(zlib.createGunzip()).pipe(stream);
+        } else {
+            stream = fs.createReadStream(logFile, {
+                encoding: 'utf8'
+            });
+        }
 
         stream.on('error', function (err) {
             if (stream.readable) {
@@ -215,7 +222,7 @@ DailyRotateFile.prototype.query = function (options, callback) {
             buff = data[l];
         });
 
-        stream.on('close', function () {
+        stream.on('end', function () {
             if (buff) {
                 add(buff, true);
             }

test/transport-tests.js

@@ -214,6 +214,28 @@ describe('winston/transports/daily-rotate-file', function () {
 
                 this.transport.close();
             });
+
+            it('should search within archived files', function (done) {
+                var opts = Object.assign({}, options);
+                opts.zippedArchive = true;
+                opts.maxSize = '1k';
+
+                this.transport = new DailyRotateFile(opts);
+
+                sendLogItem(this.transport, 'info', randomString(1056));
+                sendLogItem(this.transport, 'info', randomString(1056));
+
+                var self = this;
+
+                self.transport.on('archive', function () {
+                    self.transport.query(function (err, results) {
+                        expect(results).to.not.be.null;
+                        expect(results.length).to.equal(2);
+                        done();
+                    });
+                });
+                this.transport.close();
+            });
         });
     });
 });