masqmail: ee2afbf92428 src/accept.c

masqmail

view src/accept.c @ 156:ee2afbf92428

require host_name to be set in config file exit otherwise there is no portable way to determine the hostname (actually the hostname that masqmail should use) thus it must be set by the administrator

author	meillo@marmaro.de
date	Thu, 08 Jul 2010 09:49:05 +0200
parents	5ec5e6637049
children	89f951be358f

line source

1 /* MasqMail

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.

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.

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 */

19 #include "masqmail.h"

20 #include "readsock.h"

22 gchar *prot_names[] = {

23 "local",

24 "bsmtp",

25 "smtp",

26 "esmtp",

27 "pop3",

28 "apop",

29 "(unknown)" /* should not happen, but better than crashing. */

30 };

32 static gchar*

33 string_base62(gchar * res, guint value, gchar len)

34 {

35 static gchar base62_chars[] = "0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz";

36 gchar *p = res + len;

37 *p = '\0';

38 while (p > res) {

39 *(--p) = base62_chars[value % 62];

40 value /= 62;

41 }

42 return res;

43 }

45 static gint

46 _g_list_addr_isequal(gconstpointer a, gconstpointer b)

47 {

48 address *addr1 = (address *) a;

49 address *addr2 = (address *) b;

50 int ret;

52 if ((ret = strcasecmp(addr1->domain, addr2->domain)) == 0)

53 return strcmp(addr1->local_part, addr2->local_part);

54 else

55 return ret;

56 }

58 /* accept message from anywhere.

59 A locally originating message is indicated by msg->recieved_host == NULL

61 The -t option:

62 The ACC_RCPT_FROM_HEAD flag adds the recipients found in To/Cc/Bcc

63 headers to the recipients list.

64 The ACC_DEL_RCPTS flag makes only sense if the ACC_RCPT_FROM_HEAD

65 flag is given too. With ACC_DEL_RCPTS the recipients given on the

66 command line are removed from the ones given in headers.

67 */

69 accept_error

70 accept_message_stream(FILE * in, message * msg, guint flags)

71 {

72 gchar *line, *line1;

73 int line_size = MAX_DATALINE;

74 gboolean in_headers = TRUE;

75 header *hdr = NULL;

76 gint line_cnt = 0, data_size = 0;

78 line = g_malloc(line_size);

79 line[0] = '\0';

81 while (TRUE) {

82 int len = read_sockline1(in, &line, &line_size, 5 * 60, READSOCKL_CVT_CRLF);

84 line1 = line;

86 if ((line[0] == '.') && (!(flags & ACC_DOT_IGNORE))) {

87 if (line[1] == '\n') {

88 g_free(line);

89 break;

90 }

91 line1++;

92 }

94 if (len <= 0) {

95 if ((len == -1) && (flags & (ACC_DOT_IGNORE | ACC_NODOT_RELAX))) {

96 /* we got an EOF, and the last line was not terminated by a CR */

97 gint len1 = strlen(line1);

98 if (len1 > 0) { /* == 0 is 'normal' (EOF after a CR) */

99 if (line1[len1 - 1] != '\n') { /* some mail clients allow unterminated lines */

100 line1[len1] = '\n';

101 line1[len1 + 1] = '\0';

102 msg->data_list = g_list_prepend(msg->data_list, g_strdup(line1));

103 data_size += strlen(line1);

104 line_cnt++;

105 }

106 }

107 break;

108 } else {

109 g_free(line);

110 if (len == -1) {

111 return AERR_EOF;

112 } else if (len == -2) {

113 /* should not happen any more */

114 return AERR_OVERFLOW;

115 } else if (len == -3) {

116 return AERR_TIMEOUT;

117 } else {

118 /* does not happen */

119 DEBUG(5) debugf("read_sockline returned %d\n", len);

120 return AERR_UNKNOWN;

121 }

122 }

123 } else {

124 if (in_headers) {

125

126 /* some pop servers send the 'From ' line, skip it: */

127 if (msg->hdr_list == NULL)

128 if (strncmp(line1, "From ", 5) == 0)

129 continue;

130

131 if (line1[0] == ' ' || line1[0] == '\t') {

132 /* continuation of 'folded' header: */

133 if (hdr) {

134 hdr->header = g_strconcat(hdr->header, line1, NULL);

135 }

136

137 } else if (line1[0] == '\n') {

138 /* an empty line marks end of headers */

139 in_headers = FALSE;

140 } else {

141 /* in all other cases we expect another header */

142 if ((hdr = get_header(line1)))

143 msg->hdr_list = g_list_append(msg->hdr_list, hdr);

144 else {

145 /* if get_header() returns NULL, no header was recognized,

146 so this seems to be the first data line of a broken mailer

147 which does not send an empty line after the headers */

148 in_headers = FALSE;

149 msg->data_list = g_list_prepend(msg->data_list, g_strdup(line1));

150 }

151 }

152 } else {

153 msg->data_list = g_list_prepend(msg->data_list, g_strdup(line1));

154 data_size += strlen(line1);

155 line_cnt++;

156 }

157 }

158 if (conf.max_msg_size && (data_size > conf.max_msg_size)) {

159 DEBUG(4) debugf("accept_message_stream(): "

160 "received %d bytes (conf.max_msg_size=%d)\n",

161 data_size, conf.max_msg_size);

162 return AERR_SIZE;

163 }

164

165 }

166

167 if (msg->data_list != NULL)

168 msg->data_list = g_list_reverse(msg->data_list);

169 else

170 /* make sure data list is not NULL: */

171 msg->data_list = g_list_append(NULL, g_strdup(""));

172

173 DEBUG(4) debugf("received %d lines of data (%d bytes)\n", line_cnt, data_size);

174 /* we get here after we succesfully received the mail data */

175

176 msg->data_size = data_size;

177 msg->received_time = time(NULL);

178

179 return AERR_OK;

180 }

