masqmail

annotate src/route.c @ 345:257ffce6c1cd

find changesets by author, revision, files, or words in the commit message
added local_rcpts() and remote_rcpts() for later use
author markus schnalke <meillo@marmaro.de>
date Sat, 03 Sep 2011 18:53:54 +0200
parents 55b7bde95d37
children ddb7b3fd3d08
rev   line source
meillo@0 1 /* MasqMail
meillo@0 2 Copyright (C) 1999-2001 Oliver Kurth
meillo@241 3 Copyright (C) 2010 markus schnalke <meillo@marmaro.de>
meillo@0 4
meillo@0 5 This program is free software; you can redistribute it and/or modify
meillo@0 6 it under the terms of the GNU General Public License as published by
meillo@0 7 the Free Software Foundation; either version 2 of the License, or
meillo@0 8 (at your option) any later version.
meillo@0 9
meillo@0 10 This program is distributed in the hope that it will be useful,
meillo@0 11 but WITHOUT ANY WARRANTY; without even the implied warranty of
meillo@0 12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
meillo@0 13 GNU General Public License for more details.
meillo@0 14
meillo@0 15 You should have received a copy of the GNU General Public License
meillo@0 16 along with this program; if not, write to the Free Software
meillo@0 17 Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
meillo@0 18 */
meillo@0 19
meillo@15 20 #include <fnmatch.h>
meillo@15 21
meillo@0 22 #include "masqmail.h"
meillo@0 23
meillo@10 24 msgout_perhost*
meillo@10 25 create_msgout_perhost(gchar * host)
meillo@0 26 {
meillo@10 27 msgout_perhost *mo_ph = g_malloc(sizeof(msgout_perhost));
meillo@10 28 if (mo_ph) {
meillo@10 29 mo_ph->host = g_strdup(host);
meillo@10 30 mo_ph->msgout_list = NULL;
meillo@10 31 }
meillo@10 32 return mo_ph;
meillo@0 33 }
meillo@0 34
meillo@10 35 void
meillo@10 36 destroy_msgout_perhost(msgout_perhost * mo_ph)
meillo@0 37 {
meillo@10 38 GList *mo_node;
meillo@0 39
meillo@10 40 foreach(mo_ph->msgout_list, mo_node) {
meillo@10 41 msg_out *mo = (msg_out *) (mo_node->data);
meillo@10 42 /* the rcpt_list is owned by the msgout's, but not the rcpt's themselves */
meillo@10 43 g_list_free(mo->rcpt_list);
meillo@10 44 g_free(mo);
meillo@10 45 }
meillo@10 46 g_list_free(mo_ph->msgout_list);
meillo@10 47 g_free(mo_ph);
meillo@0 48 }
meillo@0 49
meillo@10 50 void
meillo@10 51 rewrite_headers(msg_out * msgout, connect_route * route)
meillo@0 52 {
meillo@10 53 /* if set_h_from_domain is set, replace domain in all
meillo@10 54 From: headers.
meillo@10 55 */
meillo@10 56 msgout->hdr_list = g_list_copy(msgout->msg->hdr_list);
meillo@0 57
meillo@10 58 /* map from addresses */
meillo@10 59 if (route->map_h_from_addresses != NULL) {
meillo@10 60 GList *hdr_node;
meillo@10 61 foreach(msgout->hdr_list, hdr_node) {
meillo@10 62 header *hdr = (header *) (hdr_node->data);
meillo@10 63 if (hdr->id == HEAD_FROM) {
meillo@10 64 header *new_hdr = copy_header(hdr);
meillo@10 65 if (map_address_header(new_hdr, route->map_h_from_addresses)) {
meillo@10 66 hdr_node->data = new_hdr;
meillo@10 67 /* we need this list only to carefully free the extra headers: */
meillo@10 68 msgout->xtra_hdr_list = g_list_append(msgout->xtra_hdr_list, new_hdr);
meillo@10 69 } else
meillo@10 70 g_free(new_hdr);
meillo@10 71 }
meillo@10 72 }
meillo@10 73 } else {
meillo@10 74 /* replace from domain */
meillo@10 75 if (route->set_h_from_domain != NULL) {
meillo@10 76 GList *hdr_node;
meillo@10 77
meillo@10 78 foreach(msgout->hdr_list, hdr_node) {
meillo@10 79 header *hdr = (header *) (hdr_node->data);
meillo@10 80 if (hdr->id == HEAD_FROM) {
meillo@10 81 header *new_hdr = copy_header(hdr);
meillo@10 82
meillo@10 83 DEBUG(5) debugf("setting From: domain to %s\n", route->set_h_from_domain);
meillo@10 84 if (set_address_header_domain(new_hdr, route->set_h_from_domain)) {
meillo@10 85 hdr_node->data = new_hdr;
meillo@10 86 /* we need this list only to carefully free the extra headers: */
meillo@10 87 DEBUG(6) debugf("header = %s\n", new_hdr->header);
meillo@10 88 msgout->xtra_hdr_list = g_list_append(msgout->xtra_hdr_list, new_hdr);
meillo@10 89 } else {
meillo@15 90 logwrite(LOG_ALERT, "error in set_address_header_domain(%s, %s)\n",
meillo@15 91 new_hdr->value, route->set_h_from_domain);
meillo@10 92 }
meillo@10 93 }
meillo@10 94 }
meillo@10 95 }
meillo@0 96 }
meillo@0 97
meillo@10 98 /* map reply-to addresses */
meillo@10 99 if (route->map_h_reply_to_addresses != NULL) {
meillo@10 100 GList *hdr_node;
meillo@10 101 foreach(msgout->hdr_list, hdr_node) {
meillo@10 102 header *hdr = (header *) (hdr_node->data);
meillo@10 103 if (hdr->id == HEAD_REPLY_TO) {
meillo@10 104 header *new_hdr = copy_header(hdr);
meillo@10 105 if (map_address_header
meillo@10 106 (new_hdr, route->map_h_reply_to_addresses)) {
meillo@10 107 hdr_node->data = new_hdr;
meillo@10 108 /* we need this list only to carefully free the extra headers: */
meillo@10 109 msgout->xtra_hdr_list = g_list_append(msgout->xtra_hdr_list, new_hdr);
meillo@10 110 } else
meillo@10 111 g_free(new_hdr);
meillo@10 112 }
meillo@10 113 }
meillo@10 114 } else {
meillo@10 115 /* replace Reply-to domain */
meillo@10 116 if (route->set_h_reply_to_domain != NULL) {
meillo@10 117 GList *hdr_node;
meillo@10 118
meillo@10 119 foreach(msgout->hdr_list, hdr_node) {
meillo@10 120 header *hdr = (header *) (hdr_node->data);
meillo@10 121 if (hdr->id == HEAD_REPLY_TO) {
meillo@10 122 header *new_hdr = copy_header(hdr);
meillo@10 123
meillo@10 124 set_address_header_domain(new_hdr, route-> set_h_reply_to_domain);
meillo@10 125 hdr_node->data = new_hdr;
meillo@10 126 /* we need this list only to carefully free the extra headers: */
meillo@10 127 msgout->xtra_hdr_list = g_list_append(msgout->xtra_hdr_list, new_hdr);
meillo@10 128 }
meillo@10 129 }
meillo@10 130 }
meillo@0 131 }
meillo@0 132
meillo@10 133 /* map Mail-Followup-To addresses */
meillo@10 134 if (route->map_h_mail_followup_to_addresses != NULL) {
meillo@10 135 GList *hdr_node;
meillo@10 136 foreach(msgout->hdr_list, hdr_node) {
meillo@10 137 header *hdr = (header *) (hdr_node->data);
meillo@10 138 if (strncasecmp(hdr->header, "Mail-Followup-To", 16) == 0) {
meillo@10 139 header *new_hdr = copy_header(hdr);
meillo@10 140 if (map_address_header(new_hdr, route->map_h_mail_followup_to_addresses)) {
meillo@10 141 hdr_node->data = new_hdr;
meillo@10 142 /* we need this list only to carefully free the extra headers: */
meillo@10 143 msgout->xtra_hdr_list = g_list_append(msgout->xtra_hdr_list, new_hdr);
meillo@10 144 } else
meillo@10 145 g_free(new_hdr);
meillo@10 146 }
meillo@10 147 }
meillo@10 148 }
meillo@0 149
meillo@10 150 /* set Sender: domain to return_path->domain */
meillo@10 151 if (route->expand_h_sender_domain) {
meillo@10 152 GList *hdr_node;
meillo@0 153
meillo@10 154 foreach(msgout->hdr_list, hdr_node) {
meillo@10 155 header *hdr = (header *) (hdr_node->data);
meillo@10 156 if (hdr->id == HEAD_SENDER) {
meillo@10 157 header *new_hdr = copy_header(hdr);
meillo@0 158
meillo@10 159 set_address_header_domain(new_hdr, msgout->return_path->domain);
meillo@10 160 hdr_node->data = new_hdr;
meillo@10 161 /* we need this list only to carefully free the extra headers: */
meillo@10 162 msgout->xtra_hdr_list = g_list_append(msgout->xtra_hdr_list, new_hdr);
meillo@10 163 }
meillo@10 164 }
meillo@10 165 }
meillo@0 166
meillo@10 167 /* set Sender: domain to return_path->domain */
meillo@10 168 if (route->expand_h_sender_address) {
meillo@10 169 GList *hdr_node;
meillo@0 170
meillo@10 171 foreach(msgout->hdr_list, hdr_node) {
meillo@10 172 header *hdr = (header *) (hdr_node->data);
meillo@10 173 if (hdr->id == HEAD_SENDER) {
meillo@10 174 header *new_hdr;
meillo@0 175
meillo@15 176 new_hdr = create_header(HEAD_SENDER, "Sender: %s@%s\n",
meillo@15 177 msgout->return_path->local_part, msgout->return_path->domain);
meillo@10 178 hdr_node->data = new_hdr;
meillo@10 179 /* we need this list only to carefully free the extra headers: */
meillo@10 180 msgout->xtra_hdr_list = g_list_append(msgout->xtra_hdr_list, new_hdr);
meillo@10 181 }
meillo@10 182 }
meillo@10 183 }
meillo@0 184
meillo@10 185 if (msgout->xtra_hdr_list == NULL) {
meillo@10 186 /* nothing was changed */
meillo@10 187 g_list_free(msgout->hdr_list);
meillo@10 188 msgout->hdr_list = NULL;
meillo@10 189 }
meillo@10 190 DEBUG(5) debugf("rewrite_headers() returning\n");
meillo@0 191 }
meillo@0 192
meillo@237 193 /*
meillo@237 194 Split a recipient list into the three groups:
meillo@237 195 - local recipients
meillo@237 196 - local net recipients
meillo@237 197 - other/remote/online recipients
meillo@237 198 It should be possible to call the function like:
meillo@237 199 split_rcpts(rcpts, hostlist, local, others, others);
meillo@237 200 This would split online between local and localnet+online recipients.
meillo@237 201 (untested yet; remove this line if you saw it worked -- meillo 2010-10-21)
meillo@237 202 If host_list is NULL, only splitting between local and other is done.
meillo@237 203 */
meillo@10 204 void
meillo@237 205 split_rcpts(GList* rcpt_list, GList* localnets, GList** rl_local, GList** rl_localnet, GList** rl_others)
meillo@0 206 {
meillo@10 207 GList *rcpt_node;
meillo@237 208 GList *host_node = NULL;
meillo@237 209 address *rcpt = NULL;
meillo@0 210
meillo@10 211 if (rcpt_list == NULL)
meillo@10 212 return;
meillo@0 213
meillo@10 214 foreach(rcpt_list, rcpt_node) {
meillo@237 215 rcpt = (address *) (rcpt_node->data);
meillo@237 216 host_node = NULL;
meillo@0 217
meillo@237 218 if (addr_is_local(rcpt)) {
meillo@237 219 if (rl_local)
meillo@237 220 *rl_local = g_list_append(*rl_local, rcpt);
meillo@237 221 } else {
meillo@237 222 /* if localnets is NULL, host_node will be NULL,
meillo@237 223 hence all non-locals are put to others */
meillo@237 224 foreach(localnets, host_node) {
meillo@237 225 gchar *host = (gchar *) (host_node->data);
meillo@237 226 if (fnmatch(host, rcpt->domain, FNM_CASEFOLD) == 0)
meillo@237 227 break;
meillo@237 228 }
meillo@237 229 if (host_node) {
meillo@237 230 if (rl_localnet)
meillo@237 231 *rl_localnet = g_list_append(*rl_localnet, rcpt);
meillo@237 232 } else {
meillo@237 233 if (rl_others)
meillo@237 234 *rl_others = g_list_append(*rl_others, rcpt);
meillo@237 235 }
meillo@10 236 }
meillo@10 237 }
meillo@0 238 }
meillo@0 239
meillo@345 240 /*
meillo@345 241 Return a new list of the local rcpts in the rcpt_list
meillo@345 242 TODO: This function is almost exactly the same as remote_rcpts(). Merge?
meillo@345 243 */
meillo@345 244 GList*
meillo@345 245 local_rcpts(GList* rcpt_list)
meillo@345 246 {
meillo@345 247 GList *rcpt_node;
meillo@345 248 GList *local_rcpts = NULL;
meillo@345 249 address *rcpt = NULL;
meillo@345 250
meillo@345 251 if (!rcpt_list) {
meillo@345 252 return NULL;
meillo@345 253 }
meillo@345 254 foreach(rcpt_list, rcpt_node) {
meillo@345 255 rcpt = (address *) (rcpt_node->data);
meillo@345 256 if (addr_is_local(rcpt)) {
meillo@345 257 local_rcpts = g_list_append(local_rcpts, rcpt);
meillo@345 258 }
meillo@345 259 }
meillo@345 260 return local_rcpts;
meillo@345 261 }
meillo@345 262
meillo@345 263 /*
meillo@345 264 Return a new list of non-local rcpts in the rcpt_list
meillo@345 265 TODO: This function is almost exactly the same as local_rcpts(). Merge?
meillo@345 266 */
meillo@345 267 GList*
meillo@345 268 remote_rcpts(GList* rcpt_list)
meillo@345 269 {
meillo@345 270 GList *rcpt_node;
meillo@345 271 GList *remote_rcpts = NULL;
meillo@345 272 address *rcpt = NULL;
meillo@345 273
meillo@345 274 if (!rcpt_list) {
meillo@345 275 return NULL;
meillo@345 276 }
meillo@345 277 foreach(rcpt_list, rcpt_node) {
meillo@345 278 rcpt = (address *) (rcpt_node->data);
meillo@345 279 if (!addr_is_local(rcpt)) {
meillo@345 280 remote_rcpts = g_list_append(remote_rcpts, rcpt);
meillo@345 281 }
meillo@345 282 }
meillo@345 283 return remote_rcpts;
meillo@345 284 }
meillo@345 285
meillo@10 286 static gint
meillo@317 287 _g_list_addrcmp(gconstpointer pattern, gconstpointer addr)
meillo@0 288 {
meillo@317 289 int res;
meillo@317 290 address* patternaddr = (address*) pattern;
meillo@317 291 address* stringaddr = (address*) addr;
meillo@317 292
meillo@317 293 DEBUG(6) debugf("_g_list_addrcmp: pattern `%s' `%s' on string `%s' `%s'\n",
meillo@317 294 patternaddr->local_part, patternaddr->domain,
meillo@317 295 stringaddr->local_part, stringaddr->domain);
meillo@317 296 /* TODO: check if we should match here dependent on caseless_matching */
meillo@317 297 res = fnmatch(patternaddr->local_part, stringaddr->local_part, 0);
meillo@317 298 if (res != 0) {
meillo@317 299 DEBUG(6) debugf("_g_list_addrcmp: ... failed on local_part\n");
meillo@317 300 return res;
meillo@317 301 }
meillo@317 302 res = fnmatch(patternaddr->domain, stringaddr->domain, FNM_CASEFOLD);
meillo@317 303 DEBUG(6) debugf("_g_list_addrcmp: ... %s\n", (res==0) ? "matched" : "failed on domain");
meillo@317 304 return res;
meillo@0 305 }
meillo@0 306
meillo@10 307 gboolean
meillo@317 308 route_sender_is_allowed(connect_route * route, address * ret_path)
meillo@0 309 {
meillo@317 310 if (route->denied_senders && g_list_find_custom(route->denied_senders, ret_path, _g_list_addrcmp)) {
meillo@317 311 return FALSE;
meillo@10 312 }
meillo@317 313 if (route->allowed_senders) {
meillo@317 314 if (g_list_find_custom(route->allowed_senders, ret_path, _g_list_addrcmp)) {
meillo@10 315 return TRUE;
meillo@10 316 } else {
meillo@10 317 return FALSE;
meillo@10 318 }
meillo@10 319 }
meillo@10 320 return TRUE;
meillo@0 321 }
meillo@0 322
meillo@10 323 /*
meillo@0 324 Make lists of matching/not matching rcpts.
meillo@0 325 Local domains are NOT regared here, these should be sorted out previously
meillo@0 326 */
meillo@10 327 void
meillo@317 328 route_split_rcpts(connect_route * route, GList * rcpt_list, GList ** p_rcpt_list, GList ** p_non_rcpt_list)
meillo@0 329 {
meillo@10 330 GList *tmp_list = NULL;
meillo@10 331 /* sort out those domains that can be sent over this connection: */
meillo@317 332 if (route->allowed_recipients) {
meillo@317 333 DEBUG(5) debugf("testing for route->allowed_recipients\n");
meillo@317 334 split_rcpts(rcpt_list, route->allowed_recipients, NULL, &tmp_list, p_non_rcpt_list);
meillo@10 335 } else {
meillo@317 336 DEBUG(5) debugf("route->allowed_recipients == NULL\n");
meillo@10 337 tmp_list = g_list_copy(rcpt_list);
meillo@10 338 }
meillo@0 339
meillo@10 340 /* sort out those domains that cannot be sent over this connection: */
meillo@317 341 split_rcpts(tmp_list, route->denied_recipients, NULL, p_non_rcpt_list, p_rcpt_list);
meillo@10 342 g_list_free(tmp_list);
meillo@0 343 }
meillo@0 344
meillo@10 345 msg_out*
meillo@10 346 route_prepare_msgout(connect_route * route, msg_out * msgout)
meillo@0 347 {
meillo@10 348 message *msg = msgout->msg;
meillo@10 349 GList *rcpt_list = msgout->rcpt_list;
meillo@0 350
meillo@10 351 if (rcpt_list != NULL) {
meillo@10 352 /* found a few */
meillo@10 353 DEBUG(5) {
meillo@10 354 GList *node;
meillo@10 355 debugf("rcpts for routed delivery, route = %s, id = %s\n", route->name, msg->uid);
meillo@10 356 foreach(rcpt_list, node) {
meillo@10 357 address *rcpt = (address *) (node->data);
meillo@114 358 debugf(" rcpt for routed delivery: <%s@%s>\n",
meillo@114 359 rcpt->local_part, rcpt->domain);
meillo@10 360 }
meillo@10 361 }
meillo@0 362
meillo@15 363 /* rewrite return path if there is a table, use that
meillo@10 364 if an address is found and if it has a domain, use that
meillo@10 365 */
meillo@10 366 if (route->map_return_path_addresses) {
meillo@10 367 address *ret_path = NULL;
meillo@10 368 DEBUG(5) debugf("looking up %s in map_return_path_addresses\n", msg->return_path->local_part);
meillo@10 369 ret_path = (address *) table_find_fnmatch(route->map_return_path_addresses, msg->return_path->local_part);
meillo@10 370 if (ret_path) {
meillo@10 371 DEBUG(5) debugf("found <%s@%s>\n", ret_path->local_part, ret_path->domain);
meillo@10 372 if (ret_path->domain == NULL)
meillo@10 373 ret_path->domain = route->set_return_path_domain
meillo@10 374 ? route->set_return_path_domain
meillo@10 375 : msg->return_path->domain;
meillo@10 376 msgout->return_path = copy_address(ret_path);
meillo@10 377 }
meillo@10 378 }
meillo@10 379 if (msgout->return_path == NULL) {
meillo@10 380 DEBUG(5) debugf("setting return path to %s\n", route->set_return_path_domain);
meillo@10 381 msgout->return_path = copy_modify_address(msg->return_path, NULL, route->set_return_path_domain);
meillo@10 382 }
meillo@10 383 rewrite_headers(msgout, route);
meillo@10 384
meillo@10 385 return msgout;
meillo@10 386 }
meillo@10 387 return NULL;
meillo@0 388 }
meillo@0 389
meillo@0 390 /* put msgout's is msgout_list into bins (msgout_perhost structs) for each
meillo@0 391 host. Used if there is no mail_host.
meillo@0 392 route param is not used, we leave it here because that may change.
meillo@0 393 */
meillo@0 394
meillo@10 395 GList*
meillo@10 396 route_msgout_list(connect_route * route, GList * msgout_list)
meillo@0 397 {
meillo@10 398 GList *mo_ph_list = NULL;
meillo@10 399 GList *msgout_node;
meillo@0 400
meillo@10 401 foreach(msgout_list, msgout_node) {
meillo@10 402 msg_out *msgout = (msg_out *) (msgout_node->data);
meillo@10 403 msg_out *msgout_new;
meillo@10 404 GList *rcpt_list = msgout->rcpt_list;
meillo@10 405 GList *rcpt_node;
meillo@0 406
meillo@10 407 foreach(rcpt_list, rcpt_node) {
meillo@10 408 address *rcpt = rcpt_node->data;
meillo@10 409 msgout_perhost *mo_ph = NULL;
meillo@10 410 GList *mo_ph_node = NULL;
meillo@0 411
meillo@10 412 /* search host in mo_ph_list */
meillo@10 413 foreach(mo_ph_list, mo_ph_node) {
meillo@10 414 mo_ph = (msgout_perhost *) (mo_ph_node->data);
meillo@10 415 if (strcasecmp(mo_ph->host, rcpt->domain) == 0)
meillo@10 416 break;
meillo@10 417 }
meillo@10 418 if (mo_ph_node != NULL) {
meillo@10 419 /* there is already a rcpt for this host */
meillo@10 420 msg_out *msgout_last = (msg_out *) ((g_list_last(mo_ph->msgout_list))->data);
meillo@10 421 if (msgout_last->msg == msgout->msg) {
meillo@15 422 /* if it is also the same message, it must be the last one appended
meillo@15 423 to mo_ph->msgout_list (since outer loop goes through msgout_list) */
meillo@10 424 msgout_last->rcpt_list = g_list_append(msgout_last->rcpt_list, rcpt);
meillo@10 425 } else {
meillo@10 426 /* if not, we append a new msgout */
meillo@10 427 /* make a copy of msgout */
meillo@10 428 msgout_new = create_msg_out(msgout->msg);
meillo@10 429 msgout_new->return_path = msgout->return_path;
meillo@10 430 msgout_new->hdr_list = msgout->hdr_list;
meillo@0 431
meillo@10 432 /* append our rcpt to it */
meillo@10 433 /* It is the 1st rcpt for this msg to this host, therefore we safely give NULL */
meillo@10 434 msgout_new->rcpt_list = g_list_append(NULL, rcpt);
meillo@10 435 mo_ph->msgout_list = g_list_append(mo_ph->msgout_list, msgout_new);
meillo@10 436 }
meillo@10 437 } else {
meillo@10 438 /* this rcpt to goes to another host */
meillo@10 439 mo_ph = create_msgout_perhost(rcpt->domain);
meillo@10 440 mo_ph_list = g_list_append(mo_ph_list, mo_ph);
meillo@0 441
meillo@10 442 /* make a copy of msgout */
meillo@10 443 msgout_new = create_msg_out(msgout->msg);
meillo@10 444 msgout_new->return_path = msgout->return_path;
meillo@10 445 msgout_new->hdr_list = msgout->hdr_list;
meillo@0 446
meillo@10 447 /* append our rcpt to it */
meillo@10 448 /* It is the 1st rcpt for this msg to this host, therefore we safely give NULL */
meillo@10 449 msgout_new->rcpt_list = g_list_append(NULL, rcpt);
meillo@10 450 mo_ph->msgout_list = g_list_append(mo_ph->msgout_list, msgout_new);
meillo@10 451 } /* if mo_ph != NULL */
meillo@10 452 } /* foreach(rcpt_list, ... */
meillo@10 453 } /* foreach(msgout_list, ... */
meillo@10 454
meillo@10 455 return mo_ph_list;
meillo@0 456 }