Fixed winston transport output

Author: christiand93

cf-nodejs-logging-support-winston/winston-transport.js

@@ -9,12 +9,18 @@ const CfNodejsLoggingSupportLogger = class CfNodejsLoggingSupportLogger extends
         this.logMessage = options.logMessage;
     }
 
-    log(info) {
+    log(info, callback) {
+        setImmediate(() => {
+            this.emit('logged',info);
+        });
+        
         if (info[SPLAT]) {
             this.logMessage.apply(this, [info.level, info.message, ...info[SPLAT]]);
         } else {
             this.logMessage(info.level, info.message);
         }
+
+        callback();
     }
 };
 

package-lock.json

@@ -5,7 +5,8 @@
     "main": "web.js",
     "license": "Apache-2.0",
     "scripts": {
-        "test": "echo \"Error: no test specified\" && exit 1"
+        "test": "echo \"Error: no test specified\" && exit 1",
+        "start": "node web.js"
     },
     "keywords": [
         "example",

sample/winston-sample/package-lock.json

@@ -11,6 +11,7 @@ var logger = winston.createLogger({
 
 app.get('/', function (req, res) {
     res.send('Hello World');
+    logger.log("info", "Received request");
 });
 
 app.listen(3000);

sample/winston-sample/package.json

@@ -29,11 +29,15 @@ describe('Test winston-transport.js', function () {
             info.level = "error";
             info.message = "test"
 
-            transport.log(info);
+            var called = false;
+            var callback = () => {called = true}
+
+            transport.log(info, callback);
 
             catchedArgs.length.should.equal(2);
             catchedArgs[0].should.equal("error");
             catchedArgs[1].should.equal("test");
+            called.should.equal(true)
         });
 
         it('Test log method (message with additional variables)', function () {
@@ -43,13 +47,17 @@ describe('Test winston-transport.js', function () {
             info.message = "test %d %s"
             info[SPLAT] = [42, "abc"]
 
-            transport.log(info);
+            var called = false;
+            var callback = () => {called = true}
+
+            transport.log(info, callback);
 
             catchedArgs.length.should.equal(4);
             catchedArgs[0].should.equal("error");
             catchedArgs[1].should.equal("test %d %s");
             catchedArgs[2].should.equal(42);
             catchedArgs[3].should.equal("abc");
+            called.should.equal(true)
         });
     });