// SPDX-FileCopyrightText: 2018 Kitsune Ral // SPDX-License-Identifier: LGPL-2.1-or-later /* Example of a Receipt Event: { "content": { "$1435641916114394fHBLK:matrix.org": { "m.read": { "@rikj:jki.re": { "ts": 1436451550453 } } } }, "room_id": "!KpjVgQyZpzBwvMBsnT:matrix.org", "type": "m.receipt" } */ #include "receiptevent.h" #include "logging.h" using namespace Quotient; // The library loads the event-ids-to-receipts JSON map into a vector because // map lookups are not used and vectors are massively faster. Same goes for // de-/serialization of ReceiptsForEvent::receipts. // (XXX: would this be generally preferred across CS API JSON maps?..) QJsonObject toJson(const EventsWithReceipts& ewrs) { QJsonObject json; for (const auto& e : ewrs) { QJsonObject receiptsJson; for (const auto& r : e.receipts) receiptsJson.insert(r.userId, QJsonObject { { "ts"_ls, toJson(r.timestamp) } }); json.insert(e.evtId, QJsonObject { { "m.read"_ls, receiptsJson } }); } return json; } ReceiptEvent::ReceiptEvent(const EventsWithReceipts &ewrs) : Event(typeId(), matrixTypeId(), toJson(ewrs)) {} EventsWithReceipts ReceiptEvent::eventsWithReceipts() const { EventsWithReceipts result; const auto& contents = contentJson(); result.reserve(contents.size()); for (auto eventIt = contents.begin(); eventIt != contents.end(); ++eventIt) { if (eventIt.key().isEmpty()) { qCWarning(EPHEMERAL) << "ReceiptEvent has an empty event id, skipping"; qCDebug(EPHEMERAL) << "ReceiptEvent content follows:\n" << contents; continue; } const auto reads = eventIt.value().toObject().value("m.read"_ls).toObject(); QVector usersAtEvent; usersAtEvent.reserve(reads.size()); for (auto userIt = reads.begin(); userIt != reads.end(); ++userIt) { const auto user = userIt.value().toObject(); usersAtEvent.push_back( { userIt.key(), fromJson(user["ts"_ls]) }); } result.push_back({ eventIt.key(), std::move(usersAtEvent) }); } return result; } nt/tree/?id=2f35303d2fbcf0e0fc9727c327a6c98f2da8648d'>root/lib/csapi/versions.h

blob: 896e2ea9f5a1dd2ea77148c1c490dab56a8c4654 (plain)