/****************************************************************************** * Copyright (C) 2016 Felix Rohrbach * * This library is free software; you can redistribute it and/or * modify it under the terms of the GNU Lesser General Public * License as published by the Free Software Foundation; either * version 2.1 of the License, or (at your option) any later version. * * This library is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * Lesser General Public License for more details. * * You should have received a copy of the GNU Lesser General Public * License along with this library; if not, write to the Free Software * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA */ #include "syncjob.h" #include using namespace QMatrixClient; static size_t jobId = 0; SyncJob::SyncJob(const QString& since, const QString& filter, int timeout, const QString& presence) : BaseJob(HttpVerb::Get, QStringLiteral("SyncJob-%1").arg(++jobId), QStringLiteral("_matrix/client/r0/sync")) { setLoggingCategory(SYNCJOB); QUrlQuery query; if( !filter.isEmpty() ) query.addQueryItem("filter", filter); if( !presence.isEmpty() ) query.addQueryItem("set_presence", presence); if( timeout >= 0 ) query.addQueryItem("timeout", QString::number(timeout)); if( !since.isEmpty() ) query.addQueryItem("since", since); setRequestQuery(query); setMaxRetries(std::numeric_limits::max()); } QString SyncData::nextBatch() const { return nextBatch_; } SyncDataList&& SyncData::takeRoomData() { return std::move(roomData); } Events&& SyncData::takePresenceData() { return std::move(presenceData); } Events&& SyncData::takeAccountData() { return std::move(accountData); } Events&&SyncData::takeToDeviceEvents() { return std::move(toDeviceEvents); } template inline EventsArrayT load(const QJsonObject& batches, StrT keyName) { return fromJson(batches[keyName].toObject().value("events")); } BaseJob::Status SyncJob::parseJson(const QJsonDocument& data) { return d.parseJson(data); } BaseJob::Status SyncData::parseJson(const QJsonDocument &data) { QElapsedTimer et; et.start(); auto json = data.object(); nextBatch_ = json.value("next_batch").toString(); presenceData = load(json, "presence"); accountData = load(json, "account_data"); toDeviceEvents = load(json, "to_device"); QJsonObject rooms = json.value("rooms").toObject(); JoinStates::Int ii = 1; // ii is used to make a JoinState value auto totalRooms = 0; auto totalEvents = 0; for (size_t i = 0; i < JoinStateStrings.size(); ++i, ii <<= 1) { const auto rs = rooms.value(JoinStateStrings[i]).toObject(); // We have a Qt container on the right and an STL one on the left roomData.reserve(static_cast(rs.size())); for(auto roomIt = rs.begin(); roomIt != rs.end(); ++roomIt) { roomData.emplace_back(roomIt.key(), JoinState(ii), roomIt.value().toObject()); const auto& r = roomData.back(); totalEvents += r.state.size() + r.ephemeral.size() + r.accountData.size() + r.timeline.size(); } totalRooms += roomData.size(); } qCDebug(PROFILER) << "*** SyncData::parseJson(): batch with" << totalRooms << "room(s)," << totalEvents << "event(s) in" << et; return BaseJob::Success; } const QString SyncRoomData::UnreadCountKey = QStringLiteral("x-qmatrixclient.unread_count"); SyncRoomData::SyncRoomData(const QString& roomId_, JoinState joinState_, const QJsonObject& room_) : roomId(roomId_) , joinState(joinState_) , state(load(room_, joinState == JoinState::Invite ? "invite_state" : "state")) { switch (joinState) { case JoinState::Join: ephemeral = load(room_, "ephemeral"); accountData = load(room_, "account_data"); FALLTHROUGH; case JoinState::Leave: { timeline = load(room_, "timeline"); auto timelineJson = room_.value("timeline").toObject(); timelineLimited = timelineJson.value("limited").toBool(); timelinePrevBatch = timelineJson.value("prev_batch").toString(); break; } default: /* nothing on top of state */; } auto unreadJson = room_.value("unread_notifications").toObject(); unreadCount = unreadJson.value(UnreadCountKey).toInt(-2); highlightCount = unreadJson.value("highlight_count").toInt(); notificationCount = unreadJson.value("notification_count").toInt(); if (highlightCount > 0 || notificationCount > 0) qCDebug(SYNCJOB) << "Highlights: " << highlightCount << " Notifications:" << notificationCount; }