1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
|
#include "facade.h"
#include <QDebug>
#include <functional>
#include "client/resourceaccess.h"
#include "dummycalendar_generated.h"
using namespace DummyCalendar;
using namespace flatbuffers;
DummyResourceFacade::DummyResourceFacade()
: Akonadi2::StoreFacade<Akonadi2::Domain::Event>(),
mResourceAccess(new ResourceAccess("dummyresource")),
mStorage(new Storage(Akonadi2::Store::storageLocation(), "dummyresource"))
{
// connect(mResourceAccess.data(), &ResourceAccess::ready, this, onReadyChanged);
}
DummyResourceFacade::~DummyResourceFacade()
{
}
void DummyResourceFacade::create(const Akonadi2::Domain::Event &domainObject)
{
//Create message buffer and send to resource
}
void DummyResourceFacade::modify(const Akonadi2::Domain::Event &domainObject)
{
//Create message buffer and send to resource
}
void DummyResourceFacade::remove(const Akonadi2::Domain::Event &domainObject)
{
//Create message buffer and send to resource
}
//Key.value property map using enum or strings with qvariant, or rather typesafe API?
//typesafe is a shitload more work that we can avoid
//
//The Event base implementaiton could take a pointer to a single property mapper,
//and a void pointer to the mmapped region. => event is copyable and stack allocatable and we avoid large amounts of heap allocated objects
//-The mapper should in this case live in the other thread
//-default property mapper implementation can answer "is property X supported?"
//-how do we free/munmap the data if we don't know when no one references it any longer? => no munmap needed, but read transaction to keep pointer alive
//-we could bind the lifetime to the query
//=> perhaps do heap allocate and use smart pointer?
class DummyEventAdaptor : public Akonadi2::Domain::Event {
public:
DummyEventAdaptor(const QString &resource, const QString &identifier, qint64 revision):Akonadi2::Domain::Event(resource, identifier, revision){};
//TODO
// void setProperty(const QString &key, const QVariant &value)
// {
// //Record changes to send to resource?
// //The buffer is readonly
// }
virtual QVariant getProperty(const QString &key) const
{
if (key == "summary") {
//FIXME how do we check availability for on-demand request?
return QString::fromStdString(buffer->summary()->c_str());
}
return QVariant();
}
//Data is read-only
DummyEvent const *buffer;
//Keep query alive so values remain valid
QSharedPointer<Storage> storage;
};
void DummyResourceFacade::load(const Akonadi2::Query &query, const std::function<void(const Akonadi2::Domain::Event::Ptr &)> &resultCallback)
{
qDebug() << "load called";
//TODO only read values matching the query
auto storage = QSharedPointer<Storage>::create(Akonadi2::Store::storageLocation(), "dummyresource");
storage->read("", [resultCallback, storage](void *data, int size) {
//TODO read second buffer as well
auto eventBuffer = GetDummyEvent(data);
auto event = QSharedPointer<DummyEventAdaptor>::create("dummyresource", "key", 0);
event->buffer = eventBuffer;
event->storage = storage;
resultCallback(event);
});
}
//TODO call in plugin loader
// Akonadi2::FacadeFactory::instance().registerFacade<Akonadi2::Domain::Event, DummyResourceFacade>("dummyresource", [facade](){ return new DummyResourceFacade(facade); });
|
