Может кто то подсказать все таки как сделать двунаправленное соединение

на тех же вебсокетах без получения циклической зависимости в коде приложения? Несколько раз задавал этот вопрос, но чет не догоняю как решить

Берем тот же чат. С одной стороны нужно получить новое сообщение от юзера, сделать с ним какую то логику в другом файле (хоть записать в бд, хоть залогировать, хоть какую то метрику увеличть). С другой стороны, нужно в файле с логикой отправить этому же юзеру какой то ивент, который возникает в результате какой то логики в том же файле, либо например в результате вызова функции из этого файла другим модулем . И получается один файл require-ит другой. Как быть? Спасибо

Не до конца понятно, в чём именно проблема

в том что в таком случае circular dependency, что require не позволяет сделать

Вынести все events в отдельный файл и подключать его из обоих файлов

"вынести все events" - что именно имеется ввиду, обработчики на них?

У меня есть интересная на этот счёт наработка, могу поделиться

буду благодарен, давай

Для простоты буду считать что ты пользуешься ws, ну или как-нибудь воссоздашь EventEmitter API поверх того что в офф.сокетах.

Смотри, копируешь этот код к себе https://github.com/Hedronium/event-multiplexer/blob/master/src/index.js Далее заводишь себе инстанс EventMultiplexer и регаешь на него хендлеры вебсокетовых событий.

Дай ссылку на твой код, где циклические зависимости

постараюсь минимальный пример без привязанности к моему проекту написать и так скину

Ну а сейчас будет магия. Все новые соедлинения просто добавляешь через add.

Вся логика зареганная на этом этапе автоматически применяется для добавленных так подключений Сейчас покажу пример кода.

export class Adaptor<Connection extends EE> extends EventMultiplexer<Connection> { constructor() { super(); this.on("close", this.remove); this.on("open", this.add); this.on("message", onMessage); } public handleConnection = (c: Connection) => { this.emit("open", c); return this; } } function onMessage<C extends EE>(this: Adaptor<C>, remote: C, messages: Buffer) { console.log(messages.length) const record = decode(messages) this.emit("incoming", record, reply) function reply(answer: any) { // @ts-ignore remote.send(encode(answer)) } }

спасибо

может быть я не прав, но сокеты и так двунаправленные - как сервер может что хочет и сколько хочет слать клиенту, так и наоборот)) проблема не в архитектуре приложения?

Обрати внимание, что код написан специально так, чтобы в принципе не создавать замыкания кроме как при его старте.

Но при этом все нужные вещи передаются вместе с событием — конкретный сокет и само событие, ну и reply

Не надо смешивать все в кучу. За принятие и отправку отвечает контроллер, а обрабатывет данные сервис, из него не надо посылать ни каких данных, он возвращает результат в контроллер