Spaces:
Paused
Paused
| // Ядро: реалтайм-шина. Ведёт Claude. | |
| // Кодекс после записи в БД вызывает bus.emit(space_id, { type, space_id, payload }). | |
| // Сокетный слой (ws.js) подписывается на эти события и рассылает клиентам. | |
| import { EventEmitter } from 'node:events'; | |
| class Bus extends EventEmitter { | |
| // emit события конкретного пространства | |
| emit(spaceId, event) { | |
| return super.emit('space:' + spaceId, event); | |
| } | |
| onSpace(spaceId, handler) { | |
| super.on('space:' + spaceId, handler); | |
| return () => super.off('space:' + spaceId, handler); | |
| } | |
| } | |
| export const bus = new Bus(); | |
| bus.setMaxListeners(0); // много подписчиков-сокетов — это норма | |