3d97a901de39a1970952395a63fd434eed9c6000
[gregoa/zavai.git] / src / clock.vala
1 /*
2  * clock - clock resource for zavai
3  *
4  * Copyright (C) 2009  Enrico Zini <enrico@enricozini.org>
5  *
6  * This program is free software; you can redistribute it and/or modify
7  * it under the terms of the GNU General Public License as published by
8  * the Free Software Foundation; either version 2 of the License, or
9  * (at your option) any later version.
10  *
11  * This program is distributed in the hope that it will be useful,
12  * but WITHOUT ANY WARRANTY; without even the implied warranty of
13  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
14  * GNU General Public License for more details.
15  *
16  * You should have received a copy of the GNU General Public License
17  * along with this program; if not, write to the Free Software
18  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
19  */
20
21 using GLib;
22
23 namespace zavai {
24 namespace clock {
25
26 public enum SourceType
27 {
28     SYSTEM,
29     GPS
30 }
31
32 public class Alarm : Object
33 {
34     public signal void trigger();
35
36     public time_t deadline;
37     public string label;
38
39     public Alarm(time_t deadline, string label)
40     {
41         this.deadline = deadline;
42         this.label = label;
43     }
44 }
45
46 private int alarm_compare(void* a, void* b)
47 {
48     return (int)(((Alarm*)a)->deadline - ((Alarm*)b)->deadline);
49 }
50
51 [DBus (name = "org.freesmartphone.Notification")]
52 public class AlarmNotification : Object {
53     public void Alarm () {
54         clock.check_alarms();
55     }
56 }
57
58 public class Clock: zavai.Service
59 {
60     protected time_t last_gps_time;
61     protected time_t last_gps_time_system_time;
62     protected time_t last_system_time;
63         protected dynamic DBus.Object gps_time;
64     protected uint system_time_timeout;
65     protected time_t last_minute;
66     protected time_t chosen_time;
67     protected SourceType chosen_type;
68     protected AlarmNotification listener;
69
70         protected dynamic DBus.Object otimed_alarm;
71         protected dynamic DBus.Object notification;
72     protected SList<Alarm> alarms;
73
74     // Ticks once a minute
75     public signal void minute_changed(long time, SourceType source);
76
77         public Clock()
78         {
79                 name = "clock";
80         alarms = null;
81         listener = new AlarmNotification();
82         last_minute = 0;
83         last_gps_time = 0;
84         last_gps_time_system_time = 0;
85         last_system_time = time_t();
86         chosen_time = last_system_time;
87         
88                 gps_time = zavai.registry.sbus.get_object(
89                         "org.freesmartphone.ogpsd",
90                         "/org/freedesktop/Gypsy",
91                         "org.freedesktop.Gypsy.Time");
92
93         // FSO alarm system
94             otimed_alarm = zavai.registry.sbus.get_object(
95                         "org.freesmartphone.otimed",
96                         "/org/freesmartphone/Time/Alarm",
97                         "org.freesmartphone.Time.Alarm");
98         if (otimed_alarm == null)
99             zavai.log.error("ALARM IS NULL");
100
101         zavai.registry.sbus.register_object("/", listener);
102
103         //notification = zavai.registry.sbus.get_object(
104         //    "org.freesmartphone",
105         //    "org/freesmartphone/Notification",
106         //    "org.freesmartphone.Notification");
107         //notification.Alarm += on_alarm;
108         }
109
110     public void schedule(Alarm a)
111     {
112         alarms.insert_sorted(a, alarm_compare);
113         otimed_reschedule();
114     }
115
116     private void otimed_reschedule()
117     {
118         zavai.log.info("No alarms left to reschedule");
119         if (alarms != null)
120         {
121             zavai.log.info("Scheduling next alarm: " + alarms.data.label + " at " + Time.local(alarms.data.deadline).to_string());
122             
123             try {
124                 otimed_alarm.ClearAlarm(zavai.registry.bus_name);
125             } catch (Error e) {
126                 zavai.log.error("Cannot clear alarms: " + e.message);
127             }
128             try {
129                 otimed_alarm.SetAlarm(zavai.registry.bus_name, (int)alarms.data.deadline);
130             } catch (Error e) {
131                 zavai.log.error("Cannot reschedule alarms: " + e.message);
132             }
133         }
134     }
135
136     public void check_alarms()
137     {
138         last_system_time = time_t();
139         update_time();
140         while (alarms != null && alarms.data.deadline <= chosen_time)
141         {
142             Alarm a = alarms.data;
143             alarms.remove(a);
144             zavai.log.info("Triggering " + a.label);
145             a.trigger();
146         }
147
148         otimed_reschedule();
149     }
150
151         private void on_gps_time(dynamic DBus.Object pos, int t)
152         {
153         if (t == 0)
154         {
155             last_gps_time_system_time = 0;
156             update_time();
157         } else {
158             last_gps_time = (time_t)t;
159             last_gps_time_system_time = time_t();
160             update_time();
161         }
162         }
163
164     private bool on_system_time()
165     {
166         last_system_time = time_t();
167         update_time();
168         return true;
169     }
170
171     private void update_time()
172     {
173         if (last_gps_time_system_time + 10 > last_system_time)
174         {
175             chosen_time = last_gps_time;
176             chosen_type = SourceType.GPS;
177         }
178         else
179         {
180             chosen_time = last_system_time;
181             chosen_type = SourceType.SYSTEM;
182         }
183         if (chosen_time / 60 != last_minute)
184         {
185             last_minute = chosen_time / 60;
186             minute_changed(chosen_time, chosen_type);
187         }
188     }
189
190         /// Request GPS resource
191         public override void start()
192         {
193                 if (started) return;
194
195         system_time_timeout = Timeout.add(5000, on_system_time);
196                 gps_time.TimeChanged += on_gps_time;
197         last_system_time = time_t();
198         update_time();
199
200                 base.start();
201         }
202
203         public override void stop()
204         {
205                 if (!started) return;
206
207         Source.remove(system_time_timeout);
208                 gps_time.TimeChanged -= on_gps_time;
209
210                 base.stop();
211         }
212 }
213
214 public Clock clock = null;
215
216 public void init()
217 {
218     clock = new Clock();
219
220         zavai.registry.register_service(clock);
221 }
222
223 }
224 }