Start to change the Alarm API
[gregoa/zavai.git] / src / at.vala
1 /*
2  * at - at interface
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 at {
24
25 // Return the earliest ID in the queue, or -1 if none are found
26 // Queue is null for all queues, otherwise a queue name
27 public static int earliestID(string? queue = null)
28 {
29         string argv[4];
30         argv[0] = "/usr/bin/atq";
31         if (queue == null)
32                 argv[1] = null;
33         else
34         {
35                 argv[1] = "-q";
36                 argv[2] = queue;
37                 argv[3] = null;
38         }
39
40         Pid pid;
41         int stdout;
42
43         if (!Process.spawn_async_with_pipes("/", argv, null, SpawnFlags.STDERR_TO_DEV_NULL, null, out pid, null, out stdout, null))
44                 return -1;
45
46         FileStream fs = FileStream.fdopen(stdout, "r");
47         if (fs == null)
48                 return -1;
49
50         int first_id = -1;
51         time_t first_ts = 0;
52         char buf[200];
53         string? line;
54         while ((line = fs.gets(buf)) != null)
55         {
56                 if (!line[0].isdigit()) continue;
57                 weak string rest;
58                 ulong id = line.to_ulong(out rest, 10);
59                 Time t = new Time();
60                 rest = t.strptime(rest.offset(1), "%a %b %d %H:%M:%S %Y");
61                 if (rest == null) continue;
62                 time_t tt = t.mktime();
63                 if (first_ts == 0 || tt < first_ts)
64                 {
65                         first_ts = tt;
66                         first_id = (int)id;
67                 }
68         }
69         Process.close_pid(pid);
70         return first_id;
71 }
72
73 public delegate bool jobParser(int fd);
74
75 // Get the contents of a job given its id
76 public static bool jobContents(int id, jobParser parser)
77 {
78         string argv[4];
79         argv[0] = "/usr/bin/at";
80         argv[1] = "-c";
81         argv[2] = id.to_string();
82         argv[3] = null;
83
84         Pid pid;
85         int stdoutfd;
86
87         if (!Process.spawn_async_with_pipes("/", argv, null, SpawnFlags.STDERR_TO_DEV_NULL, null, out pid, null, out stdoutfd, null))
88                 return false;
89
90         bool res = parser(stdoutfd);
91
92         Process.close_pid(pid);
93
94         return res;
95 }
96
97 /*
98 TODO: schedule alarms via at
99
100 Uses the 'z' queue.
101
102 atq -q z  can be used to list the jobs (for example, at startup, or after a job has run)
103 at -c id  can be used to query a job, parsing its contents (which can have
104           comments or variables being set)
105 zavai --notify ...  can be used to notify the job (and start zavai if it's not running)
106
107 Alarm needs to be able to serialize itself to an at invocation and to
108 deserialize itself from the output of at -c
109
110 Alarm needs to deserialize also a job with no special markers whatsoever: a
111 generic at job.
112 */
113
114
115 /*
116 public class Alarm : Object
117 {
118         // TODO: make a factory method to construct from an "at -c" output
119
120         // TODO: make a method that provides an at invocation
121
122         public signal void trigger(Alarm a);
123
124         public time_t deadline;
125         public string label;
126
127         public Alarm(time_t deadline, string label)
128         {
129                 this.deadline = deadline;
130                 this.label = label;
131         }
132 }
133 */
134
135         // Schedule a task that notifies a string
136         // TODO public void schedule_label(const Alarm a);
137
138         // Return the next item in the queue due to be run
139         // TODO public Alarm? next_scheduled();
140
141 }