спасибо!

Вчера сделал прототип либы, которая реализует аналог горутин для ноды. Но работы и бета-тестирования еще много, присоединяйтесь. https://github.com/metarhia/noroutine

Доброе утро всем.
В моем коде реконекта до rabbitMQ есть утечка пам'яти:
1. Если сервер недоступен делаю реконект путем вызова той самой функции(рекурсия) что не есть хорошо
2. Хотелось бы что-бы удалился старий контекст коллбека но чот пока не могу понять даже как в памяти это работает

amqp.connect(amqp://${rabbitMQUrl}, ( err: any, conn: Connection) => {
           if (err) {
               this._logger.error("[AMQP]", err);
               return setTimeout(this.createConnection.bind(this), 1000);
           }

           conn.on("error", err => {
               this._logger.error("[AMQP]", err);
               if (err.message !== "Connection closing") {
                   this._logger.error(err);
               }
           });
           conn.on("close", () => {
               this._logger.debug("[AMQP] reconnecting");
               return setTimeout(this.createConnection.bind(this), 1000);
           });

           this._logger.debug("[AMQP] connected");
       });


Заранее всем спасибо

Привет. Пытаюсь реализовать на ноде следующие:

Принимаю json post запросом (express) и передаю post запросом на сторонние апи (node-fetch).
В случае ошибки передачи ложу этот JSON в замыкание и сеттаймаутом повторяю отправку некоторое количество раз.

Проблема в том, что мне нужно после того как принял данные, закрыть средине, а это прерывает выполнение функций которая должна повторять запрос.

подскажите как вообще реализовать подобный функционал?
Буду благодарен за любой ответ

Насколько будет адекватным решение в случае ошибки передачи писать данные в файл и в случае появления файла запускать функцию для повторной отправки с последующим удалением файла в случае успеха?

Это ужасно

посмотрите в сторону инстументов, которые занимаются schedule задачами

Спасибо!

Вообще меня немного смущает количество зависимостей которые приходится тянуть в крошечный проект... Я Неделю изобретал fetch, пришлось затащить node-fetch, теперь вот 4 дня пытаюсь реализовать вроде как простую вещь, а нужно еще пол npm-а выкачать...

Мне нужно повторить несколько раз отправку и если не отправил, дать возможность забрать эти данные запросом из вне. Вот очень надеюсь что должен быть способ сделать это +- просто и без кучи зависимостей...

а зачем фетч понадобился?

Отправлять JSON на сторонние апи

ну есть встроенный http(s).request

чую, пока что, сложновато, в части бюрократии. Надо потренироваться на более простом source project.
Пару вопросов если можно
Что подразумевается под "новые внешние методы"?
Что подразумевается под "внутренее не публичное апи"?

У меня не получилось, здесь посоветовали несколько пакетов и с фетчем вышло сразу

:)

понятно 😐

пока не вижу зачем вам пакеты сторонние

так тут посоветовали, зачем еще то

а что именно не получилось?