wvprint/queue.cc

   1 /*
   2  * Worldvisions Weaver Software:
   3  *   Copyright (C) 1997-2004 Net Integration Technologies, Inc.
   4  *
   5  * This is the PrintQueue class for handling various queue functions
   6  * under WvPrint.
   7  */
   8 #include <wvpipe.h>
   9 #include <wvtimeoutstream.h>
  10 #include <sys/stat.h>
  11 #include <sys/types.h>
  12
  13 #include <cups/cups.h>
  14
  15 #include "queue.h"
  16 #include "wvcupsmanager.h"
  17 #include "wvprintuniconfkeys.h"
  18
  19 // This macro dose nothing, just to markup the msgid for xgettext
  20 #define N_(string)              string
  21
  22 const unsigned int MAX_JOBS = 1000;
  23
  24 /* I wodner what is the usefulness of that function */
  25 PrintQueue* PrintQueue::new_queue(WvStringParm name, const UniConf cfg,
  26                                   WvLog& log)
  27 {
  28     PrintQueue* queue = 0;
  29
  30     queue = new PrintQueue(name, cfg, log, false);
  31
  32     return queue;
  33 }
  34
  35 PrintQueue* PrintQueue::new_alias(WvStringParm name, const UniConf cfg,
  36                                   WvLog& log)
  37 {
  38     PrintQueue* queue = 0;
  39
  40     queue = new PrintQueue(name, cfg, log, true);
  41
  42     return queue;
  43 }
  44
  45 PrintQueue::PrintQueue(WvStringParm _name, const UniConf _cfg, WvLog &_log, bool _is_alias):
  46     cfg(_cfg), log(_log), name(_name),
  47     refresh_interval(15), last_refreshed(0),
  48     configured(false), cups(NULL), is_alias(_is_alias)
  49 {
  50     if (is_alias)
  51     {
  52         log(WvLog::Debug, "Setting up queue %s as an alias\n", name);
  53     }
  54     else
  55     {
  56         log(WvLog::Debug, "Setting up queue %s\n", name);
  57     }
  58 }
  59
  60 PrintQueue::~PrintQueue()
  61 {
  62     if (cups)
  63     {
  64         cups->ipp_delete_printer(name);
  65     }
  66     log(WvLog::Debug, "destroying PrintQueue() instance\n");
  67 }
  68
  69
  70 bool PrintQueue::reconfig(void)
  71 {
  72     WvString realqueuename;
  73     if(is_alias)
  74     {
  75         realqueuename = cfg["aliases"][name].getme();
  76     }
  77     else
  78     {
  79         realqueuename = name;
  80     }
  81
  82     UniConf qcfg = cfg["queues"][realqueuename];
  83     WvString device = qcfg["device"].getme("");
  84
  85     // default to parallel for the port, if there's none
  86     // if there's none it's probably because in older versions
  87     // there was no "port", and "parallel" will actually print
  88     // to USB printers anyway
  89     WvString port = qcfg["port"].getme("parallel");
  90     WvString description;
  91
  92     if (is_alias)
  93     {
  94         log(WvLog::Debug, "Creating alias queue %s for %s\n", name, realqueuename);
  95         description = WvString("Alias to %s", realqueuename);
  96     }
  97     else
  98     {
  99         log(WvLog::Debug, "Creating printer queue for %s on device %s:%s\n", name, port, device);
 100         description = qcfg["description"].getme();
 101     }
 102
 103     if (cups)
 104     {
 105         configured = cups->ipp_create_printer(name, WvString("%s:%s", port, device),
 106                                               description);
 107     }
 108     else
 109     {
 110         configured = true;
 111     }
 112     return configured;
 113 }
 114
 115
 116
 117 bool PrintQueue::cancel(int id, WvStringParm agent)
 118 {
 119     if(cups)
 120     {
 121         return cups->cancel_job(name, id);
 122     }
 123     return false;
 124 }
 125
 126 unsigned int PrintQueue::get_active_id() const
 127 {
 128     return 0;
 129 //    return active ? active->get_id() : 0;
 130 }
 131
 132 size_t PrintQueue::job_count() const
 133 {
 134     if (cups)
 135     {
 136         return cups->count_jobs(name);
 137     }
 138     return 0;
 139 }
 140
 141
 142 bool PrintQueue::increase_priority(unsigned int job_id)
 143 {
 144 #if 0
 145     PrintJobList::Iter i(jobs);
 146     i.rewind();
 147     while (i.next() && i().get_id() != job_id)
 148         { }
 149
 150     if (i().get_id() == job_id)
 151     {
 152         PrintJob *tempjob = new PrintJob(*i);
 153         jobs.unlink(&(*i));
 154         jobs.prepend(tempjob, true);
 155     }
 156     else
 157         return false;
 158 #endif
 159     log("increase_priority() not implemented\n");
 160     return true;
 161 }
 162
 163 bool PrintQueue::job_exists(WvStringParm queuename, int job_num)
 164 {
 165     if (cups)
 166     {
 167         return cups->job_exists(queuename, job_num);
 168     }
 169     return false;
 170 }
 171
 172 PrintJobVector& PrintQueue::get_jobs()
 173 {
 174     jobs.zap();
 175     cups->get_cups_jobs(name, jobs, *this);
 176
 177     return jobs;
 178 }
 179
 180
 181 bool PrintQueue::enable(void)
 182 {
 183     bool is_configured = false;
 184     if (!configured)
 185     {
 186         is_configured = reconfig();
 187     }
 188     if (configured && cups)
 189     {
 190         bool result = cups->ipp_enable_printer(name);
 191         if (!result)
 192         {
 193             log(WvLog::Error, "Print queue enabling failed !\n");
 194         }
 195     }
 196     return is_configured;
 197 }
 198
 199 bool PrintQueue::disable(void)
 200 {
 201     bool is_configured = false;
 202     if (!configured)
 203     {
 204         is_configured = reconfig();
 205     }
 206     if (configured && cups)
 207     {
 208         bool result = cups->ipp_disable_printer(name);
 209         if (!result)
 210         {
 211             log(WvLog::Error, "Print queue disabling failed !\n");
 212         }
 213     }
 214     return is_configured;
 215 }
 216
 217 void PrintQueue::set_default(void)
 218 {
 219     if (cups)
 220     {
 221         bool result = cups->set_default_printer(name);
 222         if (!result)
 223         {
 224             log(WvLog::Error, "Unable to make '%s' the default print queue.\n",
 225                 name);
 226         }
 227     }
 228 }
 229
 230 void PrintQueue::restart(void)
 231 {
 232     if (cups)
 233     {
 234         bool result = cups->ipp_enable_printer(name);
 235         if (!result)
 236         {
 237             log(WvLog::Error, "Unable restart queue '%s'.\n",
 238                 name);
 239         }
 240     }
 241 }
 242
 243
 244 /**
 245    Convert an ipp_pstate_t to a string
 246  */
 247 WvString PrintQueue::ipp_state_to_string(ipp_pstate_t state)
 248 {
 249     switch(state)
 250     {
 251     case IPP_PRINTER_IDLE:
 252         return N_("Idle");
 253         break;
 254     case IPP_PRINTER_PROCESSING:
 255         return N_("Processing...");
 256         break;
 257     case IPP_PRINTER_STOPPED:
 258         return N_("Stopped");
 259         break;
 260     default:
 261         break;
 262     }
 263     return N_("Unknown");
 264 }
 265
 266
 267 WvString PrintQueue::get_state(void)
 268 {
 269     WvString state_str;
 270     ipp_pstate_t state = IPP_PRINTER_STOPPED;
 271
 272     if (!configured)
 273     {
 274         reconfig();
 275     }
 276
 277     if (configured && cups && cups->ipp_get_printer_state(name, state))
 278     {
 279         state_str = ipp_state_to_string(state);
 280     }
 281     else
 282     {
 283         state_str = N_("ERROR");
 284     }
 285     return state_str;
 286 }