Как получить 2 ответа от сервера исользуя Promise?

Question

[Viacheslav]

По запросу с сервера возвращается 2 строки ответа по очереди, В коде получаю только одну!

const net = require("net");

const HOST = '192.168.0.75';
const PORT = '30001';

class Api {

    constructor(host, port) {
        this.HOST = host || HOST;
        this.PORT = port || PORT;
        this.socket = new net.Socket();

        this.init();
    }

    init() {
        const client = this;

        client.socket.connect(client.PORT, client.HOST, () => {
            console.log(`Client connected to: ${client.HOST}:${client.PORT}`);
        });

        client.socket.on('close', () => {
            console.log('FiscalAPI: connection closed');
        });
    };

    sendCommand(cmd) {
        const client = this;

        return new Promise((resolve, reject) => {
            if(cmd) {
                client.socket.write(cmd + '\u0000\r\n');
            }

            client.socket.on('data', (data) => {
                    resolve(data.toString());
            });

            client.socket.on('error', (error) => {
                reject(error);
            });
        });
    };

    checkPumpState(dispenser_index){
        this.sendCommand('0;open')
            .then((data) => {
                console.log(data);
                return this.sendCommand(`0;dispenser_get;${dispenser_index};1`);
            })
            .then((data) => {
                console.log(data);
                return this.sendCommand(`0;store_get;0;16\u0000\r\n`);
            })
            .then((data) => {
                console.log(data);
            })
            .catch((error) => console.log(error));
    }
}

по каждому запросу возвращается 2 ответа. Первый: echo запроса, второй: нужный для продолжения результат.
Этим кодом удается получить только первый ответ - echo. Как получить и второй тоже?

P.S.
Еще важный момент: ЗАПРОСЫ-ОТВЕТЫ должны идти в строгой последовательности, ответ на предыдущий запрос может использоваться как данные для следующего

Comments

[Viacheslav]

user_test_345, нет

[Viacheslav]

то я тестил, забыл убрать

[Viacheslav]

user_test_345, нет

[Модератор]

slaaavyn, дорогой пользователь, настоятельно рекомендуем еще раз обратить самое пристальное внимание на п. 3.1 регламента работы сервиса (и, в особенности, на его последний абзац). В противном случае, ваши вопросы будут удаляться по причине тег-спама, а систематические нарушения приведут к блокировке учетной записи.

[Aves]

slaaavyn,

const net = require('net');

const HOST = '192.168.0.75';
const PORT = '30001';

class Api {
  constructor(host, port) {
    this.HOST = host || HOST;
    this.PORT = port || PORT;
    this.socket = new net.Socket();

    this.socket.connect(this.PORT, this.HOST, () => {
      console.log(`Client connected to: ${this.HOST}:${this.PORT}`);
    });

    this.socket.on('close', () => {
      console.log('FiscalAPI: connection closed');
    });
  }

  clearListeners(data, error) {
    this.socket.off('data', data);
    this.socket.off('error', error);
  }

  sendCommand(cmd) {
    if(cmd) {
      this.socket.write(cmd + '\u0000\r\n');
    
      return new Promise((resolve, reject) => {
        const chunks = [];
        
        const handleData = chunk => {
          chunks.push(chunk);
          const data = Buffer.concat(chunks).toString().match(/.*?\r\n/g);
          if (data.length > 1) {
            resolve(data);
            this.clearListeners(handleData, handleError);
          }
        };

        const handleError = err => {
          reject(err);
          this.clearListeners(handleData, handleError);
        };

        this.socket.on('data', handleData);
        this.socket.on('error', handleError);
      });
    }
  }

  checkPumpState(dispenser_index){
    this.sendCommand('0;open')
      .then(([echo, data]) => {
        console.log(`echo: ${echo}data: ${data}`);
        return this.sendCommand(`0;dispenser_get;${dispenser_index};1`);
      })
      .then(([echo, data]) => {
        console.log(`echo: ${echo}data: ${data}`);
        return this.sendCommand(`0;store_get;0;16`);
      })
      .then(([echo, data]) => {
        console.log(`echo: ${echo}data: ${data}`);
      })
      .catch((error) => console.log(error));
  }
}

[Viacheslav]

Aves, Спасибо, завтра попробую. Выглядит правдоподобно)

[Viacheslav]

Aves, К сожалению не прокатило. Строки приходят с разной скоростью. Нужно дождаться вторую строку. Если сервер успевает откинуть две строки пока в коде еще слушаем ответы, тогда код срабатывает, если не успевает то перехватывается только первая строка.

[Alex]

slaaavyn, В смысле не успевает? Мне казалось ваша реализация обязана ждать ответ столько сколько нужно.

[Viacheslav]

s6c2@Kozack, Да, но она ждет только один ответ, а нужно ждать 2 socket.on('data'). По первому приходит echo а по второму нужный для продолжения ответ.

Answer 1

[Alex]

Я не очень понимаю что тут происходит, но предположу что у вас событие client.socket.on('data') вызывается два раза — для каждого ответа от сервера. А промис вы возвращаете сразу как получили первый ответ.

UPD принимаете все данные, но возвращаете только по событию 'end'

sendCommand(cmd) {
    if(cmd) {
      this.socket.write(cmd + '\u0000\r\n');
    }
    
      return new Promise((resolve, reject) => {
        const chunks = [];
        
        const handleData = chunk => {
          chunks.push(chunk);
        };

        const handleError = err => {
          reject(err);
        };

        const handleEnd => {
          const data = Buffer.concat(chunks).toString().match(/.*?\r\n/g);
          resolve(data);
        }

        this.socket.on('data', handleData);
        this.socket.on('error', handleError);
        this.socket.on('end', handleEnd);
      });
  }

Comments

[Viacheslav]

Да, но нужно чтобы промис возвращался после второго ответа, грубо говоря те две строки которые приходят по очереди, вернулись одной

[Viacheslav]

Владимир @, Это так не работает, чтобы получить вторую строку event 'data' должен отработать еще раз

[Viacheslav]

Владимир @, Скиньте пожалуйста пример. Как вы это видите.

[Viacheslav]

Кодом получаю только один. Это telnet сервер, поэтому я могу проверять в ручном режиме.

[Viacheslav]

Еще важный момент ЗАПРОСЫ-ОТВЕТЫ должны идти в строгой последовательности, ответ на предыдущий запрос может использоваться как данные для следующего

[Viacheslav]

SSH не вариант, так нужно. Если постоянно слушать ответы, то все приходит как нужно, загвоздка потом в парсинге ответов и последовательности запросов, поэтому и Промисы.

Answer 2

[Виталий]

sendCommand при каждом вызове создает подписчика, что-то мне подсказывает, что твой сервер течет по памяти

Comments

[Viacheslav]

На данный момент это не самое важное

[Виталий]

slaaavyn, это важнее всего остального, подобные ошибки уничтожают проекты