chore: add tests for new functionality

Author: AlemTuzlak

packages/event-bus-client/tests/index.test.ts

@@ -3,7 +3,8 @@ import { ClientEventBus } from '@tanstack/devtools-event-bus/client'
 import { EventClient } from '../src'
 
 // start the client bus for testing
-new ClientEventBus().start()
+const bus = new ClientEventBus()
+bus.start()
 // client bus uses window to dispatch events
 const clientBusEmitTarget = window
 describe('EventClient', () => {
@@ -54,7 +55,7 @@ describe('EventClient', () => {
       const targetEmitSpy = vi.spyOn(target, 'dispatchEvent')
       const targetListenSpy = vi.spyOn(target, 'addEventListener')
       const targetRemoveSpy = vi.spyOn(target, 'removeEventListener')
-      const cleanup = client.on('test:event', () => {})
+      const cleanup = client.on('test:event', () => { })
       cleanup()
       client.emit('test:event', { foo: 'bar' })
       expect(targetEmitSpy).toHaveBeenCalledWith(expect.any(Event))
@@ -78,7 +79,7 @@ describe('EventClient', () => {
       const targetEmitSpy = vi.spyOn(target, 'dispatchEvent')
       const targetListenSpy = vi.spyOn(target, 'addEventListener')
       const targetRemoveSpy = vi.spyOn(target, 'removeEventListener')
-      const cleanup = client.on('test:event', () => {})
+      const cleanup = client.on('test:event', () => { })
       cleanup()
       client.emit('test:event', { foo: 'bar' })
       expect(targetEmitSpy).toHaveBeenCalledWith(expect.any(Event))
@@ -101,7 +102,7 @@ describe('EventClient', () => {
       })
 
       const eventBusSpy = vi.spyOn(clientBusEmitTarget, 'addEventListener')
-      client.on('event', () => {})
+      client.on('event', () => { })
       expect(eventBusSpy).toHaveBeenCalledWith(
         'test:event',
         expect.any(Function),
@@ -194,6 +195,27 @@ describe('EventClient', () => {
     })
   })
 
+  describe("queued events", () => {
+    it("emits queued events when connected to the event bus", async () => {
+      bus.stop()
+      const client = new EventClient({
+        debug: false,
+        pluginId: 'test',
+      })
+      const eventHandler = vi.fn()
+      client.on('event', eventHandler)
+      client.emit('event', { foo: 'bar' })
+
+      bus.start()
+      // wait to connect to the bus
+      await new Promise(resolve => setTimeout(resolve, 500))
+      expect(eventHandler).toHaveBeenCalledWith({
+        type: 'test:event',
+        payload: { foo: 'bar' },
+        pluginId: 'test',
+      })
+    })
+  })
   describe('onAllPluginEvents', () => {
     it('should listen to all events that come from the plugin', () => {
       const client = new EventClient({