1 files changed, 80 insertions, 1 deletions

diff --git a/common/facade.cpp b/common/facade.cpp
index e51b32a..1d6b9a7 100644
--- a/common/facade.cpp
+++ b/common/facade.cpp
@@ -1,5 +1,5 @@
 /*
- * Copyright (C) 2015 Christian Mollekopf <chrigi_1@fastmail.fm>
+ *   Copyright (C) 2015 Christian Mollekopf <chrigi_1@fastmail.fm>
  *
  *   This program is free software; you can redistribute it and/or modify
  *   it under the terms of the GNU General Public License as published by
@@ -18,3 +18,82 @@
  */
 
 #include "facade.h"
+
+#include "commands.h"
+#include "log.h"
+#include "storage.h"
+#include "definitions.h"
+#include "domainadaptor.h"
+#include "queryrunner.h"
+
+using namespace Akonadi2;
+
+
+template<class DomainType>
+GenericFacade<DomainType>::GenericFacade(const QByteArray &resourceIdentifier, const DomainTypeAdaptorFactoryInterface::Ptr &adaptorFactory , const QSharedPointer<Akonadi2::ResourceAccessInterface> resourceAccess)
+    : Akonadi2::StoreFacade<DomainType>(),
+    mResourceAccess(resourceAccess),
+    mDomainTypeAdaptorFactory(adaptorFactory),
+    mResourceInstanceIdentifier(resourceIdentifier)
+{
+    if (!mResourceAccess) {
+        mResourceAccess = QSharedPointer<Akonadi2::ResourceAccess>::create(resourceIdentifier);
+    }
+}
+
+template<class DomainType>
+GenericFacade<DomainType>::~GenericFacade()
+{
+}
+
+template<class DomainType>
+QByteArray GenericFacade<DomainType>::bufferTypeForDomainType()
+{
+    //We happen to have a one to one mapping
+    return Akonadi2::ApplicationDomain::getTypeName<DomainType>();
+}
+
+template<class DomainType>
+KAsync::Job<void> GenericFacade<DomainType>::create(const DomainType &domainObject)
+{
+    if (!mDomainTypeAdaptorFactory) {
+        Warning() << "No domain type adaptor factory available";
+        return KAsync::error<void>();
+    }
+    flatbuffers::FlatBufferBuilder entityFbb;
+    mDomainTypeAdaptorFactory->createBuffer(domainObject, entityFbb);
+    return mResourceAccess->sendCreateCommand(bufferTypeForDomainType(), QByteArray::fromRawData(reinterpret_cast<const char*>(entityFbb.GetBufferPointer()), entityFbb.GetSize()));
+}
+
+template<class DomainType>
+KAsync::Job<void> GenericFacade<DomainType>::modify(const DomainType &domainObject)
+{
+    if (!mDomainTypeAdaptorFactory) {
+        Warning() << "No domain type adaptor factory available";
+        return KAsync::error<void>();
+    }
+    flatbuffers::FlatBufferBuilder entityFbb;
+    mDomainTypeAdaptorFactory->createBuffer(domainObject, entityFbb);
+    return mResourceAccess->sendModifyCommand(domainObject.identifier(), domainObject.revision(), bufferTypeForDomainType(), QByteArrayList(), QByteArray::fromRawData(reinterpret_cast<const char*>(entityFbb.GetBufferPointer()), entityFbb.GetSize()));
+}
+
+template<class DomainType>
+KAsync::Job<void> GenericFacade<DomainType>::remove(const DomainType &domainObject)
+{
+    return mResourceAccess->sendDeleteCommand(domainObject.identifier(), domainObject.revision(), bufferTypeForDomainType());
+}
+
+template<class DomainType>
+QPair<KAsync::Job<void>, typename ResultEmitter<typename DomainType::Ptr>::Ptr> GenericFacade<DomainType>::load(const Akonadi2::Query &query)
+{
+    //The runner lives for the lifetime of the query
+    auto runner = new QueryRunner<DomainType>(query, mResourceAccess, mResourceInstanceIdentifier, mDomainTypeAdaptorFactory, bufferTypeForDomainType());
+    return qMakePair(KAsync::null<void>(), runner->emitter());
+}
+
+
+template class Akonadi2::GenericFacade<Akonadi2::ApplicationDomain::Folder>;
+template class Akonadi2::GenericFacade<Akonadi2::ApplicationDomain::Mail>;
+template class Akonadi2::GenericFacade<Akonadi2::ApplicationDomain::Event>;
+
+#include "facade.moc"