Add debug log in subscribe

Author: canmingir

src/Event.js

@@ -1,18 +1,19 @@
 import { v4 as uuid } from "uuid";
 
 const subscriptions = {};
-const map = new Map();
+const messages = new Map();
 
 const subscribe = (type, callback) => {
   const id = uuid();
+  console.debug("react-event", "subscribe", type, id);
 
   if (!subscriptions[type]) {
     subscriptions[type] = {};
   }
 
   subscriptions[type][id] = callback;
 
-  let last = map.get(type);
+  let last = messages.get(type);
 
   if (last) {
     callback(last);
@@ -30,15 +31,22 @@ const subscribe = (type, callback) => {
 };
 
 const publish = (type, payload) => {
-  console.log("react-event", type, payload);
-  map.set(type, payload);
-  if (!subscriptions[type]) return;
+  console.log("react-event", "publish", type, payload);
+  messages.set(type, payload);
 
-  Object.keys(subscriptions[type]).forEach((key) => {
+  Object.keys(subscriptions[type] || {}).forEach((key) => {
     setTimeout(() => {
       subscriptions[type][key](payload);
     }, 0);
   });
 };
 
-export { subscribe, publish, map };
+function last(type, init) {
+  if (messages.has(type)) {
+    return messages.get(type);
+  } else {
+    return init;
+  }
+}
+
+export { subscribe, publish, messages, last };

src/test/event.test.js

@@ -1,4 +1,4 @@
-import { map, publish, subscribe } from "../Event";
+import { subscribe, publish, messages } from "../Event";
 
 describe("react-event", () => {
   it("subscribes and publishes events", (done) => {
@@ -57,7 +57,7 @@ describe("react-event", () => {
   it("registers the last published event to map", () => {
     publish("LAST_EVENT", { data: "test payload" });
 
-    const lastPublishedEvent = map.get("LAST_EVENT");
+    const lastPublishedEvent = messages.get("LAST_EVENT");
     expect(lastPublishedEvent).toEqual({ data: "test payload" });
   });
 });

src/useEvent.js

@@ -1,21 +1,12 @@
 import React from "react";
 
-import { map, publish, subscribe } from "./Event";
-
-function last(type, init) {
-  if (map.has(type)) {
-    return map.get(type);
-  } else {
-    return init;
-  }
-}
+import { publish, subscribe, last } from "./Event";
 
 const useEvent = (type = "", init) => {
   const [payload, setPayload] = React.useState(last(type, init));
 
   React.useEffect(() => {
     const registry = subscribe(type, (event) => {
-      map.set(type, event);
       setPayload(event);
     });