masqmail

view src/header.c @ 310:f10a56dc7481

find changesets by author, revision, files, or words in the commit message
reworked online_detect to the simpler online_query Only pipe is supported now. Use online_query="/bin/cat /path/to/file" instead of online_detect=file online_file=/path/to/file and online_query="/path/to/some/script foo" instead of online_detect=pipe online_pipe="/path/to/some/script foo" See man page masqmail.conf(5) and admin/config-transition.
author meillo@marmaro.de
date Sun, 24 Apr 2011 19:14:38 +0200
parents 2ffcd38ccf53
children 01d2f7a17bf0
line source
1 /* MasqMail
2 Copyright (C) 2000 Oliver Kurth
3
4 This program is free software; you can redistribute it and/or modify
5 it under the terms of the GNU General Public License as published by
6 the Free Software Foundation; either version 2 of the License, or
7 (at your option) any later version.
8
9 This program is distributed in the hope that it will be useful,
10 but WITHOUT ANY WARRANTY; without even the implied warranty of
11 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 GNU General Public License for more details.
13
14 You should have received a copy of the GNU General Public License
15 along with this program; if not, write to the Free Software
16 Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
17 */
18 #include "masqmail.h"
19
20 header_name header_names[] = {
21 {"From", HEAD_FROM,},
22 {"Sender", HEAD_SENDER,},
23 {"To", HEAD_TO,},
24 {"Cc", HEAD_CC,},
25 {"Bcc", HEAD_BCC,},
26 {"Date", HEAD_DATE,},
27 {"Message-Id", HEAD_MESSAGE_ID,},
28 {"Reply-To", HEAD_REPLY_TO,},
29 {"Subject", HEAD_SUBJECT,},
30 {"Return-Path", HEAD_RETURN_PATH,},
31 {"Envelope-To", HEAD_ENVELOPE_TO,},
32 {"Received", HEAD_RECEIVED},
33 };
34
35 /* this was borrowed from exim and slightly changed */
36 gchar*
37 rec_timestamp()
38 {
39 static gchar buf[64];
40 int len;
41
42 time_t now = time(NULL);
43 struct tm *t = localtime(&now);
44
45 int diff_hour, diff_min;
46 struct tm local;
47 struct tm *gmt;
48
49 memcpy(&local, t, sizeof(struct tm));
50 gmt = gmtime(&now);
51 diff_min = 60 * (local.tm_hour - gmt->tm_hour) + local.tm_min - gmt->tm_min;
52 if (local.tm_year != gmt->tm_year) {
53 diff_min += (local.tm_year > gmt->tm_year) ? 1440 : -1440;
54 } else if (local.tm_yday != gmt->tm_yday) {
55 diff_min += (local.tm_yday > gmt->tm_yday) ? 1440 : -1440;
56 }
57 diff_hour = diff_min / 60;
58 diff_min = abs(diff_min - diff_hour * 60);
59
60 len = strftime(buf, sizeof(buf), "%a, ", &local);
61 g_snprintf(buf + len, sizeof(buf) - len, "%02d ", local.tm_mday);
62 len += strlen(buf + len);
63 len += strftime(buf + len, sizeof(buf) - len, "%b %Y %H:%M:%S", &local);
64 g_snprintf(buf + len, sizeof(buf) - len, " %+03d%02d", diff_hour, diff_min);
65
66 return buf;
67 }
68
69 /* finds list of headers matching id
70 if id == HEAD_UNKNOWN and header == NULL finds all unknown headers
71 else finds all headers matching header
72 */
73 GList*
74 find_header(GList * hdr_list, header_id id, gchar * hdr_str)
75 {
76 GList *found_list = NULL;
77 GList *node;
78
79 if ((id != HEAD_UNKNOWN) || !hdr_str) {
80 foreach(hdr_list, node) {
81 header *hdr = (header *) (node->data);
82 if (hdr->id == id) {
83 found_list = g_list_append(found_list, hdr);
84 }
85 }
86 return found_list;
87 }
88
89 foreach(hdr_list, node) {
90 header *hdr = (header *) (node->data);
91 gchar buf[64], *q = buf, *p = hdr->header;
92
93 while (*p != ':' && q < buf+sizeof(buf)-1 && *p) {
94 *(q++) = *(p++);
95 }
96 *q = '\0';
97
98 if (strcasecmp(buf, hdr_str) == 0) {
99 found_list = g_list_append(found_list, hdr);
100 }
101 }
102 return found_list;
103 }
104
105 void
106 header_unfold(header * hdr)
107 {
108 char *src = hdr->header;
109 char *dest = src;
110 char *p;
111
112 p = strchr(src, '\n');
113 if (!p || !p[1]) {
114 /* no folded header */
115 return;
116 }
117
118 while (*src) {
119 if (*src == '\n') {
120 /* ignore */
121 src++;
122 } else {
123 /* copy */
124 *(dest++) = *(src++);
125 }
126 }
127 *(dest++) = '\n';
128 *(dest++) = '\0';
129 }
130
131 /*
132 fold the header at maxlen chars (newline excluded)
133 (We exclude the newline because the RFCs deal with it this way)
134 */
135 void
136 header_fold(header* hdr, unsigned int maxlen)
137 {
138 int len = strlen(hdr->header);
139 char* src = hdr->header;
140 char* dest;
141 char* tmp;
142 char* p;
143 int valueoffset;
144
145 if (len <= maxlen) {
146 /* we don't need to do anything */
147 return;
148 }
149
150 /* strip trailing whitespace */
151 for (p=src+len-1; *p==' '||*p=='\t'||*p=='\n'; p--) {
152 *p = '\0';
153 len--;
154 printf(" trailing whitespace\n");
155 }
156 printf("stripped len: %d\n", len);
157
158 /* FIXME: would be nice to have a better size calculation */
159 /* (the current size + what we insert as break, twice as often as
160 we have breaks in the optimal case) */
161 tmp = malloc(len + 2 * (len/maxlen) * strlen("\n\t"));
162 dest = tmp;
163
164 /* the position in hdr->header where the value part start */
165 valueoffset = hdr->value - hdr->header;
166
167 while (strlen(src) > maxlen) {
168 int i, l;
169 char *pp;
170
171 for (pp=src+maxlen; pp>src; pp--) {
172 if (*pp==' ' || *pp=='\t' || *p=='\n') {
173 break;
174 }
175 }
176
177 if (src == pp) {
178 /* no potential break point was found within
179 maxlen so advance further until the next */
180 for (pp=src+maxlen; *pp; pp++) {
181 if (*pp==' ' || *pp=='\t' || *p=='\n') {
182 break;
183 }
184 }
185 }
186 if (!*pp) {
187 break;
188 }
189
190 memcpy(dest, src, pp-src);
191 dest += pp-src;
192 *(dest++) = '\n';
193 *(dest++) = '\t';
194 while (*pp == ' ' || *pp == '\t' || *p=='\n') {
195 pp++;
196 }
197 src = pp;
198 }
199 memcpy(dest, src, strlen(src));
200 dest += strlen(src);
201
202 if (*(dest-1) != '\n') {
203 *dest = '\n';
204 *(dest+1) = '\0';
205 }
206
207 hdr->header = tmp;
208 hdr->value = hdr->header + valueoffset;
209 }
210
211 header*
212 create_header(header_id id, gchar * fmt, ...)
213 {
214 gchar *p;
215 header *hdr;
216 va_list args;
217 va_start(args, fmt);
218
219 /* g_malloc() calls exit on failure */
220 hdr = g_malloc(sizeof(header));
221
222 hdr->id = id;
223 hdr->header = g_strdup_vprintf(fmt, args);
224 hdr->value = NULL;
225
226 /* value shall point to the first non-whitespace char in the
227 value part of the header line (i.e. after the first colon) */
228 p = strchr(hdr->header, ':');
229 if (p) {
230 p++;
231 while (*p == ' ' || *p == '\t' || *p == '\n') {
232 p++;
233 }
234 hdr->value = (*p) ? p : NULL;
235 }
236
237 DEBUG(3) debugf("create_header(): hdr: `%s'\n", hdr->header);
238 DEBUG(3) debugf("create_header(): val: `%s'\n", hdr->value);
239
240 va_end(args);
241 return hdr;
242 }
243
244 void
245 destroy_header(header * hdr)
246 {
247 if (hdr) {
248 if (hdr->header) {
249 g_free(hdr->header);
250 }
251 g_free(hdr);
252 }
253 }
254
255 header*
256 copy_header(header * hdr)
257 {
258 header *new_hdr = NULL;
259
260 if (hdr) {
261 new_hdr = g_malloc(sizeof(header));
262 new_hdr->id = hdr->id;
263 new_hdr->header = g_strdup(hdr->header);
264 new_hdr->value = new_hdr->header + (hdr->value - hdr->header);
265 }
266 return new_hdr;
267 }
268
269 header*
270 get_header(gchar * line)
271 {
272 gchar *p = line;
273 gchar buf[64], *q = buf;
274 gint i;
275 header *hdr;
276
277 while (*p && (*p != ':') && (q < buf+sizeof(buf)-1)) {
278 *(q++) = *(p++);
279 }
280 *q = '\0';
281
282 if (*p != ':') {
283 return NULL;
284 }
285
286 hdr = g_malloc(sizeof(header));
287
288 hdr->value = NULL;
289 p++;
290
291 while (*p && (*p == ' ' || *p == '\t')) {
292 p++;
293 }
294 hdr->value = p;
295 /* Note: an empty value can also mean that it's only the first part
296 of a folded header line */
297
298 for (i = 0; i < HEAD_NUM_IDS; i++) {
299 if (strcasecmp(header_names[i].header, buf) == 0) {
300 break;
301 }
302 }
303 hdr->id = (header_id) i;
304 hdr->header = g_strdup(line);
305 hdr->value = hdr->header + (hdr->value - line);
306
307 DEBUG(4) debugf("header: %d = %s", hdr->id, hdr->header);
308 /* Note: This only outputs the first line if the header is folded */
309
310 return hdr;
311 }