Как отложить выполнение кода пока не будет получен ответ от сервера?

Question

[angelzzz]

Пишу бота телеграм на Nodejs. Бот принимает сообщения. Он принял сообщение типа start, потом он принял данные, потом он принял сообщение типа end. Когда он принимает данные между start и end, нужно данные отправить на сервер и получить ответ, а когда нажимает end нужно эти данные использовать. Проблема в том, что пользователь может отправить end слишком быстро и тогда данные не успеют обработаться. Вот фрагмент кода (таких if/else там много. Я так понимаю, что нужно использовать промисы или await/async, но не могу понять как это делается в такой конструкции

bot.on('message', msg => {
  if (msg.text == "start") {
    ....
  } else if (msg.text == "send" ) {
    bot.getFileLink(file.file_id).then(url => {
      cloudinary.uploader.upload(url, function(res) { 
        files.push(res.url);//1
      })  
    }) 
  } else if (msg.text == "end") {
    console.log(‘files = ', files);//2
  }
})

Comments

[Vladimir]

await/async тоже промисы ;)

Answer 1

[Сергей Соколов]

Нужно держать состояние диалога, индивидуальное для каждого пользователя.

Команды пользователя складывать в очередь, и как-то помечать, «где мы сейчас»: ждём очередную команду от пользователя или ждём ответа от сервера.

Состояние можно держать в Redis, MySQL или другой БД. Входящее сообщение от пользователя содержит его from.id – по нему идентифицируется диалог и берется его состояние.

Промисы и прочая асинхрота тут не поможет, так как дело шире, чем один запрос.

Comments

[angelzzz]

то есть обычным ожиданием ответа от сервера тут не обойтись?

[Сергей Соколов]

angelzzz, не обойтись, т.к. рассинхрон шире одного запроса, одной входящей команды.

[angelzzz]

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

а как реализовать вот это "если загружено"? а если не загружено, то, что тогда делать?

[Сергей Соколов]

angelzzz, представьте, что у вас чуть более масштабное устройство, бот популярен и вы подняли два сервера. Команда send пришла на один сервер, а end на другой. Никакими промисами их не связать. Нужно какое-то общее хранилище.

[Сергей Соколов]

angelzzz, да, всё верно. «Если загружено» – отсутствуют задания в статусе pending.

[Сергей Соколов]

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

[angelzzz]

Сергей Соколов, не понял только как сделать чтобы если состояние "не загружено, но отправлено" отслеживалось? понятно, что когда отправлено, то данные промисом передаются в БД, но вот когда отправлено сообщение end, то бот проверяет БД и видит, что там "не загружено, но отправлено", как сделать чтобы он ждал когда данные в БД обновятся?

[Сергей Соколов]

angelzzz, может, не ждать? ПРиняли команду, установили флаг end_pending (ждут результата, как только) и отпустили бота. Теперь «мяч» на строне долгоиграющего загружальщика длинных данных.

[angelzzz]

Сергей Соколов, я так и не понял как бот узнает, что данные загрузились, если не оповещать.
вот есть бот, в нему пришло сообщение
- start
- send //10 файлов отправилось в cloudinary (одним сообщением в телеграме) жду, когда они все загрузятся. тут как-то обновляю состояние. предположим для 9 из 10 сообщений оно "выполнено" и 1 висит как пендинг
- end //проверяю состояние. вижу, что одно пендинг. что дальше? как мне сделать, чтобы когда оно перестало быть пендинг я мог выполнить фукнцию, которая в end?

[Сергей Соколов]

angelzzz, на третьем шаге по команде end, ставите флаг end_pending и более ничего не делаете. Окончание каждой загрузки смотрит, есть ли этот флаг и есть ли еще незавершенные загрузки. Если завершилась последняя загрузка и стоит флаг, то выполнить что там по команде end

Answer 2

[dest2r4]

Long poll