diff options
Diffstat (limited to 'jobs/geteventsjob.cpp')
| -rw-r--r-- | jobs/geteventsjob.cpp | 96 |
1 files changed, 96 insertions, 0 deletions
diff --git a/jobs/geteventsjob.cpp b/jobs/geteventsjob.cpp new file mode 100644 index 00000000..748a0189 --- /dev/null +++ b/jobs/geteventsjob.cpp @@ -0,0 +1,96 @@ +/****************************************************************************** + * 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 "geteventsjob.h" + +#include <QtCore/QJsonDocument> +#include <QtCore/QJsonObject> +#include <QtCore/QJsonValue> +#include <QtCore/QJsonArray> +#include <QtCore/QDebug> + +#include <QtNetwork/QNetworkReply> + +#include "../room.h" +#include "../connectiondata.h" +#include "../events/event.h" + +using namespace QMatrixClient; + +class GetEventsJob::Private +{ + public: + Private() {} + + QList<Event*> events; + QString from; +}; + +GetEventsJob::GetEventsJob(ConnectionData* connection, QString from) + : BaseJob(connection, JobHttpType::GetJob) + , d(new Private) +{ + if( from.isEmpty() ) + from = connection->lastEvent(); + d->from = from; +} + +GetEventsJob::~GetEventsJob() +{ + delete d; +} + +QList< Event* > GetEventsJob::events() +{ + return d->events; +} + +QString GetEventsJob::apiPath() +{ + return "_matrix/client/r0/events"; +} + +QUrlQuery GetEventsJob::query() +{ + QUrlQuery query; + query.addQueryItem("from", d->from); + return query; +} + +void GetEventsJob::parseJson(const QJsonDocument& data) +{ + QJsonObject json = data.object(); + if( !json.contains("chunk") || !json.value("chunk").isArray() ) + { + fail( BaseJob::UserDefinedError, "Couldn't find chunk" ); + return; + } + QJsonArray chunk = json.value("chunk").toArray(); +// qDebug() << chunk; + for( const QJsonValue& val: chunk ) + { + QJsonObject eventObj = val.toObject(); + Event* event = Event::fromJson(eventObj); + if( event ) + { + d->events.append(event); + } + } + connection()->setLastEvent( json.value("end").toString() ); + emitResult(); +}
\ No newline at end of file |