tidy

src/network/client/nchanmessagerelay.ts

@@ -2,7 +2,7 @@ import { MessageRelay } from "./messagerelay"
 
 export class NchanMessageRelay<T> implements MessageRelay<T> {
 
-  private websockets: Map<string, WebSocket> = new Map()
+  private readonly websockets: Map<string, WebSocket> = new Map()
 
   constructor(private readonly baseURL: string) { }
 

test/server/messagerelay.spec.ts

@@ -0,0 +1,28 @@
+import "mocha"
+import { expect } from "chai"
+import { InMemoryMessageRelay } from "../mocks/inmemorymessagerelay"
+import { MessageRelay } from "../../src/network/client/messagerelay"
+
+const jestConsole = console
+
+beforeEach(() => {
+  global.console = require("console")
+})
+
+afterEach(() => {
+  global.console = jestConsole
+})
+
+describe("Lobby", () => {
+  const relay: MessageRelay<string> = new InMemoryMessageRelay<string>()
+
+  it("validate subscriber receives published message", (done) => {
+    const channel = "test"
+    const message = "hello"
+    relay.subscribe(channel, (msg) => {
+      expect(msg).to.equal(message)
+      done()
+    })
+    relay.publish(channel, message)
+  })
+})