181

182 accept_error

183 accept_message_prepare(message * msg, guint flags)

184 {

185 struct passwd *passwd = NULL;

186 GList *non_rcpt_list = NULL;

187 time_t rec_time = time(NULL);

188

189 DEBUG(5) debugf("accept_message_prepare()\n");

190

191 /* create unique message id */

192 msg->uid = g_malloc(14);

193

194 string_base62(msg->uid, rec_time, 6);

195 msg->uid[6] = '-';

196 string_base62(&(msg->uid[7]), getpid(), 3);

197 msg->uid[10] = '-';

198 string_base62(&(msg->uid[11]), msg->transfer_id, 2);

199 msg->uid[13] = 0;

200

201 /* if local, get password entry */

202 if (msg->received_host == NULL) {

203 passwd = g_memdup(getpwuid(geteuid()), sizeof(struct passwd));

204 msg->ident = g_strdup(passwd->pw_name);

205 }

206

207 /* set return path if local */

208 if (msg->return_path == NULL && msg->received_host == NULL) {

209 gchar *path = g_strdup_printf("<%s@%s>", passwd->pw_name, conf.host_name);

210 DEBUG(3) debugf("setting return_path for local accept: %s\n", path);

211 msg->return_path = create_address(path, TRUE);

212 g_free(path);

213 }

214

215 /* -t option (see comment above) */

216 if (flags & ACC_DEL_RCPTS) {

217 non_rcpt_list = msg->rcpt_list;

218 msg->rcpt_list = NULL;

219 }

220

221 /* scan headers */

222 {

223 gboolean has_id = FALSE;

224 gboolean has_date = FALSE;

225 gboolean has_sender = FALSE;

226 gboolean has_from = FALSE;

227 gboolean has_to_or_cc = FALSE;

228 GList *hdr_node, *hdr_node_next;

229 header *hdr;

230

231 for (hdr_node = g_list_first(msg->hdr_list);

232 hdr_node != NULL; hdr_node = hdr_node_next) {

233 hdr_node_next = g_list_next(hdr_node);

234 hdr = ((header *) (hdr_node->data));

235 DEBUG(5) debugf("scanning headers: %s", hdr->header);

236 switch (hdr->id) {

237 case HEAD_MESSAGE_ID:

238 has_id = TRUE;

239 break;

240 case HEAD_DATE:

241 has_date = TRUE;

242 break;

243 case HEAD_FROM:

244 has_from = TRUE;

245 break;

246 case HEAD_SENDER:

247 has_sender = TRUE;

248 break;

249 case HEAD_TO:

250 case HEAD_CC:

251 has_to_or_cc = TRUE;

252 /* fall through */

253 case HEAD_BCC:

254 if (flags & ACC_RCPT_FROM_HEAD) {

255 /* -t option (see comment above) */

256 DEBUG(5) debugf("hdr->value = %s\n", hdr->value);

257 if (hdr->value) {

258 msg->rcpt_list = addr_list_append_rfc822(msg->rcpt_list, hdr->value, conf.host_name);

259 }

260 }

261 if (hdr->id == HEAD_BCC) {

262 DEBUG(3) debugf("removing 'Bcc' header\n");

263 msg->hdr_list = g_list_remove_link(msg->hdr_list, hdr_node);

264 g_list_free_1(hdr_node);

265 destroy_header(hdr);

266 }

267 break;

268 case HEAD_ENVELOPE_TO:

269 if (flags & ACC_SAVE_ENVELOPE_TO) {

270 DEBUG(3) debugf("creating 'X-Orig-Envelope-To' header\n");

271 msg->hdr_list = g_list_prepend(msg->hdr_list, create_header(HEAD_UNKNOWN,

272 "X-Orig-Envelope-to: %s", hdr->value));

273 }

274 DEBUG(3) debugf("removing 'Envelope-To' header\n");

275 msg->hdr_list = g_list_remove_link(msg->hdr_list, hdr_node);

276 g_list_free_1(hdr_node);

277 destroy_header(hdr);

278 break;

279 case HEAD_RETURN_PATH:

280 if (flags & ACC_MAIL_FROM_HEAD) {

281 /* usually POP3 accept */

282 msg->return_path = create_address_qualified(hdr->value, TRUE, msg->received_host);

283 DEBUG(3) debugf("setting return_path to %s\n", addr_string(msg->return_path));

284 }

285 DEBUG(3) debugf("removing 'Return-Path' header\n");

286 msg->hdr_list = g_list_remove_link(msg->hdr_list, hdr_node);

287 g_list_free_1(hdr_node);

288 destroy_header(hdr);

289 break;

290 default:

291 break; /* make compiler happy */

292 }

293 }

294

295 if (msg->return_path == NULL) {

296 /* this can happen for pop3 accept only and if no Return-path: header was given */

297 GList *hdr_list;

298 header *hdr;

299

300 DEBUG(3) debugf("return_path == NULL\n");

301

302 hdr_list = find_header(msg->hdr_list, HEAD_SENDER, NULL);

303 if (!hdr_list)

304 hdr_list = find_header(msg->hdr_list, HEAD_FROM, NULL);

305 if (hdr_list) {

306 gchar *addr;

307 hdr = (header *) (g_list_first(hdr_list)->data);

308

309 DEBUG(5) debugf("hdr->value = '%s'\n", hdr->value);

310

311 addr = g_strdup(hdr->value);

312 g_strchomp(addr);

313

314 if ((msg->return_path = create_address_qualified(addr, FALSE, msg->received_host)) != NULL) {

315 DEBUG(3) debugf("setting return_path to %s\n", addr_string(msg->return_path));

316 msg->hdr_list = g_list_append(msg->hdr_list, create_header(HEAD_UNKNOWN,

317 "X-Warning: return path set from %s address\n",

318 hdr->id == HEAD_SENDER ? "Sender:" : "From:"));

319 }

320 g_free(addr);

321 }

322 if (msg->return_path == NULL) { /* no Sender: or From: or create_address_qualified failed */

323 msg->return_path = create_address_qualified("postmaster", TRUE, conf.host_name);

324 DEBUG(3) debugf("setting return_path to %s\n", addr_string(msg->return_path));

325 msg->hdr_list = g_list_append(msg->hdr_list, create_header(HEAD_UNKNOWN,

326 "X-Warning: real return path is unknown\n"));

327 }

328 }

329

330 if (flags & ACC_DEL_RCPTS) {

331 /* remove the recipients given on the command line from the ones given in headers

332 -t option (see comment above) */

333 GList *rcpt_node;

334 foreach(non_rcpt_list, rcpt_node) {

335 address *rcpt = (address *) (rcpt_node->data);

336 GList *node;

337 if ((node = g_list_find_custom(msg->rcpt_list, rcpt, _g_list_addr_isequal))) {

338 DEBUG(3) debugf("removing rcpt address %s\n", addr_string(node->data));

339 msg->rcpt_list = g_list_remove_link(msg->rcpt_list, node);

340 destroy_address((address *) (node->data));

341 g_list_free_1(node);

342 }

343 }

344 }

345

346 /* here we should have our recipients, fail if not: */

347 if (msg->rcpt_list == NULL) {

348 logwrite(LOG_WARNING, "no recipients found in message\n");

349 return AERR_NORCPT;

350 }

351

352 if (!(has_sender || has_from)) {

353 DEBUG(3) debugf("adding 'From' header\n");

354 msg->hdr_list = g_list_append(msg->hdr_list,

355 msg->full_sender_name

356 ?

357 create_header(HEAD_FROM, "From: \"%s\" <%s@%s>\n", msg->full_sender_name,

358 msg->return_path->local_part, msg->return_path->domain)

359 :

360 create_header(HEAD_FROM, "From: <%s@%s>\n",

361 msg->return_path->local_part, msg->return_path->domain)

362 );

363 }

364 if (!has_to_or_cc) {

365 DEBUG(3) debugf("no To: or Cc: header, hence adding `To: undisclosed recipients:;'\n");

366 msg->hdr_list = g_list_append(msg->hdr_list, create_header(HEAD_TO, "To: undisclosed-recipients:;\n"));

367 }

368 if (!has_date) {

369 DEBUG(3) debugf("adding 'Date:' header\n");

370 msg->hdr_list = g_list_append(msg->hdr_list, create_header(HEAD_DATE, "Date: %s\n", rec_timestamp()));

371 }

372 if (!has_id) {

373 DEBUG(3) debugf("adding 'Message-ID:' header\n");

374 msg->hdr_list = g_list_append(msg->hdr_list,

375 create_header(HEAD_MESSAGE_ID, "Message-ID: <%s@%s>\n", msg->uid, conf.host_name));

376 }

377 }

378

379 /* Received header: */

380 /* At this point because we have to know the rcpts for the 'for' part */

381 gchar *for_string = NULL;

382 header *hdr = NULL;

383

384 DEBUG(3) debugf("adding 'Received:' header\n");

385

386 if (g_list_length(msg->rcpt_list) == 1) {

387 address *addr = (address *) (g_list_first(msg->rcpt_list)->data);

388 for_string = g_strdup_printf(" for %s", addr_string(addr));

389 }

390

391 if (msg->received_host == NULL) {

392 /* received locally */

393 hdr = create_header(HEAD_RECEIVED, "Received: from %s by %s with %s (%s %s) id %s%s; %s\n",

394 passwd->pw_name, conf.host_name, prot_names[msg->received_prot],

395 PACKAGE, VERSION, msg->uid, for_string ? for_string : "", rec_timestamp());

396 } else {

397 /* received from remote */

398 #ifdef ENABLE_IDENT

399 DEBUG(5) debugf("adding 'Received:' header (5)\n");

400 hdr = create_header(HEAD_RECEIVED, "Received: from %s (ident=%s) by %s with %s (%s %s) id %s%s; %s\n",

401 msg->received_host, msg->ident ? msg->ident : "unknown", conf.host_name,

402 prot_names[msg->received_prot], PACKAGE, VERSION, msg->uid, for_string ? for_string : "",

403 rec_timestamp());

404 #else

405 hdr = create_header(HEAD_RECEIVED, "Received: from %s by %s with %s (%s %s) id %s%s; %s\n",

406 msg->received_host, conf.host_name, prot_names[msg->received_prot],

407 PACKAGE, VERSION, msg->uid, for_string ? for_string : "", rec_timestamp());

408 #endif

409 }

410 header_fold(hdr);

411 msg->hdr_list = g_list_prepend(msg->hdr_list, hdr);

412

413 if (for_string)

414 g_free(for_string);

415

416 /* write message to spool: */

417 /* accept is no longer responsible for this

418 if (!spool_write(msg, TRUE))

419 return AERR_NOSPOOL;

420 */

421 return AERR_OK;

422 }

423

424 accept_error

425 accept_message(FILE * in, message * msg, guint flags)

426 {

427 accept_error err;

428

429 err = accept_message_stream(in, msg, flags);

430 if (err == AERR_OK)

431 err = accept_message_prepare(msg, flags);

432

433 return err;

434 }