feat(dashboard/test): Added tests for dashboard endpoints

Author: kushagra0902

test/unit/dashboard-service/app.spec.ts

@@ -0,0 +1,43 @@
+import axios from 'axios'
+import { createDashboardService } from '../../../src/dashboard-service/app'
+import { expect } from 'chai'
+import WebSocket from 'ws'
+
+describe('dashboard-service app', () => {
+  it('serves health, snapshot, and websocket endpoints', async () => {
+    const service = createDashboardService({
+      host: '127.0.0.1',
+      port: 0,
+      wsPath: '/api/v1/kpis/stream',
+      pollIntervalMs: 1000,
+    })
+
+    await service.start()
+
+    const port = service.getHttpPort()
+
+    const healthResponse = await axios.get(`http://127.0.0.1:${port}/healthz`)
+    expect(healthResponse.status).to.equal(200)
+
+    const snapshotResponse = await axios.get(`http://127.0.0.1:${port}/api/v1/kpis/snapshot`)
+    expect(snapshotResponse.status).to.equal(200)
+
+    const snapshotJson = snapshotResponse.data as any
+    expect(snapshotJson.data).to.have.property('sequence')
+
+    const ws = new WebSocket(`ws://127.0.0.1:${port}/api/v1/kpis/stream`)
+
+    const connectedEvent = await new Promise<any>((resolve, reject) => {
+      const timeout = setTimeout(() => reject(new Error('timeout waiting for ws message')), 2000)
+      ws.once('message', (raw) => {
+        clearTimeout(timeout)
+        resolve(JSON.parse(raw.toString()))
+      })
+    })
+
+    expect(connectedEvent).to.have.property('type', 'dashboard.connected')
+
+    ws.close()
+    await service.stop()
+  })
+})

test/unit/dashboard-service/polling-scheduler.spec.ts

@@ -0,0 +1,39 @@
+import { expect } from 'chai'
+import Sinon from 'sinon'
+
+import { PollingScheduler } from '../../../src/dashboard-service/polling/polling-scheduler'
+
+describe('PollingScheduler', () => {
+  let clock: Sinon.SinonFakeTimers
+
+  beforeEach(() => {
+    clock = Sinon.useFakeTimers()
+  })
+
+  afterEach(() => {
+    clock.restore()
+  })
+
+  it('runs tick callback on interval while running', async () => {
+    const tick = Sinon.stub().resolves(undefined)
+    const scheduler = new PollingScheduler(1000, tick)
+
+    scheduler.start()
+    await clock.tickAsync(3000)
+
+    expect(tick.callCount).to.equal(3)
+    scheduler.stop()
+  })
+
+  it('stops running when stop is called', async () => {
+    const tick = Sinon.stub().resolves(undefined)
+    const scheduler = new PollingScheduler(500, tick)
+
+    scheduler.start()
+    await clock.tickAsync(1000)
+    scheduler.stop()
+    await clock.tickAsync(1000)
+
+    expect(tick.callCount).to.equal(2)
+  })
+})