| 90 | } |
| 91 | |
| 92 | function subscribe( |
| 93 | namespaceName: string, |
| 94 | socket: Socket, |
| 95 | isNew: boolean, |
| 96 | rooms: Set<Room> |
| 97 | ) { |
| 98 | // @ts-ignore |
| 99 | const sessionId = socket.conn.id; |
| 100 | // @ts-ignore |
| 101 | const websocket: WebSocket = socket.conn.transport.socket; |
| 102 | if (isNew) { |
| 103 | debug("subscribe connection %s to topic %s", sessionId, namespaceName); |
| 104 | websocket.subscribe(namespaceName); |
| 105 | } |
| 106 | rooms.forEach((room) => { |
| 107 | const topic = `${namespaceName}${SEPARATOR}${room}`; // '#' can be used as wildcard |
| 108 | debug("subscribe connection %s to topic %s", sessionId, topic); |
| 109 | websocket.subscribe(topic); |
| 110 | }); |
| 111 | } |
| 112 | |
| 113 | export function restoreAdapter() { |
| 114 | Adapter.prototype.addAll = addAll; |