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 }