masqmail-0.2

annotate src/smtp_in.c @ 179:ec3fe72a3e99

find changesets by author, revision, files, or words in the commit message
Fixed an important bug with folded headers! g_strconcat() returns a *copy* of the string, but hdr->value still pointed to the old header (which probably was a memory leak, too). If the folded part had been quite small it was likely that the new string was at the same position as the old one, thus making everything go well. But if pretty long headers were folded several times it was likely that the new string was allocated somewhere else in memory, thus breaking things. In result mails to lots of recipients (folded header) were frequently only sent to the ones in the first line. Sorry for the inconvenience.
author meillo@marmaro.de
date Fri, 03 Jun 2011 09:52:17 +0200
parents b072426cc6bb
children
rev   line source
meillo@0 1 /* MasqMail
meillo@0 2 Copyright (C) 1999-2001 Oliver Kurth
meillo@80 3 Copyright (C) 2010 markus schnalke <meillo@marmaro.de>
meillo@0 4
meillo@0 5 This program is free software; you can redistribute it and/or modify
meillo@0 6 it under the terms of the GNU General Public License as published by
meillo@0 7 the Free Software Foundation; either version 2 of the License, or
meillo@0 8 (at your option) any later version.
meillo@0 9
meillo@0 10 This program is distributed in the hope that it will be useful,
meillo@0 11 but WITHOUT ANY WARRANTY; without even the implied warranty of
meillo@0 12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
meillo@0 13 GNU General Public License for more details.
meillo@0 14
meillo@0 15 You should have received a copy of the GNU General Public License
meillo@0 16 along with this program; if not, write to the Free Software
meillo@0 17 Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
meillo@0 18 */
meillo@0 19
meillo@0 20 #include "masqmail.h"
meillo@0 21 #include "readsock.h"
meillo@0 22
meillo@0 23 /*
meillo@0 24 I always forget these rfc numbers:
meillo@0 25 RFC 821 (SMTP)
meillo@0 26 RFC 1869 (ESMTP)
meillo@0 27 RFC 1870 (ESMTP SIZE)
meillo@0 28 RFC 2197 (ESMTP PIPELINE)
meillo@0 29 RFC 2554 (ESMTP AUTH)
meillo@0 30 */
meillo@0 31
meillo@0 32 #ifdef ENABLE_SMTP_SERVER
meillo@0 33
meillo@10 34 smtp_cmd smtp_cmds[] = {
meillo@15 35 {SMTP_HELO, "HELO",},
meillo@15 36 {SMTP_EHLO, "EHLO",},
meillo@15 37 {SMTP_MAIL_FROM, "MAIL FROM:",},
meillo@15 38 {SMTP_RCPT_TO, "RCPT TO:",},
meillo@15 39 {SMTP_DATA, "DATA",},
meillo@15 40 {SMTP_QUIT, "QUIT",},
meillo@15 41 {SMTP_RSET, "RSET",},
meillo@15 42 {SMTP_NOOP, "NOOP",},
meillo@15 43 {SMTP_HELP, "HELP"},
meillo@0 44 };
meillo@0 45
meillo@10 46 static smtp_cmd_id
meillo@10 47 get_id(const gchar * line)
meillo@0 48 {
meillo@10 49 gint i;
meillo@10 50 for (i = 0; i < SMTP_NUM_IDS; i++) {
meillo@80 51 if (strncasecmp(smtp_cmds[i].cmd, line, strlen(smtp_cmds[i].cmd)) == 0) {
meillo@10 52 return (smtp_cmd_id) i;
meillo@80 53 }
meillo@10 54 }
meillo@10 55 return SMTP_ERROR;
meillo@0 56 }
meillo@0 57
meillo@117 58 static gboolean
meillo@117 59 get_size(gchar *line, unsigned long *msize) {
meillo@117 60 gchar *s = NULL;
meillo@117 61
meillo@117 62 /* hope we need not to handle cases like SiZe= ...*/
meillo@117 63 s = strstr(line, "SIZE=");
meillo@117 64 if (!s) {
meillo@117 65 /* try it in lowercase too */
meillo@117 66 if (!(s = strstr(line, "size="))) {
meillo@117 67 return FALSE;
meillo@117 68 }
meillo@117 69 }
meillo@117 70 s += 5;
meillo@117 71 *msize = atol(s);
meillo@117 72 DEBUG(5) debugf("get_size(): line=%s, msize=%ld\n", line, *msize);
meillo@117 73
meillo@117 74 return TRUE;
meillo@117 75 }
meillo@117 76
meillo@117 77
meillo@0 78 /* this is a quick hack: we expect the address to be syntactically correct
meillo@117 79 and containing the mailbox only, though we first check for size in
meillo@117 80 smtp_in().
meillo@136 81 Return false if address is too long.
meillo@0 82 */
meillo@10 83 static gboolean
meillo@10 84 get_address(gchar * line, gchar * addr)
meillo@0 85 {
meillo@80 86 gchar *p = line;
meillo@80 87 gchar *q = addr;
meillo@0 88
meillo@10 89 /* skip MAIL FROM: and RCPT TO: */
meillo@80 90 while (*p && (*p != ':')) {
meillo@10 91 p++;
meillo@80 92 }
meillo@10 93 p++;
meillo@0 94
meillo@10 95 /* skip spaces: */
meillo@80 96 while (*p && isspace(*p)) {
meillo@10 97 p++;
meillo@80 98 }
meillo@0 99
meillo@10 100 /* get address: */
meillo@136 101 while (*p && !isspace(*p)) {
meillo@136 102 if (q >= addr + MAX_ADDRESS-1) {
meillo@136 103 *q = '\0';
meillo@136 104 return FALSE;
meillo@136 105 }
meillo@10 106 *(q++) = *(p++);
meillo@80 107 }
meillo@136 108 *q = '\0';
meillo@0 109
meillo@10 110 return TRUE;
meillo@0 111 }
meillo@0 112
meillo@10 113 static smtp_connection*
meillo@10 114 create_base(gchar * remote_host)
meillo@0 115 {
meillo@10 116 smtp_connection *base = g_malloc(sizeof(smtp_connection));
meillo@80 117 if (!base) {
meillo@80 118 return NULL;
meillo@80 119 }
meillo@0 120
meillo@80 121 base->remote_host = g_strdup(remote_host);
meillo@0 122
meillo@80 123 base->prot = PROT_SMTP;
meillo@80 124 base->next_id = 0;
meillo@80 125 base->helo_seen = 0;
meillo@80 126 base->from_seen = 0;
meillo@80 127 base->rcpt_seen = 0;
meillo@80 128 base->msg = NULL;
meillo@80 129
meillo@80 130 return base;
meillo@0 131 }
meillo@0 132
meillo@10 133 static void
meillo@10 134 smtp_printf(FILE * out, gchar * fmt, ...)
meillo@0 135 {
meillo@10 136 va_list args;
meillo@10 137 va_start(args, fmt);
meillo@0 138
meillo@10 139 DEBUG(4) {
meillo@10 140 gchar buf[256];
meillo@10 141 va_list args_copy;
meillo@0 142
meillo@10 143 va_copy(args_copy, args);
meillo@10 144 vsnprintf(buf, 255, fmt, args_copy);
meillo@10 145 va_end(args_copy);
meillo@0 146
meillo@10 147 debugf(">>>%s", buf);
meillo@10 148 }
meillo@0 149
meillo@10 150 vfprintf(out, fmt, args);
meillo@10 151 fflush(out);
meillo@0 152
meillo@10 153 va_end(args);
meillo@0 154 }
meillo@0 155
meillo@10 156 void
meillo@10 157 smtp_in(FILE * in, FILE * out, gchar * remote_host, gchar * ident)
meillo@0 158 {
meillo@10 159 gchar *buffer;
meillo@10 160 smtp_cmd_id cmd_id;
meillo@10 161 message *msg = NULL;
meillo@10 162 smtp_connection *psc;
meillo@10 163 int len;
meillo@117 164 unsigned long size, msize;
meillo@0 165
meillo@10 166 DEBUG(5) debugf("smtp_in entered, remote_host = %s\n", remote_host);
meillo@0 167
meillo@10 168 psc = create_base(remote_host);
meillo@10 169 psc->msg = msg;
meillo@0 170
meillo@10 171 buffer = (gchar *) g_malloc(BUF_LEN);
meillo@80 172 if (!buffer) {
meillo@80 173 /* this check is actually unneccessary as g_malloc()
meillo@80 174 aborts on failure */
meillo@80 175 return;
meillo@80 176 }
meillo@0 177
meillo@80 178 /* send greeting string, containing ESMTP: */
meillo@80 179 smtp_printf(out, "220 %s MasqMail %s ESMTP\r\n", conf.host_name, VERSION);
meillo@10 180
meillo@80 181 while ((len = read_sockline(in, buffer, BUF_LEN, 5 * 60, READSOCKL_CHUG)) >= 0) {
meillo@80 182 cmd_id = get_id(buffer);
meillo@10 183
meillo@135 184 if (conf.defer_all) {
meillo@135 185 /* I need this to debug delivery failures */
meillo@127 186 smtp_printf(out, "421 %s service temporarily unavailable.\r\n", conf.host_name);
meillo@135 187 destroy_message(msg);
meillo@135 188 msg = NULL;
meillo@135 189 return;
meillo@127 190 }
meillo@127 191
meillo@80 192 switch (cmd_id) {
meillo@127 193 case SMTP_HELO:
meillo@127 194 psc->prot = PROT_SMTP;
meillo@127 195 psc->helo_seen = TRUE;
meillo@127 196 smtp_printf(out, "250 %s pretty old mailer, huh?\r\n", conf.host_name);
meillo@127 197 break;
meillo@127 198
meillo@80 199 case SMTP_EHLO:
meillo@80 200 psc->prot = PROT_ESMTP;
meillo@80 201 psc->helo_seen = TRUE;
meillo@127 202 smtp_printf(out, "250-%s Nice to meet you with ESMTP\r\n", conf.host_name);
meillo@127 203 smtp_printf(out, "250-SIZE %d\r\n", conf.max_msg_size);
meillo@127 204 smtp_printf(out, "250-PIPELINING\r\n");
meillo@127 205 smtp_printf(out, "250 HELP\r\n");
meillo@10 206 break;
meillo@80 207
meillo@80 208 case SMTP_MAIL_FROM:
meillo@80 209 {
meillo@80 210 gchar buf[MAX_ADDRESS];
meillo@80 211 address *addr;
meillo@80 212
meillo@80 213 if (!psc->helo_seen) {
meillo@80 214 smtp_printf(out, "503 need HELO or EHLO\r\n");
meillo@80 215 break;
meillo@80 216 }
meillo@80 217 if (psc->from_seen) {
meillo@80 218 smtp_printf(out, "503 MAIL FROM: already given.\r\n");
meillo@80 219 break;
meillo@80 220 }
meillo@128 221 if (get_size(buffer, &msize)) {
meillo@128 222 DEBUG(5) debugf("smtp_in(): get_size: msize=%ld, conf.mms=%d\n",
meillo@128 223 msize, conf.max_msg_size);
meillo@128 224 if (conf.max_msg_size && (msize > conf.max_msg_size)) {
meillo@128 225 smtp_printf(out, "552 Message size exceeds fixed limit.\r\n");
meillo@128 226 break;
meillo@128 227 }
meillo@128 228 }
meillo@136 229 if (!get_address(buffer, buf)) {
meillo@136 230 smtp_printf(out, "553 Address too long.\r\n");
meillo@136 231 break;
meillo@136 232 }
meillo@128 233
meillo@80 234 msg = create_message();
meillo@80 235 msg->received_host = remote_host ? g_strdup(remote_host) : NULL;
meillo@80 236 msg->received_prot = psc->prot;
meillo@80 237 msg->ident = ident ? g_strdup(ident) : NULL;
meillo@80 238 /* get transfer id and increment for next one */
meillo@80 239 msg->transfer_id = (psc->next_id)++;
meillo@80 240
meillo@80 241 if (remote_host) {
meillo@80 242 addr = create_address(buf, TRUE);
meillo@80 243 } else {
meillo@80 244 addr = create_address_qualified(buf, TRUE, conf.host_name);
meillo@80 245 }
meillo@80 246 if (!addr) {
meillo@80 247 smtp_printf(out, "501 %s: syntax error.\r\n", buf);
meillo@80 248 } else if (!addr->domain) {
meillo@80 249 smtp_printf(out, "501 return path must be qualified.\r\n", buf);
meillo@80 250 } else {
meillo@80 251 psc->from_seen = TRUE;
meillo@80 252 msg->return_path = addr;
meillo@80 253 smtp_printf(out, "250 OK %s is a nice guy.\r\n", addr->address);
meillo@80 254 }
meillo@80 255 }
meillo@10 256 break;
meillo@80 257
meillo@80 258 case SMTP_RCPT_TO:
meillo@80 259 {
meillo@80 260 char buf[MAX_ADDRESS];
meillo@80 261 address *addr;
meillo@80 262
meillo@80 263 if (!psc->helo_seen) {
meillo@80 264 smtp_printf(out, "503 need HELO or EHLO.\r\n");
meillo@80 265 break;
meillo@80 266 }
meillo@80 267 if (!psc->from_seen) {
meillo@80 268 smtp_printf(out, "503 need MAIL FROM: before RCPT TO:\r\n");
meillo@80 269 break;
meillo@80 270 }
meillo@136 271 if (!get_address(buffer, buf)) {
meillo@136 272 smtp_printf(out, "553 Address too long.\r\n");
meillo@136 273 break;
meillo@136 274 }
meillo@80 275
meillo@80 276 if (remote_host) {
meillo@80 277 addr = create_address(buf, TRUE);
meillo@80 278 } else {
meillo@80 279 addr = create_address_qualified(buf, TRUE, conf.host_name);
meillo@80 280 }
meillo@80 281 if (!addr) {
meillo@80 282 smtp_printf(out, "501 %s: syntax error in address.\r\n", buf);
meillo@80 283 break;
meillo@80 284 }
meillo@80 285 if (addr->local_part[0] == '|') {
meillo@80 286 smtp_printf(out, "501 %s: no pipe allowed for SMTP connections\r\n", buf);
meillo@80 287 break;
meillo@80 288 }
meillo@80 289 if (!addr->domain) {
meillo@80 290 smtp_printf(out, "501 recipient address must be qualified.\r\n", buf);
meillo@80 291 break;
meillo@80 292 }
meillo@80 293 gboolean do_relay = conf.do_relay;
meillo@80 294 if (!do_relay) {
meillo@80 295 do_relay = addr_is_local(msg->return_path);
meillo@80 296 if (!do_relay) {
meillo@80 297 do_relay = addr_is_local(addr);
meillo@80 298 }
meillo@80 299 }
meillo@80 300 if (!do_relay) {
meillo@80 301 smtp_printf(out, "550 relaying to %s denied.\r\n", addr_string(addr));
meillo@80 302 break;
meillo@80 303 }
meillo@80 304 psc->rcpt_seen = TRUE;
meillo@80 305 msg->rcpt_list = g_list_append(msg->rcpt_list, addr);
meillo@80 306 smtp_printf(out, "250 OK %s is our friend.\r\n", addr->address);
meillo@80 307 }
meillo@10 308 break;
meillo@80 309
meillo@80 310 case SMTP_DATA:
meillo@80 311 if (!psc->helo_seen) {
meillo@80 312 smtp_printf(out, "503 need HELO or EHLO.\r\n");
meillo@80 313 break;
meillo@80 314 }
meillo@80 315 if (!psc->rcpt_seen) {
meillo@80 316 smtp_printf(out, "503 need RCPT TO: before DATA\r\n");
meillo@80 317 break;
meillo@80 318 }
meillo@80 319 accept_error err;
meillo@80 320
meillo@80 321 smtp_printf(out, "354 okay, and do not forget the dot\r\n");
meillo@80 322
meillo@80 323 err = accept_message(in, msg, conf.do_save_envelope_to ? ACC_SAVE_ENVELOPE_TO : 0);
meillo@80 324 if (err != AERR_OK) {
meillo@117 325 switch (err) {
meillo@117 326 case AERR_TIMEOUT:
meillo@117 327 case AERR_EOF:
meillo@117 328 return;
meillo@117 329 case AERR_SIZE:
meillo@117 330 smtp_printf(out, "552 Error: message too large.\r\n");
meillo@117 331 return;
meillo@117 332 default:
meillo@117 333 /* should never happen: */
meillo@117 334 smtp_printf(out, "451 Unknown error\r\n");
meillo@80 335 return;
meillo@80 336 }
meillo@80 337 }
meillo@80 338
meillo@80 339
meillo@80 340 if (!spool_write(msg, TRUE)) {
meillo@80 341 smtp_printf(out, "451 Could not write spool file\r\n");
meillo@80 342 return;
meillo@80 343 }
meillo@80 344 pid_t pid;
meillo@80 345 smtp_printf(out, "250 OK id=%s\r\n", msg->uid);
meillo@80 346
meillo@80 347 if (remote_host != NULL) {
meillo@80 348 logwrite(LOG_NOTICE, "%s <= <%s@%s> host=%s with %s\n", msg->uid,
meillo@80 349 msg->return_path->local_part, msg->return_path->domain,
meillo@80 350 remote_host, prot_names[psc->prot]);
meillo@80 351 } else {
meillo@80 352 logwrite(LOG_NOTICE, "%s <= <%s@%s> with %s\n", msg->uid,
meillo@80 353 msg->return_path->local_part, msg->return_path->domain,
meillo@80 354 prot_names[psc->prot]);
meillo@80 355 }
meillo@80 356
meillo@80 357 if (conf.do_queue) {
meillo@80 358 DEBUG(1) debugf("queuing forced by configuration or option.\n");
meillo@80 359 } else {
meillo@80 360 pid = fork();
meillo@80 361 if (pid == 0) {
meillo@80 362 _exit(deliver(msg));
meillo@80 363 } else if (pid < 0) {
meillo@80 364 logwrite(LOG_ALERT, "could not fork for delivery, id = %s", msg->uid);
meillo@80 365 }
meillo@80 366 }
meillo@80 367 psc->rcpt_seen = psc->from_seen = FALSE;
meillo@80 368 destroy_message(msg);
meillo@80 369 msg = NULL;
meillo@80 370 break;
meillo@80 371
meillo@80 372 case SMTP_QUIT:
meillo@80 373 smtp_printf(out, "221 goodbye\r\n");
meillo@81 374 destroy_message(msg);
meillo@81 375 msg = NULL;
meillo@80 376 return;
meillo@80 377
meillo@80 378 case SMTP_RSET:
meillo@80 379 psc->from_seen = psc->rcpt_seen = FALSE;
meillo@81 380 destroy_message(msg);
meillo@81 381 msg = NULL;
meillo@80 382 smtp_printf(out, "250 OK\r\n");
meillo@80 383 break;
meillo@80 384
meillo@80 385 case SMTP_NOOP:
meillo@80 386 smtp_printf(out, "250 OK\r\n");
meillo@80 387 break;
meillo@80 388
meillo@80 389 case SMTP_HELP:
meillo@80 390 {
meillo@80 391 int i;
meillo@80 392
meillo@80 393 smtp_printf(out, "214-supported commands:\r\n");
meillo@80 394 for (i = 0; i < SMTP_NUM_IDS - 1; i++) {
meillo@80 395 smtp_printf(out, "214-%s\r\n", smtp_cmds[i].cmd);
meillo@80 396 }
meillo@80 397 smtp_printf(out, "214 %s\r\n", smtp_cmds[i].cmd);
meillo@80 398 }
meillo@80 399 break;
meillo@80 400
meillo@10 401 default:
meillo@80 402 smtp_printf(out, "501 command not recognized\r\n");
meillo@80 403 DEBUG(1) debugf("command not recognized, was '%s'\n", buffer);
meillo@10 404 break;
meillo@10 405 }
meillo@0 406 }
meillo@80 407 switch (len) {
meillo@80 408 case -3:
meillo@80 409 logwrite(LOG_NOTICE, "connection timed out\n");
meillo@80 410 break;
meillo@80 411 case -2:
meillo@80 412 logwrite(LOG_NOTICE, "line overflow\n");
meillo@80 413 break;
meillo@80 414 case -1:
meillo@80 415 logwrite(LOG_NOTICE, "received EOF\n");
meillo@80 416 break;
meillo@80 417 default:
meillo@80 418 break;
meillo@80 419 }
meillo@0 420 }
meillo@0 421 #endif