1757 lines
71 KiB
C++
1757 lines
71 KiB
C++
/*
|
|
Copyright (C) 2020 Sebastian J. Wolf and other contributors
|
|
|
|
This file is part of Fernschreiber.
|
|
|
|
Fernschreiber 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.
|
|
|
|
Fernschreiber 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.
|
|
|
|
You should have received a copy of the GNU General Public License
|
|
along with Fernschreiber. If not, see <http://www.gnu.org/licenses/>.
|
|
*/
|
|
|
|
#include "tdlibwrapper.h"
|
|
#include "tdlibsecrets.h"
|
|
#include <QDir>
|
|
#include <QFile>
|
|
#include <QFileInfo>
|
|
#include <QLocale>
|
|
#include <QProcess>
|
|
#include <QSysInfo>
|
|
#include <QJsonDocument>
|
|
#include <QStandardPaths>
|
|
#include <QDBusConnection>
|
|
#include <QDBusInterface>
|
|
#include <QRegularExpression>
|
|
#include <QRegularExpressionMatch>
|
|
#include <QRegularExpressionMatchIterator>
|
|
|
|
#define DEBUG_MODULE TDLibWrapper
|
|
#include "debuglog.h"
|
|
|
|
namespace {
|
|
const QString STATUS("status");
|
|
const QString ID("id");
|
|
const QString CHAT_ID("chat_id");
|
|
const QString MESSAGE_ID("message_id");
|
|
const QString TYPE("type");
|
|
const QString LAST_NAME("last_name");
|
|
const QString FIRST_NAME("first_name");
|
|
const QString USERNAME("username");
|
|
const QString THREAD_ID("thread_id");
|
|
const QString VALUE("value");
|
|
const QString CHAT_LIST_TYPE("chat_list_type");
|
|
const QString _TYPE("@type");
|
|
const QString _EXTRA("@extra");
|
|
const QString CHAT_LIST_MAIN("chatListMain");
|
|
}
|
|
|
|
TDLibWrapper::TDLibWrapper(AppSettings *appSettings, MceInterface *mceInterface, QObject *parent) : QObject(parent), joinChatRequested(false)
|
|
{
|
|
LOG("Initializing TD Lib...");
|
|
this->appSettings = appSettings;
|
|
this->mceInterface = mceInterface;
|
|
this->tdLibClient = td_json_client_create();
|
|
this->authorizationState = AuthorizationState::Closed;
|
|
this->isLoggingOut = false;
|
|
|
|
initializeTDLibReciever();
|
|
|
|
QString tdLibDatabaseDirectoryPath = QStandardPaths::writableLocation(QStandardPaths::AppDataLocation) + "/tdlib";
|
|
QDir tdLibDatabaseDirectory(tdLibDatabaseDirectoryPath);
|
|
if (!tdLibDatabaseDirectory.exists()) {
|
|
tdLibDatabaseDirectory.mkpath(tdLibDatabaseDirectoryPath);
|
|
}
|
|
|
|
this->dbusInterface = new DBusInterface(this);
|
|
if (this->appSettings->getUseOpenWith()) {
|
|
this->initializeOpenWith();
|
|
} else {
|
|
this->removeOpenWith();
|
|
}
|
|
|
|
connect(&emojiSearchWorker, SIGNAL(searchCompleted(QString, QVariantList)), this, SLOT(handleEmojiSearchCompleted(QString, QVariantList)));
|
|
|
|
connect(this->appSettings, SIGNAL(useOpenWithChanged()), this, SLOT(handleOpenWithChanged()));
|
|
connect(this->appSettings, SIGNAL(storageOptimizerChanged()), this, SLOT(handleStorageOptimizerChanged()));
|
|
|
|
this->setLogVerbosityLevel();
|
|
this->setOptionInteger("notification_group_count_max", 5);
|
|
}
|
|
|
|
TDLibWrapper::~TDLibWrapper()
|
|
{
|
|
LOG("Destroying TD Lib...");
|
|
this->tdLibReceiver->setActive(false);
|
|
while (this->tdLibReceiver->isRunning()) {
|
|
QCoreApplication::processEvents(QEventLoop::AllEvents, 1000);
|
|
}
|
|
qDeleteAll(basicGroups.values());
|
|
qDeleteAll(superGroups.values());
|
|
td_json_client_destroy(this->tdLibClient);
|
|
}
|
|
|
|
void TDLibWrapper::initializeTDLibReciever() {
|
|
this->tdLibReceiver = new TDLibReceiver(this->tdLibClient, this);
|
|
connect(this->tdLibReceiver, SIGNAL(versionDetected(QString)), this, SLOT(handleVersionDetected(QString)));
|
|
connect(this->tdLibReceiver, SIGNAL(authorizationStateChanged(QString, QVariantMap)), this, SLOT(handleAuthorizationStateChanged(QString, QVariantMap)));
|
|
connect(this->tdLibReceiver, SIGNAL(optionUpdated(QString, QVariant)), this, SLOT(handleOptionUpdated(QString, QVariant)));
|
|
connect(this->tdLibReceiver, SIGNAL(connectionStateChanged(QString)), this, SLOT(handleConnectionStateChanged(QString)));
|
|
connect(this->tdLibReceiver, SIGNAL(userUpdated(QVariantMap)), this, SLOT(handleUserUpdated(QVariantMap)));
|
|
connect(this->tdLibReceiver, SIGNAL(userStatusUpdated(QString, QVariantMap)), this, SLOT(handleUserStatusUpdated(QString, QVariantMap)));
|
|
connect(this->tdLibReceiver, SIGNAL(fileUpdated(QVariantMap)), this, SLOT(handleFileUpdated(QVariantMap)));
|
|
connect(this->tdLibReceiver, SIGNAL(newChatDiscovered(QVariantMap)), this, SLOT(handleNewChatDiscovered(QVariantMap)));
|
|
connect(this->tdLibReceiver, SIGNAL(unreadMessageCountUpdated(QVariantMap)), this, SLOT(handleUnreadMessageCountUpdated(QVariantMap)));
|
|
connect(this->tdLibReceiver, SIGNAL(unreadChatCountUpdated(QVariantMap)), this, SLOT(handleUnreadChatCountUpdated(QVariantMap)));
|
|
connect(this->tdLibReceiver, SIGNAL(chatLastMessageUpdated(QString, QString, QVariantMap)), this, SIGNAL(chatLastMessageUpdated(QString, QString, QVariantMap)));
|
|
connect(this->tdLibReceiver, SIGNAL(chatOrderUpdated(QString, QString)), this, SIGNAL(chatOrderUpdated(QString, QString)));
|
|
connect(this->tdLibReceiver, SIGNAL(chatReadInboxUpdated(QString, QString, int)), this, SIGNAL(chatReadInboxUpdated(QString, QString, int)));
|
|
connect(this->tdLibReceiver, SIGNAL(chatReadOutboxUpdated(QString, QString)), this, SIGNAL(chatReadOutboxUpdated(QString, QString)));
|
|
connect(this->tdLibReceiver, SIGNAL(basicGroupUpdated(qlonglong, QVariantMap)), this, SLOT(handleBasicGroupUpdated(qlonglong, QVariantMap)));
|
|
connect(this->tdLibReceiver, SIGNAL(superGroupUpdated(qlonglong, QVariantMap)), this, SLOT(handleSuperGroupUpdated(qlonglong, QVariantMap)));
|
|
connect(this->tdLibReceiver, SIGNAL(chatOnlineMemberCountUpdated(QString, int)), this, SIGNAL(chatOnlineMemberCountUpdated(QString, int)));
|
|
connect(this->tdLibReceiver, SIGNAL(messagesReceived(QVariantList, int)), this, SIGNAL(messagesReceived(QVariantList, int)));
|
|
connect(this->tdLibReceiver, SIGNAL(newMessageReceived(qlonglong, QVariantMap)), this, SIGNAL(newMessageReceived(qlonglong, QVariantMap)));
|
|
connect(this->tdLibReceiver, SIGNAL(messageInformation(qlonglong, qlonglong, QVariantMap)), this, SLOT(handleMessageInformation(qlonglong, qlonglong, QVariantMap)));
|
|
connect(this->tdLibReceiver, SIGNAL(messageSendSucceeded(qlonglong, qlonglong, QVariantMap)), this, SIGNAL(messageSendSucceeded(qlonglong, qlonglong, QVariantMap)));
|
|
connect(this->tdLibReceiver, SIGNAL(activeNotificationsUpdated(QVariantList)), this, SIGNAL(activeNotificationsUpdated(QVariantList)));
|
|
connect(this->tdLibReceiver, SIGNAL(notificationGroupUpdated(QVariantMap)), this, SIGNAL(notificationGroupUpdated(QVariantMap)));
|
|
connect(this->tdLibReceiver, SIGNAL(notificationUpdated(QVariantMap)), this, SIGNAL(notificationUpdated(QVariantMap)));
|
|
connect(this->tdLibReceiver, SIGNAL(chatNotificationSettingsUpdated(QString, QVariantMap)), this, SIGNAL(chatNotificationSettingsUpdated(QString, QVariantMap)));
|
|
connect(this->tdLibReceiver, SIGNAL(messageContentUpdated(qlonglong, qlonglong, QVariantMap)), this, SIGNAL(messageContentUpdated(qlonglong, qlonglong, QVariantMap)));
|
|
connect(this->tdLibReceiver, SIGNAL(messagesDeleted(qlonglong, QList<qlonglong>)), this, SIGNAL(messagesDeleted(qlonglong, QList<qlonglong>)));
|
|
connect(this->tdLibReceiver, SIGNAL(chats(QVariantMap)), this, SIGNAL(chatsReceived(QVariantMap)));
|
|
connect(this->tdLibReceiver, SIGNAL(chat(QVariantMap)), this, SLOT(handleChatReceived(QVariantMap)));
|
|
connect(this->tdLibReceiver, SIGNAL(secretChat(qlonglong, QVariantMap)), this, SLOT(handleSecretChatReceived(qlonglong, QVariantMap)));
|
|
connect(this->tdLibReceiver, SIGNAL(secretChatUpdated(qlonglong, QVariantMap)), this, SLOT(handleSecretChatUpdated(qlonglong, QVariantMap)));
|
|
connect(this->tdLibReceiver, SIGNAL(recentStickersUpdated(QVariantList)), this, SIGNAL(recentStickersUpdated(QVariantList)));
|
|
connect(this->tdLibReceiver, SIGNAL(stickers(QVariantList)), this, SIGNAL(stickersReceived(QVariantList)));
|
|
connect(this->tdLibReceiver, SIGNAL(installedStickerSetsUpdated(QVariantList)), this, SIGNAL(installedStickerSetsUpdated(QVariantList)));
|
|
connect(this->tdLibReceiver, SIGNAL(stickerSets(QVariantList)), this, SLOT(handleStickerSets(QVariantList)));
|
|
connect(this->tdLibReceiver, SIGNAL(stickerSet(QVariantMap)), this, SIGNAL(stickerSetReceived(QVariantMap)));
|
|
connect(this->tdLibReceiver, SIGNAL(chatMembers(QString, QVariantList, int)), this, SIGNAL(chatMembersReceived(QString, QVariantList, int)));
|
|
connect(this->tdLibReceiver, SIGNAL(userFullInfo(QVariantMap)), this, SIGNAL(userFullInfoReceived(QVariantMap)));
|
|
connect(this->tdLibReceiver, SIGNAL(userFullInfoUpdated(QString, QVariantMap)), this, SIGNAL(userFullInfoUpdated(QString, QVariantMap)));
|
|
connect(this->tdLibReceiver, SIGNAL(basicGroupFullInfo(QString, QVariantMap)), this, SIGNAL(basicGroupFullInfoReceived(QString, QVariantMap)));
|
|
connect(this->tdLibReceiver, SIGNAL(basicGroupFullInfoUpdated(QString, QVariantMap)), this, SIGNAL(basicGroupFullInfoUpdated(QString, QVariantMap)));
|
|
connect(this->tdLibReceiver, SIGNAL(supergroupFullInfo(QString, QVariantMap)), this, SIGNAL(supergroupFullInfoReceived(QString, QVariantMap)));
|
|
connect(this->tdLibReceiver, SIGNAL(supergroupFullInfoUpdated(QString, QVariantMap)), this, SIGNAL(supergroupFullInfoUpdated(QString, QVariantMap)));
|
|
connect(this->tdLibReceiver, SIGNAL(userProfilePhotos(QString, QVariantList, int)), this, SIGNAL(userProfilePhotosReceived(QString, QVariantList, int)));
|
|
connect(this->tdLibReceiver, SIGNAL(chatPermissionsUpdated(QString, QVariantMap)), this, SIGNAL(chatPermissionsUpdated(QString, QVariantMap)));
|
|
connect(this->tdLibReceiver, SIGNAL(chatPhotoUpdated(qlonglong, QVariantMap)), this, SIGNAL(chatPhotoUpdated(qlonglong, QVariantMap)));
|
|
connect(this->tdLibReceiver, SIGNAL(chatTitleUpdated(QString, QString)), this, SIGNAL(chatTitleUpdated(QString, QString)));
|
|
connect(this->tdLibReceiver, SIGNAL(chatPinnedUpdated(qlonglong, bool)), this, SIGNAL(chatPinnedUpdated(qlonglong, bool)));
|
|
connect(this->tdLibReceiver, SIGNAL(chatPinnedMessageUpdated(qlonglong, qlonglong)), this, SIGNAL(chatPinnedMessageUpdated(qlonglong, qlonglong)));
|
|
connect(this->tdLibReceiver, SIGNAL(messageIsPinnedUpdated(qlonglong, qlonglong, bool)), this, SLOT(handleMessageIsPinnedUpdated(qlonglong, qlonglong, bool)));
|
|
connect(this->tdLibReceiver, SIGNAL(usersReceived(QString, QVariantList, int)), this, SIGNAL(usersReceived(QString, QVariantList, int)));
|
|
connect(this->tdLibReceiver, SIGNAL(errorReceived(int, QString, QString)), this, SLOT(handleErrorReceived(int, QString, QString)));
|
|
connect(this->tdLibReceiver, SIGNAL(contactsImported(QVariantList, QVariantList)), this, SIGNAL(contactsImported(QVariantList, QVariantList)));
|
|
connect(this->tdLibReceiver, SIGNAL(messageEditedUpdated(qlonglong, qlonglong, QVariantMap)), this, SIGNAL(messageEditedUpdated(qlonglong, qlonglong, QVariantMap)));
|
|
connect(this->tdLibReceiver, SIGNAL(chatIsMarkedAsUnreadUpdated(qlonglong, bool)), this, SIGNAL(chatIsMarkedAsUnreadUpdated(qlonglong, bool)));
|
|
connect(this->tdLibReceiver, SIGNAL(chatDraftMessageUpdated(qlonglong, QVariantMap, QString)), this, SIGNAL(chatDraftMessageUpdated(qlonglong, QVariantMap, QString)));
|
|
connect(this->tdLibReceiver, SIGNAL(inlineQueryResults(QString, QString, QVariantList, QString, QString, QString)), this, SIGNAL(inlineQueryResults(QString, QString, QVariantList, QString, QString, QString)));
|
|
connect(this->tdLibReceiver, SIGNAL(callbackQueryAnswer(QString, bool, QString)), this, SIGNAL(callbackQueryAnswer(QString, bool, QString)));
|
|
|
|
this->tdLibReceiver->start();
|
|
}
|
|
|
|
void TDLibWrapper::sendRequest(const QVariantMap &requestObject)
|
|
{
|
|
if (this->isLoggingOut) {
|
|
LOG("Sending request to TD Lib skipped as logging out is in progress, object type name:" << requestObject.value(_TYPE).toString());
|
|
return;
|
|
}
|
|
LOG("Sending request to TD Lib, object type name:" << requestObject.value(_TYPE).toString());
|
|
QJsonDocument requestDocument = QJsonDocument::fromVariant(requestObject);
|
|
VERBOSE(requestDocument.toJson().constData());
|
|
td_json_client_send(this->tdLibClient, requestDocument.toJson().constData());
|
|
}
|
|
|
|
QString TDLibWrapper::getVersion()
|
|
{
|
|
return this->version;
|
|
}
|
|
|
|
TDLibWrapper::AuthorizationState TDLibWrapper::getAuthorizationState()
|
|
{
|
|
return this->authorizationState;
|
|
}
|
|
|
|
QVariantMap TDLibWrapper::getAuthorizationStateData()
|
|
{
|
|
return this->authorizationStateData;
|
|
}
|
|
|
|
TDLibWrapper::ConnectionState TDLibWrapper::getConnectionState()
|
|
{
|
|
return this->connectionState;
|
|
}
|
|
|
|
void TDLibWrapper::setAuthenticationPhoneNumber(const QString &phoneNumber)
|
|
{
|
|
LOG("Set authentication phone number " << phoneNumber);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "setAuthenticationPhoneNumber");
|
|
requestObject.insert("phone_number", phoneNumber);
|
|
QVariantMap phoneNumberSettings;
|
|
phoneNumberSettings.insert("allow_flash_call", false);
|
|
phoneNumberSettings.insert("is_current_phone_number", true);
|
|
requestObject.insert("settings", phoneNumberSettings);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::setAuthenticationCode(const QString &authenticationCode)
|
|
{
|
|
LOG("Set authentication code " << authenticationCode);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "checkAuthenticationCode");
|
|
requestObject.insert("code", authenticationCode);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::setAuthenticationPassword(const QString &authenticationPassword)
|
|
{
|
|
LOG("Set authentication password " << authenticationPassword);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "checkAuthenticationPassword");
|
|
requestObject.insert("password", authenticationPassword);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::registerUser(const QString &firstName, const QString &lastName)
|
|
{
|
|
LOG("Register User " << firstName << lastName);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "registerUser");
|
|
requestObject.insert(FIRST_NAME, firstName);
|
|
requestObject.insert(LAST_NAME, lastName);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::logout()
|
|
{
|
|
LOG("Logging out");
|
|
QVariantMap requestObject;
|
|
requestObject.insert("@type", "logOut");
|
|
this->sendRequest(requestObject);
|
|
this->isLoggingOut = true;
|
|
|
|
}
|
|
|
|
void TDLibWrapper::getChats()
|
|
{
|
|
LOG("Getting chats");
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "getChats");
|
|
requestObject.insert("limit", 5);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::downloadFile(int fileId)
|
|
{
|
|
LOG("Downloading file " << fileId);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "downloadFile");
|
|
requestObject.insert("file_id", fileId);
|
|
requestObject.insert("synchronous", false);
|
|
requestObject.insert("offset", 0);
|
|
requestObject.insert("limit", 0);
|
|
requestObject.insert("priority", 1);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::openChat(const QString &chatId)
|
|
{
|
|
LOG("Opening chat " << chatId);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "openChat");
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::closeChat(const QString &chatId)
|
|
{
|
|
LOG("Closing chat " << chatId);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "closeChat");
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::joinChat(const QString &chatId)
|
|
{
|
|
LOG("Joining chat " << chatId);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "joinChat");
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
this->joinChatRequested = true;
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::leaveChat(const QString &chatId)
|
|
{
|
|
LOG("Leaving chat " << chatId);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "leaveChat");
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::getChatHistory(qlonglong chatId, qlonglong fromMessageId, int offset, int limit, bool onlyLocal)
|
|
{
|
|
LOG("Retrieving chat history" << chatId << fromMessageId << offset << limit << onlyLocal);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "getChatHistory");
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
requestObject.insert("from_message_id", fromMessageId);
|
|
requestObject.insert("offset", offset);
|
|
requestObject.insert("limit", limit);
|
|
requestObject.insert("only_local", onlyLocal);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::viewMessage(const QString &chatId, const QString &messageId, bool force)
|
|
{
|
|
LOG("Mark message as viewed" << chatId << messageId);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "viewMessages");
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
requestObject.insert("force_read", force);
|
|
QVariantList messageIds;
|
|
messageIds.append(messageId);
|
|
requestObject.insert("message_ids", messageIds);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::pinMessage(const QString &chatId, const QString &messageId, bool disableNotification)
|
|
{
|
|
LOG("Pin message to chat" << chatId << messageId << disableNotification);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "pinChatMessage");
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
requestObject.insert(MESSAGE_ID, messageId);
|
|
requestObject.insert("disable_notification", disableNotification);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::unpinMessage(const QString &chatId, const QString &messageId)
|
|
{
|
|
LOG("Unpin message from chat" << chatId);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "unpinChatMessage");
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
requestObject.insert(MESSAGE_ID, messageId);
|
|
requestObject.insert(_EXTRA, "unpinChatMessage:" + chatId);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
static bool compareReplacements(const QVariant &replacement1, const QVariant &replacement2)
|
|
{
|
|
const QVariantMap replacementMap1 = replacement1.toMap();
|
|
const QVariantMap replacementMap2 = replacement2.toMap();
|
|
|
|
if (replacementMap1.value("startIndex").toInt() < replacementMap2.value("startIndex").toInt()) {
|
|
return true;
|
|
} else {
|
|
return false;
|
|
}
|
|
}
|
|
|
|
void TDLibWrapper::sendTextMessage(const QString &chatId, const QString &message, const QString &replyToMessageId)
|
|
{
|
|
LOG("Sending text message" << chatId << message << replyToMessageId);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "sendMessage");
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
if (replyToMessageId != "0") {
|
|
requestObject.insert("reply_to_message_id", replyToMessageId);
|
|
}
|
|
QVariantMap inputMessageContent;
|
|
inputMessageContent.insert(_TYPE, "inputMessageText");
|
|
|
|
// Postprocess message (e.g. for @-mentioning)
|
|
QString processedMessage = message;
|
|
QVariantList replacements;
|
|
QRegularExpression atMentionIdRegex("\\@(\\d+)\\(([^\\)]+)\\)");
|
|
QRegularExpressionMatchIterator atMentionIdMatchIterator = atMentionIdRegex.globalMatch(processedMessage);
|
|
while (atMentionIdMatchIterator.hasNext()) {
|
|
QRegularExpressionMatch nextAtMentionId = atMentionIdMatchIterator.next();
|
|
LOG("@Mentioning with user ID! Start Index: " << nextAtMentionId.capturedStart(0) << ", length: " << nextAtMentionId.capturedLength(0) << ", user ID: " << nextAtMentionId.captured(1) << ", plain text: " << nextAtMentionId.captured(2));
|
|
QVariantMap replacement;
|
|
replacement.insert("startIndex", nextAtMentionId.capturedStart(0));
|
|
replacement.insert("length", nextAtMentionId.capturedLength(0));
|
|
replacement.insert("userId", nextAtMentionId.captured(1));
|
|
replacement.insert("plainText", nextAtMentionId.captured(2));
|
|
replacements.append(replacement);
|
|
}
|
|
|
|
QVariantMap formattedText;
|
|
|
|
if (!replacements.isEmpty()) {
|
|
QVariantList entities;
|
|
std::sort(replacements.begin(), replacements.end(), compareReplacements);
|
|
QListIterator<QVariant> replacementsIterator(replacements);
|
|
int offsetCorrection = 0;
|
|
while (replacementsIterator.hasNext()) {
|
|
QVariantMap nextReplacement = replacementsIterator.next().toMap();
|
|
int replacementStartOffset = nextReplacement.value("startIndex").toInt();
|
|
int replacementLength = nextReplacement.value("length").toInt();
|
|
QString replacementPlainText = nextReplacement.value("plainText").toString();
|
|
processedMessage = processedMessage.replace(replacementStartOffset - offsetCorrection, replacementLength, replacementPlainText);
|
|
QVariantMap entity;
|
|
entity.insert("offset", replacementStartOffset - offsetCorrection);
|
|
entity.insert("length", replacementPlainText.length());
|
|
QVariantMap entityType;
|
|
entityType.insert(_TYPE, "textEntityTypeMentionName");
|
|
entityType.insert("user_id", nextReplacement.value("userId").toString());
|
|
entity.insert("type", entityType);
|
|
entities.append(entity);
|
|
offsetCorrection += replacementLength - replacementPlainText.length();
|
|
}
|
|
formattedText.insert("entities", entities);
|
|
}
|
|
|
|
formattedText.insert("text", processedMessage);
|
|
formattedText.insert(_TYPE, "formattedText");
|
|
inputMessageContent.insert("text", formattedText);
|
|
requestObject.insert("input_message_content", inputMessageContent);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::sendPhotoMessage(const QString &chatId, const QString &filePath, const QString &message, const QString &replyToMessageId)
|
|
{
|
|
LOG("Sending photo message" << chatId << filePath << message << replyToMessageId);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "sendMessage");
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
if (replyToMessageId != "0") {
|
|
requestObject.insert("reply_to_message_id", replyToMessageId);
|
|
}
|
|
QVariantMap inputMessageContent;
|
|
inputMessageContent.insert(_TYPE, "inputMessagePhoto");
|
|
QVariantMap formattedText;
|
|
formattedText.insert("text", message);
|
|
formattedText.insert(_TYPE, "formattedText");
|
|
inputMessageContent.insert("caption", formattedText);
|
|
QVariantMap photoInputFile;
|
|
photoInputFile.insert(_TYPE, "inputFileLocal");
|
|
photoInputFile.insert("path", filePath);
|
|
inputMessageContent.insert("photo", photoInputFile);
|
|
|
|
requestObject.insert("input_message_content", inputMessageContent);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::sendVideoMessage(const QString &chatId, const QString &filePath, const QString &message, const QString &replyToMessageId)
|
|
{
|
|
LOG("Sending video message" << chatId << filePath << message << replyToMessageId);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "sendMessage");
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
if (replyToMessageId != "0") {
|
|
requestObject.insert("reply_to_message_id", replyToMessageId);
|
|
}
|
|
QVariantMap inputMessageContent;
|
|
inputMessageContent.insert(_TYPE, "inputMessageVideo");
|
|
QVariantMap formattedText;
|
|
formattedText.insert("text", message);
|
|
formattedText.insert(_TYPE, "formattedText");
|
|
inputMessageContent.insert("caption", formattedText);
|
|
QVariantMap videoInputFile;
|
|
videoInputFile.insert(_TYPE, "inputFileLocal");
|
|
videoInputFile.insert("path", filePath);
|
|
inputMessageContent.insert("video", videoInputFile);
|
|
|
|
requestObject.insert("input_message_content", inputMessageContent);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::sendDocumentMessage(const QString &chatId, const QString &filePath, const QString &message, const QString &replyToMessageId)
|
|
{
|
|
LOG("Sending document message" << chatId << filePath << message << replyToMessageId);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "sendMessage");
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
if (replyToMessageId != "0") {
|
|
requestObject.insert("reply_to_message_id", replyToMessageId);
|
|
}
|
|
QVariantMap inputMessageContent;
|
|
inputMessageContent.insert(_TYPE, "inputMessageDocument");
|
|
QVariantMap formattedText;
|
|
formattedText.insert("text", message);
|
|
formattedText.insert(_TYPE, "formattedText");
|
|
inputMessageContent.insert("caption", formattedText);
|
|
QVariantMap documentInputFile;
|
|
documentInputFile.insert(_TYPE, "inputFileLocal");
|
|
documentInputFile.insert("path", filePath);
|
|
inputMessageContent.insert("document", documentInputFile);
|
|
|
|
requestObject.insert("input_message_content", inputMessageContent);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::sendVoiceNoteMessage(const QString &chatId, const QString &filePath, const QString &message, const QString &replyToMessageId)
|
|
{
|
|
LOG("Sending voice note message" << chatId << filePath << message << replyToMessageId);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "sendMessage");
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
if (replyToMessageId != "0") {
|
|
requestObject.insert("reply_to_message_id", replyToMessageId);
|
|
}
|
|
QVariantMap inputMessageContent;
|
|
inputMessageContent.insert(_TYPE, "inputMessageVoiceNote");
|
|
QVariantMap formattedText;
|
|
formattedText.insert("text", message);
|
|
formattedText.insert(_TYPE, "formattedText");
|
|
inputMessageContent.insert("caption", formattedText);
|
|
QVariantMap documentInputFile;
|
|
documentInputFile.insert(_TYPE, "inputFileLocal");
|
|
documentInputFile.insert("path", filePath);
|
|
inputMessageContent.insert("voice_note", documentInputFile);
|
|
|
|
requestObject.insert("input_message_content", inputMessageContent);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::sendLocationMessage(const QString &chatId, double latitude, double longitude, double horizontalAccuracy, const QString &replyToMessageId)
|
|
{
|
|
LOG("Sending location message" << chatId << latitude << longitude << horizontalAccuracy << replyToMessageId);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "sendMessage");
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
if (replyToMessageId != "0") {
|
|
requestObject.insert("reply_to_message_id", replyToMessageId);
|
|
}
|
|
QVariantMap inputMessageContent;
|
|
inputMessageContent.insert(_TYPE, "inputMessageLocation");
|
|
QVariantMap location;
|
|
location.insert("latitude", latitude);
|
|
location.insert("longitude", longitude);
|
|
location.insert("horizontal_accuracy", horizontalAccuracy);
|
|
location.insert(_TYPE, "location");
|
|
inputMessageContent.insert("location", location);
|
|
|
|
inputMessageContent.insert("live_period", 0);
|
|
inputMessageContent.insert("heading", 0);
|
|
inputMessageContent.insert("proximity_alert_radius", 0);
|
|
|
|
requestObject.insert("input_message_content", inputMessageContent);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::sendStickerMessage(const QString &chatId, const QString &fileId, const QString &replyToMessageId)
|
|
{
|
|
LOG("Sending sticker message" << chatId << fileId << replyToMessageId);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "sendMessage");
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
if (replyToMessageId != "0") {
|
|
requestObject.insert("reply_to_message_id", replyToMessageId);
|
|
}
|
|
QVariantMap inputMessageContent;
|
|
inputMessageContent.insert(_TYPE, "inputMessageSticker");
|
|
|
|
QVariantMap stickerInputFile;
|
|
stickerInputFile.insert(_TYPE, "inputFileRemote");
|
|
stickerInputFile.insert("id", fileId);
|
|
|
|
inputMessageContent.insert("sticker", stickerInputFile);
|
|
|
|
requestObject.insert("input_message_content", inputMessageContent);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::sendPollMessage(const QString &chatId, const QString &question, const QVariantList &options, bool anonymous, int correctOption, bool multiple, const QString &replyToMessageId)
|
|
{
|
|
LOG("Sending poll message" << chatId << question << replyToMessageId);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "sendMessage");
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
if (replyToMessageId != "0") {
|
|
requestObject.insert("reply_to_message_id", replyToMessageId);
|
|
}
|
|
QVariantMap inputMessageContent;
|
|
inputMessageContent.insert(_TYPE, "inputMessagePoll");
|
|
|
|
QVariantMap pollType;
|
|
if(correctOption > -1) {
|
|
pollType.insert(_TYPE, "pollTypeQuiz");
|
|
pollType.insert("correct_option_id", correctOption);
|
|
} else {
|
|
pollType.insert(_TYPE, "pollTypeRegular");
|
|
pollType.insert("allow_multiple_answers", multiple);
|
|
}
|
|
|
|
inputMessageContent.insert("type", pollType);
|
|
inputMessageContent.insert("question", question);
|
|
inputMessageContent.insert("options", options);
|
|
inputMessageContent.insert("is_anonymous", anonymous);
|
|
|
|
requestObject.insert("input_message_content", inputMessageContent);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::forwardMessages(const QString &chatId, const QString &fromChatId, const QVariantList &messageIds, bool sendCopy, bool removeCaption)
|
|
{
|
|
LOG("Forwarding messages" << chatId << fromChatId << messageIds);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "forwardMessages");
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
requestObject.insert("from_chat_id", fromChatId);
|
|
requestObject.insert("message_ids", messageIds);
|
|
requestObject.insert("send_copy", sendCopy);
|
|
requestObject.insert("remove_caption", removeCaption);
|
|
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::getMessage(qlonglong chatId, qlonglong messageId)
|
|
{
|
|
LOG("Retrieving message" << chatId << messageId);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "getMessage");
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
requestObject.insert(MESSAGE_ID, messageId);
|
|
requestObject.insert(_EXTRA, QString("getMessage:%1:%2").arg(chatId).arg(messageId));
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::getCallbackQueryAnswer(const QString &chatId, const QString &messageId, const QVariantMap &payload)
|
|
{
|
|
LOG("Getting Callback Query Answer" << chatId << messageId);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "getCallbackQueryAnswer");
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
requestObject.insert(MESSAGE_ID, messageId);
|
|
requestObject.insert("payload", payload);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::getChatPinnedMessage(qlonglong chatId)
|
|
{
|
|
LOG("Retrieving pinned message" << chatId);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "getChatPinnedMessage");
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
requestObject.insert(_EXTRA, "getChatPinnedMessage:" + QString::number(chatId));
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::setOptionInteger(const QString &optionName, int optionValue)
|
|
{
|
|
LOG("Setting integer option" << optionName << optionValue);
|
|
setOption(optionName, "optionValueInteger", optionValue);
|
|
}
|
|
|
|
void TDLibWrapper::setOptionBoolean(const QString &optionName, bool optionValue)
|
|
{
|
|
LOG("Setting boolean option" << optionName << optionValue);
|
|
setOption(optionName, "optionValueBoolean", optionValue);
|
|
}
|
|
|
|
void TDLibWrapper::setOption(const QString &name, const QString &type, const QVariant &value)
|
|
{
|
|
QVariantMap optionValue;
|
|
optionValue.insert(_TYPE, type);
|
|
optionValue.insert(VALUE, value);
|
|
QVariantMap request;
|
|
request.insert(_TYPE, "setOption");
|
|
request.insert("name", name);
|
|
request.insert(VALUE, optionValue);
|
|
sendRequest(request);
|
|
}
|
|
|
|
void TDLibWrapper::setChatNotificationSettings(const QString &chatId, const QVariantMap ¬ificationSettings)
|
|
{
|
|
LOG("Notification settings for chat " << chatId << notificationSettings);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "setChatNotificationSettings");
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
requestObject.insert("notification_settings", notificationSettings);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::editMessageText(const QString &chatId, const QString &messageId, const QString &message)
|
|
{
|
|
LOG("Editing message text" << chatId << messageId);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "editMessageText");
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
requestObject.insert(MESSAGE_ID, messageId);
|
|
QVariantMap inputMessageContent;
|
|
inputMessageContent.insert(_TYPE, "inputMessageText");
|
|
QVariantMap formattedText;
|
|
formattedText.insert("text", message);
|
|
inputMessageContent.insert("text", formattedText);
|
|
requestObject.insert("input_message_content", inputMessageContent);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::deleteMessages(const QString &chatId, const QVariantList messageIds)
|
|
{
|
|
LOG("Deleting some messages" << chatId << messageIds);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "deleteMessages");
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
requestObject.insert("message_ids", messageIds);
|
|
requestObject.insert("revoke", true);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::getMapThumbnailFile(const QString &chatId, double latitude, double longitude, int width, int height, const QString &extra)
|
|
{
|
|
LOG("Getting Map Thumbnail File" << chatId);
|
|
QVariantMap location;
|
|
location.insert("latitude", latitude);
|
|
location.insert("longitude", longitude);
|
|
// ensure dimensions are in bounds (16 - 1024)
|
|
int boundsWidth = std::min(std::max(width, 16), 1024);
|
|
int boundsHeight = std::min(std::max(height, 16), 1024);
|
|
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "getMapThumbnailFile");
|
|
requestObject.insert("location", location);
|
|
requestObject.insert("zoom", 17); //13-20
|
|
requestObject.insert("width", boundsWidth);
|
|
requestObject.insert("height", boundsHeight);
|
|
requestObject.insert("scale", 1); // 1-3
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
requestObject.insert(_EXTRA, extra);
|
|
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::getRecentStickers()
|
|
{
|
|
LOG("Retrieving recent stickers");
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "getRecentStickers");
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::getInstalledStickerSets()
|
|
{
|
|
LOG("Retrieving installed sticker sets");
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "getInstalledStickerSets");
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::getStickerSet(const QString &setId)
|
|
{
|
|
LOG("Retrieving sticker set" << setId);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "getStickerSet");
|
|
requestObject.insert("set_id", setId);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
void TDLibWrapper::getSupergroupMembers(const QString &groupId, int limit, int offset)
|
|
{
|
|
LOG("Retrieving SupergroupMembers");
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "getSupergroupMembers");
|
|
requestObject.insert(_EXTRA, groupId);
|
|
requestObject.insert("supergroup_id", groupId);
|
|
requestObject.insert("offset", offset);
|
|
requestObject.insert("limit", limit);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::getGroupFullInfo(const QString &groupId, bool isSuperGroup)
|
|
{
|
|
LOG("Retrieving GroupFullInfo");
|
|
QVariantMap requestObject;
|
|
if(isSuperGroup) {
|
|
requestObject.insert(_TYPE, "getSupergroupFullInfo");
|
|
requestObject.insert("supergroup_id", groupId);
|
|
} else {
|
|
requestObject.insert(_TYPE, "getBasicGroupFullInfo");
|
|
requestObject.insert("basic_group_id", groupId);
|
|
}
|
|
requestObject.insert(_EXTRA, groupId);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::getUserFullInfo(const QString &userId)
|
|
{
|
|
LOG("Retrieving UserFullInfo" << userId);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "getUserFullInfo");
|
|
requestObject.insert(_EXTRA, userId);
|
|
requestObject.insert("user_id", userId);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::createPrivateChat(const QString &userId, const QString &extra)
|
|
{
|
|
LOG("Creating Private Chat");
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "createPrivateChat");
|
|
requestObject.insert("user_id", userId);
|
|
requestObject.insert(_EXTRA, extra); //"openDirectly"/"openAndSendStartToBot:[optional parameter]" gets matched in qml
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::createNewSecretChat(const QString &userId, const QString &extra)
|
|
{
|
|
LOG("Creating new secret chat");
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "createNewSecretChat");
|
|
requestObject.insert("user_id", userId);
|
|
requestObject.insert(_EXTRA, extra); //"openDirectly" gets matched in qml
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::createSupergroupChat(const QString &supergroupId, const QString &extra)
|
|
{
|
|
LOG("Creating Supergroup Chat");
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "createSupergroupChat");
|
|
requestObject.insert("supergroup_id", supergroupId);
|
|
requestObject.insert(_EXTRA, extra); //"openDirectly" gets matched in qml
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::createBasicGroupChat(const QString &basicGroupId, const QString &extra)
|
|
{
|
|
LOG("Creating Basic Group Chat");
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "createBasicGroupChat");
|
|
requestObject.insert("basic_group_id", basicGroupId);
|
|
requestObject.insert(_EXTRA, extra); //"openDirectly"/"openAndSend:*" gets matched in qml
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::getGroupsInCommon(const QString &userId, int limit, int offset)
|
|
{
|
|
LOG("Retrieving Groups in Common");
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "getGroupsInCommon");
|
|
requestObject.insert(_EXTRA, userId);
|
|
requestObject.insert("user_id", userId);
|
|
requestObject.insert("offset", offset);
|
|
requestObject.insert("limit", limit);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::getUserProfilePhotos(const QString &userId, int limit, int offset)
|
|
{
|
|
LOG("Retrieving User Profile Photos");
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "getUserProfilePhotos");
|
|
requestObject.insert(_EXTRA, userId);
|
|
requestObject.insert("user_id", userId);
|
|
requestObject.insert("offset", offset);
|
|
requestObject.insert("limit", limit);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::setChatPermissions(const QString &chatId, const QVariantMap &chatPermissions)
|
|
{
|
|
LOG("Setting Chat Permissions");
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "setChatPermissions");
|
|
requestObject.insert(_EXTRA, chatId);
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
requestObject.insert("permissions", chatPermissions);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::setChatSlowModeDelay(const QString &chatId, int delay)
|
|
{
|
|
|
|
LOG("Setting Chat Slow Mode Delay");
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "setChatSlowModeDelay");
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
requestObject.insert("slow_mode_delay", delay);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::setChatDescription(const QString &chatId, const QString &description)
|
|
{
|
|
LOG("Setting Chat Description");
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "setChatDescription");
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
requestObject.insert("description", description);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::setChatTitle(const QString &chatId, const QString &title)
|
|
{
|
|
LOG("Setting Chat Title");
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "setChatTitle");
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
requestObject.insert("title", title);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::setBio(const QString &bio)
|
|
{
|
|
LOG("Setting Bio");
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "setBio");
|
|
requestObject.insert("bio", bio);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::toggleSupergroupIsAllHistoryAvailable(const QString &groupId, bool isAllHistoryAvailable)
|
|
{
|
|
LOG("Toggling SupergroupIsAllHistoryAvailable");
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "toggleSupergroupIsAllHistoryAvailable");
|
|
requestObject.insert("supergroup_id", groupId);
|
|
requestObject.insert("is_all_history_available", isAllHistoryAvailable);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::setPollAnswer(const QString &chatId, qlonglong messageId, QVariantList optionIds)
|
|
{
|
|
LOG("Setting Poll Answer");
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "setPollAnswer");
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
requestObject.insert(MESSAGE_ID, messageId);
|
|
requestObject.insert("option_ids", optionIds);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::stopPoll(const QString &chatId, qlonglong messageId)
|
|
{
|
|
LOG("Stopping Poll");
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "stopPoll");
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
requestObject.insert(MESSAGE_ID, messageId);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::getPollVoters(const QString &chatId, qlonglong messageId, int optionId, int limit, int offset, const QString &extra)
|
|
{
|
|
LOG("Retrieving Poll Voters");
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "getPollVoters");
|
|
requestObject.insert(_EXTRA, extra);
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
requestObject.insert(MESSAGE_ID, messageId);
|
|
requestObject.insert("option_id", optionId);
|
|
requestObject.insert("offset", offset);
|
|
requestObject.insert("limit", limit); //max 50
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::searchPublicChat(const QString &userName, bool doOpenOnFound)
|
|
{
|
|
LOG("Search public chat" << userName);
|
|
if(doOpenOnFound) {
|
|
this->activeChatSearchName = userName;
|
|
}
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "searchPublicChat");
|
|
requestObject.insert(_EXTRA, "searchPublicChat:"+userName);
|
|
requestObject.insert(USERNAME, userName);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::joinChatByInviteLink(const QString &inviteLink)
|
|
{
|
|
LOG("Join chat by invite link" << inviteLink);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "joinChatByInviteLink");
|
|
requestObject.insert("invite_link", inviteLink);
|
|
this->joinChatRequested = true;
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::getDeepLinkInfo(const QString &link)
|
|
{
|
|
LOG("Resolving TG deep link" << link);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "getDeepLinkInfo");
|
|
requestObject.insert("link", link);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::getContacts()
|
|
{
|
|
LOG("Retrieving contacts");
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "getContacts");
|
|
requestObject.insert(_EXTRA, "contactsRequested");
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::getSecretChat(qlonglong secretChatId)
|
|
{
|
|
LOG("Getting detailed information about secret chat" << secretChatId);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "getSecretChat");
|
|
requestObject.insert("secret_chat_id", secretChatId);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::closeSecretChat(qlonglong secretChatId)
|
|
{
|
|
LOG("Closing secret chat" << secretChatId);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "closeSecretChat");
|
|
requestObject.insert("secret_chat_id", secretChatId);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::importContacts(const QVariantList &contacts)
|
|
{
|
|
LOG("Importing contacts");
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "importContacts");
|
|
requestObject.insert("contacts", contacts);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::searchChatMessages(qlonglong chatId, const QString &query, qlonglong fromMessageId)
|
|
{
|
|
LOG("Searching for messages" << chatId << query << fromMessageId);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "searchChatMessages");
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
requestObject.insert("query", query);
|
|
requestObject.insert("from_message_id", fromMessageId);
|
|
requestObject.insert("offset", 0);
|
|
requestObject.insert("limit", 50);
|
|
requestObject.insert(_EXTRA, "searchChatMessages");
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::searchPublicChats(const QString &query)
|
|
{
|
|
LOG("Searching public chats" << query);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "searchPublicChats");
|
|
requestObject.insert("query", query);
|
|
requestObject.insert(_EXTRA, "searchPublicChats");
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::readAllChatMentions(qlonglong chatId)
|
|
{
|
|
LOG("Read all chat mentions" << chatId);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "readAllChatMentions");
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::toggleChatIsMarkedAsUnread(qlonglong chatId, bool isMarkedAsUnread)
|
|
{
|
|
LOG("Toggle chat is marked as unread" << chatId << isMarkedAsUnread);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "toggleChatIsMarkedAsUnread");
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
requestObject.insert("is_marked_as_unread", isMarkedAsUnread);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::toggleChatIsPinned(qlonglong chatId, bool isPinned)
|
|
{
|
|
LOG("Toggle chat is pinned" << chatId << isPinned);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "toggleChatIsPinned");
|
|
QVariantMap chatListMap;
|
|
chatListMap.insert(_TYPE, CHAT_LIST_MAIN);
|
|
requestObject.insert("chat_list", chatListMap);
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
requestObject.insert("is_pinned", isPinned);
|
|
requestObject.insert("is_marked_as_unread", isPinned);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::setChatDraftMessage(qlonglong chatId, qlonglong threadId, qlonglong replyToMessageId, const QString &draft)
|
|
{
|
|
LOG("Set Draft Message" << chatId);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "setChatDraftMessage");
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
requestObject.insert(THREAD_ID, threadId);
|
|
QVariantMap draftMessage;
|
|
QVariantMap inputMessageContent;
|
|
QVariantMap formattedText;
|
|
|
|
formattedText.insert("text", draft);
|
|
formattedText.insert("clear_draft", draft.isEmpty());
|
|
formattedText.insert(_TYPE, "formattedText");
|
|
inputMessageContent.insert(_TYPE, "inputMessageText");
|
|
inputMessageContent.insert("text", formattedText);
|
|
draftMessage.insert(_TYPE, "draftMessage");
|
|
draftMessage.insert("reply_to_message_id", replyToMessageId);
|
|
draftMessage.insert("input_message_text", inputMessageContent);
|
|
|
|
requestObject.insert("draft_message", draftMessage);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::getInlineQueryResults(qlonglong botUserId, qlonglong chatId, const QVariantMap &userLocation, const QString &query, const QString &offset, const QString &extra)
|
|
{
|
|
|
|
LOG("Get Inline Query Results" << chatId << query);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "getInlineQueryResults");
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
requestObject.insert("bot_user_id", botUserId);
|
|
if(!userLocation.isEmpty()) {
|
|
requestObject.insert("user_location", userLocation);
|
|
}
|
|
requestObject.insert("query", query);
|
|
requestObject.insert("offset", offset);
|
|
requestObject.insert(_EXTRA, extra);
|
|
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::sendInlineQueryResultMessage(qlonglong chatId, qlonglong threadId, qlonglong replyToMessageId, const QString &queryId, const QString &resultId)
|
|
{
|
|
|
|
LOG("Send Inline Query Result Message" << chatId);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "sendInlineQueryResultMessage");
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
requestObject.insert("message_thread_id", threadId);
|
|
requestObject.insert("reply_to_message_id", replyToMessageId);
|
|
requestObject.insert("query_id", queryId);
|
|
requestObject.insert("result_id", resultId);
|
|
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::sendBotStartMessage(qlonglong botUserId, qlonglong chatId, const QString ¶meter, const QString &extra)
|
|
{
|
|
|
|
LOG("Send Bot Start Message" << botUserId << chatId << parameter << extra);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "sendBotStartMessage");
|
|
requestObject.insert("bot_user_id", botUserId);
|
|
requestObject.insert(CHAT_ID, chatId);
|
|
requestObject.insert("parameter", parameter);
|
|
requestObject.insert(_EXTRA, extra);
|
|
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::cancelDownloadFile(int fileId)
|
|
{
|
|
LOG("Cancel Download File" << fileId);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "cancelDownloadFile");
|
|
requestObject.insert("file_id", fileId);
|
|
requestObject.insert("only_if_pending", false);
|
|
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::cancelUploadFile(int fileId)
|
|
{
|
|
LOG("Cancel Upload File" << fileId);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "cancelUploadFile");
|
|
requestObject.insert("file_id", fileId);
|
|
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::deleteFile(int fileId)
|
|
{
|
|
LOG("Delete cached File" << fileId);
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "deleteFile");
|
|
requestObject.insert("file_id", fileId);
|
|
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::searchEmoji(const QString &queryString)
|
|
{
|
|
LOG("Searching emoji" << queryString);
|
|
while (this->emojiSearchWorker.isRunning()) {
|
|
this->emojiSearchWorker.requestInterruption();
|
|
}
|
|
this->emojiSearchWorker.setParameters(queryString);
|
|
this->emojiSearchWorker.start();
|
|
}
|
|
|
|
QVariantMap TDLibWrapper::getUserInformation()
|
|
{
|
|
return this->userInformation;
|
|
}
|
|
|
|
QVariantMap TDLibWrapper::getUserInformation(const QString &userId)
|
|
{
|
|
// LOG("Returning user information for ID" << userId);
|
|
return this->allUsers.value(userId).toMap();
|
|
}
|
|
|
|
bool TDLibWrapper::hasUserInformation(const QString &userId)
|
|
{
|
|
return this->allUsers.contains(userId);
|
|
}
|
|
|
|
QVariantMap TDLibWrapper::getUserInformationByName(const QString &userName)
|
|
{
|
|
return this->allUserNames.value(userName).toMap();
|
|
}
|
|
|
|
QVariantMap TDLibWrapper::getUnreadMessageInformation()
|
|
{
|
|
return this->unreadMessageInformation;
|
|
}
|
|
|
|
QVariantMap TDLibWrapper::getUnreadChatInformation()
|
|
{
|
|
return this->unreadChatInformation;
|
|
}
|
|
|
|
QVariantMap TDLibWrapper::getBasicGroup(qlonglong groupId) const
|
|
{
|
|
const Group* group = basicGroups.value(groupId);
|
|
if (group) {
|
|
LOG("Returning basic group information for ID" << groupId);
|
|
return group->groupInfo;
|
|
} else {
|
|
LOG("No super group information for ID" << groupId);
|
|
return QVariantMap();
|
|
}
|
|
}
|
|
|
|
QVariantMap TDLibWrapper::getSuperGroup(qlonglong groupId) const
|
|
{
|
|
const Group* group = superGroups.value(groupId);
|
|
if (group) {
|
|
LOG("Returning super group information for ID" << groupId);
|
|
return group->groupInfo;
|
|
} else {
|
|
LOG("No super group information for ID" << groupId);
|
|
return QVariantMap();
|
|
}
|
|
}
|
|
|
|
QVariantMap TDLibWrapper::getChat(const QString &chatId)
|
|
{
|
|
LOG("Returning chat information for ID" << chatId);
|
|
return this->chats.value(chatId).toMap();
|
|
}
|
|
|
|
QVariantMap TDLibWrapper::getSecretChatFromCache(qlonglong secretChatId)
|
|
{
|
|
return this->secretChats.value(secretChatId);
|
|
}
|
|
|
|
QString TDLibWrapper::getOptionString(const QString &optionName)
|
|
{
|
|
return this->options.value(optionName).toString();
|
|
}
|
|
|
|
void TDLibWrapper::copyFileToDownloads(const QString &filePath)
|
|
{
|
|
LOG("Copy file to downloads" << filePath);
|
|
QFileInfo fileInfo(filePath);
|
|
if (fileInfo.exists()) {
|
|
QString downloadFilePath = QStandardPaths::writableLocation(QStandardPaths::DownloadLocation) + "/" + fileInfo.fileName();
|
|
if (QFile::exists(downloadFilePath)) {
|
|
emit copyToDownloadsSuccessful(fileInfo.fileName(), downloadFilePath);
|
|
} else {
|
|
if (QFile::copy(filePath, downloadFilePath)) {
|
|
emit copyToDownloadsSuccessful(fileInfo.fileName(), downloadFilePath);
|
|
} else {
|
|
emit copyToDownloadsError(fileInfo.fileName(), downloadFilePath);
|
|
}
|
|
}
|
|
} else {
|
|
emit copyToDownloadsError(fileInfo.fileName(), filePath);
|
|
}
|
|
}
|
|
|
|
void TDLibWrapper::openFileOnDevice(const QString &filePath)
|
|
{
|
|
LOG("Open file on device:" << filePath);
|
|
QStringList argumentsList;
|
|
argumentsList.append(filePath);
|
|
bool successfullyStarted = QProcess::startDetached("xdg-open", argumentsList);
|
|
if (successfullyStarted) {
|
|
LOG("Successfully opened file " << filePath);
|
|
} else {
|
|
LOG("Error opening file " << filePath);
|
|
}
|
|
}
|
|
|
|
void TDLibWrapper::controlScreenSaver(bool enabled)
|
|
{
|
|
if (enabled) {
|
|
mceInterface->displayCancelBlankingPause();
|
|
} else {
|
|
mceInterface->displayBlankingPause();
|
|
}
|
|
}
|
|
|
|
bool TDLibWrapper::getJoinChatRequested()
|
|
{
|
|
return this->joinChatRequested;
|
|
}
|
|
|
|
void TDLibWrapper::registerJoinChat()
|
|
{
|
|
this->joinChatRequested = false;
|
|
}
|
|
|
|
DBusAdaptor *TDLibWrapper::getDBusAdaptor()
|
|
{
|
|
return this->dbusInterface->getDBusAdaptor();
|
|
}
|
|
|
|
void TDLibWrapper::handleVersionDetected(const QString &version)
|
|
{
|
|
this->version = version;
|
|
emit versionDetected(version);
|
|
}
|
|
|
|
void TDLibWrapper::handleAuthorizationStateChanged(const QString &authorizationState, const QVariantMap authorizationStateData)
|
|
{
|
|
if (authorizationState == "authorizationStateClosed") {
|
|
this->authorizationState = AuthorizationState::Closed;
|
|
}
|
|
|
|
if (authorizationState == "authorizationStateClosing") {
|
|
this->authorizationState = AuthorizationState::Closing;
|
|
}
|
|
|
|
if (authorizationState == "authorizationStateLoggingOut") {
|
|
this->authorizationState = AuthorizationState::LoggingOut;
|
|
}
|
|
|
|
if (authorizationState == "authorizationStateReady") {
|
|
this->authorizationState = AuthorizationState::AuthorizationReady;
|
|
}
|
|
|
|
if (authorizationState == "authorizationStateWaitCode") {
|
|
this->authorizationState = AuthorizationState::WaitCode;
|
|
}
|
|
|
|
if (authorizationState == "authorizationStateWaitEncryptionKey") {
|
|
this->setEncryptionKey();
|
|
this->authorizationState = AuthorizationState::WaitEncryptionKey;
|
|
}
|
|
|
|
if (authorizationState == "authorizationStateWaitOtherDeviceConfirmation") {
|
|
this->authorizationState = AuthorizationState::WaitOtherDeviceConfirmation;
|
|
}
|
|
|
|
if (authorizationState == "authorizationStateWaitPassword") {
|
|
this->authorizationState = AuthorizationState::WaitPassword;
|
|
}
|
|
|
|
if (authorizationState == "authorizationStateWaitPhoneNumber") {
|
|
this->authorizationState = AuthorizationState::WaitPhoneNumber;
|
|
}
|
|
|
|
if (authorizationState == "authorizationStateWaitRegistration") {
|
|
this->authorizationState = AuthorizationState::WaitRegistration;
|
|
}
|
|
|
|
if (authorizationState == "authorizationStateWaitTdlibParameters") {
|
|
this->setInitialParameters();
|
|
this->authorizationState = AuthorizationState::WaitTdlibParameters;
|
|
}
|
|
if (authorizationState == "authorizationStateLoggingOut") {
|
|
this->authorizationState = AuthorizationState::AuthorizationStateLoggingOut;
|
|
}
|
|
if (authorizationState == "authorizationStateClosed") {
|
|
this->authorizationState = AuthorizationState::AuthorizationStateClosed;
|
|
LOG("Reloading TD Lib...");
|
|
this->basicGroups.clear();
|
|
this->superGroups.clear();
|
|
this->allUsers.clear();
|
|
this->allUserNames.clear();
|
|
this->tdLibReceiver->setActive(false);
|
|
while (this->tdLibReceiver->isRunning()) {
|
|
QCoreApplication::processEvents(QEventLoop::AllEvents, 1000);
|
|
}
|
|
td_json_client_destroy(this->tdLibClient);
|
|
this->tdLibReceiver->terminate();
|
|
QDir appPath(QStandardPaths::writableLocation(QStandardPaths::AppDataLocation));
|
|
appPath.removeRecursively();
|
|
this->tdLibClient = td_json_client_create();
|
|
initializeTDLibReciever();
|
|
this->isLoggingOut = false;
|
|
}
|
|
this->authorizationStateData = authorizationStateData;
|
|
emit authorizationStateChanged(this->authorizationState, this->authorizationStateData);
|
|
|
|
}
|
|
|
|
void TDLibWrapper::handleOptionUpdated(const QString &optionName, const QVariant &optionValue)
|
|
{
|
|
this->options.insert(optionName, optionValue);
|
|
emit optionUpdated(optionName, optionValue);
|
|
if (optionName == "my_id") {
|
|
emit ownUserIdFound(optionValue.toString());
|
|
}
|
|
}
|
|
|
|
void TDLibWrapper::handleConnectionStateChanged(const QString &connectionState)
|
|
{
|
|
if (connectionState == "connectionStateConnecting") {
|
|
this->connectionState = ConnectionState::Connecting;
|
|
}
|
|
if (connectionState == "connectionStateConnectingToProxy") {
|
|
this->connectionState = ConnectionState::ConnectingToProxy;
|
|
}
|
|
if (connectionState == "connectionStateReady") {
|
|
this->connectionState = ConnectionState::ConnectionReady;
|
|
}
|
|
if (connectionState == "connectionStateUpdating") {
|
|
this->connectionState = ConnectionState::Updating;
|
|
}
|
|
if (connectionState == "connectionStateWaitingForNetwork") {
|
|
this->connectionState = ConnectionState::WaitingForNetwork;
|
|
}
|
|
|
|
emit connectionStateChanged(this->connectionState);
|
|
}
|
|
|
|
void TDLibWrapper::handleUserUpdated(const QVariantMap &userInformation)
|
|
{
|
|
QString updatedUserId = userInformation.value("id").toString();
|
|
if (updatedUserId == this->options.value("my_id").toString()) {
|
|
LOG("Own user information updated :)");
|
|
this->userInformation = userInformation;
|
|
}
|
|
LOG("User information updated:" << userInformation.value(USERNAME).toString() << userInformation.value(FIRST_NAME).toString() << userInformation.value(LAST_NAME).toString());
|
|
this->allUsers.insert(updatedUserId, userInformation);
|
|
this->allUserNames.insert(userInformation.value(USERNAME).toString(), userInformation);
|
|
emit userUpdated(updatedUserId, userInformation);
|
|
}
|
|
|
|
void TDLibWrapper::handleUserStatusUpdated(const QString &userId, const QVariantMap &userStatusInformation)
|
|
{
|
|
if (userId == this->options.value("my_id").toString()) {
|
|
LOG("Own user status information updated :)");
|
|
this->userInformation.insert("status", userStatusInformation);
|
|
}
|
|
LOG("User status information updated:" << userId << userStatusInformation.value(_TYPE).toString());
|
|
QVariantMap updatedUserInformation = this->allUsers.value(userId).toMap();
|
|
updatedUserInformation.insert("status", userStatusInformation);
|
|
this->allUsers.insert(userId, updatedUserInformation);
|
|
this->allUserNames.insert(userInformation.value(USERNAME).toString(), userInformation);
|
|
emit userUpdated(userId, updatedUserInformation);
|
|
}
|
|
|
|
void TDLibWrapper::handleFileUpdated(const QVariantMap &fileInformation)
|
|
{
|
|
emit fileUpdated(fileInformation.value("id").toInt(), fileInformation);
|
|
}
|
|
|
|
void TDLibWrapper::handleNewChatDiscovered(const QVariantMap &chatInformation)
|
|
{
|
|
QString chatId = chatInformation.value("id").toString();
|
|
this->chats.insert(chatId, chatInformation);
|
|
emit newChatDiscovered(chatId, chatInformation);
|
|
}
|
|
|
|
void TDLibWrapper::handleChatReceived(const QVariantMap &chatInformation)
|
|
{
|
|
emit chatReceived(chatInformation);
|
|
if (!this->activeChatSearchName.isEmpty()) {
|
|
QVariantMap chatType = chatInformation.value(TYPE).toMap();
|
|
ChatType receivedChatType = chatTypeFromString(chatType.value(_TYPE).toString());
|
|
if (receivedChatType == ChatTypeBasicGroup) {
|
|
LOG("Found basic group for active search" << this->activeChatSearchName);
|
|
this->activeChatSearchName.clear();
|
|
this->createBasicGroupChat(chatType.value("basic_group_id").toString(), "openDirectly");
|
|
}
|
|
if (receivedChatType == ChatTypeSupergroup) {
|
|
LOG("Found supergroup for active search" << this->activeChatSearchName);
|
|
this->activeChatSearchName.clear();
|
|
this->createSupergroupChat(chatType.value("supergroup_id").toString(), "openDirectly");
|
|
}
|
|
}
|
|
}
|
|
|
|
void TDLibWrapper::handleUnreadMessageCountUpdated(const QVariantMap &messageCountInformation)
|
|
{
|
|
if (messageCountInformation.value(CHAT_LIST_TYPE).toString() == CHAT_LIST_MAIN) {
|
|
this->unreadMessageInformation = messageCountInformation;
|
|
emit unreadMessageCountUpdated(messageCountInformation);
|
|
}
|
|
}
|
|
|
|
void TDLibWrapper::handleUnreadChatCountUpdated(const QVariantMap &chatCountInformation)
|
|
{
|
|
if (chatCountInformation.value(CHAT_LIST_TYPE).toString() == CHAT_LIST_MAIN) {
|
|
this->unreadChatInformation = chatCountInformation;
|
|
emit unreadChatCountUpdated(chatCountInformation);
|
|
}
|
|
}
|
|
|
|
void TDLibWrapper::handleBasicGroupUpdated(qlonglong groupId, const QVariantMap &groupInformation)
|
|
{
|
|
emit basicGroupUpdated(updateGroup(groupId, groupInformation, &basicGroups)->groupId);
|
|
if (!this->activeChatSearchName.isEmpty() && this->activeChatSearchName == groupInformation.value(USERNAME).toString()) {
|
|
LOG("Found basic group for active search" << this->activeChatSearchName);
|
|
this->activeChatSearchName.clear();
|
|
this->createBasicGroupChat(groupInformation.value(ID).toString(), "openDirectly");
|
|
}
|
|
}
|
|
|
|
void TDLibWrapper::handleSuperGroupUpdated(qlonglong groupId, const QVariantMap &groupInformation)
|
|
{
|
|
emit superGroupUpdated(updateGroup(groupId, groupInformation, &superGroups)->groupId);
|
|
if (!this->activeChatSearchName.isEmpty() && this->activeChatSearchName == groupInformation.value(USERNAME).toString()) {
|
|
LOG("Found supergroup for active search" << this->activeChatSearchName);
|
|
this->activeChatSearchName.clear();
|
|
this->createSupergroupChat(groupInformation.value(ID).toString(), "openDirectly");
|
|
}
|
|
}
|
|
|
|
void TDLibWrapper::handleStickerSets(const QVariantList &stickerSets)
|
|
{
|
|
QListIterator<QVariant> stickerSetIterator(stickerSets);
|
|
while (stickerSetIterator.hasNext()) {
|
|
QVariantMap stickerSet = stickerSetIterator.next().toMap();
|
|
this->getStickerSet(stickerSet.value("id").toString());
|
|
}
|
|
emit this->stickerSetsReceived(stickerSets);
|
|
}
|
|
|
|
void TDLibWrapper::handleEmojiSearchCompleted(const QString &queryString, const QVariantList &resultList)
|
|
{
|
|
LOG("Emoji search completed" << queryString);
|
|
emit emojiSearchSuccessful(resultList);
|
|
}
|
|
|
|
void TDLibWrapper::handleOpenWithChanged()
|
|
{
|
|
if (this->appSettings->getUseOpenWith()) {
|
|
this->initializeOpenWith();
|
|
} else {
|
|
this->removeOpenWith();
|
|
}
|
|
}
|
|
|
|
void TDLibWrapper::handleSecretChatReceived(qlonglong secretChatId, const QVariantMap &secretChat)
|
|
{
|
|
this->secretChats.insert(secretChatId, secretChat);
|
|
emit secretChatReceived(secretChatId, secretChat);
|
|
}
|
|
|
|
void TDLibWrapper::handleSecretChatUpdated(qlonglong secretChatId, const QVariantMap &secretChat)
|
|
{
|
|
this->secretChats.insert(secretChatId, secretChat);
|
|
emit secretChatUpdated(secretChatId, secretChat);
|
|
}
|
|
|
|
void TDLibWrapper::handleStorageOptimizerChanged()
|
|
{
|
|
setOptionBoolean("use_storage_optimizer", appSettings->storageOptimizer());
|
|
}
|
|
|
|
void TDLibWrapper::handleErrorReceived(int code, const QString &message, const QString &extra)
|
|
{
|
|
if (!extra.isEmpty()) {
|
|
QStringList parts(extra.split(':'));
|
|
if (parts.size() == 3 && parts.at(0) == QStringLiteral("getMessage")) {
|
|
emit messageNotFound(parts.at(1).toLongLong(), parts.at(2).toLongLong());
|
|
}
|
|
}
|
|
emit errorReceived(code, message, extra);
|
|
}
|
|
|
|
void TDLibWrapper::handleMessageInformation(qlonglong chatId, qlonglong messageId, const QVariantMap &receivedInformation)
|
|
{
|
|
QString extraInformation = receivedInformation.value(_EXTRA).toString();
|
|
if (extraInformation.startsWith("getChatPinnedMessage:")) {
|
|
emit chatPinnedMessageUpdated(chatId, messageId);
|
|
}
|
|
emit receivedMessage(chatId, messageId, receivedInformation);
|
|
}
|
|
|
|
void TDLibWrapper::handleMessageIsPinnedUpdated(qlonglong chatId, qlonglong messageId, bool isPinned)
|
|
{
|
|
if (isPinned) {
|
|
emit chatPinnedMessageUpdated(chatId, messageId);
|
|
} else {
|
|
emit chatPinnedMessageUpdated(chatId, 0);
|
|
this->getChatPinnedMessage(chatId);
|
|
}
|
|
}
|
|
|
|
void TDLibWrapper::setInitialParameters()
|
|
{
|
|
LOG("Sending initial parameters to TD Lib");
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "setTdlibParameters");
|
|
QVariantMap initialParameters;
|
|
initialParameters.insert("api_id", TDLIB_API_ID);
|
|
initialParameters.insert("api_hash", TDLIB_API_HASH);
|
|
initialParameters.insert("database_directory", QStandardPaths::writableLocation(QStandardPaths::AppDataLocation) + "/tdlib");
|
|
bool onlineOnlyMode = this->appSettings->onlineOnlyMode();
|
|
initialParameters.insert("use_file_database", !onlineOnlyMode);
|
|
initialParameters.insert("use_chat_info_database", !onlineOnlyMode);
|
|
initialParameters.insert("use_message_database", !onlineOnlyMode);
|
|
initialParameters.insert("use_secret_chats", true);
|
|
initialParameters.insert("system_language_code", QLocale::system().name());
|
|
QSettings hardwareSettings("/etc/hw-release", QSettings::NativeFormat);
|
|
initialParameters.insert("device_model", hardwareSettings.value("NAME", "Unknown Mobile Device").toString());
|
|
initialParameters.insert("system_version", QSysInfo::prettyProductName());
|
|
initialParameters.insert("application_version", "0.7");
|
|
initialParameters.insert("enable_storage_optimizer", appSettings->storageOptimizer());
|
|
// initialParameters.insert("use_test_dc", true);
|
|
requestObject.insert("parameters", initialParameters);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::setEncryptionKey()
|
|
{
|
|
LOG("Setting database encryption key");
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "checkDatabaseEncryptionKey");
|
|
// see https://github.com/tdlib/td/issues/188#issuecomment-379536139
|
|
requestObject.insert("encryption_key", "");
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::setLogVerbosityLevel()
|
|
{
|
|
LOG("Setting log verbosity level to something less chatty");
|
|
QVariantMap requestObject;
|
|
requestObject.insert(_TYPE, "setLogVerbosityLevel");
|
|
requestObject.insert("new_verbosity_level", 2);
|
|
this->sendRequest(requestObject);
|
|
}
|
|
|
|
void TDLibWrapper::initializeOpenWith()
|
|
{
|
|
LOG("Initialize open-with");
|
|
LOG("Checking standard open URL file...");
|
|
const QString applicationsLocation(QStandardPaths::writableLocation(QStandardPaths::ApplicationsLocation));
|
|
const QString openUrlFilePath(applicationsLocation + "/open-url.desktop");
|
|
if (QFile::exists(openUrlFilePath)) {
|
|
LOG("Standard open URL file exists, good!");
|
|
} else {
|
|
LOG("Copying standard open URL file to " << openUrlFilePath);
|
|
QFile::copy("/usr/share/applications/open-url.desktop", openUrlFilePath);
|
|
QProcess::startDetached("update-desktop-database " + applicationsLocation);
|
|
}
|
|
|
|
const QString desktopFilePath(applicationsLocation + "/harbour-fernschreiber-open-url.desktop");
|
|
QFile desktopFile(desktopFilePath);
|
|
if (!desktopFile.exists()) {
|
|
LOG("Creating Open-With file at " << desktopFile.fileName());
|
|
if (desktopFile.open(QIODevice::WriteOnly | QIODevice::Text)) {
|
|
QTextStream fileOut(&desktopFile);
|
|
fileOut.setCodec("UTF-8");
|
|
fileOut << QString("[Desktop Entry]").toUtf8() << "\n";
|
|
fileOut << QString("Type=Application").toUtf8() << "\n";
|
|
fileOut << QString("Name=Fernschreiber").toUtf8() << "\n";
|
|
fileOut << QString("Icon=harbour-fernschreiber").toUtf8() << "\n";
|
|
fileOut << QString("NotShowIn=X-MeeGo;").toUtf8() << "\n";
|
|
fileOut << QString("MimeType=text/html;x-scheme-handler/http;x-scheme-handler/https;x-scheme-handler/tg;").toUtf8() << "\n";
|
|
fileOut << QString("X-Maemo-Service=de.ygriega.fernschreiber").toUtf8() << "\n";
|
|
fileOut << QString("X-Maemo-Object-Path=/de/ygriega/fernschreiber").toUtf8() << "\n";
|
|
fileOut << QString("X-Maemo-Method=de.ygriega.fernschreiber.openUrl").toUtf8() << "\n";
|
|
fileOut << QString("Hidden=true;").toUtf8() << "\n";
|
|
fileOut.flush();
|
|
desktopFile.close();
|
|
QProcess::startDetached("update-desktop-database " + applicationsLocation);
|
|
}
|
|
}
|
|
|
|
QString dbusPathName = QStandardPaths::writableLocation(QStandardPaths::GenericDataLocation) + "/dbus-1/services";
|
|
QDir dbusPath(dbusPathName);
|
|
if (!dbusPath.exists()) {
|
|
LOG("Creating D-Bus directory" << dbusPathName);
|
|
dbusPath.mkpath(dbusPathName);
|
|
}
|
|
QString dbusServiceFileName = dbusPathName + "/de.ygriega.fernschreiber.service";
|
|
QFile dbusServiceFile(dbusServiceFileName);
|
|
if (!dbusServiceFile.exists()) {
|
|
LOG("Creating D-Bus service file at" << dbusServiceFile.fileName());
|
|
if (dbusServiceFile.open(QIODevice::WriteOnly | QIODevice::Text)) {
|
|
QTextStream fileOut(&dbusServiceFile);
|
|
fileOut.setCodec("UTF-8");
|
|
fileOut << QString("[D-BUS Service]").toUtf8() << "\n";
|
|
fileOut << QString("Name=de.ygriega.fernschreiber").toUtf8() << "\n";
|
|
fileOut << QString("Exec=/usr/bin/invoker -s --type=silica-qt5 /usr/bin/harbour-fernschreiber").toUtf8() << "\n";
|
|
fileOut.flush();
|
|
dbusServiceFile.close();
|
|
}
|
|
}
|
|
}
|
|
|
|
void TDLibWrapper::removeOpenWith()
|
|
{
|
|
LOG("Remove open-with");
|
|
QFile::remove(QStandardPaths::writableLocation(QStandardPaths::ApplicationsLocation) + "/harbour-fernschreiber-open-url.desktop");
|
|
QProcess::startDetached("update-desktop-database " + QStandardPaths::writableLocation(QStandardPaths::ApplicationsLocation));
|
|
}
|
|
|
|
const TDLibWrapper::Group *TDLibWrapper::updateGroup(qlonglong groupId, const QVariantMap &groupInfo, QHash<qlonglong,Group*> *groups)
|
|
{
|
|
Group* group = groups->value(groupId);
|
|
if (!group) {
|
|
group = new Group(groupId);
|
|
groups->insert(groupId, group);
|
|
}
|
|
group->groupInfo = groupInfo;
|
|
return group;
|
|
}
|
|
|
|
const TDLibWrapper::Group* TDLibWrapper::getGroup(qlonglong groupId) const
|
|
{
|
|
if (groupId) {
|
|
const Group* group = superGroups.value(groupId);
|
|
return group ? group : basicGroups.value(groupId);
|
|
}
|
|
return Q_NULLPTR;
|
|
}
|
|
|
|
TDLibWrapper::ChatType TDLibWrapper::chatTypeFromString(const QString &type)
|
|
{
|
|
return (type == QStringLiteral("chatTypePrivate")) ? ChatTypePrivate :
|
|
(type == QStringLiteral("chatTypeBasicGroup")) ? ChatTypeBasicGroup :
|
|
(type == QStringLiteral("chatTypeSupergroup")) ? ChatTypeSupergroup :
|
|
(type == QStringLiteral("chatTypeSecret")) ? ChatTypeSecret :
|
|
ChatTypeUnknown;
|
|
}
|
|
|
|
TDLibWrapper::ChatMemberStatus TDLibWrapper::chatMemberStatusFromString(const QString &status)
|
|
{
|
|
// Most common ones first
|
|
return (status == QStringLiteral("chatMemberStatusMember")) ? ChatMemberStatusMember :
|
|
(status == QStringLiteral("chatMemberStatusLeft")) ? ChatMemberStatusLeft :
|
|
(status == QStringLiteral("chatMemberStatusCreator")) ? ChatMemberStatusCreator :
|
|
(status == QStringLiteral("chatMemberStatusAdministrator")) ? ChatMemberStatusAdministrator :
|
|
(status == QStringLiteral("chatMemberStatusRestricted")) ? ChatMemberStatusRestricted :
|
|
(status == QStringLiteral("chatMemberStatusBanned")) ? ChatMemberStatusBanned :
|
|
ChatMemberStatusUnknown;
|
|
}
|
|
|
|
TDLibWrapper::SecretChatState TDLibWrapper::secretChatStateFromString(const QString &state)
|
|
{
|
|
return (state == QStringLiteral("secretChatStateClosed")) ? SecretChatStateClosed :
|
|
(state == QStringLiteral("secretChatStatePending")) ? SecretChatStatePending :
|
|
(state == QStringLiteral("secretChatStateReady")) ? SecretChatStateReady :
|
|
SecretChatStateUnknown;
|
|
}
|
|
|
|
TDLibWrapper::ChatMemberStatus TDLibWrapper::Group::chatMemberStatus() const
|
|
{
|
|
const QString statusType(groupInfo.value(STATUS).toMap().value(_TYPE).toString());
|
|
return statusType.isEmpty() ? ChatMemberStatusUnknown : chatMemberStatusFromString(statusType);
|
|
}
|