Added new subscriber callback

README.md

@@ -22,6 +22,12 @@ var app = express();
 var longpoll = require("express-longpoll")(app)
 // You can also enable debug flag for debug messages
 var longpollWithDebug = require("express-longpoll")(app, { DEBUG: true });
+// You can also specify a function that is called when a new longpoll request is made
+var longpollWithDebugAndCallback = require("express-longpoll")(app, { DEBUG: true, 
+    subscriberCallback: function (id){ 
+      console.log (`New subscriber with id: ${id}`);
+    } 
+  });
 ```
 
 **Quick-start code**  

examples/basic/server.js

@@ -1,7 +1,10 @@
 var express = require('express');
 var app = express();
 const longpoll = require("../../index.js")(app, {
-    DEBUG: true
+    DEBUG: true,
+    subscriberCallback: function (id) {
+      console.log(`Subscriber Callback with id: ${id}`);
+    }
 });
 
 app.use((req, res, next) => {

index.js

@@ -7,6 +7,7 @@ var longpoll = function(app, opts) {
     // Default Config
     var config = {
         DEBUG: false,
+        subscriberCallback: null,
         events: {
             maxListeners: 0 // unlimited
         }
@@ -125,7 +126,7 @@ var longpoll = function(app, opts) {
                         eventId = eventId + "." + req.id;
                         // Clear all previous events for the ID, we only need one
                         log("Old Events cleared: ", url, eventId);
-                        dispatcher.removeAllListeners([eventId]);
+                        dispatcher.removeAllListeners(eventId);
                     }
 
                     // Method that Creates event listener
@@ -140,6 +141,11 @@ var longpoll = function(app, opts) {
 
                     // Create it
                     sub(res);
+
+                    // New subscriber callback
+                    if (config.subscriberCallback){
+                      config.subscriberCallback(req);
+                    };
                 });
                 resolve();
             });

package.json

@@ -16,7 +16,7 @@
   "dependencies": {
     "bluebird": "^3.5.0",
     "eventemitter2": "3.0.0",
-    "lodash": "4.17.4"
+    "lodash": ">=4.17.5"
   },
   "devDependencies": {
     "chai": "^3.5.0",