2017-04-06 02:06:42 +03:00
|
|
|
/*
|
|
|
|
* nheko Copyright (C) 2017 Konstantinos Sideris <siderisk@auth.gr>
|
|
|
|
*
|
|
|
|
* This program 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.
|
|
|
|
*
|
|
|
|
* This program 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 this program. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
*/
|
|
|
|
|
2017-10-21 18:53:15 +03:00
|
|
|
#include <QApplication>
|
2017-04-06 02:06:42 +03:00
|
|
|
#include <QSettings>
|
2017-10-21 21:17:01 +03:00
|
|
|
#include <QtConcurrent>
|
2017-04-06 02:06:42 +03:00
|
|
|
|
2017-08-26 13:49:16 +03:00
|
|
|
#include "AvatarProvider.h"
|
2017-10-28 15:46:39 +03:00
|
|
|
#include "Cache.h"
|
2017-04-06 02:06:42 +03:00
|
|
|
#include "ChatPage.h"
|
2018-06-09 16:03:14 +03:00
|
|
|
#include "Logging.hpp"
|
2017-08-26 13:49:16 +03:00
|
|
|
#include "MainWindow.h"
|
2017-10-28 15:46:39 +03:00
|
|
|
#include "MatrixClient.h"
|
2018-06-10 20:03:45 +03:00
|
|
|
#include "Olm.hpp"
|
2017-10-28 15:46:39 +03:00
|
|
|
#include "OverlayModal.h"
|
|
|
|
#include "QuickSwitcher.h"
|
|
|
|
#include "RoomList.h"
|
|
|
|
#include "SideBarActions.h"
|
2017-05-19 19:55:38 +03:00
|
|
|
#include "Splitter.h"
|
2017-10-28 15:46:39 +03:00
|
|
|
#include "TextInputWidget.h"
|
2017-05-19 19:55:38 +03:00
|
|
|
#include "Theme.h"
|
2017-10-28 15:46:39 +03:00
|
|
|
#include "TopRoomBar.h"
|
|
|
|
#include "TypingDisplay.h"
|
2017-04-06 02:06:42 +03:00
|
|
|
#include "UserInfoWidget.h"
|
2017-12-30 18:29:57 +03:00
|
|
|
#include "UserSettingsPage.h"
|
2018-05-05 16:38:41 +03:00
|
|
|
#include "Utils.h"
|
2017-04-06 02:06:42 +03:00
|
|
|
|
2018-05-05 22:40:24 +03:00
|
|
|
#include "notifications/Manager.h"
|
|
|
|
|
2018-01-03 19:05:49 +03:00
|
|
|
#include "dialogs/ReadReceipts.h"
|
2017-11-30 14:53:28 +03:00
|
|
|
#include "timeline/TimelineViewManager.h"
|
|
|
|
|
2018-06-10 20:03:45 +03:00
|
|
|
// TODO: Needs to be updated with an actual secret.
|
|
|
|
static const std::string STORAGE_SECRET_KEY("secret");
|
|
|
|
|
2018-06-09 16:03:14 +03:00
|
|
|
ChatPage *ChatPage::instance_ = nullptr;
|
|
|
|
constexpr int CHECK_CONNECTIVITY_INTERVAL = 15'000;
|
2018-06-10 20:03:45 +03:00
|
|
|
constexpr size_t MAX_ONETIME_KEYS = 50;
|
2018-01-03 19:05:49 +03:00
|
|
|
|
2018-05-08 18:43:56 +03:00
|
|
|
ChatPage::ChatPage(QSharedPointer<UserSettings> userSettings, QWidget *parent)
|
2017-08-20 13:47:22 +03:00
|
|
|
: QWidget(parent)
|
2018-06-09 16:03:14 +03:00
|
|
|
, isConnected_(true)
|
2017-12-30 18:29:57 +03:00
|
|
|
, userSettings_{userSettings}
|
2017-04-06 02:06:42 +03:00
|
|
|
{
|
2017-11-16 17:33:52 +03:00
|
|
|
setObjectName("chatPage");
|
2017-05-19 19:55:38 +03:00
|
|
|
|
2017-08-26 13:49:16 +03:00
|
|
|
topLayout_ = new QHBoxLayout(this);
|
|
|
|
topLayout_->setSpacing(0);
|
|
|
|
topLayout_->setMargin(0);
|
|
|
|
|
2018-05-08 18:43:56 +03:00
|
|
|
communitiesList_ = new CommunitiesList(this);
|
2018-04-28 15:27:12 +03:00
|
|
|
topLayout_->addWidget(communitiesList_);
|
2018-01-09 16:07:32 +03:00
|
|
|
|
2018-07-04 00:05:05 +03:00
|
|
|
splitter = new Splitter(this);
|
2017-08-26 13:49:16 +03:00
|
|
|
splitter->setHandleWidth(0);
|
|
|
|
|
|
|
|
topLayout_->addWidget(splitter);
|
|
|
|
|
|
|
|
// SideBar
|
2017-11-09 00:09:15 +03:00
|
|
|
sideBar_ = new QFrame(this);
|
2018-01-15 22:04:49 +03:00
|
|
|
sideBar_->setObjectName("sideBar");
|
2017-12-17 18:49:22 +03:00
|
|
|
sideBar_->setMinimumWidth(ui::sidebar::NormalSize);
|
2017-08-26 13:49:16 +03:00
|
|
|
sideBarLayout_ = new QVBoxLayout(sideBar_);
|
|
|
|
sideBarLayout_->setSpacing(0);
|
|
|
|
sideBarLayout_->setMargin(0);
|
|
|
|
|
2018-01-09 16:07:32 +03:00
|
|
|
sideBarTopWidget_ = new QWidget(sideBar_);
|
|
|
|
sidebarActions_ = new SideBarActions(this);
|
2017-11-02 01:41:13 +03:00
|
|
|
connect(
|
|
|
|
sidebarActions_, &SideBarActions::showSettings, this, &ChatPage::showUserSettingsPage);
|
2018-06-09 16:03:14 +03:00
|
|
|
connect(sidebarActions_, &SideBarActions::joinRoom, this, &ChatPage::joinRoom);
|
|
|
|
connect(sidebarActions_, &SideBarActions::createRoom, this, &ChatPage::createRoom);
|
2017-10-15 22:08:51 +03:00
|
|
|
|
2017-11-09 00:09:15 +03:00
|
|
|
user_info_widget_ = new UserInfoWidget(sideBar_);
|
2018-05-08 18:43:56 +03:00
|
|
|
room_list_ = new RoomList(userSettings_, sideBar_);
|
2018-06-09 16:03:14 +03:00
|
|
|
connect(room_list_, &RoomList::joinRoom, this, &ChatPage::joinRoom);
|
2017-08-26 13:49:16 +03:00
|
|
|
|
2017-11-09 00:09:15 +03:00
|
|
|
sideBarLayout_->addWidget(user_info_widget_);
|
|
|
|
sideBarLayout_->addWidget(room_list_);
|
|
|
|
sideBarLayout_->addWidget(sidebarActions_);
|
2017-08-26 13:49:16 +03:00
|
|
|
|
2018-01-09 16:07:32 +03:00
|
|
|
sideBarTopWidgetLayout_ = new QVBoxLayout(sideBarTopWidget_);
|
|
|
|
sideBarTopWidgetLayout_->setSpacing(0);
|
|
|
|
sideBarTopWidgetLayout_->setMargin(0);
|
|
|
|
|
2017-08-26 13:49:16 +03:00
|
|
|
// Content
|
2017-11-16 17:33:52 +03:00
|
|
|
content_ = new QFrame(this);
|
|
|
|
content_->setObjectName("mainContent");
|
2017-08-26 13:49:16 +03:00
|
|
|
contentLayout_ = new QVBoxLayout(content_);
|
|
|
|
contentLayout_->setSpacing(0);
|
|
|
|
contentLayout_->setMargin(0);
|
|
|
|
|
2017-11-09 00:09:15 +03:00
|
|
|
top_bar_ = new TopRoomBar(this);
|
2018-05-08 18:43:56 +03:00
|
|
|
view_manager_ = new TimelineViewManager(this);
|
2017-08-26 13:49:16 +03:00
|
|
|
|
2017-11-09 00:09:15 +03:00
|
|
|
contentLayout_->addWidget(top_bar_);
|
|
|
|
contentLayout_->addWidget(view_manager_);
|
2017-08-26 13:49:16 +03:00
|
|
|
|
2018-06-09 16:03:14 +03:00
|
|
|
connect(this,
|
|
|
|
&ChatPage::removeTimelineEvent,
|
|
|
|
view_manager_,
|
|
|
|
&TimelineViewManager::removeTimelineEvent);
|
|
|
|
|
2017-08-26 13:49:16 +03:00
|
|
|
// Splitter
|
|
|
|
splitter->addWidget(sideBar_);
|
|
|
|
splitter->addWidget(content_);
|
2018-06-29 14:28:48 +03:00
|
|
|
splitter->restoreSizes(parent->width());
|
2017-08-26 13:49:16 +03:00
|
|
|
|
2017-10-04 11:33:34 +03:00
|
|
|
text_input_ = new TextInputWidget(this);
|
|
|
|
typingDisplay_ = new TypingDisplay(this);
|
|
|
|
contentLayout_->addWidget(typingDisplay_);
|
2017-10-04 22:00:26 +03:00
|
|
|
contentLayout_->addWidget(text_input_);
|
2017-08-26 13:49:16 +03:00
|
|
|
|
2017-10-31 21:11:49 +03:00
|
|
|
typingRefresher_ = new QTimer(this);
|
|
|
|
typingRefresher_->setInterval(TYPING_REFRESH_TIMEOUT);
|
|
|
|
|
2018-06-09 16:03:14 +03:00
|
|
|
connect(this, &ChatPage::connectionLost, this, [this]() {
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::net()->info("connectivity lost");
|
2018-06-09 16:03:14 +03:00
|
|
|
isConnected_ = false;
|
|
|
|
http::v2::client()->shutdown();
|
|
|
|
text_input_->disableInput();
|
|
|
|
});
|
|
|
|
connect(this, &ChatPage::connectionRestored, this, [this]() {
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::net()->info("trying to re-connect");
|
2018-06-09 16:03:14 +03:00
|
|
|
text_input_->enableInput();
|
|
|
|
isConnected_ = true;
|
|
|
|
|
|
|
|
// Drop all pending connections.
|
|
|
|
http::v2::client()->shutdown();
|
|
|
|
trySync();
|
|
|
|
});
|
|
|
|
|
|
|
|
connectivityTimer_.setInterval(CHECK_CONNECTIVITY_INTERVAL);
|
|
|
|
connect(&connectivityTimer_, &QTimer::timeout, this, [=]() {
|
|
|
|
if (http::v2::client()->access_token().empty()) {
|
|
|
|
connectivityTimer_.stop();
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
http::v2::client()->versions(
|
|
|
|
[this](const mtx::responses::Versions &, mtx::http::RequestErr err) {
|
|
|
|
if (err) {
|
|
|
|
emit connectionLost();
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (!isConnected_)
|
|
|
|
emit connectionRestored();
|
|
|
|
});
|
|
|
|
});
|
|
|
|
|
|
|
|
connect(this, &ChatPage::loggedOut, this, &ChatPage::logout);
|
2018-02-20 18:09:11 +03:00
|
|
|
connect(user_info_widget_, &UserInfoWidget::logout, this, [this]() {
|
2018-06-14 02:28:35 +03:00
|
|
|
http::v2::client()->logout(
|
|
|
|
[this](const mtx::responses::Logout &, mtx::http::RequestErr err) {
|
|
|
|
if (err) {
|
|
|
|
// TODO: handle special errors
|
|
|
|
emit contentLoaded();
|
|
|
|
nhlog::net()->warn(
|
|
|
|
"failed to logout: {} - {}",
|
|
|
|
mtx::errors::to_string(err->matrix_error.errcode),
|
|
|
|
err->matrix_error.error);
|
|
|
|
return;
|
|
|
|
}
|
2018-06-09 16:03:14 +03:00
|
|
|
|
2018-06-14 02:28:35 +03:00
|
|
|
emit loggedOut();
|
|
|
|
});
|
2018-06-09 16:03:14 +03:00
|
|
|
|
2018-02-18 23:22:26 +03:00
|
|
|
emit showOverlayProgressBar();
|
|
|
|
});
|
2017-08-26 13:49:16 +03:00
|
|
|
|
2018-07-04 00:05:05 +03:00
|
|
|
connect(top_bar_, &TopRoomBar::showRoomList, splitter, &Splitter::showFullRoomList);
|
2018-02-20 18:09:11 +03:00
|
|
|
connect(top_bar_, &TopRoomBar::inviteUsers, this, [this](QStringList users) {
|
2018-06-09 16:03:14 +03:00
|
|
|
const auto room_id = current_room_.toStdString();
|
|
|
|
|
2017-12-11 00:59:50 +03:00
|
|
|
for (int ii = 0; ii < users.size(); ++ii) {
|
2018-06-09 16:03:14 +03:00
|
|
|
QTimer::singleShot(ii * 500, this, [this, room_id, ii, users]() {
|
|
|
|
const auto user = users.at(ii);
|
|
|
|
|
|
|
|
http::v2::client()->invite_user(
|
|
|
|
room_id,
|
|
|
|
user.toStdString(),
|
|
|
|
[this, user](const mtx::responses::RoomInvite &,
|
|
|
|
mtx::http::RequestErr err) {
|
|
|
|
if (err) {
|
|
|
|
emit showNotification(
|
|
|
|
QString("Failed to invite user: %1").arg(user));
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
emit showNotification(
|
|
|
|
QString("Invited user: %1").arg(user));
|
|
|
|
});
|
2017-12-11 00:59:50 +03:00
|
|
|
});
|
|
|
|
}
|
|
|
|
});
|
2017-10-01 19:49:36 +03:00
|
|
|
|
2018-02-20 18:09:11 +03:00
|
|
|
connect(room_list_, &RoomList::roomChanged, this, [this](const QString &roomid) {
|
2017-10-04 11:33:34 +03:00
|
|
|
QStringList users;
|
|
|
|
|
2018-01-14 16:57:58 +03:00
|
|
|
if (!userSettings_->isTypingNotificationsEnabled()) {
|
|
|
|
typingDisplay_->setUsers(users);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
2018-01-24 21:46:37 +03:00
|
|
|
if (typingUsers_.find(roomid) != typingUsers_.end())
|
2017-10-04 11:33:34 +03:00
|
|
|
users = typingUsers_[roomid];
|
|
|
|
|
|
|
|
typingDisplay_->setUsers(users);
|
|
|
|
});
|
2017-10-31 21:11:49 +03:00
|
|
|
connect(room_list_, &RoomList::roomChanged, text_input_, &TextInputWidget::stopTyping);
|
2017-08-26 13:49:16 +03:00
|
|
|
connect(room_list_, &RoomList::roomChanged, this, &ChatPage::changeTopRoomInfo);
|
2018-07-01 22:57:14 +03:00
|
|
|
connect(room_list_, &RoomList::roomChanged, splitter, &Splitter::showChatView);
|
2017-08-26 13:49:16 +03:00
|
|
|
connect(room_list_, &RoomList::roomChanged, text_input_, &TextInputWidget::focusLineEdit);
|
|
|
|
connect(
|
|
|
|
room_list_, &RoomList::roomChanged, view_manager_, &TimelineViewManager::setHistoryView);
|
|
|
|
|
2018-04-21 16:34:50 +03:00
|
|
|
connect(room_list_, &RoomList::acceptInvite, this, [this](const QString &room_id) {
|
|
|
|
view_manager_->addRoom(room_id);
|
2018-06-09 16:03:14 +03:00
|
|
|
joinRoom(room_id);
|
2018-04-21 16:34:50 +03:00
|
|
|
room_list_->removeRoom(room_id, currentRoom() == room_id);
|
|
|
|
});
|
|
|
|
|
|
|
|
connect(room_list_, &RoomList::declineInvite, this, [this](const QString &room_id) {
|
2018-06-09 16:03:14 +03:00
|
|
|
leaveRoom(room_id);
|
2018-04-21 16:34:50 +03:00
|
|
|
room_list_->removeRoom(room_id, currentRoom() == room_id);
|
|
|
|
});
|
2017-12-19 23:36:12 +03:00
|
|
|
|
2018-06-09 16:03:14 +03:00
|
|
|
connect(
|
|
|
|
text_input_, &TextInputWidget::startedTyping, this, &ChatPage::sendTypingNotifications);
|
|
|
|
connect(typingRefresher_, &QTimer::timeout, this, &ChatPage::sendTypingNotifications);
|
2018-02-20 18:09:11 +03:00
|
|
|
connect(text_input_, &TextInputWidget::stoppedTyping, this, [this]() {
|
2018-01-14 16:57:58 +03:00
|
|
|
if (!userSettings_->isTypingNotificationsEnabled())
|
|
|
|
return;
|
|
|
|
|
2017-10-31 21:11:49 +03:00
|
|
|
typingRefresher_->stop();
|
2018-06-12 09:45:26 +03:00
|
|
|
|
|
|
|
if (current_room_.isEmpty())
|
|
|
|
return;
|
|
|
|
|
2018-06-09 16:03:14 +03:00
|
|
|
http::v2::client()->stop_typing(
|
|
|
|
current_room_.toStdString(), [](mtx::http::RequestErr err) {
|
|
|
|
if (err) {
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::net()->warn("failed to stop typing notifications: {}",
|
|
|
|
err->matrix_error.error);
|
2018-06-09 16:03:14 +03:00
|
|
|
}
|
|
|
|
});
|
2017-10-31 21:11:49 +03:00
|
|
|
});
|
|
|
|
|
2017-08-26 13:49:16 +03:00
|
|
|
connect(view_manager_,
|
|
|
|
&TimelineViewManager::updateRoomsLastMessage,
|
|
|
|
room_list_,
|
|
|
|
&RoomList::updateRoomDescription);
|
|
|
|
|
|
|
|
connect(room_list_,
|
|
|
|
SIGNAL(totalUnreadMessageCountUpdated(int)),
|
|
|
|
this,
|
|
|
|
SLOT(showUnreadMessageNotification(int)));
|
|
|
|
|
|
|
|
connect(text_input_,
|
|
|
|
SIGNAL(sendTextMessage(const QString &)),
|
|
|
|
view_manager_,
|
2017-11-15 19:38:50 +03:00
|
|
|
SLOT(queueTextMessage(const QString &)));
|
2017-08-26 13:49:16 +03:00
|
|
|
|
2017-09-03 11:43:45 +03:00
|
|
|
connect(text_input_,
|
|
|
|
SIGNAL(sendEmoteMessage(const QString &)),
|
|
|
|
view_manager_,
|
2017-11-15 19:38:50 +03:00
|
|
|
SLOT(queueEmoteMessage(const QString &)));
|
2017-09-03 11:43:45 +03:00
|
|
|
|
2018-06-09 16:03:14 +03:00
|
|
|
connect(text_input_, &TextInputWidget::sendJoinRoomRequest, this, &ChatPage::joinRoom);
|
2017-10-08 22:38:38 +03:00
|
|
|
|
2018-01-10 10:52:59 +03:00
|
|
|
connect(text_input_,
|
|
|
|
&TextInputWidget::uploadImage,
|
|
|
|
this,
|
2018-06-09 16:03:14 +03:00
|
|
|
[this](QSharedPointer<QIODevice> dev, const QString &fn) {
|
|
|
|
QMimeDatabase db;
|
|
|
|
QMimeType mime = db.mimeTypeForData(dev.data());
|
|
|
|
|
|
|
|
if (!dev->open(QIODevice::ReadOnly)) {
|
|
|
|
emit uploadFailed(
|
|
|
|
QString("Error while reading media: %1").arg(dev->errorString()));
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
auto bin = dev->readAll();
|
|
|
|
auto payload = std::string(bin.data(), bin.size());
|
|
|
|
|
|
|
|
http::v2::client()->upload(
|
|
|
|
payload,
|
|
|
|
mime.name().toStdString(),
|
|
|
|
QFileInfo(fn).fileName().toStdString(),
|
|
|
|
[this,
|
|
|
|
room_id = current_room_,
|
|
|
|
filename = fn,
|
|
|
|
mime = mime.name(),
|
|
|
|
size = payload.size()](const mtx::responses::ContentURI &res,
|
|
|
|
mtx::http::RequestErr err) {
|
|
|
|
if (err) {
|
|
|
|
emit uploadFailed(
|
|
|
|
tr("Failed to upload image. Please try again."));
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::net()->warn("failed to upload image: {} ({})",
|
|
|
|
err->matrix_error.error,
|
|
|
|
static_cast<int>(err->status_code));
|
2018-06-09 16:03:14 +03:00
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
emit imageUploaded(room_id,
|
|
|
|
filename,
|
|
|
|
QString::fromStdString(res.content_uri),
|
|
|
|
mime,
|
|
|
|
size);
|
|
|
|
});
|
2018-01-10 10:52:59 +03:00
|
|
|
});
|
2017-09-10 12:58:00 +03:00
|
|
|
|
2018-01-10 10:52:59 +03:00
|
|
|
connect(text_input_,
|
|
|
|
&TextInputWidget::uploadFile,
|
|
|
|
this,
|
2018-06-09 16:03:14 +03:00
|
|
|
[this](QSharedPointer<QIODevice> dev, const QString &fn) {
|
|
|
|
QMimeDatabase db;
|
|
|
|
QMimeType mime = db.mimeTypeForData(dev.data());
|
|
|
|
|
|
|
|
if (!dev->open(QIODevice::ReadOnly)) {
|
|
|
|
emit uploadFailed(
|
|
|
|
QString("Error while reading media: %1").arg(dev->errorString()));
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
auto bin = dev->readAll();
|
|
|
|
auto payload = std::string(bin.data(), bin.size());
|
|
|
|
|
|
|
|
http::v2::client()->upload(
|
|
|
|
payload,
|
|
|
|
mime.name().toStdString(),
|
|
|
|
QFileInfo(fn).fileName().toStdString(),
|
|
|
|
[this,
|
|
|
|
room_id = current_room_,
|
|
|
|
filename = fn,
|
|
|
|
mime = mime.name(),
|
|
|
|
size = payload.size()](const mtx::responses::ContentURI &res,
|
|
|
|
mtx::http::RequestErr err) {
|
|
|
|
if (err) {
|
|
|
|
emit uploadFailed(
|
|
|
|
tr("Failed to upload file. Please try again."));
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::net()->warn("failed to upload file: {} ({})",
|
|
|
|
err->matrix_error.error,
|
|
|
|
static_cast<int>(err->status_code));
|
2018-06-09 16:03:14 +03:00
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
emit fileUploaded(room_id,
|
|
|
|
filename,
|
|
|
|
QString::fromStdString(res.content_uri),
|
|
|
|
mime,
|
|
|
|
size);
|
|
|
|
});
|
2018-01-10 10:52:59 +03:00
|
|
|
});
|
2017-11-30 00:39:35 +03:00
|
|
|
|
2018-01-10 10:52:59 +03:00
|
|
|
connect(text_input_,
|
|
|
|
&TextInputWidget::uploadAudio,
|
|
|
|
this,
|
2018-06-09 16:03:14 +03:00
|
|
|
[this](QSharedPointer<QIODevice> dev, const QString &fn) {
|
|
|
|
QMimeDatabase db;
|
|
|
|
QMimeType mime = db.mimeTypeForData(dev.data());
|
|
|
|
|
|
|
|
if (!dev->open(QIODevice::ReadOnly)) {
|
|
|
|
emit uploadFailed(
|
|
|
|
QString("Error while reading media: %1").arg(dev->errorString()));
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
auto bin = dev->readAll();
|
|
|
|
auto payload = std::string(bin.data(), bin.size());
|
|
|
|
|
|
|
|
http::v2::client()->upload(
|
|
|
|
payload,
|
|
|
|
mime.name().toStdString(),
|
|
|
|
QFileInfo(fn).fileName().toStdString(),
|
|
|
|
[this,
|
|
|
|
room_id = current_room_,
|
|
|
|
filename = fn,
|
|
|
|
mime = mime.name(),
|
|
|
|
size = payload.size()](const mtx::responses::ContentURI &res,
|
|
|
|
mtx::http::RequestErr err) {
|
|
|
|
if (err) {
|
|
|
|
emit uploadFailed(
|
|
|
|
tr("Failed to upload audio. Please try again."));
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::net()->warn("failed to upload audio: {} ({})",
|
|
|
|
err->matrix_error.error,
|
|
|
|
static_cast<int>(err->status_code));
|
2018-06-09 16:03:14 +03:00
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
emit audioUploaded(room_id,
|
|
|
|
filename,
|
|
|
|
QString::fromStdString(res.content_uri),
|
|
|
|
mime,
|
|
|
|
size);
|
|
|
|
});
|
2018-02-18 23:52:31 +03:00
|
|
|
});
|
|
|
|
connect(text_input_,
|
|
|
|
&TextInputWidget::uploadVideo,
|
|
|
|
this,
|
2018-06-09 16:03:14 +03:00
|
|
|
[this](QSharedPointer<QIODevice> dev, const QString &fn) {
|
|
|
|
QMimeDatabase db;
|
|
|
|
QMimeType mime = db.mimeTypeForData(dev.data());
|
|
|
|
|
|
|
|
if (!dev->open(QIODevice::ReadOnly)) {
|
|
|
|
emit uploadFailed(
|
|
|
|
QString("Error while reading media: %1").arg(dev->errorString()));
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
auto bin = dev->readAll();
|
|
|
|
auto payload = std::string(bin.data(), bin.size());
|
|
|
|
|
|
|
|
http::v2::client()->upload(
|
|
|
|
payload,
|
|
|
|
mime.name().toStdString(),
|
|
|
|
QFileInfo(fn).fileName().toStdString(),
|
|
|
|
[this,
|
|
|
|
room_id = current_room_,
|
|
|
|
filename = fn,
|
|
|
|
mime = mime.name(),
|
|
|
|
size = payload.size()](const mtx::responses::ContentURI &res,
|
|
|
|
mtx::http::RequestErr err) {
|
|
|
|
if (err) {
|
|
|
|
emit uploadFailed(
|
|
|
|
tr("Failed to upload video. Please try again."));
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::net()->warn("failed to upload video: {} ({})",
|
|
|
|
err->matrix_error.error,
|
|
|
|
static_cast<int>(err->status_code));
|
2018-06-09 16:03:14 +03:00
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
emit videoUploaded(room_id,
|
|
|
|
filename,
|
|
|
|
QString::fromStdString(res.content_uri),
|
|
|
|
mime,
|
|
|
|
size);
|
|
|
|
});
|
2018-01-10 10:52:59 +03:00
|
|
|
});
|
2017-12-01 18:33:49 +03:00
|
|
|
|
2018-06-09 16:03:14 +03:00
|
|
|
connect(this, &ChatPage::uploadFailed, this, [this](const QString &msg) {
|
2018-02-19 01:17:54 +03:00
|
|
|
text_input_->hideUploadSpinner();
|
|
|
|
emit showNotification(msg);
|
|
|
|
});
|
2018-06-09 16:03:14 +03:00
|
|
|
connect(this,
|
|
|
|
&ChatPage::imageUploaded,
|
2017-08-26 13:49:16 +03:00
|
|
|
this,
|
2018-06-09 16:03:14 +03:00
|
|
|
[this](QString roomid, QString filename, QString url, QString mime, qint64 dsize) {
|
|
|
|
text_input_->hideUploadSpinner();
|
|
|
|
view_manager_->queueImageMessage(roomid, filename, url, mime, dsize);
|
|
|
|
});
|
|
|
|
connect(this,
|
|
|
|
&ChatPage::fileUploaded,
|
2018-01-09 16:07:32 +03:00
|
|
|
this,
|
2018-06-09 16:03:14 +03:00
|
|
|
[this](QString roomid, QString filename, QString url, QString mime, qint64 dsize) {
|
|
|
|
text_input_->hideUploadSpinner();
|
|
|
|
view_manager_->queueFileMessage(roomid, filename, url, mime, dsize);
|
|
|
|
});
|
|
|
|
connect(this,
|
|
|
|
&ChatPage::audioUploaded,
|
2018-01-09 16:07:32 +03:00
|
|
|
this,
|
2018-06-09 16:03:14 +03:00
|
|
|
[this](QString roomid, QString filename, QString url, QString mime, qint64 dsize) {
|
|
|
|
text_input_->hideUploadSpinner();
|
|
|
|
view_manager_->queueAudioMessage(roomid, filename, url, mime, dsize);
|
2018-01-09 16:07:32 +03:00
|
|
|
});
|
2018-06-09 16:03:14 +03:00
|
|
|
connect(this,
|
|
|
|
&ChatPage::videoUploaded,
|
2018-01-09 16:07:32 +03:00
|
|
|
this,
|
2018-06-09 16:03:14 +03:00
|
|
|
[this](QString roomid, QString filename, QString url, QString mime, qint64 dsize) {
|
|
|
|
text_input_->hideUploadSpinner();
|
|
|
|
view_manager_->queueVideoMessage(roomid, filename, url, mime, dsize);
|
2018-01-09 16:07:32 +03:00
|
|
|
});
|
|
|
|
|
2018-06-09 16:03:14 +03:00
|
|
|
connect(room_list_, &RoomList::roomAvatarChanged, this, &ChatPage::updateTopBarAvatar);
|
2018-04-21 16:34:50 +03:00
|
|
|
|
2018-06-09 16:03:14 +03:00
|
|
|
// connect(http::client(),
|
|
|
|
// SIGNAL(getOwnCommunitiesResponse(QList<QString>)),
|
|
|
|
// this,
|
|
|
|
// SLOT(updateOwnCommunitiesInfo(QList<QString>)));
|
|
|
|
// connect(http::client(),
|
|
|
|
// &MatrixClient::communityProfileRetrieved,
|
|
|
|
// this,
|
|
|
|
// [this](QString communityId, QJsonObject profile) {
|
|
|
|
// communities_[communityId]->parseProfile(profile);
|
|
|
|
// });
|
|
|
|
// connect(http::client(),
|
|
|
|
// &MatrixClient::communityRoomsRetrieved,
|
|
|
|
// this,
|
|
|
|
// [this](QString communityId, QJsonObject rooms) {
|
|
|
|
// communities_[communityId]->parseRooms(rooms);
|
|
|
|
|
|
|
|
// if (communityId == current_community_) {
|
|
|
|
// if (communityId == "world") {
|
|
|
|
// room_list_->setFilterRooms(false);
|
|
|
|
// } else {
|
|
|
|
// room_list_->setRoomFilter(
|
|
|
|
// communities_[communityId]->getRoomList());
|
|
|
|
// }
|
|
|
|
// }
|
|
|
|
// });
|
|
|
|
|
|
|
|
connect(this, &ChatPage::leftRoom, this, &ChatPage::removeRoom);
|
|
|
|
connect(this, &ChatPage::notificationsRetrieved, this, &ChatPage::sendDesktopNotifications);
|
2017-08-26 13:49:16 +03:00
|
|
|
|
2018-01-09 16:07:32 +03:00
|
|
|
connect(communitiesList_,
|
|
|
|
&CommunitiesList::communityChanged,
|
|
|
|
this,
|
2018-02-20 18:09:11 +03:00
|
|
|
[this](const QString &communityId) {
|
2018-01-09 16:07:32 +03:00
|
|
|
current_community_ = communityId;
|
2018-01-24 21:46:37 +03:00
|
|
|
|
|
|
|
if (communityId == "world")
|
2018-01-09 16:07:32 +03:00
|
|
|
room_list_->setFilterRooms(false);
|
2018-01-24 21:46:37 +03:00
|
|
|
else
|
|
|
|
room_list_->setRoomFilter(communities_[communityId]->getRoomList());
|
2018-01-09 16:07:32 +03:00
|
|
|
});
|
|
|
|
|
2018-01-09 22:57:41 +03:00
|
|
|
setGroupViewState(userSettings_->isGroupViewEnabled());
|
|
|
|
|
|
|
|
connect(userSettings_.data(),
|
|
|
|
&UserSettings::groupViewStateChanged,
|
|
|
|
this,
|
|
|
|
&ChatPage::setGroupViewState);
|
|
|
|
|
2018-04-21 16:34:50 +03:00
|
|
|
connect(this, &ChatPage::initializeRoomList, room_list_, &RoomList::initialize);
|
|
|
|
connect(this,
|
|
|
|
&ChatPage::initializeViews,
|
|
|
|
view_manager_,
|
|
|
|
[this](const mtx::responses::Rooms &rooms) { view_manager_->initialize(rooms); });
|
2018-06-28 16:16:43 +03:00
|
|
|
connect(this,
|
|
|
|
&ChatPage::initializeEmptyViews,
|
|
|
|
view_manager_,
|
|
|
|
&TimelineViewManager::initWithMessages);
|
2018-04-21 16:34:50 +03:00
|
|
|
connect(this, &ChatPage::syncUI, this, [this](const mtx::responses::Rooms &rooms) {
|
2018-04-22 14:19:05 +03:00
|
|
|
try {
|
2018-05-08 20:30:09 +03:00
|
|
|
room_list_->cleanupInvites(cache::client()->invites());
|
2018-04-22 14:19:05 +03:00
|
|
|
} catch (const lmdb::error &e) {
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::db()->error("failed to retrieve invites: {}", e.what());
|
2018-04-22 14:19:05 +03:00
|
|
|
}
|
|
|
|
|
2018-04-21 16:34:50 +03:00
|
|
|
view_manager_->initialize(rooms);
|
|
|
|
removeLeftRooms(rooms.leave);
|
2018-04-21 17:14:16 +03:00
|
|
|
|
2018-05-05 16:38:41 +03:00
|
|
|
bool hasNotifications = false;
|
2018-04-21 17:14:16 +03:00
|
|
|
for (const auto &room : rooms.join) {
|
|
|
|
auto room_id = QString::fromStdString(room.first);
|
|
|
|
|
|
|
|
updateTypingUsers(room_id, room.second.ephemeral.typing);
|
|
|
|
updateRoomNotificationCount(
|
|
|
|
room_id, room.second.unread_notifications.notification_count);
|
2018-05-05 16:38:41 +03:00
|
|
|
|
|
|
|
if (room.second.unread_notifications.notification_count > 0)
|
|
|
|
hasNotifications = true;
|
2018-04-21 17:14:16 +03:00
|
|
|
}
|
2018-05-05 16:38:41 +03:00
|
|
|
|
|
|
|
if (hasNotifications)
|
2018-06-09 16:03:14 +03:00
|
|
|
http::v2::client()->notifications(
|
|
|
|
5,
|
|
|
|
[this](const mtx::responses::Notifications &res,
|
|
|
|
mtx::http::RequestErr err) {
|
|
|
|
if (err) {
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::net()->warn(
|
2018-06-09 16:03:14 +03:00
|
|
|
"failed to retrieve notifications: {} ({})",
|
|
|
|
err->matrix_error.error,
|
|
|
|
static_cast<int>(err->status_code));
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
emit notificationsRetrieved(std::move(res));
|
|
|
|
});
|
2018-04-21 16:34:50 +03:00
|
|
|
});
|
|
|
|
connect(this, &ChatPage::syncRoomlist, room_list_, &RoomList::sync);
|
2018-05-18 21:37:08 +03:00
|
|
|
connect(
|
|
|
|
this, &ChatPage::syncTopBar, this, [this](const std::map<QString, RoomInfo> &updates) {
|
|
|
|
if (updates.find(currentRoom()) != updates.end())
|
|
|
|
changeTopRoomInfo(currentRoom());
|
|
|
|
});
|
2018-04-21 16:34:50 +03:00
|
|
|
|
2018-06-09 16:03:14 +03:00
|
|
|
// Callbacks to update the user info (top left corner of the page).
|
|
|
|
connect(this, &ChatPage::setUserAvatar, user_info_widget_, &UserInfoWidget::setAvatar);
|
|
|
|
connect(this, &ChatPage::setUserDisplayName, this, [this](const QString &name) {
|
|
|
|
QSettings settings;
|
|
|
|
auto userid = settings.value("auth/user_id").toString();
|
|
|
|
user_info_widget_->setUserId(userid);
|
|
|
|
user_info_widget_->setDisplayName(name);
|
|
|
|
});
|
|
|
|
|
|
|
|
connect(this, &ChatPage::tryInitialSyncCb, this, &ChatPage::tryInitialSync);
|
|
|
|
connect(this, &ChatPage::trySyncCb, this, &ChatPage::trySync);
|
2018-06-10 20:03:45 +03:00
|
|
|
connect(this, &ChatPage::tryDelayedSyncCb, this, [this]() {
|
|
|
|
QTimer::singleShot(5000, this, &ChatPage::trySync);
|
|
|
|
});
|
2018-04-21 16:34:50 +03:00
|
|
|
|
2018-06-09 16:03:14 +03:00
|
|
|
connect(this, &ChatPage::dropToLoginPageCb, this, &ChatPage::dropToLoginPage);
|
2018-06-30 15:13:15 +03:00
|
|
|
connect(this, &ChatPage::messageReply, text_input_, &TextInputWidget::addReply);
|
2018-06-09 16:03:14 +03:00
|
|
|
|
|
|
|
instance_ = this;
|
2017-04-06 02:06:42 +03:00
|
|
|
}
|
|
|
|
|
2017-08-20 13:47:22 +03:00
|
|
|
void
|
|
|
|
ChatPage::logout()
|
2017-04-09 02:17:04 +03:00
|
|
|
{
|
2017-10-20 22:32:48 +03:00
|
|
|
deleteConfigs();
|
|
|
|
|
|
|
|
resetUI();
|
|
|
|
|
2018-04-24 23:57:49 +03:00
|
|
|
emit closing();
|
2018-06-09 16:03:14 +03:00
|
|
|
connectivityTimer_.stop();
|
|
|
|
}
|
|
|
|
|
|
|
|
void
|
|
|
|
ChatPage::dropToLoginPage(const QString &msg)
|
|
|
|
{
|
|
|
|
deleteConfigs();
|
|
|
|
resetUI();
|
|
|
|
|
|
|
|
http::v2::client()->shutdown();
|
|
|
|
connectivityTimer_.stop();
|
|
|
|
|
|
|
|
emit showLoginPage(msg);
|
2017-10-20 22:32:48 +03:00
|
|
|
}
|
|
|
|
|
|
|
|
void
|
|
|
|
ChatPage::resetUI()
|
|
|
|
{
|
|
|
|
room_list_->clear();
|
|
|
|
top_bar_->reset();
|
|
|
|
user_info_widget_->reset();
|
|
|
|
view_manager_->clearAll();
|
2017-10-21 16:46:11 +03:00
|
|
|
|
|
|
|
showUnreadMessageNotification(0);
|
2017-10-20 22:32:48 +03:00
|
|
|
}
|
|
|
|
|
|
|
|
void
|
|
|
|
ChatPage::deleteConfigs()
|
|
|
|
{
|
2017-08-26 13:49:16 +03:00
|
|
|
QSettings settings;
|
|
|
|
settings.beginGroup("auth");
|
|
|
|
settings.remove("");
|
|
|
|
settings.endGroup();
|
|
|
|
settings.beginGroup("client");
|
|
|
|
settings.remove("");
|
|
|
|
settings.endGroup();
|
|
|
|
settings.beginGroup("notifications");
|
|
|
|
settings.remove("");
|
|
|
|
settings.endGroup();
|
|
|
|
|
2018-05-08 20:30:09 +03:00
|
|
|
cache::client()->deleteData();
|
2018-06-09 16:03:14 +03:00
|
|
|
http::v2::client()->clear();
|
2017-04-09 02:17:04 +03:00
|
|
|
}
|
|
|
|
|
2017-08-20 13:47:22 +03:00
|
|
|
void
|
|
|
|
ChatPage::bootstrap(QString userid, QString homeserver, QString token)
|
2017-04-06 02:06:42 +03:00
|
|
|
{
|
2018-06-09 16:03:14 +03:00
|
|
|
using namespace mtx::identifiers;
|
|
|
|
|
|
|
|
try {
|
|
|
|
http::v2::client()->set_user(parse<User>(userid.toStdString()));
|
|
|
|
} catch (const std::invalid_argument &e) {
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::ui()->critical("bootstrapped with invalid user_id: {}",
|
2018-06-09 16:03:14 +03:00
|
|
|
userid.toStdString());
|
|
|
|
}
|
|
|
|
|
|
|
|
http::v2::client()->set_server(homeserver.toStdString());
|
|
|
|
http::v2::client()->set_access_token(token.toStdString());
|
2017-08-26 13:49:16 +03:00
|
|
|
|
2018-06-10 20:03:45 +03:00
|
|
|
// The Olm client needs the user_id & device_id that will be included
|
|
|
|
// in the generated payloads & keys.
|
|
|
|
olm::client()->set_user_id(http::v2::client()->user_id().to_string());
|
|
|
|
olm::client()->set_device_id(http::v2::client()->device_id());
|
|
|
|
|
2017-08-26 13:49:16 +03:00
|
|
|
try {
|
2018-06-12 20:36:16 +03:00
|
|
|
cache::init(userid);
|
2017-10-03 21:16:31 +03:00
|
|
|
|
2018-06-12 20:36:16 +03:00
|
|
|
const bool isInitialized = cache::client()->isInitialized();
|
|
|
|
const bool isValid = cache::client()->isFormatValid();
|
|
|
|
|
|
|
|
if (isInitialized && !isValid) {
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::db()->warn("breaking changes in cache");
|
2018-06-12 20:36:16 +03:00
|
|
|
// TODO: Deleting session data but keep using the
|
|
|
|
// same device doesn't work.
|
2018-05-08 20:30:09 +03:00
|
|
|
cache::client()->deleteData();
|
2017-12-10 13:51:44 +03:00
|
|
|
|
2018-06-12 20:36:16 +03:00
|
|
|
cache::init(userid);
|
|
|
|
cache::client()->setCurrentFormat();
|
|
|
|
} else if (isInitialized) {
|
2017-10-03 21:16:31 +03:00
|
|
|
loadStateFromCache();
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
} catch (const lmdb::error &e) {
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::db()->critical("failure during boot: {}", e.what());
|
2018-05-08 20:30:09 +03:00
|
|
|
cache::client()->deleteData();
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::net()->info("falling back to initial sync");
|
2017-08-26 13:49:16 +03:00
|
|
|
}
|
|
|
|
|
2018-06-10 20:03:45 +03:00
|
|
|
try {
|
|
|
|
// It's the first time syncing with this device
|
|
|
|
// There isn't a saved olm account to restore.
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::crypto()->info("creating new olm account");
|
2018-06-10 20:03:45 +03:00
|
|
|
olm::client()->create_new_account();
|
|
|
|
cache::client()->saveOlmAccount(olm::client()->save(STORAGE_SECRET_KEY));
|
|
|
|
} catch (const lmdb::error &e) {
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::crypto()->critical("failed to save olm account {}", e.what());
|
2018-06-10 20:03:45 +03:00
|
|
|
emit dropToLoginPageCb(QString::fromStdString(e.what()));
|
|
|
|
return;
|
|
|
|
} catch (const mtx::crypto::olm_exception &e) {
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::crypto()->critical("failed to create new olm account {}", e.what());
|
2018-06-10 20:03:45 +03:00
|
|
|
emit dropToLoginPageCb(QString::fromStdString(e.what()));
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
2018-06-12 20:36:16 +03:00
|
|
|
getProfileInfo();
|
2018-06-09 16:03:14 +03:00
|
|
|
tryInitialSync();
|
2017-04-06 02:06:42 +03:00
|
|
|
}
|
|
|
|
|
2017-08-20 13:47:22 +03:00
|
|
|
void
|
|
|
|
ChatPage::updateTopBarAvatar(const QString &roomid, const QPixmap &img)
|
2017-04-06 02:06:42 +03:00
|
|
|
{
|
2017-08-26 13:49:16 +03:00
|
|
|
if (current_room_ != roomid)
|
|
|
|
return;
|
2017-04-06 02:06:42 +03:00
|
|
|
|
2017-08-26 13:49:16 +03:00
|
|
|
top_bar_->updateRoomAvatar(img.toImage());
|
2017-04-06 02:06:42 +03:00
|
|
|
}
|
|
|
|
|
2018-01-09 16:07:32 +03:00
|
|
|
void
|
|
|
|
ChatPage::updateOwnCommunitiesInfo(const QList<QString> &own_communities)
|
|
|
|
{
|
|
|
|
for (int i = 0; i < own_communities.size(); i++) {
|
|
|
|
QSharedPointer<Community> community = QSharedPointer<Community>(new Community());
|
|
|
|
|
2018-01-24 21:46:37 +03:00
|
|
|
communities_[own_communities[i]] = community;
|
2018-01-09 16:07:32 +03:00
|
|
|
}
|
|
|
|
|
2018-01-24 21:46:37 +03:00
|
|
|
communitiesList_->setCommunities(communities_);
|
2018-01-09 16:07:32 +03:00
|
|
|
}
|
|
|
|
|
2017-08-20 13:47:22 +03:00
|
|
|
void
|
|
|
|
ChatPage::changeTopRoomInfo(const QString &room_id)
|
2017-04-06 02:06:42 +03:00
|
|
|
{
|
2018-04-22 11:27:00 +03:00
|
|
|
if (room_id.isEmpty()) {
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::ui()->warn("cannot switch to empty room_id");
|
2018-04-22 11:27:00 +03:00
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
2018-04-21 16:34:50 +03:00
|
|
|
try {
|
2018-05-08 20:30:09 +03:00
|
|
|
auto room_info = cache::client()->getRoomInfo({room_id.toStdString()});
|
2017-04-06 02:06:42 +03:00
|
|
|
|
2018-04-21 16:34:50 +03:00
|
|
|
if (room_info.find(room_id) == room_info.end())
|
|
|
|
return;
|
2017-05-07 17:15:38 +03:00
|
|
|
|
2018-04-21 16:34:50 +03:00
|
|
|
const auto name = QString::fromStdString(room_info[room_id].name);
|
|
|
|
const auto avatar_url = QString::fromStdString(room_info[room_id].avatar_url);
|
2017-05-07 17:15:38 +03:00
|
|
|
|
2018-04-21 16:34:50 +03:00
|
|
|
top_bar_->updateRoomName(name);
|
|
|
|
top_bar_->updateRoomTopic(QString::fromStdString(room_info[room_id].topic));
|
|
|
|
|
2018-05-08 20:30:09 +03:00
|
|
|
auto img = cache::client()->getRoomAvatar(room_id);
|
2018-04-24 14:13:05 +03:00
|
|
|
|
|
|
|
if (img.isNull())
|
2018-04-21 16:34:50 +03:00
|
|
|
top_bar_->updateRoomAvatarFromName(name);
|
2018-04-24 14:13:05 +03:00
|
|
|
else
|
|
|
|
top_bar_->updateRoomAvatar(img);
|
2018-04-22 11:27:00 +03:00
|
|
|
|
2018-04-21 16:34:50 +03:00
|
|
|
} catch (const lmdb::error &e) {
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::ui()->error("failed to change top bar room info: {}", e.what());
|
2018-04-21 16:34:50 +03:00
|
|
|
}
|
2018-04-24 14:13:05 +03:00
|
|
|
|
|
|
|
current_room_ = room_id;
|
2017-04-06 02:06:42 +03:00
|
|
|
}
|
|
|
|
|
2017-08-20 13:47:22 +03:00
|
|
|
void
|
|
|
|
ChatPage::showUnreadMessageNotification(int count)
|
2017-04-15 19:04:02 +03:00
|
|
|
{
|
2017-08-26 13:49:16 +03:00
|
|
|
emit unreadMessages(count);
|
2017-04-15 19:04:02 +03:00
|
|
|
|
2017-08-26 13:49:16 +03:00
|
|
|
// TODO: Make the default title a const.
|
|
|
|
if (count == 0)
|
|
|
|
emit changeWindowTitle("nheko");
|
|
|
|
else
|
|
|
|
emit changeWindowTitle(QString("nheko (%1)").arg(count));
|
2017-05-07 17:15:38 +03:00
|
|
|
}
|
|
|
|
|
2017-08-20 13:47:22 +03:00
|
|
|
void
|
|
|
|
ChatPage::loadStateFromCache()
|
2017-07-29 11:49:00 +03:00
|
|
|
{
|
2018-06-28 16:16:43 +03:00
|
|
|
emit contentLoaded();
|
|
|
|
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::db()->info("restoring state from cache");
|
2017-07-29 11:49:00 +03:00
|
|
|
|
2018-06-12 20:36:16 +03:00
|
|
|
getProfileInfo();
|
|
|
|
|
2018-04-21 16:34:50 +03:00
|
|
|
QtConcurrent::run([this]() {
|
|
|
|
try {
|
2018-06-10 20:03:45 +03:00
|
|
|
cache::client()->restoreSessions();
|
|
|
|
olm::client()->load(cache::client()->restoreOlmAccount(),
|
|
|
|
STORAGE_SECRET_KEY);
|
|
|
|
|
2018-05-08 20:30:09 +03:00
|
|
|
cache::client()->populateMembers();
|
2017-10-08 21:35:37 +03:00
|
|
|
|
2018-06-28 16:16:43 +03:00
|
|
|
emit initializeEmptyViews(cache::client()->roomMessages());
|
2018-05-08 20:30:09 +03:00
|
|
|
emit initializeRoomList(cache::client()->roomInfo());
|
2018-06-28 16:16:43 +03:00
|
|
|
|
2018-06-10 20:03:45 +03:00
|
|
|
} catch (const mtx::crypto::olm_exception &e) {
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::crypto()->critical("failed to restore olm account: {}", e.what());
|
2018-06-10 20:03:45 +03:00
|
|
|
emit dropToLoginPageCb(
|
|
|
|
tr("Failed to restore OLM account. Please login again."));
|
|
|
|
return;
|
2018-04-21 16:34:50 +03:00
|
|
|
} catch (const lmdb::error &e) {
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::db()->critical("failed to restore cache: {}", e.what());
|
2018-06-10 20:03:45 +03:00
|
|
|
emit dropToLoginPageCb(
|
|
|
|
tr("Failed to restore save data. Please login again."));
|
2018-04-21 16:34:50 +03:00
|
|
|
return;
|
2018-06-28 16:16:43 +03:00
|
|
|
} catch (const json::exception &e) {
|
|
|
|
nhlog::db()->critical("failed to parse cache data: {}", e.what());
|
|
|
|
return;
|
2018-04-21 16:34:50 +03:00
|
|
|
}
|
2018-01-24 21:46:37 +03:00
|
|
|
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::crypto()->info("ed25519 : {}", olm::client()->identity_keys().ed25519);
|
|
|
|
nhlog::crypto()->info("curve25519: {}", olm::client()->identity_keys().curve25519);
|
2018-06-10 20:03:45 +03:00
|
|
|
|
2018-04-21 16:34:50 +03:00
|
|
|
// Start receiving events.
|
2018-06-09 16:03:14 +03:00
|
|
|
emit trySyncCb();
|
2018-04-21 16:34:50 +03:00
|
|
|
});
|
2017-07-29 11:49:00 +03:00
|
|
|
}
|
|
|
|
|
2017-08-20 13:47:22 +03:00
|
|
|
void
|
|
|
|
ChatPage::showQuickSwitcher()
|
2017-08-15 21:06:27 +03:00
|
|
|
{
|
2017-10-07 20:09:34 +03:00
|
|
|
if (quickSwitcher_.isNull()) {
|
|
|
|
quickSwitcher_ = QSharedPointer<QuickSwitcher>(
|
2018-05-08 20:30:09 +03:00
|
|
|
new QuickSwitcher(this),
|
2018-02-20 18:09:11 +03:00
|
|
|
[](QuickSwitcher *switcher) { switcher->deleteLater(); });
|
2017-08-26 13:49:16 +03:00
|
|
|
|
2017-10-07 20:09:34 +03:00
|
|
|
connect(quickSwitcher_.data(),
|
2017-08-26 13:49:16 +03:00
|
|
|
&QuickSwitcher::roomSelected,
|
|
|
|
room_list_,
|
|
|
|
&RoomList::highlightSelectedRoom);
|
2017-10-07 20:09:34 +03:00
|
|
|
|
2018-02-20 18:09:11 +03:00
|
|
|
connect(quickSwitcher_.data(), &QuickSwitcher::closing, this, [this]() {
|
|
|
|
if (!quickSwitcherModal_.isNull())
|
|
|
|
quickSwitcherModal_->hide();
|
|
|
|
text_input_->setFocus(Qt::FocusReason::PopupFocusReason);
|
2017-08-26 13:49:16 +03:00
|
|
|
});
|
|
|
|
}
|
|
|
|
|
2017-10-07 20:09:34 +03:00
|
|
|
if (quickSwitcherModal_.isNull()) {
|
|
|
|
quickSwitcherModal_ = QSharedPointer<OverlayModal>(
|
|
|
|
new OverlayModal(MainWindow::instance(), quickSwitcher_.data()),
|
2018-02-20 18:09:11 +03:00
|
|
|
[](OverlayModal *modal) { modal->deleteLater(); });
|
2017-11-22 22:13:22 +03:00
|
|
|
quickSwitcherModal_->setColor(QColor(30, 30, 30, 170));
|
2017-08-26 13:49:16 +03:00
|
|
|
}
|
|
|
|
|
2018-04-27 01:57:46 +03:00
|
|
|
quickSwitcherModal_->show();
|
2017-10-01 19:49:36 +03:00
|
|
|
}
|
|
|
|
|
2017-12-19 23:36:12 +03:00
|
|
|
void
|
2018-04-21 16:34:50 +03:00
|
|
|
ChatPage::removeRoom(const QString &room_id)
|
2017-12-19 23:36:12 +03:00
|
|
|
{
|
|
|
|
try {
|
2018-05-08 20:30:09 +03:00
|
|
|
cache::client()->removeRoom(room_id);
|
|
|
|
cache::client()->removeInvite(room_id.toStdString());
|
2017-12-19 23:36:12 +03:00
|
|
|
} catch (const lmdb::error &e) {
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::db()->critical("failure while removing room: {}", e.what());
|
2017-12-19 23:36:12 +03:00
|
|
|
// TODO: Notify the user.
|
|
|
|
}
|
|
|
|
|
|
|
|
room_list_->removeRoom(room_id, room_id == current_room_);
|
|
|
|
}
|
|
|
|
|
2017-10-04 11:33:34 +03:00
|
|
|
void
|
2017-12-04 19:41:19 +03:00
|
|
|
ChatPage::updateTypingUsers(const QString &roomid, const std::vector<std::string> &user_ids)
|
2017-10-04 11:33:34 +03:00
|
|
|
{
|
2018-01-14 16:57:58 +03:00
|
|
|
if (!userSettings_->isTypingNotificationsEnabled())
|
|
|
|
return;
|
|
|
|
|
2018-04-24 14:50:47 +03:00
|
|
|
typingUsers_[roomid] = generateTypingUsers(roomid, user_ids);
|
|
|
|
|
|
|
|
if (current_room_ == roomid)
|
|
|
|
typingDisplay_->setUsers(typingUsers_[roomid]);
|
|
|
|
}
|
2018-03-25 00:16:15 +03:00
|
|
|
|
2018-04-24 14:50:47 +03:00
|
|
|
QStringList
|
|
|
|
ChatPage::generateTypingUsers(const QString &room_id, const std::vector<std::string> &typing_users)
|
|
|
|
{
|
2017-10-04 11:33:34 +03:00
|
|
|
QStringList users;
|
|
|
|
|
2017-10-31 21:11:49 +03:00
|
|
|
QSettings settings;
|
2018-04-24 14:50:47 +03:00
|
|
|
QString local_user = settings.value("auth/user_id").toString();
|
2017-10-31 21:11:49 +03:00
|
|
|
|
2018-04-24 14:50:47 +03:00
|
|
|
for (const auto &uid : typing_users) {
|
|
|
|
const auto remote_user = QString::fromStdString(uid);
|
2017-12-04 19:41:19 +03:00
|
|
|
|
2018-04-24 14:50:47 +03:00
|
|
|
if (remote_user == local_user)
|
2017-10-31 21:11:49 +03:00
|
|
|
continue;
|
2017-12-04 19:41:19 +03:00
|
|
|
|
2018-04-24 14:50:47 +03:00
|
|
|
users.append(Cache::displayName(room_id, remote_user));
|
2017-10-31 21:11:49 +03:00
|
|
|
}
|
2017-10-04 11:33:34 +03:00
|
|
|
|
|
|
|
users.sort();
|
|
|
|
|
2018-04-24 14:50:47 +03:00
|
|
|
return users;
|
2017-10-04 11:33:34 +03:00
|
|
|
}
|
|
|
|
|
2017-10-28 20:46:34 +03:00
|
|
|
void
|
2017-12-04 19:41:19 +03:00
|
|
|
ChatPage::removeLeftRooms(const std::map<std::string, mtx::responses::LeftRoom> &rooms)
|
2017-10-28 20:46:34 +03:00
|
|
|
{
|
2017-12-04 19:41:19 +03:00
|
|
|
for (auto it = rooms.cbegin(); it != rooms.cend(); ++it) {
|
|
|
|
const auto room_id = QString::fromStdString(it->first);
|
2018-04-21 16:34:50 +03:00
|
|
|
room_list_->removeRoom(room_id, room_id == current_room_);
|
2017-10-28 20:46:34 +03:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2018-01-03 19:05:49 +03:00
|
|
|
void
|
|
|
|
ChatPage::showReadReceipts(const QString &event_id)
|
|
|
|
{
|
|
|
|
if (receiptsDialog_.isNull()) {
|
|
|
|
receiptsDialog_ = QSharedPointer<dialogs::ReadReceipts>(
|
|
|
|
new dialogs::ReadReceipts(this),
|
2018-02-20 18:09:11 +03:00
|
|
|
[](dialogs::ReadReceipts *dialog) { dialog->deleteLater(); });
|
2018-01-03 19:05:49 +03:00
|
|
|
}
|
|
|
|
|
|
|
|
if (receiptsModal_.isNull()) {
|
|
|
|
receiptsModal_ = QSharedPointer<OverlayModal>(
|
|
|
|
new OverlayModal(MainWindow::instance(), receiptsDialog_.data()),
|
2018-02-20 18:09:11 +03:00
|
|
|
[](OverlayModal *modal) { modal->deleteLater(); });
|
2018-01-03 19:05:49 +03:00
|
|
|
receiptsModal_->setColor(QColor(30, 30, 30, 170));
|
|
|
|
}
|
|
|
|
|
2018-05-08 20:30:09 +03:00
|
|
|
receiptsDialog_->addUsers(cache::client()->readReceipts(event_id, current_room_));
|
2018-02-17 19:43:40 +03:00
|
|
|
receiptsModal_->show();
|
2018-01-03 19:05:49 +03:00
|
|
|
}
|
|
|
|
|
2018-01-09 22:57:41 +03:00
|
|
|
void
|
|
|
|
ChatPage::setGroupViewState(bool isEnabled)
|
|
|
|
{
|
|
|
|
if (!isEnabled) {
|
|
|
|
communitiesList_->communityChanged("world");
|
2018-04-28 15:27:12 +03:00
|
|
|
communitiesList_->hide();
|
2018-01-09 22:57:41 +03:00
|
|
|
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
2018-04-28 15:27:12 +03:00
|
|
|
communitiesList_->show();
|
2018-01-09 22:57:41 +03:00
|
|
|
}
|
|
|
|
|
2018-02-15 22:58:57 +03:00
|
|
|
void
|
|
|
|
ChatPage::updateRoomNotificationCount(const QString &room_id, uint16_t notification_count)
|
|
|
|
{
|
|
|
|
room_list_->updateUnreadMessageCount(room_id, notification_count);
|
|
|
|
}
|
2018-05-05 16:38:41 +03:00
|
|
|
|
|
|
|
void
|
|
|
|
ChatPage::sendDesktopNotifications(const mtx::responses::Notifications &res)
|
|
|
|
{
|
|
|
|
for (const auto &item : res.notifications) {
|
|
|
|
const auto event_id = utils::event_id(item.event);
|
|
|
|
|
|
|
|
try {
|
|
|
|
if (item.read) {
|
2018-05-08 20:30:09 +03:00
|
|
|
cache::client()->removeReadNotification(event_id);
|
2018-05-05 16:38:41 +03:00
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
2018-05-08 20:30:09 +03:00
|
|
|
if (!cache::client()->isNotificationSent(event_id)) {
|
2018-05-05 22:40:24 +03:00
|
|
|
const auto room_id = QString::fromStdString(item.room_id);
|
|
|
|
const auto user_id = utils::event_sender(item.event);
|
2018-05-05 16:38:41 +03:00
|
|
|
|
|
|
|
// We should only sent one notification per event.
|
2018-05-08 20:30:09 +03:00
|
|
|
cache::client()->markSentNotification(event_id);
|
2018-05-05 22:40:24 +03:00
|
|
|
|
2018-05-07 12:00:49 +03:00
|
|
|
// Don't send a notification when the current room is opened.
|
|
|
|
if (isRoomActive(room_id))
|
|
|
|
continue;
|
|
|
|
|
2018-05-05 22:40:24 +03:00
|
|
|
NotificationsManager::postNotification(
|
2018-05-08 20:30:09 +03:00
|
|
|
QString::fromStdString(
|
|
|
|
cache::client()->singleRoomInfo(item.room_id).name),
|
2018-05-05 22:40:24 +03:00
|
|
|
Cache::displayName(room_id, user_id),
|
2018-05-07 12:00:49 +03:00
|
|
|
utils::event_body(item.event));
|
2018-05-05 16:38:41 +03:00
|
|
|
}
|
|
|
|
} catch (const lmdb::error &e) {
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::db()->warn("error while sending desktop notification: {}", e.what());
|
2018-05-05 16:38:41 +03:00
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
2018-06-09 16:03:14 +03:00
|
|
|
|
|
|
|
void
|
|
|
|
ChatPage::tryInitialSync()
|
|
|
|
{
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::crypto()->info("ed25519 : {}", olm::client()->identity_keys().ed25519);
|
|
|
|
nhlog::crypto()->info("curve25519: {}", olm::client()->identity_keys().curve25519);
|
2018-06-09 16:03:14 +03:00
|
|
|
|
2018-06-10 20:03:45 +03:00
|
|
|
// Upload one time keys for the device.
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::crypto()->info("generating one time keys");
|
2018-06-10 20:03:45 +03:00
|
|
|
olm::client()->generate_one_time_keys(MAX_ONETIME_KEYS);
|
2018-06-09 16:03:14 +03:00
|
|
|
|
2018-06-10 20:03:45 +03:00
|
|
|
http::v2::client()->upload_keys(
|
|
|
|
olm::client()->create_upload_keys_request(),
|
|
|
|
[this](const mtx::responses::UploadKeys &res, mtx::http::RequestErr err) {
|
2018-06-09 16:03:14 +03:00
|
|
|
if (err) {
|
|
|
|
const int status_code = static_cast<int>(err->status_code);
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::crypto()->critical("failed to upload one time keys: {} {}",
|
|
|
|
err->matrix_error.error,
|
|
|
|
status_code);
|
2018-06-10 20:03:45 +03:00
|
|
|
// TODO We should have a timeout instead of keeping hammering the server.
|
2018-06-09 16:03:14 +03:00
|
|
|
emit tryInitialSyncCb();
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
2018-06-18 12:56:47 +03:00
|
|
|
olm::mark_keys_as_published();
|
|
|
|
|
2018-06-10 20:03:45 +03:00
|
|
|
for (const auto &entry : res.one_time_key_counts)
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::net()->info(
|
2018-06-10 20:03:45 +03:00
|
|
|
"uploaded {} {} one-time keys", entry.second, entry.first);
|
|
|
|
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::net()->info("trying initial sync");
|
2018-06-10 20:03:45 +03:00
|
|
|
|
|
|
|
mtx::http::SyncOpts opts;
|
|
|
|
opts.timeout = 0;
|
|
|
|
http::v2::client()->sync(opts,
|
|
|
|
std::bind(&ChatPage::initialSyncHandler,
|
|
|
|
this,
|
|
|
|
std::placeholders::_1,
|
|
|
|
std::placeholders::_2));
|
2018-06-09 16:03:14 +03:00
|
|
|
});
|
|
|
|
}
|
|
|
|
|
|
|
|
void
|
|
|
|
ChatPage::trySync()
|
|
|
|
{
|
|
|
|
mtx::http::SyncOpts opts;
|
|
|
|
|
|
|
|
if (!connectivityTimer_.isActive())
|
|
|
|
connectivityTimer_.start();
|
|
|
|
|
|
|
|
try {
|
|
|
|
opts.since = cache::client()->nextBatchToken();
|
|
|
|
} catch (const lmdb::error &e) {
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::db()->error("failed to retrieve next batch token: {}", e.what());
|
2018-06-09 16:03:14 +03:00
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
http::v2::client()->sync(
|
|
|
|
opts, [this](const mtx::responses::Sync &res, mtx::http::RequestErr err) {
|
|
|
|
if (err) {
|
|
|
|
const auto error = QString::fromStdString(err->matrix_error.error);
|
|
|
|
const auto msg = tr("Please try to login again: %1").arg(error);
|
|
|
|
const auto err_code = mtx::errors::to_string(err->matrix_error.errcode);
|
|
|
|
const int status_code = static_cast<int>(err->status_code);
|
|
|
|
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::net()->error("sync error: {} {}", status_code, err_code);
|
2018-06-09 16:03:14 +03:00
|
|
|
|
2018-06-10 20:03:45 +03:00
|
|
|
if (status_code <= 0 || status_code >= 600) {
|
|
|
|
if (!http::v2::is_logged_in())
|
|
|
|
return;
|
|
|
|
|
2018-06-17 16:53:14 +03:00
|
|
|
emit tryDelayedSyncCb();
|
2018-06-10 20:03:45 +03:00
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
2018-06-09 16:03:14 +03:00
|
|
|
switch (status_code) {
|
|
|
|
case 502:
|
|
|
|
case 504:
|
|
|
|
case 524: {
|
2018-06-10 20:03:45 +03:00
|
|
|
emit trySyncCb();
|
2018-06-09 16:03:14 +03:00
|
|
|
return;
|
|
|
|
}
|
2018-06-17 16:53:14 +03:00
|
|
|
default: {
|
2018-06-10 20:03:45 +03:00
|
|
|
if (!http::v2::is_logged_in())
|
2018-06-09 16:03:14 +03:00
|
|
|
return;
|
|
|
|
|
2018-06-17 16:53:14 +03:00
|
|
|
if (err->matrix_error.errcode ==
|
|
|
|
mtx::errors::ErrorCode::M_UNKNOWN_TOKEN)
|
|
|
|
emit dropToLoginPageCb(msg);
|
|
|
|
else
|
|
|
|
emit tryDelayedSyncCb();
|
|
|
|
|
2018-06-09 16:03:14 +03:00
|
|
|
return;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::net()->debug("sync completed: {}", res.next_batch);
|
2018-06-09 16:03:14 +03:00
|
|
|
|
2018-06-10 20:03:45 +03:00
|
|
|
// Ensure that we have enough one-time keys available.
|
|
|
|
ensureOneTimeKeyCount(res.device_one_time_keys_count);
|
|
|
|
|
2018-06-09 16:03:14 +03:00
|
|
|
// TODO: fine grained error handling
|
|
|
|
try {
|
|
|
|
cache::client()->saveState(res);
|
2018-06-10 20:03:45 +03:00
|
|
|
olm::handle_to_device_messages(res.to_device);
|
|
|
|
|
2018-06-09 16:03:14 +03:00
|
|
|
emit syncUI(res.rooms);
|
|
|
|
|
|
|
|
auto updates = cache::client()->roomUpdates(res);
|
|
|
|
|
|
|
|
emit syncTopBar(updates);
|
|
|
|
emit syncRoomlist(updates);
|
|
|
|
} catch (const lmdb::error &e) {
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::db()->error("saving sync response: {}", e.what());
|
2018-06-09 16:03:14 +03:00
|
|
|
}
|
|
|
|
|
|
|
|
emit trySyncCb();
|
|
|
|
});
|
|
|
|
}
|
|
|
|
|
|
|
|
void
|
|
|
|
ChatPage::joinRoom(const QString &room)
|
|
|
|
{
|
|
|
|
const auto room_id = room.toStdString();
|
|
|
|
|
|
|
|
http::v2::client()->join_room(
|
|
|
|
room_id, [this, room_id](const nlohmann::json &, mtx::http::RequestErr err) {
|
|
|
|
if (err) {
|
|
|
|
emit showNotification(
|
|
|
|
QString("Failed to join room: %1")
|
|
|
|
.arg(QString::fromStdString(err->matrix_error.error)));
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
emit showNotification("You joined the room");
|
|
|
|
|
|
|
|
// We remove any invites with the same room_id.
|
|
|
|
try {
|
|
|
|
cache::client()->removeInvite(room_id);
|
|
|
|
} catch (const lmdb::error &e) {
|
|
|
|
emit showNotification(
|
|
|
|
QString("Failed to remove invite: %1").arg(e.what()));
|
|
|
|
}
|
|
|
|
});
|
|
|
|
}
|
|
|
|
|
|
|
|
void
|
|
|
|
ChatPage::createRoom(const mtx::requests::CreateRoom &req)
|
|
|
|
{
|
|
|
|
http::v2::client()->create_room(
|
|
|
|
req, [this](const mtx::responses::CreateRoom &res, mtx::http::RequestErr err) {
|
|
|
|
if (err) {
|
|
|
|
emit showNotification(
|
|
|
|
tr("Room creation failed: %1")
|
|
|
|
.arg(QString::fromStdString(err->matrix_error.error)));
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
emit showNotification(QString("Room %1 created")
|
|
|
|
.arg(QString::fromStdString(res.room_id.to_string())));
|
|
|
|
});
|
|
|
|
}
|
|
|
|
|
|
|
|
void
|
|
|
|
ChatPage::leaveRoom(const QString &room_id)
|
|
|
|
{
|
|
|
|
http::v2::client()->leave_room(
|
|
|
|
room_id.toStdString(), [this, room_id](const json &, mtx::http::RequestErr err) {
|
|
|
|
if (err) {
|
|
|
|
emit showNotification(
|
|
|
|
tr("Failed to leave room: %1")
|
|
|
|
.arg(QString::fromStdString(err->matrix_error.error)));
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
emit leftRoom(room_id);
|
|
|
|
});
|
|
|
|
}
|
|
|
|
|
|
|
|
void
|
|
|
|
ChatPage::sendTypingNotifications()
|
|
|
|
{
|
|
|
|
if (!userSettings_->isTypingNotificationsEnabled())
|
|
|
|
return;
|
|
|
|
|
|
|
|
http::v2::client()->start_typing(
|
|
|
|
current_room_.toStdString(), 10'000, [](mtx::http::RequestErr err) {
|
|
|
|
if (err) {
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::net()->warn("failed to send typing notification: {}",
|
|
|
|
err->matrix_error.error);
|
2018-06-09 16:03:14 +03:00
|
|
|
}
|
|
|
|
});
|
|
|
|
}
|
2018-06-10 20:03:45 +03:00
|
|
|
|
|
|
|
void
|
|
|
|
ChatPage::initialSyncHandler(const mtx::responses::Sync &res, mtx::http::RequestErr err)
|
|
|
|
{
|
|
|
|
if (err) {
|
|
|
|
const auto error = QString::fromStdString(err->matrix_error.error);
|
|
|
|
const auto msg = tr("Please try to login again: %1").arg(error);
|
|
|
|
const auto err_code = mtx::errors::to_string(err->matrix_error.errcode);
|
|
|
|
const int status_code = static_cast<int>(err->status_code);
|
|
|
|
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::net()->error("sync error: {} {}", status_code, err_code);
|
2018-06-10 20:03:45 +03:00
|
|
|
|
|
|
|
switch (status_code) {
|
|
|
|
case 502:
|
|
|
|
case 504:
|
|
|
|
case 524: {
|
|
|
|
emit tryInitialSyncCb();
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
default: {
|
|
|
|
emit dropToLoginPageCb(msg);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::net()->info("initial sync completed");
|
2018-06-10 20:03:45 +03:00
|
|
|
|
|
|
|
try {
|
|
|
|
cache::client()->saveState(res);
|
|
|
|
|
|
|
|
olm::handle_to_device_messages(res.to_device);
|
|
|
|
|
|
|
|
emit initializeViews(std::move(res.rooms));
|
|
|
|
emit initializeRoomList(cache::client()->roomInfo());
|
|
|
|
} catch (const lmdb::error &e) {
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::db()->error("{}", e.what());
|
2018-06-10 20:03:45 +03:00
|
|
|
emit tryInitialSyncCb();
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
emit trySyncCb();
|
|
|
|
emit contentLoaded();
|
|
|
|
}
|
|
|
|
|
|
|
|
void
|
|
|
|
ChatPage::ensureOneTimeKeyCount(const std::map<std::string, uint16_t> &counts)
|
|
|
|
{
|
|
|
|
for (const auto &entry : counts) {
|
|
|
|
if (entry.second < MAX_ONETIME_KEYS) {
|
|
|
|
const int nkeys = MAX_ONETIME_KEYS - entry.second;
|
|
|
|
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::crypto()->info("uploading {} {} keys", nkeys, entry.first);
|
2018-06-10 20:03:45 +03:00
|
|
|
olm::client()->generate_one_time_keys(nkeys);
|
|
|
|
|
|
|
|
http::v2::client()->upload_keys(
|
|
|
|
olm::client()->create_upload_keys_request(),
|
|
|
|
[](const mtx::responses::UploadKeys &, mtx::http::RequestErr err) {
|
|
|
|
if (err) {
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::crypto()->warn(
|
2018-06-10 20:03:45 +03:00
|
|
|
"failed to update one-time keys: {} {}",
|
|
|
|
err->matrix_error.error,
|
|
|
|
static_cast<int>(err->status_code));
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
2018-06-18 12:56:47 +03:00
|
|
|
olm::mark_keys_as_published();
|
2018-06-10 20:03:45 +03:00
|
|
|
});
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
2018-06-12 20:36:16 +03:00
|
|
|
|
|
|
|
void
|
|
|
|
ChatPage::getProfileInfo()
|
|
|
|
{
|
|
|
|
QSettings settings;
|
|
|
|
const auto userid = settings.value("auth/user_id").toString().toStdString();
|
|
|
|
|
|
|
|
http::v2::client()->get_profile(
|
|
|
|
userid, [this](const mtx::responses::Profile &res, mtx::http::RequestErr err) {
|
|
|
|
if (err) {
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::net()->warn("failed to retrieve own profile info");
|
2018-06-12 20:36:16 +03:00
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
emit setUserDisplayName(QString::fromStdString(res.display_name));
|
|
|
|
|
|
|
|
if (cache::client()) {
|
|
|
|
auto data = cache::client()->image(res.avatar_url);
|
|
|
|
if (!data.isNull()) {
|
|
|
|
emit setUserAvatar(QImage::fromData(data));
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
if (res.avatar_url.empty())
|
|
|
|
return;
|
|
|
|
|
|
|
|
http::v2::client()->download(
|
|
|
|
res.avatar_url,
|
|
|
|
[this, res](const std::string &data,
|
|
|
|
const std::string &,
|
|
|
|
const std::string &,
|
|
|
|
mtx::http::RequestErr err) {
|
|
|
|
if (err) {
|
2018-06-14 02:28:35 +03:00
|
|
|
nhlog::net()->warn(
|
2018-06-12 20:36:16 +03:00
|
|
|
"failed to download user avatar: {} - {}",
|
|
|
|
mtx::errors::to_string(err->matrix_error.errcode),
|
|
|
|
err->matrix_error.error);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (cache::client())
|
|
|
|
cache::client()->saveImage(res.avatar_url, data);
|
|
|
|
|
|
|
|
emit setUserAvatar(
|
|
|
|
QImage::fromData(QByteArray(data.data(), data.size())));
|
|
|
|
});
|
|
|
|
});
|
|
|
|
// TODO http::client()->getOwnCommunities();
|
|
|
|
}
|
2018-07-04 00:05:05 +03:00
|
|
|
|
|
|
|
void
|
|
|
|
ChatPage::hideSideBars()
|
|
|
|
{
|
|
|
|
communitiesList_->hide();
|
|
|
|
sideBar_->hide();
|
|
|
|
top_bar_->enableBackButton();
|
|
|
|
}
|
|
|
|
|
|
|
|
void
|
|
|
|
ChatPage::showSideBars()
|
|
|
|
{
|
|
|
|
if (userSettings_->isGroupViewEnabled())
|
|
|
|
communitiesList_->show();
|
|
|
|
|
|
|
|
sideBar_->show();
|
|
|
|
top_bar_->disableBackButton();
|
|
|
|
}
|
|
|
|
|
|
|
|
int
|
|
|
|
ChatPage::timelineWidth()
|
|
|
|
{
|
|
|
|
int sidebarWidth = sideBar_->size().width();
|
|
|
|
sidebarWidth += communitiesList_->size().width();
|
|
|
|
|
|
|
|
return size().width() - sidebarWidth;
|
|
|
|
}
|
|
|
|
bool
|
|
|
|
ChatPage::isSideBarExpanded()
|
|
|
|
{
|
|
|
|
return sideBar_->size().width() > ui::sidebar::NormalSize;
|
|
|
|
}
|