346 lines
11 KiB
C++
346 lines
11 KiB
C++
// SPDX-FileCopyrightText: 2018-2019 Black Hat <bhat@encom.eu.org>
|
|
// SPDX-License-Identifier: GPL-3.0-only
|
|
|
|
#include "roomlistmodel.h"
|
|
|
|
#include <Quotient/events/roommemberevent.h>
|
|
|
|
#include "enums/neochatroomtype.h"
|
|
#include "eventhandler.h"
|
|
#include "neochatconnection.h"
|
|
#include "neochatroom.h"
|
|
#include "roomlistlogging.h"
|
|
#include "spacehierarchycache.h"
|
|
|
|
#include <KLocalizedString>
|
|
|
|
using namespace Quotient;
|
|
|
|
Q_DECLARE_METATYPE(Quotient::JoinState)
|
|
|
|
std::function<bool(const Quotient::RoomEvent *)> RoomListModel::m_hiddenFilter = [](const Quotient::RoomEvent *) -> bool {
|
|
return false;
|
|
};
|
|
|
|
RoomListModel::RoomListModel(QObject *parent)
|
|
: QAbstractListModel(parent)
|
|
{
|
|
connect(&SpaceHierarchyCache::instance(), &SpaceHierarchyCache::spaceHierarchyChanged, this, [this]() {
|
|
Q_EMIT dataChanged(index(0, 0), index(rowCount(), 0), {IsChildSpaceRole});
|
|
});
|
|
}
|
|
|
|
RoomListModel::~RoomListModel() = default;
|
|
|
|
NeoChatConnection *RoomListModel::connection() const
|
|
{
|
|
return m_connection;
|
|
}
|
|
|
|
void RoomListModel::setConnection(NeoChatConnection *connection)
|
|
{
|
|
if (connection == m_connection) {
|
|
return;
|
|
}
|
|
if (m_connection) {
|
|
m_connection->disconnect(this);
|
|
}
|
|
if (!connection) {
|
|
qCDebug(RoomList) << "Removing current connection";
|
|
m_connection = nullptr;
|
|
beginResetModel();
|
|
m_rooms.clear();
|
|
endResetModel();
|
|
return;
|
|
}
|
|
|
|
m_connection = connection;
|
|
|
|
for (NeoChatRoom *room : std::as_const(m_rooms)) {
|
|
room->disconnect(this);
|
|
}
|
|
|
|
connect(connection, &Connection::connected, this, &RoomListModel::doResetModel);
|
|
connect(connection, &Connection::invitedRoom, this, &RoomListModel::updateRoom);
|
|
connect(connection, &Connection::joinedRoom, this, &RoomListModel::updateRoom);
|
|
connect(connection, &Connection::leftRoom, this, &RoomListModel::updateRoom);
|
|
connect(connection, &Connection::aboutToDeleteRoom, this, &RoomListModel::deleteRoom);
|
|
connect(connection, &Connection::directChatsListChanged, this, [this, connection](Quotient::DirectChatsMap additions, Quotient::DirectChatsMap removals) {
|
|
auto refreshRooms = [this, &connection](Quotient::DirectChatsMap rooms) {
|
|
for (const QString &roomID : std::as_const(rooms)) {
|
|
auto room = connection->room(roomID);
|
|
if (room) {
|
|
refresh(static_cast<NeoChatRoom *>(room));
|
|
}
|
|
}
|
|
};
|
|
|
|
refreshRooms(std::move(additions));
|
|
refreshRooms(std::move(removals));
|
|
});
|
|
|
|
doResetModel();
|
|
|
|
Q_EMIT connectionChanged();
|
|
}
|
|
|
|
void RoomListModel::doResetModel()
|
|
{
|
|
beginResetModel();
|
|
m_rooms.clear();
|
|
const auto rooms = m_connection->allRooms();
|
|
for (const auto &room : rooms) {
|
|
doAddRoom(room);
|
|
}
|
|
endResetModel();
|
|
}
|
|
|
|
NeoChatRoom *RoomListModel::roomAt(int row) const
|
|
{
|
|
auto room = m_rooms.at(row);
|
|
QQmlEngine::setObjectOwnership(room, QQmlEngine::CppOwnership);
|
|
return room;
|
|
}
|
|
|
|
void RoomListModel::doAddRoom(Room *r)
|
|
{
|
|
Q_ASSERT(r);
|
|
if (!r) {
|
|
qCCritical(RoomList) << "Attempt to add nullptr to the room list";
|
|
return;
|
|
}
|
|
const auto room = static_cast<NeoChatRoom *>(r);
|
|
m_rooms.append(room);
|
|
connectRoomSignals(room);
|
|
Q_EMIT roomAdded(room);
|
|
}
|
|
|
|
void RoomListModel::connectRoomSignals(NeoChatRoom *room)
|
|
{
|
|
connect(room, &Room::displaynameChanged, this, [this, room] {
|
|
refresh(room, {DisplayNameRole});
|
|
});
|
|
connect(room, &Room::changed, this, [this, room](Room::Changes changes) {
|
|
if (changes & (Room::Change::UnreadStats | Room::Change::Highlights)) {
|
|
refresh(room, {ContextNotificationCountRole, HasHighlightNotificationsRole, NotificationCountRole});
|
|
}
|
|
});
|
|
connect(room, &Room::notificationCountChanged, this, [this, room] {
|
|
refresh(room);
|
|
});
|
|
connect(room, &Room::highlightCountChanged, this, [this, room] {
|
|
refresh(room);
|
|
});
|
|
connect(room, &Room::avatarChanged, this, [this, room] {
|
|
refresh(room, {AvatarRole});
|
|
});
|
|
connect(room, &Room::tagsChanged, this, [this, room] {
|
|
refresh(room);
|
|
});
|
|
connect(room, &Room::joinStateChanged, this, [this, room] {
|
|
refresh(room);
|
|
});
|
|
connect(room, &Room::addedMessages, this, [this, room] {
|
|
refresh(room, {SubtitleTextRole});
|
|
});
|
|
connect(room, &Room::pendingEventMerged, this, [this, room] {
|
|
refresh(room, {SubtitleTextRole});
|
|
});
|
|
}
|
|
|
|
void RoomListModel::updateRoom(Room *room, Room *prev)
|
|
{
|
|
// There are two cases when this method is called:
|
|
// 1. (prev == nullptr) adding a new room to the room list
|
|
// 2. (prev != nullptr) accepting/rejecting an invitation or inviting to
|
|
// the previously left room (in both cases prev has the previous state).
|
|
if (prev == room) {
|
|
qCCritical(RoomList) << "RoomListModel::updateRoom: room tried to replace itself";
|
|
refresh(static_cast<NeoChatRoom *>(room));
|
|
return;
|
|
}
|
|
if (prev && room->id() != prev->id()) {
|
|
qCCritical(RoomList) << "RoomListModel::updateRoom: attempt to update room" << room->id() << "to" << prev->id();
|
|
// That doesn't look right but technically we still can do it.
|
|
}
|
|
// Ok, we're through with pre-checks, now for the real thing.
|
|
auto newRoom = static_cast<NeoChatRoom *>(room);
|
|
const auto it = std::find_if(m_rooms.begin(), m_rooms.end(), [prev, newRoom](const NeoChatRoom *r) {
|
|
return r == prev || r == newRoom;
|
|
});
|
|
if (it != m_rooms.end()) {
|
|
const int row = it - m_rooms.begin();
|
|
// There's no guarantee that prev != newRoom
|
|
if (*it == prev && *it != newRoom) {
|
|
prev->disconnect(this);
|
|
m_rooms.replace(row, newRoom);
|
|
connectRoomSignals(newRoom);
|
|
}
|
|
Q_EMIT dataChanged(index(row), index(row));
|
|
} else {
|
|
beginInsertRows(QModelIndex(), m_rooms.count(), m_rooms.count());
|
|
doAddRoom(newRoom);
|
|
endInsertRows();
|
|
}
|
|
}
|
|
|
|
void RoomListModel::deleteRoom(Room *room)
|
|
{
|
|
qCDebug(RoomList) << "Deleting room" << room->id();
|
|
const auto it = std::find(m_rooms.begin(), m_rooms.end(), room);
|
|
if (it == m_rooms.end()) {
|
|
return; // Already deleted, nothing to do
|
|
}
|
|
qCDebug(RoomList) << "Erasing room" << room->id();
|
|
const int row = it - m_rooms.begin();
|
|
beginRemoveRows(QModelIndex(), row, row);
|
|
m_rooms.erase(it);
|
|
endRemoveRows();
|
|
}
|
|
|
|
int RoomListModel::rowCount(const QModelIndex &parent) const
|
|
{
|
|
if (parent.isValid()) {
|
|
return 0;
|
|
}
|
|
return m_rooms.count();
|
|
}
|
|
|
|
QVariant RoomListModel::data(const QModelIndex &index, int role) const
|
|
{
|
|
if (!index.isValid()) {
|
|
return QVariant();
|
|
}
|
|
|
|
if (index.row() >= m_rooms.count()) {
|
|
qCWarning(RoomList) << __FUNCTION__ << "called with invalid index" << index << m_rooms.count();
|
|
return QVariant();
|
|
}
|
|
NeoChatRoom *room = m_rooms.at(index.row());
|
|
if (role == DisplayNameRole || role == Qt::DisplayRole) {
|
|
return room->displayName();
|
|
}
|
|
if (role == EscapedDisplayNameRole) {
|
|
return room->displayName().toHtmlEscaped();
|
|
}
|
|
if (role == AvatarRole) {
|
|
return room->avatarMediaUrl();
|
|
}
|
|
if (role == CanonicalAliasRole) {
|
|
return room->canonicalAlias();
|
|
}
|
|
if (role == TopicRole) {
|
|
return room->topic();
|
|
}
|
|
if (role == CategoryRole) {
|
|
return NeoChatRoomType::typeForRoom(room);
|
|
}
|
|
if (role == ContextNotificationCountRole) {
|
|
return room->contextAwareNotificationCount();
|
|
}
|
|
if (role == HasHighlightNotificationsRole) {
|
|
return room->highlightCount() > 0 && room->contextAwareNotificationCount() > 0;
|
|
}
|
|
if (role == JoinStateRole) {
|
|
if (!room->successorId().isEmpty()) {
|
|
return u"upgraded"_s;
|
|
}
|
|
return QVariant::fromValue(room->joinState());
|
|
}
|
|
if (role == CurrentRoomRole) {
|
|
return QVariant::fromValue(room);
|
|
}
|
|
if (role == SubtitleTextRole) {
|
|
const auto lastEvent = room->lastEvent(m_hiddenFilter);
|
|
if (lastEvent == nullptr || room->isEventSpoiler(lastEvent)) {
|
|
return QString();
|
|
}
|
|
return EventHandler::subtitleText(room, lastEvent);
|
|
}
|
|
if (role == AvatarImageRole) {
|
|
return room->avatar(128);
|
|
}
|
|
if (role == RoomIdRole) {
|
|
return room->id();
|
|
}
|
|
if (role == IsSpaceRole) {
|
|
return room->isSpace();
|
|
}
|
|
if (role == IsChildSpaceRole) {
|
|
return SpaceHierarchyCache::instance().isChild(room->id());
|
|
}
|
|
if (role == ReplacementIdRole) {
|
|
return room->successorId();
|
|
}
|
|
if (role == IsDirectChat) {
|
|
return room->isDirectChat();
|
|
}
|
|
if (role == NotificationCountRole) {
|
|
return room->notificationCount();
|
|
}
|
|
if (role == RoomTypeRole) {
|
|
if (room->creation()) {
|
|
return room->creation()->contentPart<QString>("type"_L1);
|
|
}
|
|
}
|
|
|
|
return QVariant();
|
|
}
|
|
|
|
void RoomListModel::refresh(NeoChatRoom *room, const QList<int> &roles)
|
|
{
|
|
const auto it = std::find(m_rooms.begin(), m_rooms.end(), room);
|
|
if (it == m_rooms.end()) {
|
|
qCCritical(RoomList) << "Room" << room->id() << "not found in the room list";
|
|
return;
|
|
}
|
|
const auto idx = index(it - m_rooms.begin());
|
|
Q_EMIT dataChanged(idx, idx, roles);
|
|
}
|
|
|
|
QHash<int, QByteArray> RoomListModel::roleNames() const
|
|
{
|
|
QHash<int, QByteArray> roles;
|
|
roles[DisplayNameRole] = "displayName";
|
|
roles[EscapedDisplayNameRole] = "escapedDisplayName";
|
|
roles[AvatarRole] = "avatar";
|
|
roles[CanonicalAliasRole] = "canonicalAlias";
|
|
roles[TopicRole] = "topic";
|
|
roles[CategoryRole] = "category";
|
|
roles[ContextNotificationCountRole] = "contextNotificationCount";
|
|
roles[HasHighlightNotificationsRole] = "hasHighlightNotifications";
|
|
roles[JoinStateRole] = "joinState";
|
|
roles[CurrentRoomRole] = "currentRoom";
|
|
roles[SubtitleTextRole] = "subtitleText";
|
|
roles[IsSpaceRole] = "isSpace";
|
|
roles[RoomIdRole] = "roomId";
|
|
roles[IsChildSpaceRole] = "isChildSpace";
|
|
roles[IsDirectChat] = "isDirectChat";
|
|
roles[NotificationCountRole] = "notificationCount";
|
|
roles[RoomTypeRole] = "roomType";
|
|
return roles;
|
|
}
|
|
|
|
NeoChatRoom *RoomListModel::roomByAliasOrId(const QString &aliasOrId)
|
|
{
|
|
for (const auto &room : std::as_const(m_rooms)) {
|
|
if (room->aliases().contains(aliasOrId) || room->id() == aliasOrId) {
|
|
QQmlEngine::setObjectOwnership(room, QQmlEngine::CppOwnership);
|
|
return room;
|
|
}
|
|
}
|
|
return nullptr;
|
|
}
|
|
|
|
int RoomListModel::rowForRoom(NeoChatRoom *room) const
|
|
{
|
|
return m_rooms.indexOf(room);
|
|
}
|
|
|
|
void RoomListModel::setHiddenFilter(std::function<bool(const Quotient::RoomEvent *)> hiddenFilter)
|
|
{
|
|
RoomListModel::m_hiddenFilter = hiddenFilter;
|
|
}
|
|
|
|
#include "moc_roomlistmodel.cpp"
|