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

源码开发语言/平台
当前位置：首页 > 源码/资料 > 通讯/手机编程 > 手机短信编程 > 查看源码
gw_stuff.c
资源名称：smslink-0.44b.tar.gz　[点击查看]
上传用户：eo_sii
上传日期：2007-01-05
资源大小：91k
文件大小：40k
源码类别：

手机短信编程

开发平台：

Unix_Linux

gw_stuff.c：源码内容
  1. /*==========================================================
  2.  * Program : gw_stuff.c                    Project : smslink
  3.  * Author  : Philippe Andersson.
  4.  * Date    : 01/03/00
  5.  * Version : 0.16b
  6.  * Notice  : (c) Les Ateliers du Heron, 1998 for Scitex Europe, S.A.
  7.  * Comment : Library of functions for the smslink sms2mail gateway.
  8.  *
  9.  * Modification History :
  10.  * - 0.01b (19/08/99) : Initial release. Moved the mail gateway-
  11.  *   specific functions from stuff.c over here.
  12.  * - 0.02b (28/09/99) : Created mailbox_run().
  13.  * - 0.03b (29/09/99) : Extensive rework. Added tkize_ibox_line(),
  14.  *   reset_mail_struct() and parse_smail().
  15.  * - 0.04b (04/10/99) : Added expand_addr().
  16.  * - 0.05b (17/10/99) : Expanded parse_smail() extensively.
  17.  * - 0.06b (19/10/99) : Debugged tkize_ibox_line(). Increased
  18.  *   debugging output. Created shell for send_mail().
  19.  * - 0.07b (20/10/99) : Added mkfromfield().
  20.  * - 0.08b (21/10/99) : Added is_dotted_quad () and resolve().
  21.  * - 0.09b (08/11/99) : Built dialog in send_mail(). Added
  22.  *   slurp_n_catch().
  23.  * - 0.10b (09/11/99) : Modified parse_smail() to provide a
  24.  *   default subject field if the SMS doesn't contain one. Involved
  25.  *   alter the parameters passed to the function. Cosmetics.
  26.  * - 0.11b (12/11/99) : Improved send_mail() to free() the
  27.  *   allocated space for the nicified date.
  28.  * - 0.12b (30/11/99) : Added temp file creation to mailbox_run().
  29.  * - 0.13b (24/02/00) : Completed the transfer routine to the
  30.  *   new mailbox file in mailbox_run().
  31.  * - 0.14b (26/02/00) : Made sure the lockfile (MBOX_LOCKF) was
  32.  *   deleted on each fatal error, as well as on SIGTERM being
  33.  *   caught (in mailgws_death()). Improved error reporting in
  34.  *   various functions. Cosmetics.
  35.  * - 0.15b (29/02/00) : Added functions to handle recepients
  36.  *   lists (as part of struct email_msg). Heavily modified most
  37.  *   functions (send_mail(), parse_smail(), expand_addr()) and
  38.  *   created sub_tkize_field() to account for changes in the
  39.  *   email_msg struct.
  40.  * - 0.16b (01/03/00) : Replaced the "old" slurp_n_catch() by
  41.  *   a new version inspired by get_gsm_answer() (cf. serv_stuff.c).
  42.  *   This should be more robust and less sensitive to the amount
  43.  *   of data sent back by the server (here: sendmail). Created
  44.  *   the clean_field() function (forgotten when split expand_addr()
  45.  *   from sub_tkize_field()).
  46.  *========================================================*/
  48. #include <unistd.h>
  49. #include <stdio.h>                         /* for fprintf */
  50. #include <stdlib.h>                  /* for errno & stuff */
  51. #include <errno.h>
  52. #include <string.h>
  53. #include <syslog.h>
  54. #include <netdb.h>                 /* for gethostbyname() */
  55. #include <sys/socket.h>
  56. #include <netinet/in.h>
  57. #include <arpa/inet.h>
  58. #include <sys/time.h>           /* for the struct timeval */
  59. #include <sys/types.h>
  60. #include <sys/ipc.h>
  61. #include <sys/ioctl.h>            /* for the ioctl() call */
  62. #ifdef LINUX_LC6
  63. #  include <limits.h>                     /* for PATH_MAX */
  64. #  include <linux/limits.h>
  65. #else
  66. #  include <limits.h>
  67. #endif
  69. #include "sms_serv.h"
  71. /*========================================================*/
  72. /* For debugging purposes only - comment out for normal compile */
  73. /* #define INCL_DEBUG_CODE */
  75. /*========================================================*/
  76. void mailgws_death ()
  77. {
  78.   extern int inbox_is_locked;
  79.   
  80.   /* log it... */
  81.   syslog ((FACILITY | LOG_INFO), "gateway exiting on SIGTERM.");
  82.   
  83.   /* remove inbox lock file if necessary */
  84.   if (inbox_is_locked) {
  85.     unlink (MBOX_LOCKF);
  86.   }
  88.   /* closes connection to the syslog daemon */
  89.   closelog ();
  90.   
  91.   /* now exits gracefully */
  92.   exit (0);
  93. }                                     /* mailgws_death () */
  94. /*========================================================*/
  95. void rcpt_list_init (rcpt_list *list)
  96. {
  97.   list->head = NULL;
  98.   list->tail = NULL;
  99. }                                    /* rcpt_list_init () */
  100. /*========================================================*/
  101. int empty_rcpt_list (rcpt_list list)
  102. {
  103.   return (list.head == NULL);
  104. }                                   /* empty_rcpt_list () */
  105. /*========================================================*/
  106. void rcpt_list_insert (rcpt_list *list, char *recepient)
  107. {
  108.   /* WARNING : the order of the elements might be relevent - let's
  109.    * store them as they were in the header => avoid inserting at
  110.    * list head. Do it at the tail. */
  111.   
  112.   int l;
  113.   struct rcpt_item *element;
  115.   /* alloc memory for new element */
  116.   element = (struct rcpt_item *) malloc (sizeof (struct rcpt_item));
  117.   if (!element) {
  118.     syslog ((FACILITY | LOG_ERR), "can't malloc() for new RCPT entry.");
  119.     unlink (MBOX_LOCKF);
  120.     syserr ("sms2mailgw: can't malloc() for new RCPT entry");
  121.   }
  122.   
  123.   /* initialize fields for new element */
  124.   l = strlen (recepient);
  125.   element->rcpt = (char *) malloc ((l + 1) * sizeof (char));
  126.   if (!element->rcpt) {
  127.     syslog ((FACILITY | LOG_ERR), "can't malloc() for new recepient string.");
  128.     unlink (MBOX_LOCKF);
  129.     syserr ("sms2mailgw: can't malloc() for new recepient string");
  130.   }
  131.   strcpy (element->rcpt, recepient);
  132.   
  133.   /* chain it in the list */
  134.   if (empty_rcpt_list (*list)) {
  135.     list->head = element;
  136.     list->tail = element;
  137.     element->next = NULL;
  138.     element->prev = NULL;
  139.   }
  140.   else {
  141.     element->next = NULL;
  142.     element->prev = list->tail;
  143.     list->tail->next = element;
  144.     list->tail = element;
  145.   }
  146. }                                  /* rcpt_list_insert () */
  147. /*========================================================*/
  148. void free_rcpt_list (rcpt_list *list)
  149. {
  150.   struct rcpt_item *cursor;
  152.   if (!empty_rcpt_list (*list)) {
  153.     /* hop to element before last */
  154.     cursor = list->tail->prev;
  155.     /* now go back and clean behind */
  156.     while (cursor != NULL) {
  157.       free (cursor->next->rcpt);
  158.       free (cursor->next);
  159.       cursor->next = NULL;
  160.       list->tail = cursor;
  161.       cursor = cursor->prev;
  162.     }                           /* while (cursor != NULL) */
  163.   }                          /* if (!empty_rcpt_list (... */
  164.   /* now clean last element and reset header */
  165.   free (list->head->rcpt);
  166.   free (list->head);
  167.   list->head = NULL;
  168.   list->tail = NULL;
  169. }                                    /* free_rcpt_list () */
  170. /*========================================================*/
  171. #ifdef INCL_DEBUG_CODE
  172. void print_rcpt_list (rcpt_list list)
  173. {
  174.   struct rcpt_item *cursor;
  176.   if (!empty_rcpt_list (list)) {
  177.     cursor = list.head;
  178.     fprintf (stderr, "<%s>n", cursor->rcpt);
  179.     while (cursor->next != NULL) {
  180.       cursor = cursor->next;
  181.       fprintf (stderr, "<%s>n", cursor->rcpt);
  182.     }
  183.   }
  184.   else {
  185.     fprintf (stderr, "sms2mailgw: empty recepient list.n");
  186.   }
  187. }                                    /* print_acl_list () */
  188. #endif
  189. /*========================================================*/
  190. int is_dotted_quad (char *string)
  191. {
  192.   int is_dq;
  193.   char *s;
  194.   int ntok = 0;
  195.   char *ptok = NULL;
  196.   long int ip_byte;
  197.   char **endptr;
  198.   char *dummyp;
  199.   
  200.   /*--------------------------------------Initializations */
  201.   s = (char *) malloc ((strlen (string) + 1) * sizeof (char));
  202.   if (! s) {
  203.     syslog ((FACILITY | LOG_ERR), "can't malloc().");
  204.     unlink (MBOX_LOCKF);
  205.     syserr ("sms2mailgw: can't malloc()");
  206.   }
  207.   strcpy (s, string);
  208.   /*--------------------------------------------Main Loop */
  209.   /* no point going any further if the 1st char. is not a digit */
  210.   is_dq = isdigit (string[0]);
  211.   if (is_dq) {
  212.     ptok = strtok (s, ".");
  213.     while (ptok != NULL) {
  214.       ntok++;
  215. #ifdef INCL_DEBUG_CODE
  216.       fprintf (stderr, "got token #%d : <%s>n", ntok, ptok);
  217. #endif
  218.       dummyp = ptok + strlen (ptok);
  219.       endptr = &dummyp;
  220.       ip_byte = strtol (ptok, endptr, 10);
  221.       if (strlen (*endptr) != 0) {
  222. #ifdef INCL_DEBUG_CODE
  223. fprintf (stderr, "error on token #%d : can't convert <%s>n", ntok, *endptr);
  224. #endif
  225. is_dq = FALSE;
  226.       }
  227.       ptok = strtok (NULL, ".");
  228.     }
  229.     if (ntok != 4) {
  230.       is_dq = FALSE;
  231.     }
  232.   }                                         /* if (is_dq) */
  233.   /*------------------------------------------Conclusions */
  234.   free (s);
  235.   /*-------------------------------------------------Exit */
  236.   return (is_dq);
  237. }                                    /* is_dotted_quad () */
  238. /*========================================================*/
  239. unsigned long int resolve (char *host)
  240. /* return the host ip address in network format */
  241. {
  242.   struct hostent *h_ent;
  243.   struct in_addr target_ip;
  244.   char **addrs;
  245.   char *scratch;
  246.   
  247.   if (is_dotted_quad (host)) {
  248. #ifdef INCL_DEBUG_CODE
  249.     fprintf (stderr, "I think I got an IP addressn");
  250. #endif
  251.     if (inet_aton (host, &target_ip) == 0)
  252.       syslog ((FACILITY | LOG_ERR), "invalid server IP address (%s).", host);
  253.       scratch = (char *) malloc ((MINIBUFF + 1) * sizeof (char));
  254.       sprintf (scratch, "sms2mailgw: invalid server IP address (%s)", host);
  255.       herror (scratch);
  256.       free (scratch);
  257.       unlink (MBOX_LOCKF);
  258.       exit (1);
  259.   }
  260.   else {
  261. #ifdef INCL_DEBUG_CODE
  262.     fprintf (stderr, "I think I got a host namen");
  263. #endif
  264.     if ((h_ent = gethostbyname (host)) == NULL) {
  265.       syslog ((FACILITY | LOG_ERR), "can't resolve hostname (%s).", host);
  266.       scratch = (char *) malloc ((MINIBUFF + 1) * sizeof (char));
  267.       sprintf (scratch, "sms2mailgw: can't resolve hostname (%s)", host);
  268.       herror (scratch);
  269.       free (scratch);
  270.       unlink (MBOX_LOCKF);
  271.       exit (1);
  272.     }
  273.     /* lines below cf. "Beginning Linux Progr.", pp. 468-473 */
  274.     addrs = h_ent->h_addr_list;
  275.     target_ip = *(struct in_addr *)*addrs;
  276. #ifdef INCL_DEBUG_CODE
  277.     fprintf (stderr, "server IP address is: [%s]n", inet_ntoa (target_ip));
  278. #endif
  279.   }                             /* if (isdigit (host[0])) */
  280.   return (target_ip.s_addr);
  281. }                                           /* resolve () */
  282. /*========================================================*/
  283. int tkize_ibox_line (char *l, struct inbox_line *tkl)
  284. {
  285.   char *token;
  286.   char *scratch;
  287.   
  288.   /*--------------------------------------Initializations */
  289.   /* copy input string to scratch space - we can't modify it */
  290.   scratch = (char *) malloc ((strlen (l) + 1) * sizeof (char));
  291.   if (! scratch) {
  292.     syslog ((FACILITY | LOG_ERR), "can't malloc().");
  293.     unlink (MBOX_LOCKF);
  294.     syserr ("sms2mailgw: can't malloc()");
  295.   }
  296.   scratch[0] = '';
  297.   strcpy (scratch, l);
  298.   
  299.   /*--------------------------------------Parsing routine */
  300.   /*...............................................Device */
  301.   if ((token = strtok (scratch, ",")) == NULL) {
  302.     return (-1);
  303.   }
  304.   strcpy (tkl->device, token);
  305.   
  306.   /*................................................MsgID */
  307.   if ((token = strtok (NULL, ",")) == NULL) {
  308.     return (-1);
  309.   }
  310.   tkl->msgid = atoi (token);
  311.   
  312.   /*..............................................FromGSM */
  313.   if ((token = strtok (NULL, ",")) == NULL) {
  314.     return (-1);
  315.   }
  316.   strcpy (tkl->fromgsm, token);
  317.   
  318.   /*.................................................Date */
  319.   if ((token = strtok (NULL, ",")) == NULL) {
  320.     return (-1);
  321.   }
  322.   strcpy (tkl->date, token);
  323.   
  324.   /*.................................................Time */
  325.   if ((token = strtok (NULL, ",")) == NULL) {
  326.     return (-1);
  327.   }
  328.   strcpy (tkl->time, token);
  329.   
  330.   /*.................................................Text */
  331.   /* just grab the rest of the line */
  332.   if ((token = strtok (NULL, "")) == NULL) {
  333.     return (-1);
  334.   }
  335.   /* remove trailing LF */
  336.   token[strlen (token) - 1] = '';
  337.   dequote (token);
  338.   strcpy (tkl->text, token);
  339.   
  340.   /*-------------------------------------------------Exit */
  341.   free (scratch);
  342.   return 0;                                    /* success */
  343. }                                   /* tkize_ibox_line () */
  344. /*========================================================*/
  345. char *expand_addr (char *field, char *defdom)
  346. {
  347.   char *newstring;
  349.   /*---------------------------------------Initialization */
  350.   newstring = (char *) malloc ((BIGBUFF + 1) * sizeof (char));
  351.   if (! newstring) {
  352.     syslog ((FACILITY | LOG_ERR), "can't malloc().");
  353.     unlink (MBOX_LOCKF);
  354.     syserr ("sms2mailgw: can't malloc()");
  355.   }
  356.   newstring[0] = '';
  357.   
  358.   /*---------------------------------Main processing loop */
  359.   if (strchr (field, '@') == NULL) {
  360.     sprintf (newstring, "%s@%s", field, defdom);
  361.   }
  362.   else {
  363.     strcpy (newstring, field);
  364.   }
  365.   /*------------------------------------------Conclusions */
  366. #ifdef INCL_DEBUG_CODE
  367.   fprintf (stderr, "expanded field: [%s]n", newstring);
  368. #endif
  369.   return (newstring);
  370. }                                       /* expand_addr () */
  371. /*========================================================*/
  372. char *clean_field (char *field)
  373. /* For fields that cannot be multi-part (Reply-to:), remove
  374.  * the field header and any additional address. */
  375. {
  376.   char *ptr;
  377.   
  378.   /* The field for sure has a field header - skip it */
  379.   shiftleft (field, 2);
  380.   /* If the first char now is a space, skip that as well */
  381.   if (field[0] == ' ') {
  382.     shiftleft (field, 1);
  383.   }
  384.   /* If the field contains a comma, kill it and all that follows */
  385.   if ((ptr = strchr (field, ',')) != NULL) {
  386.     ptr[0] = '';
  387.   }
  388.   
  389.   return (field);
  390. }                                       /* clean_field () */
  391. /*========================================================*/
  392. int sub_tkize_field (rcpt_list *list, char *field, char *defdom)
  393. {
  394.   int nfields = 0;
  395.   char *s;
  396.   char *ptr;
  397.   char *newstring;
  398.   char *item;
  399.   
  400.   /*---------------------------------------Initialization */
  401.   /* take a local copy of "field" to avoid it being modified */
  402.   s = (char *) malloc ((strlen (field) + 1) * sizeof (char));
  403.   if (! s) {
  404.     syslog ((FACILITY | LOG_ERR), "can't malloc().");
  405.     unlink (MBOX_LOCKF);
  406.     syserr ("sms2mailgw: can't malloc()");
  407.   }
  408.   s[0] = '';
  409.   strcpy (s, field);
  410.   ptr = s;
  411.   
  412.   /* s for sure has a field header ("T:" for inst.) - skip it */
  413.   ptr += 2;
  414.   /* if there was a blank between the header and the field, skip it too */
  415.   if (ptr[0] == ' ') {
  416.     ptr++;
  417.   }
  418.   
  419.   /*---------------------------------Main processing loop */
  420.   if ((item = strtok (ptr, ",")) == NULL) {
  421.     /* field header w/o contents */
  422.     free (s);
  423.     return (nfields);
  424.   }
  425.   /* process first item */
  426.   newstring = expand_addr (item, defdom);
  427.   rcpt_list_insert (list, newstring);
  428.   nfields++;
  429.   free (newstring);
  430.   
  431.   /* now tokenize and process the rest */
  432.   while ((item = strtok (NULL, ",")) != NULL) {
  433.     /* process additional item(s) */
  434.     newstring = expand_addr (item, defdom);
  435.     rcpt_list_insert (list, newstring);
  436.     nfields++;
  437.     free (newstring);
  438.   }                                        /* while (...) */
  439.   /*------------------------------------------Conclusions */
  440.   free (s);
  441.   return (nfields);
  442. }                                   /* sub_tkize_field () */
  443. /*========================================================*/
  444. char *mkfromfield (char *srcgsm, char *host, char *defdom)
  445. {
  446.   char *fromfield;
  447.   
  448.   /*--------------------------------------Initializations */
  449.   fromfield = (char *) malloc ((BUFFSIZE + 1) * sizeof (char));
  450.   if (! fromfield) {
  451.     syslog ((FACILITY | LOG_ERR), "can't malloc().");
  452.     unlink (MBOX_LOCKF);
  453.     syserr ("sms2mailgw: can't malloc()");
  454.   }
  455.   fromfield[0] = '';
  456.   
  457.   /*-------------------------------------------Processing */
  458.   sprintf (fromfield, "%s%s@%s.%s", GWUSER, srcgsm, host, defdom);
  459.   
  460.   /*------------------------------------------Conclusions */
  461.   return (fromfield);
  462. }                                       /* mkfromfield () */
  463. /*========================================================*/
  464. void reset_mail_struct (struct email_msg *m)
  465. {
  466.   if (m->from) {
  467.     free (m->from);
  468.     m->from = NULL;
  469.   }
  470.   
  471.   if (!empty_rcpt_list (m->to))
  472.     free_rcpt_list (&(m->to));
  473.   if (!empty_rcpt_list (m->cc))
  474.     free_rcpt_list (&(m->cc));
  475.   if (!empty_rcpt_list (m->bcc))
  476.     free_rcpt_list (&(m->bcc));
  477.   
  478.   if (m->reply_to) {
  479.     free (m->reply_to);
  480.     m->reply_to = NULL;
  481.   }
  482.   if (m->subject) {
  483.     free (m->subject);
  484.     m->subject = NULL;
  485.   }
  486.   if (m->body) {
  487.     free (m->body);
  488.     m->body = NULL;
  489.   }
  490. }                                 /* reset_mail_struct () */
  491. /*========================================================*/
  492. int parse_smail (struct inbox_line *ibl, struct email_msg *m, char *host,
  493.                  char *domain)
  494. {
  495.   char *s;
  496.   char *s_saved;
  497.   char *ptr;
  498.   char *s_end;
  499.   int end_found;
  500.   char field_header;
  501.   char end_marker;
  502.   
  503.   /*--------------------------------------Initializations */
  504.   /* struct email fields */
  505.   m->from = NULL;
  506.   rcpt_list_init (&(m->to));
  507.   rcpt_list_init (&(m->cc));
  508.   rcpt_list_init (&(m->bcc));
  509.   m->reply_to = NULL;
  510.   m->subject = NULL;
  511.   m->body = NULL;
  512.   
  513.   /* copy sms string to scratch space - we can't modify it */
  514.   s = (char *) malloc ((MAXMSGLEN + 1) * sizeof (char));
  515.   if (! s) {
  516.     syslog ((FACILITY | LOG_ERR), "can't malloc().");
  517.     unlink (MBOX_LOCKF);
  518.     syserr ("sms2mailgw: can't malloc()");
  519.   }
  520.   s[0] = '';
  521.   strcpy (s, ibl->text);
  522.   s_saved = s;
  523. #ifdef INCL_DEBUG_CODE
  524.   fprintf (stderr, "ns as received:n[%s]n", s);
  525. #endif
  526.   
  527.   /*--------------------------------------Main Processing */
  528.   /* First field have to be To: */
  529.   if ((toupper (s[0]) == 'T') && (s[1] == ':')) {
  530.     /* if space between : and address, remove it */
  531.     if (s[2] == ' ') {
  532.       ptr = (s + 2);
  533.       shiftleft (ptr, 1);
  534.     }
  535.     end_found = FALSE;
  536.     ptr = s;
  537.     while (!end_found) {
  538.       if ((ptr = strchr (ptr, ' ')) == NULL) {
  539.         /* To: was the only field */
  540.         syslog ((FACILITY | LOG_ERR), "can't parse, nothing more than To: field.");
  541. free (s_saved);
  542. return (-1);
  543.       }
  544.       if ((ptr[-1] == ',') && (ptr[0] != '')) {
  545.         /* we have a multipart to: field */
  546. ptr++;
  547.       }
  548.       else {
  549.         end_found = TRUE;
  550. s_end = ptr;
  551.       }
  552.     }                               /* while (!end_found) */
  553.     if (ptr[0] != '') {
  554.       ptr++;
  555.     }
  556.     s_end[0] = '';
  557.     /* sub-tokenize it and save it */
  558. #ifdef INCL_DEBUG_CODE
  559.     fprintf (stderr, "to field: [%s]n", s);
  560. #endif
  561.     sub_tkize_field (&(m->to), s, domain);
  562.     
  563.     /* reset s to begin of next field */
  564.     s = ptr;
  565.     
  566.     /* now loop to process the rest */
  567.     while (s[0]) {
  568.       field_header = toupper (s[0]);
  569.       if ((strchr (FIELD_HEADERS, field_header) != NULL) && (s[1] == ':')) {
  570.         /* we have a valid header */
  571. switch (field_header) {
  572.   case 'T' : {
  573.     end_marker = ' ';
  574.     break;
  575.   }
  576.   
  577.   case 'C' : {
  578.     end_marker = ' ';
  579.     break;
  580.   }
  581.   
  582.   case 'R' : {
  583.     if (m->reply_to) {
  584.       free (m->reply_to);
  585.     }
  586.     end_marker = ' ';
  587.     break;
  588.   }
  589.   
  590.   case 'B' : {
  591.     end_marker = ' ';
  592.     break;
  593.   }
  594.   
  595.   case 'F' : {
  596.     if (m->from) {
  597.       free (m->from);
  598.     }
  599.     end_marker = ' ';
  600.     break;
  601.   }
  602.   
  603.   case 'S' : {
  604.     if (m->subject) {
  605.       free (m->subject);
  606.     }
  607.     end_marker = '#';
  608.     break;
  609.   }
  610. }                        /* switch (field_header) */
  611. /* if space between : and address, remove it */
  612. if (s[2] == ' ') {
  613.   ptr = (s + 2);
  614.   shiftleft (ptr, 1);
  615. }
  616. end_found = FALSE;
  617. ptr = s;
  618. while (!end_found) {
  619.   if ((ptr = strchr (ptr, end_marker)) == NULL) {
  620.     /* we reached end-of-string */
  621.     end_found = TRUE;
  622.     ptr = s + strlen (s);
  623.     s_end = ptr;
  624.   }
  625.   else {
  626.     if ((ptr[-1] == ',') && (ptr[0] != '')) {
  627.       /* multipart field */
  628.       ptr++;
  629.     }
  630.     else {
  631.       end_found = TRUE;
  632.       s_end = ptr;
  633.     }
  634.   }                  /* if (end_marker not found) */
  635. }                           /* while (!end_found) */
  636. if (ptr[0] != '') {
  637.   ptr++;
  638. }
  639. s_end[0] = '';
  640. /* assigns the right field */
  641. switch (field_header) {
  642.   case 'T' : {
  643. #ifdef INCL_DEBUG_CODE
  644.             fprintf (stderr, "field: [%s]n", s);
  645. #endif
  646.             sub_tkize_field (&(m->to), s, domain);
  647.     break;
  648.   }
  649.   
  650.   case 'C' : {
  651. #ifdef INCL_DEBUG_CODE
  652.             fprintf (stderr, "field: [%s]n", s);
  653. #endif
  654.             sub_tkize_field (&(m->cc), s, domain);
  655.     break;
  656.   }
  657.   
  658.   case 'R' : {
  659. #ifdef INCL_DEBUG_CODE
  660.             fprintf (stderr, "field: [%s]n", s);
  661. #endif
  662.             clean_field (s);
  663.     m->reply_to = expand_addr (s, domain);
  664.     break;
  665.   }
  666.   
  667.   case 'B' : {
  668. #ifdef INCL_DEBUG_CODE
  669.             fprintf (stderr, "field: [%s]n", s);
  670. #endif
  671.             sub_tkize_field (&(m->bcc), s, domain);
  672.     break;
  673.   }
  674.   
  675.   case 'F' : {
  676. #ifdef INCL_DEBUG_CODE
  677.             fprintf (stderr, "field: [%s]n", s);
  678. #endif
  679.             clean_field (s);
  680.             m->from = expand_addr (s, domain);
  681.     break;
  682.   }
  683.   
  684.   case 'S' : {
  685. #ifdef INCL_DEBUG_CODE
  686.             fprintf (stderr, "field: [%s]n", s);
  687. #endif
  688.     /* remove field header */
  689.     s += 2;
  690.     /* if ':' is followed by ' ', remove it as well */
  691.     if ((s[0]) && (s[0] == ' ')) {
  692.       s++;
  693.     }
  694.     m->subject = (char *) malloc ((strlen (s) + 1) * sizeof (char));
  695.     if (! m->subject) {
  696.       syslog ((FACILITY | LOG_ERR), "can't malloc().");
  697.               unlink (MBOX_LOCKF);
  698.       syserr ("sms2mailgw: can't malloc()");
  699.     }
  700.     m->subject[0] = '';
  701.     strcpy (m->subject, s);
  702.     break;
  703.   }
  704. }                        /* switch (field_header) */
  705. s = ptr;
  706.       }
  707.       else {
  708.         /* the rest is considered BODY */
  709. if (s[0]) {
  710. #ifdef INCL_DEBUG_CODE
  711.           fprintf (stderr, "body: [%s]n", s);
  712. #endif
  713.   m->body = (char *) malloc ((strlen (s) + 1) * sizeof (char));
  714.   if (! m->body) {
  715.     syslog ((FACILITY | LOG_ERR), "can't malloc().");
  716.             unlink (MBOX_LOCKF);
  717.     syserr ("sms2mailgw: can't malloc()");
  718.   }
  719.   m->body[0] = '';
  720.   strcpy (m->body, s);
  721.   ptr = s + strlen (s);
  722.   s = ptr;
  723. }                                    /* if (s[0]) */
  724.       }                        /* if (valid header found) */
  725.     }                                     /* while (s[0]) */
  726.   }
  727.   else {
  728.     /* can't even find To: field */
  729.     syslog ((FACILITY | LOG_ERR), "can't parse, can't find To: field.");
  730.     free (s_saved);
  731.     return (-1);
  732.   }                           /* if ('T' followed by ':') */
  733.   
  734.   /*--------------------------Make sure we have a subject */
  735.   if (! m->subject) {
  736.     m->subject = (char *) malloc ((MINIBUFF + 1) * sizeof (char));
  737.     if (! m->subject) {
  738.       syslog ((FACILITY | LOG_ERR), "can't malloc().");
  739.       unlink (MBOX_LOCKF);
  740.       syserr ("sms2mailgw: can't malloc()");
  741.     }
  742.     m->subject[0] = '';
  743.     sprintf (m->subject, "An SMS for you from GSM number %s.", ibl->fromgsm);
  744.   }
  745.   /*-------------------------------------------------Exit */
  746.   free (s_saved);
  747.   return 0;                                    /* success */
  748. }                                       /* parse_smail () */
  749. /*========================================================*/
  750. int slurp_n_catch (int fd, int resptime, char *catch)
  751. /* slurps n_lines lines from the input stream, and return a bool
  752. value telling whether catch was found in any of those lines. */
  753. {
  754.   int nread, retval, previous, found;
  755.   fd_set inputs;
  756.   struct timeval timeout;
  757.   char *buffer;
  758.   
  759.   /*--------------------------------------Initializations */
  760.   nread = previous = 0;
  761.   found = FALSE;
  762.   
  763.   FD_ZERO (&inputs);
  764.   FD_SET (fd, &inputs);
  765.   
  766.   timeout.tv_sec = 10;
  767.   timeout.tv_usec = 0;
  768.   
  769.   /* wait for data to arrive on the line */
  770.   retval = select (FD_SETSIZE, &inputs, NULL, NULL, &timeout);
  771.   switch (retval) {
  772.     case 0:
  773.       syslog ((FACILITY | LOG_WARNING), "timeout while waiting for server reply.");
  774.       break;
  775.     
  776.     case -1:
  777.       syslog ((FACILITY | LOG_ERR), "call to select() failed.");
  778.       unlink (MBOX_LOCKF);
  779.       syserr ("sms2mailgw: call to select() failed");
  780.       break;
  781.       
  782.     default:
  783.       if (FD_ISSET (fd, &inputs)) {
  784.         /* first wait for all data to be ready */
  785. ioctl (fd, FIONREAD, &nread);
  786. while (nread != previous) {
  787.   sleep (resptime);
  788.   previous = nread;
  789.   ioctl (fd, FIONREAD, &nread);
  790. }                    /* while (nread != previous) */
  791. /* we know what's the data size - alloc space for it */
  792. buffer = (char *) malloc ((nread + 1) * sizeof (char));
  793. if (!buffer) {
  794.           syslog ((FACILITY | LOG_ERR), "can't allocate buffer space.");
  795.           unlink (MBOX_LOCKF);
  796.   syserr ("sms2mailgw: can't allocate buffer space");
  797. }
  798. /* now we can finally read this data */
  799. nread = read (fd, buffer, nread);
  800. switch (nread) {
  801.   case 0:
  802.     /* EOF */
  803.     buffer[nread] = '';
  804.     syslog ((FACILITY | LOG_WARNING), "no data from server waiting for [%s].",
  805.             catch);
  806.     break;
  807.     
  808.   case -1:
  809.             syslog ((FACILITY | LOG_ERR), "error while reading answer from server.");
  810.             unlink (MBOX_LOCKF);
  811.     syserr ("sms2mailgw: error while reading answer from server");
  812.     break;
  813.     
  814.   default:
  815.     buffer[nread] = '';
  816. #ifdef INCL_DEBUG_CODE
  817.     fprintf (stderr, "pid<%d> Got : [%s] (%d char)n", getpid (), buffer, nread);
  818. #endif
  819.     /* here we could pre-process it (remove Ctrl-Z) */
  820.     /* look for catch */
  821.             found = (strstr (buffer, catch) != NULL);
  822.     break;
  823. }                               /* switch (nread) */
  824.       }                                /* if (FD_ISSET... */
  825.       free (buffer);
  826.       break;
  827.   }                                    /* switch (retval) */
  828.   /*------------------------------------------------------*/
  829. #ifdef INCL_DEBUG_CODE
  830.   fprintf (stderr, "catch found: [%s]n", found ? "yes" : "no");
  831. #endif
  832.   /*----------------------------------Conclusion and exit */
  833.   return (found);
  834. }                                     /* slurp_n_catch () */
  835. /*========================================================*/
  836. int send_mail (struct email_msg *m, struct inbox_line *ibl, char *mailhost,
  837.                char *localhost, char *defdom)
  838. {
  839.   struct servent *sent;
  840.   struct in_addr server_ip;
  841.   struct sockaddr_in sockaddr;
  842.   struct rcpt_item *cursor;
  843.   int sockfd;
  844.   int addrlen;
  845.   char *cmdline;
  846.   char *nd;
  848. #ifdef INCL_DEBUG_CODE
  849.   fprintf (stderr, "===========================================n");
  850.   if (m->from)
  851.     fprintf (stderr, "From: %sn", m->from);
  852.   if (!empty_rcpt_list (m->to)) {
  853.     fprintf (stderr, "To: recepientsn");
  854.     print_rcpt_list (m->to);
  855.   }
  856.   if (!empty_rcpt_list (m->cc)) {
  857.     fprintf (stderr, "CC: recepientsn");
  858.     print_rcpt_list (m->cc);
  859.   }
  860.   if (!empty_rcpt_list (m->bcc)) {
  861.     fprintf (stderr, "BCC: recepientsn");
  862.     print_rcpt_list (m->bcc);
  863.   }
  864.   if (m->reply_to)
  865.     fprintf (stderr, "Reply-To: %sn", m->reply_to);
  866.   if (m->subject)
  867.     fprintf (stderr, "Subject: %sn", m->subject);
  868.   if (m->body)
  869.     fprintf (stderr, "%sn", m->body);
  870.   fprintf (stderr, "===========================================n");
  871. #endif
  872.     
  873.   /*--------------------------------------Initializations */
  874.   cmdline = (char *) malloc ((BUFFSIZE + 1) * sizeof (char));
  875.   if (!cmdline) {    
  876.     syslog ((FACILITY | LOG_ERR), "can't malloc().");
  877.     unlink (MBOX_LOCKF);
  878.     syserr ("sms2mailgw: can't malloc()");
  879.   }
  880.   cmdline[0] = '';
  882.   /* first resolve server name */
  883.   server_ip.s_addr = resolve (mailhost);
  884.   
  885.   /* get the port number we should connect to */
  886.   if ((sent = getservbyname ("smtp", "tcp")) == NULL) {
  887.     syslog ((FACILITY | LOG_ERR), "can't get service port info.");
  888.     unlink (MBOX_LOCKF);
  889.     syserr ("sms2mailgw: can't get service port info");
  890.   }
  891. #ifdef INCL_DEBUG_CODE
  892.   fprintf (stderr, "found port <%d> for service smtpn", ntohs (sent->s_port));
  893. #endif
  894.     
  895.   /* create the socket */
  896.   if ((sockfd = socket (AF_INET, SOCK_STREAM, 0)) == -1) {
  897.     syslog ((FACILITY | LOG_ERR), "can't create socket.");
  898.     unlink (MBOX_LOCKF);
  899.     syserr ("sms2mailgw: can't create socket");
  900.   }
  901.   
  902.   /* build the server socket address parameters */
  903.   sockaddr.sin_family = AF_INET;
  904.   sockaddr.sin_port = sent->s_port;
  905.   sockaddr.sin_addr.s_addr = server_ip.s_addr;
  906.   addrlen = sizeof (sockaddr);
  907.   
  908.   /* now connect to the server */
  909.   if (connect (sockfd, (struct sockaddr *)&sockaddr, addrlen) == -1) {
  910.     syslog ((FACILITY | LOG_ERR), "can't connect to server.");
  911.     unlink (MBOX_LOCKF);
  912.     syserr ("sms2mailgw: can't connect to server");
  913.   }
  914.     
  915.   /*......................................Start of dialog */
  916.   /* slurp server announce and catch prompt */
  917.   if (!slurp_n_catch (sockfd, 1, "220")) {
  918.     syslog ((FACILITY | LOG_ERR), "can't get server announce.");
  919.     unlink (MBOX_LOCKF);
  920.     syserr ("sms2mailgw: can't get server announce");
  921.   }
  922.     
  923.   /* set sender ID - get ok */
  924.   sprintf (cmdline, "HELO %s.%sn", localhost, defdom);
  925.   tellsock (sockfd, cmdline);
  927.   if (!slurp_n_catch (sockfd, 1, "250")) {
  928.     syslog ((FACILITY | LOG_ERR), "failed on HELO command.");
  929.     unlink (MBOX_LOCKF);
  930.     syserr ("sms2mailgw: failed on HELO command");
  931.   }
  932.     
  933.   /* send from: field */
  934.   sprintf (cmdline, "MAIL FROM: %sn", m->from);
  935.   tellsock (sockfd, cmdline);
  937.   if (!slurp_n_catch (sockfd, 1, "250")) {
  938.     syslog ((FACILITY | LOG_ERR), "failed on MAIL command.");
  939.     unlink (MBOX_LOCKF);
  940.     syserr ("sms2mailgw: failed on MAIL command");
  941.   }
  942.   
  943.   /*. . . . . . . . . . . . . Loop through all recepients */
  944.   /* To: field */
  945.   if (!empty_rcpt_list (m->to)) {
  946.     cursor = m->to.head;
  947.     sprintf (cmdline, "RCPT TO: %sn", cursor->rcpt);
  948.     tellsock (sockfd, cmdline);
  950.     if (!slurp_n_catch (sockfd, 1, "250")) {
  951.       syslog ((FACILITY | LOG_ERR), "failed on RCPT command.");
  952.       unlink (MBOX_LOCKF);
  953.       syserr ("sms2mailgw: failed on RCPT command");
  954.     }
  955.     while ((cursor = cursor->next) != NULL) {
  956.       sprintf (cmdline, "RCPT TO: %sn", cursor->rcpt);
  957.       tellsock (sockfd, cmdline);
  959.       if (!slurp_n_catch (sockfd, 1, "250")) {
  960. syslog ((FACILITY | LOG_ERR), "failed on RCPT command.");
  961. unlink (MBOX_LOCKF);
  962. syserr ("sms2mailgw: failed on RCPT command");
  963.       }
  964.     }                                      /* while (...) */
  965.   }                             /* if (not empty to-list) */
  966.   
  967.   /* CC: field */
  968.   if (!empty_rcpt_list (m->cc)) {
  969.     cursor = m->cc.head;
  970.     sprintf (cmdline, "RCPT TO: %sn", cursor->rcpt);
  971.     tellsock (sockfd, cmdline);
  973.     if (!slurp_n_catch (sockfd, 1, "250")) {
  974.       syslog ((FACILITY | LOG_ERR), "failed on RCPT command.");
  975.       unlink (MBOX_LOCKF);
  976.       syserr ("sms2mailgw: failed on RCPT command");
  977.     }
  978.     while ((cursor = cursor->next) != NULL) {
  979.       sprintf (cmdline, "RCPT TO: %sn", cursor->rcpt);
  980.       tellsock (sockfd, cmdline);
  982.       if (!slurp_n_catch (sockfd, 1, "250")) {
  983. syslog ((FACILITY | LOG_ERR), "failed on RCPT command.");
  984. unlink (MBOX_LOCKF);
  985. syserr ("sms2mailgw: failed on RCPT command");
  986.       }
  987.     }                                      /* while (...) */
  988.   }                             /* if (not empty cc-list) */
  990.   /* BCC: field */
  991.   if (!empty_rcpt_list (m->bcc)) {
  992.     cursor = m->bcc.head;
  993.     sprintf (cmdline, "RCPT TO: %sn", cursor->rcpt);
  994.     tellsock (sockfd, cmdline);
  996.     if (!slurp_n_catch (sockfd, 1, "250")) {
  997.       syslog ((FACILITY | LOG_ERR), "failed on RCPT command.");
  998.       unlink (MBOX_LOCKF);
  999.       syserr ("sms2mailgw: failed on RCPT command");
  1000.     }
  1001.     while ((cursor = cursor->next) != NULL) {
  1002.       sprintf (cmdline, "RCPT TO: %sn", cursor->rcpt);
  1003.       tellsock (sockfd, cmdline);
  1005.       if (!slurp_n_catch (sockfd, 1, "250")) {
  1006. syslog ((FACILITY | LOG_ERR), "failed on RCPT command.");
  1007. unlink (MBOX_LOCKF);
  1008. syserr ("sms2mailgw: failed on RCPT command");
  1009.       }
  1010.     }                                      /* while (...) */
  1011.   }                            /* if (not empty bcc-list) */
  1013.   /*. . . . . . . . . . . . . . . . . . . . . . . . . . . */
  1015.   /* now send mail data */
  1016.   sprintf (cmdline, "DATAn");
  1017.   tellsock (sockfd, cmdline);
  1019.   if (!slurp_n_catch (sockfd, 1, "354")) {
  1020.     syslog ((FACILITY | LOG_ERR), "failed on DATA command.");
  1021.     unlink (MBOX_LOCKF);
  1022.     syserr ("sms2mailgw: failed on DATA command");
  1023.   }
  1024.   
  1025.   /* From: field as "comment" */
  1026.   if (m->from) {
  1027.     sprintf (cmdline, "From: %sn", m->from);
  1028.     tellsock (sockfd, cmdline);
  1029.   }
  1030.   /* To: field as "comment" */
  1031.   if (!empty_rcpt_list (m->to)) {
  1032.     cursor = m->to.head;
  1033.     sprintf (cmdline, "To: %s", cursor->rcpt);
  1035.     while ((cursor = cursor->next) != NULL) {
  1036.       strcat (cmdline, ", ");
  1037.       strcat (cmdline, cursor->rcpt);
  1038.     }                                      /* while (...) */
  1040.     strcat (cmdline, "n");
  1041.     tellsock (sockfd, cmdline);
  1042.   }                             /* if (not empty to-list) */
  1043.   /* CC: field as "comment" */
  1044.   if (!empty_rcpt_list (m->cc)) {
  1045.     cursor = m->cc.head;
  1046.     sprintf (cmdline, "Cc: %s", cursor->rcpt);
  1048.     while ((cursor = cursor->next) != NULL) {
  1049.       strcat (cmdline, ", ");
  1050.       strcat (cmdline, cursor->rcpt);
  1051.     }                                      /* while (...) */
  1053.     strcat (cmdline, "n");
  1054.     tellsock (sockfd, cmdline);
  1055.   }                             /* if (not empty to-list) */
  1056.   /* BCC: field as "comment" */
  1057.   if (!empty_rcpt_list (m->bcc)) {
  1058.     cursor = m->bcc.head;
  1059.     sprintf (cmdline, "Bcc: %s", cursor->rcpt);
  1061.     while ((cursor = cursor->next) != NULL) {
  1062.       strcat (cmdline, ", ");
  1063.       strcat (cmdline, cursor->rcpt);
  1064.     }                                      /* while (...) */
  1066.     strcat (cmdline, "n");
  1067.     tellsock (sockfd, cmdline);
  1068.   }                             /* if (not empty to-list) */
  1069.   /* Reply-to: field */
  1070.   if (m->reply_to) {
  1071.     sprintf (cmdline, "Reply-to: %sn", m->reply_to);
  1072.     tellsock (sockfd, cmdline);
  1073.   }
  1074.   /* Subject: field */
  1075.   if (m->subject) {
  1076.     sprintf (cmdline, "Subject: %sn", m->subject);
  1077.     tellsock (sockfd, cmdline);
  1078.   }
  1079.   /* Message Body */
  1080.   if (m->body) {
  1081.     sprintf (cmdline, "%sn", m->body);
  1082.     tellsock (sockfd, cmdline);
  1083.   }
  1084.   
  1085.   /* add some system info */
  1086.   sprintf (cmdline, "n=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-n");
  1087.   tellsock (sockfd, cmdline);
  1088.   sprintf (cmdline, "This mail has been relayed to you by SMSLink's sms2mailgwn");
  1089.   tellsock (sockfd, cmdline);
  1090.   sprintf (cmdline, "ver. %s (%s) running on %s.%s.n", SMS_GW_VERSION,
  1091.            SMS_GW_DATE, localhost, defdom);
  1092.   tellsock (sockfd, cmdline);
  1093.   nd = nicedate (ibl->date);
  1094.   sprintf (cmdline, "The original message was received on %s at %sn",
  1095.            nd, ibl->time);
  1096.   tellsock (sockfd, cmdline);
  1097.   sprintf (cmdline, "from the GSM number [%s] through device [%s].n", ibl->fromgsm,
  1098.            ibl->device);
  1099.   tellsock (sockfd, cmdline);
  1100.   sprintf (cmdline, "The message ID was [%d].n", ibl->msgid);
  1101.   tellsock (sockfd, cmdline);
  1102.   
  1103.   /* now close the DATA section: one dot only */
  1104.   sprintf (cmdline, ".n");
  1105.   tellsock (sockfd, cmdline);
  1107.   if (!slurp_n_catch (sockfd, 1, "250")) {
  1108.     syslog ((FACILITY | LOG_ERR), "failed on DATA transfer.");
  1109.     unlink (MBOX_LOCKF);
  1110.     syserr ("sms2mailgw: failed on DATA transfer");
  1111.   }
  1112.   
  1113.   /* send the QUIT command */
  1114.   sprintf (cmdline, "QUITn");
  1115.   tellsock (sockfd, cmdline);
  1117.   if (!slurp_n_catch (sockfd, 1, "221")) {
  1118.     syslog ((FACILITY | LOG_ERR), "failed on QUIT command.");
  1119.     unlink (MBOX_LOCKF);
  1120.     syserr ("sms2mailgw: failed on QUIT command");
  1121.   }
  1122.   
  1123.   /*------------------------------------------Conclusions */
  1124.   /* close socket */
  1125.   if (close (sockfd) == -1) {
  1126.     syslog ((FACILITY | LOG_ERR), "can't close socket.");
  1127.     unlink (MBOX_LOCKF);
  1128.     syserr ("sms2mailgw: can't close socket");
  1129.   }
  1130.   
  1131.   /* free what's need to be */
  1132.   free (nd);
  1133.   
  1134.   /* leave */
  1135.   return (0);
  1136. }                                         /* send_mail () */
  1137. /*========================================================*/
  1138. int mailbox_run (char *localhost, char *defaultdomain)
  1139. {
  1140.   struct email_msg email;
  1141.   struct inbox_line tkline;            /* tokenized line */
  1142.   char *line;                                /* raw line */
  1143.   char *buffline;                       /* transfer line */
  1144.   FILE *inbox;
  1145.   FILE *newbox;
  1146.   int anymailfound = FALSE;
  1147.   int filecreatedyet = FALSE;
  1148.   int msg_count = 0;
  1149.   int lineismail;
  1150.   int lcursor;
  1151.   int nline = 0;
  1152.   char *cmd;
  1153.   char *newboxname;
  1154.   
  1155.   /*---------------------------------Initialize variables */
  1156.   line = (char *) malloc ((BIGBUFF + 1) * sizeof (char));
  1157.   if (! line) {
  1158.     syslog ((FACILITY | LOG_ERR), "can't malloc().");
  1159.     unlink (MBOX_LOCKF);
  1160.     syserr ("sms2mailgw: can't malloc()");
  1161.   }
  1162.   line[0] = '';
  1163.   buffline = (char *) malloc ((BIGBUFF + 1) * sizeof (char));
  1164.   if (! buffline) {
  1165.     syslog ((FACILITY | LOG_ERR), "can't malloc().");
  1166.     unlink (MBOX_LOCKF);
  1167.     syserr ("sms2mailgw: can't malloc()");
  1168.   }
  1169.   buffline[0] = '';
  1170.   cmd = (char *) malloc ((BUFFSIZE + 1) * sizeof (char));
  1171.   if (! cmd) {
  1172.     syslog ((FACILITY | LOG_ERR), "can't malloc().");
  1173.     unlink (MBOX_LOCKF);
  1174.     syserr ("sms2mailgw: can't malloc()");
  1175.   }
  1176.   cmd[0] = '';
  1177.   newboxname = (char *) malloc ((PATH_MAX + 1) * sizeof (char));
  1178.   if (! newboxname) {
  1179.     syslog ((FACILITY | LOG_ERR), "can't malloc().");
  1180.     unlink (MBOX_LOCKF);
  1181.     syserr ("sms2mailgw: can't malloc()");
  1182.   }
  1183.   newboxname[0] = '';
  1184.   sprintf (newboxname, "%s.tmp.%d", MBOX_FILE, getpid());
  1185.   /*--------------------------------------------Open file */
  1186.   if ((inbox = fopen (MBOX_FILE, "r")) == NULL) {
  1187.     syslog ((FACILITY | LOG_ERR), "can't fopen() inbox file.");
  1188.     unlink (MBOX_LOCKF);
  1189.     syserr ("sms2mailgw: can't fopen() inbox file");
  1190.   }
  1191.   /*----------------------Read file and process each line */
  1192.   while (fgets (line, BIGBUFF, inbox) != NULL) {
  1193.     nline++;
  1194.     /* tokenize line to fill a struct inbox_line */
  1195.     if (tkize_ibox_line (line, &tkline) == -1) {
  1196.       syslog ((FACILITY | LOG_ERR), "inbox corruption - can't parse line %d.", nline);
  1197.       unlink (MBOX_LOCKF);
  1198.       syserr ("sms2mailgw: inbox corruption - can't parse line");
  1199.     }
  1200.     
  1201.     /* is it a mail message ? */
  1202.     if ((toupper (tkline.text[0]) == 'T') && (tkline.text[1] == ':')) {
  1203.       if (parse_smail (&tkline, &email, localhost, defaultdomain) == -1) {
  1204.         /* reject line after all */
  1205. lineismail = FALSE;
  1206. /* log it */
  1207.         syslog ((FACILITY | LOG_NOTICE), "inbox line #%d don't comply with protocol.",
  1208.        nline);
  1209.       }
  1210.       else {
  1211.         lineismail = TRUE;
  1212.         anymailfound = TRUE;
  1213. if (!email.from) {
  1214.   email.from = mkfromfield (tkline.fromgsm, localhost, defaultdomain);
  1215. }
  1216.         send_mail (&email, &tkline, MAILHOST, localhost, defaultdomain);
  1217. reset_mail_struct (&email);
  1218.         msg_count++;
  1219.       }
  1220.     }
  1221.     else {
  1222.       lineismail = FALSE;
  1223.     }                              /* if (it is an email) */
  1224.     if (anymailfound) {
  1225.       if (!filecreatedyet) {
  1226.         /* open new inbox file */
  1227. if ((newbox = fopen (newboxname, "w")) == NULL) {
  1228.   syslog ((FACILITY | LOG_ERR), "can't fopen() temp inbox file.");
  1229.           unlink (MBOX_LOCKF);
  1230.   syserr ("sms2mailgw: can't fopen() temp inbox file");
  1231. }
  1232.         filecreatedyet = TRUE;
  1233. /* transfer up to current line - current not included */
  1234.         lcursor = 1;
  1235.         /* "rewind" input file */
  1236.         if (fseek (inbox, (long) 0, SEEK_SET) == -1) {
  1237.   syslog ((FACILITY | LOG_ERR), "can't fseek() on inbox file.");
  1238.           unlink (MBOX_LOCKF);
  1239.   syserr ("sms2mailgw: can't fseek() on inbox file");
  1240.         }
  1241.         while (lcursor < nline) {
  1242.           if (fgets (buffline, BIGBUFF, inbox) == NULL) {
  1243.     syslog ((FACILITY | LOG_ERR), "can't read from inbox file.");
  1244.             unlink (MBOX_LOCKF);
  1245.     syserr ("sms2mailgw: can't read from inbox file");
  1246.           }
  1247.           if (fputs (buffline, newbox) == EOF) {
  1248.     syslog ((FACILITY | LOG_ERR), "can't write to new inbox file.");
  1249.             unlink (MBOX_LOCKF);
  1250.     syserr ("sms2mailgw: can't write to new inbox file");
  1251.           }
  1252.           lcursor++;
  1253.         }                      /* while (lcursor < nline) */
  1254.         /* re-read line #nline to skip it */
  1255.         if (fgets (buffline, BIGBUFF, inbox) == NULL) {
  1256.   syslog ((FACILITY | LOG_ERR), "can't read from inbox file.");
  1257.           unlink (MBOX_LOCKF);
  1258.   syserr ("sms2mailgw: can't read from inbox file");
  1259.         }
  1260.       }                            /* if (msg_count == 1) */
  1261.       if (! lineismail) {
  1262.         /* transfer current line to new file */
  1263.         if (fputs (line, newbox) == EOF) {
  1264.   syslog ((FACILITY | LOG_ERR), "can't write to new inbox file.");
  1265.           unlink (MBOX_LOCKF);
  1266.   syserr ("sms2mailgw: can't write to new inbox file");
  1267.         }
  1268.       }                              /* if (! lineismail) */
  1269.     }                                /* if (anymailfound) */
  1270.   }                                    /* while (fgets... */
  1271.   /*------------------------------Close file and conclude */
  1272.   fclose (inbox);
  1273.   if (anymailfound) {
  1274.     fclose (newbox);
  1275.     /* now mv newbox inbox */
  1276.     sprintf (cmd, "mv %s %s", newboxname, MBOX_FILE);
  1277.     if (system (cmd) != 0) {
  1278.       syslog ((FACILITY | LOG_ERR), "can't move new inbox file - system() failed.");
  1279.       unlink (MBOX_LOCKF);
  1280.       syserr ("sms2mailgw: can't move new inbox file - system() failed");
  1281.     }
  1282.   }
  1283.   
  1284.   /* free what's needs to be */
  1285.   free (line);
  1286.   free (buffline);
  1287.   free (cmd);
  1288.   free (newboxname);
  1289.   
  1290.   return (msg_count);
  1291. }                                       /* mailbox_run () */
  1292. /*==========================================================
  1293.  * EOF : gw_stuff.c
  1294.  *===================*/