sendWithCondition

Author: GrosSacASac

js/network/onewaydata/changelog.md

@@ -1,3 +1,7 @@
+# 6.2.0
+
+ * add .sendWithCondition(messageObject, condition)
+
 # 6.1.0
 
  * data must be a string
@@ -10,7 +14,7 @@
  * Completed Readme
  * Better handling of badly formatted requests
  * Set reconnection time to 10000ms
- * Add possibility to change reconnection time with reconnectionTimeh
+ * Add possibility to change reconnection time with reconnectionTime
  * Removed a weird condition
  * Simplify code with optional chaining
  * Fix reconnection

js/network/onewaydata/examples/client.html

@@ -28,7 +28,7 @@ <h2>Message sent with event type football/goal</h2>
     const li = document.createElement(`li`);
     li.textContent = `goal for ${event.data}`;
     goals.appendChild(li);
-});     
+});
 </script>
 </body>
 </html>

js/network/onewaydata/readme.md

@@ -39,6 +39,17 @@ eventStream.on(RECONNECT, ({lastId, response}) => {
         sendOne(response, `here is what you missed since last disconnection`);
     }
 });
+
+// eventStream.off(RECONNECT); // unsubscribe
+// eventStream.close(); // closes all eventStream 
+// eventStream.setAndSendId(); // shorthand to send id only and saving lastEventId
+// same as send but takes a filter function 
+eventStream.sendWithCondition({
+    data: `latitude434521, longitude`,
+    event: "fire"},
+    function (request, response) {
+        return request.isFirefighter; // only send to isFirefighter === true
+});
 ```
 
 ### with express/polka

js/network/onewaydata/source/onewaydata.js

@@ -76,6 +76,7 @@ const createEventStream = (options) => {
     const eventStream = Emitter({ lastEventId: 0 });
 
     let responses = [];
+    let requests = [];
     let onRequest;
 
     const requestHandler = (request, response) => {
@@ -94,6 +95,7 @@ const createEventStream = (options) => {
             [`Content-Type`]: MIME,
         });
         responses.push(response);
+        requests.push(request);
 
         const lastId = request.headers[LAST_ID];
         if (lastId) {
@@ -110,6 +112,7 @@ const createEventStream = (options) => {
             const index = responses.indexOf(response);
             if (index !== -1) {
                 responses.splice(index, 1);
+                requests.push(index, 1);
                 eventStream.emit(DISCONNECT, { response });
             }
         });
@@ -124,7 +127,9 @@ const createEventStream = (options) => {
         responses.forEach(response => {
             response.end();
         });
-        responses = [];
+        responses = undefined;
+        requests = undefined;
+        eventStream.off()
     };
 
     const setAndSendId = (id) => {
@@ -142,6 +147,15 @@ const createEventStream = (options) => {
         });
     };
 
+    const sendWithCondition = (messageObject, condition) => {
+        const message = formatEvent(messageObject);
+        responses.forEach((response, i) => {
+            if (condition(requests[i], response)) {
+                response.write(message);
+            }
+        });
+    };
+
     if (asMiddleWare) {
         eventStream.middleWare = (request, response, next) => {
             const handled = requestHandler(request, response);
@@ -152,14 +166,15 @@ const createEventStream = (options) => {
     } else {
         onRequest = (request, response) => {
             if (condition(request)) {
-                requestHandler(request, response, responses);
+                requestHandler(request, response);
             }
         };
         server.on(`request`, onRequest);
     }
 
     return Object.assign(eventStream, {
         send,
+        sendWithCondition,
         setAndSendId,
         close,
     });