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
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
|
#include <QtTest>
#include <QString>
// #include "dummycalendar_generated.h"
#include "event_generated.h"
#include "entity_generated.h"
#include "metadata_generated.h"
#include "createentity_generated.h"
#include "dummyresource/resourcefactory.h"
#include "clientapi.h"
#include "commands.h"
#include "entitybuffer.h"
static void removeFromDisk(const QString &name)
{
Akonadi2::Storage store(Akonadi2::Store::storageLocation(), name, Akonadi2::Storage::ReadWrite);
store.removeFromDisk();
}
class DummyResourceTest : public QObject
{
Q_OBJECT
private Q_SLOTS:
void initTestCase()
{
auto factory = Akonadi2::ResourceFactory::load("org.kde.dummy");
QVERIFY(factory);
removeFromDisk("org.kde.dummy");
removeFromDisk("org.kde.dummy.userqueue");
removeFromDisk("org.kde.dummy.synchronizerqueue");
}
void cleanupTestCase()
{
removeFromDisk("org.kde.dummy");
removeFromDisk("org.kde.dummy.userqueue");
removeFromDisk("org.kde.dummy.synchronizerqueue");
}
void testProcessCommand()
{
flatbuffers::FlatBufferBuilder eventFbb;
eventFbb.Clear();
{
auto summary = eventFbb.CreateString("summary");
Akonadi2::Domain::Buffer::EventBuilder eventBuilder(eventFbb);
eventBuilder.add_summary(summary);
auto eventLocation = eventBuilder.Finish();
Akonadi2::Domain::Buffer::FinishEventBuffer(eventFbb, eventLocation);
}
flatbuffers::FlatBufferBuilder entityFbb;
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());
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);
const QByteArray command(reinterpret_cast<const char *>(fbb.GetBufferPointer()), fbb.GetSize());
{
flatbuffers::Verifier verifyer(reinterpret_cast<const uint8_t *>(command.data()), command.size());
QVERIFY(Akonadi2::Commands::VerifyCreateEntityBuffer(verifyer));
}
//Actual test
Akonadi2::Pipeline pipeline("org.kde.dummy");
QSignalSpy revisionSpy(&pipeline, SIGNAL(revisionUpdated()));
DummyResource resource;
resource.configurePipeline(&pipeline);
resource.processCommand(Akonadi2::Commands::CreateEntityCommand, command, command.size(), &pipeline);
resource.processCommand(Akonadi2::Commands::CreateEntityCommand, command, command.size(), &pipeline);
QVERIFY(revisionSpy.isValid());
QTRY_COMPARE(revisionSpy.count(), 2);
QTest::qWait(100);
QCOMPARE(revisionSpy.count(), 2);
}
void testWriteToFacade()
{
Akonadi2::Query query;
Akonadi2::Domain::Event event;
event.setProperty("summary", "summaryValue");
Akonadi2::Store::create<Akonadi2::Domain::Event>(event, "org.kde.dummy");
QTest::qWait(1000);
//TODO wait for success response
}
void testResourceSync()
{
Akonadi2::Pipeline pipeline("org.kde.dummy");
DummyResource resource;
auto job = resource.synchronizeWithSource(&pipeline);
auto future = job.exec();
QTRY_VERIFY(future.isFinished());
}
void testSyncAndFacade()
{
Akonadi2::Query query;
query.resources << "org.kde.dummy";
async::SyncListResult<Akonadi2::Domain::Event::Ptr> result(Akonadi2::Store::load<Akonadi2::Domain::Event>(query));
result.exec();
QVERIFY(!result.isEmpty());
auto value = result.first();
QVERIFY(!value->getProperty("summary").toString().isEmpty());
qDebug() << value->getProperty("summary").toString();
}
};
QTEST_MAIN(DummyResourceTest)
#include "dummyresourcetest.moc"
|
