« back to all changes in this revision
Viewing changes to src/Backend/RelevancyService.vala
- browse files at revision 399
- compare with another revision
- download diff
- download tarball
- view history from revision 399
- Committer: RabbitBot
- Author(s): Corentin Noël
- Date: 2014-01-14 13:05:03 UTC
- mfrom: (396.1.1 slingshot)
- Revision ID: rabbitbot-20140114130503-vl01yvhtdlu0dvs4
* Removed every using statement
* Changed VWidgets and HWidgets to Widgets with the corresponding orientation (Gtk deprecation)
* Ported Zeitgeist parts to version 2.0
* Changed VWidgets and HWidgets to Widgets with the corresponding orientation (Gtk deprecation)
* Ported Zeitgeist parts to version 2.0
- files added:
- cmake/FindGirCompiler.cmake
- files removed:
- cmake/Makefile
- files modified:
- CMakeLists.txt
added
removed
src/Backend/RelevancyService.vala
17
17
//
18
18
// Thanks to Synapse Developers for this class
19
19
20
using Zeitgeist;
21
22
namespace Slingshot.Backend {
23
24
public class RelevancyService : Object {
25
26
private Zeitgeist.Log zg_log;
27
private Zeitgeist.DataSourceRegistry zg_dsr;
28
private Gee.HashMap<string, int> app_popularity;
29
private bool has_datahub_gio_module = false;
30
31
private const float MULTIPLIER = 65535.0f;
32
33
public signal void update_complete ();
34
35
public RelevancyService () {
36
37
zg_log = new Zeitgeist.Log ();
38
app_popularity = new Gee.HashMap<string, int> ();
39
40
refresh_popularity ();
41
check_data_sources.begin ();
42
43
Timeout.add_seconds (60*30, refresh_popularity);
44
45
}
46
47
private async void check_data_sources () {
48
49
zg_dsr = new Zeitgeist.DataSourceRegistry ();
20
public class Slingshot.Backend.RelevancyService : Object {
21
22
private Zeitgeist.Log zg_log;
23
private Zeitgeist.DataSourceRegistry zg_dsr;
24
private Gee.HashMap<string, int> app_popularity;
25
private bool has_datahub_gio_module = false;
26
27
private const float MULTIPLIER = 65535.0f;
28
29
public signal void update_complete ();
30
31
public RelevancyService () {
32
33
zg_log = new Zeitgeist.Log ();
34
app_popularity = new Gee.HashMap<string, int> ();
35
36
refresh_popularity ();
37
check_data_sources.begin ();
38
39
Timeout.add_seconds (60*30, refresh_popularity);
40
41
}
42
43
private async void check_data_sources () {
44
45
zg_dsr = new Zeitgeist.DataSourceRegistry ();
46
try {
50
47
var ptr_arr = yield zg_dsr.get_data_sources (null);
51
48
52
for (uint i=0; i < ptr_arr.len; i++) {
49
for (uint i=0; i < ptr_arr.length; i++) {
53
50
54
51
unowned Zeitgeist.DataSource ds;
55
ds = (Zeitgeist.DataSource) ptr_arr.index (i);
56
if (ds.get_unique_id () == "com.zeitgeist-project,datahub,gio-launch-listener"
57
&& ds.is_enabled ()) {
52
ds = (Zeitgeist.DataSource) ptr_arr.get (i);
53
if (ds.unique_id == "com.zeitgeist-project,datahub,gio-launch-listener"
54
&& ds.enabled == true) {
58
55
59
56
has_datahub_gio_module = true;
60
57
break;
61
58
}
62
59
}
60
} catch (Error e) {
61
critical (e.message);
63
62
}
64
65
public bool refresh_popularity () {
66
63
}
64
65
public bool refresh_popularity () {
66
67
load_application_relevancies.begin ();
68
return true;
69
70
}
71
private void reload_relevancies () {
72
73
Idle.add_full (Priority.LOW, () => {
67
74
load_application_relevancies.begin ();
68
return true;
69
70
}
71
private void reload_relevancies () {
72
73
Idle.add_full (Priority.LOW, () => {
74
load_application_relevancies.begin ();
75
return false;
76
});
77
}
78
79
private async void load_application_relevancies () {
80
81
Idle.add (load_application_relevancies.callback, Priority.HIGH);
82
yield;
83
84
int64 end = Zeitgeist.Timestamp.now ();
85
int64 start = end - Zeitgeist.Timestamp.WEEK * 4;
86
Zeitgeist.TimeRange tr = new Zeitgeist.TimeRange (start, end);
87
88
var event = new Zeitgeist.Event ();
89
event.set_interpretation ("!" + ZG_LEAVE_EVENT);
90
var subject = new Zeitgeist.Subject ();
91
subject.set_interpretation (NFO_SOFTWARE);
92
subject.set_uri ("application://*");
93
event.add_subject (subject);
94
95
var ptr_arr = new PtrArray ();
96
ptr_arr.add (event);
97
98
Zeitgeist.ResultSet rs;
99
100
try {
101
102
rs = yield zg_log.find_events (tr, (owned) ptr_arr,
103
Zeitgeist.StorageState.ANY,
104
256,
105
Zeitgeist.ResultType.MOST_POPULAR_SUBJECTS,
106
null);
107
108
app_popularity.clear ();
109
uint size = rs.size ();
110
uint index = 0;
111
112
// Zeitgeist (0.6) doesn't have any stats API, so let's approximate
113
114
foreach (Zeitgeist.Event e in rs) {
115
116
if (e.num_subjects () <= 0) continue;
117
Zeitgeist.Subject s = e.get_subject (0);
118
119
float power = index / (size * 2) + 0.5f; // linearly <0.5, 1.0>
120
float relevancy = 1.0f / Math.powf (index + 1, power);
121
app_popularity[s.get_uri ()] = (int)(relevancy * MULTIPLIER);
122
index++;
123
}
124
update_complete ();
125
} catch (Error err) {
126
warning ("%s", err.message);
127
return;
128
}
129
}
130
131
public float get_app_popularity (string desktop_id) {
132
133
var id = "application://" + desktop_id;
134
135
if (app_popularity.has_key(id)) {
136
return app_popularity[id] / MULTIPLIER;
137
}
138
139
return 0.0f;
140
}
141
142
public void app_launched (App app) {
143
144
string app_uri = null;
145
if (app.desktop_id != null) {
146
app_uri = "application://" + app.desktop_id;
147
}
148
149
push_app_launch (app_uri, app.name);
150
151
// and refresh
152
reload_relevancies ();
153
}
154
155
private void push_app_launch (string app_uri, string? display_name) {
156
157
message ("Pushing launch event: %s [%s]", app_uri, display_name);
158
var event = new Zeitgeist.Event ();
159
var subject = new Zeitgeist.Subject ();
160
161
event.set_actor ("application://synapse.desktop");
162
event.set_interpretation (Zeitgeist.ZG_ACCESS_EVENT);
163
event.set_manifestation (Zeitgeist.ZG_USER_ACTIVITY);
164
event.add_subject (subject);
165
166
subject.set_uri (app_uri);
167
subject.set_interpretation (Zeitgeist.NFO_SOFTWARE);
168
subject.set_manifestation (Zeitgeist.NFO_SOFTWARE_ITEM);
169
subject.set_mimetype ("application/x-desktop");
170
subject.set_text (display_name);
171
172
zg_log.insert_events_no_reply (event, null);
173
}
174
}
175
}
75
return false;
76
});
77
}
78
79
private async void load_application_relevancies () {
80
81
Idle.add (load_application_relevancies.callback, Priority.HIGH);
82
yield;
83
84
int64 end = Zeitgeist.Timestamp.from_now ();
85
int64 start = end - Zeitgeist.Timestamp.WEEK * 4;
86
Zeitgeist.TimeRange tr = new Zeitgeist.TimeRange (start, end);
87
88
var event = new Zeitgeist.Event ();
89
event.interpretation = "!" + Zeitgeist.ZG.LEAVE_EVENT;
90
var subject = new Zeitgeist.Subject ();
91
subject.interpretation = Zeitgeist.NFO.SOFTWARE;
92
subject.uri = "application://*";
93
event.add_subject (subject);
94
95
var ptr_arr = new GLib.GenericArray<Zeitgeist.Event> ();
96
ptr_arr.add (event);
97
98
Zeitgeist.ResultSet rs;
99
100
try {
101
102
rs = yield zg_log.find_events (tr, (owned) ptr_arr,
103
Zeitgeist.StorageState.ANY,
104
256,
105
Zeitgeist.ResultType.MOST_POPULAR_SUBJECTS,
106
null);
107
108
app_popularity.clear ();
109
uint size = rs.size ();
110
uint index = 0;
111
112
// Zeitgeist (0.6) doesn't have any stats API, so let's approximate
113
114
foreach (Zeitgeist.Event e in rs) {
115
116
if (e.num_subjects () <= 0) continue;
117
Zeitgeist.Subject s = e.get_subject (0);
118
119
float power = index / (size * 2) + 0.5f; // linearly <0.5, 1.0>
120
float relevancy = 1.0f / Math.powf (index + 1, power);
121
app_popularity[s.uri] = (int)(relevancy * MULTIPLIER);
122
index++;
123
}
124
update_complete ();
125
} catch (Error err) {
126
warning ("%s", err.message);
127
return;
128
}
129
}
130
131
public float get_app_popularity (string desktop_id) {
132
133
var id = "application://" + desktop_id;
134
135
if (app_popularity.has_key(id)) {
136
return app_popularity[id] / MULTIPLIER;
137
}
138
139
return 0.0f;
140
}
141
142
public void app_launched (App app) {
143
144
string app_uri = null;
145
if (app.desktop_id != null) {
146
app_uri = "application://" + app.desktop_id;
147
}
148
149
push_app_launch (app_uri, app.name);
150
151
// and refresh
152
reload_relevancies ();
153
}
154
155
private void push_app_launch (string app_uri, string? display_name) {
156
157
message ("Pushing launch event: %s [%s]", app_uri, display_name);
158
var event = new Zeitgeist.Event ();
159
var subject = new Zeitgeist.Subject ();
160
161
event.actor = "application://synapse.desktop";
162
event.interpretation = Zeitgeist.ZG.ACCESS_EVENT;
163
event.manifestation = Zeitgeist.ZG.USER_ACTIVITY;
164
event.add_subject (subject);
165
166
subject.uri = app_uri;
167
subject.interpretation = Zeitgeist.NFO.SOFTWARE;
168
subject.manifestation = Zeitgeist.NFO.SOFTWARE_ITEM;
169
subject.mimetype = "application/x-desktop";
170
subject.text = display_name;
171
var ptr_arr = new GLib.GenericArray<Zeitgeist.Event> ();
172
ptr_arr.add (event);
173
174
try {
175
zg_log.insert_events_no_reply (ptr_arr);
176
} catch (Error e) {
177
critical (e.message);
178
}
179
}
180
}
b'\\ No newline at end of file'
Loggerhead is a web-based interface for Breezy
Version: 2.0.1