masqmail

annotate src/deliver.c @ 187:bd7c52a36b0c

find changesets by author, revision, files, or words in the commit message
improved mservdetect in various ways errors are handled better (no segfaults anymore) copied the relevant part of interface.c into mservdetect.c described how I think the mserver protocol works
author meillo@marmaro.de
date Thu, 15 Jul 2010 00:14:26 +0200
parents 91f8ee6514f5
children dc89737b27aa
rev   line source
meillo@0 1 /* MasqMail
meillo@0 2 Copyright (C) 1999-2002 Oliver Kurth
meillo@76 3 Copyright (C) 2008 markus schnalke <meillo@marmaro.de>
meillo@0 4
meillo@0 5 This program is free software; you can redistribute it and/or modify
meillo@0 6 it under the terms of the GNU General Public License as published by
meillo@0 7 the Free Software Foundation; either version 2 of the License, or
meillo@0 8 (at your option) any later version.
meillo@0 9
meillo@0 10 This program is distributed in the hope that it will be useful,
meillo@0 11 but WITHOUT ANY WARRANTY; without even the implied warranty of
meillo@0 12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
meillo@0 13 GNU General Public License for more details.
meillo@0 14
meillo@0 15 You should have received a copy of the GNU General Public License
meillo@0 16 along with this program; if not, write to the Free Software
meillo@0 17 Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
meillo@0 18 */
meillo@0 19
meillo@0 20 #include <fnmatch.h>
meillo@0 21 #include <sysexits.h>
meillo@0 22 #include <netdb.h>
meillo@0 23
meillo@15 24 #include "masqmail.h"
meillo@15 25 #include "smtp_out.h"
meillo@15 26
meillo@0 27 /* collect failed/defered rcpts for failure/warning messages */
meillo@15 28 /* returns TRUE if either there are no failures or a failure message has been successfully sent */
meillo@10 29 gboolean
meillo@10 30 delivery_failures(message * msg, GList * rcpt_list, gchar * err_fmt, ...)
meillo@0 31 {
meillo@10 32 gboolean ok_fail = TRUE, ok_warn = TRUE;
meillo@10 33 time_t now = time(NULL);
meillo@0 34
meillo@10 35 GList *failed_list = NULL, *defered_list = NULL, *rcpt_node;
meillo@10 36 va_list args;
meillo@10 37 va_start(args, err_fmt);
meillo@0 38
meillo@10 39 foreach(rcpt_list, rcpt_node) {
meillo@10 40 address *rcpt = (address *) (rcpt_node->data);
meillo@10 41
meillo@10 42 if (addr_is_defered(rcpt)) {
meillo@10 43 if ((now - msg->received_time) >= conf.max_defer_time) {
meillo@10 44 addr_mark_failed(rcpt);
meillo@10 45 } else
meillo@10 46 defered_list = g_list_prepend(defered_list, rcpt);
meillo@10 47 }
meillo@10 48 if (addr_is_failed(rcpt))
meillo@10 49 failed_list = g_list_prepend(failed_list, rcpt);
meillo@10 50 }
meillo@10 51 if (failed_list != NULL) {
meillo@10 52 ok_fail = fail_msg(msg, conf.errmsg_file, failed_list, err_fmt, args);
meillo@10 53 g_list_free(failed_list);
meillo@10 54 }
meillo@10 55 if (defered_list != NULL) {
meillo@10 56 ok_warn = warn_msg(msg, conf.warnmsg_file, defered_list, err_fmt, args);
meillo@10 57 g_list_free(defered_list);
meillo@10 58 }
meillo@10 59 va_end(args);
meillo@10 60 return ok_fail && ok_warn;
meillo@0 61 }
meillo@0 62
meillo@10 63 static gint
meillo@10 64 _g_list_strcasecmp(gconstpointer a, gconstpointer b)
meillo@0 65 {
meillo@10 66 return (gint) strcasecmp(a, b);
meillo@0 67 }
meillo@0 68
meillo@10 69 gboolean
meillo@10 70 deliver_local(msg_out * msgout)
meillo@0 71 {
meillo@10 72 message *msg = msgout->msg;
meillo@10 73 GList *rcpt_list = msgout->rcpt_list;
meillo@10 74 GList *rcpt_node;
meillo@10 75 gboolean ok = TRUE, flag = FALSE, ok_fail = FALSE;
meillo@0 76
meillo@10 77 DEBUG(5) debugf("deliver_local entered\n");
meillo@0 78
meillo@10 79 flag = (msg->data_list == NULL);
meillo@10 80 if (flag) {
meillo@10 81 if (!(ok = spool_read_data(msg))) {
meillo@10 82 logwrite(LOG_ALERT, "could not open data spool file for %s\n", msg->uid);
meillo@10 83 }
meillo@10 84 }
meillo@10 85 if (!ok)
meillo@10 86 return FALSE;
meillo@0 87
meillo@10 88 ok = FALSE;
meillo@10 89 for (rcpt_node = g_list_first(rcpt_list); rcpt_node; rcpt_node = g_list_next(rcpt_node)) {
meillo@10 90 GList *hdr_list;
meillo@10 91 address *rcpt = (address *) (rcpt_node->data);
meillo@10 92 address *env_addr = addr_find_ancestor(rcpt);
meillo@10 93 address *ret_path = msg->return_path;
meillo@10 94 header *retpath_hdr, *envto_hdr;
meillo@0 95
meillo@15 96 /* we need a private copy of the hdr list because we add headers here that belong to the rcpt only.
meillo@15 97 g_list_copy copies only the nodes, so it is safe to g_list_free it */
meillo@10 98 hdr_list = g_list_copy(msg->hdr_list);
meillo@10 99 retpath_hdr = create_header(HEAD_ENVELOPE_TO, "Envelope-to: %s\n", addr_string(env_addr));
meillo@10 100 envto_hdr = create_header(HEAD_RETURN_PATH, "Return-path: %s\n", addr_string(ret_path));
meillo@0 101
meillo@10 102 hdr_list = g_list_prepend(hdr_list, envto_hdr);
meillo@10 103 hdr_list = g_list_prepend(hdr_list, retpath_hdr);
meillo@0 104
meillo@10 105 if (rcpt->local_part[0] == '|') {
meillo@10 106 DEBUG(1) debugf("attempting to deliver %s with pipe\n", msg->uid);
meillo@10 107 if (pipe_out(msg, hdr_list, rcpt, &(rcpt->local_part[1]),
meillo@10 108 (conf.pipe_fromline ? MSGSTR_FROMLINE : 0)
meillo@10 109 | (conf.pipe_fromhack ? MSGSTR_FROMHACK : 0))) {
meillo@15 110 logwrite(LOG_NOTICE, "%s => %s <%s@%s> with pipe\n",
meillo@15 111 msg->uid, rcpt->local_part, env_addr->local_part, env_addr->domain);
meillo@10 112 addr_mark_delivered(rcpt);
meillo@10 113 ok = TRUE;
meillo@10 114 } else {
meillo@10 115 if ((errno != (1024 + EX_TEMPFAIL)) && (errno != EAGAIN)) {
meillo@10 116 addr_mark_failed(rcpt);
meillo@10 117 } else {
meillo@10 118 addr_mark_defered(rcpt); /* has no effect yet, except that mail remains in spool */
meillo@10 119 }
meillo@10 120 }
meillo@10 121 } else {
meillo@10 122 /* figure out which mailbox type should be used for this user */
meillo@10 123 gchar *user = rcpt->local_part;
meillo@10 124 gchar *mbox_type = conf.mbox_default;
meillo@0 125
meillo@10 126 if (g_list_find_custom (conf.mbox_users, user, _g_list_strcasecmp) != NULL)
meillo@10 127 mbox_type = "mbox";
meillo@10 128 else if (g_list_find_custom (conf.mda_users, user, _g_list_strcasecmp) != NULL)
meillo@10 129 mbox_type = "mda";
meillo@10 130 else if (g_list_find_custom (conf.maildir_users, user, _g_list_strcasecmp) != NULL)
meillo@10 131 mbox_type = "maildir";
meillo@10 132
meillo@10 133 if (strcmp(mbox_type, "mbox") == 0) {
meillo@10 134 DEBUG(1) debugf("attempting to deliver %s with mbox\n", msg->uid);
meillo@10 135 if (append_file(msg, hdr_list, rcpt->local_part)) {
meillo@10 136 if (env_addr != rcpt) {
meillo@10 137 logwrite(LOG_NOTICE, "%s => %s@%s <%s@%s> with mbox\n",
meillo@10 138 msg->uid, rcpt->local_part, rcpt->domain,
meillo@10 139 env_addr->local_part, env_addr->domain);
meillo@10 140 } else {
meillo@10 141 logwrite(LOG_NOTICE, "%s => <%s@%s> with mbox\n",
meillo@10 142 msg->uid, rcpt->local_part, rcpt->domain);
meillo@10 143 }
meillo@10 144 addr_mark_delivered(rcpt);
meillo@10 145 ok = TRUE;
meillo@10 146 } else {
meillo@10 147 if (errno != EAGAIN) { /* prevents 'Resource temporarily unavailable (11)' */
meillo@10 148 addr_mark_failed(rcpt);
meillo@10 149 } else {
meillo@10 150 addr_mark_defered(rcpt);
meillo@10 151 }
meillo@10 152 }
meillo@10 153
meillo@10 154 } else if (strcmp(mbox_type, "mda") == 0) {
meillo@10 155 if (conf.mda) {
meillo@10 156 gchar *cmd = g_malloc(256);
meillo@10 157 GList *var_table = var_table_rcpt(var_table_msg(NULL, msg), rcpt);
meillo@10 158
meillo@10 159 DEBUG(1) debugf("attempting to deliver %s with mda\n", msg->uid);
meillo@10 160
meillo@10 161 if (expand(var_table, conf.mda, cmd, 256)) {
meillo@10 162
meillo@10 163 if (pipe_out(msg, hdr_list, rcpt, cmd, (conf.mda_fromline ? MSGSTR_FROMLINE : 0)
meillo@10 164 | (conf.mda_fromhack ? MSGSTR_FROMHACK : 0))) {
meillo@10 165 logwrite(LOG_NOTICE, "%s => %s@%s with mda (cmd = '%s')\n",
meillo@10 166 msg->uid, rcpt->local_part, rcpt->domain, cmd);
meillo@10 167 addr_mark_delivered(rcpt);
meillo@10 168 ok = TRUE;
meillo@10 169 } else {
meillo@10 170 if ((errno != (1024 + EX_TEMPFAIL)) && (errno != EAGAIN)) {
meillo@10 171 addr_mark_failed(rcpt);
meillo@10 172 } else {
meillo@10 173 addr_mark_defered(rcpt); /* has no effect yet, except that mail remains in spool */
meillo@10 174 }
meillo@10 175 }
meillo@10 176 } else
meillo@10 177 logwrite(LOG_ALERT, "could not expand string %s\n", conf.mda);
meillo@10 178
meillo@10 179 destroy_table(var_table);
meillo@10 180 } else
meillo@10 181 logwrite(LOG_ALERT, "mbox type is mda, but no mda command given in configuration\n");
meillo@0 182
meillo@0 183 #ifdef ENABLE_MAILDIR
meillo@10 184 } else if (strcmp(mbox_type, "maildir") == 0) {
meillo@10 185 DEBUG(1) debugf("attempting to deliver %s with maildir\n", msg->uid);
meillo@10 186 if (maildir_out(msg, hdr_list, rcpt->local_part, 0)) {
meillo@10 187 if (env_addr != rcpt) {
meillo@10 188 logwrite(LOG_NOTICE, "%s => %s@%s <%s@%s> with local\n", msg->uid,
meillo@10 189 rcpt->local_part, rcpt->domain, env_addr->local_part, env_addr->domain);
meillo@10 190 } else {
meillo@10 191 logwrite(LOG_NOTICE, "%s => <%s@%s> with maildir\n", msg->uid,
meillo@10 192 rcpt->local_part, rcpt->domain);
meillo@10 193 }
meillo@10 194 addr_mark_delivered(rcpt);
meillo@10 195 ok = TRUE;
meillo@10 196 } else
meillo@10 197 addr_mark_failed(rcpt);
meillo@0 198 #endif
meillo@10 199 } else
meillo@10 200 logwrite(LOG_ALERT, "unknown mbox type '%s'\n", mbox_type);
meillo@10 201 }
meillo@0 202
meillo@10 203 destroy_header(retpath_hdr);
meillo@10 204 destroy_header(envto_hdr);
meillo@0 205
meillo@10 206 g_list_free(hdr_list);
meillo@10 207 }
meillo@10 208 ok_fail = delivery_failures(msg, rcpt_list, "%s (%d)", ext_strerror(errno), errno);
meillo@0 209
meillo@10 210 if (flag)
meillo@10 211 msg_free_data(msg);
meillo@10 212 if (ok || ok_fail)
meillo@10 213 deliver_finish(msgout);
meillo@0 214
meillo@10 215 return ok;
meillo@0 216 }
meillo@0 217
meillo@15 218 /* make a list of rcpt's of a message that are local return a new copy of the list */
meillo@10 219 void
meillo@10 220 msg_rcptlist_local(GList * rcpt_list, GList ** p_local_list, GList ** p_nonlocal_list)
meillo@0 221 {
meillo@10 222 GList *rcpt_node;
meillo@0 223
meillo@10 224 foreach(rcpt_list, rcpt_node) {
meillo@10 225 address *rcpt = (address *) (rcpt_node->data);
meillo@10 226 GList *dom_node;
meillo@0 227
meillo@10 228 DEBUG(5) debugf("checking address %s\n", rcpt->address);
meillo@0 229
meillo@10 230 /* search for local host list: */
meillo@10 231 foreach(conf.local_hosts, dom_node) {
meillo@10 232 if (strcasecmp(dom_node->data, rcpt->domain) == 0) {
meillo@10 233 *p_local_list = g_list_append(*p_local_list, rcpt);
meillo@10 234 DEBUG(5) debugf("<%s@%s> is local\n", rcpt->local_part, rcpt->domain);
meillo@10 235 break;
meillo@10 236 } else {
meillo@10 237 *p_nonlocal_list = g_list_append(*p_nonlocal_list, rcpt);
meillo@10 238 }
meillo@10 239 }
meillo@10 240 }
meillo@0 241 }
meillo@0 242
meillo@10 243 gboolean
meillo@10 244 deliver_msglist_host_pipe(connect_route * route, GList * msgout_list, gchar * host, GList * res_list)
meillo@0 245 {
meillo@10 246 gboolean ok = TRUE;
meillo@10 247 GList *msgout_node;
meillo@0 248
meillo@10 249 DEBUG(5) debugf("deliver_msglist_host_pipe entered\n");
meillo@0 250
meillo@10 251 if (route->pipe == NULL) {
meillo@10 252 logwrite(LOG_ALERT, "no pipe command given for route (protocol is pipe!)\n");
meillo@10 253 return FALSE;
meillo@10 254 }
meillo@0 255
meillo@10 256 foreach(msgout_list, msgout_node) {
meillo@10 257 msg_out *msgout = (msg_out *) (msgout_node->data);
meillo@10 258 gboolean flag, ok_msg = TRUE, ok_fail = FALSE;
meillo@10 259 message *msg = msgout->msg;
meillo@10 260 GList *rcpt_node, *rcpt_list = msgout->rcpt_list;
meillo@0 261
meillo@10 262 DEBUG(1) debugf("attempting to deliver %s with pipe\n", msg->uid);
meillo@0 263
meillo@10 264 flag = (msg->data_list == NULL);
meillo@10 265 if (flag) {
meillo@10 266 if (!(ok_msg = spool_read_data(msg))) {
meillo@10 267 logwrite(LOG_ALERT, "could not open data spool file for %s\n", msg->uid);
meillo@10 268 }
meillo@10 269 }
meillo@10 270 if (!ok_msg)
meillo@10 271 continue;
meillo@0 272
meillo@10 273 ok = FALSE;
meillo@10 274 foreach(rcpt_list, rcpt_node) {
meillo@10 275 address *rcpt = (address *) (rcpt_node->data);
meillo@10 276 gchar *cmd = g_malloc(256);
meillo@10 277 GList *var_table = var_table_rcpt(var_table_msg(NULL, msg), rcpt);
meillo@0 278
meillo@10 279 DEBUG(1) debugf("attempting to deliver %s to %s@%s with pipe\n", msg->uid, rcpt->local_part, rcpt->domain);
meillo@10 280
meillo@10 281 if (expand(var_table, route->pipe, cmd, 256)) {
meillo@10 282
meillo@10 283 if (pipe_out(msg, msg->hdr_list, rcpt, cmd, (route->pipe_fromline ? MSGSTR_FROMLINE : 0)
meillo@10 284 | (route->pipe_fromhack ? MSGSTR_FROMHACK : 0))) {
meillo@10 285 logwrite(LOG_NOTICE, "%s => %s@%s with pipe (cmd = '%s')\n",
meillo@10 286 msg->uid, rcpt->local_part, rcpt->domain, cmd);
meillo@10 287 addr_mark_delivered(rcpt);
meillo@10 288 ok = TRUE;
meillo@10 289 } else {
meillo@10 290 logwrite(LOG_ALERT, "pipe_out '%s' failed\n", route->pipe);
meillo@10 291
meillo@10 292 if (route->connect_error_fail) {
meillo@10 293 addr_mark_failed(rcpt);
meillo@10 294 } else {
meillo@10 295 addr_mark_defered(rcpt);
meillo@10 296 }
meillo@10 297 }
meillo@10 298 } else
meillo@10 299 logwrite(LOG_ALERT, "could not expand string %s\n", route->pipe);
meillo@10 300
meillo@10 301 destroy_table(var_table);
meillo@10 302 }
meillo@10 303 ok_fail = delivery_failures(msg, rcpt_list, "%s", strerror(errno));
meillo@10 304
meillo@10 305 if (flag)
meillo@10 306 msg_free_data(msg);
meillo@10 307
meillo@10 308 if (ok || ok_fail)
meillo@10 309 deliver_finish(msgout);
meillo@0 310 }
meillo@0 311
meillo@10 312 return ok;
meillo@0 313 }
meillo@0 314
meillo@15 315 /* deliver list of messages to one host and finishes them if the message was delivered to at least one rcpt.
meillo@10 316 Returns TRUE if at least one msg was delivered to at least one rcpt.
meillo@0 317 */
meillo@10 318 gboolean
meillo@10 319 deliver_msglist_host_smtp(connect_route * route, GList * msgout_list, gchar * host, GList * res_list)
meillo@0 320 {
meillo@10 321 gboolean ok = FALSE;
meillo@10 322 GList *msgout_node;
meillo@10 323 smtp_base *psb;
meillo@178 324 gint port = 25;
meillo@0 325
meillo@10 326 /* paranoid check: */
meillo@10 327 if (msgout_list == NULL) {
meillo@10 328 logwrite(LOG_ALERT, "Ooops: empty list of messages in deliver_msglist_host()\n");
meillo@10 329 return FALSE;
meillo@10 330 }
meillo@10 331
meillo@10 332 if (host == NULL) {
meillo@179 333 /* XXX: what if mail_host isn't set? Is this possible? */
meillo@10 334 host = route->mail_host->address;
meillo@10 335 port = route->mail_host->port;
meillo@178 336 }
meillo@10 337
meillo@0 338 #ifdef ENABLE_POP3
meillo@10 339 if (route->pop3_login) {
meillo@10 340 if (!(pop_before_smtp(route->pop3_login)))
meillo@10 341 return FALSE;
meillo@10 342 }
meillo@0 343 #endif
meillo@0 344
meillo@10 345 if ((psb = (route->wrapper ? smtp_out_open_child(route->wrapper) : smtp_out_open(host, port, res_list)))) {
meillo@0 346
meillo@179 347 if (route->wrapper) {
meillo@179 348 /* it seems as if the remote_host is only set for logging
meillo@179 349 /* XXX: this could probably be moved into smtp_out_open_child() */
meillo@10 350 psb->remote_host = host;
meillo@179 351 }
meillo@0 352
meillo@10 353 set_heloname(psb, route->helo_name ? route->helo_name : conf.host_name, route->do_correct_helo);
meillo@0 354
meillo@0 355 #ifdef ENABLE_AUTH
meillo@12 356 if ((route->auth_name) && (route->auth_login) && (route->auth_secret))
meillo@10 357 set_auth(psb, route->auth_name, route->auth_login, route->auth_secret);
meillo@0 358 #endif
meillo@10 359 if (smtp_out_init(psb)) {
meillo@0 360
meillo@10 361 if (!route->do_pipelining)
meillo@10 362 psb->use_pipelining = FALSE;
meillo@0 363
meillo@10 364 foreach(msgout_list, msgout_node) {
meillo@10 365 msg_out *msgout = (msg_out *) (msgout_node->data);
meillo@10 366 gboolean flag, ok_msg = FALSE, ok_fail = FALSE;
meillo@10 367 message *msg = msgout->msg;
meillo@0 368
meillo@15 369 /* we may have to read the data at this point and remember if we did */
meillo@10 370 flag = (msg->data_list == NULL);
meillo@10 371 if (flag) {
meillo@10 372 if (!spool_read_data(msg)) {
meillo@10 373 logwrite(LOG_ALERT, "could not open data spool file %s\n", msg->uid);
meillo@10 374 break;
meillo@10 375 }
meillo@10 376 }
meillo@10 377
meillo@10 378 smtp_out_msg(psb, msg, msgout->return_path, msgout->rcpt_list, msgout->hdr_list);
meillo@10 379
meillo@15 380 ok_fail = delivery_failures(msg, msgout->rcpt_list,
meillo@15 381 "while connected with %s, the server replied\n\t%s", host, psb->buffer);
meillo@10 382
meillo@10 383 if ((psb->error == smtp_eof)
meillo@10 384 || (psb->error == smtp_timeout)) {
meillo@10 385 /* connection lost */
meillo@10 386 break;
meillo@10 387 } else if (psb->error != smtp_ok) {
meillo@10 388 if (g_list_next(msgout_node) != NULL)
meillo@10 389 if (!smtp_out_rset(psb))
meillo@10 390 break;
meillo@10 391 }
meillo@10 392 ok_msg = (psb->error == smtp_ok);
meillo@10 393
meillo@10 394 if (flag)
meillo@10 395 msg_free_data(msg);
meillo@10 396 if (ok_msg)
meillo@10 397 ok = TRUE;
meillo@10 398 if (ok_msg || ok_fail) {
meillo@10 399 deliver_finish(msgout);
meillo@10 400 }
meillo@10 401 }
meillo@10 402 if (psb->error == smtp_ok || (psb->error == smtp_fail)
meillo@10 403 || (psb->error == smtp_trylater) || (psb->error == smtp_syntax)) {
meillo@10 404 smtp_out_quit(psb);
meillo@10 405 }
meillo@10 406 } else {
meillo@10 407 /* smtp_out_init() failed */
meillo@10 408 if ((psb->error == smtp_fail) || (psb->error == smtp_trylater) || (psb->error == smtp_syntax)) {
meillo@10 409 smtp_out_quit(psb);
meillo@10 410
meillo@10 411 foreach(msgout_list, msgout_node) {
meillo@10 412 msg_out *msgout = (msg_out *) (msgout_node->data);
meillo@10 413 smtp_out_mark_rcpts(psb, msgout->rcpt_list);
meillo@10 414
meillo@10 415 if (delivery_failures(msgout->msg, msgout->rcpt_list,
meillo@10 416 "while connected with %s, the server replied\n\t%s", host, psb->buffer))
meillo@10 417 deliver_finish(msgout);
meillo@10 418 }
meillo@10 419 }
meillo@10 420 }
meillo@10 421 destroy_smtpbase(psb);
meillo@10 422 } else {
meillo@10 423 /* smtp_out_open() failed */
meillo@10 424 foreach(msgout_list, msgout_node) {
meillo@10 425 msg_out *msgout = (msg_out *) (msgout_node->data);
meillo@10 426 GList *rcpt_node;
meillo@10 427
meillo@10 428 for (rcpt_node = g_list_first(msgout->rcpt_list); rcpt_node; rcpt_node = g_list_next(rcpt_node)) {
meillo@10 429 address *rcpt = (address *) (rcpt_node->data);
meillo@10 430
meillo@10 431 addr_unmark_delivered(rcpt);
meillo@10 432 if (route->connect_error_fail) {
meillo@10 433 addr_mark_failed(rcpt);
meillo@10 434 } else {
meillo@10 435 addr_mark_defered(rcpt);
meillo@10 436 }
meillo@10 437 if (route->wrapper
meillo@15 438 ? delivery_failures(msgout->msg, msgout->rcpt_list, "could not open wrapper:\n\t%s",
meillo@10 439 strerror(errno))
meillo@15 440 : delivery_failures(msgout->msg, msgout->rcpt_list, "could not open connection to %s:%d :\n\t%s",
meillo@10 441 host, port, h_errno != 0 ? hstrerror(h_errno) : strerror(errno)))
meillo@10 442 deliver_finish(msgout);
meillo@10 443 }
meillo@10 444 }
meillo@0 445 }
meillo@10 446 return ok;
meillo@0 447 }
meillo@0 448
meillo@10 449 gboolean
meillo@10 450 deliver_msglist_host(connect_route * route, GList * msgout_list, gchar * host, GList * res_list)
meillo@0 451 {
meillo@10 452 DEBUG(5) debugf("protocol = %s\n", route->protocol);
meillo@0 453
meillo@10 454 if (strcmp(route->protocol, "pipe") == 0) {
meillo@10 455 return deliver_msglist_host_pipe(route, msgout_list, host, res_list);
meillo@10 456 } else {
meillo@10 457 return deliver_msglist_host_smtp(route, msgout_list, host, res_list);
meillo@10 458 }
meillo@0 459 }
meillo@0 460
meillo@0 461 /*
meillo@0 462 delivers messages in msgout_list using route
meillo@0 463 */
meillo@10 464 gboolean
meillo@10 465 deliver_route_msgout_list(connect_route * route, GList * msgout_list)
meillo@0 466 {
meillo@10 467 gboolean ok = FALSE;
meillo@0 468
meillo@15 469 DEBUG(5) debugf("deliver_route_msgout_list entered, route->name = %s\n", route->name);
meillo@0 470
meillo@179 471 if (route->mail_host) {
meillo@179 472 /* this is easy... deliver everything to a smart host for relay */
meillo@10 473 if (deliver_msglist_host(route, msgout_list, NULL, route->resolve_list))
meillo@10 474 ok = TRUE;
meillo@0 475
meillo@10 476 } else {
meillo@10 477 /* this is not easy... */
meillo@10 478 GList *mo_ph_list;
meillo@0 479
meillo@10 480 mo_ph_list = route_msgout_list(route, msgout_list);
meillo@10 481 /* okay, now we have ordered our messages by the hosts. */
meillo@10 482 if (mo_ph_list != NULL) {
meillo@10 483 GList *mo_ph_node;
meillo@10 484 /* TODO: It would be nice to be able to fork for each host.
meillo@10 485 We cannot do that yet because of complications with finishing the
meillo@10 486 messages. Threads could be a solution because they use the same
meillo@10 487 memory. But we are not thread safe yet...
meillo@10 488 */
meillo@10 489 foreach(mo_ph_list, mo_ph_node) {
meillo@10 490 msgout_perhost *mo_ph = (msgout_perhost *) (mo_ph_node->data);
meillo@10 491 if (deliver_msglist_host (route, mo_ph->msgout_list, mo_ph->host, route->resolve_list))
meillo@10 492 ok = TRUE;
meillo@10 493
meillo@10 494 destroy_msgout_perhost(mo_ph);
meillo@10 495 }
meillo@10 496 g_list_free(mo_ph_list);
meillo@10 497 }
meillo@10 498 }
meillo@10 499 return ok;
meillo@0 500 }
meillo@0 501
meillo@0 502 /*
meillo@0 503 calls route_prepare_msg()
meillo@15 504 delivers messages in msg_list using route by calling deliver_route_msgout_list()
meillo@0 505 */
meillo@10 506 gboolean
meillo@10 507 deliver_route_msg_list(connect_route * route, GList * msgout_list)
meillo@0 508 {
meillo@10 509 GList *msgout_list_deliver = NULL;
meillo@10 510 GList *msgout_node;
meillo@10 511 gboolean ok = TRUE;
meillo@0 512
meillo@10 513 DEBUG(6) debugf("deliver_route_msg_list()\n");
meillo@0 514
meillo@10 515 foreach(msgout_list, msgout_node) {
meillo@10 516 msg_out *msgout = (msg_out *) (msgout_node->data);
meillo@10 517 msg_out *msgout_cloned = clone_msg_out(msgout);
meillo@10 518 GList *rcpt_list_non_delivered = NULL;
meillo@10 519 GList *rcpt_node;
meillo@0 520
meillo@15 521 /* we have to delete already delivered rcpt's because a previous route may have delivered to it */
meillo@10 522 foreach(msgout_cloned->rcpt_list, rcpt_node) {
meillo@10 523 address *rcpt = (address *) (rcpt_node->data);
meillo@15 524 /* failed addresses already have been bounced - there should be a better way to handle those. */
meillo@10 525 if (!addr_is_delivered(rcpt) && !addr_is_failed(rcpt)
meillo@10 526 && !(rcpt->flags & ADDR_FLAG_LAST_ROUTE))
meillo@10 527 rcpt_list_non_delivered = g_list_append(rcpt_list_non_delivered, rcpt);
meillo@10 528 }
meillo@10 529 g_list_free(msgout_cloned->rcpt_list);
meillo@10 530 msgout_cloned->rcpt_list = rcpt_list_non_delivered;
meillo@0 531
meillo@10 532 if (msgout_cloned->rcpt_list) {
meillo@10 533 if (route_is_allowed_mail_local(route, msgout->msg->return_path)
meillo@10 534 && route_is_allowed_return_path(route, msgout->msg-> return_path)) {
meillo@10 535 GList *rcpt_list_allowed = NULL, *rcpt_list_notallowed = NULL;
meillo@10 536 msg_rcptlist_route(route, msgout_cloned->rcpt_list, &rcpt_list_allowed, &rcpt_list_notallowed);
meillo@0 537
meillo@10 538 if (rcpt_list_allowed != NULL) {
meillo@10 539 logwrite(LOG_NOTICE, "%s using '%s'\n", msgout->msg->uid, route->name);
meillo@0 540
meillo@10 541 g_list_free(msgout_cloned->rcpt_list);
meillo@10 542 msgout_cloned->rcpt_list = rcpt_list_allowed;
meillo@0 543
meillo@10 544 if (route->last_route) {
meillo@10 545 GList *rcpt_node;
meillo@10 546 foreach(msgout_cloned->rcpt_list, rcpt_node) {
meillo@10 547 address *rcpt = (address *) (rcpt_node->data);
meillo@10 548 rcpt->flags |= ADDR_FLAG_LAST_ROUTE;
meillo@10 549 }
meillo@10 550 }
meillo@10 551
meillo@10 552 route_prepare_msgout(route, msgout_cloned);
meillo@10 553 msgout_list_deliver = g_list_append(msgout_list_deliver, msgout_cloned);
meillo@10 554 } else
meillo@10 555 destroy_msg_out(msgout_cloned);
meillo@10 556 } else
meillo@10 557 destroy_msg_out(msgout_cloned);
meillo@10 558 } else
meillo@10 559 destroy_msg_out(msgout_cloned);
meillo@10 560 }
meillo@10 561
meillo@10 562 if (msgout_list_deliver != NULL) {
meillo@10 563 if (deliver_route_msgout_list(route, msgout_list_deliver))
meillo@10 564 ok = TRUE;
meillo@10 565 destroy_msg_out_list(msgout_list_deliver);
meillo@10 566 }
meillo@10 567 return ok;
meillo@0 568 }
meillo@0 569
meillo@0 570 /* copy pointers of delivered addresses to the msg's non_rcpt_list,
meillo@0 571 to make sure that they will not be delivered again.
meillo@0 572 */
meillo@10 573 void
meillo@10 574 update_non_rcpt_list(msg_out * msgout)
meillo@0 575 {
meillo@10 576 GList *rcpt_node;
meillo@10 577 message *msg = msgout->msg;
meillo@0 578
meillo@10 579 foreach(msgout->rcpt_list, rcpt_node) {
meillo@10 580 address *rcpt = (address *) (rcpt_node->data);
meillo@10 581 if (addr_is_delivered(rcpt) || addr_is_failed(rcpt))
meillo@10 582 msg->non_rcpt_list = g_list_append(msg->non_rcpt_list, rcpt);
meillo@10 583 }
meillo@0 584 }
meillo@0 585
meillo@15 586 /* after delivery attempts, we check if there are any rcpt addresses left in the message.
meillo@15 587 If all addresses have been completed, the spool files will be deleted,
meillo@15 588 otherwise the header spool will be written back.
meillo@0 589 We never changed the data spool, so there is no need to write that back.
meillo@0 590
meillo@0 591 returns TRUE if all went well.
meillo@0 592 */
meillo@10 593 gboolean
meillo@10 594 deliver_finish(msg_out * msgout)
meillo@0 595 {
meillo@10 596 GList *rcpt_node;
meillo@10 597 gboolean ok = FALSE;
meillo@10 598 message *msg = msgout->msg;
meillo@10 599 gboolean finished = TRUE;
meillo@0 600
meillo@10 601 update_non_rcpt_list(msgout);
meillo@0 602
meillo@10 603 /* we NEVER made copies of the addresses, flags affecting addresses
meillo@10 604 were always set on the original address structs */
meillo@10 605 foreach(msg->rcpt_list, rcpt_node) {
meillo@10 606 address *rcpt = (address *) (rcpt_node->data);
meillo@10 607 if (!addr_is_finished_children(rcpt))
meillo@10 608 finished = FALSE;
meillo@10 609 else {
meillo@15 610 /* if ALL children have been delivered, mark parent as delivered.
meillo@15 611 if there is one or more not delivered, it must have failed, we mark the parent as failed as well.
meillo@10 612 */
meillo@10 613 if (addr_is_delivered_children(rcpt)) {
meillo@10 614 addr_mark_delivered(rcpt);
meillo@10 615 } else {
meillo@10 616 addr_mark_failed(rcpt);
meillo@10 617 }
meillo@10 618 }
meillo@10 619 }
meillo@10 620
meillo@10 621 if (!finished) {
meillo@10 622 /* one not delivered address was found */
meillo@10 623 if (spool_write(msg, FALSE)) {
meillo@10 624 ok = TRUE;
meillo@10 625 DEBUG(2) debugf("spool header for %s written back.\n", msg->uid);
meillo@10 626 } else
meillo@10 627 logwrite(LOG_ALERT, "could not write back spool header for %s\n", msg->uid);
meillo@10 628 } else {
meillo@10 629 ok = spool_delete_all(msg);
meillo@10 630 if (ok)
meillo@10 631 logwrite(LOG_NOTICE, "%s completed.\n", msg->uid);
meillo@10 632 }
meillo@10 633 return ok;
meillo@0 634 }
meillo@0 635
meillo@10 636 gboolean
meillo@10 637 deliver_finish_list(GList * msgout_list)
meillo@0 638 {
meillo@10 639 gboolean ok = TRUE;
meillo@10 640 GList *msgout_node;
meillo@10 641 foreach(msgout_list, msgout_node) {
meillo@10 642 msg_out *msgout = (msg_out *) (msgout_node->data);
meillo@10 643 if (!deliver_finish(msgout))
meillo@10 644 ok = FALSE;
meillo@0 645 }
meillo@10 646 return ok;
meillo@0 647 }
meillo@0 648
meillo@10 649 gboolean
meillo@10 650 deliver_msgout_list_online(GList * msgout_list)
meillo@10 651 {
meillo@10 652 GList *rf_list = NULL;
meillo@10 653 gchar *connect_name = detect_online();
meillo@10 654 gboolean ok = FALSE;
meillo@0 655
meillo@10 656 if (connect_name != NULL) {
meillo@10 657 logwrite(LOG_NOTICE, "detected online configuration %s\n", connect_name);
meillo@10 658 /* we are online! */
meillo@10 659 rf_list = (GList *) table_find(conf.connect_routes, connect_name);
meillo@10 660 if (rf_list != NULL) {
meillo@10 661 GList *route_list = read_route_list(rf_list, FALSE);
meillo@10 662 if (route_list) {
meillo@10 663 GList *route_node;
meillo@10 664 foreach(route_list, route_node) {
meillo@10 665 connect_route *route = (connect_route *) (route_node->data);
meillo@10 666 ok = deliver_route_msg_list(route, msgout_list);
meillo@10 667 }
meillo@10 668 destroy_route_list(route_list);
meillo@10 669 } else
meillo@10 670 logwrite(LOG_ALERT, "could not read route list '%s'\n", connect_name);
meillo@10 671 } else {
meillo@10 672 logwrite(LOG_ALERT, "route list with name '%s' not found.\n", connect_name);
meillo@10 673 }
meillo@10 674 }
meillo@10 675 return ok;
meillo@10 676 }
meillo@0 677
meillo@10 678 gboolean
meillo@10 679 deliver_msg_list(GList * msg_list, guint flags)
meillo@10 680 {
meillo@10 681 GList *msgout_list = create_msg_out_list(msg_list);
meillo@10 682 GList *local_msgout_list = NULL, *localnet_msgout_list = NULL, *other_msgout_list = NULL;
meillo@10 683 GList *msgout_node;
meillo@10 684 GList *alias_table = NULL;
meillo@10 685 gboolean ok = TRUE;
meillo@0 686
meillo@10 687 if (conf.alias_file) {
meillo@17 688 alias_table = table_read(conf.alias_file, ':');
meillo@10 689 }
meillo@0 690
meillo@10 691 /* sort messages for different deliveries */
meillo@10 692 foreach(msgout_list, msgout_node) {
meillo@10 693 msg_out *msgout = (msg_out *) (msgout_node->data);
meillo@10 694 GList *rcpt_list;
meillo@10 695 GList *local_rcpt_list = NULL;
meillo@10 696 GList *localnet_rcpt_list = NULL;
meillo@10 697 GList *other_rcpt_list;
meillo@0 698
meillo@114 699 if (!spool_lock(msgout->msg->uid)) {
meillo@114 700 DEBUG(5) debugf("spool_lock(%s) failed.\n", msgout->msg->uid);
meillo@10 701 continue;
meillo@114 702 }
meillo@114 703 DEBUG(5) debugf("spool_lock(%s)\n", msgout->msg->uid);
meillo@0 704
meillo@10 705 rcpt_list = g_list_copy(msgout->msg->rcpt_list);
meillo@10 706 if (conf.log_user) {
meillo@10 707 address *addr = create_address_qualified(conf.log_user, TRUE, conf.host_name);
meillo@10 708 if (addr)
meillo@10 709 rcpt_list = g_list_prepend(rcpt_list, addr);
meillo@10 710 }
meillo@10 711 if (alias_table) {
meillo@10 712 GList *aliased_rcpt_list;
meillo@10 713 aliased_rcpt_list = alias_expand(alias_table, rcpt_list, msgout->msg->non_rcpt_list);
meillo@10 714 g_list_free(rcpt_list);
meillo@10 715 rcpt_list = aliased_rcpt_list;
meillo@10 716 }
meillo@0 717
meillo@10 718 /* local recipients */
meillo@10 719 other_rcpt_list = NULL;
meillo@10 720 rcptlist_with_addr_is_local(rcpt_list, &local_rcpt_list, &other_rcpt_list);
meillo@0 721
meillo@10 722 if (flags & DLVR_LOCAL) {
meillo@10 723 if (local_rcpt_list != NULL) {
meillo@10 724 msg_out *local_msgout = clone_msg_out(msgout);
meillo@10 725 local_msgout->rcpt_list = local_rcpt_list;
meillo@10 726 local_msgout_list = g_list_append(local_msgout_list, local_msgout);
meillo@10 727 }
meillo@10 728 }
meillo@0 729
meillo@10 730 g_list_free(rcpt_list);
meillo@0 731
meillo@10 732 /* local net recipients */
meillo@10 733 rcpt_list = other_rcpt_list;
meillo@10 734 other_rcpt_list = NULL;
meillo@10 735 rcptlist_with_one_of_hostlist(rcpt_list, conf.local_nets, &localnet_rcpt_list, &other_rcpt_list);
meillo@0 736
meillo@10 737 if (flags & DLVR_LAN) {
meillo@10 738 if (localnet_rcpt_list != NULL) {
meillo@10 739 msg_out *localnet_msgout = clone_msg_out(msgout);
meillo@10 740 localnet_msgout->rcpt_list = localnet_rcpt_list;
meillo@10 741 localnet_msgout_list = g_list_append(localnet_msgout_list, localnet_msgout);
meillo@10 742 }
meillo@10 743 }
meillo@0 744
meillo@10 745 if (flags & DLVR_ONLINE) {
meillo@10 746 /* the rest, this is online delivery */
meillo@10 747 if (other_rcpt_list != NULL) {
meillo@10 748 msg_out *other_msgout = clone_msg_out(msgout);
meillo@10 749 other_msgout->rcpt_list = other_rcpt_list;
meillo@10 750 other_msgout_list = g_list_append(other_msgout_list, other_msgout);
meillo@10 751 }
meillo@10 752 }
meillo@10 753 }
meillo@0 754
meillo@10 755 if (alias_table)
meillo@10 756 destroy_table(alias_table);
meillo@0 757
meillo@10 758 /* actual delivery */
meillo@10 759 if (local_msgout_list != NULL) {
meillo@114 760 DEBUG(5) debugf("local_msgout_list\n");
meillo@10 761 foreach(local_msgout_list, msgout_node) {
meillo@10 762 msg_out *msgout = (msg_out *) (msgout_node->data);
meillo@10 763 if (!deliver_local(msgout))
meillo@10 764 ok = FALSE;
meillo@10 765 }
meillo@10 766 destroy_msg_out_list(local_msgout_list);
meillo@10 767 }
meillo@0 768
meillo@10 769 if (localnet_msgout_list != NULL) {
meillo@10 770 GList *route_list = NULL;
meillo@10 771 GList *route_node;
meillo@0 772
meillo@114 773 DEBUG(5) debugf("localnet_msgout_list\n");
meillo@10 774 if (conf.local_net_routes)
meillo@10 775 route_list = read_route_list(conf.local_net_routes, TRUE);
meillo@10 776 else
meillo@10 777 route_list = g_list_append(NULL, create_local_route());
meillo@0 778
meillo@10 779 foreach(route_list, route_node) {
meillo@10 780 connect_route *route = (connect_route *) (route_node->data);
meillo@10 781 if (!deliver_route_msg_list(route, localnet_msgout_list))
meillo@10 782 ok = FALSE;
meillo@10 783 }
meillo@10 784 destroy_msg_out_list(localnet_msgout_list);
meillo@10 785 destroy_route_list(route_list);
meillo@10 786 }
meillo@10 787
meillo@10 788 if (other_msgout_list != NULL) {
meillo@114 789 DEBUG(5) debugf("other_msgout_list\n");
meillo@10 790 if (!deliver_msgout_list_online(other_msgout_list))
meillo@10 791 ok = FALSE;
meillo@10 792 destroy_msg_out_list(other_msgout_list);
meillo@10 793 }
meillo@10 794
meillo@10 795 foreach(msgout_list, msgout_node) {
meillo@10 796 msg_out *msgout = (msg_out *) (msgout_node->data);
meillo@114 797 if (spool_unlock(msgout->msg->uid)) {
meillo@114 798 DEBUG(5) debugf("spool_unlock(%s)\n", msgout->msg->uid);
meillo@114 799 } else {
meillo@114 800 DEBUG(5) debugf("spool_unlock(%s) failed.\n", msgout->msg->uid);
meillo@114 801 }
meillo@114 802
meillo@10 803 }
meillo@10 804
meillo@10 805 destroy_msg_out_list(msgout_list);
meillo@10 806
meillo@10 807 return ok;
meillo@0 808 }
meillo@0 809
meillo@0 810 /* This function searches in the list of rcpt addresses
meillo@0 811 for local and 'local net' addresses. Remote addresses
meillo@0 812 which are reachable only when online are treated specially
meillo@0 813 in another function.
meillo@0 814
meillo@0 815 deliver() is called when a message has just been received and should
meillo@0 816 be delivered immediately.
meillo@0 817 */
meillo@10 818 gboolean
meillo@10 819 deliver(message * msg)
meillo@0 820 {
meillo@10 821 gboolean ok;
meillo@10 822 GList *msg_list = g_list_append(NULL, msg);
meillo@0 823
meillo@10 824 ok = deliver_msg_list(msg_list, DLVR_ALL);
meillo@10 825 g_list_free(msg_list);
meillo@0 826
meillo@10 827 return ok;
meillo@0 828 }