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: 2018 Kitsune Ral <kitsune-ral@users.sf.net>
// SPDX-License-Identifier: LGPL-2.1-or-later
#pragma once
#include "quotient_common.h"
#include "events/stateevent.h"
namespace Quotient {
constexpr inline auto UnreadNotificationsKey = "unread_notifications"_L1;
constexpr inline auto PartiallyReadCountKey = "x-quotient.since_fully_read_count"_L1;
constexpr inline auto NewUnreadCountKey = "org.matrix.msc2654.unread_count"_L1;
constexpr inline auto HighlightCountKey = "highlight_count"_L1;
//! \brief Room summary, as defined in MSC688
//!
//! Every member of this structure is an optional; as per the MSC, only changed values are sent
//! from the server so if nothing is in the payload the respective member will be omitted.
//! In particular, `!heroes.has_value()` means that nothing has come from the server;
//! `heroes.value().isEmpty()` means a peculiar but valid case of a room with the only member -
//! the current user.
struct QUOTIENT_API RoomSummary {
std::optional<int> joinedMemberCount;
std::optional<int> invitedMemberCount;
std::optional<QStringList> heroes; //!< mxids used to form the room name
bool isEmpty() const;
};
QUOTIENT_API QDebug operator<<(QDebug dbg, const RoomSummary& rs);
template <>
struct JsonObjectConverter<RoomSummary> {
static void dumpTo(QJsonObject& jo, const RoomSummary& rs);
static void fillFrom(const QJsonObject& jo, RoomSummary& rs);
};
/// Information on e2e device updates. Note: only present on an
/// incremental sync.
struct DevicesList {
/// List of users who have updated their device identity keys, or who
/// now share an encrypted room with the client since the previous
/// sync response.
QStringList changed;
/// List of users with whom we do not share any encrypted rooms
/// any more since the previous sync response.
QStringList left;
};
QDebug operator<<(QDebug dhg, const DevicesList& devicesList);
template <>
struct JsonObjectConverter<DevicesList> {
static void dumpTo(QJsonObject &jo, const DevicesList &dev);
static void fillFrom(const QJsonObject& jo, DevicesList& rs);
};
class QUOTIENT_API SyncRoomData {
public:
QString roomId;
JoinState joinState;
RoomSummary summary;
StateEvents state;
RoomEvents timeline;
Events ephemeral;
Events accountData;
bool timelineLimited;
QString timelinePrevBatch;
std::optional<int> partiallyReadCount;
std::optional<int> unreadCount;
std::optional<int> highlightCount;
SyncRoomData(QString roomId, JoinState joinState,
const QJsonObject& roomJson);
};
// QVector cannot work with non-copyable objects, std::vector can.
using SyncDataList = std::vector<SyncRoomData>;
class QUOTIENT_API SyncData {
public:
SyncData() = default;
explicit SyncData(const QString& cacheFileName);
//! Parse sync response into room events
//! \param json response from /sync or a room state cache
void parseJson(const QJsonObject& json, const QString& baseDir = {});
Events takePresenceData();
Events takeAccountData();
Events takeToDeviceEvents();
const QHash<QString, int>& deviceOneTimeKeysCount() const
{
return deviceOneTimeKeysCount_;
}
SyncDataList takeRoomData();
DevicesList takeDevicesList();
QString nextBatch() const { return nextBatch_; }
QStringList unresolvedRooms() const { return unresolvedRoomIds; }
static constexpr int MajorCacheVersion = 11;
static std::pair<int, int> cacheVersion();
static QString fileNameForRoom(QString roomId);
private:
QString nextBatch_;
Events presenceData;
Events accountData;
Events toDeviceEvents;
SyncDataList roomData;
QStringList unresolvedRoomIds;
QHash<QString, int> deviceOneTimeKeysCount_;
DevicesList devicesList;
};
} // namespace Quotient
|
