sendsms.c

手机短消息的服务器端和客户端的源代码 是应用于LINUX/UNIX开发环境的

/*==========================================================
 * Program : sendsms.c                     Project : smslink
 * Author  : Philippe Andersson.
 * Date    : 01/03/00
 * Version : 0.10b
 * Notice  : (c) Les Ateliers du Heron, 1998 for Scitex Europe, S.A.
 * Comment : SMS client.
 *
 * Modification History :
 * - 0.01a (28/09/98) : Initial release.
 * - 0.02a (21/10/98) : Adapted client to modifications in server
 *   consecutive to full GSM dialog implementation.
 * ++++ Switch to Beta ++++
 * - 0.03b (21/10/98) : First Beta release.
 * - 0.04b (23/10/98) : Added handling of the 'user' parameter.
 * - 0.05b (28/10/98) : Improved error reporting regarding
 *   host name resolution failure.
 * - 0.06b (03/11/98) : Added -f parameter (load message from
 *   a text file).
 * - 0.07b (06/02/99) : Added "-f -" option for stdin processing.
 *   Added Solaris compatibility. (contrib. by Philipp Klaus).
 * - 0.08b (16/02/99) : Adapted "slurping" of server announce
 *   after Ph. Klaus' modifications. Also solved a problem
 *   in the HP-UX port (PATH_MAX needs limits.h on HP-UX).
 * - 0.09b (20/05/99) : Corrected a bug that prevented comp-
 *   ilation on LINUX_LC6 platform.
 * - 0.10b (01/03/00) : Replaced the "old" slurp_n_catch() by
 *   a new version copied on get_gsm_answer(). This one should
 *   be more robust and less sensitive to the amount of data
 *   sent back by the server.
 *========================================================*/

#include <stdio.h>
#include <stdlib.h>
#include <string.h>               /* for strcpy & friends */
#ifdef HPUX
#  include <sys/unistd.h>                /* for getopt () */
#  include <limits.h>                     /* for PATH_MAX */
#else
#  include <unistd.h>                    /* for getopt () */
#  ifdef LINUX_LC6
#    include <limits.h>
#    include <linux/limits.h>
#  endif
#endif                                      /* ifdef HPUX */
#include <netdb.h>                 /* for gethostbyname() */
#include <pwd.h>                        /* for getpwuid() */
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/types.h>
#include <sys/time.h>           /* for the struct timeval */
#include <sys/ioctl.h>            /* for the ioctl() call */
#ifdef SOLARIS
#  include <sys/filio.h>
#endif

/*--------------------------------------Personal includes */
#include "sendsms.h"

/*========================================================*/
/**********             LOCAL DEFINES              ********/
/*========================================================*/

/* For debugging purposes only - comment out for normal compile */
/* #define INCL_DEBUG_CODE */

/*========================================================*/
/**********           GLOBAL VARIABLES             ********/
/*========================================================*/

