]> code.citadel.org Git - citadel.git/blobdiff - citadel/serv_smtp.c
* Replaced all "Citadel/UX" references with "Citadel"
[citadel.git] / citadel / serv_smtp.c
index 73739f4880e4282b7bd3cc3b1cf238e25a8b21fa..6f23e086a978214a10844200d82553186cfe5066 100644 (file)
@@ -14,6 +14,7 @@
  * RFC 2033 - Local Mail Transfer Protocol
  * RFC 2034 - SMTP Service Extension for Returning Enhanced Error Codes
  * RFC 2197 - SMTP Service Extension for Command Pipelining
+ * RFC 2487 - SMTP Service Extension for Secure SMTP over TLS
  * RFC 2554 - SMTP Service Extension for Authentication
  * RFC 2821 - Simple Mail Transfer Protocol
  * RFC 2822 - Internet Message Format
 #include "clientsocket.h"
 #include "locate_host.h"
 
+#ifdef HAVE_OPENSSL
+#include "serv_crypto.h"
+#endif
+
+
 
 #ifndef HAVE_SNPRINTF
 #include "snprintf.h"
@@ -129,7 +135,7 @@ void smtp_greeting(void) {
        snprintf(SMTP_RECPS, SIZ, "%s", "");
        snprintf(SMTP_ROOMS, SIZ, "%s", "");
 
-       cprintf("220 %s ESMTP Citadel/UX server ready.\r\n", config.c_fqdn);
+       cprintf("220 %s ESMTP Citadel server ready.\r\n", config.c_fqdn);
 }
 
 /*
@@ -141,6 +147,17 @@ void lmtp_greeting(void) {
 }
 
 
+/*
+ * Login greeting common to all auth methods
+ */
+void smtp_auth_greeting(void) {
+               cprintf("235 2.0.0 Hello, %s\r\n", CC->user.fullname);
+               lprintf(CTDL_NOTICE, "SMTP authenticated %s\n", CC->user.fullname);
+               CC->internal_pgm = 0;
+               CC->cs_flags &= ~CS_STEALTH;
+}
+
+
 /*
  * Implement HELO and EHLO commands.
  *
@@ -180,8 +197,21 @@ void smtp_hello(char *argbuf, int which_command) {
                }
                cprintf("250-HELP\r\n");
                cprintf("250-SIZE %ld\r\n", config.c_maxmsglen);
-               cprintf("250-PIPELINING\r\n");
-               cprintf("250-AUTH=LOGIN\r\n");
+
+               /* Only offer the PIPELINING command if TLS is inactive, because
+                * of flow control issues.  Also, avoid offering TLS if TLS is
+                * already active.
+                */
+               if (!CC->redirect_ssl) {
+                       cprintf("250-PIPELINING\r\n");
+#ifdef HAVE_OPENSSL
+                       cprintf("250-STARTTLS\r\n");
+#endif
+               }
+
+               cprintf("250-AUTH LOGIN PLAIN\r\n");
+               cprintf("250-AUTH=LOGIN PLAIN\r\n");
+
                cprintf("250 ENHANCEDSTATUSCODES\r\n");
        }
 }
