diff options
| -rw-r--r-- | jobs/initialsyncjob.cpp | 117 | ||||
| -rw-r--r-- | jobs/initialsyncjob.h | 53 |
2 files changed, 0 insertions, 170 deletions
diff --git a/jobs/initialsyncjob.cpp b/jobs/initialsyncjob.cpp deleted file mode 100644 index 9512e0ea..00000000 --- a/jobs/initialsyncjob.cpp +++ /dev/null @@ -1,117 +0,0 @@ -/****************************************************************************** - * Copyright (C) 2015 Felix Rohrbach <kde@fxrh.de> - * - * 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 "initialsyncjob.h" - -#include <QtNetwork/QNetworkAccessManager> -#include <QtNetwork/QNetworkReply> -#include <QtCore/QUrlQuery> -#include <QtCore/QJsonDocument> -#include <QtCore/QJsonObject> -#include <QtCore/QJsonArray> -#include <QtCore/QJsonValue> - -#include "../connectiondata.h" -#include "../room.h" -#include "../state.h" -#include "../events/event.h" - -using namespace QMatrixClient; - -class InitialSyncJob::Private -{ - public: - Private() {} - - QList<Event*> events; - QList<State*> initialState; -}; - -InitialSyncJob::InitialSyncJob(ConnectionData* connection) - : BaseJob(connection, JobHttpType::GetJob) - , d(new Private) -{ -} - -InitialSyncJob::~InitialSyncJob() -{ - delete d; -} - -QList< Event* > InitialSyncJob::events() -{ - return d->events; -} - -QList< State* > InitialSyncJob::initialState() -{ - return d->initialState; -} - -QString InitialSyncJob::apiPath() -{ - return "_matrix/client/r0/initialSync"; -} - -QUrlQuery InitialSyncJob::query() -{ - QUrlQuery query; - query.addQueryItem("limit", "200"); - return query; -} - -void InitialSyncJob::parseJson(const QJsonDocument& data) -{ - QJsonObject json = data.object(); - if( !json.contains("rooms") || !json.value("rooms").isArray() ) - { - fail( KJob::UserDefinedError+2, "Didn't find rooms" ); - qDebug() << json; - return; - } - QJsonArray array = json.value("rooms").toArray(); - for( const QJsonValue& val : array ) - { - if( !val.isObject() ) - { - qWarning() << "Strange: " << val; - continue; - } - QJsonObject obj = val.toObject(); - QJsonObject messages = obj.value("messages").toObject(); - QJsonArray chunk = messages.value("chunk").toArray(); - for( const QJsonValue& val: chunk ) - { - Event* event = Event::fromJson(val.toObject()); - if( event ) - d->events.append( event ); - } - QJsonArray state = obj.value("state").toArray(); - for( const QJsonValue& val: state ) - { -// qDebug() << val.toObject(); - State* state = State::fromJson(val.toObject()); - if( state ) - d->initialState.append( state ); - } - } - connection()->setLastEvent( json.value("end").toString() ); - qDebug() << connection()->lastEvent(); - emitResult(); -} - diff --git a/jobs/initialsyncjob.h b/jobs/initialsyncjob.h deleted file mode 100644 index 188522c1..00000000 --- a/jobs/initialsyncjob.h +++ /dev/null @@ -1,53 +0,0 @@ -/****************************************************************************** - * Copyright (C) 2015 Felix Rohrbach <kde@fxrh.de> - * - * 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 - */ - -#ifndef QMATRIXCLIENT_INITIALSYNCJOB_H -#define QMATRIXCLIENT_INITIALSYNCJOB_H - -#include "basejob.h" - -#include "lib/room.h" - -namespace QMatrixClient -{ - class ConnectionData; - class Event; - class State; - - class InitialSyncJob: public BaseJob - { - Q_OBJECT - public: - InitialSyncJob(ConnectionData* connection); - virtual ~InitialSyncJob(); - - QList<Event*> events(); - QList<State*> initialState(); - - protected: - QString apiPath(); - QUrlQuery query(); - void parseJson(const QJsonDocument& data); - - private: - class Private; - Private* d; - }; -} - -#endif // QMATRIXCLIENT_INITIALSYNCJOB_H
\ No newline at end of file |