]> code.citadel.org Git - citadel.git/blobdiff - citadel/msgbase.c
* Got bounce messages working (mostly ... testers, please beat this up!)
[citadel.git] / citadel / msgbase.c
index f196880378b6b4fc8740f6e6cd30e68bf7238ce7..b4ed04e1f26fad003dfeb477b0cbb07de4d17d53 100644 (file)
@@ -1,4 +1,5 @@
 /* $Id$ */
+
 #include "sysdep.h"
 #include <stdlib.h>
 #include <unistd.h>
@@ -27,6 +28,8 @@
 #include "tools.h"
 #include "mime_parser.h"
 #include "html.h"
+#include "genstamp.h"
+#include "internet_addressing.h"
 
 #define desired_section ((char *)CtdlGetUserData(SYM_DESIRED_SECTION))
 #define ma ((struct ma_info *)CtdlGetUserData(SYM_MA_INFO))
@@ -48,7 +51,8 @@ char *msgkeys[] = {
        "from",
        "", "", "",
        "exti",
-       "", "", 
+       "rfca",
+       "", 
        "hnod",
        "msgn",
        "", "", "",
@@ -126,6 +130,16 @@ int alias(char *name)
        fclose(fp);
        lprintf(7, "Mail is being forwarded to %s\n", name);
 
+       /* Change "user @ xxx" to "user" if xxx is an alias for this host */
+       for (a=0; a<strlen(name); ++a) {
+               if (name[a] == '@') {
+                       if (CtdlHostAlias(&name[a+1]) == hostalias_localhost) {
+                               name[a] = 0;
+                               lprintf(7, "Changed to <%s>\n", name);
+                       }
+               }
+       }
+
        /* determine local or remote type, see citadel.h */
        for (a = 0; a < strlen(name); ++a)
                if (name[a] == '!')
@@ -152,7 +166,7 @@ int alias(char *name)
                fp = fopen("network/mail.sysinfo", "r");
                if (fp == NULL)
                        return (MES_ERROR);
-             GETSN:do {
+GETSN:         do {
                        a = getstring(fp, aaa);
                } while ((a >= 0) && (strcasecmp(aaa, bbb)));
                a = getstring(fp, aaa);
@@ -671,8 +685,9 @@ void CtdlFreeMessage(struct CtdlMessage *msg)
        if (is_valid_message(msg) == 0) return;
 
        for (i = 0; i < 256; ++i)
-               if (msg->cm_fields[i] != NULL)
+               if (msg->cm_fields[i] != NULL) {
                        phree(msg->cm_fields[i]);
+               }
 
        msg->cm_magic = 0;      /* just in case */
        phree(msg);
@@ -680,129 +695,15 @@ void CtdlFreeMessage(struct CtdlMessage *msg)
 
 
 /*
- * Get a message off disk.  (returns om_* values found in msgbase.h)
- * 
+ * Callback function for mime parser that wants to display text
  */
-int CtdlOutputMsg(long msg_num,                /* message number (local) to fetch */
-               int mode,               /* how would you like that message? */
-               int headers_only,       /* eschew the message body? */
-               int do_proto,           /* do Citadel protocol responses? */
-               FILE *outfp,
-               int outsock,
-               int crlf                /* Use CRLF newlines instead of LF? */
-) {
-       int a, i, k;
-       char buf[1024];
-       time_t xtime;
-       CIT_UBYTE ch;
-       char allkeys[256];
-       char display_name[256];
-       struct CtdlMessage *TheMessage;
-       char *mptr;
-       char *nl;       /* newline string */
-
-       /* buffers needed for RFC822 translation */
-       char suser[256];
-       char luser[256];
-       char snode[256];
-       char lnode[256];
-       char mid[256];
-       /*                                       */
-
-
-       /* BEGIN NESTED FUNCTION omprintf() */
-       void omprintf(const char *format, ...) {   
-               va_list arg_ptr;   
-               char buf[256];   
-        
-               va_start(arg_ptr, format);   
-               if (vsnprintf(buf, sizeof buf, format, arg_ptr) == -1)
-                       buf[sizeof buf - 2] = '\n';
-               if (outfp != NULL) {
-                       fwrite(buf, strlen(buf), 1, outfp);
-               }
-               else if (outsock >= 0) {
-                       write(outsock, buf, strlen(buf));
-               }
-               else {
-                       client_write(buf, strlen(buf)); 
-               }
-               va_end(arg_ptr);
-       }   
-       /* END NESTED FUNCTION omprintf() */
-
-       /* BEGIN NESTED FUNCTION omfmout() */
-       void omfmout(char *mptr) {
-               int b, c;
-               int real = 0;
-               int old = 0;
-               CIT_UBYTE ch;
-               char aaa[140];
-               char buffer[256];
-
-               strcpy(aaa, "");
-               old = 255;
-               strcpy(buffer, "");
-               c = 1;                  /* c is the current pos */
-
-FMTA:          ch = *mptr++;
-               old = real;
-               real = ch;
-               if (ch <= 0)
-                       goto FMTEND;
-       
-               if (((ch == 13) || (ch == 10)) && (old != 13) && (old != 10))
-                       ch = 32;
-               if (((old == 13) || (old == 10)) && (isspace(real))) {
-                       omprintf("%s", nl);
-                       c = 1;
-               }
-               if (ch > 126)
-                       goto FMTA;
-       
-               if (ch > 32) {
-                       if (((strlen(aaa) + c) > (75)) && (strlen(aaa) > (75))) {
-                               omprintf("%s%s", nl, aaa);
-                               c = strlen(aaa);
-                               aaa[0] = 0;
-                       }
-                       b = strlen(aaa);
-                       aaa[b] = ch;
-                       aaa[b + 1] = 0;
-               }
-               if (ch == 32) {
-                       if ((strlen(aaa) + c) > (75)) {
-                               omprintf("%s", nl);
-                               c = 1;
-                       }
-                       omprintf("%s ", aaa);
-                       ++c;
-                       c = c + strlen(aaa);
-                       strcpy(aaa, "");
-                       goto FMTA;
-               }
-               if ((ch == 13) || (ch == 10)) {
-                       omprintf("%s%s", aaa, nl);
-                       c = 1;
-                       strcpy(aaa, "");
-                       goto FMTA;
-               }
-               goto FMTA;
-
-FMTEND:                omprintf("%s%s", aaa, nl);
-       }
-       /* END NESTED FUNCTION omfmout() */
-
-       /* BEGIN NESTED FUNCTION fixed_output() */
-       /*
-       * Callback function for mime parser that wants to display text
-       */
-       void fixed_output(char *name, char *filename, char *partnum, char *disp,
-                       void *content, char *cbtype, size_t length)
+void fixed_output(char *name, char *filename, char *partnum, char *disp,
+               void *content, char *cbtype, size_t length)
        {
                char *ptr;
                char *wptr;
                size_t wlen;
+               CIT_UBYTE ch;
        
                if (!strcasecmp(cbtype, "multipart/alternative")) {
                        strcpy(ma->prefix, partnum);
@@ -827,8 +728,8 @@ FMTEND:             omprintf("%s%s", aaa, nl);
                        wptr = content;
                        while (wlen--) {
                                ch = *wptr++;
-                               if (ch==10) omprintf("%s", nl);
-                               else omprintf("%c", ch);
+                               if (ch==10) cprintf("\r\n");
+                               else cprintf("%c", ch);
                        }
                }
                else if (!strcasecmp(cbtype, "text/html")) {
@@ -837,18 +738,46 @@ FMTEND:           omprintf("%s%s", aaa, nl);
                        wptr = ptr;
                        while (wlen--) {
                                ch = *wptr++;
-                               if (ch==10) omprintf("%s", nl);
-                               else omprintf("%c", ch);
+                               if (ch==10) cprintf("\r\n");
+                               else cprintf("%c", ch);
                        }
                        phree(ptr);
                }
                else if (strncasecmp(cbtype, "multipart/", 10)) {
-                       omprintf("Part %s: %s (%s) (%d bytes)%s",
-                               partnum, filename, cbtype, length, nl);
+                       cprintf("Part %s: %s (%s) (%d bytes)\r\n",
+                               partnum, filename, cbtype, length);
                }
        }
 
-       /* END NESTED FUNCTION fixed_output() */
+
+/*
+ * Get a message off disk.  (returns om_* values found in msgbase.h)
+ * 
+ */
+int CtdlOutputMsg(long msg_num,                /* message number (local) to fetch */
+               int mode,               /* how would you like that message? */
+               int headers_only,       /* eschew the message body? */
+               int do_proto,           /* do Citadel protocol responses? */
+               int crlf                /* Use CRLF newlines instead of LF? */
+) {
+       int i, k;
+       char buf[1024];
+       CIT_UBYTE ch;
+       char allkeys[256];
+       char display_name[256];
+       struct CtdlMessage *TheMessage;
+       char *mptr;
+       char *nl;       /* newline string */
+
+       /* buffers needed for RFC822 translation */
+       char suser[256];
+       char luser[256];
+       char fuser[256];
+       char snode[256];
+       char lnode[256];
+       char mid[256];
+       char datestamp[256];
+       /*                                       */
 
        lprintf(7, "CtdlOutputMsg() msgnum=%ld, mode=%d\n", 
                msg_num, mode);
@@ -863,7 +792,7 @@ FMTEND:             omprintf("%s%s", aaa, nl);
                return(om_not_logged_in);
        }
 
-       /* FIX ... small security issue
+       /* FIXME ... small security issue
         * We need to check to make sure the requested message is actually
         * in the current room, and set msg_ok to 1 only if it is.  This
         * functionality is currently missing because I'm in a hurry to replace
@@ -983,53 +912,64 @@ FMTEND:           omprintf("%s%s", aaa, nl);
 
        strcpy(suser, "");
        strcpy(luser, "");
+       strcpy(fuser, "");
        strcpy(snode, NODENAME);
        strcpy(lnode, HUMANNODE);
        if (mode == MT_RFC822) {
+               cprintf("X-UIDL: %ld%s", msg_num, nl);
                for (i = 0; i < 256; ++i) {
                        if (TheMessage->cm_fields[i]) {
                                mptr = TheMessage->cm_fields[i];
 
                                if (i == 'A') {
                                        strcpy(luser, mptr);
-                               } else if (i == 'P') {
-                                       omprintf("Path: %s%s", mptr, nl);
-                                       for (a = 0; a < strlen(mptr); ++a) {
-                                               if (mptr[a] == '!') {
-                                                       strcpy(mptr, &mptr[a + 1]);
-                                                       a = 0;
-                                               }
-                                       }
                                        strcpy(suser, mptr);
-                               } else if (i == 'U')
-                                       omprintf("Subject: %s%s", mptr, nl);
+                               }
+                               else if (i == 'P') {
+                                       cprintf("Path: %s%s", mptr, nl);
+                               }
+                               else if (i == 'U')
+                                       cprintf("Subject: %s%s", mptr, nl);
                                else if (i == 'I')
                                        strcpy(mid, mptr);
                                else if (i == 'H')
                                        strcpy(lnode, mptr);
                                else if (i == 'O')
-                                       omprintf("X-Citadel-Room: %s%s",
+                                       cprintf("X-Citadel-Room: %s%s",
                                                mptr, nl);
                                else if (i == 'N')
                                        strcpy(snode, mptr);
                                else if (i == 'R')
-                                       omprintf("To: %s%s", mptr, nl);
+                                       cprintf("To: %s%s", mptr, nl);
                                else if (i == 'T') {
-                                       xtime = atol(mptr);
-                                       omprintf("Date: %s", asctime(localtime(&xtime)));
+                                       generate_rfc822_datestamp(datestamp,
+                                                               atol(mptr) );
+                                       cprintf("Date: %s%s", datestamp, nl);
                                }
                        }
                }
        }
 
+       for (i=0; i<strlen(suser); ++i) {
+               suser[i] = tolower(suser[i]);
+               if (!isalnum(suser[i])) suser[i]='_';
+       }
+
        if (mode == MT_RFC822) {
                if (!strcasecmp(snode, NODENAME)) {
                        strcpy(snode, FQDN);
                }
-               omprintf("Message-ID: <%s@%s>%s", mid, snode, nl);
+               cprintf("Message-ID: <%s@%s>%s", mid, snode, nl);
                PerformUserHooks(luser, (-1L), EVT_OUTPUTMSG);
-               omprintf("From: %s@%s (%s)%s", suser, snode, luser, nl);
-               omprintf("Organization: %s%s", lnode, nl);
+
+               if (strlen(fuser) > 0) {
+                       cprintf("From: %s (%s)%s", fuser, luser, nl);
+               }
+               else {
+                       cprintf("From: %s@%s (%s)%s", suser, snode, luser, nl);
+               }
+
+               cprintf("Organization: %s%s", lnode, nl);
        }
 
        /* end header processing loop ... at this point, we're in the text */
@@ -1048,15 +988,15 @@ FMTEND:          omprintf("%s%s", aaa, nl);
                        return(om_ok);
                }
                else if (mode == MT_RFC822) {   /* unparsed RFC822 dump */
-                       /* FIX ... we have to put some code in here to avoid
+                       /* FIXME ... we have to put some code in here to avoid
                         * printing duplicate header information when both
                         * Citadel and RFC822 headers exist.  Preference should
                         * probably be given to the RFC822 headers.
                         */
                        while (ch=*(mptr++), ch!=0) {
                                if (ch==13) ;
-                               else if (ch==10) omprintf("%s", nl);
-                               else omprintf("%c", ch);
+                               else if (ch==10) cprintf("%s", nl);
+                               else cprintf("%c", ch);
                        }
                        if (do_proto) cprintf("000\n");
                        CtdlFreeMessage(TheMessage);
@@ -1074,7 +1014,10 @@ FMTEND:          omprintf("%s%s", aaa, nl);
        if (mode == MT_CITADEL)
                if (do_proto) cprintf("text\n");
        if (mode == MT_RFC822) {
-               omprintf("%s", nl);
+               if (TheMessage->cm_fields['U'] == NULL) {
+                       cprintf("Subject: (no subject)%s", nl);
+               }
+               cprintf("%s", nl);
        }
 
        /* If the format type on disk is 1 (fixed-format), then we want
@@ -1087,7 +1030,7 @@ FMTEND:           omprintf("%s%s", aaa, nl);
                        if (ch == 13)
                                ch = 10;
                        if ((ch == 10) || (strlen(buf) > 250)) {
-                               omprintf("%s%s", buf, nl);
+                               cprintf("%s%s", buf, nl);
                                strcpy(buf, "");
                        } else {
                                buf[strlen(buf) + 1] = 0;
@@ -1095,7 +1038,7 @@ FMTEND:           omprintf("%s%s", aaa, nl);
                        }
                }
                if (strlen(buf) > 0)
-                       omprintf("%s%s", buf, nl);
+                       cprintf("%s%s", buf, nl);
        }
 
        /* If the message on disk is format 0 (Citadel vari-format), we
@@ -1106,7 +1049,7 @@ FMTEND:           omprintf("%s%s", aaa, nl);
         * message to the reader's screen width.
         */
        if (TheMessage->cm_format_type == FMT_CITADEL) {
-               omfmout(mptr);
+               memfmout(80, mptr, 0);
        }
 
        /* If the message on disk is format 4 (MIME), we've gotta hand it
@@ -1139,7 +1082,7 @@ void cmd_msg0(char *cmdbuf)
        msgid = extract_long(cmdbuf, 0);
        headers_only = extract_int(cmdbuf, 1);
 
-       CtdlOutputMsg(msgid, MT_CITADEL, headers_only, 1, NULL, -1, 0);
+       CtdlOutputMsg(msgid, MT_CITADEL, headers_only, 1, 0);
        return;
 }
 
@@ -1155,7 +1098,7 @@ void cmd_msg2(char *cmdbuf)
        msgid = extract_long(cmdbuf, 0);
        headers_only = extract_int(cmdbuf, 1);
 
-       CtdlOutputMsg(msgid, MT_RFC822, headers_only, 1, NULL, -1, 1);
+       CtdlOutputMsg(msgid, MT_RFC822, headers_only, 1, 1);
 }
 
 
@@ -1200,14 +1143,14 @@ void cmd_msg3(char *cmdbuf)
 
 
 /* 
- * display a message (mode 4 - MIME) (FIX ... still evolving, not complete)
+ * display a message (mode 4 - MIME) (FIXME ... still evolving, not complete)
  */
 void cmd_msg4(char *cmdbuf)
 {
        long msgid;
 
        msgid = extract_long(cmdbuf, 0);
-       CtdlOutputMsg(msgid, MT_MIME, 0, 1, NULL, -1, 0);
+       CtdlOutputMsg(msgid, MT_MIME, 0, 1, 0);
 }
 
 /*
@@ -1222,7 +1165,7 @@ void cmd_opna(char *cmdbuf)
        msgid = extract_long(cmdbuf, 0);
        extract(desired_section, cmdbuf, 1);
 
-       CtdlOutputMsg(msgid, MT_DOWNLOAD, 0, 1, NULL, -1, 1);
+       CtdlOutputMsg(msgid, MT_DOWNLOAD, 0, 1, 1);
 }                      
 
 
@@ -1583,11 +1526,25 @@ long CtdlSaveMsg(struct CtdlMessage *msg,       /* message to save */
        strcpy(force_room, force);
 
        /* Strip non-printable characters out of the recipient name */
+       lprintf(9, "Checking recipient (if present)\n");
        strcpy(recipient, rec);
        for (a = 0; a < strlen(recipient); ++a)
                if (!isprint(recipient[a]))
                        strcpy(&recipient[a], &recipient[a + 1]);
 
+       /* Change "user @ xxx" to "user" if xxx is an alias for this host */
+       for (a=0; a<strlen(recipient); ++a) {
+               if (recipient[a] == '@') {
+                       if (CtdlHostAlias(&recipient[a+1]) 
+                          == hostalias_localhost) {
+                               recipient[a] = 0;
+                               lprintf(7, "Changed to <%s>\n", recipient);
+                       }
+               }
+       }
+
+       lprintf(9, "Recipient is <%s>\n", recipient);
+
        /* Learn about what's inside, because it's what's inside that counts */
        lprintf(9, "Learning what's inside\n");
        if (msg->cm_fields['M'] == NULL) {
@@ -1744,8 +1701,11 @@ long CtdlSaveMsg(struct CtdlMessage *msg,        /* message to save */
                instr = mallok(2048);
                sprintf(instr,
                        "Content-type: %s\n\nmsgid|%ld\nsubmitted|%ld\n"
+                       "bounceto|%s@%s\n"
                        "remote|%s|0||\n",
-                       SPOOLMIME, newmsgid, time(NULL), recipient );
+                       SPOOLMIME, newmsgid, time(NULL),
+                       msg->cm_fields['A'], msg->cm_fields['N'],
+                       recipient );
 
                imsg = mallok(sizeof(struct CtdlMessage));
                memset(imsg, 0, sizeof(struct CtdlMessage));
@@ -2447,7 +2407,7 @@ void CtdlWriteObject(char *req_room,              /* Room to stuff it in */
        FILE *fp, *tempfp;
        char filename[PATH_MAX];
        char cmdbuf[256];
-       int ch;
+       char ch;
        struct quickroom qrbuf;
        char roomname[ROOMNAMELEN];
        struct CtdlMessage *msg;