@@ -216,7 +246,7 @@ void smtp_get_user(char *argbuf) {
        char username[SIZ];
 
        CtdlDecodeBase64(username, argbuf, SIZ);
-       lprintf(9, "Trying <%s>\n", username);
+       lprintf(CTDL_DEBUG, "Trying <%s>\n", username);
        if (CtdlLoginExistingUser(username) == login_ok) {
                CtdlEncodeBase64(buf, "Password:", 9);
                cprintf("334 %s\r\n", buf);
@@ -236,12 +266,9 @@ void smtp_get_pass(char *argbuf) {
        char password[SIZ];
 
        CtdlDecodeBase64(password, argbuf, SIZ);
-       lprintf(9, "Trying <%s>\n", password);
+       lprintf(CTDL_DEBUG, "Trying <%s>\n", password);
        if (CtdlTryPassword(password) == pass_ok) {
-               cprintf("235 2.0.0 Hello, %s\r\n", CC->user.fullname);
-               lprintf(9, "SMTP authenticated login successful\n");
-               CC->internal_pgm = 0;
-               CC->cs_flags &= ~CS_STEALTH;
+               smtp_auth_greeting();
        }
        else {
                cprintf("535 5.7.0 Authentication failed.\r\n");
@@ -255,21 +282,55 @@ void smtp_get_pass(char *argbuf) {
  */
 void smtp_auth(char *argbuf) {
        char buf[SIZ];
+       char method[SIZ];
+       char encoded_authstring[SIZ];
+       char decoded_authstring[SIZ];
+       char ident[SIZ];
+       char user[SIZ];
+       char pass[SIZ];
 
-       if (strncasecmp(argbuf, "login", 5) ) {
-               cprintf("504 5.7.4 We only support LOGIN authentication.\r\n");
+       if (CC->logged_in) {
+               cprintf("504 5.7.4 Already logged in.\r\n");
+               return;
+       }
+
+       extract_token(method, argbuf, 0, ' ');
+
+       if (!strncasecmp(method, "login", 5) ) {
+               if (strlen(argbuf) >= 7) {
+                       smtp_get_user(&argbuf[6]);
+               }
+               else {
+                       CtdlEncodeBase64(buf, "Username:", 9);
+                       cprintf("334 %s\r\n", buf);
+                       SMTP->command_state = smtp_user;
+               }
                return;
        }
 
-       if (strlen(argbuf) >= 7) {
-               smtp_get_user(&argbuf[6]);
+       if (!strncasecmp(method, "plain", 5) ) {
+               extract_token(encoded_authstring, argbuf, 1, ' ');
+               CtdlDecodeBase64(decoded_authstring,
+                               encoded_authstring,
+                               strlen(encoded_authstring) );
+               strcpy(ident, decoded_authstring);
+               strcpy(user, &decoded_authstring[strlen(ident) + 1] );
+               strcpy(pass, &decoded_authstring[strlen(ident) + strlen(user) + 2] );
+
+               if (CtdlLoginExistingUser(user) == login_ok) {
+                       if (CtdlTryPassword(pass) == pass_ok) {
+                               smtp_auth_greeting();
+                               return;
+                       }
+               }
+               cprintf("504 5.7.4 Authentication failed.\r\n");
        }
 
-       else {
-               CtdlEncodeBase64(buf, "Username:", 9);
-               cprintf("334 %s\r\n", buf);
-               SMTP->command_state = smtp_user;
+       if (strncasecmp(method, "login", 5) ) {
+               cprintf("504 5.7.4 Unknown authentication method.\r\n");
+               return;
        }
+
 }
 
 
@@ -356,10 +417,12 @@ void smtp_expn(char *argbuf) {
 /*
  * Implements the RSET (reset state) command.
  * Currently this just zeroes out the state buffer.  If pointers to data
- * allocated with mallok() are ever placed in the state buffer, we have to
- * be sure to phree() them first!
+ * allocated with malloc() are ever placed in the state buffer, we have to
+ * be sure to free() them first!
+ *
+ * Set do_response to nonzero to output the SMTP RSET response code.
  */
-void smtp_rset(void) {
+void smtp_rset(int do_response) {
        int is_lmtp;
 
        /*
@@ -387,7 +450,9 @@ void smtp_rset(void) {
         */
        SMTP->is_lmtp = is_lmtp;
 
-       cprintf("250 2.0.0 Zap!\r\n");
+       if (do_response) {
+               cprintf("250 2.0.0 Zap!\r\n");
+       }
 }
 
 /*
@@ -501,7 +566,7 @@ void smtp_rcpt(char *argbuf) {
           && (!SMTP->is_lmtp) ) {
                if (rbl_check(message_to_spammer)) {
                        cprintf("550 %s\r\n", message_to_spammer);
-                       /* no need to phree(valid), it's not allocated yet */
+                       /* no need to free(valid), it's not allocated yet */
                        return;
                }
        }
@@ -509,15 +574,25 @@ void smtp_rcpt(char *argbuf) {
        valid = validate_recipients(recp);
        if (valid->num_error > 0) {
                cprintf("599 5.1.1 Error: %s\r\n", valid->errormsg);
-               phree(valid);
+               free(valid);
                return;
        }
 
+       if (valid->num_internet > 0) {
+               if (CC->logged_in) {
+                        if (CtdlCheckInternetMailPermission(&CC->user)==0) {
+                               cprintf("551 5.7.1 <%s> - you do not have permission to send Internet mail\r\n", recp);
+                                free(valid);
+                                return;
+                        }
+                }
+       }
+
        if (valid->num_internet > 0) {
                if ( (SMTP->message_originated_locally == 0)
                   && (SMTP->is_lmtp == 0) ) {
                        cprintf("551 5.7.1 <%s> - relaying denied\r\n", recp);
-                       phree(valid);
+                       free(valid);
                        return;
                }
        }
@@ -559,7 +634,7 @@ void smtp_data(void) {
        cprintf("354 Transmit message now - terminate with '.' by itself\r\n");
        
        datestring(nowstamp, sizeof nowstamp, time(NULL), DATESTRING_RFC822);
-       body = mallok(4096);
+       body = malloc(4096);
 
        if (body != NULL) snprintf(body, 4096,
                "Received: from %s (%s [%s])\n"
@@ -577,7 +652,7 @@ void smtp_data(void) {
                return;
        }
 
-       lprintf(9, "Converting message...\n");
+       lprintf(CTDL_DEBUG, "Converting message...\n");
        msg = convert_internet_message(body);
 
        /* If the user is locally authenticated, FORCE the From: header to
@@ -591,16 +666,16 @@ void smtp_data(void) {
         * is read with a Citadel client.
         */
        if ( (CC->logged_in) && (config.c_rfc822_strict_from == 0) ) {
-               if (msg->cm_fields['A'] != NULL) phree(msg->cm_fields['A']);
-               if (msg->cm_fields['N'] != NULL) phree(msg->cm_fields['N']);
-               if (msg->cm_fields['H'] != NULL) phree(msg->cm_fields['H']);
-               if (msg->cm_fields['F'] != NULL) phree(msg->cm_fields['F']);
-               if (msg->cm_fields['O'] != NULL) phree(msg->cm_fields['O']);
-               msg->cm_fields['A'] = strdoop(CC->user.fullname);
-               msg->cm_fields['N'] = strdoop(config.c_nodename);
-               msg->cm_fields['H'] = strdoop(config.c_humannode);
-               msg->cm_fields['F'] = strdoop(CC->cs_inet_email);
-               msg->cm_fields['O'] = strdoop(MAILROOM);
+               if (msg->cm_fields['A'] != NULL) free(msg->cm_fields['A']);
+               if (msg->cm_fields['N'] != NULL) free(msg->cm_fields['N']);
+               if (msg->cm_fields['H'] != NULL) free(msg->cm_fields['H']);
+               if (msg->cm_fields['F'] != NULL) free(msg->cm_fields['F']);
+               if (msg->cm_fields['O'] != NULL) free(msg->cm_fields['O']);
+               msg->cm_fields['A'] = strdup(CC->user.fullname);
+               msg->cm_fields['N'] = strdup(config.c_nodename);
+               msg->cm_fields['H'] = strdup(config.c_humannode);
+               msg->cm_fields['F'] = strdup(CC->cs_inet_email);
+               msg->cm_fields['O'] = strdup(MAILROOM);
        }
 
        /* Submit the message into the Citadel system. */
@@ -615,7 +690,7 @@ void smtp_data(void) {
        if (scan_errors > 0) {  /* We don't want this message! */
 
                if (msg->cm_fields['0'] == NULL) {
-                       msg->cm_fields['0'] = strdoop(
+                       msg->cm_fields['0'] = strdup(
                                "5.7.1 Message rejected by filter");
                }
 
@@ -648,11 +723,32 @@ void smtp_data(void) {
        }
 
        CtdlFreeMessage(msg);
-       phree(valid);
+       free(valid);
        smtp_data_clear();      /* clear out the buffers now */
 }
 
 
+/*
+ * implements the STARTTLS command (Citadel API version)
+ */
+#ifdef HAVE_OPENSSL
+void smtp_starttls(void)
+{
+       char ok_response[SIZ];
+       char nosup_response[SIZ];
+       char error_response[SIZ];
+
+       sprintf(ok_response,
+               "200 2.0.0 Begin TLS negotiation now\r\n");
+       sprintf(nosup_response,
+               "554 5.7.3 TLS not supported here\r\n");
+       sprintf(error_response,
+               "554 5.7.3 Internal error\r\n");
+       CtdlStartTLS(ok_response, nosup_response, error_response);
+       smtp_rset(0);
+}
+#endif
+
 
 
 /* 
@@ -664,15 +760,13 @@ void smtp_command_loop(void) {
        time(&CC->lastcmd);
        memset(cmdbuf, 0, sizeof cmdbuf); /* Clear it, just in case */
        if (client_gets(cmdbuf) < 1) {
-               lprintf(3, "SMTP socket is broken.  Ending session.\n");
+               lprintf(CTDL_CRIT, "SMTP socket is broken.  Ending session.\n");
                CC->kill_me = 1;
                return;
        }
-       lprintf(5, "SMTP: %s\n", cmdbuf);
+       lprintf(CTDL_INFO, "SMTP: %s\n", cmdbuf);
        while (strlen(cmdbuf) < 5) strcat(cmdbuf, " ");
 
-       lprintf(9, "CC->logged_in = %d\n", CC->logged_in);
-
        if (SMTP->command_state == smtp_user) {
                smtp_get_user(cmdbuf);
        }
@@ -728,9 +822,13 @@ void smtp_command_loop(void) {
        }
 
        else if (!strncasecmp(cmdbuf, "RSET", 4)) {
-               smtp_rset();
+               smtp_rset(1);
        }
-
+#ifdef HAVE_OPENSSL
+       else if (!strcasecmp(cmdbuf, "STARTTLS")) {
+               smtp_starttls();
+       }
+#endif
        else if (!strncasecmp(cmdbuf, "VRFY", 4)) {
                smtp_vrfy(&cmdbuf[5]);
        }
@@ -739,6 +837,7 @@ void smtp_command_loop(void) {
                cprintf("502 5.0.0 I'm afraid I can't do that.\r\n");
        }
 
+
 }
 
 
@@ -776,7 +875,7 @@ void smtp_try(const char *key, const char *addr, int *status,
        /* Parse out the host portion of the recipient address */
        process_rfc822_addr(addr, user, node, name);
 
-       lprintf(9, "Attempting SMTP delivery to <%s> @ <%s> (%s)\n",
+       lprintf(CTDL_DEBUG, "Attempting SMTP delivery to <%s> @ <%s> (%s)\n",
                user, node, name);
 
        /* Load the message out of the database into a temp file */
@@ -841,7 +940,7 @@ void smtp_try(const char *key, const char *addr, int *status,
 
        /* Figure out what mail exchanger host we have to connect to */
        num_mxhosts = getmx(mxhosts, node);
-       lprintf(9, "Number of MX hosts for <%s> is %d\n", node, num_mxhosts);
+       lprintf(CTDL_DEBUG, "Number of MX hosts for <%s> is %d\n", node, num_mxhosts);
        if (num_mxhosts < 1) {
                *status = 5;
                snprintf(dsn, SIZ, "No MX hosts found for <%s>", node);
@@ -851,10 +950,10 @@ void smtp_try(const char *key, const char *addr, int *status,
        sock = (-1);
        for (mx=0; (mx<num_mxhosts && sock < 0); ++mx) {
                extract(buf, mxhosts, mx);
-               lprintf(9, "Trying <%s>\n", buf);
+               lprintf(CTDL_DEBUG, "Trying <%s>\n", buf);
                sock = sock_connect(buf, "25", "tcp");
                snprintf(dsn, SIZ, "Could not connect: %s", strerror(errno));
-               if (sock >= 0) lprintf(9, "Connected!\n");
+               if (sock >= 0) lprintf(CTDL_DEBUG, "Connected!\n");
                if (sock < 0) snprintf(dsn, SIZ, "%s", strerror(errno));
        }
 
@@ -869,7 +968,7 @@ void smtp_try(const char *key, const char *addr, int *status,
                strcpy(dsn, "Connection broken during SMTP conversation");
                goto bail;
        }
-       lprintf(9, "<%s\n", buf);
+       lprintf(CTDL_DEBUG, "<%s\n", buf);
        if (buf[0] != '2') {
                if (buf[0] == '4') {
                        *status = 4;
@@ -887,14 +986,14 @@ void smtp_try(const char *key, const char *addr, int *status,
 
        /* Do a HELO command */
        snprintf(buf, sizeof buf, "HELO %s\r\n", config.c_fqdn);
-       lprintf(9, ">%s", buf);
+       lprintf(CTDL_DEBUG, ">%s", buf);
        sock_write(sock, buf, strlen(buf));
        if (ml_sock_gets(sock, buf) < 0) {
                *status = 4;
                strcpy(dsn, "Connection broken during SMTP HELO");
                goto bail;
        }
-       lprintf(9, "<%s\n", buf);
+       lprintf(CTDL_DEBUG, "<%s\n", buf);
        if (buf[0] != '2') {
                if (buf[0] == '4') {
                        *status = 4;
@@ -911,14 +1010,14 @@ void smtp_try(const char *key, const char *addr, int *status,
 
        /* HELO succeeded, now try the MAIL From: command */
        snprintf(buf, sizeof buf, "MAIL From: <%s>\r\n", mailfrom);
-       lprintf(9, ">%s", buf);
+       lprintf(CTDL_DEBUG, ">%s", buf);
        sock_write(sock, buf, strlen(buf));
        if (ml_sock_gets(sock, buf) < 0) {
                *status = 4;
                strcpy(dsn, "Connection broken during SMTP MAIL");
                goto bail;
        }
-       lprintf(9, "<%s\n", buf);
+       lprintf(CTDL_DEBUG, "<%s\n", buf);
        if (buf[0] != '2') {
                if (buf[0] == '4') {
                        *status = 4;
@@ -935,14 +1034,14 @@ void smtp_try(const char *key, const char *addr, int *status,
 
        /* MAIL succeeded, now try the RCPT To: command */
        snprintf(buf, sizeof buf, "RCPT To: <%s>\r\n", addr);
-       lprintf(9, ">%s", buf);
+       lprintf(CTDL_DEBUG, ">%s", buf);
        sock_write(sock, buf, strlen(buf));
        if (ml_sock_gets(sock, buf) < 0) {
                *status = 4;
                strcpy(dsn, "Connection broken during SMTP RCPT");
                goto bail;
        }
-       lprintf(9, "<%s\n", buf);
+       lprintf(CTDL_DEBUG, "<%s\n", buf);
        if (buf[0] != '2') {
                if (buf[0] == '4') {
                        *status = 4;
@@ -958,14 +1057,14 @@ void smtp_try(const char *key, const char *addr, int *status,
 
 
        /* RCPT succeeded, now try the DATA command */
-       lprintf(9, ">DATA\n");
+       lprintf(CTDL_DEBUG, ">DATA\n");
        sock_write(sock, "DATA\r\n", 6);
        if (ml_sock_gets(sock, buf) < 0) {
                *status = 4;
                strcpy(dsn, "Connection broken during SMTP DATA");
                goto bail;
        }
-       lprintf(9, "<%s\n", buf);
+       lprintf(CTDL_DEBUG, "<%s\n", buf);
        if (buf[0] != '3') {
                if (buf[0] == '4') {
                        *status = 3;
@@ -989,8 +1088,8 @@ void smtp_try(const char *key, const char *addr, int *status,
                msg_size -= blocksize;
        }
        if (buf[blocksize-1] != 10) {
-               lprintf(5, "Possible problem: message did not correctly "
-                       "terminate. (expecting 0x10, got 0x%02x)\n",
+               lprintf(CTDL_WARNING, "Possible problem: message did not "
+                       "correctly terminate. (expecting 0x10, got 0x%02x)\n",
                                buf[blocksize-1]);
        }
 
@@ -1000,7 +1099,7 @@ void smtp_try(const char *key, const char *addr, int *status,
                strcpy(dsn, "Connection broken during SMTP message transmit");
                goto bail;
        }
-       lprintf(9, "%s\n", buf);
+       lprintf(CTDL_DEBUG, "%s\n", buf);
        if (buf[0] != '2') {
                if (buf[0] == '4') {
                        *status = 4;
@@ -1018,10 +1117,12 @@ void smtp_try(const char *key, const char *addr, int *status,
        safestrncpy(dsn, &buf[4], 1023);
        *status = 2;
 
-       lprintf(9, ">QUIT\n");
+       lprintf(CTDL_DEBUG, ">QUIT\n");
        sock_write(sock, "QUIT\r\n", 6);
        ml_sock_gets(sock, buf);
-       lprintf(9, "<%s\n", buf);
+       lprintf(CTDL_DEBUG, "<%s\n", buf);
+       lprintf(CTDL_INFO, "SMTP delivery to <%s> @ <%s> (%s) succeeded\n",
+               user, node, name);
 
 bail:  if (msg_fp != NULL) fclose(msg_fp);
        sock_close(sock);
@@ -1053,7 +1154,7 @@ void smtp_do_bounce(char *instr) {
        struct recptypes *valid;
        int successful_bounce = 0;
 
-       lprintf(9, "smtp_do_bounce() called\n");
+       lprintf(CTDL_DEBUG, "smtp_do_bounce() called\n");
        strcpy(bounceto, "");
 
        lines = num_tokens(instr, '\n');
@@ -1075,24 +1176,24 @@ void smtp_do_bounce(char *instr) {
 
 
 
-       bmsg = (struct CtdlMessage *) mallok(sizeof(struct CtdlMessage));
+       bmsg = (struct CtdlMessage *) malloc(sizeof(struct CtdlMessage));
        if (bmsg == NULL) return;
        memset(bmsg, 0, sizeof(struct CtdlMessage));
 
         bmsg->cm_magic = CTDLMESSAGE_MAGIC;
         bmsg->cm_anon_type = MES_NORMAL;
         bmsg->cm_format_type = 1;
-        bmsg->cm_fields['A'] = strdoop("Citadel");
-        bmsg->cm_fields['O'] = strdoop(MAILROOM);
-        bmsg->cm_fields['N'] = strdoop(config.c_nodename);
+        bmsg->cm_fields['A'] = strdup("Citadel");
+        bmsg->cm_fields['O'] = strdup(MAILROOM);
+        bmsg->cm_fields['N'] = strdup(config.c_nodename);
 
-       if (give_up) bmsg->cm_fields['M'] = strdoop(
+       if (give_up) bmsg->cm_fields['M'] = strdup(
 "A message you sent could not be delivered to some or all of its recipients\n"
 "due to prolonged unavailability of its destination(s).\n"
 "Giving up on the following addresses:\n\n"
 );
 
-        else bmsg->cm_fields['M'] = strdoop(
+        else bmsg->cm_fields['M'] = strdup(
 "A message you sent could not be delivered to some or all of its recipients.\n"
 "The following addresses were undeliverable:\n\n"
 );
@@ -1108,7 +1209,7 @@ void smtp_do_bounce(char *instr) {
                extract(dsn, buf, 3);
                bounce_this = 0;
 
-               lprintf(9, "key=<%s> addr=<%s> status=%d dsn=<%s>\n",
+               lprintf(CTDL_DEBUG, "key=<%s> addr=<%s> status=%d dsn=<%s>\n",
                        key, addr, status, dsn);
 
                if (!strcasecmp(key, "bounceto")) {
@@ -1129,11 +1230,11 @@ void smtp_do_bounce(char *instr) {
                        ++num_bounces;
 
                        if (bmsg->cm_fields['M'] == NULL) {
-                               lprintf(2, "ERROR ... M field is null "
+                               lprintf(CTDL_ERR, "ERROR ... M field is null "
                                        "(%s:%d)\n", __FILE__, __LINE__);
                        }
 
-                       bmsg->cm_fields['M'] = reallok(bmsg->cm_fields['M'],
+                       bmsg->cm_fields['M'] = realloc(bmsg->cm_fields['M'],
                                strlen(bmsg->cm_fields['M']) + 1024 );
                        strcat(bmsg->cm_fields['M'], addr);
                        strcat(bmsg->cm_fields['M'], ": ");
@@ -1147,13 +1248,13 @@ void smtp_do_bounce(char *instr) {
        }
 
        /* Deliver the bounce if there's anything worth mentioning */
-       lprintf(9, "num_bounces = %d\n", num_bounces);
+       lprintf(CTDL_DEBUG, "num_bounces = %d\n", num_bounces);
        if (num_bounces > 0) {
 
                /* First try the user who sent the message */
-               lprintf(9, "bounce to user? <%s>\n", bounceto);
+               lprintf(CTDL_DEBUG, "bounce to user? <%s>\n", bounceto);
                if (strlen(bounceto) == 0) {
-                       lprintf(7, "No bounce address specified\n");
+                       lprintf(CTDL_ERR, "No bounce address specified\n");
                        bounce_msgid = (-1L);
                }
 
@@ -1173,12 +1274,12 @@ void smtp_do_bounce(char *instr) {
 
                /* Free up the memory we used */
                if (valid != NULL) {
-                       phree(valid);
+                       free(valid);
                }
        }
 
        CtdlFreeMessage(bmsg);
-       lprintf(9, "Done processing bounces\n");
+       lprintf(CTDL_DEBUG, "Done processing bounces\n");
 }
 
 
@@ -1252,15 +1353,15 @@ void smtp_do_procmsg(long msgnum, void *userdata) {
        time_t last_attempted = 0L;
        time_t retry = SMTP_RETRY_INTERVAL;
 
-       lprintf(9, "smtp_do_procmsg(%ld)\n", msgnum);
+       lprintf(CTDL_DEBUG, "smtp_do_procmsg(%ld)\n", msgnum);
 
-       msg = CtdlFetchMessage(msgnum);
+       msg = CtdlFetchMessage(msgnum, 1);
        if (msg == NULL) {
-               lprintf(3, "SMTP: tried %ld but no such message!\n", msgnum);
+               lprintf(CTDL_ERR, "SMTP: tried %ld but no such message!\n", msgnum);
                return;
        }
 
-       instr = strdoop(msg->cm_fields['M']);
+       instr = strdup(msg->cm_fields['M']);
        CtdlFreeMessage(msg);
 
        /* Strip out the headers amd any other non-instruction line */
@@ -1301,8 +1402,8 @@ void smtp_do_procmsg(long msgnum, void *userdata) {
         * Postpone delivery if we've already tried recently.
         */
        if (((time(NULL) - last_attempted) < retry) && (run_queue_now == 0)) {
-               lprintf(7, "Retry time not yet reached.\n");
-               phree(instr);
+               lprintf(CTDL_DEBUG, "Retry time not yet reached.\n");
+               free(instr);
                return;
        }
 
@@ -1311,8 +1412,8 @@ void smtp_do_procmsg(long msgnum, void *userdata) {
         * Bail out if there's no actual message associated with this
         */
        if (text_msgid < 0L) {
-               lprintf(3, "SMTP: no 'msgid' directive found!\n");
-               phree(instr);
+               lprintf(CTDL_ERR, "SMTP: no 'msgid' directive found!\n");
+               free(instr);
                return;
        }
 
@@ -1341,15 +1442,15 @@ void smtp_do_procmsg(long msgnum, void *userdata) {
 
                        --i;
                        --lines;
-                       lprintf(9, "SMTP: Trying <%s>\n", addr);
+                       lprintf(CTDL_DEBUG, "SMTP: Trying <%s>\n", addr);
                        smtp_try(key, addr, &status, dsn, sizeof dsn, text_msgid);
                        if (status != 2) {
                                if (results == NULL) {
-                                       results = mallok(1024);
+                                       results = malloc(1024);
                                        memset(results, 0, 1024);
                                }
                                else {
-                                       results = reallok(results,
+                                       results = realloc(results,
                                                strlen(results) + 1024);
                                }
                                snprintf(&results[strlen(results)], 1024,
@@ -1360,9 +1461,9 @@ void smtp_do_procmsg(long msgnum, void *userdata) {
        }
 
        if (results != NULL) {
-               instr = reallok(instr, strlen(instr) + strlen(results) + 2);
+               instr = realloc(instr, strlen(instr) + strlen(results) + 2);
                strcat(instr, results);
-               phree(results);
+               free(results);
        }
 
 
@@ -1390,7 +1491,7 @@ void smtp_do_procmsg(long msgnum, void *userdata) {
         */
        if (incomplete_deliveries_remaining > 0) {
                CtdlDeleteMessages(SMTP_SPOOLOUT_ROOM, msgnum, "");
-               msg = mallok(sizeof(struct CtdlMessage));
+               msg = malloc(sizeof(struct CtdlMessage));
                memset(msg, 0, sizeof(struct CtdlMessage));
                msg->cm_magic = CTDLMESSAGE_MAGIC;
                msg->cm_anon_type = MES_NORMAL;
@@ -1402,7 +1503,7 @@ void smtp_do_procmsg(long msgnum, void *userdata) {
                        "attempted|%ld\n"
                        "retry|%ld\n",
                        SPOOLMIME, instr, (long)time(NULL), (long)retry );
-               phree(instr);
+               free(instr);
                CtdlSubmitMsg(msg, NULL, SMTP_SPOOLOUT_ROOM);
                CtdlFreeMessage(msg);
        }
@@ -1431,16 +1532,16 @@ void smtp_do_queue(void) {
        /* 
         * Go ahead and run the queue
         */
-       lprintf(7, "SMTP: processing outbound queue\n");
+       lprintf(CTDL_INFO, "SMTP: processing outbound queue\n");
 
        if (getroom(&CC->room, SMTP_SPOOLOUT_ROOM) != 0) {
-               lprintf(3, "Cannot find room <%s>\n", SMTP_SPOOLOUT_ROOM);
+               lprintf(CTDL_ERR, "Cannot find room <%s>\n", SMTP_SPOOLOUT_ROOM);
                return;
        }
        CtdlForEachMessage(MSGS_ALL, 0L,
                SPOOLMIME, NULL, smtp_do_procmsg, NULL);
 
-       lprintf(7, "SMTP: queue run completed\n");
+       lprintf(CTDL_INFO, "SMTP: queue run completed\n");
        run_queue_now = 0;
        doing_queue = 0;
 }
@@ -1482,7 +1583,7 @@ void cmd_smtp(char *argbuf) {
        }
 
        else {
-               cprintf("%d Invalid command.\n", ERROR+ILLEGAL_VALUE);
+               cprintf("%d Invalid command.\n", ERROR + ILLEGAL_VALUE);
        }
 
 }
@@ -1523,12 +1624,14 @@ char *serv_smtp_init(void)
        CtdlRegisterServiceHook(config.c_smtp_port,     /* On the net... */
                                NULL,
                                smtp_greeting,
-                               smtp_command_loop);
+                               smtp_command_loop,
+                               NULL);
 
        CtdlRegisterServiceHook(0,                      /* ...and locally */
                                "lmtp.socket",
                                lmtp_greeting,
-                               smtp_command_loop);
+                               smtp_command_loop,
+                               NULL);
 
        smtp_init_spoolout();
        CtdlRegisterSessionHook(smtp_do_queue, EVT_TIMER);