Use jobs to track progress of write commands.

2 files changed, 12 insertions, 8 deletions

diff --git a/dummyresource/facade.cpp b/dummyresource/facade.cpp
index 668fbbf..13c174b 100644
--- a/dummyresource/facade.cpp
+++ b/dummyresource/facade.cpp
@@ -46,7 +46,7 @@ DummyResourceFacade::~DummyResourceFacade()
 {
 }
 
-void DummyResourceFacade::create(const Akonadi2::Domain::Event &domainObject)
+Async::Job<void> DummyResourceFacade::create(const Akonadi2::Domain::Event &domainObject)
 {
     //Create message buffer and send to resource
     flatbuffers::FlatBufferBuilder eventFbb;
@@ -64,24 +64,28 @@ void DummyResourceFacade::create(const Akonadi2::Domain::Event &domainObject)
     Akonadi2::EntityBuffer::assembleEntityBuffer(entityFbb, 0, 0, eventFbb.GetBufferPointer(), eventFbb.GetSize(), 0, 0);
 
     flatbuffers::FlatBufferBuilder fbb;
-    auto type = fbb.CreateString(Akonadi2::Domain::getTypeName<Akonadi2::Domain::Event>().toStdString().data());
+    //This is the resource type and not the domain type
+    auto type = fbb.CreateString("event");
     auto delta = fbb.CreateVector<uint8_t>(entityFbb.GetBufferPointer(), entityFbb.GetSize());
     Akonadi2::Commands::CreateEntityBuilder builder(fbb);
     builder.add_domainType(type);
     builder.add_delta(delta);
     auto location = builder.Finish();
     Akonadi2::Commands::FinishCreateEntityBuffer(fbb, location);
-    mResourceAccess->sendCommand(Akonadi2::Commands::CreateEntityCommand, fbb);
+    mResourceAccess->open();
+    return mResourceAccess->sendCommand(Akonadi2::Commands::CreateEntityCommand, fbb);
 }
 
-void DummyResourceFacade::modify(const Akonadi2::Domain::Event &domainObject)
+Async::Job<void> DummyResourceFacade::modify(const Akonadi2::Domain::Event &domainObject)
 {
     //Create message buffer and send to resource
+    return Async::null<void>();
 }
 
-void DummyResourceFacade::remove(const Akonadi2::Domain::Event &domainObject)
+Async::Job<void> DummyResourceFacade::remove(const Akonadi2::Domain::Event &domainObject)
 {
     //Create message buffer and send to resource
+    return Async::null<void>();
 }
 
 static std::function<bool(const std::string &key, DummyEvent const *buffer)> prepareQuery(const Akonadi2::Query &query)
diff --git a/dummyresource/facade.h b/dummyresource/facade.h
index e01d254..9c8827a 100644
--- a/dummyresource/facade.h
+++ b/dummyresource/facade.h
@@ -37,9 +37,9 @@ class DummyResourceFacade : public Akonadi2::StoreFacade<Akonadi2::Domain::Event
 public:
     DummyResourceFacade();
     virtual ~DummyResourceFacade();
-    virtual void create(const Akonadi2::Domain::Event &domainObject);
-    virtual void modify(const Akonadi2::Domain::Event &domainObject);
-    virtual void remove(const Akonadi2::Domain::Event &domainObject);
+    virtual Async::Job<void> create(const Akonadi2::Domain::Event &domainObject);
+    virtual Async::Job<void> modify(const Akonadi2::Domain::Event &domainObject);
+    virtual Async::Job<void> remove(const Akonadi2::Domain::Event &domainObject);
     virtual void load(const Akonadi2::Query &query, const std::function<void(const Akonadi2::Domain::Event::Ptr &)> &resultCallback, const std::function<void()> &completeCallback);
 
 private: