1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
|
// SPDX-FileCopyrightText: Nheko Contributors
//
// SPDX-License-Identifier: GPL-3.0-or-later
#include "NhekoDBusBackend.h"
#include <mutex>
#include "Cache_p.h"
#include "ChatPage.h"
#include "Logging.h"
#include "MainWindow.h"
#include "MxcImageProvider.h"
#include "timeline/RoomlistModel.h"
#include <QDBusConnection>
NhekoDBusBackend::NhekoDBusBackend(RoomlistModel *parent)
: QObject{parent}
, m_parent{parent}
{
}
namespace {
struct RoomReplyState
{
QVector<nheko::dbus::RoomInfoItem> model;
std::map<QString, RoomInfo> roominfos;
std::mutex m;
};
}
QVector<nheko::dbus::RoomInfoItem>
NhekoDBusBackend::rooms() const
{
nhlog::ui()->debug("Rooms requested over D-Bus.");
const auto roomListModel = m_parent->models;
QVector<nheko::dbus::RoomInfoItem> model;
for (const auto &room : roomListModel) {
const auto aliases = cache::client()->getStateEvent<mtx::events::state::CanonicalAlias>(
room->roomId().toStdString());
QString alias;
if (aliases.has_value()) {
const auto &val = aliases.value().content;
if (!val.alias.empty())
alias = QString::fromStdString(val.alias);
else if (val.alt_aliases.size() > 0)
alias = QString::fromStdString(val.alt_aliases.front());
}
model.push_back(nheko::dbus::RoomInfoItem{room->roomId(),
alias,
room->plainRoomName(),
room->roomAvatarUrl(),
room->notificationCount()});
}
nhlog::ui()->debug("Sending {} rooms over D-Bus...", model.size());
return model;
}
QImage
NhekoDBusBackend::image(const QString &uri, const QDBusMessage &message) const
{
message.setDelayedReply(true);
nhlog::ui()->debug("Rooms requested over D-Bus.");
MainWindow::instance()->imageProvider()->download(
QString(uri).remove("mxc://"),
{96, 96},
[message](const QString &, const QSize &, const QImage &image, const QString &) {
auto reply = message.createReply();
reply << QVariant::fromValue(image);
QDBusConnection::sessionBus().send(reply);
},
true);
return {};
}
void
NhekoDBusBackend::activateRoom(const QString &alias) const
{
bringWindowToTop();
m_parent->setCurrentRoom(alias);
}
void
NhekoDBusBackend::joinRoom(const QString &alias) const
{
bringWindowToTop();
ChatPage::instance()->joinRoom(alias);
}
void
NhekoDBusBackend::directChat(const QString &userId) const
{
bringWindowToTop();
ChatPage::instance()->startChat(userId);
}
QString
NhekoDBusBackend::statusMessage() const
{
return ChatPage::instance()->status();
}
void
NhekoDBusBackend::setStatusMessage(const QString &message)
{
ChatPage::instance()->setStatus(message);
}
void
NhekoDBusBackend::bringWindowToTop() const
{
MainWindow::instance()->show();
MainWindow::instance()->raise();
}
|
