1

На сайте после создания заказа клиент переходит на страницу, где ему откликаются боты через рандомные промежутки времени(чтобы выполнить его заказ) . Боты пушатся в socket через php, nodejs принимает и рендерит на странице.

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

Код на nodejs

managementNsp.on('connection', function(socket){
socket.on('addBid', function (data) {
     if (data.writer.isBot) {

        function asyncPushToChat() {
             var messagesArray = ["Hello", "Test message"];
             messagesArray.forEach(function(item) {
                setTimeout(function(){
                    push(item);
                }, randomSeconds);
            });
        }

    }
});

Как функцию asyncPushToChat сделать асинхронной??

если так переписать на промисы, это верно?

managementNsp.on('connection', function(socket){
socket.on('addBid', function (data) {
    if (data.writer.isBot) {
        function asyncPushMessageToChat()
        {
            return new Promise(function(resolve, reject)
            {
                connection.query("SELECT text FROM bot_message", function (err, messagesArray) {
                    if (err) {
                        reject(err);
                    }

                    messagesArray.forEach(function(item) {
                        setTimeout(function(){
                            return resolve(item);
                        }, randomSeconds);
                    });
                });
            });
        }

        asyncPushMessageToChat()
            .then(function(res)
            {
                //append to html
            })
            .catch(function(err){
                console.log(err);
            });
    }
});
3
  • asyncPushToChat и так асинхронная, за счет использования setTimeout, она просто нигде не вызывалась
    – Grundy
    30 июн 2017 в 18:44
  • 1
    если так переписать на промисы, это верно? - нет. потому что для одного Promise идет попытка выполнить функцию resolve несколько раз
    – Grundy
    30 июн 2017 в 18:45
  • 1
    вместо forEach в промисе - массив промисов, затем Promise.all
    – n3r0bi0m4n
    30 июн 2017 в 22:13

1 ответ 1

0

Переписал так

if (data.writer.isBot == 1) {

        connection.query("SELECT text FROM bot_message WHERE bot_id = ?", data.writer.id, function (err, rows) {

            if (err) reject(err);

            for (var i in rows) {
                var messageData = {
                    from : data.writer.id,
                    orderId : data.bidding.orderId,
                    isPing : data.order.isPing,
                    to : data.bidding.userId,
                    bidding : data.bidding.id,
                    message : rows[i].text
                };

                (function(i, messageData) {
                    setTimeout(function () {
                        clientSocket.emit('emulateSendMessage', messageData);
                    }, 6000 * i);
                })(i, messageData);
            }

        });
    }

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge you have read our privacy policy.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.