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
|
/* log-test.vala
*
* Copyright © 2012 Christian Dywan <christian@twotoasts.de>
*
* Based upon a C implementation (© 2010 Canonical Ltd) by:
* Mikkel Kamstrup Erlandsen <mikkel.kamstrup@canonical.com>
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU Lesser General Public License as published by
* the Free Software Foundation, either version 2.1 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*
*/
using Zeitgeist;
using Assertions;
int main (string[] argv)
{
Test.init (ref argv);
Test.add_func ("/Log/InsertGetDelete", insert_get_delete_test);
Test.add_func ("/Log/GetDefault", get_default_test);
return Test.run ();
}
void events_received (Zeitgeist.Log log,
AsyncResult res,
GenericArray<Event> expected_events,
Array<uint32> event_ids, MainLoop mainloop)
{
ResultSet events;
try {
events = log.get_events.end (res);
}
catch (Error error) {
critical ("Failed to get events: %s", error.message);
return;
}
/* Assert that we got what we expected, and collect the event ids,
* so we can delete the events */
assert (expected_events.length == events.size());
for (int i = 0; i < events.size(); ++i)
{
Event exp_event = expected_events[i];
Event? event = events.next_value();
assert (event.interpretation == exp_event.interpretation);
assert (event.manifestation == exp_event.manifestation);
assert (event.actor == exp_event.actor);
assert (event.num_subjects () == exp_event.num_subjects ());
}
// TODO: extend this delete test
log.delete_events.begin (event_ids, null, () => { mainloop.quit (); });
}
void events_inserted (Zeitgeist.Log log,
AsyncResult res,
GenericArray<Event> expected_events,
MainLoop mainloop)
{
Array<uint32> event_ids;
try {
event_ids = log.insert_events.end (res);
}
catch (Error error) {
critical ("Failed to insert events: %s", error.message);
return;
}
assert (expected_events.length == event_ids.length);
log.get_events.begin (event_ids, null, (log, res) => {
events_received ((Zeitgeist.Log) log, res, expected_events, event_ids, mainloop);
});
}
bool quit_main_loop ()
{
new MainLoop (MainContext.default ()).quit ();
return false;
}
void insert_get_delete_test ()
{
var mainloop = new MainLoop(MainContext.default ());
var expected_events = new GenericArray<Event> ();
var ev = new Event ();
var su = new Subject ();
ev.add_subject (su);
expected_events.add (ev);
ev.interpretation = "foo://Interp";
ev.manifestation = "foo://Manif";
ev.actor = "app://firefox.desktop";
su.uri = "file:///tmp/bar.txt";
su.interpretation = "foo://TextDoc";
su.manifestation = "foo://File";
su.mimetype = "text/plain";
su.origin = "file:///tmp";
su.text = "bar.txt";
su.storage = "bfb486f6-f5f8-4296-8871-0cc749cf8ef7";
/* This method call now owns all events, subjects, and the events array */
Zeitgeist.Log.get_default ().insert_events.begin (
expected_events, null, (log, res) => {
events_inserted ((Zeitgeist.Log) log, res, expected_events, mainloop);
});
assert (expected_events.length == 1);
Timeout.add_seconds (1, quit_main_loop);
mainloop.run ();
}
void get_default_test ()
{
var log1 = Zeitgeist.Log.get_default ();
var log2 = Zeitgeist.Log.get_default ();
assert (log1 == log2);
}
// vim:expandtab:ts=4:sw=4
|
