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
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
|
#include <QtTest>
#include <QString>
#include "dummyresource/resourcefactory.h"
#include "store.h"
#include "resourceconfig.h"
#include "resourcecontrol.h"
#include "log.h"
#include "test.h"
#include "testutils.h"
#include "definitions.h"
#include "storage.h"
using namespace Sink;
using namespace Sink::ApplicationDomain;
class UpgradeTest : public QObject
{
Q_OBJECT
private slots:
void initTestCase()
{
Sink::Test::initTest();
auto factory = Sink::ResourceFactory::load("sink.dummy");
QVERIFY(factory);
::DummyResource::removeFromDisk("sink.dummy.instance1");
ResourceConfig::addResource("sink.dummy.instance1", "sink.dummy");
}
void init()
{
}
void cleanup()
{
VERIFYEXEC(Sink::Store::removeDataFromDisk(QByteArray("sink.dummy.instance1")));
}
void noUpgradeOnNoDb()
{
auto upgradeJob = Sink::Store::upgrade()
.then([](const Sink::Store::UpgradeResult &result) {
ASYNCVERIFY(!result.upgradeExecuted);
return KAsync::null();
});
VERIFYEXEC(upgradeJob);
}
void noUpgradeOnCurrentDb()
{
Event event("sink.dummy.instance1");
event.setProperty("uid", "testuid");
event.setProperty("summary", "summaryValue");
Sink::Store::create<Event>(event).exec().waitForFinished();
// Ensure all local data is processed
VERIFYEXEC(Sink::ResourceControl::flushMessageQueue("sink.dummy.instance1"));
auto upgradeJob = Sink::Store::upgrade()
.then([](const Sink::Store::UpgradeResult &result) {
ASYNCVERIFY(!result.upgradeExecuted);
return KAsync::null();
});
VERIFYEXEC(upgradeJob);
}
void upgradeFromOldDb()
{
Event event("sink.dummy.instance1");
event.setProperty("uid", "testuid");
event.setProperty("summary", "summaryValue");
Sink::Store::create<Event>(event).exec().waitForFinished();
// Ensure all local data is processed
VERIFYEXEC(Sink::ResourceControl::flushMessageQueue("sink.dummy.instance1"));
//force the db to an old version.
{
Sink::Storage::DataStore store(Sink::storageLocation(), "sink.dummy.instance1", Sink::Storage::DataStore::ReadWrite);
auto t = store.createTransaction();
t.openDatabase().write("__internal_databaseVersion", QByteArray::number(1));
t.commit();
}
auto upgradeJob = Sink::Store::upgrade()
.then([](const Sink::Store::UpgradeResult &result) {
ASYNCVERIFY(result.upgradeExecuted);
return KAsync::null();
});
VERIFYEXEC(upgradeJob);
//FIXME
// QTest::qWait(1000);
// {
// Sink::Storage::DataStore::clearEnv();
// Sink::Storage::DataStore store(Sink::storageLocation(), "sink.dummy.instance1", Sink::Storage::DataStore::ReadOnly);
// auto version = Sink::Storage::DataStore::databaseVersion(store.createTransaction(Sink::Storage::DataStore::ReadOnly));
// QCOMPARE(version, Sink::latestDatabaseVersion());
// }
}
void upgradeFromDbWithNoVersion()
{
Event event("sink.dummy.instance1");
event.setProperty("uid", "testuid");
event.setProperty("summary", "summaryValue");
Sink::Store::create<Event>(event).exec().waitForFinished();
// Ensure all local data is processed
VERIFYEXEC(Sink::ResourceControl::flushMessageQueue("sink.dummy.instance1"));
//force the db to an old version.
Sink::Storage::DataStore store(Sink::storageLocation(), "sink.dummy.instance1", Sink::Storage::DataStore::ReadWrite);
auto t = store.createTransaction();
t.openDatabase().remove("__internal_databaseVersion");
t.commit();
auto upgradeJob = Sink::Store::upgrade()
.then([](const Sink::Store::UpgradeResult &result) {
ASYNCVERIFY(result.upgradeExecuted);
return KAsync::null();
});
VERIFYEXEC(upgradeJob);
//FIXME
// QTest::qWait(1000);
// {
// Sink::Storage::DataStore::clearEnv();
// Sink::Storage::DataStore store(Sink::storageLocation(), "sink.dummy.instance1", Sink::Storage::DataStore::ReadOnly);
// auto version = Sink::Storage::DataStore::databaseVersion(store.createTransaction(Sink::Storage::DataStore::ReadOnly));
// QCOMPARE(version, Sink::latestDatabaseVersion());
// }
}
};
QTEST_MAIN(UpgradeTest)
#include "upgradetest.moc"
|
