masqmail

annotate src/smtp_out.c @ 43:90644c204265

find changesets by author, revision, files, or words in the commit message
we already have an always-bcc feature: log_user
author meillo@marmaro.de
date Mon, 17 May 2010 12:07:33 +0200
parents 26e34ae9a3e3
children a80ebfa16cd5
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@0 177
meillo@10 178 return TRUE;
meillo@0 179 }
meillo@0 180
meillo@10 181 static gboolean
meillo@10 182 check_response(smtp_base * psb, gboolean after_data)
meillo@0 183 {
meillo@10 184 char c = psb->buffer[0];
meillo@0 185
meillo@10 186 if (((c == '2') && !after_data) || ((c == '3') && after_data)) {
meillo@10 187 psb->error = smtp_ok;
meillo@10 188 DEBUG(6) debugf("response OK:'%s' after_date = %d\n", psb->buffer, (int) after_data);
meillo@10 189 return TRUE;
meillo@10 190 } else {
meillo@10 191 if (c == '4')
meillo@10 192 psb->error = smtp_trylater;
meillo@10 193 else if (c == '5')
meillo@10 194 psb->error = smtp_fail;
meillo@10 195 else
meillo@10 196 psb->error = smtp_syntax;
meillo@10 197 DEBUG(6) debugf("response failure:'%s' after_date = %d\n", psb->buffer, (int) after_data);
meillo@10 198 return FALSE;
meillo@10 199 }
meillo@0 200 }
meillo@0 201
meillo@10 202 static gboolean
meillo@10 203 check_init_response(smtp_base * psb)
meillo@0 204 {
meillo@10 205 if (check_response(psb, FALSE)) {
meillo@10 206 psb->use_esmtp = (strstr(psb->buffer, "ESMTP") != NULL);
meillo@0 207
meillo@10 208 DEBUG(4) debugf(psb->use_esmtp ? "uses esmtp\n" : "no esmtp\n");
meillo@0 209
meillo@10 210 return TRUE;
meillo@10 211 }
meillo@10 212 return FALSE;
meillo@0 213 }
meillo@0 214
meillo@10 215 static gchar*
meillo@10 216 get_response_arg(gchar * response)
meillo@0 217 {
meillo@10 218 gchar buf[SMTP_BUF_LEN];
meillo@10 219 gchar *p = response, *q = buf;
meillo@0 220
meillo@10 221 while (*p && (*p != '\n') && isspace(*p))
meillo@10 222 p++;
meillo@10 223 if (*p && (*p != '\n')) {
meillo@10 224 while (*p && (*p != '\n') && (*p != '\r') && (q < buf + SMTP_BUF_LEN - 1))
meillo@10 225 *(q++) = *(p++);
meillo@15 226 *q = '\0';
meillo@10 227 return g_strdup(buf);
meillo@10 228 }
meillo@10 229 return NULL;
meillo@0 230 }
meillo@0 231
meillo@10 232 static gboolean
meillo@10 233 check_helo_response(smtp_base * psb)
meillo@0 234 {
meillo@10 235 gchar *ptr = psb->buffer;
meillo@0 236
meillo@10 237 if (!check_response(psb, FALSE))
meillo@10 238 return FALSE;
meillo@0 239
meillo@10 240 while (*ptr) {
meillo@10 241 if (strncasecmp(&(ptr[4]), "SIZE", 4) == 0) {
meillo@10 242 gchar *arg;
meillo@10 243 psb->use_size = TRUE;
meillo@10 244 arg = get_response_arg(&(ptr[8]));
meillo@10 245 if (arg) {
meillo@10 246 psb->max_size = atoi(arg);
meillo@10 247 g_free(arg);
meillo@10 248 }
meillo@10 249 }
meillo@0 250
meillo@10 251 if (strncasecmp(&(ptr[4]), "PIPELINING", 10) == 0)
meillo@10 252 psb->use_pipelining = TRUE;
meillo@0 253
meillo@10 254 if (strncasecmp(&(ptr[4]), "AUTH", 4) == 0) {
meillo@10 255 if ((ptr[8] == ' ') || (ptr[8] == '=') || (ptr[8] == '\t')) { /* not sure about '\t' */
meillo@10 256 gchar *arg;
meillo@10 257 psb->use_auth = TRUE;
meillo@10 258 arg = get_response_arg(&(ptr[9])); /* after several years I finally learnt to count */
meillo@10 259 if (arg) {
meillo@10 260 psb->auth_names = g_strsplit(arg, " ", 0);
meillo@10 261 g_free(arg);
meillo@10 262
meillo@10 263 DEBUG(4) {
meillo@10 264 gint i = 0;
meillo@10 265 while (psb->auth_names[i]) {
meillo@10 266 debugf("offered AUTH %s\n", psb->auth_names[i]);
meillo@10 267 i++;
meillo@10 268 }
meillo@10 269 }
meillo@10 270 }
meillo@10 271 }
meillo@10 272 }
meillo@10 273
meillo@10 274 while (*ptr != '\n')
meillo@10 275 ptr++;
meillo@10 276 ptr++;
meillo@0 277 }
meillo@0 278
meillo@10 279 DEBUG(4) {
meillo@10 280 debugf(psb->use_size ? "uses SIZE\n" : "no size\n");
meillo@10 281 debugf(psb->use_pipelining ? "uses PIPELINING\n" : "no pipelining\n");
meillo@10 282 debugf(psb->use_auth ? "uses AUTH\n" : "no auth\n");
meillo@10 283 }
meillo@0 284
meillo@10 285 return TRUE;
meillo@0 286 }
meillo@0 287
meillo@10 288 static gboolean
meillo@10 289 smtp_helo(smtp_base * psb, gchar * helo)
meillo@0 290 {
meillo@10 291 while (TRUE) {
meillo@10 292 if (psb->use_esmtp) {
meillo@10 293 fprintf(psb->out, "EHLO %s\r\n", helo);
meillo@10 294 fflush(psb->out);
meillo@0 295
meillo@10 296 DEBUG(4) debugf("EHLO %s\r\n", helo);
meillo@0 297
meillo@10 298 } else {
meillo@10 299 fprintf(psb->out, "HELO %s\r\n", helo);
meillo@10 300 fflush(psb->out);
meillo@0 301
meillo@10 302 DEBUG(4) debugf("HELO %s\r\n", helo);
meillo@0 303
meillo@10 304 }
meillo@0 305
meillo@10 306 if (!read_response(psb, SMTP_CMD_TIMEOUT))
meillo@10 307 return FALSE;
meillo@10 308
meillo@10 309 if (check_helo_response(psb))
meillo@10 310 return TRUE;
meillo@10 311 else {
meillo@10 312 if (psb->error == smtp_fail) {
meillo@10 313 if (psb->use_esmtp) {
meillo@10 314 /* our guess that server understands EHLO was wrong, try again with HELO */
meillo@10 315 psb->use_esmtp = FALSE;
meillo@10 316 } else {
meillo@10 317 /* what sort of server ist THAT ?! give up... */
meillo@10 318 return FALSE;
meillo@10 319 }
meillo@10 320 } else
meillo@10 321 return FALSE;
meillo@10 322 }
meillo@0 323 }
meillo@0 324 }
meillo@0 325
meillo@10 326 static void
meillo@10 327 smtp_cmd_mailfrom(smtp_base * psb, address * return_path, guint size)
meillo@0 328 {
meillo@10 329 if (psb->use_size) {
meillo@10 330 fprintf(psb->out, "MAIL FROM:%s SIZE=%d\r\n", addr_string(return_path), size);
meillo@10 331 fflush(psb->out);
meillo@0 332
meillo@10 333 DEBUG(4) debugf("MAIL FROM:%s SIZE=%d\r\n", addr_string(return_path), size);
meillo@0 334
meillo@10 335 } else {
meillo@10 336 fprintf(psb->out, "MAIL FROM:%s\r\n", addr_string(return_path));
meillo@10 337 fflush(psb->out);
meillo@0 338
meillo@10 339 DEBUG(4) debugf("MAIL FROM:%s\r\n", addr_string(return_path));
meillo@10 340 }
meillo@0 341 }
meillo@0 342
meillo@10 343 static void
meillo@10 344 smtp_cmd_rcptto(smtp_base * psb, address * rcpt)
meillo@0 345 {
meillo@10 346 fprintf(psb->out, "RCPT TO:%s\r\n", addr_string(rcpt));
meillo@10 347 fflush(psb->out);
meillo@10 348 DEBUG(4) debugf("RCPT TO:%s\n", addr_string(rcpt));
meillo@0 349 }
meillo@0 350
meillo@10 351 static void
meillo@10 352 send_data_line(smtp_base * psb, gchar * data)
meillo@0 353 {
meillo@10 354 /* According to RFC 821 each line should be terminated with CRLF.
meillo@10 355 Since a dot on a line itself marks the end of data, each line
meillo@10 356 beginning with a dot is prepended with another dot.
meillo@10 357 */
meillo@10 358 gchar *ptr;
meillo@15 359 gboolean new_line = TRUE; /* previous versions assumed that each item was exactly one line.
meillo@15 360 This is no longer the case */
meillo@0 361
meillo@10 362 ptr = data;
meillo@10 363 while (*ptr) {
meillo@10 364 int c = (int) (*ptr);
meillo@10 365 if (c == '.')
meillo@10 366 if (new_line)
meillo@10 367 putc('.', psb->out);
meillo@10 368 if (c == '\n') {
meillo@10 369 putc('\r', psb->out);
meillo@10 370 putc('\n', psb->out);
meillo@10 371 new_line = TRUE;
meillo@10 372 } else {
meillo@10 373 putc(c, psb->out);
meillo@10 374 new_line = FALSE;
meillo@10 375 }
meillo@10 376 ptr++;
meillo@10 377 }
meillo@0 378 }
meillo@0 379
meillo@10 380 static void
meillo@10 381 send_header(smtp_base * psb, GList * hdr_list)
meillo@0 382 {
meillo@10 383 GList *node;
meillo@10 384 gint num_hdrs = 0;
meillo@0 385
meillo@10 386 /* header */
meillo@10 387 if (hdr_list) {
meillo@10 388 foreach(hdr_list, node) {
meillo@10 389 if (node->data) {
meillo@10 390 header *hdr = (header *) (node->data);
meillo@10 391 if (hdr->header) {
meillo@10 392 send_data_line(psb, hdr->header);
meillo@10 393 num_hdrs++;
meillo@10 394 }
meillo@10 395 }
meillo@10 396 }
meillo@0 397 }
meillo@0 398
meillo@10 399 /* empty line separating headers from data: */
meillo@10 400 putc('\r', psb->out);
meillo@10 401 putc('\n', psb->out);
meillo@0 402
meillo@10 403 DEBUG(4) debugf("sent %d headers\n", num_hdrs);
meillo@0 404 }
meillo@0 405
meillo@10 406 static void
meillo@10 407 send_data(smtp_base * psb, message * msg)
meillo@0 408 {
meillo@10 409 GList *node;
meillo@10 410 gint num_lines = 0;
meillo@0 411
meillo@10 412 /* data */
meillo@10 413 if (msg->data_list) {
meillo@10 414 for (node = g_list_first(msg->data_list); node; node = g_list_next(node)) {
meillo@10 415 if (node->data) {
meillo@10 416 send_data_line(psb, node->data);
meillo@10 417 num_lines++;
meillo@10 418 }
meillo@10 419 }
meillo@10 420 }
meillo@0 421
meillo@10 422 DEBUG(4) debugf("sent %d lines of data\n", num_lines);
meillo@0 423
meillo@10 424 fprintf(psb->out, ".\r\n");
meillo@10 425 fflush(psb->out);
meillo@0 426 }
meillo@0 427
meillo@10 428 void
meillo@10 429 smtp_out_mark_rcpts(smtp_base * psb, GList * rcpt_list)
meillo@0 430 {
meillo@10 431 GList *rcpt_node;
meillo@10 432 for (rcpt_node = g_list_first(rcpt_list); rcpt_node; rcpt_node = g_list_next(rcpt_node)) {
meillo@10 433 address *rcpt = (address *) (rcpt_node->data);
meillo@0 434
meillo@10 435 addr_unmark_delivered(rcpt);
meillo@0 436
meillo@10 437 if ((psb->error == smtp_trylater) || (psb->error == smtp_timeout) || (psb->error == smtp_eof)) {
meillo@10 438 addr_mark_defered(rcpt);
meillo@10 439 } else {
meillo@10 440 addr_mark_failed(rcpt);
meillo@10 441 }
meillo@10 442 }
meillo@0 443 }
meillo@0 444
meillo@10 445 void
meillo@10 446 smtp_out_log_failure(smtp_base * psb, message * msg)
meillo@0 447 {
meillo@10 448 gchar *err_str;
meillo@0 449
meillo@10 450 if (psb->error == smtp_timeout)
meillo@10 451 err_str = g_strdup("connection timed out.");
meillo@10 452 else if (psb->error == smtp_eof)
meillo@10 453 err_str = g_strdup("connection terminated prematurely.");
meillo@10 454 else if (psb->error == smtp_syntax)
meillo@10 455 err_str = g_strdup_printf("got unexpected response: %s", psb->buffer);
meillo@10 456 else if (psb->error == smtp_cancel)
meillo@10 457 err_str = g_strdup("delivery was canceled.\n");
meillo@10 458 else
meillo@10 459 /* error message should still be in the buffer */
meillo@10 460 err_str = g_strdup_printf("failed: %s\n", psb->buffer);
meillo@0 461
meillo@10 462 if (msg == NULL)
meillo@10 463 logwrite(LOG_NOTICE, "host=%s %s\n", psb->remote_host, err_str);
meillo@10 464 else
meillo@10 465 logwrite(LOG_NOTICE, "%s == host=%s %s\n", msg->uid, psb->remote_host, err_str);
meillo@0 466
meillo@10 467 g_free(err_str);
meillo@0 468 }
meillo@0 469
meillo@10 470 smtp_base*
meillo@10 471 smtp_out_open(gchar * host, gint port, GList * resolve_list)
meillo@0 472 {
meillo@10 473 smtp_base *psb;
meillo@10 474 gint sock;
meillo@10 475 mxip_addr *addr;
meillo@0 476
meillo@10 477 DEBUG(5) debugf("smtp_out_open entered, host = %s\n", host);
meillo@0 478
meillo@10 479 if ((addr = connect_resolvelist(&sock, host, port, resolve_list))) {
meillo@10 480 /* create structure to hold status data: */
meillo@10 481 psb = create_smtpbase(sock);
meillo@10 482 psb->remote_host = addr->name;
meillo@0 483
meillo@10 484 DEBUG(5) {
meillo@10 485 struct sockaddr_in name;
meillo@10 486 int len = sizeof(struct sockaddr);
meillo@10 487 getsockname(sock, (struct sockaddr *) (&name), &len);
meillo@10 488 debugf("socket: name.sin_addr = %s\n", inet_ntoa(name.sin_addr));
meillo@10 489 }
meillo@10 490 return psb;
meillo@10 491 } else {
meillo@10 492 DEBUG(5) debugf("connect_resolvelist failed: %s %s\n", strerror(errno), hstrerror(h_errno));
meillo@10 493 }
meillo@0 494
meillo@10 495 return NULL;
meillo@0 496 }
meillo@0 497
meillo@10 498 smtp_base*
meillo@10 499 smtp_out_open_child(gchar * cmd)
meillo@0 500 {
meillo@10 501 smtp_base *psb;
meillo@10 502 gint sock;
meillo@0 503
meillo@10 504 DEBUG(5) debugf("smtp_out_open_child entered, cmd = %s\n", cmd);
meillo@0 505
meillo@10 506 sock = child(cmd);
meillo@0 507
meillo@10 508 if (sock > 0) {
meillo@10 509 psb = create_smtpbase(sock);
meillo@10 510 psb->remote_host = NULL;
meillo@0 511
meillo@10 512 return psb;
meillo@10 513 }
meillo@0 514
meillo@10 515 return NULL;
meillo@0 516 }
meillo@0 517
meillo@10 518 gboolean
meillo@10 519 smtp_out_rset(smtp_base * psb)
meillo@0 520 {
meillo@10 521 gboolean ok;
meillo@0 522
meillo@10 523 fprintf(psb->out, "RSET\r\n");
meillo@10 524 fflush(psb->out);
meillo@10 525 DEBUG(4) debugf("RSET\n");
meillo@0 526
meillo@10 527 if ((ok = read_response(psb, SMTP_CMD_TIMEOUT)))
meillo@10 528 if (check_response(psb, FALSE))
meillo@10 529 return TRUE;
meillo@0 530
meillo@10 531 smtp_out_log_failure(psb, NULL);
meillo@10 532
meillo@10 533 return FALSE;
meillo@0 534 }
meillo@0 535
meillo@0 536 #ifdef ENABLE_AUTH
meillo@0 537
meillo@10 538 static gboolean
meillo@10 539 smtp_out_auth_cram_md5(smtp_base * psb)
meillo@0 540 {
meillo@10 541 gboolean ok = FALSE;
meillo@0 542
meillo@10 543 fprintf(psb->out, "AUTH CRAM-MD5\r\n");
meillo@10 544 fflush(psb->out);
meillo@10 545 DEBUG(4) debugf("AUTH CRAM-MD5\n");
meillo@10 546 if ((ok = read_response(psb, SMTP_CMD_TIMEOUT))) {
meillo@10 547 if ((ok = check_response(psb, TRUE))) {
meillo@10 548 gchar *chall64 = get_response_arg(&(psb->buffer[4]));
meillo@10 549 gint chall_size;
meillo@10 550 gchar *chall = base64_decode(chall64, &chall_size);
meillo@10 551 guchar digest[16], *reply64, *reply;
meillo@10 552 gchar digest_string[33];
meillo@10 553 gint i;
meillo@0 554 #ifdef USE_LIB_CRYPTO
meillo@10 555 unsigned int digest_len;
meillo@0 556 #endif
meillo@10 557
meillo@10 558 DEBUG(5) debugf("encoded challenge = %s\n", chall64);
meillo@10 559 DEBUG(5) debugf("decoded challenge = %s, size = %d\n", chall, chall_size);
meillo@10 560
meillo@10 561 DEBUG(5) debugf("secret = %s\n", psb->auth_secret);
meillo@10 562
meillo@0 563 #ifdef USE_LIB_CRYPTO
meillo@10 564 HMAC(EVP_md5(), psb->auth_secret, strlen(psb->auth_secret), chall, chall_size, digest, &digest_len);
meillo@0 565 #else
meillo@10 566 hmac_md5(chall, chall_size, psb->auth_secret, strlen(psb->auth_secret), digest);
meillo@0 567 #endif
meillo@10 568
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@10 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@10 576 DEBUG(5) debugf("unencoded reply = %s\n", reply);
meillo@10 577
meillo@10 578 reply64 = base64_encode(reply, strlen(reply));
meillo@10 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@10 583 DEBUG(4) debugf("%s\n", reply64);
meillo@10 584
meillo@10 585 if ((ok = read_response(psb, SMTP_CMD_TIMEOUT)))
meillo@10 586 ok = check_response(psb, FALSE);
meillo@10 587
meillo@10 588 g_free(reply64);
meillo@10 589 g_free(reply);
meillo@10 590 g_free(chall);
meillo@10 591 g_free(chall64);
meillo@10 592 }
meillo@10 593 }
meillo@10 594 return ok;
meillo@0 595 }
meillo@0 596
meillo@10 597 static gboolean
meillo@10 598 smtp_out_auth_login(smtp_base * psb)
meillo@0 599 {
meillo@10 600 gboolean ok = FALSE;
meillo@10 601 fprintf(psb->out, "AUTH LOGIN\r\n");
meillo@10 602 fflush(psb->out);
meillo@10 603 if ((ok = read_response(psb, SMTP_CMD_TIMEOUT))) {
meillo@10 604 if ((ok = check_response(psb, TRUE))) {
meillo@10 605 gchar *resp64;
meillo@10 606 guchar *resp;
meillo@10 607 gint resp_size;
meillo@10 608 gchar *reply64;
meillo@10 609
meillo@10 610 resp64 = get_response_arg(&(psb->buffer[4]));
meillo@10 611 DEBUG(5) debugf("encoded response = %s\n", resp64);
meillo@10 612 resp = base64_decode(resp64, &resp_size);
meillo@10 613 g_free(resp64);
meillo@10 614 DEBUG(5) debugf("decoded response = %s, size = %d\n", resp, resp_size);
meillo@10 615 g_free(resp);
meillo@10 616 reply64 = base64_encode(psb->auth_login, strlen(psb->auth_login));
meillo@10 617 fprintf(psb->out, "%s\r\n", reply64);
meillo@10 618 fflush(psb->out);
meillo@10 619 g_free(reply64);
meillo@10 620 if ((ok = read_response(psb, SMTP_CMD_TIMEOUT))) {
meillo@10 621 if ((ok = check_response(psb, TRUE))) {
meillo@10 622 resp64 = get_response_arg(&(psb->buffer[4]));
meillo@10 623 DEBUG(5) debugf("encoded response = %s\n", resp64);
meillo@10 624 resp = base64_decode(resp64, &resp_size);
meillo@10 625 g_free(resp64);
meillo@10 626 DEBUG(5) debugf("decoded response = %s, size = %d\n", resp, resp_size);
meillo@10 627 g_free(resp);
meillo@10 628 reply64 = base64_encode(psb->auth_secret, strlen(psb->auth_secret));
meillo@10 629 fprintf(psb->out, "%s\r\n", reply64);
meillo@10 630 fflush(psb->out);
meillo@10 631 g_free(reply64);
meillo@10 632 if ((ok = read_response(psb, SMTP_CMD_TIMEOUT)))
meillo@10 633 ok = check_response(psb, FALSE);
meillo@10 634 }
meillo@10 635 }
meillo@10 636 }
meillo@0 637 }
meillo@10 638 return ok;
meillo@0 639 }
meillo@0 640
meillo@10 641 gboolean
meillo@10 642 smtp_out_auth(smtp_base * psb)
meillo@0 643 {
meillo@10 644 gboolean ok = FALSE;
meillo@10 645 gint i = 0;
meillo@10 646 while (psb->auth_names[i]) {
meillo@10 647 if (strcasecmp(psb->auth_names[i], psb->auth_name) == 0)
meillo@10 648 break;
meillo@10 649 i++;
meillo@10 650 }
meillo@10 651 if (psb->auth_names[i]) {
meillo@10 652 if (strcasecmp(psb->auth_name, "cram-md5") == 0) {
meillo@10 653 smtp_out_auth_cram_md5(psb);
meillo@10 654 } else if (strcasecmp(psb->auth_name, "login") == 0) {
meillo@10 655 smtp_out_auth_login(psb);
meillo@10 656 } else {
meillo@10 657 logwrite(LOG_ERR, "auth method %s not supported\n", psb->auth_name);
meillo@10 658 }
meillo@10 659 } else {
meillo@10 660 logwrite(LOG_ERR, "no auth method %s found.\n", psb->auth_name);
meillo@10 661 }
meillo@10 662 return ok;
meillo@0 663 }
meillo@0 664
meillo@0 665 #endif
meillo@0 666
meillo@10 667 gboolean
meillo@10 668 smtp_out_init(smtp_base * psb)
meillo@0 669 {
meillo@10 670 gboolean ok;
meillo@0 671
meillo@10 672 if ((ok = read_response(psb, SMTP_INITIAL_TIMEOUT))) {
meillo@10 673 if ((ok = check_init_response(psb))) {
meillo@10 674
meillo@10 675 if ((ok = smtp_helo(psb, psb->helo_name))) {
meillo@0 676 #ifdef ENABLE_AUTH
meillo@10 677 if (psb->auth_name && psb->use_auth) {
meillo@10 678 /* we completely disregard the response of server here. If
meillo@10 679 authentication fails, the server will complain later
meillo@10 680 anyway. I know, this is not polite... */
meillo@10 681 smtp_out_auth(psb);
meillo@10 682 }
meillo@10 683 #endif
meillo@10 684 }
meillo@10 685 }
meillo@0 686 }
meillo@10 687 if (!ok)
meillo@10 688 smtp_out_log_failure(psb, NULL);
meillo@10 689 return ok;
meillo@0 690 }
meillo@0 691
meillo@10 692 gint
meillo@10 693 smtp_out_msg(smtp_base * psb, message * msg, address * return_path, GList * rcpt_list, GList * hdr_list)
meillo@0 694 {
meillo@10 695 gint i, size;
meillo@10 696 gboolean ok = TRUE;
meillo@10 697 int rcpt_cnt;
meillo@10 698 int rcpt_accept = 0;
meillo@0 699
meillo@10 700 DEBUG(5) debugf("smtp_out_msg entered\n");
meillo@0 701
meillo@10 702 /* defaults: */
meillo@10 703 if (return_path == NULL)
meillo@10 704 return_path = msg->return_path;
meillo@10 705 if (hdr_list == NULL)
meillo@10 706 hdr_list = msg->hdr_list;
meillo@10 707 if (rcpt_list == NULL)
meillo@10 708 rcpt_list = msg->rcpt_list;
meillo@10 709 rcpt_cnt = g_list_length(rcpt_list);
meillo@0 710
meillo@10 711 size = msg_calc_size(msg, TRUE);
meillo@0 712
meillo@10 713 /* respect maximum size given by server: */
meillo@10 714 if ((psb->max_size > 0) && (size > psb->max_size)) {
meillo@10 715 logwrite(LOG_WARNING, "%s == host=%s message size (%d) > fixed maximum message size of server (%d)",
meillo@10 716 msg->uid, psb->remote_host, size, psb->max_size);
meillo@10 717 psb->error = smtp_cancel;
meillo@10 718 ok = FALSE;
meillo@10 719 }
meillo@0 720
meillo@10 721 if (ok) {
meillo@10 722 smtp_cmd_mailfrom(psb, return_path, psb->use_size ? size + SMTP_SIZE_ADD : 0);
meillo@0 723
meillo@10 724 if (!psb->use_pipelining) {
meillo@10 725 if ((ok = read_response(psb, SMTP_CMD_TIMEOUT)))
meillo@10 726 ok = check_response(psb, FALSE);
meillo@10 727 }
meillo@10 728 }
meillo@10 729 if (ok) {
meillo@10 730 GList *rcpt_node;
meillo@10 731 rcpt_accept = 0;
meillo@0 732
meillo@10 733 for (rcpt_node = g_list_first(rcpt_list); rcpt_node != NULL; rcpt_node = g_list_next(rcpt_node)) {
meillo@10 734 address *rcpt = (address *) (rcpt_node->data);
meillo@10 735 smtp_cmd_rcptto(psb, rcpt);
meillo@10 736 if (!psb->use_pipelining) {
meillo@10 737 if ((ok = read_response(psb, SMTP_CMD_TIMEOUT)))
meillo@10 738 if (check_response(psb, FALSE)) {
meillo@10 739 rcpt_accept++;
meillo@10 740 addr_mark_delivered(rcpt);
meillo@10 741 } else {
meillo@10 742 /* if server returned an error for one recp. we
meillo@10 743 may still try the others. But if it is a timeout, eof
meillo@10 744 or unexpected response, it is more serious and we should
meillo@10 745 give up. */
meillo@10 746 if ((psb->error != smtp_trylater) && (psb->error != smtp_fail)) {
meillo@10 747 ok = FALSE;
meillo@10 748 break;
meillo@10 749 } else {
meillo@15 750 logwrite(LOG_NOTICE, "%s == %s host=%s failed: %s",
meillo@15 751 msg->uid, addr_string(rcpt), psb->remote_host, psb->buffer);
meillo@10 752 if (psb->error == smtp_trylater) {
meillo@10 753 addr_mark_defered(rcpt);
meillo@10 754 } else {
meillo@10 755 addr_mark_failed(rcpt);
meillo@10 756 }
meillo@10 757 }
meillo@10 758 } else
meillo@10 759 break;
meillo@10 760 }
meillo@10 761 }
meillo@0 762
meillo@10 763 /* There is no point in going on if no recp.s were accpted.
meillo@10 764 But we can check that at this point only if not pipelining: */
meillo@10 765 ok = (ok && (psb->use_pipelining || (rcpt_accept > 0)));
meillo@10 766 if (ok) {
meillo@0 767
meillo@10 768 fprintf(psb->out, "DATA\r\n");
meillo@10 769 fflush(psb->out);
meillo@0 770
meillo@10 771 DEBUG(4) debugf("DATA\r\n");
meillo@10 772
meillo@10 773 if (psb->use_pipelining) {
meillo@10 774 /* the first pl'ed command was MAIL FROM
meillo@10 775 the last was DATA, whose response can be handled by the 'normal' code
meillo@10 776 all in between were RCPT TO:
meillo@10 777 */
meillo@10 778 /* response to MAIL FROM: */
meillo@10 779 if ((ok = read_response(psb, SMTP_CMD_TIMEOUT))) {
meillo@10 780 if ((ok = check_response(psb, FALSE))) {
meillo@10 781
meillo@10 782 /* response(s) to RCPT TO:
meillo@10 783 this is very similar to the sequence above for no pipeline
meillo@10 784 */
meillo@10 785 for (i = 0; i < rcpt_cnt; i++) {
meillo@10 786 if ((ok = read_response(psb, SMTP_CMD_TIMEOUT))) {
meillo@10 787 address *rcpt = g_list_nth_data(rcpt_list, i);
meillo@10 788 if (check_response(psb, FALSE)) {
meillo@10 789 rcpt_accept++;
meillo@10 790 addr_mark_delivered(rcpt);
meillo@10 791 } else {
meillo@10 792 /* if server returned an error 4xx or 5xx for one recp. we
meillo@10 793 may still try the others. But if it is a timeout, eof
meillo@10 794 or unexpected response, it is more serious and we
meillo@10 795 should give up. */
meillo@10 796 if ((psb->error != smtp_trylater) &&
meillo@10 797 (psb->error != smtp_fail)) {
meillo@10 798 ok = FALSE;
meillo@10 799 break;
meillo@10 800 } else {
meillo@10 801 logwrite(LOG_NOTICE, "%s == %s host=%s failed: %s", msg->uid,
meillo@10 802 addr_string(rcpt), psb->remote_host, psb->buffer);
meillo@10 803 if (psb->error == smtp_trylater) {
meillo@10 804 addr_mark_defered(rcpt);
meillo@10 805 } else {
meillo@10 806 addr_mark_failed(rcpt);
meillo@10 807 }
meillo@10 808 }
meillo@10 809 }
meillo@10 810 } else {
meillo@10 811 DEBUG(5) debugf("check_response failed after RCPT TO\n");
meillo@10 812 break;
meillo@10 813 }
meillo@10 814 }
meillo@10 815 if (rcpt_accept == 0)
meillo@10 816 ok = FALSE;
meillo@10 817 } else {
meillo@10 818 DEBUG(5) debugf("check_response failed after MAIL FROM\n");
meillo@10 819 }
meillo@10 820 } else {
meillo@10 821 DEBUG(5)
meillo@10 822 debugf("read_response failed after MAIL FROM\n");
meillo@10 823 }
meillo@10 824 }
meillo@10 825
meillo@10 826 /* if(psb->use_pipelining) */
meillo@10 827 /* response to the DATA cmd */
meillo@10 828 if (ok) {
meillo@10 829 if (read_response(psb, SMTP_DATA_TIMEOUT)) {
meillo@10 830 if (check_response(psb, TRUE)) {
meillo@10 831 send_header(psb, hdr_list);
meillo@10 832 send_data(psb, msg);
meillo@10 833
meillo@10 834 if (read_response(psb, SMTP_FINAL_TIMEOUT))
meillo@10 835 ok = check_response(psb, FALSE);
meillo@10 836 }
meillo@10 837 }
meillo@10 838 }
meillo@0 839 }
meillo@10 840 }
meillo@10 841
meillo@10 842 DEBUG(5) {
meillo@10 843 debugf("psb->error = %d\n", psb->error);
meillo@10 844 debugf("ok = %d\n", ok);
meillo@10 845 debugf("rcpt_accept = %d\n", rcpt_accept);
meillo@10 846 }
meillo@10 847
meillo@10 848 if (psb->error == smtp_ok) {
meillo@10 849 GList *rcpt_node;
meillo@10 850 for (rcpt_node = g_list_first(rcpt_list); rcpt_node; rcpt_node = g_list_next(rcpt_node)) {
meillo@10 851 address *rcpt = (address *) (rcpt_node->data);
meillo@10 852 if (addr_is_delivered(rcpt))
meillo@10 853 logwrite(LOG_NOTICE, "%s => %s host=%s with %s\n", msg->uid, addr_string(rcpt),
meillo@10 854 psb->remote_host, psb->use_esmtp ? "esmtp" : "smtp");
meillo@0 855 }
meillo@10 856 } else {
meillo@10 857 /* if something went wrong,
meillo@10 858 we have to unmark the rcpts prematurely marked as delivered
meillo@10 859 and mark the status */
meillo@10 860 smtp_out_mark_rcpts(psb, rcpt_list);
meillo@10 861
meillo@10 862 /* log the failure: */
meillo@10 863 smtp_out_log_failure(psb, msg);
meillo@0 864 }
meillo@10 865 return rcpt_accept;
meillo@0 866 }
meillo@0 867
meillo@10 868 gboolean
meillo@10 869 smtp_out_quit(smtp_base * psb)
meillo@0 870 {
meillo@10 871 fprintf(psb->out, "QUIT\r\n");
meillo@10 872 fflush(psb->out);
meillo@0 873
meillo@10 874 DEBUG(4) debugf("QUIT\n");
meillo@0 875
meillo@10 876 signal(SIGALRM, SIG_DFL);
meillo@10 877
meillo@10 878 return TRUE;
meillo@0 879 }
meillo@10 880
meillo@10 881 gint
meillo@10 882 smtp_deliver(gchar * host, gint port, GList * resolve_list, message * msg, address * return_path, GList * rcpt_list)
meillo@0 883 {
meillo@10 884 smtp_base *psb;
meillo@10 885 smtp_error err;
meillo@0 886
meillo@10 887 DEBUG(5) debugf("smtp_deliver entered\n");
meillo@0 888
meillo@10 889 if (return_path == NULL)
meillo@10 890 return_path = msg->return_path;
meillo@0 891
meillo@10 892 if ((psb = smtp_out_open(host, port, resolve_list))) {
meillo@10 893 set_heloname(psb, return_path->domain, TRUE);
meillo@10 894 /* initiate connection, send message and quit: */
meillo@10 895 if (smtp_out_init(psb)) {
meillo@10 896 smtp_out_msg(psb, msg, return_path, rcpt_list, NULL);
meillo@10 897 if (psb->error == smtp_ok || (psb->error == smtp_fail) || (psb->error == smtp_trylater)
meillo@10 898 || (psb->error == smtp_syntax) || (psb->error == smtp_cancel))
meillo@10 899 smtp_out_quit(psb);
meillo@10 900 }
meillo@10 901
meillo@10 902 err = psb->error;
meillo@10 903 destroy_smtpbase(psb);
meillo@10 904
meillo@10 905 return err;
meillo@10 906 }
meillo@10 907 return -1;
meillo@0 908 }