1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
|
#include "tgbot/net/TgLongPoll.h"
#include "tgbot/Api.h"
#include "tgbot/Bot.h"
#include "tgbot/EventHandler.h"
#include <cstdint>
#include <memory>
#include <vector>
#include <utility>
namespace TgBot {
TgLongPoll::TgLongPoll(const Api* api, const EventHandler* eventHandler, std::int32_t limit, std::int32_t timeout, std::shared_ptr<std::vector<std::string>> allowUpdates)
: _api(api), _eventHandler(eventHandler), _limit(limit), _timeout(timeout)
, _allowUpdates(std::move(allowUpdates)) {
const_cast<TgBot::HttpClient&>(_api->_httpClient)._timeout = _timeout + 5;
}
TgLongPoll::TgLongPoll(const Bot& bot, std::int32_t limit, std::int32_t timeout, const std::shared_ptr<std::vector<std::string>>& allowUpdates)
: TgLongPoll(&bot.getApi(), &bot.getEventHandler(), limit, timeout, allowUpdates) {
}
void TgLongPoll::start() {
// handle updates
for (Update::Ptr& item : _updates) {
if (item->updateId >= _lastUpdateId) {
_lastUpdateId = item->updateId + 1;
}
_eventHandler->handleUpdate(item);
}
// confirm handled updates
_updates = _api->getUpdates(_lastUpdateId, _limit, _timeout, _allowUpdates);
}
}
|
