160 lines
4.6 KiB
C++
160 lines
4.6 KiB
C++
/*
|
|
This file is part of Telegram Desktop,
|
|
the official desktop version of Telegram messaging app, see https://telegram.org
|
|
|
|
Telegram Desktop is free software: you can redistribute it and/or modify
|
|
it under the terms of the GNU General Public License as published by
|
|
the Free Software Foundation, either version 3 of the License, or
|
|
(at your option) any later version.
|
|
|
|
It is distributed in the hope that it will be useful,
|
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
GNU General Public License for more details.
|
|
|
|
In addition, as a special exception, the copyright holders give permission
|
|
to link the code of portions of this program with the OpenSSL library.
|
|
|
|
Full license: https://github.com/telegramdesktop/tdesktop/blob/master/LICENSE
|
|
Copyright (c) 2014-2017 John Preston, https://desktop.telegram.org
|
|
*/
|
|
#pragma once
|
|
|
|
#include "core/observer.h"
|
|
|
|
namespace MTP {
|
|
class DcOptions;
|
|
class Instance;
|
|
} // namespace MTP
|
|
|
|
class AuthSession;
|
|
class MainWidget;
|
|
class FileUploader;
|
|
class Translator;
|
|
|
|
class Messenger final : public QObject, public RPCSender, private base::Subscriber {
|
|
Q_OBJECT
|
|
|
|
public:
|
|
Messenger();
|
|
|
|
Messenger(const Messenger &other) = delete;
|
|
Messenger &operator=(const Messenger &other) = delete;
|
|
|
|
void prepareToDestroy();
|
|
~Messenger();
|
|
|
|
MainWindow *mainWindow();
|
|
|
|
static Messenger *InstancePointer();
|
|
static Messenger &Instance() {
|
|
auto result = InstancePointer();
|
|
t_assert(result != nullptr);
|
|
return *result;
|
|
}
|
|
|
|
MTP::DcOptions *dcOptions() {
|
|
return _dcOptions.get();
|
|
}
|
|
|
|
void setMtpMainDcId(MTP::DcId mainDcId);
|
|
void setMtpKey(MTP::DcId dcId, const MTP::AuthKey::Data &keyData);
|
|
QByteArray serializeMtpAuthorization() const;
|
|
void setMtpAuthorization(const QByteArray &serialized);
|
|
void startMtp();
|
|
MTP::Instance *mtp() {
|
|
return _mtproto.get();
|
|
}
|
|
void suggestMainDcId(MTP::DcId mainDcId);
|
|
void destroyStaleAuthorizationKeys();
|
|
|
|
AuthSession *authSession() {
|
|
return _authSession.get();
|
|
}
|
|
void authSessionCreate(UserId userId);
|
|
void authSessionDestroy();
|
|
base::Observable<void> &authSessionChanged() {
|
|
return _authSessionChanged;
|
|
}
|
|
|
|
void setInternalLinkDomain(const QString &domain) const;
|
|
QString createInternalLink(const QString &query) const;
|
|
QString createInternalLinkFull(const QString &query) const;
|
|
|
|
FileUploader *uploader();
|
|
void uploadProfilePhoto(const QImage &tosend, const PeerId &peerId);
|
|
void regPhotoUpdate(const PeerId &peer, const FullMsgId &msgId);
|
|
bool isPhotoUpdating(const PeerId &peer);
|
|
void cancelPhotoUpdate(const PeerId &peer);
|
|
|
|
void selfPhotoCleared(const MTPUserProfilePhoto &result);
|
|
void chatPhotoCleared(PeerId peer, const MTPUpdates &updates);
|
|
void selfPhotoDone(const MTPphotos_Photo &result);
|
|
void chatPhotoDone(PeerId peerId, const MTPUpdates &updates);
|
|
bool peerPhotoFail(PeerId peerId, const RPCError &e);
|
|
void peerClearPhoto(PeerId peer);
|
|
|
|
void writeUserConfigIn(TimeMs ms);
|
|
|
|
void killDownloadSessionsStart(int32 dc);
|
|
void killDownloadSessionsStop(int32 dc);
|
|
|
|
void checkLocalTime();
|
|
void checkMapVersion();
|
|
|
|
void handleAppActivated();
|
|
void handleAppDeactivated();
|
|
|
|
// Temporary here, when all Images and Documents are owned by AuthSession it'll have this.
|
|
void delayedDestroyLoader(std::unique_ptr<FileLoader> loader);
|
|
|
|
signals:
|
|
void peerPhotoDone(PeerId peer);
|
|
void peerPhotoFail(PeerId peer);
|
|
|
|
public slots:
|
|
void onAllKeysDestroyed();
|
|
void onDelayedDestroyLoaders();
|
|
|
|
void photoUpdated(const FullMsgId &msgId, bool silent, const MTPInputFile &file);
|
|
|
|
void onSwitchDebugMode();
|
|
void onSwitchWorkMode();
|
|
void onSwitchTestMode();
|
|
|
|
void killDownloadSessions();
|
|
void onAppStateChanged(Qt::ApplicationState state);
|
|
|
|
void call_handleHistoryUpdate();
|
|
void call_handleUnreadCounterUpdate();
|
|
void call_handleDelayedPeerUpdates();
|
|
void call_handleObservables();
|
|
|
|
private:
|
|
void destroyMtpKeys(MTP::AuthKeysList &&keys);
|
|
void startLocalStorage();
|
|
void loadLanguage();
|
|
|
|
QMap<FullMsgId, PeerId> photoUpdates;
|
|
|
|
QMap<int32, TimeMs> killDownloadSessionTimes;
|
|
SingleTimer killDownloadSessionsTimer;
|
|
|
|
// Some fields are just moved from the declaration.
|
|
struct Private;
|
|
const std::unique_ptr<Private> _private;
|
|
|
|
std::unique_ptr<MainWindow> _window;
|
|
FileUploader *_uploader = nullptr;
|
|
Translator *_translator = nullptr;
|
|
|
|
std::unique_ptr<MTP::DcOptions> _dcOptions;
|
|
std::unique_ptr<MTP::Instance> _mtproto;
|
|
std::unique_ptr<MTP::Instance> _mtprotoForKeysDestroy;
|
|
std::unique_ptr<AuthSession> _authSession;
|
|
base::Observable<void> _authSessionChanged;
|
|
|
|
SingleDelayedCall _delayedLoadersDestroyer;
|
|
std::vector<std::unique_ptr<FileLoader>> _delayedDestroyedLoaders;
|
|
|
|
};
|