citadel/citmail.c

   1 /*
   2  * $Id$
   3  *
   4  * This program attempts to act like a local MDA if you're using sendmail or
   5  * some other non-Citadel MTA.  It basically just contacts the Citadel SMTP
   6  * listener on a unix domain socket and transmits the message.
   7  *
   8  */
   9
  10 #include "sysdep.h"
  11 #include <stdlib.h>
  12 #include <unistd.h>
  13 #include <ctype.h>
  14 #include <stdio.h>
  15 #include <signal.h>
  16 #include <sys/types.h>
  17 #include <sys/socket.h>
  18 #include <sys/un.h>
  19 #include <netdb.h>
  20 #include <string.h>
  21 #include <pwd.h>
  22 #include <errno.h>
  23 #include <stdarg.h>
  24 #include <limits.h>
  25 #include "citadel.h"
  26 #ifndef HAVE_SNPRINTF
  27 #include "snprintf.h"
  28 #endif
  29 #include "config.h"
  30
  31 /* #define DEBUG  */    /* uncomment to get protocol traces */
  32
  33 int serv_sock;
  34
  35
  36 void strip_trailing_nonprint(char *buf)
  37 {
  38         while ( (strlen(buf)>0) && (!isprint(buf[strlen(buf) - 1])) )
  39                 buf[strlen(buf) - 1] = 0;
  40 }
  41
  42
  43 void timeout(int signum)
  44 {
  45         exit(signum);
  46 }
  47
  48
  49 int uds_connectsock(char *sockpath)
  50 {
  51         int s;
  52         struct sockaddr_un addr;
  53
  54         memset(&addr, 0, sizeof(addr));
  55         addr.sun_family = AF_UNIX;
  56         strncpy(addr.sun_path, sockpath, sizeof addr.sun_path);
  57
  58         s = socket(AF_UNIX, SOCK_STREAM, 0);
  59         if (s < 0) {
  60                 fprintf(stderr, "Can't create socket: %s\n",
  61                         strerror(errno));
  62                 exit(3);
  63         }
  64
  65         if (connect(s, (struct sockaddr *) &addr, sizeof(addr)) < 0) {
  66                 fprintf(stderr, "can't connect: %s\n",
  67                         strerror(errno));
  68                 exit(3);
  69         }
  70
  71         return s;
  72 }
  73
  74
  75 /*
  76  * input binary data from socket
  77  */
  78 void serv_read(char *buf, int bytes)
  79 {
  80         int len, rlen;
  81
  82         len = 0;
  83         while (len < bytes) {
  84                 rlen = read(serv_sock, &buf[len], bytes - len);
  85                 if (rlen < 1) {
  86                         return;
  87                 }
  88                 len = len + rlen;
  89         }
  90 }
  91
  92
  93 /*
  94  * send binary to server
  95  */
  96 void serv_write(char *buf, int nbytes)
  97 {
  98         int bytes_written = 0;
  99         int retval;
 100         while (bytes_written < nbytes) {
 101                 retval = write(serv_sock, &buf[bytes_written],
 102                                nbytes - bytes_written);
 103                 if (retval < 1) {
 104                         return;
 105                 }
 106                 bytes_written = bytes_written + retval;
 107         }
 108 }
 109
 110
 111
 112 /*
 113  * input string from socket - implemented in terms of serv_read()
 114  */
 115 void serv_gets(char *buf)
 116 {
 117         int i;
 118
 119         /* Read one character at a time.
 120          */
 121         for (i = 0;; i++) {
 122                 serv_read(&buf[i], 1);
 123                 if (buf[i] == '\n' || i == (SIZ-1))
 124                         break;
 125         }
 126
 127         /* If we got a long line, discard characters until the newline.
 128          */
 129         if (i == (SIZ-1))
 130                 while (buf[i] != '\n')
 131                         serv_read(&buf[i], 1);
 132
 133         /* Strip all trailing nonprintables (crlf)
 134          */
 135         buf[i] = 0;
 136         strip_trailing_nonprint(buf);
 137 #ifdef DEBUG
 138         printf("> %s\n", buf);
 139 #endif
 140 }
 141
 142
 143 /*
 144  * send line to server - implemented in terms of serv_write()
 145  */
 146 void serv_puts(char *buf)
 147 {
 148 #ifdef DEBUG
 149         printf("< %s\n", buf);
 150 #endif
 151         serv_write(buf, strlen(buf));
 152         serv_write("\n", 1);
 153 }
 154
 155
 156
 157
 158
 159 void cleanup(int exitcode) {
 160         char buf[1024];
 161
 162         serv_puts("QUIT");
 163         serv_gets(buf);
 164         exit(exitcode);
 165 }
 166
 167
 168
 169 int main(int argc, char **argv) {
 170         char buf[1024];
 171         char fromline[1024];
 172         FILE *fp;
 173
 174         get_config();
 175
 176         fp = tmpfile();
 177         if (fp == NULL) return(errno);
 178         snprintf(fromline, sizeof fromline, "From: someone@somewhere.org");
 179         while (fgets(buf, 1024, stdin) != NULL) {
 180                 fprintf(fp, "%s", buf);
 181                 if (!strncasecmp(buf, "From:", 5)) strcpy(fromline, buf);
 182         }
 183         strip_trailing_nonprint(fromline);
 184
 185         serv_sock = uds_connectsock("smtp.socket");
 186         serv_gets(buf);
 187         if (buf[0]!='2') cleanup(1);
 188
 189         serv_puts("HELO localhost");
 190         serv_gets(buf);
 191         if (buf[0]!='2') cleanup(1);
 192
 193         snprintf(buf, sizeof buf, "MAIL %s", fromline);
 194         serv_puts(buf);
 195         serv_gets(buf);
 196         if (buf[0]!='2') cleanup(1);
 197
 198         snprintf(buf, sizeof buf, "RCPT To: %s", argv[1]);
 199         serv_puts(buf);
 200         serv_gets(buf);
 201         if (buf[0]!='2') cleanup(1);
 202
 203         serv_puts("DATA");
 204         serv_gets(buf);
 205         if (buf[0]!='3') cleanup(1);
 206
 207         rewind(fp);
 208         while (fgets(buf, sizeof buf, fp) != NULL) {
 209                 strip_trailing_nonprint(buf);
 210                 serv_puts(buf);
 211         }
 212         serv_puts(".");
 213         serv_gets(buf);
 214         if (buf[0]!='2') cleanup(1);
 215         else cleanup(0);
 216         return(0);
 217 }