/*========================================================*/
/**********               FUNCTIONS                ********/
/*========================================================*/
void syserr (char *msg)
{
  extern int errno, sys_nerr;
#ifdef LINUX_LC6
  extern const char *const sys_errlist[];
#else
  extern char * sys_errlist[];
#endif                                /* #ifdef LINUX_LC6 */

  fprintf (stderr, "ERROR %s", msg);
  if (errno > 0 && errno < sys_nerr)
    fprintf (stderr, " (%d ; %s)\n", errno, sys_errlist[errno]);
  else
    fprintf (stderr, "\n");
  exit (1);
}                                            /* syserr () */
/*========================================================*/
void tellsock (int sock, char *string)
{
  int length;
  
  length = strlen (string);
  if (write (sock, string, length) != length)
    syserr ("sendsms: error while writing to socket");

}                                          /* tellsock () */
/*========================================================*/
void quote (char *string)
/* we take it for granted that we malloc'ed at least 2 char more
than max length */
{
  char *ptr;
  
  ptr = string + strlen (string);
  /* shift all chars 1 place to the right */
  while (ptr >= string) {
    ptr [1] = ptr[0];
    ptr--;
  }
  string[0] = '"';
  ptr = string + strlen (string);
  ptr[1] = '\0';
  ptr[0] = '"';
}                                             /* quote () */
/*========================================================*/
int desLF (char *string)
{
  char *ptr;
  
  if ((ptr = strchr (string, '\n')) != NULL) {
    ptr[0] = ' ';
  }
  
  return (strlen (string));
}                                             /* desLF () */
/*========================================================*/
int is_dotted_quad (char *string)
{
  int is_dq;
  char *s;
  int ntok = 0;
  char *ptok = NULL;
  long int ip_byte;
  char **endptr;
  char *dummyp;
  
  /*--------------------------------------Initializations */
  s = (char *) malloc ((strlen (string) + 1) * sizeof (char));
  strcpy (s, string);
  /*--------------------------------------------Main Loop */
  /* no point going any further if the 1st char. is not a digit */
  is_dq = isdigit (string[0]);
  if (is_dq) {
    ptok = strtok (s, ".");
    while (ptok != NULL) {
      ntok++;
#ifdef INCL_DEBUG_CODE
      printf ("got token #%d : <%s>\n", ntok, ptok);
#endif
      dummyp = ptok + strlen (ptok);
      endptr = &dummyp;
      ip_byte = strtol (ptok, endptr, 10);
      if (strlen (*endptr) != 0) {
#ifdef INCL_DEBUG_CODE
	printf ("error on token #%d : can't convert <%s>\n", ntok, *endptr);
#endif
	is_dq = FALSE;
      }
      ptok = strtok (NULL, ".");
    }
    if (ntok != 4) {
      is_dq = FALSE;
    }
  }                                         /* if (is_dq) */
  /*------------------------------------------Conclusions */
  free (s);
  /*-------------------------------------------------Exit */
  return (is_dq);
}                                    /* is_dotted_quad () */
/*========================================================*/
unsigned long int resolve (char *host)
/* return the host ip address in network format */
{
  struct hostent *h_ent;
  struct in_addr target_ip;
  char **addrs;
  char *scratch;
  
  if (is_dotted_quad (host)) {
#ifdef INCL_DEBUG_CODE
    printf ("I think I got an IP address\n");
#endif
    if (inet_aton (host, &target_ip) == 0)
      syserr ("sendsms: invalid server IP address");
  }
  else {
#ifdef INCL_DEBUG_CODE
    printf ("I think I got a host name\n");
#endif
    if ((h_ent = gethostbyname (host)) == NULL) {
      scratch = (char *) malloc ((MINIBUFF + 1) * sizeof (char));
      sprintf (scratch, "sendsms: can't resolve hostname (%s)", host);
      herror (scratch);
      free (scratch);
      exit (1);
    }
    /* lines below cf. "Beginning Linux Progr.", pp. 468-473 */
    addrs = h_ent->h_addr_list;
    target_ip = *(struct in_addr *)*addrs;
#ifdef INCL_DEBUG_CODE
    printf ("server IP address is: [%s]\n", inet_ntoa (target_ip));
#endif
  }                             /* if (isdigit (host[0])) */
  return (target_ip.s_addr);
}                                           /* resolve () */
/*========================================================*/
int load_from_file (char *msg, char *file)
{
  FILE *infile;
  char *buff;
  
  /*--------------------------------------Initializations */
  buff = (char *) malloc ((BUFFSIZE + 1) * sizeof (char));
  if (!buff)
    syserr ("sendsms: can't malloc");
  msg[0] = '\0';
  
  /*------------------------------------------------------*/
  /* open file */
  if (file[0] == '-' && file[1] == '\0') {
    infile = stdin;
  } else {
    if ((infile = fopen (file, "r")) == NULL)
      syserr ("sendsms: can't open input file");
  }
  
  /* read from file */
  while (fgets (buff, BUFFSIZE, infile)) {
    desLF (buff);
    if ((strlen (msg) + strlen (buff)) > MAXMSGLEN) {
      strncat (msg, buff, (MAXMSGLEN - strlen (msg)));
      fprintf (stderr, "Warning: input file too long - truncation will occur\n");
    }
    else {
      strcat (msg, buff);
    }
  }                                           /* while () */
  
  /* close file */
  if (infile != stdin)
    fclose (infile);
  
  /*------------------------------------------------------*/
  return (strlen (msg));
}                                    /* load_from_file () */
/*========================================================*/
int slurp_n_catch (int fd, int resptime, char *catch)
{
  int nread, retval, previous, found;
  fd_set inputs;
  struct timeval timeout;
  char *buffer;
  
  /*--------------------------------------Initializations */
  nread = previous = 0;
  found = FALSE;
  
  FD_ZERO (&inputs);
  FD_SET (fd, &inputs);
  
  timeout.tv_sec = 10;
  timeout.tv_usec = 0;
  
  /* wait for data to arrive on the line */
  retval = select (FD_SETSIZE, &inputs, NULL, NULL, &timeout);
  switch (retval) {
    case 0:
      fprintf (stderr, "sendsms: WARNING: timeout while waiting for server reply.");
      break;
    
    case -1:
      syserr ("sendsms: call to select() failed");
      break;
      
    default:
      if (FD_ISSET (fd, &inputs)) {
        /* first wait for all data to be ready */
	ioctl (fd, FIONREAD, &nread);
	while (nread != previous) {
	  sleep (resptime);
	  previous = nread;
	  ioctl (fd, FIONREAD, &nread);
	}                    /* while (nread != previous) */
	/* we know what's the data size - alloc space for it */
	buffer = (char *) malloc ((nread + 1) * sizeof (char));
	if (!buffer)
	  syserr ("sendsms: can't allocate buffer space");
	/* now we can finally read this data */
	nread = read (fd, buffer, nread);
	switch (nread) {
	  case 0:
	    /* EOF */
	    buffer[nread] = '\0';
	    fprintf (stderr, "sendsms: no data from server waiting for [%s].",
	             catch);
	    break;
	    
	  case -1:
	    syserr ("sendsms: error while reading answer from server");
	    break;
	    
	  default:
	    buffer[nread] = '\0';
#ifdef INCL_DEBUG_CODE
	    fprintf (stderr, "pid<%d> Got : [%s] (%d char)\n", getpid (), buffer,
	             nread);
#endif
	    /* here we could pre-process it (remove Ctrl-Z) */
	    /* look for catch */
            found = (strstr (buffer, catch) != NULL);
	    break;
	}                               /* switch (nread) */
      }                                /* if (FD_ISSET... */
      free (buffer);
      break;
  }                                    /* switch (retval) */
  /*------------------------------------------------------*/
#ifdef INCL_DEBUG_CODE
  printf ("catch found: [%s]\n", found ? "yes" : "no");
#endif
  /*----------------------------------Conclusion and exit */
  return (found);
}                                     /* slurp_n_catch () */
/*========================================================*/
int get_gsm_answer (int fd, char *answer, int size, int resptime)
{
  int nread, retval, previous;
  fd_set inputs;
  struct timeval timeout;
  char *buffer;
  
  /*--------------------------------------Initializations */
  nread = previous = 0;
  
  FD_ZERO (&inputs);
  FD_SET (fd, &inputs);
  
  timeout.tv_sec = 10;
  timeout.tv_usec = 0;
  
  /* wait for data to arrive on the line */
  retval = select (FD_SETSIZE, &inputs, NULL, NULL, &timeout);
  switch (retval) {
    case 0:
      fprintf (stderr, "timeout while waiting for GSM answer.\n");
      break;