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
|
#include "omemo_db.h"
#include <QXmppConfiguration.h>
#include <QXmppFutureUtils_p.h>
#include <QString>
#include <iostream>
#include <optional>
static const QString service = "xxcc", key_namespace = "omemo";
OmemoDb::OmemoDb(const JidDb &db) :
db(db)
{
}
QXmppTask<QXmppOmemoStorage::OmemoData> OmemoDb::allData()
{
QXmppOmemoStorage::OmemoData ret;
QHash<QString, QHash<uint32_t, Device>> devices;
for (const auto &d : db.omemoDevices())
ret.devices.insert(d.jid, d.devices);
ret.ownDevice = db.omemoOwnDevice();
ret.preKeyPairs = db.preKeyPairs();
ret.signedPreKeyPairs = db.signedPreKeyPairs();
return QXmpp::Private::makeReadyTask(QXmppOmemoStorage::OmemoData(ret));
}
QXmppTask<void> OmemoDb::setOwnDevice(const std::optional<OwnDevice> &device)
{
if (device.has_value() && db.store(device.value()))
std::cerr << "db.store failed" << std::endl;
return QXmpp::Private::makeReadyTask();
}
QXmppTask<void> OmemoDb::addSignedPreKeyPair(const uint32_t keyId,
const SignedPreKeyPair &keyPair)
{
if (db.store(keyId, keyPair))
std::cerr << "db.store failed" << std::endl;
return QXmpp::Private::makeReadyTask();
}
QXmppTask<void> OmemoDb::removeSignedPreKeyPair(uint32_t keyId)
{
db.removeSignedPreKeyPair(keyId);
return QXmpp::Private::makeReadyTask();
}
QXmppTask<void> OmemoDb::addPreKeyPairs(
const QHash<uint32_t, QByteArray> &keyPairs)
{
if (db.store(keyPairs))
std::cerr << "db.store failed" << std::endl;
return QXmpp::Private::makeReadyTask();
}
QXmppTask<void> OmemoDb::removePreKeyPair(const uint32_t keyId)
{
db.removePreKeyPair(keyId);
return QXmpp::Private::makeReadyTask();
}
QXmppTask<void> OmemoDb::addDevice(const QString &jid,
const uint32_t deviceId, const Device &d)
{
if (db.store(jid, deviceId, d))
std::cerr << "db.store failed" << std::endl;
return QXmpp::Private::makeReadyTask();
}
QXmppTask<void> OmemoDb::removeDevice(const QString &jid,
const uint32_t deviceId)
{
db.removeOmemoDevice(jid, deviceId);
return QXmpp::Private::makeReadyTask();
}
QXmppTask<void> OmemoDb::removeDevices(const QString &jid)
{
db.removeOmemoDevices(jid);
return QXmpp::Private::makeReadyTask();
}
QXmppTask<void> OmemoDb::resetAll()
{
db.removeOmemo();
return QXmpp::Private::makeReadyTask();
}
|
