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
|
/* Copyright 2016 Software Freedom Conservancy Inc.
*
* This software is licensed under the GNU Lesser General Public License
* (version 2.1 or later). See the COPYING file in this distribution.
*/
public delegate int64 GetSourceDatabaseKey(DataSource source);
// A DatabaseSourceCollection is a SourceCollection that understands database keys (IDs) and the
// nature that a row in a database can only be instantiated once in the system, and so it tracks
// their existence in a map so they can be fetched by their key.
//
// TODO: This would be better implemented as an observer class, possibly with an interface to
// force subclasses to provide a fetch_by_key() method.
public abstract class DatabaseSourceCollection : SourceCollection {
private unowned GetSourceDatabaseKey source_key_func;
private Gee.HashMap<int64?, DataSource> map = new Gee.HashMap<int64?, DataSource>(int64_hash,
int64_equal);
public DatabaseSourceCollection(string name, GetSourceDatabaseKey source_key_func) {
base (name);
this.source_key_func = source_key_func;
}
public override void notify_items_added(Gee.Iterable<DataObject> added) {
foreach (DataObject object in added) {
DataSource source = (DataSource) object;
int64 key = source_key_func(source);
assert(!map.has_key(key));
map.set(key, source);
}
base.notify_items_added(added);
}
public override void notify_items_removed(Gee.Iterable<DataObject> removed) {
foreach (DataObject object in removed) {
int64 key = source_key_func((DataSource) object);
bool is_removed = map.unset(key);
assert(is_removed);
}
base.notify_items_removed(removed);
}
protected DataSource fetch_by_key(int64 key) {
return map.get(key);
}
}
public class DatabaseSourceHoldingTank : SourceHoldingTank {
private unowned GetSourceDatabaseKey get_key;
private Gee.HashMap<int64?, DataSource> map = new Gee.HashMap<int64?, DataSource>(int64_hash,
int64_equal);
public DatabaseSourceHoldingTank(SourceCollection sources,
SourceHoldingTank.CheckToKeep check_to_keep, GetSourceDatabaseKey get_key) {
base (sources, check_to_keep);
this.get_key = get_key;
}
public DataSource? get_by_id(int64 id) {
return map.get(id);
}
protected override void notify_contents_altered(Gee.Collection<DataSource>? added,
Gee.Collection<DataSource>? removed) {
if (added != null) {
foreach (DataSource source in added)
map.set(get_key(source), source);
}
if (removed != null) {
foreach (DataSource source in removed)
map.unset(get_key(source));
}
base.notify_contents_altered(added, removed);
}
}
|
