fix: do not open a new ws connection if already existing

src/index.mjs

@@ -47,9 +47,12 @@ export function websocketStore(url, initialValue, socketOptions) {
     }
 
     // we are still in the opening phase
-    if(openPromise) {
+    if (openPromise) {
       return openPromise;
     }
+    if (socket) {
+      return
+    }
 
     socket = new WebSocket(url, socketOptions);
 

tests/store-ava.mjs

@@ -96,3 +96,21 @@ test.skip("failing subscription", async t => {
 
   t.true(true);
 });
+
+test("should not open a new ws connection if already existing", async t => {
+  let counter = 0;
+  t.context.wss.on('connection', () => { counter += 1 })
+
+  const store = websocketStore(`ws://localhost:${t.context.port}`, "INITIAL");
+
+  const unsubscribe = store.subscribe(value => {});
+  await wait(300);
+  const anotherUnsubscribe = store.subscribe(value => {});
+
+  await wait(50);
+
+  unsubscribe();
+  anotherUnsubscribe();
+
+  t.is(counter, 1)
+})