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

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

传真(Fax)编程

开发平台：

C/C++

SendFaxClient.c++：源码内容
  1. /* $Id: SendFaxClient.c++,v 1.7 2008/05/14 00:49:55 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 "config.h"
  27. #include "Sys.h"
  29. #include <ctype.h>
  30. #include <string.h>
  31. #include <errno.h>
  33. #include "SendFaxClient.h"
  34. #include "TypeRules.h"
  35. #include "DialRules.h"
  36. #include "Array.h"
  38. struct FileInfo : public fxObj {
  39.     fxStr name; // user-specified document file
  40.     fxStr temp; // converted temporary file
  41.     fxStr doc; // document name on server
  42.     const TypeRule* rule;
  44.     FileInfo();
  45.     FileInfo(const FileInfo& other);
  46.     ~FileInfo();
  47. };
  48. fxDECLARE_ObjArray(FileInfoArray, FileInfo)
  50. struct PollRequest : public fxObj {
  51.     fxStr sep;
  52.     fxStr pwd;
  54.     PollRequest();
  55.     PollRequest(const PollRequest& other);
  56.     ~PollRequest();
  57. };
  58. fxDECLARE_ObjArray(PollRequestArray, PollRequest)
  60. SendFaxClient::SendFaxClient()
  61. {
  62.     jobs = new SendFaxJobArray;
  63.     typeRules = NULL;
  64.     dialRules = NULL;
  65.     files = new FileInfoArray;
  66.     polls = new PollRequestArray;
  67.     setup = false;
  69.     setupConfig();
  70. }
  72. SendFaxClient::~SendFaxClient()
  73. {
  74.     if (tmpFile != "")
  75. Sys::unlink(tmpFile);
  76.     delete typeRules;
  77.     delete dialRules;
  78.     delete polls;
  79.     delete files;
  80.     delete jobs;
  81. }
  83. void SendFaxClient::vprintError(const char* fmt, va_list ap)
  84.     { FaxClient::vprintError(fmt, ap); }
  85. void SendFaxClient::vprintWarning(const char* fmt, va_list ap)
  86.     { FaxClient::vprintWarning(fmt, ap); }
  87. void SendFaxClient::vtraceServer(const char* fmt, va_list ap)
  88.     { FaxClient::vtraceServer(fmt, ap); }
  90. bool
  91. SendFaxClient::prepareForJobSubmissions(fxStr& emsg)
  92. {
  93.     if (senderName == "" && !setupSenderIdentity(from, emsg))
  94. return (false);
  95.     /*
  96.      * Prepare documents for transmission.
  97.      */
  98.     if (typeRules == NULL) {
  99. typeRules = TypeRules::read(typeRulesFile);
  100. if (!typeRules) {
  101.     emsg = "Unable to setup file typing and conversion rules";
  102.     return (false);
  103. }
  104.     }
  105.     typeRules->setVerbose(verbose);
  106.     if (dialRules == NULL) {
  107. dialRules = new DialStringRules(dialRulesFile);
  108. dialRules->setVerbose(verbose);
  109. /*
  110.  * NB: Not finding a client-side dialrules file is not fatal; it
  111.  *     used to generate a warning message but so many people were
  112.  *     confused by this that the message has been removed so I no
  113.  *     longer have to explain why it's not a problem.
  114.  */
  115. (void) dialRules->parse(false);
  116.     } else
  117. dialRules->setVerbose(verbose);
  118.     /*
  119.      * Lock down job page size information.
  120.      */
  121.     u_int i, n;
  122.     for (i = 0, n = jobs->length(); i < n; i++) {
  123. SendFaxJob& job = (*jobs)[i];
  124. if (job.getPageWidth() != 0 && job.getPageLength() != 0)
  125.     continue;
  126. if (!job.setPageSize(job.getPageSize())) {
  127.     emsg = "Unknown page size " | job.getPageSize();
  128.     return (false);
  129. }
  130.     }
  131.     /*
  132.      * NB: Not (currently) smart enough to recognize when
  133.      *     documents need to be reprocessed.  For now we
  134.      *     just assume document conversions are not affected
  135.      *     by job state changes.
  136.      */
  137.     totalPages = 0;
  138.     for (i = 0, n = files->length(); i < n; i++)
  139. if (!prepareFile((*files)[i], emsg))
  140.     return (false);
  141.     /*
  142.      * Prepare cover pages.
  143.      */
  144.     for (i = 0, n = jobs->length(); i < n; i++) {
  145. SendFaxJob& job = (*jobs)[i];
  146. /*
  147.  * Convert dialstrings to a displayable format.  This
  148.  * deals with problems like calling card access codes
  149.  * getting stuck on the cover sheet and/or displayed in
  150.  * status messages.
  151.  */
  152. job.setExternalNumber(dialRules->displayNumber(job.getDialString()));
  153. /*
  154.  * Suppress the cover page if we're just doing a poll;
  155.  * otherwise, generate a cover sheet for each destination
  156.  * This done now so that we can be sure everything is ready
  157.  * to send before we setup a connection to the server.
  158.  */
  159. if (job.getAutoCoverPage() && getNumberOfFiles() > 0) {
  160.     fxStr file;
  161.     if (!makeCoverPage(job, file, emsg))
  162. return (false);
  163.     job.setCoverPageFile(file, true);
  164. }
  165.     }
  166.     return (setup = true);
  167. }
  169. static fxStr
  170. joinargs(const char* app, const char* av[])
  171. {
  172.     fxStr s(app);
  173.     for (int i = 1; av[i] != NULL; i += 2)
  174. s.append(fxStr::format(" %s '%s'", av[i], av[i+1]));
  175.     return s;
  176. }
  178. static void
  179. addarg(const char* av[], int& ac, const char* flag, const fxStr& opt)
  180. {
  181.     if (opt != "") {
  182. av[ac++] = flag;
  183. av[ac++] = opt;
  184.     }
  185. }
  187. /*
  188.  * Invoke the cover page generation program.
  189.  */
  190. bool
  191. SendFaxClient::makeCoverPage(const SendFaxJob& job, fxStr& file, fxStr& emsg)
  192. {
  193.     const char* templ = _PATH_TMP "/sndfaxXXXXXX";
  194.     char* buff = strcpy(new char[strlen(templ) + 1], templ);
  195.     int fd = Sys::mkstemp(buff);
  196.     tmpFile = buff;
  197.     delete [] buff;
  198.     if (fd >= 0) {
  199. #define MAXARGS 128
  200. const char* av[MAXARGS];
  201. int ac = 0;
  202. const char* cp = strrchr(coverCmd, '/');
  203. // NB: can't use ?: 'cuz of AIX compiler (XXX)
  204. if (cp)
  205.     av[ac++] = cp+1; // program name
  206. else
  207.     av[ac++] = coverCmd;
  208. addarg(av, ac, "-C", job.getCoverTemplate());
  209. addarg(av, ac, "-D", dateFormat);
  210. addarg(av, ac, "-c", job.getCoverComments());
  211. addarg(av, ac, "-f", senderName);
  212. addarg(av, ac, "-l", job.getCoverLocation());
  213. addarg(av, ac, "-n", job.getExternalNumber());
  214. addarg(av, ac, "-r", job.getCoverRegarding());
  215. addarg(av, ac, "-s", job.getPageSize());
  216. addarg(av, ac, "-t", job.getCoverName());
  217. addarg(av, ac, "-v", job.getCoverVoiceNumber());
  218. addarg(av, ac, "-x", job.getCoverCompany());
  219. addarg(av, ac, "-L", job.getCoverFromLocation());
  220. addarg(av, ac, "-N", job.getCoverFromFax());
  221. addarg(av, ac, "-V", job.getCoverFromVoice());
  222. addarg(av, ac, "-X", job.getCoverFromCompany());
  223. addarg(av, ac, "-M", job.getMailbox());
  224. fxStr pages;
  225. if (totalPages > 0) {
  226.     pages = fxStr::format("%u", totalPages);
  227.     addarg(av, ac, "-p", pages);
  228. }
  229. av[ac] = NULL;
  230. if (verbose)
  231.     printf("COVER SHEET "%s"n", (const char*) joinargs(coverCmd,av));
  232. int pfd[2];
  233. if (pipe(pfd) >= 0) {
  234.     pid_t pid = fork();
  235.     switch (pid) {
  236.     case -1: // error
  237. emsg = fxStr::format("Error creating cover sheet; "
  238.     "could not fork subprocess: %s", strerror(errno));
  239. Sys::close(pfd[1]);
  240. break;
  241.     case 0: // child, exec command
  242. if (pfd[1] != STDOUT_FILENO)
  243.     dup2(pfd[1], STDOUT_FILENO);
  244. // XXX should close other descriptors
  245. dup2(STDOUT_FILENO, STDERR_FILENO);
  246. Sys::execv(coverCmd, (char* const*) av);
  247. _exit(-1);
  248. /*NOTREACHED*/
  249.     default: // parent, read from pipe and wait
  250. Sys::close(pfd[1]);
  251. { char buf[16*1024]; // XXX for HP C++ compiler
  252.   int cc, ignore;
  253.   while ((cc = read(pfd[0], buf, sizeof (buf))) > 0) {
  254.       ignore = write(fd, buf, cc);
  255.   }
  256. }
  257. (void) Sys::close(pfd[0]);
  258. (void) Sys::close(fd);
  259. int status;
  260. if (Sys::waitpid(pid, status) == pid && status == 0) {
  261.     file = tmpFile;
  262.     return (true);
  263. }
  264. emsg = fxStr::format("Error creating cover sheet; "
  265.     "command was "%s"; exit status %x"
  266.     , (const char*) joinargs(coverCmd, av)
  267.     , status
  268. );
  269. break;
  270.     }
  271.     Sys::close(pfd[0]);
  272. } else {
  273.     emsg = fxStr::format("Error creating cover sheet; "
  274. "unable to create pipe to subprocess: %s", strerror(errno));
  275. }
  276. #undef MAXARGS
  277.     } else
  278. emsg = fxStr::format("%s: Can not create temporary file for cover page",
  279.     (const char*) tmpFile);
  280.     Sys::unlink(tmpFile);
  281.     return (false);
  282. }
  284. SendFaxJob&
  285. SendFaxClient::addJob(void)
  286. {
  287.     u_int ix = jobs->length();
  288.     jobs->resize(ix+1);
  289.     (*jobs)[ix] = proto;
  290.     setup = false;
  291.     return ((*jobs)[ix]);
  292. }
  293. u_int SendFaxClient::getNumberOfJobs() const { return jobs->length(); }
  295. SendFaxJob*
  296. SendFaxClient::findJob(const fxStr& number, const fxStr& name)
  297. {
  298.     for (u_int i = 0, n = jobs->length(); i < n; i++) {
  299. SendFaxJob& job = (*jobs)[i];
  300. if (job.getDialString() != number)
  301.     continue;
  302. if (name != "" && job.getCoverName() == name)
  303.     return (&job);
  304.     }
  305.     return (NULL);
  306. }
  308. SendFaxJob*
  309. SendFaxClient::findJobByTag(const fxStr& tag)
  310. {
  311.     for (u_int i = 0, n = jobs->length(); i < n; i++) {
  312. SendFaxJob& job = (*jobs)[i];
  313. if (job.getJobTag() == tag)
  314.     return (&job);
  315.     }
  316.     return (NULL);
  317. }
  319. void
  320. SendFaxClient::removeJob(const SendFaxJob& job)
  321. {
  322.     u_int ix = jobs->find(job);
  323.     if (ix != fx_invalidArrayIndex)
  324. jobs->remove(ix);
  325. }
  327. /*
  328.  * Add a new file to send to each destination.
  329.  */
  330. u_int
  331. SendFaxClient::addFile(const fxStr& filename)
  332. {
  333.     u_int ix = files->length();
  334.     files->resize(ix+1);
  335.     (*files)[ix].name = filename;
  336.     setup = false;
  337.     return (ix);
  338. }
  340. const fxStr&
  341. SendFaxClient::getFileDocument(u_int ix) const
  342. {
  343.     return (ix < files->length() ? (*files)[ix].doc : fxStr::null);
  344. }
  346. u_int SendFaxClient::getNumberOfFiles() const { return files->length(); }
  348. u_int
  349. SendFaxClient::findFile(const fxStr& filename) const
  350. {
  351.     for (u_int i = 0, n = files->length(); i < n; i++)
  352. if ((*files)[i].name == filename)
  353.     return (i);
  354.     return (fx_invalidArrayIndex);
  355. }
  357. void
  358. SendFaxClient::removeFile(u_int ix)
  359. {
  360.     if (ix < files->length())
  361. files->remove(ix);
  362. }
  364. void
  365. SendFaxClient::purgeFileConversions()
  366. {
  367.     for (u_int i = 0, n = files->length(); i < n; i++) {
  368. FileInfo& info = (*files)[i];
  369. if (info.temp != "" && info.temp != info.name) {
  370.     Sys::unlink(info.temp);
  371.     info.temp = "";
  372. }
  373.     }
  374. }
  376. u_int
  377. SendFaxClient::addPollRequest()
  378. {
  379.     return addPollRequest(fxStr::null, fxStr::null);
  380. }
  381. u_int
  382. SendFaxClient::addPollRequest(const fxStr& sep)
  383. {
  384.     return addPollRequest(sep, fxStr::null);
  385. }
  386. u_int
  387. SendFaxClient::addPollRequest(const fxStr& sep, const fxStr& pwd)
  388. {
  389.     u_int ix = polls->length();
  390.     polls->resize(ix+1);
  391.     (*polls)[ix].sep = sep;
  392.     (*polls)[ix].pwd = pwd;
  393.     setup = false;
  394.     return (ix);
  395. }
  396. u_int SendFaxClient::getNumberOfPollRequests() const { return polls->length(); }
  398. void
  399. SendFaxClient::getPollRequest(u_int ix, fxStr& sep, fxStr& pwd)
  400. {
  401.     if (ix < polls->length()) {
  402. sep = (*polls)[ix].sep;
  403. pwd = (*polls)[ix].pwd;
  404.     }
  405. }
  407. void
  408. SendFaxClient::removePollRequest(u_int ix)
  409. {
  410.     if (ix < polls->length())
  411. polls->remove(ix);
  412. }
  414. /*
  415.  * Submit documents and jobs to the server.
  416.  */
  417. bool
  418. SendFaxClient::submitJobs(fxStr& emsg)
  419. {
  420.     if (!setup) {
  421. emsg = "Documents not prepared";
  422. return (false);
  423.     }
  424.     if (!isLoggedIn()) {
  425. emsg = "Not logged in to server";
  426. return (false);
  427.     }
  428.     /*
  429.      * Transfer documents to the server.
  430.      */
  431.     if (!sendDocuments(emsg))
  432. return (false);
  433.     /*
  434.      * Construct jobs and submit them.
  435.      */
  436.     if (!(*jobs)[0].initJobs(*this, emsg))
  437. return (false);
  438.     for (u_int i = 0, n = jobs->length(); i < n; i++) {
  439. SendFaxJob& job = (*jobs)[i];
  440. if (!job.createJob(*this, emsg))
  441.     return (false);
  442. if (!jobSubmit(job.getJobID())) {
  443.     emsg = getLastResponse();
  444.     return (false);
  445. }
  446. notifyNewJob(job); // notify client
  447.     }
  448.     return (true);
  449. }
  451. /*
  452.  * Transfer the document files to the server and
  453.  * record the serve-side documents for job submission.
  454.  */
  455. bool
  456. SendFaxClient::sendDocuments(fxStr& emsg)
  457. {
  458.     emsg = "";
  459.     for (u_int i = 0, n = files->length(); i < n; i++) {
  460. FileInfo& info = (*files)[i];
  461. int fd = Sys::open(info.temp, O_RDONLY);
  462. if (fd < 0) {
  463.     emsg = fxStr::format(info.temp | ": Can not open: %s",
  464. strerror(errno));
  465.     return (false); // XXX
  466. }
  467. bool fileSent;
  468. if (info.rule->getResult() == TypeRule::TIFF) {
  469.     fileSent = setFormat(FORM_TIFF)
  470.     && setType(TYPE_I)
  471.     && sendData(fd, &FaxClient::storeTemp, info.doc, emsg);
  472. } else if (info.rule->getResult() == TypeRule::PCL) {
  473.     fileSent = setFormat(FORM_PCL)
  474.          && setType(TYPE_I)
  475.     && sendData(fd, &FaxClient::storeTemp, info.doc, emsg);
  476. } else if (info.rule->getResult() == TypeRule::PDF) {
  477.     fileSent = setFormat(FORM_PDF)
  478.          && setType(TYPE_I)
  479.     && sendData(fd, &FaxClient::storeTemp, info.doc, emsg);
  480. } else {
  481.     fileSent = setFormat(FORM_PS)
  482.          && setType(TYPE_I) // XXX TYPE_A???
  483.     && sendZData(fd, &FaxClient::storeTemp, info.doc, emsg);
  484. }
  485. Sys::close(fd);
  486. if (!fileSent) {
  487.     if (emsg == "")
  488. emsg = "Document transfer failed: " | getLastResponse();
  489.     return (false);
  490. }
  491.     }
  492.     return (true);
  493. }
  495. /*
  496.  * Default notification handler for when a new job is created.
  497.  */
  498. void
  499. SendFaxClient::notifyNewJob(const SendFaxJob& job)
  500. {
  501.     int nfiles = files->length();
  502.     printf("request id is %s (group id %s) for host %s (%u %s)n"
  503. , (const char*) job.getJobID()
  504. , (const char*) job.getGroupID()
  505. , (const char*) getHost()
  506. , nfiles
  507. , nfiles > 1 ? "files" : "file"
  508.     );
  509. }
  511. /*
  512.  * Configuration file support.
  513.  */
  514. #define N(a) (sizeof (a) / sizeof (a[0]))
  516. const SendFaxClient::SF_stringtag SendFaxClient::strings[] = {
  517. { "typerules", &SendFaxClient::typeRulesFile,
  518.   FAX_LIBDATA "/" FAX_TYPERULES },
  519. { "dialrules", &SendFaxClient::dialRulesFile,
  520.   FAX_LIBDATA "/" FAX_DIALRULES },
  521. { "covercmd", &SendFaxClient::coverCmd,
  522.   FAX_CLIENTBIN "/" "faxcover" },
  523. { "from", &SendFaxClient::from, NULL },
  524. { "dateformat", &SendFaxClient::dateFormat, NULL },
  525. };
  527. void
  528. SendFaxClient::setupConfig()
  529. {
  530.     for (int i = N(strings)-1; i >= 0; i--)
  531. (*this).*strings[i].p = (strings[i].def ? strings[i].def : "");
  532.     verbose = false;
  533.     delete typeRules, typeRules = NULL;
  534.     delete dialRules, dialRules = NULL;
  536.     proto.setupConfig();
  537. }
  539. void
  540. SendFaxClient::resetConfig()
  541. {
  542.     FaxClient::resetConfig();
  543.     setupConfig();
  544. }
  546. bool
  547. SendFaxClient::setConfigItem(const char* tag, const char* value)
  548. {
  549.     u_int ix;
  550.     if (findTag(tag, (const tags*) strings, N(strings), ix)) {
  551. (*this).*strings[ix].p = value;
  552.     } else if (streq(tag, "verbose")) {
  553. setVerbose(getBoolean(value));
  554. FaxClient::setVerbose(getVerbose()); // XXX
  555.     } else if (proto.setConfigItem(tag, value)) {
  556. ;
  557.     } else if (!FaxClient::setConfigItem(tag, value))
  558. return (false);
  559.     return (true);
  560. }
  561. #undef N
  563. /*
  564.  * Setup the sender's identity.
  565.  */
  566. bool
  567. SendFaxClient::setupSenderIdentity(const fxStr& from, fxStr& emsg)
  568. {
  569.     FaxClient::setupUserIdentity(emsg); // client identity
  571.     if (from != "") {
  572. u_int l = from.next(0, '<');
  573. if (l == from.length()) {
  574.     l = from.next(0, '(');
  575.     if (l != from.length()) { // joe@foobar (Joe Schmo)
  576. setBlankMailboxes(from.head(l));
  577. l++, senderName = from.token(l, ')');
  578.     } else { // joe
  579. setBlankMailboxes(from);
  580. if (from == getUserName())
  581.     senderName = FaxClient::getSenderName();
  582. else
  583.     senderName = "";
  584.     }
  585. } else { // Joe Schmo <joe@foobar>
  586.     senderName = from.head(l);
  587.     l++, setBlankMailboxes(from.token(l, '>'));
  588. }
  590. // strip leading&trailing white space and quotes
  591. senderName.remove(0, senderName.skip(0, " t""));
  592. senderName.resize(senderName.skipR(senderName.length(), " t""));
  594. if (senderName == "" && getNonBlankMailbox(senderName)) {
  595.     /*
  596.      * Mail address, but no "real name"; construct one from
  597.      * the account name.  Do this by first stripping anything
  598.      * to the right of an '@' and then stripping any leading
  599.      * uucp patch (host!host!...!user).
  600.      */
  601.     senderName.resize(senderName.next(0, '@'));
  602.     senderName.remove(0, senderName.nextR(senderName.length(), '!'));
  603. }
  605. // strip and leading&trailing white space
  606. senderName.remove(0, senderName.skip(0, " t"));
  607. senderName.resize(senderName.skipR(senderName.length(), " t"));
  608.     } else {
  609. senderName = FaxClient::getSenderName();
  610. setBlankMailboxes(getUserName());
  611.     }
  612.     fxStr mbox;
  613.     if (senderName == "" || !getNonBlankMailbox(mbox)) {
  614. emsg = "Malformed (null) sender name or mail address";
  615. return (false);
  616.     } else
  617. return (true);
  618. }
  620. void SendFaxClient::setFromIdentity(const char* s) { from = s; }
  622. /*
  623.  * Assign the specified string to any unspecified email
  624.  * addresses used for notification mail.
  625.  */
  626. void
  627. SendFaxClient::setBlankMailboxes(const fxStr& s)
  628. {
  629.     for (u_int i = 0, n = jobs->length(); i < n; i++) {
  630. SendFaxJob& job = (*jobs)[i];
  631. if (job.getMailbox() == "")
  632.     job.setMailbox(s);
  633.     }
  634. }
  636. /*
  637.  * Return the first non-null mailbox string
  638.  * in the set of jobs.
  639.  */
  640. bool
  641. SendFaxClient::getNonBlankMailbox(fxStr& s)
  642. {
  643.     for (u_int i = 0, n = jobs->length(); i < n; i++) {
  644. SendFaxJob& job = (*jobs)[i];
  645. if (job.getMailbox() != "") {
  646.     s = job.getMailbox();
  647.     return (true);
  648. }
  649.     }
  650.     return (false);
  651. }
  653. /*
  654.  * Process a file submitted for transmission.
  655.  */
  656. bool
  657. SendFaxClient::prepareFile(FileInfo& info, fxStr& emsg)
  658. {
  659.     info.rule = fileType(info.name, emsg);
  660.     if (!info.rule)
  661. return (false);
  662.     if (info.temp != "" && info.temp != info.name)
  663. Sys::unlink(info.temp);
  664.     if (info.rule->getCmd() != "") { // conversion required
  665.         const char* templ = _PATH_TMP "/sndfaxXXXXXX";
  666.         char* buff = strcpy(new char[strlen(templ) + 1], templ);
  667.         Sys::mktemp(buff);
  668.         tmpFile = buff;
  669.         delete [] buff;
  670.         /*
  671.  * XXX **** WARNING **** XXXX
  672.  *
  673.  * We need to generate files according to each job's
  674.  * parameters (page dimensions, resolution, etc.) but
  675.  * the existing protocol does not support doing this
  676.  * right so for now we assume all jobs share these
  677.  * parameters and just use the values from the first
  678.  * prototype job.
  679.  */
  680. fxStr sysCmd = info.rule->getFmtdCmd(info.name, tmpFile,
  681. proto.getHResolution(), proto.getVResolution(),
  682. "1", proto.getPageSize());
  683. if (verbose)
  684.     printf("CONVERT "%s"n", (const char*) sysCmd);
  685. if (system(sysCmd) != 0) {
  686.     Sys::unlink(tmpFile);
  687.     emsg = fxStr::format("Error converting data; command was "%s"",
  688. (const char*) sysCmd);
  689.     return (false);
  690. }
  691. info.temp = tmpFile;
  692.     } else // already postscript, pdf, pcl, or tiff
  693. info.temp = info.name;
  694.     switch (info.rule->getResult()) {
  695.     case TypeRule::TIFF:
  696. countTIFFPages(info.temp);
  697. break;
  698.     case TypeRule::PCL:
  699. // maybe use pclcount/pcl6count from http://www.fea.unicamp.br/pclcount/
  700. break;
  701.     case TypeRule::POSTSCRIPT:
  702.     case TypeRule::PDF:
  703. estimatePostScriptPages(info.temp);
  704. break;
  705.     }
  706.     return (true);
  707. }
  709. /*
  710.  * Return a TypeRule for the specified file.
  711.  */
  712. const TypeRule*
  713. SendFaxClient::fileType(const char* filename, fxStr& emsg)
  714. {
  715.     struct stat sb;
  716.     int fd = Sys::open(filename, O_RDONLY);
  717.     if (fd < 0) {
  718. emsg = fxStr::format("%s: Can not open file", filename);
  719. return (NULL);
  720.     }
  721.     if (Sys::fstat(fd, sb) < 0) {
  722. emsg = fxStr::format("%s: Can not stat file", filename);
  723. Sys::close(fd);
  724. return (NULL);
  725.     }
  726.     if ((sb.st_mode & S_IFMT) != S_IFREG) {
  727. emsg = fxStr::format("%s: Not a regular file", filename);
  728. Sys::close(fd);
  729. return (NULL);
  730.     }
  731.     char buf[512];
  732.     int cc = Sys::read(fd, buf, sizeof (buf));
  733.     Sys::close(fd);
  734.     if (cc == 0) {
  735. emsg = fxStr::format("%s: Empty file", filename);
  736. return (NULL);
  737.     }
  738.     const TypeRule* tr = typeRules->match(buf, cc);
  739.     if (!tr) {
  740. emsg = fxStr::format("%s: Can not determine file type", filename);
  741. return (NULL);
  742.     }
  743.     if (tr->getResult() == TypeRule::ERROR) {
  744. emsg = fxStr::format("%s: ", filename) | tr->getErrMsg();
  745. return (NULL);
  746.     }
  747.     return tr;   
  748. }
  750. #include "tiffio.h"
  752. /*
  753.  * Count the number of ``pages'' in a TIFF file.
  754.  */
  755. void
  756. SendFaxClient::countTIFFPages(const char* filename)
  757. {
  758.     TIFF* tif = TIFFOpen(filename, "r");
  759.     if (tif) {
  760. do {
  761.     totalPages++;
  762. } while (TIFFReadDirectory(tif));
  763. TIFFClose(tif);
  764.     }
  765. }
  767. /*
  768.  * Count the number of pages in a PostScript file.
  769.  * We can really only estimate the number as we
  770.  * depend on the DSC comments to figure this out.
  771.  */
  772. void
  773. SendFaxClient::estimatePostScriptPages(const char* filename)
  774. {
  775.     FILE* fd = fopen(filename, "r");
  776.     if (fd != NULL) {
  777. char line[2048];
  778. if (fgets(line, sizeof (line)-1, fd) != NULL) {
  779.     /*
  780.      * We only consider ``conforming'' PostScript documents.
  781.      */
  782.     if (line[0] == '%' && line[1] == '!') {
  783. int npagecom = 0; // # %%Page comments
  784. int npages = 0; // # pages according to %%Pages comments
  785. while (fgets(line, sizeof (line)-1, fd) != NULL) {
  786.     int n;
  787.     if (strncmp(line, "%%Page:", 7) == 0)
  788. npagecom++;
  789.     else if (sscanf(line, "%%%%Pages: %u", &n) == 1)
  790. npages += n;
  791. }
  792. /*
  793.  * Believe %%Pages comments over counting of %%Page comments.
  794.  */
  795. if (npages > 0)
  796.     totalPages += npages;
  797. else if (npagecom > 0)
  798.     totalPages += npagecom;
  799.     } else if (memcmp(line, "%PDF", 4) == 0) {
  800.         int npages = 0;         // # pages according to "/Type /Page"
  801.         const int slen = 12;    // len of "/Type /Page" + 1 char to check for 's'
  802.         char* endbuf = line+sizeof(line);
  803.   
  804.         rewind(fd);
  805.         char *cp = line;
  806. int len;
  807.         while ((len = fread(cp, 1, endbuf-cp, fd)) > slen+line-cp) {
  808.                     endbuf = cp+len;    // Will only change on the last pass.
  809.             cp = line;
  810.             while ((cp = (char *) memchr((const char*) cp, '/', endbuf-cp-slen))) {
  811.                 if ((memcmp(cp, "/Type /Page", slen-1) == 0 && *(cp+slen-1) != 's') || 
  812.     (memcmp(cp, "/Type/Page",  slen-2) == 0 && *(cp+slen-2) != 's'))
  813.                     npages++;
  814. cp++;
  815.             }
  816.             if ((cp = (char *) memchr((const char*) endbuf-slen, '/', slen))) {
  817.         memcpy(line, cp, endbuf-cp);
  818.         cp = line+(endbuf-cp);
  819.     } else
  820.                 cp = line;
  821.         }
  822.         if (npages > 0)
  823.             totalPages += npages;
  824.     }
  825. }
  826. fclose(fd);
  827.     }
  828. }
  830. FileInfo::FileInfo()
  831. {
  832.     rule = NULL;
  833. }
  834. FileInfo::FileInfo(const FileInfo& other)
  835.     : fxObj(other)
  836.     , name(other.name)
  837.     , temp(other.temp)
  838.     , rule(other.rule)
  839. {
  840. }
  841. FileInfo::~FileInfo()
  842. {
  843.     if (temp != name)
  844. Sys::unlink(temp);
  845. }
  846. fxIMPLEMENT_ObjArray(FileInfoArray, FileInfo)
  848. PollRequest::PollRequest() {}
  849. PollRequest::~PollRequest() {}
  850. PollRequest::PollRequest(const PollRequest& other)
  851.     : fxObj(other)
  852.     , sep(other.sep)
  853.     , pwd(other.pwd)
  854. {}
  855. fxIMPLEMENT_ObjArray(PollRequestArray, PollRequest)