masqmail

annotate src/smtp_out.c @ 177:6530806d418f

find changesets by author, revision, files, or words in the commit message
better debug logging of outgoing SMTP dialogs the dialog is logged in the style of the RFC examples: ``C: foo'' is said by the client, ``S: bar'' is said by the server debug level 4 is used, but login data is logged on level 6
author meillo@marmaro.de
date Wed, 14 Jul 2010 16:35:17 +0200
parents a39c8ee61185
children 10da50168dab
rev   line source
meillo@0 1 /* smtp_out.c, Copyright (C) 1999-2001 Oliver Kurth,
meillo@0 2 *
meillo@0 3 * This program is free software; you can redistribute it and/or modify
meillo@0 4 * it under the terms of the GNU General Public License as published by
meillo@0 5 * the Free Software Foundation; either version 2 of the License, or
meillo@0 6 * (at your option) any later version.
meillo@10 7 *
meillo@0 8 * This program is distributed in the hope that it will be useful,
meillo@0 9 * but WITHOUT ANY WARRANTY; without even the implied warranty of
meillo@0 10 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
meillo@0 11 * GNU General Public License for more details.
meillo@0 12 *
meillo@0 13 * You should have received a copy of the GNU General Public License
meillo@0 14 * along with this program; if not, write to the Free Software
meillo@0 15 * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
meillo@0 16 */
meillo@0 17
meillo@0 18 /*
meillo@0 19 send bugs to: kurth@innominate.de
meillo@0 20 */
meillo@0 21
meillo@0 22 /*
meillo@0 23 I always forget these rfc numbers:
meillo@0 24 RFC 821 (SMTP)
meillo@0 25 RFC 1869 (ESMTP)
meillo@0 26 RFC 1870 (ESMTP SIZE)
meillo@0 27 RFC 2197 (ESMTP PIPELINE)
meillo@0 28 RFC 2554 (ESMTP AUTH)
meillo@0 29 */
meillo@0 30
meillo@0 31 #include "masqmail.h"
meillo@0 32 #include "smtp_out.h"
meillo@0 33 #include "readsock.h"
meillo@0 34
meillo@0 35 #ifdef ENABLE_AUTH
meillo@0 36
meillo@0 37 #ifdef USE_LIB_CRYPTO
meillo@0 38 #include <openssl/hmac.h>
meillo@0 39 #include <openssl/md5.h>
meillo@0 40 #include <openssl/evp.h>
meillo@0 41 #else
meillo@0 42 #include "md5/global.h"
meillo@0 43 #include "md5/md5.h"
meillo@0 44 #include "md5/hmac_md5.h"
meillo@0 45 #endif
meillo@0 46
meillo@0 47 #include "base64/base64.h"
meillo@0 48 #endif
meillo@0 49
meillo@10 50 void
meillo@10 51 destroy_smtpbase(smtp_base * psb)
meillo@0 52 {
meillo@10 53 fclose(psb->in);
meillo@10 54 fclose(psb->out);
meillo@0 55
meillo@10 56 close(psb->sock);
meillo@0 57
meillo@10 58 if (psb->helo_name)
meillo@10 59 g_free(psb->helo_name);
meillo@10 60 if (psb->buffer)
meillo@10 61 g_free(psb->buffer);
meillo@10 62 if (psb->auth_names)
meillo@10 63 g_strfreev(psb->auth_names);
meillo@0 64
meillo@10 65 if (psb->auth_name)
meillo@10 66 g_free(psb->auth_name);
meillo@10 67 if (psb->auth_login)
meillo@10 68 g_free(psb->auth_login);
meillo@10 69 if (psb->auth_secret)
meillo@10 70 g_free(psb->auth_secret);
meillo@0 71 }
meillo@0 72
meillo@10 73 gchar*
meillo@10 74 set_heloname(smtp_base * psb, gchar * default_name, gboolean do_correct)
meillo@0 75 {
meillo@10 76 struct sockaddr_in sname;
meillo@10 77 int len = sizeof(struct sockaddr_in);
meillo@10 78 struct hostent *host_entry;
meillo@0 79
meillo@10 80 if (do_correct) {
meillo@10 81 getsockname(psb->sock, (struct sockaddr *) (&sname), &len);
meillo@10 82 DEBUG(5) debugf("socket: name.sin_addr = %s\n", inet_ntoa(sname.sin_addr));
meillo@10 83 host_entry = gethostbyaddr((const char *) &(sname.sin_addr), sizeof(sname.sin_addr), AF_INET);
meillo@10 84 if (host_entry) {
meillo@10 85 psb->helo_name = g_strdup(host_entry->h_name);
meillo@10 86 } else {
meillo@10 87 /* we failed to look up our own name. Instead of giving our local hostname,
meillo@10 88 we may give our IP number to show the server that we are at least
meillo@10 89 willing to be honest. For the really picky ones. */
meillo@10 90 DEBUG(5) debugf("failed to look up own host name.\n");
meillo@10 91 psb->helo_name = g_strdup_printf("[%s]", inet_ntoa(sname.sin_addr));
meillo@10 92 }
meillo@10 93 DEBUG(5) debugf("helo_name = %s\n", psb->helo_name);
meillo@10 94 }
meillo@10 95 if (psb->helo_name == NULL) {
meillo@10 96 psb->helo_name = g_strdup(default_name);
meillo@10 97 }
meillo@10 98 return psb->helo_name;
meillo@10 99 }
meillo@0 100
meillo@0 101 #ifdef ENABLE_AUTH
meillo@0 102
meillo@10 103 gboolean
meillo@10 104 set_auth(smtp_base * psb, gchar * name, gchar * login, gchar * secret)
meillo@0 105 {
meillo@10 106 if ((strcasecmp(name, "CRAM-MD5") == 0) || (strcasecmp(name, "LOGIN") == 0)) {
meillo@10 107 psb->auth_name = g_strdup(name);
meillo@10 108 psb->auth_login = g_strdup(login);
meillo@10 109 psb->auth_secret = g_strdup(secret);
meillo@10 110
meillo@10 111 return TRUE;
meillo@10 112 }
meillo@10 113 return FALSE;
meillo@0 114 }
meillo@0 115
meillo@0 116 #endif
meillo@0 117
meillo@10 118 static smtp_base*
meillo@10 119 create_smtpbase(gint sock)
meillo@0 120 {
meillo@10 121 gint dup_sock;
meillo@0 122
meillo@10 123 smtp_base *psb = (smtp_base *) g_malloc(sizeof(smtp_base));
meillo@0 124
meillo@10 125 psb->sock = sock;
meillo@0 126
meillo@10 127 psb->use_esmtp = FALSE;
meillo@10 128 psb->use_size = FALSE;
meillo@10 129 psb->use_pipelining = FALSE;
meillo@10 130 psb->use_auth = FALSE;
meillo@0 131
meillo@10 132 psb->max_size = 0;
meillo@10 133 psb->auth_names = NULL;
meillo@0 134
meillo@10 135 psb->buffer = (gchar *) g_malloc(SMTP_BUF_LEN);
meillo@0 136
meillo@10 137 dup_sock = dup(sock);
meillo@10 138 psb->out = fdopen(sock, "w");
meillo@10 139 psb->in = fdopen(dup_sock, "r");
meillo@0 140
meillo@10 141 psb->error = smtp_ok;
meillo@0 142
meillo@10 143 psb->helo_name = NULL;
meillo@0 144
meillo@10 145 psb->auth_name = psb->auth_login = psb->auth_secret = NULL;
meillo@10 146
meillo@10 147 return psb;
meillo@0 148 }
meillo@0 149
meillo@10 150 static gboolean
meillo@10 151 read_response(smtp_base * psb, int timeout)
meillo@0 152 {
meillo@10 153 gint buf_pos = 0;
meillo@10 154 gchar code[5];
meillo@10 155 gint i, len;
meillo@0 156
meillo@10 157 do {
meillo@10 158 len = read_sockline(psb->in, &(psb->buffer[buf_pos]), SMTP_BUF_LEN - buf_pos, timeout, READSOCKL_CHUG);
meillo@10 159 if (len == -3) {
meillo@10 160 psb->error = smtp_timeout;
meillo@10 161 return FALSE;
meillo@10 162 } else if (len == -2) {
meillo@10 163 psb->error = smtp_syntax;
meillo@10 164 return FALSE;
meillo@10 165 } else if (len == -1) {
meillo@10 166 psb->error = smtp_eof;
meillo@10 167 return FALSE;
meillo@10 168 }
meillo@10 169 for (i = 0; i < 4; i++)
meillo@10 170 code[i] = psb->buffer[buf_pos + i];
meillo@15 171 code[i] = '\0';
meillo@10 172 psb->last_code = atoi(code);
meillo@0 173
meillo@10 174 buf_pos += len;
meillo@0 175
meillo@10 176 } while (code[3] == '-');
meillo@177 177 if (psb->buffer) {
meillo@177 178 DEBUG(4) debugf("S: %s\n", psb->buffer);
meillo@177 179 }
meillo@0 180
meillo@10 181 return TRUE;
meillo@0 182 }
meillo@0 183
meillo@10 184 static gboolean
meillo@10 185 check_response(smtp_base * psb, gboolean after_data)
meillo@0 186 {
meillo@10 187 char c = psb->buffer[0];
meillo@0 188
meillo@10 189 if (((c == '2') && !after_data) || ((c == '3') && after_data)) {
meillo@10 190 psb->error = smtp_ok;
meillo@176 191 DEBUG(6) debugf("response OK:'%s' after_data = %d\n", psb->buffer, (int) after_data);
meillo@10 192 return TRUE;
meillo@10 193 } else {
meillo@10 194 if (c == '4')
meillo@10 195 psb->error = smtp_trylater;
meillo@10 196 else if (c == '5')
meillo@10 197 psb->error = smtp_fail;
meillo@10 198 else
meillo@10 199 psb->error = smtp_syntax;
meillo@176 200 DEBUG(6) debugf("response failure:'%s' after_data = %d\n", psb->buffer, (int) after_data);
meillo@10 201 return FALSE;
meillo@10 202 }
meillo@0 203 }
meillo@0 204
meillo@10 205 static gboolean
meillo@10 206 check_init_response(smtp_base * psb)
meillo@0 207 {
meillo@10 208 if (check_response(psb, FALSE)) {
meillo@10 209 psb->use_esmtp = (strstr(psb->buffer, "ESMTP") != NULL);
meillo@0 210
meillo@10 211 DEBUG(4) debugf(psb->use_esmtp ? "uses esmtp\n" : "no esmtp\n");
meillo@0 212
meillo@10 213 return TRUE;
meillo@10 214 }
meillo@10 215 return FALSE;
meillo@0 216 }
meillo@0 217
meillo@10 218 static gchar*
meillo@10 219 get_response_arg(gchar * response)
meillo@0 220 {
meillo@10 221 gchar buf[SMTP_BUF_LEN];
meillo@10 222 gchar *p = response, *q = buf;
meillo@0 223
meillo@10 224 while (*p && (*p != '\n') && isspace(*p))
meillo@10 225 p++;
meillo@10 226 if (*p && (*p != '\n')) {
meillo@10 227 while (*p && (*p != '\n') && (*p != '\r') && (q < buf + SMTP_BUF_LEN - 1))
meillo@10 228 *(q++) = *(p++);
meillo@15 229 *q = '\0';
meillo@10 230 return g_strdup(buf);
meillo@10 231 }
meillo@10 232 return NULL;
meillo@0 233 }
meillo@0 234
meillo@10 235 static gboolean
meillo@10 236 check_helo_response(smtp_base * psb)
meillo@0 237 {
meillo@10 238 gchar *ptr = psb->buffer;
meillo@0 239
meillo@10 240 if (!check_response(psb, FALSE))
meillo@10 241 return FALSE;
meillo@0 242
meillo@10 243 while (*ptr) {
meillo@10 244 if (strncasecmp(&(ptr[4]), "SIZE", 4) == 0) {
meillo@10 245 gchar *arg;
meillo@10 246 psb->use_size = TRUE;
meillo@10 247 arg = get_response_arg(&(ptr[8]));
meillo@10 248 if (arg) {
meillo@10 249 psb->max_size = atoi(arg);
meillo@10 250 g_free(arg);
meillo@10 251 }
meillo@10 252 }
meillo@0 253
meillo@10 254 if (strncasecmp(&(ptr[4]), "PIPELINING", 10) == 0)
meillo@10 255 psb->use_pipelining = TRUE;
meillo@0 256
meillo@10 257 if (strncasecmp(&(ptr[4]), "AUTH", 4) == 0) {
meillo@10 258 if ((ptr[8] == ' ') || (ptr[8] == '=') || (ptr[8] == '\t')) { /* not sure about '\t' */
meillo@10 259 gchar *arg;
meillo@10 260 psb->use_auth = TRUE;
meillo@10 261 arg = get_response_arg(&(ptr[9])); /* after several years I finally learnt to count */
meillo@10 262 if (arg) {
meillo@10 263 psb->auth_names = g_strsplit(arg, " ", 0);
meillo@10 264 g_free(arg);
meillo@10 265
meillo@10 266 DEBUG(4) {
meillo@10 267 gint i = 0;
meillo@114 268 debugf("in check_helo_response()\n");
meillo@10 269 while (psb->auth_names[i]) {
meillo@114 270 debugf(" offered AUTH %s\n", psb->auth_names[i]);
meillo@10 271 i++;
meillo@10 272 }
meillo@10 273 }
meillo@10 274 }
meillo@10 275 }
meillo@10 276 }
meillo@10 277
meillo@10 278 while (*ptr != '\n')
meillo@10 279 ptr++;
meillo@10 280 ptr++;
meillo@0 281 }
meillo@0 282
meillo@10 283 DEBUG(4) {
meillo@114 284 debugf(" %s\n", psb->use_size ? "uses SIZE" : "no size");
meillo@114 285 debugf(" %s\n", psb->use_pipelining ? "uses PIPELINING" : "no pipelining");
meillo@114 286 debugf(" %s\n", psb->use_auth ? "uses AUTH" : "no auth");
meillo@10 287 }
meillo@0 288
meillo@10 289 return TRUE;
meillo@0 290 }
meillo@0 291
meillo@10 292 static gboolean
meillo@10 293 smtp_helo(smtp_base * psb, gchar * helo)
meillo@0 294 {
meillo@10 295 while (TRUE) {
meillo@10 296 if (psb->use_esmtp) {
meillo@10 297 fprintf(psb->out, "EHLO %s\r\n", helo);
meillo@10 298 fflush(psb->out);
meillo@0 299
meillo@177 300 DEBUG(4) debugf("C: EHLO %s\r\n", helo);
meillo@0 301
meillo@10 302 } else {
meillo@10 303 fprintf(psb->out, "HELO %s\r\n", helo);
meillo@10 304 fflush(psb->out);
meillo@0 305
meillo@177 306 DEBUG(4) debugf("C: HELO %s\r\n", helo);
meillo@0 307
meillo@10 308 }
meillo@0 309
meillo@10 310 if (!read_response(psb, SMTP_CMD_TIMEOUT))
meillo@10 311 return FALSE;
meillo@10 312
meillo@10 313 if (check_helo_response(psb))
meillo@10 314 return TRUE;
meillo@10 315 else {
meillo@10 316 if (psb->error == smtp_fail) {
meillo@10 317 if (psb->use_esmtp) {
meillo@10 318 /* our guess that server understands EHLO was wrong, try again with HELO */
meillo@10 319 psb->use_esmtp = FALSE;
meillo@10 320 } else {
meillo@10 321 /* what sort of server ist THAT ?! give up... */
meillo@10 322 return FALSE;
meillo@10 323 }
meillo@10 324 } else
meillo@10 325 return FALSE;
meillo@10 326 }
meillo@0 327 }
meillo@0 328 }
meillo@0 329
meillo@10 330 static void
meillo@10 331 smtp_cmd_mailfrom(smtp_base * psb, address * return_path, guint size)
meillo@0 332 {
meillo@10 333 if (psb->use_size) {
meillo@10 334 fprintf(psb->out, "MAIL FROM:%s SIZE=%d\r\n", addr_string(return_path), size);
meillo@10 335 fflush(psb->out);
meillo@0 336
meillo@177 337 DEBUG(4) debugf("C: MAIL FROM:%s SIZE=%d\r\n", addr_string(return_path), size);
meillo@0 338
meillo@10 339 } else {
meillo@10 340 fprintf(psb->out, "MAIL FROM:%s\r\n", addr_string(return_path));
meillo@10 341 fflush(psb->out);
meillo@0 342
meillo@177 343 DEBUG(4) debugf("C: MAIL FROM:%s\r\n", addr_string(return_path));
meillo@10 344 }
meillo@0 345 }
meillo@0 346
meillo@10 347 static void
meillo@10 348 smtp_cmd_rcptto(smtp_base * psb, address * rcpt)
meillo@0 349 {
meillo@10 350 fprintf(psb->out, "RCPT TO:%s\r\n", addr_string(rcpt));
meillo@10 351 fflush(psb->out);
meillo@177 352 DEBUG(4) debugf("C: RCPT TO:%s\n", addr_string(rcpt));
meillo@0 353 }
meillo@0 354
meillo@10 355 static void
meillo@10 356 send_data_line(smtp_base * psb, gchar * data)
meillo@0 357 {
meillo@10 358 /* According to RFC 821 each line should be terminated with CRLF.
meillo@10 359 Since a dot on a line itself marks the end of data, each line
meillo@10 360 beginning with a dot is prepended with another dot.
meillo@10 361 */
meillo@10 362 gchar *ptr;
meillo@15 363 gboolean new_line = TRUE; /* previous versions assumed that each item was exactly one line.
meillo@15 364 This is no longer the case */
meillo@0 365
meillo@10 366 ptr = data;
meillo@10 367 while (*ptr) {
meillo@10 368 int c = (int) (*ptr);
meillo@119 369 if (c == '.' && new_line) {
meillo@119 370 /* dot-stuffing */
meillo@119 371 putc('.', psb->out);
meillo@119 372 }
meillo@10 373 if (c == '\n') {
meillo@119 374 /* CRLF line terminators */
meillo@10 375 putc('\r', psb->out);
meillo@10 376 putc('\n', psb->out);
meillo@10 377 new_line = TRUE;
meillo@10 378 } else {
meillo@10 379 putc(c, psb->out);
meillo@10 380 new_line = FALSE;
meillo@10 381 }
meillo@10 382 ptr++;
meillo@10 383 }
meillo@0 384 }
meillo@0 385
meillo@10 386 static void
meillo@10 387 send_header(smtp_base * psb, GList * hdr_list)
meillo@0 388 {
meillo@10 389 GList *node;
meillo@10 390 gint num_hdrs = 0;
meillo@0 391
meillo@10 392 /* header */
meillo@10 393 if (hdr_list) {
meillo@10 394 foreach(hdr_list, node) {
meillo@10 395 if (node->data) {
meillo@10 396 header *hdr = (header *) (node->data);
meillo@10 397 if (hdr->header) {
meillo@10 398 send_data_line(psb, hdr->header);
meillo@10 399 num_hdrs++;
meillo@10 400 }
meillo@10 401 }
meillo@10 402 }
meillo@0 403 }
meillo@0 404
meillo@10 405 /* empty line separating headers from data: */
meillo@10 406 putc('\r', psb->out);
meillo@10 407 putc('\n', psb->out);
meillo@0 408
meillo@10 409 DEBUG(4) debugf("sent %d headers\n", num_hdrs);
meillo@0 410 }
meillo@0 411
meillo@10 412 static void
meillo@10 413 send_data(smtp_base * psb, message * msg)
meillo@0 414 {
meillo@10 415 GList *node;
meillo@10 416 gint num_lines = 0;
meillo@0 417
meillo@10 418 /* data */
meillo@10 419 if (msg->data_list) {
meillo@10 420 for (node = g_list_first(msg->data_list); node; node = g_list_next(node)) {
meillo@10 421 if (node->data) {
meillo@10 422 send_data_line(psb, node->data);
meillo@10 423 num_lines++;
meillo@10 424 }
meillo@10 425 }
meillo@10 426 }
meillo@0 427
meillo@10 428 DEBUG(4) debugf("sent %d lines of data\n", num_lines);
meillo@0 429
meillo@10 430 fprintf(psb->out, ".\r\n");
meillo@10 431 fflush(psb->out);
meillo@177 432 DEBUG(4) debugf("C: .\n");
meillo@0 433 }
meillo@0 434
meillo@10 435 void
meillo@10 436 smtp_out_mark_rcpts(smtp_base * psb, GList * rcpt_list)
meillo@0 437 {
meillo@10 438 GList *rcpt_node;
meillo@10 439 for (rcpt_node = g_list_first(rcpt_list); rcpt_node; rcpt_node = g_list_next(rcpt_node)) {
meillo@10 440 address *rcpt = (address *) (rcpt_node->data);
meillo@0 441
meillo@10 442 addr_unmark_delivered(rcpt);
meillo@0 443
meillo@10 444 if ((psb->error == smtp_trylater) || (psb->error == smtp_timeout) || (psb->error == smtp_eof)) {
meillo@10 445 addr_mark_defered(rcpt);
meillo@10 446 } else {
meillo@10 447 addr_mark_failed(rcpt);
meillo@10 448 }
meillo@10 449 }
meillo@0 450 }
meillo@0 451
meillo@10 452 void
meillo@10 453 smtp_out_log_failure(smtp_base * psb, message * msg)
meillo@0 454 {
meillo@10 455 gchar *err_str;
meillo@0 456
meillo@10 457 if (psb->error == smtp_timeout)
meillo@10 458 err_str = g_strdup("connection timed out.");
meillo@10 459 else if (psb->error == smtp_eof)
meillo@10 460 err_str = g_strdup("connection terminated prematurely.");
meillo@10 461 else if (psb->error == smtp_syntax)
meillo@10 462 err_str = g_strdup_printf("got unexpected response: %s", psb->buffer);
meillo@10 463 else if (psb->error == smtp_cancel)
meillo@10 464 err_str = g_strdup("delivery was canceled.\n");
meillo@10 465 else
meillo@10 466 /* error message should still be in the buffer */
meillo@10 467 err_str = g_strdup_printf("failed: %s\n", psb->buffer);
meillo@0 468
meillo@10 469 if (msg == NULL)
meillo@10 470 logwrite(LOG_NOTICE, "host=%s %s\n", psb->remote_host, err_str);
meillo@10 471 else
meillo@10 472 logwrite(LOG_NOTICE, "%s == host=%s %s\n", msg->uid, psb->remote_host, err_str);
meillo@0 473
meillo@10 474 g_free(err_str);
meillo@0 475 }
meillo@0 476
meillo@10 477 smtp_base*
meillo@10 478 smtp_out_open(gchar * host, gint port, GList * resolve_list)
meillo@0 479 {
meillo@10 480 smtp_base *psb;
meillo@10 481 gint sock;
meillo@10 482 mxip_addr *addr;
meillo@0 483
meillo@10 484 DEBUG(5) debugf("smtp_out_open entered, host = %s\n", host);
meillo@0 485
meillo@10 486 if ((addr = connect_resolvelist(&sock, host, port, resolve_list))) {
meillo@10 487 /* create structure to hold status data: */
meillo@10 488 psb = create_smtpbase(sock);
meillo@10 489 psb->remote_host = addr->name;
meillo@0 490
meillo@10 491 DEBUG(5) {
meillo@10 492 struct sockaddr_in name;
meillo@10 493 int len = sizeof(struct sockaddr);
meillo@10 494 getsockname(sock, (struct sockaddr *) (&name), &len);
meillo@10 495 debugf("socket: name.sin_addr = %s\n", inet_ntoa(name.sin_addr));
meillo@10 496 }
meillo@10 497 return psb;
meillo@10 498 } else {
meillo@10 499 DEBUG(5) debugf("connect_resolvelist failed: %s %s\n", strerror(errno), hstrerror(h_errno));
meillo@10 500 }
meillo@0 501
meillo@10 502 return NULL;
meillo@0 503 }
meillo@0 504
meillo@10 505 smtp_base*
meillo@10 506 smtp_out_open_child(gchar * cmd)
meillo@0 507 {
meillo@10 508 smtp_base *psb;
meillo@10 509 gint sock;
meillo@0 510
meillo@10 511 DEBUG(5) debugf("smtp_out_open_child entered, cmd = %s\n", cmd);
meillo@0 512
meillo@10 513 sock = child(cmd);
meillo@0 514
meillo@10 515 if (sock > 0) {
meillo@10 516 psb = create_smtpbase(sock);
meillo@10 517 psb->remote_host = NULL;
meillo@0 518
meillo@10 519 return psb;
meillo@10 520 }
meillo@0 521
meillo@10 522 return NULL;
meillo@0 523 }
meillo@0 524
meillo@10 525 gboolean
meillo@10 526 smtp_out_rset(smtp_base * psb)
meillo@0 527 {
meillo@10 528 gboolean ok;
meillo@0 529
meillo@10 530 fprintf(psb->out, "RSET\r\n");
meillo@10 531 fflush(psb->out);
meillo@177 532 DEBUG(4) debugf("C: RSET\n");
meillo@0 533
meillo@10 534 if ((ok = read_response(psb, SMTP_CMD_TIMEOUT)))
meillo@10 535 if (check_response(psb, FALSE))
meillo@10 536 return TRUE;
meillo@0 537
meillo@10 538 smtp_out_log_failure(psb, NULL);
meillo@10 539
meillo@10 540 return FALSE;
meillo@0 541 }
meillo@0 542
meillo@0 543 #ifdef ENABLE_AUTH
meillo@0 544
meillo@10 545 static gboolean
meillo@10 546 smtp_out_auth_cram_md5(smtp_base * psb)
meillo@0 547 {
meillo@10 548 gboolean ok = FALSE;
meillo@0 549
meillo@177 550 fprintf(psb->out, "C: AUTH CRAM-MD5\r\n");
meillo@10 551 fflush(psb->out);
meillo@10 552 DEBUG(4) debugf("AUTH CRAM-MD5\n");
meillo@10 553 if ((ok = read_response(psb, SMTP_CMD_TIMEOUT))) {
meillo@10 554 if ((ok = check_response(psb, TRUE))) {
meillo@10 555 gchar *chall64 = get_response_arg(&(psb->buffer[4]));
meillo@10 556 gint chall_size;
meillo@10 557 gchar *chall = base64_decode(chall64, &chall_size);
meillo@10 558 guchar digest[16], *reply64, *reply;
meillo@10 559 gchar digest_string[33];
meillo@10 560 gint i;
meillo@0 561 #ifdef USE_LIB_CRYPTO
meillo@10 562 unsigned int digest_len;
meillo@0 563 #endif
meillo@10 564
meillo@114 565 DEBUG(5) debugf("smtp_out_auth_cram_md5():\n");
meillo@114 566 DEBUG(5) debugf(" encoded challenge = %s\n", chall64);
meillo@114 567 DEBUG(5) debugf(" decoded challenge = %s, size = %d\n", chall, chall_size);
meillo@114 568 DEBUG(5) debugf(" secret = %s\n", psb->auth_secret);
meillo@10 569
meillo@0 570 #ifdef USE_LIB_CRYPTO
meillo@10 571 HMAC(EVP_md5(), psb->auth_secret, strlen(psb->auth_secret), chall, chall_size, digest, &digest_len);
meillo@0 572 #else
meillo@10 573 hmac_md5(chall, chall_size, psb->auth_secret, strlen(psb->auth_secret), digest);
meillo@0 574 #endif
meillo@10 575
meillo@10 576 for (i = 0; i < 16; i++)
meillo@10 577 sprintf(&(digest_string[i + i]), "%02x", (unsigned int) (digest[i]));
meillo@15 578 digest_string[32] = '\0';
meillo@10 579
meillo@114 580 DEBUG(5) debugf(" digest = %s\n", digest_string);
meillo@10 581
meillo@10 582 reply = g_strdup_printf("%s %s", psb->auth_login, digest_string);
meillo@114 583 DEBUG(5) debugf(" unencoded reply = %s\n", reply);
meillo@10 584
meillo@10 585 reply64 = base64_encode(reply, strlen(reply));
meillo@114 586 DEBUG(5) debugf(" encoded reply = %s\n", reply64);
meillo@10 587
meillo@10 588 fprintf(psb->out, "%s\r\n", reply64);
meillo@10 589 fflush(psb->out);
meillo@177 590 DEBUG(6) debugf(" reply64 = %s\n", reply64);
meillo@177 591 DEBUG(6) debugf("C: %s\n", reply64);
meillo@10 592
meillo@10 593 if ((ok = read_response(psb, SMTP_CMD_TIMEOUT)))
meillo@10 594 ok = check_response(psb, FALSE);
meillo@10 595
meillo@10 596 g_free(reply64);
meillo@10 597 g_free(reply);
meillo@10 598 g_free(chall);
meillo@10 599 g_free(chall64);
meillo@10 600 }
meillo@10 601 }
meillo@10 602 return ok;
meillo@0 603 }
meillo@0 604
meillo@10 605 static gboolean
meillo@10 606 smtp_out_auth_login(smtp_base * psb)
meillo@0 607 {
meillo@10 608 gboolean ok = FALSE;
meillo@10 609 fprintf(psb->out, "AUTH LOGIN\r\n");
meillo@10 610 fflush(psb->out);
meillo@177 611 DEBUG(4) debugf("C: AUTH LOGIN\r\n");
meillo@10 612 if ((ok = read_response(psb, SMTP_CMD_TIMEOUT))) {
meillo@10 613 if ((ok = check_response(psb, TRUE))) {
meillo@10 614 gchar *resp64;
meillo@10 615 guchar *resp;
meillo@10 616 gint resp_size;
meillo@10 617 gchar *reply64;
meillo@10 618
meillo@114 619 DEBUG(5) debugf("smtp_out_auth_login():\n");
meillo@10 620 resp64 = get_response_arg(&(psb->buffer[4]));
meillo@114 621 DEBUG(5) debugf(" encoded response = %s\n", resp64);
meillo@10 622 resp = base64_decode(resp64, &resp_size);
meillo@10 623 g_free(resp64);
meillo@114 624 DEBUG(5) debugf(" decoded response = %s, size = %d\n", resp, resp_size);
meillo@10 625 g_free(resp);
meillo@10 626 reply64 = base64_encode(psb->auth_login, strlen(psb->auth_login));
meillo@10 627 fprintf(psb->out, "%s\r\n", reply64);
meillo@10 628 fflush(psb->out);
meillo@177 629 DEBUG(6) debugf("C: %s\n", reply64);
meillo@10 630 g_free(reply64);
meillo@10 631 if ((ok = read_response(psb, SMTP_CMD_TIMEOUT))) {
meillo@10 632 if ((ok = check_response(psb, TRUE))) {
meillo@10 633 resp64 = get_response_arg(&(psb->buffer[4]));
meillo@114 634 DEBUG(5) debugf(" encoded response = %s\n", resp64);
meillo@10 635 resp = base64_decode(resp64, &resp_size);
meillo@10 636 g_free(resp64);
meillo@114 637 DEBUG(5) debugf(" decoded response = %s, size = %d\n", resp, resp_size);
meillo@10 638 g_free(resp);
meillo@10 639 reply64 = base64_encode(psb->auth_secret, strlen(psb->auth_secret));
meillo@10 640 fprintf(psb->out, "%s\r\n", reply64);
meillo@10 641 fflush(psb->out);
meillo@177 642 DEBUG(6) debugf("C: %s\n", reply64);
meillo@10 643 g_free(reply64);
meillo@10 644 if ((ok = read_response(psb, SMTP_CMD_TIMEOUT)))
meillo@10 645 ok = check_response(psb, FALSE);
meillo@10 646 }
meillo@10 647 }
meillo@10 648 }
meillo@0 649 }
meillo@10 650 return ok;
meillo@0 651 }
meillo@0 652
meillo@10 653 gboolean
meillo@10 654 smtp_out_auth(smtp_base * psb)
meillo@0 655 {
meillo@10 656 gboolean ok = FALSE;
meillo@10 657 gint i = 0;
meillo@10 658 while (psb->auth_names[i]) {
meillo@10 659 if (strcasecmp(psb->auth_names[i], psb->auth_name) == 0)
meillo@10 660 break;
meillo@10 661 i++;
meillo@10 662 }
meillo@10 663 if (psb->auth_names[i]) {
meillo@10 664 if (strcasecmp(psb->auth_name, "cram-md5") == 0) {
meillo@10 665 smtp_out_auth_cram_md5(psb);
meillo@10 666 } else if (strcasecmp(psb->auth_name, "login") == 0) {
meillo@10 667 smtp_out_auth_login(psb);
meillo@10 668 } else {
meillo@10 669 logwrite(LOG_ERR, "auth method %s not supported\n", psb->auth_name);
meillo@10 670 }
meillo@10 671 } else {
meillo@10 672 logwrite(LOG_ERR, "no auth method %s found.\n", psb->auth_name);
meillo@10 673 }
meillo@10 674 return ok;
meillo@0 675 }
meillo@0 676
meillo@0 677 #endif
meillo@0 678
meillo@10 679 gboolean
meillo@10 680 smtp_out_init(smtp_base * psb)
meillo@0 681 {
meillo@10 682 gboolean ok;
meillo@0 683
meillo@10 684 if ((ok = read_response(psb, SMTP_INITIAL_TIMEOUT))) {
meillo@10 685 if ((ok = check_init_response(psb))) {
meillo@10 686
meillo@10 687 if ((ok = smtp_helo(psb, psb->helo_name))) {
meillo@0 688 #ifdef ENABLE_AUTH
meillo@10 689 if (psb->auth_name && psb->use_auth) {
meillo@10 690 /* we completely disregard the response of server here. If
meillo@10 691 authentication fails, the server will complain later
meillo@10 692 anyway. I know, this is not polite... */
meillo@10 693 smtp_out_auth(psb);
meillo@10 694 }
meillo@10 695 #endif
meillo@10 696 }
meillo@10 697 }
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@10 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@10 869 logwrite(LOG_NOTICE, "%s => %s host=%s with %s\n", msg->uid, addr_string(rcpt),
meillo@10 870 psb->remote_host, psb->use_esmtp ? "esmtp" : "smtp");
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@10 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@10 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@10 911 if (smtp_out_init(psb)) {
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 }