masqmail

annotate src/smtp_out.c @ 366:41958685480d

find changesets by author, revision, files, or words in the commit message
Switched to `type *name' style Andrew Koenig's ``C Traps and Pitfalls'' (Ch.2.1) convinced me that it is best to go with the way C had been designed. The ``declaration reflects use'' concept conflicts with a ``type* name'' notation. Hence I switched.
author markus schnalke <meillo@marmaro.de>
date Thu, 22 Sep 2011 15:07:40 +0200
parents 02bc0331e390
children b27f66555ba8
rev   line source
meillo@224 1 /* smtp_out.c
meillo@224 2 Copyright (C) 1999-2001 Oliver Kurth
meillo@224 3 Copyright (C) 2010 markus schnalke <meillo@marmaro.de>
meillo@224 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@10 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., 675 Mass Ave, Cambridge, MA 02139, USA.
meillo@0 18 */
meillo@0 19
meillo@0 20 /*
meillo@0 21 I always forget these rfc numbers:
meillo@0 22 RFC 821 (SMTP)
meillo@0 23 RFC 1869 (ESMTP)
meillo@0 24 RFC 1870 (ESMTP SIZE)
meillo@0 25 RFC 2197 (ESMTP PIPELINE)
meillo@0 26 RFC 2554 (ESMTP AUTH)
meillo@0 27 */
meillo@0 28
meillo@0 29 #include "masqmail.h"
meillo@0 30 #include "smtp_out.h"
meillo@0 31 #include "readsock.h"
meillo@0 32
meillo@0 33 #ifdef ENABLE_AUTH
meillo@0 34 #include "md5/md5.h"
meillo@0 35 #include "md5/hmac_md5.h"
meillo@0 36 #include "base64/base64.h"
meillo@0 37 #endif
meillo@0 38
meillo@10 39 void
meillo@366 40 destroy_smtpbase(smtp_base *psb)
meillo@0 41 {
meillo@10 42 fclose(psb->in);
meillo@10 43 fclose(psb->out);
meillo@0 44
meillo@10 45 close(psb->sock);
meillo@0 46
meillo@10 47 if (psb->helo_name)
meillo@10 48 g_free(psb->helo_name);
meillo@10 49 if (psb->buffer)
meillo@10 50 g_free(psb->buffer);
meillo@10 51 if (psb->auth_names)
meillo@10 52 g_strfreev(psb->auth_names);
meillo@0 53
meillo@10 54 if (psb->auth_name)
meillo@10 55 g_free(psb->auth_name);
meillo@10 56 if (psb->auth_login)
meillo@10 57 g_free(psb->auth_login);
meillo@10 58 if (psb->auth_secret)
meillo@10 59 g_free(psb->auth_secret);
meillo@0 60 }
meillo@0 61
meillo@10 62 gchar*
meillo@366 63 set_heloname(smtp_base *psb, gchar *default_name, gboolean do_correct)
meillo@0 64 {
meillo@10 65 struct sockaddr_in sname;
meillo@10 66 int len = sizeof(struct sockaddr_in);
meillo@10 67 struct hostent *host_entry;
meillo@0 68
meillo@10 69 if (do_correct) {
meillo@10 70 getsockname(psb->sock, (struct sockaddr *) (&sname), &len);
meillo@10 71 DEBUG(5) debugf("socket: name.sin_addr = %s\n", inet_ntoa(sname.sin_addr));
meillo@10 72 host_entry = gethostbyaddr((const char *) &(sname.sin_addr), sizeof(sname.sin_addr), AF_INET);
meillo@10 73 if (host_entry) {
meillo@10 74 psb->helo_name = g_strdup(host_entry->h_name);
meillo@10 75 } else {
meillo@10 76 /* we failed to look up our own name. Instead of giving our local hostname,
meillo@10 77 we may give our IP number to show the server that we are at least
meillo@10 78 willing to be honest. For the really picky ones. */
meillo@10 79 DEBUG(5) debugf("failed to look up own host name.\n");
meillo@10 80 psb->helo_name = g_strdup_printf("[%s]", inet_ntoa(sname.sin_addr));
meillo@10 81 }
meillo@10 82 DEBUG(5) debugf("helo_name = %s\n", psb->helo_name);
meillo@10 83 }
meillo@10 84 if (psb->helo_name == NULL) {
meillo@10 85 psb->helo_name = g_strdup(default_name);
meillo@10 86 }
meillo@10 87 return psb->helo_name;
meillo@10 88 }
meillo@0 89
meillo@0 90 #ifdef ENABLE_AUTH
meillo@0 91
meillo@10 92 gboolean
meillo@366 93 set_auth(smtp_base *psb, gchar *name, gchar *login, gchar *secret)
meillo@0 94 {
meillo@10 95 if ((strcasecmp(name, "CRAM-MD5") == 0) || (strcasecmp(name, "LOGIN") == 0)) {
meillo@10 96 psb->auth_name = g_strdup(name);
meillo@10 97 psb->auth_login = g_strdup(login);
meillo@10 98 psb->auth_secret = g_strdup(secret);
meillo@10 99
meillo@10 100 return TRUE;
meillo@10 101 }
meillo@10 102 return FALSE;
meillo@0 103 }
meillo@0 104
meillo@0 105 #endif
meillo@0 106
meillo@10 107 static smtp_base*
meillo@10 108 create_smtpbase(gint sock)
meillo@0 109 {
meillo@10 110 gint dup_sock;
meillo@0 111
meillo@10 112 smtp_base *psb = (smtp_base *) g_malloc(sizeof(smtp_base));
meillo@0 113
meillo@10 114 psb->sock = sock;
meillo@0 115
meillo@10 116 psb->use_size = FALSE;
meillo@10 117 psb->use_pipelining = FALSE;
meillo@10 118 psb->use_auth = FALSE;
meillo@0 119
meillo@10 120 psb->max_size = 0;
meillo@10 121 psb->auth_names = NULL;
meillo@0 122
meillo@10 123 psb->buffer = (gchar *) g_malloc(SMTP_BUF_LEN);
meillo@0 124
meillo@10 125 dup_sock = dup(sock);
meillo@10 126 psb->out = fdopen(sock, "w");
meillo@10 127 psb->in = fdopen(dup_sock, "r");
meillo@0 128
meillo@10 129 psb->error = smtp_ok;
meillo@0 130
meillo@10 131 psb->helo_name = NULL;
meillo@0 132
meillo@10 133 psb->auth_name = psb->auth_login = psb->auth_secret = NULL;
meillo@10 134
meillo@10 135 return psb;
meillo@0 136 }
meillo@0 137
meillo@10 138 static gboolean
meillo@366 139 read_response(smtp_base *psb, int timeout)
meillo@0 140 {
meillo@10 141 gint buf_pos = 0;
meillo@10 142 gchar code[5];
meillo@10 143 gint i, len;
meillo@0 144
meillo@10 145 do {
meillo@10 146 len = read_sockline(psb->in, &(psb->buffer[buf_pos]), SMTP_BUF_LEN - buf_pos, timeout, READSOCKL_CHUG);
meillo@10 147 if (len == -3) {
meillo@10 148 psb->error = smtp_timeout;
meillo@10 149 return FALSE;
meillo@10 150 } else if (len == -2) {
meillo@10 151 psb->error = smtp_syntax;
meillo@10 152 return FALSE;
meillo@10 153 } else if (len == -1) {
meillo@10 154 psb->error = smtp_eof;
meillo@10 155 return FALSE;
meillo@10 156 }
meillo@10 157 for (i = 0; i < 4; i++)
meillo@10 158 code[i] = psb->buffer[buf_pos + i];
meillo@15 159 code[i] = '\0';
meillo@10 160 psb->last_code = atoi(code);
meillo@0 161
meillo@10 162 buf_pos += len;
meillo@0 163
meillo@10 164 } while (code[3] == '-');
meillo@177 165 if (psb->buffer) {
meillo@177 166 DEBUG(4) debugf("S: %s\n", psb->buffer);
meillo@177 167 }
meillo@0 168
meillo@10 169 return TRUE;
meillo@0 170 }
meillo@0 171
meillo@10 172 static gboolean
meillo@366 173 check_response(smtp_base *psb, gboolean after_data)
meillo@0 174 {
meillo@10 175 char c = psb->buffer[0];
meillo@0 176
meillo@10 177 if (((c == '2') && !after_data) || ((c == '3') && after_data)) {
meillo@10 178 psb->error = smtp_ok;
meillo@176 179 DEBUG(6) debugf("response OK:'%s' after_data = %d\n", psb->buffer, (int) after_data);
meillo@10 180 return TRUE;
meillo@10 181 } else {
meillo@10 182 if (c == '4')
meillo@10 183 psb->error = smtp_trylater;
meillo@10 184 else if (c == '5')
meillo@10 185 psb->error = smtp_fail;
meillo@10 186 else
meillo@10 187 psb->error = smtp_syntax;
meillo@176 188 DEBUG(6) debugf("response failure:'%s' after_data = %d\n", psb->buffer, (int) after_data);
meillo@10 189 return FALSE;
meillo@10 190 }
meillo@0 191 }
meillo@0 192
meillo@10 193 static gchar*
meillo@366 194 get_response_arg(gchar *response)
meillo@0 195 {
meillo@10 196 gchar buf[SMTP_BUF_LEN];
meillo@10 197 gchar *p = response, *q = buf;
meillo@0 198
meillo@10 199 while (*p && (*p != '\n') && isspace(*p))
meillo@10 200 p++;
meillo@10 201 if (*p && (*p != '\n')) {
meillo@10 202 while (*p && (*p != '\n') && (*p != '\r') && (q < buf + SMTP_BUF_LEN - 1))
meillo@10 203 *(q++) = *(p++);
meillo@15 204 *q = '\0';
meillo@10 205 return g_strdup(buf);
meillo@10 206 }
meillo@10 207 return NULL;
meillo@0 208 }
meillo@0 209
meillo@10 210 static gboolean
meillo@366 211 check_helo_response(smtp_base *psb)
meillo@0 212 {
meillo@222 213 gchar *ptr;
meillo@0 214
meillo@10 215 if (!check_response(psb, FALSE))
meillo@10 216 return FALSE;
meillo@0 217
meillo@222 218 if (psb->last_code == 220) {
meillo@222 219 logwrite(LOG_NOTICE, "received a 220 greeting after sending EHLO,\n");
meillo@222 220 logwrite(LOG_NOTICE, "please remove `instant_helo' from your route config\n");
meillo@222 221 /* read the next response, cause that's the actual helo response */
meillo@222 222 if (!read_response(psb, SMTP_CMD_TIMEOUT) || !check_response(psb, FALSE)) {
meillo@222 223 return FALSE;
meillo@222 224 }
meillo@222 225 }
meillo@222 226
meillo@222 227 ptr = psb->buffer;
meillo@222 228
meillo@10 229 while (*ptr) {
meillo@10 230 if (strncasecmp(&(ptr[4]), "SIZE", 4) == 0) {
meillo@10 231 gchar *arg;
meillo@10 232 psb->use_size = TRUE;
meillo@10 233 arg = get_response_arg(&(ptr[8]));
meillo@10 234 if (arg) {
meillo@10 235 psb->max_size = atoi(arg);
meillo@10 236 g_free(arg);
meillo@10 237 }
meillo@10 238 }
meillo@0 239
meillo@10 240 if (strncasecmp(&(ptr[4]), "PIPELINING", 10) == 0)
meillo@10 241 psb->use_pipelining = TRUE;
meillo@0 242
meillo@10 243 if (strncasecmp(&(ptr[4]), "AUTH", 4) == 0) {
meillo@10 244 if ((ptr[8] == ' ') || (ptr[8] == '=') || (ptr[8] == '\t')) { /* not sure about '\t' */
meillo@10 245 gchar *arg;
meillo@10 246 psb->use_auth = TRUE;
meillo@10 247 arg = get_response_arg(&(ptr[9])); /* after several years I finally learnt to count */
meillo@10 248 if (arg) {
meillo@10 249 psb->auth_names = g_strsplit(arg, " ", 0);
meillo@10 250 g_free(arg);
meillo@10 251
meillo@10 252 DEBUG(4) {
meillo@10 253 gint i = 0;
meillo@114 254 debugf("in check_helo_response()\n");
meillo@10 255 while (psb->auth_names[i]) {
meillo@114 256 debugf(" offered AUTH %s\n", psb->auth_names[i]);
meillo@10 257 i++;
meillo@10 258 }
meillo@10 259 }
meillo@10 260 }
meillo@10 261 }
meillo@10 262 }
meillo@10 263
meillo@10 264 while (*ptr != '\n')
meillo@10 265 ptr++;
meillo@10 266 ptr++;
meillo@0 267 }
meillo@0 268
meillo@10 269 DEBUG(4) {
meillo@114 270 debugf(" %s\n", psb->use_size ? "uses SIZE" : "no size");
meillo@114 271 debugf(" %s\n", psb->use_pipelining ? "uses PIPELINING" : "no pipelining");
meillo@114 272 debugf(" %s\n", psb->use_auth ? "uses AUTH" : "no auth");
meillo@10 273 }
meillo@0 274
meillo@10 275 return TRUE;
meillo@0 276 }
meillo@0 277
meillo@246 278 /*
meillo@246 279 We first try EHLO, but if it fails HELO in a second fall back try.
meillo@246 280 This is what is requested by RFC 2821 (sec 3.2):
meillo@246 281
meillo@246 282 Once the server has sent the welcoming message and
meillo@246 283 the client has received it, the client normally sends
meillo@246 284 the EHLO command to the server, [...]
meillo@246 285 For a particular connection attempt, if the server
meillo@246 286 returns a "command not recognized" response to EHLO,
meillo@246 287 the client SHOULD be able to fall back and send HELO.
meillo@246 288
meillo@246 289 Up to and including version 0.3.0 masqmail used ESMTP only if the
meillo@246 290 string ``ESMTP'' appeared within the server's greeting message. This
meillo@246 291 made it impossible to use AUTH with servers that would send odd
meillo@246 292 greeting messages.
meillo@246 293 */
meillo@10 294 static gboolean
meillo@366 295 smtp_helo(smtp_base *psb, gchar *helo)
meillo@0 296 {
meillo@246 297 fprintf(psb->out, "EHLO %s\r\n", helo);
meillo@246 298 fflush(psb->out);
meillo@246 299 DEBUG(4) debugf("C: EHLO %s\r\n", helo);
meillo@0 300
meillo@246 301 if (!read_response(psb, SMTP_CMD_TIMEOUT)) {
meillo@246 302 return FALSE;
meillo@246 303 }
meillo@246 304 if (check_helo_response(psb)) {
meillo@246 305 DEBUG(4) debugf("uses esmtp\n");
meillo@246 306 return TRUE;
meillo@246 307 }
meillo@0 308
meillo@246 309 if (psb->error != smtp_fail) {
meillo@246 310 return FALSE;
meillo@246 311 }
meillo@0 312
meillo@246 313 /* our guess that server understands EHLO could have been wrong,
meillo@246 314 try again with HELO */
meillo@0 315
meillo@246 316 fprintf(psb->out, "HELO %s\r\n", helo);
meillo@246 317 fflush(psb->out);
meillo@246 318 DEBUG(4) debugf("C: HELO %s\r\n", helo);
meillo@0 319
meillo@246 320 if (!read_response(psb, SMTP_CMD_TIMEOUT)) {
meillo@246 321 return FALSE;
meillo@246 322 }
meillo@246 323 if (check_helo_response(psb)) {
meillo@246 324 DEBUG(4) debugf("uses smtp\n");
meillo@246 325 return TRUE;
meillo@246 326 }
meillo@10 327
meillo@246 328 /* what sort of server ist THAT ?! give up... */
meillo@246 329 return FALSE;
meillo@0 330 }
meillo@0 331
meillo@10 332 static void
meillo@366 333 smtp_cmd_mailfrom(smtp_base *psb, address *return_path, guint size)
meillo@0 334 {
meillo@10 335 if (psb->use_size) {
meillo@10 336 fprintf(psb->out, "MAIL FROM:%s SIZE=%d\r\n", addr_string(return_path), size);
meillo@10 337 fflush(psb->out);
meillo@0 338
meillo@177 339 DEBUG(4) debugf("C: MAIL FROM:%s SIZE=%d\r\n", addr_string(return_path), size);
meillo@0 340
meillo@10 341 } else {
meillo@10 342 fprintf(psb->out, "MAIL FROM:%s\r\n", addr_string(return_path));
meillo@10 343 fflush(psb->out);
meillo@0 344
meillo@177 345 DEBUG(4) debugf("C: MAIL FROM:%s\r\n", addr_string(return_path));
meillo@10 346 }
meillo@0 347 }
meillo@0 348
meillo@10 349 static void
meillo@366 350 smtp_cmd_rcptto(smtp_base *psb, address *rcpt)
meillo@0 351 {
meillo@10 352 fprintf(psb->out, "RCPT TO:%s\r\n", addr_string(rcpt));
meillo@10 353 fflush(psb->out);
meillo@177 354 DEBUG(4) debugf("C: RCPT TO:%s\n", addr_string(rcpt));
meillo@0 355 }
meillo@0 356
meillo@10 357 static void
meillo@366 358 send_data_line(smtp_base *psb, gchar *data)
meillo@0 359 {
meillo@10 360 /* According to RFC 821 each line should be terminated with CRLF.
meillo@10 361 Since a dot on a line itself marks the end of data, each line
meillo@10 362 beginning with a dot is prepended with another dot.
meillo@10 363 */
meillo@10 364 gchar *ptr;
meillo@15 365 gboolean new_line = TRUE; /* previous versions assumed that each item was exactly one line.
meillo@15 366 This is no longer the case */
meillo@0 367
meillo@10 368 ptr = data;
meillo@10 369 while (*ptr) {
meillo@10 370 int c = (int) (*ptr);
meillo@119 371 if (c == '.' && new_line) {
meillo@119 372 /* dot-stuffing */
meillo@119 373 putc('.', psb->out);
meillo@119 374 }
meillo@10 375 if (c == '\n') {
meillo@119 376 /* CRLF line terminators */
meillo@10 377 putc('\r', psb->out);
meillo@10 378 putc('\n', psb->out);
meillo@10 379 new_line = TRUE;
meillo@10 380 } else {
meillo@10 381 putc(c, psb->out);
meillo@10 382 new_line = FALSE;
meillo@10 383 }
meillo@10 384 ptr++;
meillo@10 385 }
meillo@0 386 }
meillo@0 387
meillo@10 388 static void
meillo@366 389 send_header(smtp_base *psb, GList *hdr_list)
meillo@0 390 {
meillo@10 391 GList *node;
meillo@10 392 gint num_hdrs = 0;
meillo@0 393
meillo@10 394 /* header */
meillo@10 395 if (hdr_list) {
meillo@10 396 foreach(hdr_list, node) {
meillo@10 397 if (node->data) {
meillo@10 398 header *hdr = (header *) (node->data);
meillo@10 399 if (hdr->header) {
meillo@10 400 send_data_line(psb, hdr->header);
meillo@10 401 num_hdrs++;
meillo@10 402 }
meillo@10 403 }
meillo@10 404 }
meillo@0 405 }
meillo@0 406
meillo@10 407 /* empty line separating headers from data: */
meillo@10 408 putc('\r', psb->out);
meillo@10 409 putc('\n', psb->out);
meillo@0 410
meillo@10 411 DEBUG(4) debugf("sent %d headers\n", num_hdrs);
meillo@0 412 }
meillo@0 413
meillo@10 414 static void
meillo@366 415 send_data(smtp_base *psb, message *msg)
meillo@0 416 {
meillo@10 417 GList *node;
meillo@10 418 gint num_lines = 0;
meillo@0 419
meillo@10 420 /* data */
meillo@10 421 if (msg->data_list) {
meillo@10 422 for (node = g_list_first(msg->data_list); node; node = g_list_next(node)) {
meillo@10 423 if (node->data) {
meillo@10 424 send_data_line(psb, node->data);
meillo@10 425 num_lines++;
meillo@10 426 }
meillo@10 427 }
meillo@10 428 }
meillo@0 429
meillo@10 430 DEBUG(4) debugf("sent %d lines of data\n", num_lines);
meillo@0 431
meillo@10 432 fprintf(psb->out, ".\r\n");
meillo@10 433 fflush(psb->out);
meillo@177 434 DEBUG(4) debugf("C: .\n");
meillo@0 435 }
meillo@0 436
meillo@10 437 void
meillo@366 438 smtp_out_mark_rcpts(smtp_base *psb, GList *rcpt_list)
meillo@0 439 {
meillo@10 440 GList *rcpt_node;
meillo@10 441 for (rcpt_node = g_list_first(rcpt_list); rcpt_node; rcpt_node = g_list_next(rcpt_node)) {
meillo@10 442 address *rcpt = (address *) (rcpt_node->data);
meillo@0 443
meillo@10 444 addr_unmark_delivered(rcpt);
meillo@0 445
meillo@10 446 if ((psb->error == smtp_trylater) || (psb->error == smtp_timeout) || (psb->error == smtp_eof)) {
meillo@10 447 addr_mark_defered(rcpt);
meillo@10 448 } else {
meillo@10 449 addr_mark_failed(rcpt);
meillo@10 450 }
meillo@10 451 }
meillo@0 452 }
meillo@0 453
meillo@10 454 void
meillo@366 455 smtp_out_log_failure(smtp_base *psb, message *msg)
meillo@0 456 {
meillo@10 457 gchar *err_str;
meillo@0 458
meillo@10 459 if (psb->error == smtp_timeout)
meillo@10 460 err_str = g_strdup("connection timed out.");
meillo@10 461 else if (psb->error == smtp_eof)
meillo@10 462 err_str = g_strdup("connection terminated prematurely.");
meillo@10 463 else if (psb->error == smtp_syntax)
meillo@10 464 err_str = g_strdup_printf("got unexpected response: %s", psb->buffer);
meillo@10 465 else if (psb->error == smtp_cancel)
meillo@10 466 err_str = g_strdup("delivery was canceled.\n");
meillo@10 467 else
meillo@10 468 /* error message should still be in the buffer */
meillo@10 469 err_str = g_strdup_printf("failed: %s\n", psb->buffer);
meillo@0 470
meillo@10 471 if (msg == NULL)
meillo@10 472 logwrite(LOG_NOTICE, "host=%s %s\n", psb->remote_host, err_str);
meillo@10 473 else
meillo@10 474 logwrite(LOG_NOTICE, "%s == host=%s %s\n", msg->uid, psb->remote_host, err_str);
meillo@0 475
meillo@10 476 g_free(err_str);
meillo@0 477 }
meillo@0 478
meillo@10 479 smtp_base*
meillo@366 480 smtp_out_open(gchar *host, gint port, GList *resolve_list)
meillo@0 481 {
meillo@10 482 smtp_base *psb;
meillo@10 483 gint sock;
meillo@10 484 mxip_addr *addr;
meillo@0 485
meillo@10 486 DEBUG(5) debugf("smtp_out_open entered, host = %s\n", host);
meillo@0 487
meillo@10 488 if ((addr = connect_resolvelist(&sock, host, port, resolve_list))) {
meillo@10 489 /* create structure to hold status data: */
meillo@10 490 psb = create_smtpbase(sock);
meillo@10 491 psb->remote_host = addr->name;
meillo@0 492
meillo@10 493 DEBUG(5) {
meillo@10 494 struct sockaddr_in name;
meillo@10 495 int len = sizeof(struct sockaddr);
meillo@10 496 getsockname(sock, (struct sockaddr *) (&name), &len);
meillo@10 497 debugf("socket: name.sin_addr = %s\n", inet_ntoa(name.sin_addr));
meillo@10 498 }
meillo@10 499 return psb;
meillo@10 500 } else {
meillo@10 501 DEBUG(5) debugf("connect_resolvelist failed: %s %s\n", strerror(errno), hstrerror(h_errno));
meillo@10 502 }
meillo@0 503
meillo@10 504 return NULL;
meillo@0 505 }
meillo@0 506
meillo@10 507 smtp_base*
meillo@366 508 smtp_out_open_child(gchar *cmd, char *host)
meillo@0 509 {
meillo@10 510 smtp_base *psb;
meillo@10 511 gint sock;
meillo@0 512
meillo@10 513 DEBUG(5) debugf("smtp_out_open_child entered, cmd = %s\n", cmd);
meillo@321 514 psb->remote_host = host;
meillo@10 515 sock = child(cmd);
meillo@10 516 if (sock > 0) {
meillo@10 517 psb = create_smtpbase(sock);
meillo@10 518 psb->remote_host = NULL;
meillo@0 519
meillo@10 520 return psb;
meillo@10 521 }
meillo@0 522
meillo@10 523 return NULL;
meillo@0 524 }
meillo@0 525
meillo@10 526 gboolean
meillo@366 527 smtp_out_rset(smtp_base *psb)
meillo@0 528 {
meillo@10 529 gboolean ok;
meillo@0 530
meillo@10 531 fprintf(psb->out, "RSET\r\n");
meillo@10 532 fflush(psb->out);
meillo@177 533 DEBUG(4) debugf("C: RSET\n");
meillo@0 534
meillo@10 535 if ((ok = read_response(psb, SMTP_CMD_TIMEOUT)))
meillo@10 536 if (check_response(psb, FALSE))
meillo@10 537 return TRUE;
meillo@0 538
meillo@10 539 smtp_out_log_failure(psb, NULL);
meillo@10 540
meillo@10 541 return FALSE;
meillo@0 542 }
meillo@0 543
meillo@0 544 #ifdef ENABLE_AUTH
meillo@0 545
meillo@10 546 static gboolean
meillo@366 547 smtp_out_auth_cram_md5(smtp_base *psb)
meillo@0 548 {
meillo@10 549 gboolean ok = FALSE;
meillo@0 550
meillo@177 551 fprintf(psb->out, "C: AUTH CRAM-MD5\r\n");
meillo@10 552 fflush(psb->out);
meillo@10 553 DEBUG(4) debugf("AUTH CRAM-MD5\n");
meillo@10 554 if ((ok = read_response(psb, SMTP_CMD_TIMEOUT))) {
meillo@10 555 if ((ok = check_response(psb, TRUE))) {
meillo@10 556 gchar *chall64 = get_response_arg(&(psb->buffer[4]));
meillo@10 557 gint chall_size;
meillo@10 558 gchar *chall = base64_decode(chall64, &chall_size);
meillo@10 559 guchar digest[16], *reply64, *reply;
meillo@10 560 gchar digest_string[33];
meillo@10 561 gint i;
meillo@10 562
meillo@114 563 DEBUG(5) debugf("smtp_out_auth_cram_md5():\n");
meillo@114 564 DEBUG(5) debugf(" encoded challenge = %s\n", chall64);
meillo@114 565 DEBUG(5) debugf(" decoded challenge = %s, size = %d\n", chall, chall_size);
meillo@114 566 DEBUG(5) debugf(" secret = %s\n", psb->auth_secret);
meillo@10 567
meillo@10 568 hmac_md5(chall, chall_size, psb->auth_secret, strlen(psb->auth_secret), digest);
meillo@10 569 for (i = 0; i < 16; i++)
meillo@10 570 sprintf(&(digest_string[i + i]), "%02x", (unsigned int) (digest[i]));
meillo@15 571 digest_string[32] = '\0';
meillo@10 572
meillo@114 573 DEBUG(5) debugf(" digest = %s\n", digest_string);
meillo@10 574
meillo@10 575 reply = g_strdup_printf("%s %s", psb->auth_login, digest_string);
meillo@114 576 DEBUG(5) debugf(" unencoded reply = %s\n", reply);
meillo@10 577
meillo@10 578 reply64 = base64_encode(reply, strlen(reply));
meillo@114 579 DEBUG(5) debugf(" encoded reply = %s\n", reply64);
meillo@10 580
meillo@10 581 fprintf(psb->out, "%s\r\n", reply64);
meillo@10 582 fflush(psb->out);
meillo@177 583 DEBUG(6) debugf(" reply64 = %s\n", reply64);
meillo@177 584 DEBUG(6) debugf("C: %s\n", reply64);
meillo@10 585
meillo@10 586 if ((ok = read_response(psb, SMTP_CMD_TIMEOUT)))
meillo@10 587 ok = check_response(psb, FALSE);
meillo@10 588
meillo@10 589 g_free(reply64);
meillo@10 590 g_free(reply);
meillo@10 591 g_free(chall);
meillo@10 592 g_free(chall64);
meillo@10 593 }
meillo@10 594 }
meillo@10 595 return ok;
meillo@0 596 }
meillo@0 597
meillo@10 598 static gboolean
meillo@366 599 smtp_out_auth_login(smtp_base *psb)
meillo@0 600 {
meillo@10 601 gboolean ok = FALSE;
meillo@10 602 fprintf(psb->out, "AUTH LOGIN\r\n");
meillo@10 603 fflush(psb->out);
meillo@177 604 DEBUG(4) debugf("C: AUTH LOGIN\r\n");
meillo@10 605 if ((ok = read_response(psb, SMTP_CMD_TIMEOUT))) {
meillo@10 606 if ((ok = check_response(psb, TRUE))) {
meillo@10 607 gchar *resp64;
meillo@10 608 guchar *resp;
meillo@10 609 gint resp_size;
meillo@10 610 gchar *reply64;
meillo@10 611
meillo@114 612 DEBUG(5) debugf("smtp_out_auth_login():\n");
meillo@10 613 resp64 = get_response_arg(&(psb->buffer[4]));
meillo@312 614 DEBUG(5) debugf(" encoded response = `%s'\n", resp64);
meillo@10 615 resp = base64_decode(resp64, &resp_size);
meillo@10 616 g_free(resp64);
meillo@312 617 DEBUG(5) debugf(" decoded response = `%s', size = %d\n", resp, resp_size);
meillo@10 618 g_free(resp);
meillo@10 619 reply64 = base64_encode(psb->auth_login, strlen(psb->auth_login));
meillo@10 620 fprintf(psb->out, "%s\r\n", reply64);
meillo@10 621 fflush(psb->out);
meillo@177 622 DEBUG(6) debugf("C: %s\n", reply64);
meillo@10 623 g_free(reply64);
meillo@10 624 if ((ok = read_response(psb, SMTP_CMD_TIMEOUT))) {
meillo@10 625 if ((ok = check_response(psb, TRUE))) {
meillo@10 626 resp64 = get_response_arg(&(psb->buffer[4]));
meillo@312 627 DEBUG(5) debugf(" encoded response = `%s'\n", resp64);
meillo@10 628 resp = base64_decode(resp64, &resp_size);
meillo@10 629 g_free(resp64);
meillo@312 630 DEBUG(5) debugf(" decoded response = `%s', size = %d\n", resp, resp_size);
meillo@10 631 g_free(resp);
meillo@10 632 reply64 = base64_encode(psb->auth_secret, strlen(psb->auth_secret));
meillo@10 633 fprintf(psb->out, "%s\r\n", reply64);
meillo@10 634 fflush(psb->out);
meillo@177 635 DEBUG(6) debugf("C: %s\n", reply64);
meillo@10 636 g_free(reply64);
meillo@10 637 if ((ok = read_response(psb, SMTP_CMD_TIMEOUT)))
meillo@10 638 ok = check_response(psb, FALSE);
meillo@10 639 }
meillo@10 640 }
meillo@10 641 }
meillo@0 642 }
meillo@10 643 return ok;
meillo@0 644 }
meillo@0 645
meillo@10 646 gboolean
meillo@366 647 smtp_out_auth(smtp_base *psb)
meillo@0 648 {
meillo@10 649 gboolean ok = FALSE;
meillo@10 650 gint i = 0;
meillo@10 651 while (psb->auth_names[i]) {
meillo@10 652 if (strcasecmp(psb->auth_names[i], psb->auth_name) == 0)
meillo@10 653 break;
meillo@10 654 i++;
meillo@10 655 }
meillo@10 656 if (psb->auth_names[i]) {
meillo@10 657 if (strcasecmp(psb->auth_name, "cram-md5") == 0) {
meillo@10 658 smtp_out_auth_cram_md5(psb);
meillo@10 659 } else if (strcasecmp(psb->auth_name, "login") == 0) {
meillo@10 660 smtp_out_auth_login(psb);
meillo@10 661 } else {
meillo@10 662 logwrite(LOG_ERR, "auth method %s not supported\n", psb->auth_name);
meillo@10 663 }
meillo@10 664 } else {
meillo@10 665 logwrite(LOG_ERR, "no auth method %s found.\n", psb->auth_name);
meillo@10 666 }
meillo@10 667 return ok;
meillo@0 668 }
meillo@0 669
meillo@0 670 #endif
meillo@0 671
meillo@10 672 gboolean
meillo@366 673 smtp_out_init(smtp_base *psb, gboolean instant_helo)
meillo@0 674 {
meillo@10 675 gboolean ok;
meillo@0 676
meillo@222 677 logwrite(LOG_INFO, "smtp_out_init(): instant_helo:%d\n", instant_helo);
meillo@10 678
meillo@246 679 if (!instant_helo) {
meillo@222 680 if ((ok = read_response(psb, SMTP_INITIAL_TIMEOUT))) {
meillo@246 681 ok = check_response(psb, FALSE);
meillo@222 682 }
meillo@222 683 if (!ok) {
meillo@222 684 smtp_out_log_failure(psb, NULL);
meillo@222 685 return ok;
meillo@222 686 }
meillo@222 687 }
meillo@222 688
meillo@222 689 if ((ok = smtp_helo(psb, psb->helo_name))) {
meillo@0 690 #ifdef ENABLE_AUTH
meillo@222 691 if (psb->auth_name && psb->use_auth) {
meillo@222 692 /* we completely disregard the response of server here. If
meillo@222 693 authentication fails, the server will complain later
meillo@222 694 anyway. I know, this is not polite... */
meillo@222 695 smtp_out_auth(psb);
meillo@222 696 }
meillo@10 697 #endif
meillo@0 698 }
meillo@10 699 if (!ok)
meillo@10 700 smtp_out_log_failure(psb, NULL);
meillo@10 701 return ok;
meillo@0 702 }
meillo@0 703
meillo@10 704 gint
meillo@366 705 smtp_out_msg(smtp_base *psb, message *msg, address *return_path, GList *rcpt_list, GList *hdr_list)
meillo@0 706 {
meillo@10 707 gint i, size;
meillo@10 708 gboolean ok = TRUE;
meillo@10 709 int rcpt_cnt;
meillo@10 710 int rcpt_accept = 0;
meillo@0 711
meillo@10 712 DEBUG(5) debugf("smtp_out_msg entered\n");
meillo@0 713
meillo@10 714 /* defaults: */
meillo@10 715 if (return_path == NULL)
meillo@10 716 return_path = msg->return_path;
meillo@10 717 if (hdr_list == NULL)
meillo@10 718 hdr_list = msg->hdr_list;
meillo@10 719 if (rcpt_list == NULL)
meillo@10 720 rcpt_list = msg->rcpt_list;
meillo@10 721 rcpt_cnt = g_list_length(rcpt_list);
meillo@0 722
meillo@10 723 size = msg_calc_size(msg, TRUE);
meillo@0 724
meillo@10 725 /* respect maximum size given by server: */
meillo@10 726 if ((psb->max_size > 0) && (size > psb->max_size)) {
meillo@114 727 logwrite(LOG_WARNING, "%s == host=%s message size (%d) > "
meillo@114 728 "fixed maximum message size of server (%d)",
meillo@10 729 msg->uid, psb->remote_host, size, psb->max_size);
meillo@10 730 psb->error = smtp_cancel;
meillo@10 731 ok = FALSE;
meillo@10 732 }
meillo@0 733
meillo@10 734 if (ok) {
meillo@119 735 /* pretend the message is a bit larger,
meillo@119 736 just in case the size calculation is buggy */
meillo@119 737 smtp_cmd_mailfrom(psb, return_path, psb->use_size ? size+SMTP_SIZE_ADD : 0);
meillo@0 738
meillo@10 739 if (!psb->use_pipelining) {
meillo@10 740 if ((ok = read_response(psb, SMTP_CMD_TIMEOUT)))
meillo@10 741 ok = check_response(psb, FALSE);
meillo@10 742 }
meillo@10 743 }
meillo@10 744 if (ok) {
meillo@10 745 GList *rcpt_node;
meillo@10 746 rcpt_accept = 0;
meillo@0 747
meillo@10 748 for (rcpt_node = g_list_first(rcpt_list); rcpt_node != NULL; rcpt_node = g_list_next(rcpt_node)) {
meillo@10 749 address *rcpt = (address *) (rcpt_node->data);
meillo@10 750 smtp_cmd_rcptto(psb, rcpt);
meillo@10 751 if (!psb->use_pipelining) {
meillo@10 752 if ((ok = read_response(psb, SMTP_CMD_TIMEOUT)))
meillo@10 753 if (check_response(psb, FALSE)) {
meillo@10 754 rcpt_accept++;
meillo@10 755 addr_mark_delivered(rcpt);
meillo@10 756 } else {
meillo@10 757 /* if server returned an error for one recp. we
meillo@10 758 may still try the others. But if it is a timeout, eof
meillo@10 759 or unexpected response, it is more serious and we should
meillo@10 760 give up. */
meillo@10 761 if ((psb->error != smtp_trylater) && (psb->error != smtp_fail)) {
meillo@10 762 ok = FALSE;
meillo@10 763 break;
meillo@10 764 } else {
meillo@114 765 logwrite(LOG_NOTICE, "%s == %s host=%s failed: %s\n",
meillo@15 766 msg->uid, addr_string(rcpt), psb->remote_host, psb->buffer);
meillo@10 767 if (psb->error == smtp_trylater) {
meillo@10 768 addr_mark_defered(rcpt);
meillo@10 769 } else {
meillo@10 770 addr_mark_failed(rcpt);
meillo@10 771 }
meillo@10 772 }
meillo@10 773 } else
meillo@10 774 break;
meillo@10 775 }
meillo@10 776 }
meillo@0 777
meillo@10 778 /* There is no point in going on if no recp.s were accpted.
meillo@10 779 But we can check that at this point only if not pipelining: */
meillo@10 780 ok = (ok && (psb->use_pipelining || (rcpt_accept > 0)));
meillo@10 781 if (ok) {
meillo@0 782
meillo@10 783 fprintf(psb->out, "DATA\r\n");
meillo@10 784 fflush(psb->out);
meillo@0 785
meillo@177 786 DEBUG(4) debugf("C: DATA\r\n");
meillo@10 787
meillo@10 788 if (psb->use_pipelining) {
meillo@10 789 /* the first pl'ed command was MAIL FROM
meillo@10 790 the last was DATA, whose response can be handled by the 'normal' code
meillo@10 791 all in between were RCPT TO:
meillo@10 792 */
meillo@10 793 /* response to MAIL FROM: */
meillo@10 794 if ((ok = read_response(psb, SMTP_CMD_TIMEOUT))) {
meillo@10 795 if ((ok = check_response(psb, FALSE))) {
meillo@10 796
meillo@10 797 /* response(s) to RCPT TO:
meillo@10 798 this is very similar to the sequence above for no pipeline
meillo@10 799 */
meillo@10 800 for (i = 0; i < rcpt_cnt; i++) {
meillo@10 801 if ((ok = read_response(psb, SMTP_CMD_TIMEOUT))) {
meillo@10 802 address *rcpt = g_list_nth_data(rcpt_list, i);
meillo@10 803 if (check_response(psb, FALSE)) {
meillo@10 804 rcpt_accept++;
meillo@10 805 addr_mark_delivered(rcpt);
meillo@10 806 } else {
meillo@10 807 /* if server returned an error 4xx or 5xx for one recp. we
meillo@10 808 may still try the others. But if it is a timeout, eof
meillo@10 809 or unexpected response, it is more serious and we
meillo@10 810 should give up. */
meillo@10 811 if ((psb->error != smtp_trylater) &&
meillo@10 812 (psb->error != smtp_fail)) {
meillo@10 813 ok = FALSE;
meillo@10 814 break;
meillo@10 815 } else {
meillo@114 816 logwrite(LOG_NOTICE, "%s == %s host=%s failed: %s\n", msg->uid,
meillo@10 817 addr_string(rcpt), psb->remote_host, psb->buffer);
meillo@10 818 if (psb->error == smtp_trylater) {
meillo@10 819 addr_mark_defered(rcpt);
meillo@10 820 } else {
meillo@10 821 addr_mark_failed(rcpt);
meillo@10 822 }
meillo@10 823 }
meillo@10 824 }
meillo@10 825 } else {
meillo@10 826 DEBUG(5) debugf("check_response failed after RCPT TO\n");
meillo@10 827 break;
meillo@10 828 }
meillo@10 829 }
meillo@10 830 if (rcpt_accept == 0)
meillo@10 831 ok = FALSE;
meillo@10 832 } else {
meillo@10 833 DEBUG(5) debugf("check_response failed after MAIL FROM\n");
meillo@10 834 }
meillo@10 835 } else {
meillo@10 836 DEBUG(5)
meillo@10 837 debugf("read_response failed after MAIL FROM\n");
meillo@10 838 }
meillo@10 839 }
meillo@10 840
meillo@10 841 /* if(psb->use_pipelining) */
meillo@10 842 /* response to the DATA cmd */
meillo@10 843 if (ok) {
meillo@10 844 if (read_response(psb, SMTP_DATA_TIMEOUT)) {
meillo@10 845 if (check_response(psb, TRUE)) {
meillo@10 846 send_header(psb, hdr_list);
meillo@10 847 send_data(psb, msg);
meillo@10 848
meillo@10 849 if (read_response(psb, SMTP_FINAL_TIMEOUT))
meillo@10 850 ok = check_response(psb, FALSE);
meillo@10 851 }
meillo@10 852 }
meillo@10 853 }
meillo@0 854 }
meillo@10 855 }
meillo@10 856
meillo@10 857 DEBUG(5) {
meillo@114 858 debugf("smtp_out_msg():\n");
meillo@114 859 debugf(" psb->error = %d\n", psb->error);
meillo@114 860 debugf(" ok = %d\n", ok);
meillo@114 861 debugf(" rcpt_accept = %d\n", rcpt_accept);
meillo@10 862 }
meillo@10 863
meillo@10 864 if (psb->error == smtp_ok) {
meillo@10 865 GList *rcpt_node;
meillo@10 866 for (rcpt_node = g_list_first(rcpt_list); rcpt_node; rcpt_node = g_list_next(rcpt_node)) {
meillo@10 867 address *rcpt = (address *) (rcpt_node->data);
meillo@10 868 if (addr_is_delivered(rcpt))
meillo@246 869 logwrite(LOG_NOTICE, "%s => %s host=%s\n",
meillo@246 870 msg->uid, addr_string(rcpt), psb->remote_host);
meillo@0 871 }
meillo@10 872 } else {
meillo@10 873 /* if something went wrong,
meillo@10 874 we have to unmark the rcpts prematurely marked as delivered
meillo@10 875 and mark the status */
meillo@10 876 smtp_out_mark_rcpts(psb, rcpt_list);
meillo@10 877
meillo@10 878 /* log the failure: */
meillo@10 879 smtp_out_log_failure(psb, msg);
meillo@0 880 }
meillo@10 881 return rcpt_accept;
meillo@0 882 }
meillo@0 883
meillo@10 884 gboolean
meillo@366 885 smtp_out_quit(smtp_base *psb)
meillo@0 886 {
meillo@10 887 fprintf(psb->out, "QUIT\r\n");
meillo@10 888 fflush(psb->out);
meillo@0 889
meillo@177 890 DEBUG(4) debugf("C: QUIT\n");
meillo@0 891
meillo@10 892 signal(SIGALRM, SIG_DFL);
meillo@10 893
meillo@10 894 return TRUE;
meillo@0 895 }
meillo@10 896
meillo@10 897 gint
meillo@366 898 smtp_deliver(gchar *host, gint port, GList *resolve_list, message *msg, address *return_path, GList *rcpt_list)
meillo@0 899 {
meillo@10 900 smtp_base *psb;
meillo@10 901 smtp_error err;
meillo@0 902
meillo@10 903 DEBUG(5) debugf("smtp_deliver entered\n");
meillo@0 904
meillo@10 905 if (return_path == NULL)
meillo@10 906 return_path = msg->return_path;
meillo@0 907
meillo@10 908 if ((psb = smtp_out_open(host, port, resolve_list))) {
meillo@10 909 set_heloname(psb, return_path->domain, TRUE);
meillo@10 910 /* initiate connection, send message and quit: */
meillo@222 911 if (smtp_out_init(psb, FALSE)) {
meillo@10 912 smtp_out_msg(psb, msg, return_path, rcpt_list, NULL);
meillo@10 913 if (psb->error == smtp_ok || (psb->error == smtp_fail) || (psb->error == smtp_trylater)
meillo@10 914 || (psb->error == smtp_syntax) || (psb->error == smtp_cancel))
meillo@10 915 smtp_out_quit(psb);
meillo@10 916 }
meillo@10 917
meillo@10 918 err = psb->error;
meillo@10 919 destroy_smtpbase(psb);
meillo@10 920
meillo@10 921 return err;
meillo@10 922 }
meillo@10 923 return -1;
meillo@0 924 }