save

libs/server/src/broadcast/rediscast.ts

@@ -1,12 +1,14 @@
 import { Redis, type RedisOptions } from "ioredis"
 import type { WsxSocket } from "../socket"
+import { genId } from "../utils/gen-id"
 import { Broadcast, broadcastSymbols } from "./broadcast"
 import type { Topic } from "./topic"
 
 /**
  * Redis broadcast. Shares actions via Redis Pub/Sub
  */
 export class Rediscast extends Broadcast {
+	private id: string = genId()
 	redis: Redis
 	prefix: string
 

libs/server/src/socket/index.ts

@@ -1,5 +1,6 @@
 import type { ServerWebSocket } from "bun"
 import type { Topic } from "../broadcast"
+import { genId } from "../utils/gen-id"
 import * as symbols from "./symbols"
 export { symbols as socketSymbols }
 
@@ -14,11 +15,7 @@ export type WsxRawSocket = ServerWebSocket<{
  */
 export class WsxSocket<Ws extends WsxRawSocket = WsxRawSocket> {
 	constructor(public raw: Ws) {
-		if (!this.id) {
-			const array = new Uint32Array(1)
-			crypto.getRandomValues(array)
-			this.id = array[0].toString()
-		}
+		this.id ??= genId()
 	}
 
 	static reuse(ws: WsxRawSocket): WsxSocket {

libs/server/src/utils/gen-id.ts

@@ -0,0 +1,5 @@
+export function genId() {
+	const array = new Uint32Array(1)
+	crypto.getRandomValues(array)
+	return array[0].toString()
+}