meillo@0: /* MasqMail meillo@0: Copyright (C) 1999-2001 Oliver Kurth meillo@80: Copyright (C) 2010 markus schnalke meillo@0: meillo@0: This program is free software; you can redistribute it and/or modify meillo@0: it under the terms of the GNU General Public License as published by meillo@0: the Free Software Foundation; either version 2 of the License, or meillo@0: (at your option) any later version. meillo@0: meillo@0: This program is distributed in the hope that it will be useful, meillo@0: but WITHOUT ANY WARRANTY; without even the implied warranty of meillo@0: MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the meillo@0: GNU General Public License for more details. meillo@0: meillo@0: You should have received a copy of the GNU General Public License meillo@0: along with this program; if not, write to the Free Software meillo@0: Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. meillo@0: */ meillo@0: meillo@0: #include "masqmail.h" meillo@0: #include "readsock.h" meillo@0: meillo@0: /* meillo@0: I always forget these rfc numbers: meillo@0: RFC 821 (SMTP) meillo@0: RFC 1869 (ESMTP) meillo@0: RFC 1870 (ESMTP SIZE) meillo@0: RFC 2197 (ESMTP PIPELINE) meillo@0: RFC 2554 (ESMTP AUTH) meillo@0: */ meillo@0: meillo@0: #ifdef ENABLE_SMTP_SERVER meillo@0: meillo@10: smtp_cmd smtp_cmds[] = { meillo@15: {SMTP_HELO, "HELO",}, meillo@15: {SMTP_EHLO, "EHLO",}, meillo@15: {SMTP_MAIL_FROM, "MAIL FROM:",}, meillo@15: {SMTP_RCPT_TO, "RCPT TO:",}, meillo@15: {SMTP_DATA, "DATA",}, meillo@15: {SMTP_QUIT, "QUIT",}, meillo@15: {SMTP_RSET, "RSET",}, meillo@15: {SMTP_NOOP, "NOOP",}, meillo@15: {SMTP_HELP, "HELP"}, meillo@0: }; meillo@0: meillo@10: static smtp_cmd_id meillo@10: get_id(const gchar * line) meillo@0: { meillo@10: gint i; meillo@10: for (i = 0; i < SMTP_NUM_IDS; i++) { meillo@80: if (strncasecmp(smtp_cmds[i].cmd, line, strlen(smtp_cmds[i].cmd)) == 0) { meillo@10: return (smtp_cmd_id) i; meillo@80: } meillo@10: } meillo@10: return SMTP_ERROR; meillo@0: } meillo@0: meillo@117: static gboolean meillo@117: get_size(gchar *line, unsigned long *msize) { meillo@117: gchar *s = NULL; meillo@117: meillo@117: /* hope we need not to handle cases like SiZe= ...*/ meillo@117: s = strstr(line, "SIZE="); meillo@117: if (!s) { meillo@117: /* try it in lowercase too */ meillo@117: if (!(s = strstr(line, "size="))) { meillo@117: return FALSE; meillo@117: } meillo@117: } meillo@117: s += 5; meillo@117: *msize = atol(s); meillo@117: DEBUG(5) debugf("get_size(): line=%s, msize=%ld\n", line, *msize); meillo@117: meillo@117: return TRUE; meillo@117: } meillo@117: meillo@117: meillo@0: /* this is a quick hack: we expect the address to be syntactically correct meillo@117: and containing the mailbox only, though we first check for size in meillo@117: smtp_in(). meillo@0: */ meillo@10: static gboolean meillo@10: get_address(gchar * line, gchar * addr) meillo@0: { meillo@80: gchar *p = line; meillo@80: gchar *q = addr; meillo@0: meillo@10: /* skip MAIL FROM: and RCPT TO: */ meillo@80: while (*p && (*p != ':')) { meillo@10: p++; meillo@80: } meillo@10: p++; meillo@0: meillo@10: /* skip spaces: */ meillo@80: while (*p && isspace(*p)) { meillo@10: p++; meillo@80: } meillo@0: meillo@10: /* get address: */ meillo@80: while (*p && !isspace(*p) && (q < addr + MAX_ADDRESS - 1)) { meillo@10: *(q++) = *(p++); meillo@80: } meillo@10: *q = 0; meillo@0: meillo@10: return TRUE; meillo@0: } meillo@0: meillo@10: static smtp_connection* meillo@10: create_base(gchar * remote_host) meillo@0: { meillo@10: smtp_connection *base = g_malloc(sizeof(smtp_connection)); meillo@80: if (!base) { meillo@80: return NULL; meillo@80: } meillo@0: meillo@80: base->remote_host = g_strdup(remote_host); meillo@0: meillo@80: base->prot = PROT_SMTP; meillo@80: base->next_id = 0; meillo@80: base->helo_seen = 0; meillo@80: base->from_seen = 0; meillo@80: base->rcpt_seen = 0; meillo@80: base->msg = NULL; meillo@80: meillo@80: return base; meillo@0: } meillo@0: meillo@10: static void meillo@10: smtp_printf(FILE * out, gchar * fmt, ...) meillo@0: { meillo@10: va_list args; meillo@10: va_start(args, fmt); meillo@0: meillo@10: DEBUG(4) { meillo@10: gchar buf[256]; meillo@10: va_list args_copy; meillo@0: meillo@10: va_copy(args_copy, args); meillo@10: vsnprintf(buf, 255, fmt, args_copy); meillo@10: va_end(args_copy); meillo@0: meillo@10: debugf(">>>%s", buf); meillo@10: } meillo@0: meillo@10: vfprintf(out, fmt, args); meillo@10: fflush(out); meillo@0: meillo@10: va_end(args); meillo@0: } meillo@0: meillo@10: void meillo@10: smtp_in(FILE * in, FILE * out, gchar * remote_host, gchar * ident) meillo@0: { meillo@10: gchar *buffer; meillo@10: smtp_cmd_id cmd_id; meillo@10: message *msg = NULL; meillo@10: smtp_connection *psc; meillo@10: int len; meillo@117: unsigned long size, msize; meillo@0: meillo@10: DEBUG(5) debugf("smtp_in entered, remote_host = %s\n", remote_host); meillo@0: meillo@10: psc = create_base(remote_host); meillo@10: psc->msg = msg; meillo@0: meillo@10: buffer = (gchar *) g_malloc(BUF_LEN); meillo@80: if (!buffer) { meillo@80: /* this check is actually unneccessary as g_malloc() meillo@80: aborts on failure */ meillo@80: return; meillo@80: } meillo@0: meillo@80: /* send greeting string, containing ESMTP: */ meillo@80: smtp_printf(out, "220 %s MasqMail %s ESMTP\r\n", conf.host_name, VERSION); meillo@10: meillo@80: while ((len = read_sockline(in, buffer, BUF_LEN, 5 * 60, READSOCKL_CHUG)) >= 0) { meillo@80: cmd_id = get_id(buffer); meillo@10: meillo@80: switch (cmd_id) { meillo@80: case SMTP_EHLO: meillo@80: psc->prot = PROT_ESMTP; meillo@80: /* fall through */ meillo@80: case SMTP_HELO: meillo@80: psc->helo_seen = TRUE; meillo@10: meillo@80: if (conf.defer_all) { /* I need this to debug delivery failures */ meillo@80: smtp_printf(out, "421 %s service temporarily unavailable.\r\n", conf.host_name); meillo@10: break; meillo@10: } meillo@80: meillo@80: if (psc->prot == PROT_ESMTP) { meillo@80: smtp_printf(out, "250-%s Nice to meet you with ESMTP\r\n", conf.host_name); meillo@117: smtp_printf(out, "250-SIZE %d\r\n", conf.max_msg_size); meillo@80: smtp_printf(out, "250-PIPELINING\r\n" "250 HELP\r\n"); meillo@80: } else { meillo@80: smtp_printf(out, "250 %s pretty old mailer, huh?\r\n", conf.host_name); meillo@80: } meillo@10: break; meillo@80: meillo@80: case SMTP_MAIL_FROM: meillo@117: if (get_size(buffer, &msize)) { meillo@117: DEBUG(5) debugf("smtp_in(): get_size: msize=%ld, conf.mms=%d\n", meillo@117: msize, conf.max_msg_size); meillo@117: if (msize > conf.max_msg_size) { meillo@117: smtp_printf(out, "552 Message size exceeds fixed limit.\r\n"); meillo@117: break; meillo@117: } meillo@117: } meillo@117: meillo@80: { meillo@80: gchar buf[MAX_ADDRESS]; meillo@80: address *addr; meillo@80: meillo@80: if (!psc->helo_seen) { meillo@80: smtp_printf(out, "503 need HELO or EHLO\r\n"); meillo@80: break; meillo@80: } meillo@80: if (psc->from_seen) { meillo@80: smtp_printf(out, "503 MAIL FROM: already given.\r\n"); meillo@80: break; meillo@80: } meillo@80: meillo@80: msg = create_message(); meillo@80: msg->received_host = remote_host ? g_strdup(remote_host) : NULL; meillo@80: msg->received_prot = psc->prot; meillo@80: msg->ident = ident ? g_strdup(ident) : NULL; meillo@80: /* get transfer id and increment for next one */ meillo@80: msg->transfer_id = (psc->next_id)++; meillo@80: meillo@80: get_address(buffer, buf); meillo@80: if (remote_host) { meillo@80: addr = create_address(buf, TRUE); meillo@80: } else { meillo@80: addr = create_address_qualified(buf, TRUE, conf.host_name); meillo@80: } meillo@80: if (!addr) { meillo@80: smtp_printf(out, "501 %s: syntax error.\r\n", buf); meillo@80: } else if (!addr->domain) { meillo@80: smtp_printf(out, "501 return path must be qualified.\r\n", buf); meillo@80: } else { meillo@80: psc->from_seen = TRUE; meillo@80: msg->return_path = addr; meillo@80: smtp_printf(out, "250 OK %s is a nice guy.\r\n", addr->address); meillo@80: } meillo@80: } meillo@10: break; meillo@80: meillo@80: case SMTP_RCPT_TO: meillo@80: { meillo@80: char buf[MAX_ADDRESS]; meillo@80: address *addr; meillo@80: meillo@80: if (!psc->helo_seen) { meillo@80: smtp_printf(out, "503 need HELO or EHLO.\r\n"); meillo@80: break; meillo@80: } meillo@80: if (!psc->from_seen) { meillo@80: smtp_printf(out, "503 need MAIL FROM: before RCPT TO:\r\n"); meillo@80: break; meillo@80: } meillo@80: meillo@80: get_address(buffer, buf); meillo@80: if (remote_host) { meillo@80: addr = create_address(buf, TRUE); meillo@80: } else { meillo@80: addr = create_address_qualified(buf, TRUE, conf.host_name); meillo@80: } meillo@80: if (!addr) { meillo@80: smtp_printf(out, "501 %s: syntax error in address.\r\n", buf); meillo@80: break; meillo@80: } meillo@80: if (addr->local_part[0] == '|') { meillo@80: smtp_printf(out, "501 %s: no pipe allowed for SMTP connections\r\n", buf); meillo@80: break; meillo@80: } meillo@80: if (!addr->domain) { meillo@80: smtp_printf(out, "501 recipient address must be qualified.\r\n", buf); meillo@80: break; meillo@80: } meillo@80: gboolean do_relay = conf.do_relay; meillo@80: if (!do_relay) { meillo@80: do_relay = addr_is_local(msg->return_path); meillo@80: if (!do_relay) { meillo@80: do_relay = addr_is_local(addr); meillo@80: } meillo@80: } meillo@80: if (!do_relay) { meillo@80: smtp_printf(out, "550 relaying to %s denied.\r\n", addr_string(addr)); meillo@80: break; meillo@80: } meillo@80: psc->rcpt_seen = TRUE; meillo@80: msg->rcpt_list = g_list_append(msg->rcpt_list, addr); meillo@80: smtp_printf(out, "250 OK %s is our friend.\r\n", addr->address); meillo@80: } meillo@10: break; meillo@80: meillo@80: case SMTP_DATA: meillo@80: if (!psc->helo_seen) { meillo@80: smtp_printf(out, "503 need HELO or EHLO.\r\n"); meillo@80: break; meillo@80: } meillo@80: if (!psc->rcpt_seen) { meillo@80: smtp_printf(out, "503 need RCPT TO: before DATA\r\n"); meillo@80: break; meillo@80: } meillo@80: accept_error err; meillo@80: meillo@80: smtp_printf(out, "354 okay, and do not forget the dot\r\n"); meillo@80: meillo@80: err = accept_message(in, msg, conf.do_save_envelope_to ? ACC_SAVE_ENVELOPE_TO : 0); meillo@80: if (err != AERR_OK) { meillo@117: switch (err) { meillo@117: case AERR_TIMEOUT: meillo@117: case AERR_EOF: meillo@117: return; meillo@117: case AERR_SIZE: meillo@117: smtp_printf(out, "552 Error: message too large.\r\n"); meillo@117: return; meillo@117: default: meillo@117: /* should never happen: */ meillo@117: smtp_printf(out, "451 Unknown error\r\n"); meillo@80: return; meillo@80: } meillo@80: } meillo@80: meillo@80: meillo@80: if (!spool_write(msg, TRUE)) { meillo@80: smtp_printf(out, "451 Could not write spool file\r\n"); meillo@80: return; meillo@80: } meillo@80: pid_t pid; meillo@80: smtp_printf(out, "250 OK id=%s\r\n", msg->uid); meillo@80: meillo@80: if (remote_host != NULL) { meillo@80: logwrite(LOG_NOTICE, "%s <= <%s@%s> host=%s with %s\n", msg->uid, meillo@80: msg->return_path->local_part, msg->return_path->domain, meillo@80: remote_host, prot_names[psc->prot]); meillo@80: } else { meillo@80: logwrite(LOG_NOTICE, "%s <= <%s@%s> with %s\n", msg->uid, meillo@80: msg->return_path->local_part, msg->return_path->domain, meillo@80: prot_names[psc->prot]); meillo@80: } meillo@80: meillo@80: if (conf.do_queue) { meillo@80: DEBUG(1) debugf("queuing forced by configuration or option.\n"); meillo@80: } else { meillo@80: pid = fork(); meillo@80: if (pid == 0) { meillo@80: _exit(deliver(msg)); meillo@80: } else if (pid < 0) { meillo@80: logwrite(LOG_ALERT, "could not fork for delivery, id = %s", msg->uid); meillo@80: } meillo@80: } meillo@80: psc->rcpt_seen = psc->from_seen = FALSE; meillo@80: destroy_message(msg); meillo@80: msg = NULL; meillo@80: break; meillo@80: meillo@80: case SMTP_QUIT: meillo@80: smtp_printf(out, "221 goodbye\r\n"); meillo@81: destroy_message(msg); meillo@81: msg = NULL; meillo@80: return; meillo@80: meillo@80: case SMTP_RSET: meillo@80: psc->from_seen = psc->rcpt_seen = FALSE; meillo@81: destroy_message(msg); meillo@81: msg = NULL; meillo@80: smtp_printf(out, "250 OK\r\n"); meillo@80: break; meillo@80: meillo@80: case SMTP_NOOP: meillo@80: smtp_printf(out, "250 OK\r\n"); meillo@80: break; meillo@80: meillo@80: case SMTP_HELP: meillo@80: { meillo@80: int i; meillo@80: meillo@80: smtp_printf(out, "214-supported commands:\r\n"); meillo@80: for (i = 0; i < SMTP_NUM_IDS - 1; i++) { meillo@80: smtp_printf(out, "214-%s\r\n", smtp_cmds[i].cmd); meillo@80: } meillo@80: smtp_printf(out, "214 %s\r\n", smtp_cmds[i].cmd); meillo@80: } meillo@80: break; meillo@80: meillo@10: default: meillo@80: smtp_printf(out, "501 command not recognized\r\n"); meillo@80: DEBUG(1) debugf("command not recognized, was '%s'\n", buffer); meillo@10: break; meillo@10: } meillo@0: } meillo@80: switch (len) { meillo@80: case -3: meillo@80: logwrite(LOG_NOTICE, "connection timed out\n"); meillo@80: break; meillo@80: case -2: meillo@80: logwrite(LOG_NOTICE, "line overflow\n"); meillo@80: break; meillo@80: case -1: meillo@80: logwrite(LOG_NOTICE, "received EOF\n"); meillo@80: break; meillo@80: default: meillo@80: break; meillo@80: } meillo@0: } meillo@0: #endif