From fdeb92ca128e6eb51bbcace0b47519b12a08ce93 Mon Sep 17 00:00:00 2001 From: Christian Mollekopf Date: Sun, 8 May 2016 10:32:01 +0200 Subject: Run preprocessors before persising the value. And allow preprocessors to modify the result. --- tests/pipelinetest.cpp | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) (limited to 'tests') diff --git a/tests/pipelinetest.cpp b/tests/pipelinetest.cpp index cdd260d..9290050 100644 --- a/tests/pipelinetest.cpp +++ b/tests/pipelinetest.cpp @@ -146,13 +146,13 @@ QByteArray deleteEntityCommand(const QByteArray &uid, qint64 revision) class TestProcessor : public Sink::Preprocessor { public: - void newEntity(const QByteArray &uid, qint64 revision, const Sink::ApplicationDomain::BufferAdaptor &newEntity, Sink::Storage::Transaction &transaction) Q_DECL_OVERRIDE + void newEntity(const QByteArray &uid, qint64 revision, Sink::ApplicationDomain::BufferAdaptor &newEntity, Sink::Storage::Transaction &transaction) Q_DECL_OVERRIDE { newUids << uid; newRevisions << revision; } - void modifiedEntity(const QByteArray &uid, qint64 revision, const Sink::ApplicationDomain::BufferAdaptor &oldEntity, const Sink::ApplicationDomain::BufferAdaptor &newEntity, + void modifiedEntity(const QByteArray &uid, qint64 revision, const Sink::ApplicationDomain::BufferAdaptor &oldEntity, Sink::ApplicationDomain::BufferAdaptor &newEntity, Sink::Storage::Transaction &transaction) Q_DECL_OVERRIDE { modifiedUids << uid; @@ -198,6 +198,10 @@ private slots: auto command = createEntityCommand(createEvent(entityFbb)); Sink::Pipeline pipeline("org.kde.pipelinetest.instance1"); + + auto adaptorFactory = QSharedPointer::create(); + pipeline.setAdaptorFactory("event", adaptorFactory); + pipeline.startTransaction(); pipeline.newEntity(command.constData(), command.size()); pipeline.commit(); -- cgit v1.2.3