开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 通讯/手机编程 > 传真(Fax)编程 > 查看源码
faxalter.c++
资源名称：hylafax-5.3.0.tar.gz　[点击查看]
上传用户：weiyuanprp
上传日期：2020-05-20
资源大小：1169k
文件大小：9k
源码类别：

传真(Fax)编程

开发平台：

C/C++

faxalter.c++：源码内容
  1. /* $Id: faxalter.c++,v 1.11 2009/09/29 11:46:01 faxguy Exp $ */
  2. /*
  3.  * Copyright (c) 1990-1996 Sam Leffler
  4.  * Copyright (c) 1991-1996 Silicon Graphics, Inc.
  5.  * HylaFAX is a trademark of Silicon Graphics
  6.  *
  7.  * Permission to use, copy, modify, distribute, and sell this software and 
  8.  * its documentation for any purpose is hereby granted without fee, provided
  9.  * that (i) the above copyright notices and this permission notice appear in
  10.  * all copies of the software and related documentation, and (ii) the names of
  11.  * Sam Leffler and Silicon Graphics may not be used in any advertising or
  12.  * publicity relating to the software without the specific, prior written
  13.  * permission of Sam Leffler and Silicon Graphics.
  14.  * 
  15.  * THE SOFTWARE IS PROVIDED "AS-IS" AND WITHOUT WARRANTY OF ANY KIND, 
  16.  * EXPRESS, IMPLIED OR OTHERWISE, INCLUDING WITHOUT LIMITATION, ANY 
  17.  * WARRANTY OF MERCHANTABILITY OR FITNESS FOR A PARTICULAR PURPOSE.  
  18.  * 
  19.  * IN NO EVENT SHALL SAM LEFFLER OR SILICON GRAPHICS BE LIABLE FOR
  20.  * ANY SPECIAL, INCIDENTAL, INDIRECT OR CONSEQUENTIAL DAMAGES OF ANY KIND,
  21.  * OR ANY DAMAGES WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS,
  22.  * WHETHER OR NOT ADVISED OF THE POSSIBILITY OF DAMAGE, AND ON ANY THEORY OF 
  23.  * LIABILITY, ARISING OUT OF OR IN CONNECTION WITH THE USE OR PERFORMANCE 
  24.  * OF THIS SOFTWARE.
  25.  */
  26. #include "FaxClient.h"
  27. #include "Sys.h"
  28. #include "config.h"
  30. extern int
  31. parseAtSyntax(const char* s, const struct tm& ref, struct tm& at0, fxStr& emsg);
  33. class faxAlterApp : public FaxClient {
  34. private:
  35.     bool groups; // group or job id's
  36.     fxStr script; // commands to send for each job
  38.     void usage();
  39. public:
  40.     faxAlterApp();
  41.     ~faxAlterApp();
  43.     int run(int argc, char** argv);
  44.     bool duplicate ();
  45. };
  46. faxAlterApp::faxAlterApp() { groups = false; }
  47. faxAlterApp::~faxAlterApp() {}
  49. bool faxAlterApp::duplicate ()
  50. {
  51.     /*
  52.      * Before we dup the job, we need to get the list of documents
  53.      * Documents are sent as continuations to the 213, like:
  54.      * -> JPARM document
  55.      * 213-PS docq/doc281.ps
  56.      * 213-PS docq/doc283.ps
  57.      * 213-PS docq/doc284.ps
  58.      * 213 End of documents.
  59.      */
  60.     command("JPARM document");
  61.     fxStr docs = getLastContinuation();
  63.     fxStr jid, gid, emsg;
  64.     if (! newJob(jid, gid, emsg) ) {
  65. printError("%s", (const char*) emsg);
  66. return false;
  67.     }
  69.     for ( u_int pos = 0, next; (next = docs.next(pos, 'n')) < docs.length(); )
  70.     {
  71. /*
  72.  * The document is in the form "<TYPE> <filename>"
  73.  * - separate it and resubmit the document
  74.  */
  75. fxStr tmp = docs.extract(pos, next-pos);
  76. int c = tmp.find(0, " ");
  77. if (c)
  78.     jobDocument(&tmp[c+1]);
  79. pos = next+1;
  80.     }
  82.     return true;
  83. }
  85. int
  86. faxAlterApp::run(int argc, char** argv)
  87. {
  88.     resetConfig();
  89.     readConfig(FAX_SYSCONF);
  90.     readConfig(FAX_USERCONF);
  92.     fxStr emsg;
  93.     time_t now = Sys::now();
  94.     struct tm tts = *localtime(&now);
  95.     struct tm when;
  96.     bool useadmin = false;
  97.     bool resubmit = false;
  98.     char *owner = NULL;
  99.     char *pass = NULL;
  100.     char *adminpass = NULL;
  102.     int c, rc = 0;
  103.     while ((c = Sys::getopt(argc, argv, "a:C:d:h:k:m:n:O:P:t:u:U:ADQRgprv")) != -1)
  104. switch (c) {
  105. case 'A': // connect with administrative privileges
  106.     useadmin = true;
  107.     break;
  108. case 'C': // a user-specified command
  109.     script.append(optarg);
  110.             script.append("n");
  111.     break;
  112. case 'D': // set notification to when done
  113.         script.append(groups ? "JGPARM " : "JPARM ");
  114.         script.append("NOTIFY DONEn");
  115.     break;
  116. case 'Q': // no notification (quiet)
  117.         script.append(groups ? "JGPARM " : "JPARM ");
  118.         script.append("NOTIFY DONEn");
  119.     break;
  120. case 'R': // set notification to when requeued
  121.         script.append(groups ? "JGPARM " : "JPARM ");
  122.         script.append("NOTIFY DONE+REQUEUEn");
  123.     break;
  124. case 'a': // send at specified time
  125.     if (strcasecmp(optarg, "NOW")) {
  126. if (!parseAtSyntax(optarg, *localtime(&now), tts, emsg)) {
  127.     printError("%s", (const char*) emsg);
  128.     return (1);
  129. }
  130. now = mktime(&tts);
  131. when = *gmtime(&now); // NB: must be relative to GMT
  132.         script.append(groups ? "JGPARM " : "JPARM ");
  133. script.append("SENDTIME ");
  134.             {
  135.                 fxStr tmpbuf = fxStr::format(
  136.                     "%d%02d%02d%02d%02d"
  137.             , when.tm_year+1900
  138.             , when.tm_mon+1
  139.             , when.tm_mday
  140.             , when.tm_hour
  141.             , when.tm_min
  142.         );
  143.                 script.append(tmpbuf);
  144.                 script.append("n");
  145.             }
  146.     } else {
  147.             script.append(groups ? "JGPARM " : "JPARM ");
  148.             script.append("SENDTIME NOWn");
  149.         }
  150.     break;
  151. case 'd': // destination number
  152.             script.append(groups ? "JGPARM " : "JPARM ");
  153.     script.append("EXTERNAL ");
  154.             script.append(optarg);
  155.             script.append("n");
  156.             script.append(groups ? "JGPARM " : "JPARM ");
  157.     script.append("DIALSTRING ");
  158.             script.append(optarg);
  159.             script.append("n");
  160.     break;
  161. case 'g': // apply to groups, not jobs
  162.     groups = true;
  163.     break;
  164. case 'h': // server's host
  165.     setHost(optarg);
  166.     break;
  167. case 'k': // kill job at specified time
  168.     if (!parseAtSyntax(optarg, tts, when, emsg)) {
  169. printError("%s", optarg, (const char*) emsg);
  170. return (1);
  171.     }
  172.     { time_t tv = mktime(&when) - now;
  173.           script.append(groups ? "JGPARM " : "JPARM ");
  174.       script.append("LASTTIME ");
  175.       fxStr tmpbuf = fxStr::format(
  176.              "%02d%02d%02d"
  177.      , tv/(24*60*60)
  178.      , (tv/(60*60))%24
  179.      , (tv/60)%60
  180.       );
  181.           script.append(tmpbuf);
  182.           script.append("n");
  183.     }
  184.     break;
  185. case 'm': // modem
  186.         script.append(groups ? "JGPARM " : "JPARM ");
  187.     script.append("MODEM ");
  188.         script.append(optarg);
  189.         script.append("n");
  190.     break;
  191. case 'n': // set notification
  192.         script.append(groups ? "JGPARM " : "JPARM ");
  193.     script.append("NOTIFY ");
  194. if (strcasecmp(optarg, "done") == 0) {
  195.             script.append("DONEn");
  196.         } else if (strcasecmp(optarg, "requeued") == 0) {
  197.             script.append("DONE+REQUEUEn");
  198.         } else {
  199.             script.append(optarg);
  200.             script.append("n");
  201.         }
  202.     break;
  203. case 'O':
  204.     readConfigItem(optarg);
  205.     break;
  206. case 'p': // send now (push)
  207.         script.append(groups ? "JGPARM " : "JPARM ");
  208.     script.append("SENDTIME NOWn");
  209.     break;
  210. case 'P': // scheduling priority
  211.     if ((u_int) atoi(optarg) > 255)
  212. fxFatal("Invalid job priority %s;"
  213.     " values must be in the range [0,255]", optarg);
  214.         script.append(groups ? "JGPARM " : "JPARM ");
  215.     script.append("SCHEDPRI ");
  216.     script.append(optarg);
  217.             script.append("n");
  218.     break;
  219. case 'r':
  220.     resubmit = true;
  221.     break;
  222. case 't': // set max number of retries
  223.     if (atoi(optarg) < 0)
  224. fxFatal("Bad number of retries for -t option: %s", optarg);
  225.         script.append(groups ? "JGPARM " : "JPARM ");
  226.     script.append("MAXDIALS ");
  227.     script.append(optarg);
  228.             script.append("n");
  229.     break;
  230. case 'u': // specify login
  231.     owner = optarg;
  232.     break;
  233. case 'U': // specify pass:adminpass
  234.     {
  235. char* pp = strchr(optarg, ':');
  236. if (pp && *(pp + 1) != '') {
  237.     *pp = '';
  238.     adminpass = pp + 1;
  239. }
  240.     }
  241.     pass = optarg;
  242.     break;
  243. case 'v': // trace protocol
  244.     setVerbose(true);
  245.     break;
  246. case '?':
  247.     usage();
  248. }
  249.     if (optind >= argc)
  250. usage();
  251.     if (script == "" && !resubmit)
  252. fxFatal("No job parameters specified for alteration.");
  253.     if (callServer(emsg)) {
  254. if (login(owner, pass, emsg) &&
  255.     (!useadmin || admin(adminpass, emsg))) {
  256.     for (; optind < argc; optind++) {
  257. const char* jobid = argv[optind];
  258. if (setCurrentJob(jobid)) {
  259.     /*
  260.      * We take the approach that if we can't do the work on a
  261.      * job, we continue on to the next
  262.      */
  263.     if (resubmit) {
  264. if (! duplicate()) {
  265.     rc = 3;
  266.     continue;
  267. }
  268. const char* old_job = jobid;
  269. jobid = getCurrentJob();
  270. printf("Job %s: duplicated as job %s.n", old_job, jobid);
  271.     } else if (! jobSuspend(jobid)) {
  272. emsg = getLastResponse();
  273. printError("%s", (const char*) emsg);
  274. rc = 3;
  275. continue;
  276.     }
  277.     if (!runScript(script, script.length(), "<stdin>", emsg)) {
  278. printError("%s", (const char*) emsg);
  279. rc = 3;
  280. continue;
  281.     }
  282.     if (!jobSubmit(jobid)) {
  283. emsg = getLastResponse();
  284. printError("%s", (const char*) emsg);
  285. rc = 3;
  286. continue;
  287.     }
  288.     printf("Job %s: done.n", jobid);
  289. } else {
  290.     emsg = getLastResponse();
  291.     printError("%s", (const char*) emsg);
  292.     rc = 3;
  293.     continue;
  294. }
  295.     }
  296. } else {
  297.     printError("%s", (const char*) emsg);
  298.     rc = 2;
  299. }
  300. hangupServer();
  301.     } else {
  302. printError("%s", (const char*) emsg);
  303. rc = 2;
  304.     }
  305.     return (rc);
  306. }
  308. void
  309. faxAlterApp::usage()
  310. {
  311.     fxFatal("usage: faxalter"
  312.       " [-h server-host]"
  313.       " [-a time]"
  314.       " [-C command]"
  315.       " [-d number]"
  316.       " [-k time]"
  317.       " [-m modem]"
  318.       " [-n notify]"
  319.       " [-P priority]"
  320.       " [-t tries]"
  321.       " [-u user]"
  322.       " [-U pass[:adminpass]]"
  323.       " [-A]"
  324.       " [-g]"
  325.       " [-p]"
  326.       " [-r]"
  327.       " [-v]"
  328.       " [-DQR]"
  329.       " jobID...");
  330. }
  332. int
  333. main(int argc, char** argv)
  334. {
  335.     faxAlterApp app;
  336.     return (app.run(argc, argv));
  337. }