/* 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 "mtproto/mtproto_auth_key.h" #include "mtproto/dc_options.h" #include "mtproto/connection_abstract.h" #include "mtproto/facade.h" #include "base/openssl_help.h" #include "base/timer.h" namespace MTP { namespace details { class BoundKeyCreator; } // namespace details // How much time to wait for some more requests, when sending msg acks. constexpr auto kAckSendWaiting = 10 * crl::time(1000); class Instance; namespace internal { class AbstractConnection; class ConnectionPrivate; class SessionData; class RSAPublicKey; struct ConnectionOptions; class Connection { public: enum ConnectionType { TcpConnection, HttpConnection }; Connection(not_null instance); ~Connection(); void start(std::shared_ptr data, ShiftedDcId shiftedDcId); void kill(); void waitTillFinish(); static const int UpdateAlways = 666; int32 state() const; QString transport() const; private: not_null _instance; std::unique_ptr _thread; ConnectionPrivate *_private = nullptr; }; class ConnectionPrivate : public QObject { Q_OBJECT public: ConnectionPrivate( not_null instance, not_null thread, not_null owner, std::shared_ptr data, ShiftedDcId shiftedDcId); ~ConnectionPrivate(); void stop(); int32 getShiftedDcId() const; int32 getState() const; QString transport() const; public slots: void restartNow(); void onPingSendForce(); // Sessions signals, when we need to send something void tryToSend(); void updateAuthKey(); void onConfigLoaded(); void onCDNConfigLoaded(); private: struct TestConnection { ConnectionPointer data; int priority = 0; }; enum class HandleResult { Success, Ignored, RestartConnection, ResetSession, DestroyTemporaryKey, ParseError, }; void connectToServer(bool afterConfig = false); void connectingTimedOut(); void doDisconnect(); void restart(); void finishAndDestroy(); void requestCDNConfig(); void handleError(int errorCode); void onError( not_null connection, qint32 errorCode); void onConnected(not_null connection); void onDisconnected(not_null connection); void onSentSome(uint64 size); void onReceivedSome(); void handleReceived(); void retryByTimer(); void waitConnectedFailed(); void waitReceivedFailed(); void waitBetterFailed(); void markConnectionOld(); void sendPingByTimer(); void destroyAllConnections(); void confirmBestConnection(); void removeTestConnection(not_null connection); int16 getProtocolDcId() const; mtpMsgId placeToContainer( SecureRequest &toSendRequest, mtpMsgId &bigMsgId, bool forceNewMsgId, mtpMsgId *&haveSentArr, SecureRequest &req); mtpMsgId prepareToSend( SecureRequest &request, mtpMsgId currentLastId, bool forceNewMsgId); mtpMsgId replaceMsgId(SecureRequest &request, mtpMsgId newId); bool sendSecureRequest(SecureRequest &&request, bool needAnyResponse); mtpRequestId wasSent(mtpMsgId msgId) const; [[nodiscard]] HandleResult handleOneReceived(const mtpPrime *from, const mtpPrime *end, uint64 msgId, int32 serverTime, uint64 serverSalt, bool badTime); mtpBuffer ungzip(const mtpPrime *from, const mtpPrime *end) const; void handleMsgsStates(const QVector &ids, const QByteArray &states, QVector &acked); // _sessionDataMutex must be locked for read. bool setState(int32 state, int32 ifState = Connection::UpdateAlways); void appendTestConnection( DcOptions::Variants::Protocol protocol, const QString &ip, int port, const bytes::vector &protocolSecret); // if badTime received - search for ids in sessionData->haveSent and sessionData->wereAcked and sync time/salt, return true if found bool requestsFixTimeSalt(const QVector &ids, int32 serverTime, uint64 serverSalt); // remove msgs with such ids from sessionData->haveSent, add to sessionData->wereAcked void requestsAcked(const QVector &ids, bool byResponse = false); void resend( mtpMsgId msgId, crl::time msCanWait = 0, bool forceContainer = false); void resendMany( QVector msgIds, crl::time msCanWait = 0, bool forceContainer = false); void tryAcquireKeyCreation(); void resetSession(); void checkAuthKey(); void authKeyChecked(); void destroyTemporaryKey(); void clearUnboundKeyCreator(); void releaseKeyCreationOnFail(); void applyAuthKey(AuthKeyPtr &&temporaryKey); const not_null _instance; DcType _dcType = DcType::Regular; mutable QReadWriteLock stateConnMutex; int32 _state = DisconnectedState; bool _needSessionReset = false; ShiftedDcId _shiftedDcId = 0; not_null _owner; ConnectionPointer _connection; std::vector _testConnections; crl::time _startedConnectingAt = 0; base::Timer _retryTimer; // exp retry timer int _retryTimeout = 1; qint64 _retryWillFinish = 0; base::Timer _oldConnectionTimer; bool _oldConnection = true; base::Timer _waitForConnectedTimer; base::Timer _waitForReceivedTimer; base::Timer _waitForBetterTimer; crl::time _waitForReceived = 0; crl::time _waitForConnected = 0; crl::time _firstSentAt = -1; QVector _ackRequestData; QVector _resendRequestData; mtpPingId _pingId = 0; mtpPingId _pingIdToSend = 0; crl::time _pingSendAt = 0; mtpMsgId _pingMsgId = 0; base::Timer _pingSender; bool _finished = false; AuthKeyPtr _temporaryKey; uint64 _keyId = 0; std::shared_ptr _sessionData; std::unique_ptr _connectionOptions; std::unique_ptr _keyCreator; }; } // namespace internal } // namespace MTP