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