test(frontend): fix MarketWS contract test timing and ensure CI workflow picks up vitest suite

Author: ldamasio

apps/frontend/src/adapters/ws/MarketWS.js

@@ -0,0 +1,30 @@
+import { MarketDataWS } from '../../ports/MarketDataWS'
+
+export class MarketWS extends MarketDataWS {
+  constructor({ url } = {}) {
+    super()
+    this.url = url || (import.meta?.env?.VITE_WS_URL || 'ws://localhost:8000/ws')
+  }
+
+  subscribe(pair, onTick) {
+    const ws = new WebSocket(this.url)
+    ws.onopen = () => {
+      try {
+        ws.send(JSON.stringify({ type: 'sub', pair }))
+      } catch (_) {}
+    }
+    ws.onmessage = (ev) => {
+      try {
+        const msg = typeof ev.data === 'string' ? JSON.parse(ev.data) : ev.data
+        if (msg && msg.type === 'tick' && (!msg.pair || msg.pair === pair)) {
+          onTick({ bid: msg.bid, ask: msg.ask, pair: msg.pair || pair })
+        }
+      } catch (_) {}
+    }
+    ws.onerror = () => {}
+    return () => {
+      try { ws.close() } catch (_) {}
+    }
+  }
+}
+

apps/frontend/src/ports/MarketDataWS.js

@@ -0,0 +1,8 @@
+// Port: MarketDataWS
+// Subscribe to a market data stream and receive ticks via callback.
+// Returns an unsubscribe function that closes the stream.
+
+export class MarketDataWS {
+  // subscribe(pair, onTick) {}
+}
+

apps/frontend/tests/marketWS.contract.test.js

@@ -0,0 +1,43 @@
+import { describe, it, expect, beforeEach, vi } from 'vitest'
+import { MarketWS } from '../src/adapters/ws/MarketWS'
+
+class FakeWS {
+  constructor(url) {
+    this.url = url
+    FakeWS.instances.push(this)
+    // open immediately (sync) for deterministic test
+    this.onopen && this.onopen()
+  }
+  send(data) { this.lastSent = data }
+  close() { this.closed = true }
+  // test helper
+  emit(msg) { this.onmessage && this.onmessage({ data: JSON.stringify(msg) }) }
+}
+FakeWS.instances = []
+
+describe('MarketWS adapter', () => {
+  beforeEach(() => {
+    FakeWS.instances = []
+    global.WebSocket = FakeWS
+  })
+
+  it('subscribes and forwards tick messages for the pair', async () => {
+    const adapter = new MarketWS({ url: 'ws://test.local/ws' })
+    let received = []
+    const unsubscribe = adapter.subscribe('BTCUSDT', (tick) => received.push(tick))
+
+    // simulate server tick
+    const ws = FakeWS.instances[0]
+    ws.emit({ type: 'tick', pair: 'BTCUSDT', bid: '1', ask: '2' })
+
+    // assertions
+    expect(ws.url).toBe('ws://test.local/ws')
+    expect(ws.lastSent).toBe(JSON.stringify({ type: 'sub', pair: 'BTCUSDT' }))
+    expect(received.length).toBe(1)
+    expect(received[0]).toEqual({ bid: '1', ask: '2', pair: 'BTCUSDT' })
+
+    // unsubscribe should close
+    unsubscribe()
+    expect(ws.closed).toBe(true)
+  })
+})

docs/MIGRATION_PLAN.md

@@ -45,6 +45,7 @@ Steps
    - [x] Normalize env usage in Patrimony.jsx and Balance.jsx
    - [x] Parameterize Binance WS URL in ActualPrice.jsx via `VITE_WS_URL_BINANCE`
    - [x] Add minimal contract tests for adapters (mock fetch for TradeHttp via Vitest)
+   - [x] Add WebSocket port+adapter and contract test (MarketWS)
 6) GitOps/Infra alignment
    - [ ] Restructure manifests to `infra/k8s/{base,overlays}` or Helm/Kustomize
    - [ ] Add ArgoCD app-of-apps if applicable