2020-06-11 09:41:03 +00:00
|
|
|
/*
|
|
|
|
This file is part of Telegram Desktop,
|
|
|
|
the official desktop application for the Telegram messaging service.
|
|
|
|
|
|
|
|
For license and copyright information please follow this link:
|
|
|
|
https://github.com/telegramdesktop/tdesktop/blob/master/LEGAL
|
|
|
|
*/
|
|
|
|
#pragma once
|
|
|
|
|
|
|
|
#include "data/data_pts_waiter.h"
|
|
|
|
#include "base/timer.h"
|
|
|
|
|
|
|
|
class ApiWrap;
|
|
|
|
class History;
|
|
|
|
|
2021-03-12 12:48:00 +00:00
|
|
|
namespace MTP {
|
|
|
|
class Error;
|
|
|
|
} // namespace MTP
|
|
|
|
|
2020-06-11 09:41:03 +00:00
|
|
|
namespace Main {
|
|
|
|
class Session;
|
|
|
|
} // namespace Main
|
|
|
|
|
|
|
|
namespace Api {
|
|
|
|
|
|
|
|
class Updates final {
|
|
|
|
public:
|
|
|
|
explicit Updates(not_null<Main::Session*> session);
|
|
|
|
|
|
|
|
[[nodiscard]] Main::Session &session() const;
|
|
|
|
[[nodiscard]] ApiWrap &api() const;
|
|
|
|
|
|
|
|
void applyUpdates(
|
|
|
|
const MTPUpdates &updates,
|
|
|
|
uint64 sentMessageRandomId = 0);
|
|
|
|
void applyUpdatesNoPtsCheck(const MTPUpdates &updates);
|
|
|
|
void applyUpdateNoPtsCheck(const MTPUpdate &update);
|
|
|
|
|
2020-11-17 15:05:35 +00:00
|
|
|
[[nodiscard]] int32 pts() const;
|
|
|
|
|
2020-06-11 09:41:03 +00:00
|
|
|
void updateOnline();
|
|
|
|
[[nodiscard]] bool isIdle() const;
|
|
|
|
void checkIdleFinish();
|
|
|
|
bool lastWasOnline() const;
|
|
|
|
crl::time lastSetOnline() const;
|
|
|
|
bool isQuitPrevent();
|
|
|
|
|
|
|
|
bool updateAndApply(int32 pts, int32 ptsCount, const MTPUpdates &updates);
|
|
|
|
bool updateAndApply(int32 pts, int32 ptsCount, const MTPUpdate &update);
|
|
|
|
bool updateAndApply(int32 pts, int32 ptsCount);
|
|
|
|
|
|
|
|
void checkLastUpdate(bool afterSleep);
|
|
|
|
|
|
|
|
// ms <= 0 - stop timer
|
|
|
|
void ptsWaiterStartTimerFor(ChannelData *channel, crl::time ms);
|
|
|
|
|
|
|
|
void getDifference();
|
|
|
|
void requestChannelRangeDifference(not_null<History*> history);
|
|
|
|
|
|
|
|
void addActiveChat(rpl::producer<PeerData*> chat);
|
|
|
|
|
|
|
|
private:
|
|
|
|
enum class ChannelDifferenceRequest {
|
|
|
|
Unknown,
|
|
|
|
PtsGapOrShortPoll,
|
|
|
|
AfterFail,
|
|
|
|
};
|
|
|
|
|
2021-03-17 20:25:53 +00:00
|
|
|
enum class SkipUpdatePolicy {
|
|
|
|
SkipNone,
|
|
|
|
SkipMessageIds,
|
|
|
|
SkipExceptGroupCallParticipants,
|
|
|
|
};
|
|
|
|
|
2020-06-11 09:41:03 +00:00
|
|
|
struct ActiveChatTracker {
|
|
|
|
PeerData *peer = nullptr;
|
|
|
|
rpl::lifetime lifetime;
|
|
|
|
};
|
|
|
|
|
|
|
|
void channelRangeDifferenceSend(
|
|
|
|
not_null<ChannelData*> channel,
|
|
|
|
MsgRange range,
|
|
|
|
int32 pts);
|
|
|
|
void channelRangeDifferenceDone(
|
|
|
|
not_null<ChannelData*> channel,
|
|
|
|
MsgRange range,
|
|
|
|
const MTPupdates_ChannelDifference &result);
|
|
|
|
|
|
|
|
void updateOnline(bool gotOtherOffline);
|
|
|
|
void sendPing();
|
|
|
|
void getDifferenceByPts();
|
|
|
|
void getDifferenceAfterFail();
|
|
|
|
|
|
|
|
[[nodiscard]] bool requestingDifference() const {
|
|
|
|
return _ptsWaiter.requesting();
|
|
|
|
}
|
|
|
|
void getChannelDifference(
|
|
|
|
not_null<ChannelData*> channel,
|
|
|
|
ChannelDifferenceRequest from = ChannelDifferenceRequest::Unknown);
|
|
|
|
void differenceDone(const MTPupdates_Difference &result);
|
2021-03-12 12:48:00 +00:00
|
|
|
void differenceFail(const MTP::Error &error);
|
2020-06-11 09:41:03 +00:00
|
|
|
void feedDifference(
|
|
|
|
const MTPVector<MTPUser> &users,
|
|
|
|
const MTPVector<MTPChat> &chats,
|
|
|
|
const MTPVector<MTPMessage> &msgs,
|
|
|
|
const MTPVector<MTPUpdate> &other);
|
|
|
|
void stateDone(const MTPupdates_State &state);
|
|
|
|
void setState(int32 pts, int32 date, int32 qts, int32 seq);
|
|
|
|
void channelDifferenceDone(
|
|
|
|
not_null<ChannelData*> channel,
|
|
|
|
const MTPupdates_ChannelDifference &diff);
|
|
|
|
void channelDifferenceFail(
|
|
|
|
not_null<ChannelData*> channel,
|
2021-03-12 12:48:00 +00:00
|
|
|
const MTP::Error &error);
|
2020-06-11 09:41:03 +00:00
|
|
|
void failDifferenceStartTimerFor(ChannelData *channel);
|
|
|
|
void feedChannelDifference(const MTPDupdates_channelDifference &data);
|
|
|
|
|
|
|
|
void mtpUpdateReceived(const MTPUpdates &updates);
|
|
|
|
void mtpNewSessionCreated();
|
|
|
|
void feedUpdateVector(
|
|
|
|
const MTPVector<MTPUpdate> &updates,
|
2021-03-17 20:25:53 +00:00
|
|
|
SkipUpdatePolicy policy = SkipUpdatePolicy::SkipNone);
|
2020-06-11 09:41:03 +00:00
|
|
|
// Doesn't call sendHistoryChangeNotifications itself.
|
|
|
|
void feedMessageIds(const MTPVector<MTPUpdate> &updates);
|
|
|
|
// Doesn't call sendHistoryChangeNotifications itself.
|
|
|
|
void feedUpdate(const MTPUpdate &update);
|
|
|
|
|
2021-03-17 20:25:53 +00:00
|
|
|
void applyGroupCallParticipantUpdates(const MTPUpdates &updates);
|
|
|
|
|
2020-06-11 09:41:03 +00:00
|
|
|
bool whenGetDiffChanged(
|
|
|
|
ChannelData *channel,
|
|
|
|
int32 ms,
|
|
|
|
base::flat_map<not_null<ChannelData*>, crl::time> &whenMap,
|
|
|
|
crl::time &curTime);
|
|
|
|
|
2020-12-14 12:52:18 +00:00
|
|
|
void handleSendActionUpdate(
|
|
|
|
PeerId peerId,
|
|
|
|
MsgId rootId,
|
2021-03-05 15:21:11 +00:00
|
|
|
PeerId fromId,
|
2020-12-14 12:52:18 +00:00
|
|
|
const MTPSendMessageAction &action);
|
|
|
|
|
2020-06-11 09:41:03 +00:00
|
|
|
const not_null<Main::Session*> _session;
|
|
|
|
|
|
|
|
int32 _updatesDate = 0;
|
|
|
|
int32 _updatesQts = -1;
|
|
|
|
int32 _updatesSeq = 0;
|
|
|
|
base::Timer _noUpdatesTimer;
|
|
|
|
base::Timer _onlineTimer;
|
|
|
|
|
|
|
|
PtsWaiter _ptsWaiter;
|
|
|
|
|
|
|
|
base::flat_map<not_null<ChannelData*>, crl::time> _whenGetDiffByPts;
|
|
|
|
base::flat_map<not_null<ChannelData*>, crl::time> _whenGetDiffAfterFail;
|
|
|
|
crl::time _getDifferenceTimeByPts = 0;
|
|
|
|
crl::time _getDifferenceTimeAfterFail = 0;
|
|
|
|
|
|
|
|
base::Timer _byPtsTimer;
|
|
|
|
|
|
|
|
base::flat_map<int32, MTPUpdates> _bySeqUpdates;
|
|
|
|
base::Timer _bySeqTimer;
|
|
|
|
|
|
|
|
base::Timer _byMinChannelTimer;
|
|
|
|
|
|
|
|
// growing timeout for getDifference calls, if it fails
|
|
|
|
crl::time _failDifferenceTimeout = 1;
|
|
|
|
// growing timeout for getChannelDifference calls, if it fails
|
|
|
|
base::flat_map<
|
|
|
|
not_null<ChannelData*>,
|
|
|
|
crl::time> _channelFailDifferenceTimeout;
|
|
|
|
base::Timer _failDifferenceTimer;
|
|
|
|
|
|
|
|
base::flat_map<
|
|
|
|
not_null<ChannelData*>,
|
|
|
|
mtpRequestId> _rangeDifferenceRequests;
|
|
|
|
|
|
|
|
crl::time _lastUpdateTime = 0;
|
|
|
|
bool _handlingChannelDifference = false;
|
|
|
|
|
|
|
|
base::flat_map<int, ActiveChatTracker> _activeChats;
|
2020-12-11 11:04:34 +00:00
|
|
|
base::flat_map<
|
2020-12-14 12:52:18 +00:00
|
|
|
not_null<PeerData*>,
|
2021-03-05 15:21:11 +00:00
|
|
|
base::flat_map<PeerId, crl::time>> _pendingSpeakingCallParticipants;
|
2020-06-11 09:41:03 +00:00
|
|
|
|
|
|
|
mtpRequestId _onlineRequest = 0;
|
|
|
|
base::Timer _idleFinishTimer;
|
|
|
|
crl::time _lastSetOnline = 0;
|
|
|
|
bool _lastWasOnline = false;
|
|
|
|
bool _isIdle = false;
|
|
|
|
|
|
|
|
rpl::lifetime _lifetime;
|
|
|
|
|
|
|
|
};
|
|
|
|
|
|
|
|
} // namespace Api
|