Ported the pipeline to the entitystore

1 files changed, 8 insertions, 3 deletions

diff --git a/common/storage/entitystore.h b/common/storage/entitystore.h
index 455e9c3..65bff50 100644
--- a/common/storage/entitystore.h
+++ b/common/storage/entitystore.h
@@ -38,9 +38,14 @@ public:
     typedef QSharedPointer<EntityStore> Ptr;
     EntityStore(const ResourceContext &resourceContext);
 
-    void add(const ApplicationDomain::ApplicationDomainType &);
-    void modify(const ApplicationDomain::ApplicationDomainType &);
-    void remove(const ApplicationDomain::ApplicationDomainType &);
+    typedef std::function<void(const ApplicationDomain::ApplicationDomainType &, ApplicationDomain::ApplicationDomainType &)> PreprocessModification;
+    typedef std::function<void(ApplicationDomain::ApplicationDomainType &)> PreprocessCreation;
+    typedef std::function<void(const ApplicationDomain::ApplicationDomainType &)> PreprocessRemoval;
+
+    bool add(const QByteArray &type, const ApplicationDomain::ApplicationDomainType &, bool replayToSource, const PreprocessCreation &);
+    bool modify(const QByteArray &type, const ApplicationDomain::ApplicationDomainType &, const QByteArrayList &deletions, bool replayToSource, const PreprocessModification &);
+    bool remove(const QByteArray &type, const QByteArray &uid, bool replayToSource, const PreprocessRemoval &);
+    void cleanupRevision(qint64 revision);
 
     void startTransaction(Sink::Storage::DataStore::AccessMode);
     void commitTransaction();