2 ce062d50 2019-08-21 martijn * Copyright (c) 2019 Martijn van Duren <martijn@openbsd.org>
4 ce062d50 2019-08-21 martijn * Permission to use, copy, modify, and distribute this software for any
5 ce062d50 2019-08-21 martijn * purpose with or without fee is hereby granted, provided that the above
6 ce062d50 2019-08-21 martijn * copyright notice and this permission notice appear in all copies.
8 ce062d50 2019-08-21 martijn * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
9 ce062d50 2019-08-21 martijn * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
10 ce062d50 2019-08-21 martijn * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
11 ce062d50 2019-08-21 martijn * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
12 ce062d50 2019-08-21 martijn * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
13 ce062d50 2019-08-21 martijn * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
14 ce062d50 2019-08-21 martijn * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
16 ce062d50 2019-08-21 martijn #include <sys/time.h>
17 ce062d50 2019-08-21 martijn #include <sys/tree.h>
18 ce062d50 2019-08-21 martijn #include <sys/socket.h>
19 ce062d50 2019-08-21 martijn #include <sys/un.h>
21 ce062d50 2019-08-21 martijn #include <arpa/inet.h>
22 078ff8cf 2019-08-21 martijn #include <netinet/in.h>
24 ce062d50 2019-08-21 martijn #include <err.h>
25 ce062d50 2019-08-21 martijn #include <errno.h>
26 ce062d50 2019-08-21 martijn #include <event.h>
27 ce062d50 2019-08-21 martijn #include <fcntl.h>
28 ce062d50 2019-08-21 martijn #include <inttypes.h>
29 ce062d50 2019-08-21 martijn #include <limits.h>
30 ce062d50 2019-08-21 martijn #include <stdarg.h>
31 ce062d50 2019-08-21 martijn #include <stdio.h>
32 ce062d50 2019-08-21 martijn #include <stdlib.h>
33 ce062d50 2019-08-21 martijn #include <string.h>
34 ce062d50 2019-08-21 martijn #include <syslog.h>
35 ce062d50 2019-08-21 martijn #include <unistd.h>
37 ce062d50 2019-08-21 martijn #include "opensmtpd.h"
38 ce062d50 2019-08-21 martijn #include "ioev.h"
40 ce062d50 2019-08-21 martijn #define NITEMS(x) (sizeof(x) / sizeof(*x))
42 d229c123 2019-08-22 martijn struct osmtpd_callback {
43 d229c123 2019-08-22 martijn enum osmtpd_type type;
44 d229c123 2019-08-22 martijn enum osmtpd_phase phase;
45 d229c123 2019-08-22 martijn int incoming;
46 d229c123 2019-08-22 martijn void (*osmtpd_cb)(struct osmtpd_callback *, struct osmtpd_ctx *, char *,
48 d229c123 2019-08-22 martijn void *cb;
49 d229c123 2019-08-22 martijn int doregister;
50 d229c123 2019-08-22 martijn int storereport;
53 d229c123 2019-08-22 martijn struct osmtpd_session {
54 d229c123 2019-08-22 martijn struct osmtpd_ctx ctx;
55 d229c123 2019-08-22 martijn RB_ENTRY(osmtpd_session) entry;
58 d229c123 2019-08-22 martijn static void osmtpd_register(enum osmtpd_type, enum osmtpd_phase, int, int,
60 d229c123 2019-08-22 martijn static const char *osmtpd_typetostr(enum osmtpd_type);
61 d229c123 2019-08-22 martijn static const char *osmtpd_phasetostr(enum osmtpd_phase);
62 d229c123 2019-08-22 martijn static enum osmtpd_phase osmtpd_strtophase(const char *, const char *);
63 d229c123 2019-08-22 martijn static void osmtpd_newline(struct io *, int, void *);
64 d229c123 2019-08-22 martijn static void osmtpd_outevt(struct io *, int, void *);
65 d229c123 2019-08-22 martijn static void osmtpd_noargs(struct osmtpd_callback *, struct osmtpd_ctx *,
66 d229c123 2019-08-22 martijn char *, char *);
67 d229c123 2019-08-22 martijn static void osmtpd_onearg(struct osmtpd_callback *, struct osmtpd_ctx *,
68 d229c123 2019-08-22 martijn char *, char *);
69 d229c123 2019-08-22 martijn static void osmtpd_connect(struct osmtpd_callback *, struct osmtpd_ctx *,
70 d229c123 2019-08-22 martijn char *, char *);
71 d229c123 2019-08-22 martijn static void osmtpd_link_connect(struct osmtpd_callback *, struct osmtpd_ctx *,
72 d229c123 2019-08-22 martijn char *, char *);
73 d229c123 2019-08-22 martijn static void osmtpd_link_disconnect(struct osmtpd_callback *,
74 d229c123 2019-08-22 martijn struct osmtpd_ctx *, char *, char *);
75 d229c123 2019-08-22 martijn static void osmtpd_link_identify(struct osmtpd_callback *, struct osmtpd_ctx *,
76 d229c123 2019-08-22 martijn char *, char *);
77 d229c123 2019-08-22 martijn static void osmtpd_link_tls(struct osmtpd_callback *, struct osmtpd_ctx *,
78 d229c123 2019-08-22 martijn char *, char *);
79 d229c123 2019-08-22 martijn static void osmtpd_tx_begin(struct osmtpd_callback *, struct osmtpd_ctx *,
80 d229c123 2019-08-22 martijn char *, char *);
81 d229c123 2019-08-22 martijn static void osmtpd_tx_mail(struct osmtpd_callback *, struct osmtpd_ctx *,
82 d229c123 2019-08-22 martijn char *, char *);
83 d229c123 2019-08-22 martijn static void osmtpd_tx_rcpt(struct osmtpd_callback *, struct osmtpd_ctx *,
84 d229c123 2019-08-22 martijn char *, char *);
85 d229c123 2019-08-22 martijn static void osmtpd_tx_envelope(struct osmtpd_callback *, struct osmtpd_ctx *,
86 d229c123 2019-08-22 martijn char *, char *);
87 d229c123 2019-08-22 martijn static void osmtpd_tx_data(struct osmtpd_callback *, struct osmtpd_ctx *,
88 d229c123 2019-08-22 martijn char *, char *);
89 d229c123 2019-08-22 martijn static void osmtpd_tx_commit(struct osmtpd_callback *, struct osmtpd_ctx *,
90 d229c123 2019-08-22 martijn char *, char *);
91 d229c123 2019-08-22 martijn static void osmtpd_tx_rollback(struct osmtpd_callback *, struct osmtpd_ctx *,
92 d229c123 2019-08-22 martijn char *, char *);
93 d229c123 2019-08-22 martijn static void osmtpd_addrtoss(char *, struct sockaddr_storage *, int, char *);
94 d229c123 2019-08-22 martijn static enum osmtpd_status osmtpd_strtostatus(const char *, char *);
95 d229c123 2019-08-22 martijn static int osmtpd_session_cmp(struct osmtpd_session *, struct osmtpd_session *);
96 d229c123 2019-08-22 martijn static void *(*oncreatecb)(struct osmtpd_ctx *) = NULL;
97 d229c123 2019-08-22 martijn static void (*ondeletecb)(struct osmtpd_ctx *, void *) = NULL;
100 d229c123 2019-08-22 martijn static struct osmtpd_callback osmtpd_callbacks[] = {
102 d229c123 2019-08-22 martijn OSMTPD_TYPE_FILTER,
103 d229c123 2019-08-22 martijn OSMTPD_PHASE_CONNECT,
105 d229c123 2019-08-22 martijn osmtpd_connect,
111 d229c123 2019-08-22 martijn OSMTPD_TYPE_FILTER,
112 d229c123 2019-08-22 martijn OSMTPD_PHASE_HELO,
114 d229c123 2019-08-22 martijn osmtpd_onearg,
120 d229c123 2019-08-22 martijn OSMTPD_TYPE_FILTER,
121 d229c123 2019-08-22 martijn OSMTPD_PHASE_EHLO,
123 d229c123 2019-08-22 martijn osmtpd_onearg,
129 d229c123 2019-08-22 martijn OSMTPD_TYPE_FILTER,
130 d229c123 2019-08-22 martijn OSMTPD_PHASE_STARTTLS,
132 d229c123 2019-08-22 martijn osmtpd_noargs,
138 d229c123 2019-08-22 martijn OSMTPD_TYPE_FILTER,
139 d229c123 2019-08-22 martijn OSMTPD_PHASE_AUTH,
141 d229c123 2019-08-22 martijn osmtpd_onearg,
147 d229c123 2019-08-22 martijn OSMTPD_TYPE_FILTER,
148 d229c123 2019-08-22 martijn OSMTPD_PHASE_MAIL_FROM,
150 d229c123 2019-08-22 martijn osmtpd_onearg,
156 d229c123 2019-08-22 martijn OSMTPD_TYPE_FILTER,
157 d229c123 2019-08-22 martijn OSMTPD_PHASE_RCPT_TO,
159 d229c123 2019-08-22 martijn osmtpd_onearg,
165 d229c123 2019-08-22 martijn OSMTPD_TYPE_FILTER,
166 d229c123 2019-08-22 martijn OSMTPD_PHASE_DATA,
168 d229c123 2019-08-22 martijn osmtpd_noargs,
174 d229c123 2019-08-22 martijn OSMTPD_TYPE_FILTER,
175 d229c123 2019-08-22 martijn OSMTPD_PHASE_DATA_LINE,
177 d229c123 2019-08-22 martijn osmtpd_onearg,
183 d229c123 2019-08-22 martijn OSMTPD_TYPE_FILTER,
184 d229c123 2019-08-22 martijn OSMTPD_PHASE_RSET,
186 d229c123 2019-08-22 martijn osmtpd_noargs,
192 d229c123 2019-08-22 martijn OSMTPD_TYPE_FILTER,
193 d229c123 2019-08-22 martijn OSMTPD_PHASE_QUIT,
195 d229c123 2019-08-22 martijn osmtpd_noargs,
201 d229c123 2019-08-22 martijn OSMTPD_TYPE_FILTER,
202 d229c123 2019-08-22 martijn OSMTPD_PHASE_NOOP,
204 d229c123 2019-08-22 martijn osmtpd_noargs,
210 d229c123 2019-08-22 martijn OSMTPD_TYPE_FILTER,
211 d229c123 2019-08-22 martijn OSMTPD_PHASE_HELP,
213 d229c123 2019-08-22 martijn osmtpd_noargs,
219 d229c123 2019-08-22 martijn OSMTPD_TYPE_FILTER,
220 d229c123 2019-08-22 martijn OSMTPD_PHASE_WIZ,
222 d229c123 2019-08-22 martijn osmtpd_noargs,
228 d229c123 2019-08-22 martijn OSMTPD_TYPE_FILTER,
229 d229c123 2019-08-22 martijn OSMTPD_PHASE_COMMIT,
231 d229c123 2019-08-22 martijn osmtpd_noargs,
237 d229c123 2019-08-22 martijn OSMTPD_TYPE_REPORT,
238 d229c123 2019-08-22 martijn OSMTPD_PHASE_LINK_CONNECT,
240 d229c123 2019-08-22 martijn osmtpd_link_connect,
246 d229c123 2019-08-22 martijn OSMTPD_TYPE_REPORT,
247 d229c123 2019-08-22 martijn OSMTPD_PHASE_LINK_DISCONNECT,
249 d229c123 2019-08-22 martijn osmtpd_link_disconnect,
255 d229c123 2019-08-22 martijn OSMTPD_TYPE_REPORT,
256 d229c123 2019-08-22 martijn OSMTPD_PHASE_LINK_IDENTIFY,
258 d229c123 2019-08-22 martijn osmtpd_link_identify,
264 d229c123 2019-08-22 martijn OSMTPD_TYPE_REPORT,
265 d229c123 2019-08-22 martijn OSMTPD_PHASE_LINK_TLS,
267 d229c123 2019-08-22 martijn osmtpd_link_tls,
273 d229c123 2019-08-22 martijn OSMTPD_TYPE_REPORT,
274 d229c123 2019-08-22 martijn OSMTPD_PHASE_TX_BEGIN,
276 d229c123 2019-08-22 martijn osmtpd_tx_begin,
282 d229c123 2019-08-22 martijn OSMTPD_TYPE_REPORT,
283 d229c123 2019-08-22 martijn OSMTPD_PHASE_TX_MAIL,
285 d229c123 2019-08-22 martijn osmtpd_tx_mail,
291 d229c123 2019-08-22 martijn OSMTPD_TYPE_REPORT,
292 d229c123 2019-08-22 martijn OSMTPD_PHASE_TX_RCPT,
294 d229c123 2019-08-22 martijn osmtpd_tx_rcpt,
300 d229c123 2019-08-22 martijn OSMTPD_TYPE_REPORT,
301 d229c123 2019-08-22 martijn OSMTPD_PHASE_TX_ENVELOPE,
303 d229c123 2019-08-22 martijn osmtpd_tx_envelope,
309 d229c123 2019-08-22 martijn OSMTPD_TYPE_REPORT,
310 d229c123 2019-08-22 martijn OSMTPD_PHASE_TX_DATA,
312 d229c123 2019-08-22 martijn osmtpd_tx_data,
318 d229c123 2019-08-22 martijn OSMTPD_TYPE_REPORT,
319 d229c123 2019-08-22 martijn OSMTPD_PHASE_TX_COMMIT,
321 d229c123 2019-08-22 martijn osmtpd_tx_commit,
327 d229c123 2019-08-22 martijn OSMTPD_TYPE_REPORT,
328 d229c123 2019-08-22 martijn OSMTPD_PHASE_TX_ROLLBACK,
330 d229c123 2019-08-22 martijn osmtpd_tx_rollback,
336 d229c123 2019-08-22 martijn OSMTPD_TYPE_REPORT,
337 d229c123 2019-08-22 martijn OSMTPD_PHASE_PROTOCOL_CLIENT,
339 d229c123 2019-08-22 martijn osmtpd_onearg,
345 d229c123 2019-08-22 martijn OSMTPD_TYPE_REPORT,
346 d229c123 2019-08-22 martijn OSMTPD_PHASE_PROTOCOL_SERVER,
348 d229c123 2019-08-22 martijn osmtpd_onearg,
354 d229c123 2019-08-22 martijn OSMTPD_TYPE_REPORT,
355 d229c123 2019-08-22 martijn OSMTPD_PHASE_FILTER_RESPONSE,
357 d229c123 2019-08-22 martijn osmtpd_onearg,
363 d229c123 2019-08-22 martijn OSMTPD_TYPE_REPORT,
364 d229c123 2019-08-22 martijn OSMTPD_PHASE_TIMEOUT,
366 d229c123 2019-08-22 martijn osmtpd_noargs,
372 d229c123 2019-08-22 martijn OSMTPD_TYPE_REPORT,
373 d229c123 2019-08-22 martijn OSMTPD_PHASE_LINK_CONNECT,
375 d229c123 2019-08-22 martijn osmtpd_link_connect,
381 d229c123 2019-08-22 martijn OSMTPD_TYPE_REPORT,
382 d229c123 2019-08-22 martijn OSMTPD_PHASE_LINK_DISCONNECT,
384 d229c123 2019-08-22 martijn osmtpd_link_disconnect,
390 d229c123 2019-08-22 martijn OSMTPD_TYPE_REPORT,
391 d229c123 2019-08-22 martijn OSMTPD_PHASE_LINK_IDENTIFY,
393 d229c123 2019-08-22 martijn osmtpd_link_identify,
399 d229c123 2019-08-22 martijn OSMTPD_TYPE_REPORT,
400 d229c123 2019-08-22 martijn OSMTPD_PHASE_LINK_TLS,
402 d229c123 2019-08-22 martijn osmtpd_link_tls,
408 d229c123 2019-08-22 martijn OSMTPD_TYPE_REPORT,
409 d229c123 2019-08-22 martijn OSMTPD_PHASE_TX_BEGIN,
411 d229c123 2019-08-22 martijn osmtpd_tx_begin,
417 d229c123 2019-08-22 martijn OSMTPD_TYPE_REPORT,
418 d229c123 2019-08-22 martijn OSMTPD_PHASE_TX_MAIL,
420 d229c123 2019-08-22 martijn osmtpd_tx_mail,
426 d229c123 2019-08-22 martijn OSMTPD_TYPE_REPORT,
427 d229c123 2019-08-22 martijn OSMTPD_PHASE_TX_RCPT,
429 d229c123 2019-08-22 martijn osmtpd_tx_rcpt,
435 d229c123 2019-08-22 martijn OSMTPD_TYPE_REPORT,
436 d229c123 2019-08-22 martijn OSMTPD_PHASE_TX_ENVELOPE,
438 d229c123 2019-08-22 martijn osmtpd_tx_envelope,
444 d229c123 2019-08-22 martijn OSMTPD_TYPE_REPORT,
445 d229c123 2019-08-22 martijn OSMTPD_PHASE_TX_DATA,
447 d229c123 2019-08-22 martijn osmtpd_tx_data,
453 d229c123 2019-08-22 martijn OSMTPD_TYPE_REPORT,
454 d229c123 2019-08-22 martijn OSMTPD_PHASE_TX_COMMIT,
456 d229c123 2019-08-22 martijn osmtpd_tx_commit,
462 d229c123 2019-08-22 martijn OSMTPD_TYPE_REPORT,
463 d229c123 2019-08-22 martijn OSMTPD_PHASE_TX_ROLLBACK,
465 d229c123 2019-08-22 martijn osmtpd_tx_rollback,
471 d229c123 2019-08-22 martijn OSMTPD_TYPE_REPORT,
472 d229c123 2019-08-22 martijn OSMTPD_PHASE_PROTOCOL_CLIENT,
474 d229c123 2019-08-22 martijn osmtpd_onearg,
480 d229c123 2019-08-22 martijn OSMTPD_TYPE_REPORT,
481 d229c123 2019-08-22 martijn OSMTPD_PHASE_PROTOCOL_SERVER,
483 d229c123 2019-08-22 martijn osmtpd_onearg,
489 d229c123 2019-08-22 martijn OSMTPD_TYPE_REPORT,
490 d229c123 2019-08-22 martijn OSMTPD_PHASE_FILTER_RESPONSE,
492 d229c123 2019-08-22 martijn osmtpd_onearg,
498 d229c123 2019-08-22 martijn OSMTPD_TYPE_REPORT,
499 d229c123 2019-08-22 martijn OSMTPD_PHASE_TIMEOUT,
501 d229c123 2019-08-22 martijn osmtpd_noargs,
508 ce062d50 2019-08-21 martijn static struct io *io_stdout;
509 ce062d50 2019-08-21 martijn static int ready = 0;
510 ce062d50 2019-08-21 martijn /* Default from smtpd */
511 ce062d50 2019-08-21 martijn static int session_timeout = 300;
513 d229c123 2019-08-22 martijn RB_HEAD(osmtpd_sessions, osmtpd_session) osmtpd_sessions = RB_INITIALIZER(NULL);
514 9e3e8410 2019-08-22 martijn RB_PROTOTYPE_STATIC(osmtpd_sessions, osmtpd_session, entry, osmtpd_session_cmp);
517 ce062d50 2019-08-21 martijn osmtpd_register_filter_connect(void (*cb)(struct osmtpd_ctx *, const char *,
518 ce062d50 2019-08-21 martijn struct sockaddr_storage *))
520 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_FILTER, OSMTPD_PHASE_CONNECT, 1, 0,
521 ce062d50 2019-08-21 martijn (void *)cb);
522 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_DISCONNECT, 1, 0,
527 ce062d50 2019-08-21 martijn osmtpd_register_filter_helo(void (*cb)(struct osmtpd_ctx *, const char *))
529 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_FILTER, OSMTPD_PHASE_HELO, 1, 0,
530 ce062d50 2019-08-21 martijn (void *)cb);
531 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_DISCONNECT, 1, 0,
536 ce062d50 2019-08-21 martijn osmtpd_register_filter_ehlo(void (*cb)(struct osmtpd_ctx *, const char *))
538 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_FILTER, OSMTPD_PHASE_EHLO, 1, 0,
539 ce062d50 2019-08-21 martijn (void *)cb);
540 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_DISCONNECT, 1, 0,
545 ce062d50 2019-08-21 martijn osmtpd_register_filter_starttls(void (*cb)(struct osmtpd_ctx *))
547 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_FILTER, OSMTPD_PHASE_STARTTLS, 1, 0,
548 ce062d50 2019-08-21 martijn (void *)cb);
549 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_DISCONNECT, 1, 0,
554 ce062d50 2019-08-21 martijn osmtpd_register_filter_auth(void (*cb)(struct osmtpd_ctx *, const char *))
556 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_FILTER, OSMTPD_PHASE_AUTH, 1, 0,
557 ce062d50 2019-08-21 martijn (void *)cb);
558 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_DISCONNECT, 1, 0,
563 ce062d50 2019-08-21 martijn osmtpd_register_filter_mailfrom(void (*cb)(struct osmtpd_ctx *, const char *))
565 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_FILTER, OSMTPD_PHASE_MAIL_FROM, 1, 0,
566 ce062d50 2019-08-21 martijn (void *)cb);
567 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_DISCONNECT, 1, 0,
572 ce062d50 2019-08-21 martijn osmtpd_register_filter_rcptto(void (*cb)(struct osmtpd_ctx *, const char *))
574 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_FILTER, OSMTPD_PHASE_RCPT_TO, 1, 0,
575 ce062d50 2019-08-21 martijn (void *)cb);
576 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_DISCONNECT, 1, 0,
581 ce062d50 2019-08-21 martijn osmtpd_register_filter_data(void (*cb)(struct osmtpd_ctx *))
583 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_FILTER, OSMTPD_PHASE_DATA, 1, 0,
584 ce062d50 2019-08-21 martijn (void *)cb);
585 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_DISCONNECT, 1, 0,
590 ce062d50 2019-08-21 martijn osmtpd_register_filter_dataline(void (*cb)(struct osmtpd_ctx *, const char *))
592 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_FILTER, OSMTPD_PHASE_DATA_LINE, 1, 0,
593 ce062d50 2019-08-21 martijn (void *)cb);
594 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_DISCONNECT, 1, 0,
599 ce062d50 2019-08-21 martijn osmtpd_register_filter_rset(void (*cb)(struct osmtpd_ctx *))
601 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_FILTER, OSMTPD_PHASE_RSET, 1, 0,
602 ce062d50 2019-08-21 martijn (void *)cb);
603 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_DISCONNECT, 1, 0,
608 ce062d50 2019-08-21 martijn osmtpd_register_filter_quit(void (*cb)(struct osmtpd_ctx *))
610 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_FILTER, OSMTPD_PHASE_QUIT, 1, 0,
611 ce062d50 2019-08-21 martijn (void *)cb);
612 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_DISCONNECT, 1, 0,
617 ce062d50 2019-08-21 martijn osmtpd_register_filter_noop(void (*cb)(struct osmtpd_ctx *))
619 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_FILTER, OSMTPD_PHASE_NOOP, 1, 0,
620 ce062d50 2019-08-21 martijn (void *)cb);
621 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_DISCONNECT, 1, 0,
626 ce062d50 2019-08-21 martijn osmtpd_register_filter_help(void (*cb)(struct osmtpd_ctx *))
628 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_FILTER, OSMTPD_PHASE_HELP, 1, 0,
629 ce062d50 2019-08-21 martijn (void *)cb);
630 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_DISCONNECT, 1, 0,
635 ce062d50 2019-08-21 martijn osmtpd_register_filter_wiz(void (*cb)(struct osmtpd_ctx *))
637 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_FILTER, OSMTPD_PHASE_WIZ, 1, 0,
638 ce062d50 2019-08-21 martijn (void *)cb);
639 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_DISCONNECT, 1, 0,
644 ce062d50 2019-08-21 martijn osmtpd_register_filter_commit(void (*cb)(struct osmtpd_ctx *))
646 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_FILTER, OSMTPD_PHASE_COMMIT, 1, 0,
647 ce062d50 2019-08-21 martijn (void *)cb);
648 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_DISCONNECT, 1, 0,
653 ce062d50 2019-08-21 martijn osmtpd_register_report_connect(int incoming, void (*cb)(struct osmtpd_ctx *,
654 ce062d50 2019-08-21 martijn const char *, const char *, struct sockaddr_storage *,
655 ce062d50 2019-08-21 martijn struct sockaddr_storage *))
657 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_FILTER, OSMTPD_PHASE_LINK_CONNECT, incoming,
658 ce062d50 2019-08-21 martijn 0, (void *)cb);
659 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_DISCONNECT,
660 ce062d50 2019-08-21 martijn incoming, 0, NULL);
664 ce062d50 2019-08-21 martijn osmtpd_register_report_disconnect(int incoming, void (*cb)(struct osmtpd_ctx *))
666 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_DISCONNECT,
667 ce062d50 2019-08-21 martijn incoming, 0, (void *)cb);
671 ce062d50 2019-08-21 martijn osmtpd_register_report_identify(int incoming, void (*cb)(struct osmtpd_ctx *,
672 ce062d50 2019-08-21 martijn const char *))
674 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_IDENTIFY,
675 ce062d50 2019-08-21 martijn incoming, 0, (void *)cb);
676 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_DISCONNECT,
677 ce062d50 2019-08-21 martijn incoming, 0, NULL);
681 ce062d50 2019-08-21 martijn osmtpd_register_report_tls(int incoming, void (*cb)(struct osmtpd_ctx *,
682 ce062d50 2019-08-21 martijn const char *))
684 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_TLS, incoming, 0,
685 ce062d50 2019-08-21 martijn (void *)cb);
686 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_DISCONNECT,
687 ce062d50 2019-08-21 martijn incoming, 0, NULL);
691 ce062d50 2019-08-21 martijn osmtpd_register_report_begin(int incoming, void (*cb)(struct osmtpd_ctx *,
692 ce062d50 2019-08-21 martijn uint32_t))
694 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_TX_BEGIN, incoming, 0,
695 ce062d50 2019-08-21 martijn (void *)cb);
696 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_DISCONNECT,
697 ce062d50 2019-08-21 martijn incoming, 0, NULL);
701 ce062d50 2019-08-21 martijn osmtpd_register_report_mail(int incoming, void (*cb)(struct osmtpd_ctx *,
702 ce062d50 2019-08-21 martijn uint32_t, const char *, enum osmtpd_status))
704 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_TX_MAIL, incoming, 0,
705 ce062d50 2019-08-21 martijn (void *)cb);
706 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_DISCONNECT,
707 ce062d50 2019-08-21 martijn incoming, 0, NULL);
711 ce062d50 2019-08-21 martijn osmtpd_register_report_rcpt(int incoming, void (*cb)(struct osmtpd_ctx *,
712 ce062d50 2019-08-21 martijn uint32_t, const char *, enum osmtpd_status))
714 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_TX_RCPT, incoming, 0,
715 ce062d50 2019-08-21 martijn (void *)cb);
716 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_DISCONNECT,
717 ce062d50 2019-08-21 martijn incoming, 0, NULL);
721 ce062d50 2019-08-21 martijn osmtpd_register_report_envelope(int incoming, void (*cb)(struct osmtpd_ctx *,
722 ce062d50 2019-08-21 martijn uint32_t, uint64_t))
724 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_TX_ENVELOPE, incoming,
725 ce062d50 2019-08-21 martijn 0, (void *)cb);
726 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_DISCONNECT,
727 ce062d50 2019-08-21 martijn incoming, 0, NULL);
731 ce062d50 2019-08-21 martijn osmtpd_register_report_data(int incoming, void (*cb)(struct osmtpd_ctx *,
732 ce062d50 2019-08-21 martijn uint32_t, enum osmtpd_status))
734 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_TX_DATA, incoming, 0,
735 ce062d50 2019-08-21 martijn (void *)cb);
736 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_DISCONNECT,
737 ce062d50 2019-08-21 martijn incoming, 0, NULL);
741 ce062d50 2019-08-21 martijn osmtpd_register_report_commit(int incoming, void (*cb)(struct osmtpd_ctx *,
742 ce062d50 2019-08-21 martijn uint32_t, size_t))
744 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_TX_COMMIT, incoming, 0,
745 ce062d50 2019-08-21 martijn (void *)cb);
746 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_DISCONNECT,
747 ce062d50 2019-08-21 martijn incoming, 0, NULL);
751 ce062d50 2019-08-21 martijn osmtpd_register_report_rollback(int incoming, void (*cb)(struct osmtpd_ctx *,
752 ce062d50 2019-08-21 martijn uint32_t))
754 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_TX_ROLLBACK, incoming,
755 ce062d50 2019-08-21 martijn 0, (void *)cb);
756 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_DISCONNECT,
757 ce062d50 2019-08-21 martijn incoming, 0, NULL);
761 ce062d50 2019-08-21 martijn osmtpd_register_report_client(int incoming, void (*cb)(struct osmtpd_ctx *,
762 ce062d50 2019-08-21 martijn const char *))
764 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_PROTOCOL_CLIENT,
765 ce062d50 2019-08-21 martijn incoming, 0, (void *)cb);
766 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_DISCONNECT,
767 ce062d50 2019-08-21 martijn incoming, 0, NULL);
771 ce062d50 2019-08-21 martijn osmtpd_register_report_server(int incoming, void (*cb)(struct osmtpd_ctx *,
772 ce062d50 2019-08-21 martijn const char *))
774 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_PROTOCOL_SERVER,
775 ce062d50 2019-08-21 martijn incoming, 0, (void *)cb);
776 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_DISCONNECT,
777 ce062d50 2019-08-21 martijn incoming, 0, NULL);
781 ce062d50 2019-08-21 martijn osmtpd_register_report_response(int incoming, void (*cb)(struct osmtpd_ctx *,
782 ce062d50 2019-08-21 martijn const char *))
784 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_FILTER_RESPONSE,
785 ce062d50 2019-08-21 martijn incoming, 0, (void *)cb);
786 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_DISCONNECT,
787 ce062d50 2019-08-21 martijn incoming, 0, NULL);
791 ce062d50 2019-08-21 martijn osmtpd_register_report_timeout(int incoming, void (*cb)(struct osmtpd_ctx *))
793 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_TIMEOUT, incoming, 0,
794 ce062d50 2019-08-21 martijn (void *)cb);
795 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_DISCONNECT,
796 ce062d50 2019-08-21 martijn incoming, 0, NULL);
800 ce062d50 2019-08-21 martijn osmtpd_localdata(void *(*oncreate)(struct osmtpd_ctx *),
801 ce062d50 2019-08-21 martijn void (*ondelete)(struct osmtpd_ctx *, void *))
803 ce062d50 2019-08-21 martijn oncreatecb = oncreate;
804 ce062d50 2019-08-21 martijn ondeletecb = ondelete;
808 ce062d50 2019-08-21 martijn osmtpd_need(int incoming, int needs)
810 ce062d50 2019-08-21 martijn if (needs & (OSMTPD_NEED_SRC | OSMTPD_NEED_DST | OSMTPD_NEED_RDNS |
811 ce062d50 2019-08-21 martijn OSMTPD_NEED_FRDNS))
812 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_FILTER, OSMTPD_PHASE_LINK_CONNECT,
813 ce062d50 2019-08-21 martijn incoming, 1, NULL);
814 ce062d50 2019-08-21 martijn if (needs & OSMTPD_NEED_IDENTITY)
815 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_IDENTIFY,
816 ce062d50 2019-08-21 martijn incoming, 1, NULL);
817 ce062d50 2019-08-21 martijn if (needs & OSMTPD_NEED_CIPHERS)
818 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_TLS,
819 ce062d50 2019-08-21 martijn incoming, 1, NULL);
820 ce062d50 2019-08-21 martijn if (needs & OSMTPD_NEED_MSGID) {
821 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_TX_BEGIN,
822 ce062d50 2019-08-21 martijn incoming, 1, NULL);
823 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_TX_ROLLBACK,
824 ce062d50 2019-08-21 martijn incoming, 0, NULL);
825 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_TX_COMMIT,
826 ce062d50 2019-08-21 martijn incoming, 0, NULL);
828 ce062d50 2019-08-21 martijn if (needs & OSMTPD_NEED_MAILFROM) {
829 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_TX_MAIL,
830 ce062d50 2019-08-21 martijn incoming, 1, NULL);
831 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_TX_ROLLBACK,
832 ce062d50 2019-08-21 martijn incoming, 0, NULL);
833 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_TX_COMMIT,
834 ce062d50 2019-08-21 martijn incoming, 0, NULL);
836 ce062d50 2019-08-21 martijn if (needs & OSMTPD_NEED_RCPTTO) {
837 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_TX_RCPT,
838 ce062d50 2019-08-21 martijn incoming, 1, NULL);
839 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_TX_ROLLBACK,
840 ce062d50 2019-08-21 martijn incoming, 0, NULL);
841 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_TX_COMMIT,
842 ce062d50 2019-08-21 martijn incoming, 0, NULL);
844 ce062d50 2019-08-21 martijn if (needs & OSMTPD_NEED_EVPID) {
845 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_TX_ENVELOPE,
846 ce062d50 2019-08-21 martijn incoming, 1, NULL);
847 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_TX_ROLLBACK,
848 ce062d50 2019-08-21 martijn incoming, 0, NULL);
849 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_TX_COMMIT,
850 ce062d50 2019-08-21 martijn incoming, 0, NULL);
853 ce062d50 2019-08-21 martijn osmtpd_register(OSMTPD_TYPE_REPORT, OSMTPD_PHASE_LINK_DISCONNECT,
854 ce062d50 2019-08-21 martijn incoming, 0, NULL);
858 ce062d50 2019-08-21 martijn osmtpd_run(void)
860 ce062d50 2019-08-21 martijn size_t i = 0;
861 ce062d50 2019-08-21 martijn int registered = 0;
862 ce062d50 2019-08-21 martijn /* Doesn't leak, since it needs to exists until the application ends. */
863 ce062d50 2019-08-21 martijn struct io *io_stdin;
865 ce062d50 2019-08-21 martijn event_init();
867 ce062d50 2019-08-21 martijn if ((io_stdin = io_new()) == NULL ||
868 ce062d50 2019-08-21 martijn (io_stdout = io_new()) == NULL)
869 ce062d50 2019-08-21 martijn err(1, "io_new");
870 ce062d50 2019-08-21 martijn io_set_nonblocking(STDIN_FILENO);
871 ce062d50 2019-08-21 martijn io_set_fd(io_stdin, STDIN_FILENO);
872 ce062d50 2019-08-21 martijn io_set_callback(io_stdin, osmtpd_newline, NULL);
873 ce062d50 2019-08-21 martijn io_set_read(io_stdin);
874 ce062d50 2019-08-21 martijn io_set_nonblocking(STDOUT_FILENO);
875 ce062d50 2019-08-21 martijn io_set_fd(io_stdout, STDOUT_FILENO);
876 ce062d50 2019-08-21 martijn io_set_callback(io_stdout, osmtpd_outevt, NULL);
877 ce062d50 2019-08-21 martijn io_set_write(io_stdout);
879 ce062d50 2019-08-21 martijn for (i = 0; i < NITEMS(osmtpd_callbacks); i++) {
880 ce062d50 2019-08-21 martijn if (osmtpd_callbacks[i].doregister) {
881 ce062d50 2019-08-21 martijn if (osmtpd_callbacks[i].cb != NULL)
882 ce062d50 2019-08-21 martijn registered = 1;
883 ce062d50 2019-08-21 martijn io_printf(io_stdout, "register|%s|smtp-%s|%s\n",
884 ce062d50 2019-08-21 martijn osmtpd_typetostr(osmtpd_callbacks[i].type),
885 ce062d50 2019-08-21 martijn osmtpd_callbacks[i].incoming ? "in" : "out",
886 ce062d50 2019-08-21 martijn osmtpd_phasetostr(osmtpd_callbacks[i].phase));
890 ce062d50 2019-08-21 martijn if (!registered)
891 ce062d50 2019-08-21 martijn errx(1, "No events registered");
892 ce062d50 2019-08-21 martijn io_printf(io_stdout, "register|ready\n");
893 ce062d50 2019-08-21 martijn ready = 1;
895 ce062d50 2019-08-21 martijn event_dispatch();
898 ce062d50 2019-08-21 martijn static void
899 ce062d50 2019-08-21 martijn osmtpd_newline(struct io *io, int ev, void *arg)
901 ce062d50 2019-08-21 martijn static char *linedup = NULL;
902 ce062d50 2019-08-21 martijn static size_t dupsize = 0;
903 ce062d50 2019-08-21 martijn struct osmtpd_session *ctx, search;
904 ce062d50 2019-08-21 martijn enum osmtpd_type type;
905 ce062d50 2019-08-21 martijn enum osmtpd_phase phase;
906 ce062d50 2019-08-21 martijn int version_major, version_minor, incoming;
907 ce062d50 2019-08-21 martijn struct timespec tm;
908 ce062d50 2019-08-21 martijn char *line = NULL;
909 ce062d50 2019-08-21 martijn const char *errstr = NULL;
910 ce062d50 2019-08-21 martijn size_t linelen;
911 ce062d50 2019-08-21 martijn char *end;
912 ce062d50 2019-08-21 martijn size_t i;
914 ce062d50 2019-08-21 martijn if (ev == IO_DISCONNECTED)
915 ce062d50 2019-08-21 martijn exit(0);
916 ce062d50 2019-08-21 martijn if (ev != IO_DATAIN)
918 ce062d50 2019-08-21 martijn while ((line = io_getline(io, &linelen)) > 0) {
919 ce062d50 2019-08-21 martijn if (dupsize < linelen) {
920 ce062d50 2019-08-21 martijn if ((linedup = realloc(linedup, linelen + 1)) == NULL)
921 ce062d50 2019-08-21 martijn err(1, NULL);
922 ce062d50 2019-08-21 martijn dupsize = linelen + 1;
924 ce062d50 2019-08-21 martijn strlcpy(linedup, line, dupsize);
925 ce062d50 2019-08-21 martijn if ((end = strchr(line, '|')) == NULL)
926 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: missing version: %s", linedup);
927 ce062d50 2019-08-21 martijn end++[0] = '\0';
928 ce062d50 2019-08-21 martijn if (strcmp(line, "filter") == 0)
929 ce062d50 2019-08-21 martijn type = OSMTPD_TYPE_FILTER;
930 ce062d50 2019-08-21 martijn else if (strcmp(line, "report") == 0)
931 ce062d50 2019-08-21 martijn type = OSMTPD_TYPE_REPORT;
932 ce062d50 2019-08-21 martijn else if (strcmp(line, "config") == 0) {
933 ce062d50 2019-08-21 martijn line = end;
934 ce062d50 2019-08-21 martijn if (strcmp(line, "ready") == 0)
935 ce062d50 2019-08-21 martijn continue;
936 ce062d50 2019-08-21 martijn if ((end = strchr(line, '|')) == NULL)
937 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: missing key: %s", linedup);
938 ce062d50 2019-08-21 martijn end++[0] = '\0';
939 ce062d50 2019-08-21 martijn if (strcmp(line, "smtp-session-timeout") == 0) {
940 ce062d50 2019-08-21 martijn session_timeout = strtonum(end, 0, INT_MAX,
941 ce062d50 2019-08-21 martijn &errstr);
942 ce062d50 2019-08-21 martijn if (errstr != NULL)
943 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: "
944 ce062d50 2019-08-21 martijn "invalid smtp-sesion-timeout: %s",
945 ce062d50 2019-08-21 martijn linedup);
947 ce062d50 2019-08-21 martijn continue;
950 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: unknown message type: %s", linedup);
951 ce062d50 2019-08-21 martijn line = end;
952 ce062d50 2019-08-21 martijn if ((end = strchr(line, '|')) == NULL)
953 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: missing time: %s", linedup);
954 ce062d50 2019-08-21 martijn end++[0] = '\0';
955 ce062d50 2019-08-21 martijn if (strcmp(line, "0.1") != 0)
956 ce062d50 2019-08-21 martijn errx(1, "Unsupported protocol received: %s", linedup);
957 ce062d50 2019-08-21 martijn version_major = 0;
958 ce062d50 2019-08-21 martijn version_minor = 1;
959 ce062d50 2019-08-21 martijn line = end;
960 ce062d50 2019-08-21 martijn if ((end = strchr(line, '.')) == NULL)
961 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: invalid timestamp: %s", linedup);
962 ce062d50 2019-08-21 martijn end++[0] = '\0';
963 ce062d50 2019-08-21 martijn tm.tv_sec = (time_t) strtonum(line, 0, INT64_MAX, &errstr);
964 ce062d50 2019-08-21 martijn if (errstr != NULL)
965 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: invalid timestamp: %s", linedup);
966 ce062d50 2019-08-21 martijn line = end;
967 ce062d50 2019-08-21 martijn if ((end = strchr(line, '|')) == NULL)
968 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: missing direction: %s", linedup);
969 ce062d50 2019-08-21 martijn end++[0] = '\0';
970 ce062d50 2019-08-21 martijn tm.tv_nsec = (long) strtonum(line, 0, LONG_MAX, &errstr);
971 ce062d50 2019-08-21 martijn if (errstr != NULL)
972 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: invalid timestamp: %s",
973 ce062d50 2019-08-21 martijn linedup);
974 ce062d50 2019-08-21 martijn tm.tv_nsec *= 10 * (9 - (end - line));
975 ce062d50 2019-08-21 martijn line = end;
976 ce062d50 2019-08-21 martijn if ((end = strchr(line, '|')) == NULL)
977 ce062d50 2019-08-21 martijn errx(1, "Invalid line receieved: missing phase: %s",
978 ce062d50 2019-08-21 martijn linedup);
979 ce062d50 2019-08-21 martijn end++[0] = '\0';
980 ce062d50 2019-08-21 martijn if (strcmp(line, "smtp-in") == 0)
981 ce062d50 2019-08-21 martijn incoming = 1;
982 ce062d50 2019-08-21 martijn else if (strcmp(line, "smtp-out") == 0)
983 ce062d50 2019-08-21 martijn incoming = 0;
985 ce062d50 2019-08-21 martijn errx(1, "Invalid line: invalid direction: %s", linedup);
986 ce062d50 2019-08-21 martijn line = end;
987 ce062d50 2019-08-21 martijn if ((end = strchr(line, '|')) == NULL)
988 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: missing reqid: %s",
989 ce062d50 2019-08-21 martijn linedup);
990 ce062d50 2019-08-21 martijn end++[0] = '\0';
991 ce062d50 2019-08-21 martijn phase = osmtpd_strtophase(line, linedup);
992 ce062d50 2019-08-21 martijn line = end;
993 ce062d50 2019-08-21 martijn errno = 0;
994 ce062d50 2019-08-21 martijn search.ctx.reqid = strtoull(line, &end, 16);
995 ce062d50 2019-08-21 martijn if ((search.ctx.reqid == ULLONG_MAX && errno != 0) ||
996 ce062d50 2019-08-21 martijn (end[0] != '|' && end[0] != '\0'))
997 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: invalid reqid: %s",
998 ce062d50 2019-08-21 martijn linedup);
999 ce062d50 2019-08-21 martijn line = end + 1;
1000 ce062d50 2019-08-21 martijn ctx = RB_FIND(osmtpd_sessions, &osmtpd_sessions, &search);
1001 ce062d50 2019-08-21 martijn if (ctx == NULL) {
1002 ce062d50 2019-08-21 martijn if ((ctx = malloc(sizeof(*ctx))) == NULL)
1003 ce062d50 2019-08-21 martijn err(1, NULL);
1004 ce062d50 2019-08-21 martijn ctx->ctx.reqid = search.ctx.reqid;
1005 ce062d50 2019-08-21 martijn ctx->ctx.rdns = NULL;
1006 ce062d50 2019-08-21 martijn ctx->ctx.fcrdns = NULL;
1007 ce062d50 2019-08-21 martijn ctx->ctx.identity = NULL;
1008 ce062d50 2019-08-21 martijn ctx->ctx.ciphers = NULL;
1009 ce062d50 2019-08-21 martijn ctx->ctx.msgid = 0;
1010 ce062d50 2019-08-21 martijn ctx->ctx.mailfrom = NULL;
1011 ce062d50 2019-08-21 martijn ctx->ctx.rcptto = malloc(sizeof(*(ctx->ctx.rcptto)));
1012 ce062d50 2019-08-21 martijn if (ctx->ctx.rcptto == NULL)
1013 ce062d50 2019-08-21 martijn err(1, "malloc");
1014 ce062d50 2019-08-21 martijn ctx->ctx.rcptto[0] = NULL;
1015 ce062d50 2019-08-21 martijn memset(&(ctx->ctx.src), 0, sizeof(ctx->ctx.src));
1016 ce062d50 2019-08-21 martijn ctx->ctx.src.ss_family = AF_UNSPEC;
1017 ce062d50 2019-08-21 martijn memset(&(ctx->ctx.dst), 0, sizeof(ctx->ctx.dst));
1018 ce062d50 2019-08-21 martijn ctx->ctx.dst.ss_family = AF_UNSPEC;
1019 ce062d50 2019-08-21 martijn RB_INSERT(osmtpd_sessions, &osmtpd_sessions, ctx);
1020 ce062d50 2019-08-21 martijn ctx->ctx.evpid = 0;
1021 ce062d50 2019-08-21 martijn ctx->ctx.local = NULL;
1022 ce062d50 2019-08-21 martijn if (oncreatecb != NULL)
1023 ce062d50 2019-08-21 martijn ctx->ctx.local = oncreatecb(&ctx->ctx);
1025 ce062d50 2019-08-21 martijn ctx->ctx.type = type;
1026 ce062d50 2019-08-21 martijn ctx->ctx.phase = phase;
1027 ce062d50 2019-08-21 martijn ctx->ctx.version_major = version_major;
1028 ce062d50 2019-08-21 martijn ctx->ctx.version_minor = version_minor;
1029 ce062d50 2019-08-21 martijn ctx->ctx.incoming = incoming;
1030 ce062d50 2019-08-21 martijn ctx->ctx.tm.tv_sec = tm.tv_sec;
1031 ce062d50 2019-08-21 martijn ctx->ctx.tm.tv_nsec = tm.tv_nsec;
1032 ce062d50 2019-08-21 martijn ctx->ctx.token = 0;
1034 ce062d50 2019-08-21 martijn for (i = 0; i < NITEMS(osmtpd_callbacks); i++) {
1035 ce062d50 2019-08-21 martijn if (ctx->ctx.type == osmtpd_callbacks[i].type &&
1036 ce062d50 2019-08-21 martijn ctx->ctx.phase == osmtpd_callbacks[i].phase &&
1037 ce062d50 2019-08-21 martijn ctx->ctx.incoming == osmtpd_callbacks[i].incoming)
1040 ce062d50 2019-08-21 martijn if (i == NITEMS(osmtpd_callbacks)) {
1041 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: received unregistered "
1042 ce062d50 2019-08-21 martijn "line: %s", linedup);
1044 ce062d50 2019-08-21 martijn if (ctx->ctx.type == OSMTPD_TYPE_FILTER) {
1045 ce062d50 2019-08-21 martijn ctx->ctx.token = strtoull(line, &end, 16);
1046 ce062d50 2019-08-21 martijn if ((ctx->ctx.token == ULLONG_MAX && errno != 0) ||
1047 ce062d50 2019-08-21 martijn end[0] != '|')
1048 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: invalid token: %s", linedup);
1049 ce062d50 2019-08-21 martijn line = end + 1;
1051 ce062d50 2019-08-21 martijn osmtpd_callbacks[i].osmtpd_cb(&(osmtpd_callbacks[i]),
1052 ce062d50 2019-08-21 martijn &(ctx->ctx), line, linedup);
1056 ce062d50 2019-08-21 martijn static void
1057 ce062d50 2019-08-21 martijn osmtpd_outevt(struct io *io, int evt, void *arg)
1059 ce062d50 2019-08-21 martijn switch (evt) {
1060 ce062d50 2019-08-21 martijn case IO_LOWAT:
1061 ce062d50 2019-08-21 martijn return;
1062 ce062d50 2019-08-21 martijn case IO_DISCONNECTED:
1063 ce062d50 2019-08-21 martijn exit(0);
1064 ce062d50 2019-08-21 martijn default:
1065 ce062d50 2019-08-21 martijn errx(1, "Unexpectd event");
1069 ce062d50 2019-08-21 martijn static void
1070 ce062d50 2019-08-21 martijn osmtpd_noargs(struct osmtpd_callback *cb, struct osmtpd_ctx *ctx, char *params,
1071 ce062d50 2019-08-21 martijn char *linedup)
1073 ce062d50 2019-08-21 martijn void (*f)(struct osmtpd_ctx *);
1075 ce062d50 2019-08-21 martijn f = cb->cb;
1076 ce062d50 2019-08-21 martijn f(ctx);
1079 ce062d50 2019-08-21 martijn static void
1080 ce062d50 2019-08-21 martijn osmtpd_onearg(struct osmtpd_callback *cb, struct osmtpd_ctx *ctx, char *line,
1081 ce062d50 2019-08-21 martijn char *linedup)
1083 ce062d50 2019-08-21 martijn void (*f)(struct osmtpd_ctx *, const char *);
1085 ce062d50 2019-08-21 martijn f = cb->cb;
1086 ce062d50 2019-08-21 martijn f(ctx, line);
1089 ce062d50 2019-08-21 martijn static void
1090 ce062d50 2019-08-21 martijn osmtpd_connect(struct osmtpd_callback *cb, struct osmtpd_ctx *ctx, char *params,
1091 ce062d50 2019-08-21 martijn char *linedup)
1093 ce062d50 2019-08-21 martijn struct sockaddr_storage ss;
1094 ce062d50 2019-08-21 martijn char *hostname;
1095 ce062d50 2019-08-21 martijn char *address;
1096 ce062d50 2019-08-21 martijn void (*f)(struct osmtpd_ctx *, const char *, struct sockaddr_storage *);
1098 ce062d50 2019-08-21 martijn hostname = params;
1099 ce062d50 2019-08-21 martijn if ((address = strchr(params, '|')) == NULL)
1100 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: missing address: %s", linedup);
1101 ce062d50 2019-08-21 martijn address++[0] = '\0';
1103 ce062d50 2019-08-21 martijn osmtpd_addrtoss(address, &ss, 0, linedup);
1105 ce062d50 2019-08-21 martijn f = cb->cb;
1106 ce062d50 2019-08-21 martijn f(ctx, hostname, &ss);
1109 ce062d50 2019-08-21 martijn static void
1110 ce062d50 2019-08-21 martijn osmtpd_link_connect(struct osmtpd_callback *cb, struct osmtpd_ctx *ctx,
1111 ce062d50 2019-08-21 martijn char *params, char *linedup)
1113 ce062d50 2019-08-21 martijn char *end, *rdns, *fcrdns;
1114 ce062d50 2019-08-21 martijn struct sockaddr_storage src, dst;
1115 ce062d50 2019-08-21 martijn void (*f)(struct osmtpd_ctx *, const char *, const char *,
1116 ce062d50 2019-08-21 martijn struct sockaddr_storage *, struct sockaddr_storage *);
1118 ce062d50 2019-08-21 martijn if ((end = strchr(params, '|')) == NULL)
1119 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: missing fcrdns: %s", linedup);
1120 ce062d50 2019-08-21 martijn end++[0] = '\0';
1121 ce062d50 2019-08-21 martijn rdns = params;
1122 ce062d50 2019-08-21 martijn params = end;
1123 ce062d50 2019-08-21 martijn if ((end = strchr(params, '|')) == NULL)
1124 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: missing src: %s", linedup);
1125 ce062d50 2019-08-21 martijn end++[0] = '\0';
1126 ce062d50 2019-08-21 martijn fcrdns = params;
1127 ce062d50 2019-08-21 martijn params = end;
1128 ce062d50 2019-08-21 martijn if ((end = strchr(params, '|')) == NULL)
1129 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: missing dst: %s", linedup);
1130 ce062d50 2019-08-21 martijn end++[0] = '\0';
1131 ce062d50 2019-08-21 martijn osmtpd_addrtoss(params, &src, 1, linedup);
1132 ce062d50 2019-08-21 martijn params = end;
1133 ce062d50 2019-08-21 martijn osmtpd_addrtoss(params, &dst, 1, linedup);
1134 ce062d50 2019-08-21 martijn if (cb->storereport) {
1135 ce062d50 2019-08-21 martijn if ((ctx->rdns = strdup(params)) == NULL)
1136 ce062d50 2019-08-21 martijn err(1, NULL);
1137 ce062d50 2019-08-21 martijn if ((ctx->fcrdns = strdup(params)) == NULL)
1138 ce062d50 2019-08-21 martijn err(1, NULL);
1139 ce062d50 2019-08-21 martijn memcpy(&(ctx->src), &src, sizeof(ctx->src));
1140 ce062d50 2019-08-21 martijn memcpy(&(ctx->dst), &dst, sizeof(ctx->dst));
1142 ce062d50 2019-08-21 martijn if ((f = cb->cb) != NULL)
1143 ce062d50 2019-08-21 martijn f(ctx, rdns, fcrdns, &src, &dst);
1146 ce062d50 2019-08-21 martijn static void
1147 ce062d50 2019-08-21 martijn osmtpd_link_disconnect(struct osmtpd_callback *cb, struct osmtpd_ctx *ctx,
1148 ce062d50 2019-08-21 martijn char *param, char *linedup)
1150 ce062d50 2019-08-21 martijn void (*f)(struct osmtpd_ctx *);
1151 ce062d50 2019-08-21 martijn size_t i;
1152 ce062d50 2019-08-21 martijn struct osmtpd_session *session, search;
1154 ce062d50 2019-08-21 martijn if ((f = cb->cb) != NULL)
1155 ce062d50 2019-08-21 martijn f(ctx);
1157 ce062d50 2019-08-21 martijn search.ctx.reqid = ctx->reqid;
1158 ce062d50 2019-08-21 martijn session = RB_FIND(osmtpd_sessions, &osmtpd_sessions, &search);
1159 ce062d50 2019-08-21 martijn if (session != NULL) {
1160 ce062d50 2019-08-21 martijn RB_REMOVE(osmtpd_sessions, &osmtpd_sessions, session);
1161 ce062d50 2019-08-21 martijn if (ondeletecb != NULL)
1162 ce062d50 2019-08-21 martijn ondeletecb(ctx, session->ctx.local);
1163 ce062d50 2019-08-21 martijn free(session->ctx.rdns);
1164 ce062d50 2019-08-21 martijn free(session->ctx.fcrdns);
1165 ce062d50 2019-08-21 martijn free(session->ctx.identity);
1166 ce062d50 2019-08-21 martijn free(session->ctx.ciphers);
1167 ce062d50 2019-08-21 martijn free(session->ctx.mailfrom);
1168 ce062d50 2019-08-21 martijn for (i = 0; session->ctx.rcptto[i] != NULL; i++)
1169 ce062d50 2019-08-21 martijn free(session->ctx.rcptto[i]);
1170 ce062d50 2019-08-21 martijn free(session->ctx.rcptto);
1171 ce062d50 2019-08-21 martijn free(session);
1175 ce062d50 2019-08-21 martijn static void
1176 ce062d50 2019-08-21 martijn osmtpd_link_identify(struct osmtpd_callback *cb, struct osmtpd_ctx *ctx,
1177 ce062d50 2019-08-21 martijn char *identity, char *linedup)
1179 ce062d50 2019-08-21 martijn void (*f)(struct osmtpd_ctx *, const char *);
1181 ce062d50 2019-08-21 martijn if (cb->storereport) {
1182 ce062d50 2019-08-21 martijn if ((ctx->identity = strdup(identity)) == NULL)
1183 ce062d50 2019-08-21 martijn err(1, NULL);
1186 ce062d50 2019-08-21 martijn if ((f = cb->cb) != NULL)
1187 ce062d50 2019-08-21 martijn f(ctx, identity);
1190 ce062d50 2019-08-21 martijn static void
1191 ce062d50 2019-08-21 martijn osmtpd_link_tls(struct osmtpd_callback *cb, struct osmtpd_ctx *ctx,
1192 ce062d50 2019-08-21 martijn char *ciphers, char *linedup)
1194 ce062d50 2019-08-21 martijn void (*f)(struct osmtpd_ctx *, const char *);
1196 ce062d50 2019-08-21 martijn if (cb->storereport) {
1197 ce062d50 2019-08-21 martijn if ((ctx->ciphers = strdup(ciphers)) == NULL)
1198 ce062d50 2019-08-21 martijn err(1, NULL);
1201 ce062d50 2019-08-21 martijn if ((f = cb->cb) != NULL)
1202 ce062d50 2019-08-21 martijn f(ctx, ciphers);
1205 ce062d50 2019-08-21 martijn static void
1206 ce062d50 2019-08-21 martijn osmtpd_tx_begin(struct osmtpd_callback *cb, struct osmtpd_ctx *ctx,
1207 ce062d50 2019-08-21 martijn char *msgid, char *linedup)
1209 ce062d50 2019-08-21 martijn unsigned long imsgid;
1210 ce062d50 2019-08-21 martijn char *endptr;
1211 ce062d50 2019-08-21 martijn void (*f)(struct osmtpd_ctx *, uint32_t);
1213 ce062d50 2019-08-21 martijn errno = 0;
1214 ce062d50 2019-08-21 martijn imsgid = strtoul(msgid, &endptr, 16);
1215 ce062d50 2019-08-21 martijn if ((imsgid == ULONG_MAX && errno != 0) || endptr[0] != '\0')
1216 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: invalid msgid: %s", linedup);
1217 ce062d50 2019-08-21 martijn ctx->msgid = imsgid;
1218 ce062d50 2019-08-21 martijn /* Check if we're in range */
1219 ce062d50 2019-08-21 martijn if ((unsigned long) ctx->msgid != imsgid)
1220 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: invalid msgid: %s", linedup);
1222 ce062d50 2019-08-21 martijn if (!cb->storereport)
1223 ce062d50 2019-08-21 martijn ctx->msgid = 0;
1225 ce062d50 2019-08-21 martijn if ((f = cb->cb) != NULL)
1226 ce062d50 2019-08-21 martijn f(ctx, imsgid);
1229 ce062d50 2019-08-21 martijn static void
1230 ce062d50 2019-08-21 martijn osmtpd_tx_mail(struct osmtpd_callback *cb, struct osmtpd_ctx *ctx,
1231 ce062d50 2019-08-21 martijn char *params, char *linedup)
1233 ce062d50 2019-08-21 martijn char *end, *mailfrom;
1234 ce062d50 2019-08-21 martijn unsigned long imsgid;
1235 ce062d50 2019-08-21 martijn uint32_t msgid;
1236 ce062d50 2019-08-21 martijn void (*f)(struct osmtpd_ctx *, uint32_t, const char *,
1237 ce062d50 2019-08-21 martijn enum osmtpd_status);
1239 ce062d50 2019-08-21 martijn errno = 0;
1240 ce062d50 2019-08-21 martijn imsgid = strtoul(params, &end, 16);
1241 ce062d50 2019-08-21 martijn if ((imsgid == ULONG_MAX && errno != 0))
1242 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: invalid msgid: %s", linedup);
1243 ce062d50 2019-08-21 martijn if (end[0] != '|')
1244 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: missing address: %s", linedup);
1245 ce062d50 2019-08-21 martijn msgid = imsgid;
1246 ce062d50 2019-08-21 martijn if ((unsigned long) msgid != imsgid)
1247 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: invalid msgid: %s", linedup);
1248 ce062d50 2019-08-21 martijn params = end + 1;
1250 ce062d50 2019-08-21 martijn if ((end = strchr(params, '|')) == NULL)
1251 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: missing status: %s", linedup);
1252 ce062d50 2019-08-21 martijn end++[0] = '\0';
1253 ce062d50 2019-08-21 martijn mailfrom = params;
1254 ce062d50 2019-08-21 martijn if (cb->storereport) {
1255 ce062d50 2019-08-21 martijn if ((ctx->mailfrom = strdup(mailfrom)) == NULL)
1256 ce062d50 2019-08-21 martijn err(1, NULL);
1258 ce062d50 2019-08-21 martijn params = end;
1260 ce062d50 2019-08-21 martijn if ((f = cb->cb) != NULL)
1261 996ed925 2019-08-21 martijn f(ctx, msgid, mailfrom, osmtpd_strtostatus(params, linedup));
1264 ce062d50 2019-08-21 martijn static void
1265 ce062d50 2019-08-21 martijn osmtpd_tx_rcpt(struct osmtpd_callback *cb, struct osmtpd_ctx *ctx,
1266 ce062d50 2019-08-21 martijn char *params, char *linedup)
1268 ce062d50 2019-08-21 martijn char *end, *rcptto;
1269 ce062d50 2019-08-21 martijn unsigned long imsgid;
1270 ce062d50 2019-08-21 martijn uint32_t msgid;
1271 ce062d50 2019-08-21 martijn size_t i;
1272 ce062d50 2019-08-21 martijn void (*f)(struct osmtpd_ctx *, uint32_t, const char *,
1273 ce062d50 2019-08-21 martijn enum osmtpd_status);
1275 ce062d50 2019-08-21 martijn errno = 0;
1276 ce062d50 2019-08-21 martijn imsgid = strtoul(params, &end, 16);
1277 ce062d50 2019-08-21 martijn if ((imsgid == ULONG_MAX && errno != 0))
1278 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: invalid msgid: %s", linedup);
1279 ce062d50 2019-08-21 martijn if (end[0] != '|')
1280 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: missing address: %s", linedup);
1281 ce062d50 2019-08-21 martijn msgid = imsgid;
1282 ce062d50 2019-08-21 martijn if ((unsigned long) msgid != imsgid)
1283 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: invalid msgid: %s", linedup);
1284 ce062d50 2019-08-21 martijn params = end + 1;
1286 ce062d50 2019-08-21 martijn if ((end = strchr(params, '|')) == NULL)
1287 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: missing status: %s", linedup);
1288 ce062d50 2019-08-21 martijn end++[0] = '\0';
1290 ce062d50 2019-08-21 martijn rcptto = params;
1291 ce062d50 2019-08-21 martijn params = end;
1293 ce062d50 2019-08-21 martijn if (cb->storereport) {
1294 ce062d50 2019-08-21 martijn for (i = 0; ctx->rcptto[i] != NULL; i++)
1296 ce062d50 2019-08-21 martijn ctx->rcptto = reallocarray(ctx->rcptto, i + 2,
1297 ce062d50 2019-08-21 martijn sizeof(*(ctx->rcptto)));
1298 ce062d50 2019-08-21 martijn if (ctx->rcptto == NULL)
1299 ce062d50 2019-08-21 martijn err(1, NULL);
1301 ce062d50 2019-08-21 martijn if ((ctx->rcptto[i] = strdup(rcptto)) == NULL)
1302 ce062d50 2019-08-21 martijn err(1, NULL);
1303 ce062d50 2019-08-21 martijn ctx->rcptto[i + 1] = NULL;
1306 ce062d50 2019-08-21 martijn if ((f = cb->cb) != NULL)
1307 ce062d50 2019-08-21 martijn f(ctx, msgid, rcptto,
1308 ce062d50 2019-08-21 martijn osmtpd_strtostatus(params, linedup));
1311 ce062d50 2019-08-21 martijn static void
1312 ce062d50 2019-08-21 martijn osmtpd_tx_envelope(struct osmtpd_callback *cb, struct osmtpd_ctx *ctx,
1313 ce062d50 2019-08-21 martijn char *params, char *linedup)
1315 ce062d50 2019-08-21 martijn unsigned long imsgid;
1316 ce062d50 2019-08-21 martijn uint32_t msgid;
1317 ce062d50 2019-08-21 martijn uint64_t evpid;
1318 ce062d50 2019-08-21 martijn char *end;
1319 ce062d50 2019-08-21 martijn void (*f)(struct osmtpd_ctx *, uint32_t, uint64_t);
1321 ce062d50 2019-08-21 martijn errno = 0;
1322 ce062d50 2019-08-21 martijn imsgid = strtoul(params, &end, 16);
1323 ce062d50 2019-08-21 martijn if ((imsgid == ULONG_MAX && errno != 0))
1324 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: invalid msgid: %s", linedup);
1325 ce062d50 2019-08-21 martijn if (end[0] != '|')
1326 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: missing address: %s", linedup);
1327 ce062d50 2019-08-21 martijn msgid = imsgid;
1328 ce062d50 2019-08-21 martijn if ((unsigned long) msgid != imsgid)
1329 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: invalid msgid: %s", linedup);
1330 ce062d50 2019-08-21 martijn params = end + 1;
1332 ce062d50 2019-08-21 martijn evpid = strtoull(params, &end, 16);
1333 ce062d50 2019-08-21 martijn if ((ctx->evpid == ULLONG_MAX && errno != 0) ||
1334 ce062d50 2019-08-21 martijn end[0] != '\0')
1335 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: invalid evpid: %s", linedup);
1336 ce062d50 2019-08-21 martijn if (cb->storereport)
1337 ce062d50 2019-08-21 martijn ctx->evpid = evpid;
1339 ce062d50 2019-08-21 martijn if ((f = cb->cb) != NULL)
1340 ce062d50 2019-08-21 martijn f(ctx, msgid, evpid);
1343 ce062d50 2019-08-21 martijn static void
1344 ce062d50 2019-08-21 martijn osmtpd_tx_data(struct osmtpd_callback *cb, struct osmtpd_ctx *ctx,
1345 ce062d50 2019-08-21 martijn char *params, char *linedup)
1347 ce062d50 2019-08-21 martijn char *end;
1348 ce062d50 2019-08-21 martijn unsigned long imsgid;
1349 ce062d50 2019-08-21 martijn uint32_t msgid;
1350 ce062d50 2019-08-21 martijn void (*f)(struct osmtpd_ctx *, uint32_t, enum osmtpd_status);
1352 ce062d50 2019-08-21 martijn errno = 0;
1353 ce062d50 2019-08-21 martijn imsgid = strtoul(params, &end, 16);
1354 ce062d50 2019-08-21 martijn if ((imsgid == ULONG_MAX && errno != 0))
1355 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: invalid msgid: %s", linedup);
1356 ce062d50 2019-08-21 martijn if (end[0] != '|')
1357 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: missing address: %s", linedup);
1358 ce062d50 2019-08-21 martijn msgid = imsgid;
1359 ce062d50 2019-08-21 martijn if ((unsigned long) msgid != imsgid)
1360 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: invalid msgid: %s", linedup);
1361 ce062d50 2019-08-21 martijn params = end + 1;
1363 ce062d50 2019-08-21 martijn if ((f = cb->cb) != NULL)
1364 ce062d50 2019-08-21 martijn f(ctx, msgid, osmtpd_strtostatus(params, linedup));
1367 ce062d50 2019-08-21 martijn static void
1368 ce062d50 2019-08-21 martijn osmtpd_tx_commit(struct osmtpd_callback *cb, struct osmtpd_ctx *ctx,
1369 ce062d50 2019-08-21 martijn char *params, char *linedup)
1371 ce062d50 2019-08-21 martijn char *end;
1372 ce062d50 2019-08-21 martijn const char *errstr;
1373 ce062d50 2019-08-21 martijn unsigned long imsgid;
1374 ce062d50 2019-08-21 martijn uint32_t msgid;
1375 ce062d50 2019-08-21 martijn size_t i, msgsz;
1376 ce062d50 2019-08-21 martijn void (*f)(struct osmtpd_ctx *, uint32_t, size_t);
1378 ce062d50 2019-08-21 martijn errno = 0;
1379 ce062d50 2019-08-21 martijn imsgid = strtoul(params, &end, 16);
1380 ce062d50 2019-08-21 martijn if ((imsgid == ULONG_MAX && errno != 0))
1381 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: invalid msgid: %s", linedup);
1382 ce062d50 2019-08-21 martijn if (end[0] != '|')
1383 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: missing address: %s", linedup);
1384 ce062d50 2019-08-21 martijn msgid = imsgid;
1385 ce062d50 2019-08-21 martijn if ((unsigned long) msgid != imsgid)
1386 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: invalid msgid: %s", linedup);
1387 ce062d50 2019-08-21 martijn params = end + 1;
1389 ce062d50 2019-08-21 martijn msgsz = strtonum(params, 0, SIZE_MAX, &errstr);
1390 ce062d50 2019-08-21 martijn if (errstr != NULL)
1391 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: invalid msg size: %s", linedup);
1393 ce062d50 2019-08-21 martijn free(ctx->mailfrom);
1394 ce062d50 2019-08-21 martijn ctx->mailfrom = NULL;
1396 ce062d50 2019-08-21 martijn for (i = 0; ctx->rcptto[i] != NULL; i++)
1397 ce062d50 2019-08-21 martijn free(ctx->rcptto[i]);
1398 ce062d50 2019-08-21 martijn ctx->rcptto[0] = NULL;
1399 ce062d50 2019-08-21 martijn ctx->evpid = 0;
1400 ce062d50 2019-08-21 martijn ctx->msgid = 0;
1402 ce062d50 2019-08-21 martijn if ((f = cb->cb) != NULL)
1403 ce062d50 2019-08-21 martijn f(ctx, msgid, msgsz);
1406 ce062d50 2019-08-21 martijn static void
1407 ce062d50 2019-08-21 martijn osmtpd_tx_rollback(struct osmtpd_callback *cb, struct osmtpd_ctx *ctx,
1408 ce062d50 2019-08-21 martijn char *params, char *linedup)
1410 ce062d50 2019-08-21 martijn char *end;
1411 ce062d50 2019-08-21 martijn unsigned long imsgid;
1412 ce062d50 2019-08-21 martijn uint32_t msgid;
1413 ce062d50 2019-08-21 martijn size_t i;
1414 ce062d50 2019-08-21 martijn void (*f)(struct osmtpd_ctx *, uint32_t);
1416 ce062d50 2019-08-21 martijn errno = 0;
1417 ce062d50 2019-08-21 martijn imsgid = strtoul(params, &end, 16);
1418 ce062d50 2019-08-21 martijn if ((imsgid == ULONG_MAX && errno != 0))
1419 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: invalid msgid: %s", linedup);
1420 ce062d50 2019-08-21 martijn if (end[0] != '\0')
1421 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: missing address: %s", linedup);
1422 ce062d50 2019-08-21 martijn msgid = imsgid;
1423 ce062d50 2019-08-21 martijn if ((unsigned long) msgid != imsgid)
1424 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: invalid msgid: %s", linedup);
1426 ce062d50 2019-08-21 martijn if ((f = cb->cb) != NULL)
1427 ce062d50 2019-08-21 martijn f(ctx, msgid);
1429 ce062d50 2019-08-21 martijn free(ctx->mailfrom);
1430 ce062d50 2019-08-21 martijn ctx->mailfrom = NULL;
1432 ce062d50 2019-08-21 martijn for (i = 0; ctx->rcptto[i] != NULL; i++)
1433 ce062d50 2019-08-21 martijn free(ctx->rcptto[i]);
1434 ce062d50 2019-08-21 martijn ctx->rcptto[0] = NULL;
1435 ce062d50 2019-08-21 martijn ctx->evpid = 0;
1436 ce062d50 2019-08-21 martijn ctx->msgid = 0;
1440 ce062d50 2019-08-21 martijn osmtpd_filter_proceed(struct osmtpd_ctx *ctx)
1442 ce062d50 2019-08-21 martijn io_printf(io_stdout, "filter-result|%016"PRIx64"|%016"PRIx64"|"
1443 ce062d50 2019-08-21 martijn "proceed\n", ctx->token, ctx->reqid);
1447 ce062d50 2019-08-21 martijn osmtpd_filter_reject(struct osmtpd_ctx *ctx, int code, const char *reason, ...)
1449 ce062d50 2019-08-21 martijn va_list ap;
1451 ce062d50 2019-08-21 martijn if (code < 200 || code > 599)
1452 ce062d50 2019-08-21 martijn errx(1, "Invalid reject code");
1454 ce062d50 2019-08-21 martijn io_printf(io_stdout, "filter-result|%016"PRIx64"|%016"PRIx64"|reject|"
1455 ce062d50 2019-08-21 martijn "%d ", ctx->token, ctx->reqid, code);
1456 ce062d50 2019-08-21 martijn va_start(ap, reason);
1457 ce062d50 2019-08-21 martijn io_vprintf(io_stdout, reason, ap);
1458 ce062d50 2019-08-21 martijn va_end(ap);
1459 ce062d50 2019-08-21 martijn io_printf(io_stdout, "\n");
1463 ce062d50 2019-08-21 martijn osmtpd_filter_disconnect(struct osmtpd_ctx *ctx, const char *reason, ...)
1465 ce062d50 2019-08-21 martijn va_list ap;
1467 ce062d50 2019-08-21 martijn io_printf(io_stdout, "filter-result|%016"PRIx64"|%016"PRIx64"|"
1468 ce062d50 2019-08-21 martijn "disconnect|421 ", ctx->token, ctx->reqid);
1469 ce062d50 2019-08-21 martijn va_start(ap, reason);
1470 ce062d50 2019-08-21 martijn io_vprintf(io_stdout, reason, ap);
1471 ce062d50 2019-08-21 martijn va_end(ap);
1472 ce062d50 2019-08-21 martijn io_printf(io_stdout, "\n");
1476 4fb72612 2019-08-21 martijn osmtpd_filter_rewrite(struct osmtpd_ctx *ctx, const char *value, ...)
1478 4fb72612 2019-08-21 martijn va_list ap;
1480 4fb72612 2019-08-21 martijn io_printf(io_stdout, "filter-result|%016"PRIx64"|%016"PRIx64"|"
1481 4fb72612 2019-08-21 martijn "rewrite|", ctx->token, ctx->reqid);
1482 4fb72612 2019-08-21 martijn va_start(ap, value);
1483 4fb72612 2019-08-21 martijn io_vprintf(io_stdout, value, ap);
1484 4fb72612 2019-08-21 martijn va_end(ap);
1485 4fb72612 2019-08-21 martijn io_printf(io_stdout, "\n");
1489 ce062d50 2019-08-21 martijn osmtpd_filter_dataline(struct osmtpd_ctx *ctx, const char *line, ...)
1491 ce062d50 2019-08-21 martijn va_list ap;
1493 ce062d50 2019-08-21 martijn io_printf(io_stdout, "filter-dataline|%016"PRIx64"|%016"PRIx64"|",
1494 ce062d50 2019-08-21 martijn ctx->token, ctx->reqid);
1495 ce062d50 2019-08-21 martijn va_start(ap, line);
1496 ce062d50 2019-08-21 martijn io_vprintf(io_stdout, line, ap);
1497 ce062d50 2019-08-21 martijn va_end(ap);
1498 ce062d50 2019-08-21 martijn io_printf(io_stdout, "\n");
1501 ce062d50 2019-08-21 martijn static void
1502 ce062d50 2019-08-21 martijn osmtpd_register(enum osmtpd_type type, enum osmtpd_phase phase, int incoming,
1503 ce062d50 2019-08-21 martijn int storereport, void *cb)
1505 ce062d50 2019-08-21 martijn size_t i;
1507 ce062d50 2019-08-21 martijn if (ready)
1508 ce062d50 2019-08-21 martijn errx(1, "Can't register when proc is running");
1510 ce062d50 2019-08-21 martijn for (i = 0; i < NITEMS(osmtpd_callbacks); i++) {
1511 ce062d50 2019-08-21 martijn if (type == osmtpd_callbacks[i].type &&
1512 ce062d50 2019-08-21 martijn phase == osmtpd_callbacks[i].phase &&
1513 ce062d50 2019-08-21 martijn incoming == osmtpd_callbacks[i].incoming) {
1514 ce062d50 2019-08-21 martijn if (osmtpd_callbacks[i].cb != NULL && cb != NULL)
1515 ce062d50 2019-08-21 martijn errx(1, "Event already registered");
1516 ce062d50 2019-08-21 martijn osmtpd_callbacks[i].cb = cb;
1517 ce062d50 2019-08-21 martijn osmtpd_callbacks[i].doregister = 1;
1518 ce062d50 2019-08-21 martijn if (storereport)
1519 ce062d50 2019-08-21 martijn osmtpd_callbacks[i].storereport = 1;
1520 ce062d50 2019-08-21 martijn return;
1523 ce062d50 2019-08-21 martijn /* NOT REACHED */
1524 ce062d50 2019-08-21 martijn errx(1, "Trying to register unknown event");
1527 ce062d50 2019-08-21 martijn static enum osmtpd_phase
1528 ce062d50 2019-08-21 martijn osmtpd_strtophase(const char *phase, const char *linedup)
1530 ce062d50 2019-08-21 martijn if (strcmp(phase, "connect") == 0)
1531 ce062d50 2019-08-21 martijn return OSMTPD_PHASE_CONNECT;
1532 ce062d50 2019-08-21 martijn if (strcmp(phase, "helo") == 0)
1533 ce062d50 2019-08-21 martijn return OSMTPD_PHASE_HELO;
1534 ce062d50 2019-08-21 martijn if (strcmp(phase, "ehlo") == 0)
1535 ce062d50 2019-08-21 martijn return OSMTPD_PHASE_EHLO;
1536 ce062d50 2019-08-21 martijn if (strcmp(phase, "starttls") == 0)
1537 ce062d50 2019-08-21 martijn return OSMTPD_PHASE_STARTTLS;
1538 ce062d50 2019-08-21 martijn if (strcmp(phase, "auth") == 0)
1539 ce062d50 2019-08-21 martijn return OSMTPD_PHASE_AUTH;
1540 ce062d50 2019-08-21 martijn if (strcmp(phase, "mail-from") == 0)
1541 ce062d50 2019-08-21 martijn return OSMTPD_PHASE_MAIL_FROM;
1542 ce062d50 2019-08-21 martijn if (strcmp(phase, "rcpt-to") == 0)
1543 ce062d50 2019-08-21 martijn return OSMTPD_PHASE_RCPT_TO;
1544 ce062d50 2019-08-21 martijn if (strcmp(phase, "data") == 0)
1545 ce062d50 2019-08-21 martijn return OSMTPD_PHASE_DATA;
1546 ce062d50 2019-08-21 martijn if (strcmp(phase, "data-line") == 0)
1547 ce062d50 2019-08-21 martijn return OSMTPD_PHASE_DATA_LINE;
1548 ce062d50 2019-08-21 martijn if (strcmp(phase, "rset") == 0)
1549 ce062d50 2019-08-21 martijn return OSMTPD_PHASE_RSET;
1550 ce062d50 2019-08-21 martijn if (strcmp(phase, "quit") == 0)
1551 ce062d50 2019-08-21 martijn return OSMTPD_PHASE_QUIT;
1552 ce062d50 2019-08-21 martijn if (strcmp(phase, "noop") == 0)
1553 ce062d50 2019-08-21 martijn return OSMTPD_PHASE_NOOP;
1554 ce062d50 2019-08-21 martijn if (strcmp(phase, "help") == 0)
1555 ce062d50 2019-08-21 martijn return OSMTPD_PHASE_HELP;
1556 ce062d50 2019-08-21 martijn if (strcmp(phase, "wiz") == 0)
1557 ce062d50 2019-08-21 martijn return OSMTPD_PHASE_WIZ;
1558 ce062d50 2019-08-21 martijn if (strcmp(phase, "commit") == 0)
1559 ce062d50 2019-08-21 martijn return OSMTPD_PHASE_COMMIT;
1560 ce062d50 2019-08-21 martijn if (strcmp(phase, "link-connect") == 0)
1561 ce062d50 2019-08-21 martijn return OSMTPD_PHASE_LINK_CONNECT;
1562 ce062d50 2019-08-21 martijn if (strcmp(phase, "link-disconnect") == 0)
1563 ce062d50 2019-08-21 martijn return OSMTPD_PHASE_LINK_DISCONNECT;
1564 ce062d50 2019-08-21 martijn if (strcmp(phase, "link-identify") == 0)
1565 ce062d50 2019-08-21 martijn return OSMTPD_PHASE_LINK_IDENTIFY;
1566 ce062d50 2019-08-21 martijn if (strcmp(phase, "link-tls") == 0)
1567 ce062d50 2019-08-21 martijn return OSMTPD_PHASE_LINK_TLS;
1568 ce062d50 2019-08-21 martijn if (strcmp(phase, "tx-begin") == 0)
1569 ce062d50 2019-08-21 martijn return OSMTPD_PHASE_TX_BEGIN;
1570 ce062d50 2019-08-21 martijn if (strcmp(phase, "tx-mail") == 0)
1571 ce062d50 2019-08-21 martijn return OSMTPD_PHASE_TX_MAIL;
1572 ce062d50 2019-08-21 martijn if (strcmp(phase, "tx-rcpt") == 0)
1573 ce062d50 2019-08-21 martijn return OSMTPD_PHASE_TX_RCPT;
1574 ce062d50 2019-08-21 martijn if (strcmp(phase, "tx-envelope") == 0)
1575 ce062d50 2019-08-21 martijn return OSMTPD_PHASE_TX_ENVELOPE;
1576 ce062d50 2019-08-21 martijn if (strcmp(phase, "tx-data") == 0)
1577 ce062d50 2019-08-21 martijn return OSMTPD_PHASE_TX_DATA;
1578 ce062d50 2019-08-21 martijn if (strcmp(phase, "tx-commit") == 0)
1579 ce062d50 2019-08-21 martijn return OSMTPD_PHASE_TX_COMMIT;
1580 ce062d50 2019-08-21 martijn if (strcmp(phase, "tx-rollback") == 0)
1581 ce062d50 2019-08-21 martijn return OSMTPD_PHASE_TX_ROLLBACK;
1582 ce062d50 2019-08-21 martijn if (strcmp(phase, "protocol-client") == 0)
1583 ce062d50 2019-08-21 martijn return OSMTPD_PHASE_PROTOCOL_CLIENT;
1584 ce062d50 2019-08-21 martijn if (strcmp(phase, "protocol-server") == 0)
1585 ce062d50 2019-08-21 martijn return OSMTPD_PHASE_PROTOCOL_SERVER;
1586 ce062d50 2019-08-21 martijn if (strcmp(phase, "filter-response") == 0)
1587 ce062d50 2019-08-21 martijn return OSMTPD_PHASE_FILTER_RESPONSE;
1588 ce062d50 2019-08-21 martijn if (strcmp(phase, "timeout") == 0)
1589 ce062d50 2019-08-21 martijn return OSMTPD_PHASE_TIMEOUT;
1590 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: invalid phase: %s", linedup);
1593 ce062d50 2019-08-21 martijn static const char *
1594 ce062d50 2019-08-21 martijn osmtpd_typetostr(enum osmtpd_type type)
1596 ce062d50 2019-08-21 martijn switch (type) {
1597 ce062d50 2019-08-21 martijn case OSMTPD_TYPE_FILTER:
1598 ce062d50 2019-08-21 martijn return "filter";
1599 ce062d50 2019-08-21 martijn case OSMTPD_TYPE_REPORT:
1600 ce062d50 2019-08-21 martijn return "report";
1602 ce062d50 2019-08-21 martijn errx(1, "In valid type: %d\n", type);
1605 ce062d50 2019-08-21 martijn static const char *
1606 ce062d50 2019-08-21 martijn osmtpd_phasetostr(enum osmtpd_phase phase)
1608 ce062d50 2019-08-21 martijn switch (phase) {
1609 ce062d50 2019-08-21 martijn case OSMTPD_PHASE_CONNECT:
1610 ce062d50 2019-08-21 martijn return "connect";
1611 ce062d50 2019-08-21 martijn case OSMTPD_PHASE_HELO:
1612 ce062d50 2019-08-21 martijn return "helo";
1613 ce062d50 2019-08-21 martijn case OSMTPD_PHASE_EHLO:
1614 ce062d50 2019-08-21 martijn return "ehlo";
1615 ce062d50 2019-08-21 martijn case OSMTPD_PHASE_STARTTLS:
1616 ce062d50 2019-08-21 martijn return "starttls";
1617 ce062d50 2019-08-21 martijn case OSMTPD_PHASE_AUTH:
1618 ce062d50 2019-08-21 martijn return "auth";
1619 ce062d50 2019-08-21 martijn case OSMTPD_PHASE_MAIL_FROM:
1620 ce062d50 2019-08-21 martijn return "mail-from";
1621 ce062d50 2019-08-21 martijn case OSMTPD_PHASE_RCPT_TO:
1622 ce062d50 2019-08-21 martijn return "rcpt-to";
1623 ce062d50 2019-08-21 martijn case OSMTPD_PHASE_DATA:
1624 ce062d50 2019-08-21 martijn return "data";
1625 ce062d50 2019-08-21 martijn case OSMTPD_PHASE_DATA_LINE:
1626 ce062d50 2019-08-21 martijn return "data-line";
1627 ce062d50 2019-08-21 martijn case OSMTPD_PHASE_RSET:
1628 ce062d50 2019-08-21 martijn return "rset";
1629 ce062d50 2019-08-21 martijn case OSMTPD_PHASE_QUIT:
1630 ce062d50 2019-08-21 martijn return "quit";
1631 ce062d50 2019-08-21 martijn case OSMTPD_PHASE_NOOP:
1632 ce062d50 2019-08-21 martijn return "noop";
1633 ce062d50 2019-08-21 martijn case OSMTPD_PHASE_HELP:
1634 ce062d50 2019-08-21 martijn return "help";
1635 ce062d50 2019-08-21 martijn case OSMTPD_PHASE_WIZ:
1636 ce062d50 2019-08-21 martijn return "wiz";
1637 ce062d50 2019-08-21 martijn case OSMTPD_PHASE_COMMIT:
1638 ce062d50 2019-08-21 martijn return "commit";
1639 ce062d50 2019-08-21 martijn case OSMTPD_PHASE_LINK_CONNECT:
1640 ce062d50 2019-08-21 martijn return "link-connect";
1641 ce062d50 2019-08-21 martijn case OSMTPD_PHASE_LINK_DISCONNECT:
1642 ce062d50 2019-08-21 martijn return "link-disconnect";
1643 ce062d50 2019-08-21 martijn case OSMTPD_PHASE_LINK_IDENTIFY:
1644 ce062d50 2019-08-21 martijn return "link-identify";
1645 ce062d50 2019-08-21 martijn case OSMTPD_PHASE_LINK_TLS:
1646 ce062d50 2019-08-21 martijn return "link-tls";
1647 ce062d50 2019-08-21 martijn case OSMTPD_PHASE_TX_BEGIN:
1648 ce062d50 2019-08-21 martijn return "tx-begin";
1649 ce062d50 2019-08-21 martijn case OSMTPD_PHASE_TX_MAIL:
1650 ce062d50 2019-08-21 martijn return "tx-mail";
1651 ce062d50 2019-08-21 martijn case OSMTPD_PHASE_TX_RCPT:
1652 ce062d50 2019-08-21 martijn return "tx-rcpt";
1653 ce062d50 2019-08-21 martijn case OSMTPD_PHASE_TX_ENVELOPE:
1654 ce062d50 2019-08-21 martijn return "tx-envelope";
1655 ce062d50 2019-08-21 martijn case OSMTPD_PHASE_TX_DATA:
1656 ce062d50 2019-08-21 martijn return "tx-data";
1657 ce062d50 2019-08-21 martijn case OSMTPD_PHASE_TX_COMMIT:
1658 ce062d50 2019-08-21 martijn return "tx-commit";
1659 ce062d50 2019-08-21 martijn case OSMTPD_PHASE_TX_ROLLBACK:
1660 ce062d50 2019-08-21 martijn return "tx-rollback";
1661 ce062d50 2019-08-21 martijn case OSMTPD_PHASE_PROTOCOL_CLIENT:
1662 ce062d50 2019-08-21 martijn return "protocol-client";
1663 ce062d50 2019-08-21 martijn case OSMTPD_PHASE_PROTOCOL_SERVER:
1664 ce062d50 2019-08-21 martijn return "protocol-server";
1665 ce062d50 2019-08-21 martijn case OSMTPD_PHASE_FILTER_RESPONSE:
1666 ce062d50 2019-08-21 martijn return "filter-response";
1667 ce062d50 2019-08-21 martijn case OSMTPD_PHASE_TIMEOUT:
1668 ce062d50 2019-08-21 martijn return "timeout";
1670 ce062d50 2019-08-21 martijn errx(1, "In valid phase: %d\n", phase);
1673 ce062d50 2019-08-21 martijn static enum
1674 ce062d50 2019-08-21 martijn osmtpd_status osmtpd_strtostatus(const char *status, char *linedup)
1676 ce062d50 2019-08-21 martijn if (strcmp(status, "ok") == 0)
1677 ce062d50 2019-08-21 martijn return OSMTPD_STATUS_OK;
1678 ce062d50 2019-08-21 martijn else if (strcmp(status, "tempfail") == 0)
1679 ce062d50 2019-08-21 martijn return OSMTPD_STATUS_TEMPFAIL;
1680 ce062d50 2019-08-21 martijn else if (strcmp(status, "permfail") == 0)
1681 ce062d50 2019-08-21 martijn return OSMTPD_STATUS_PERMFAIL;
1682 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: invalid status: %s\n", linedup);
1685 ce062d50 2019-08-21 martijn static void
1686 ce062d50 2019-08-21 martijn osmtpd_addrtoss(char *addr, struct sockaddr_storage *ss, int hasport,
1687 ce062d50 2019-08-21 martijn char *linedup)
1689 ce062d50 2019-08-21 martijn char *port;
1690 ce062d50 2019-08-21 martijn const char *errstr = NULL;
1691 ce062d50 2019-08-21 martijn struct sockaddr_in *sin;
1692 ce062d50 2019-08-21 martijn struct sockaddr_in6 *sin6;
1693 ce062d50 2019-08-21 martijn struct sockaddr_un *sun;
1695 ce062d50 2019-08-21 martijn if (strncasecmp(addr, "ipv6:", 5) == 0) {
1696 ce062d50 2019-08-21 martijn sin6 = (struct sockaddr_in6 *)ss;
1697 ce062d50 2019-08-21 martijn sin6->sin6_len = sizeof(*sin6);
1698 ce062d50 2019-08-21 martijn sin6->sin6_family = AF_INET6;
1699 ce062d50 2019-08-21 martijn sin6->sin6_port = 0;
1700 ce062d50 2019-08-21 martijn if (hasport) {
1701 ce062d50 2019-08-21 martijn if ((port = strrchr(addr, ':')) == NULL)
1702 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: invalid "
1703 ce062d50 2019-08-21 martijn "address (%s): %s", addr, linedup);
1704 ce062d50 2019-08-21 martijn port++;
1705 ce062d50 2019-08-21 martijn sin6->sin6_port = htons(strtonum(port, 0, UINT16_MAX,
1706 ce062d50 2019-08-21 martijn &errstr));
1707 ce062d50 2019-08-21 martijn if (errstr != NULL)
1708 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: invalid "
1709 ce062d50 2019-08-21 martijn "address (%s): %s", addr, linedup);
1710 ce062d50 2019-08-21 martijn port[-1] = '\0';
1712 ce062d50 2019-08-21 martijn switch (inet_pton(AF_INET6, addr + 5, &(sin6->sin6_addr))) {
1713 ce062d50 2019-08-21 martijn case 1:
1715 ce062d50 2019-08-21 martijn case 0:
1716 ce062d50 2019-08-21 martijn port[-1] = ':';
1717 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: invalid address "
1718 ce062d50 2019-08-21 martijn "(%s): %s", addr, linedup);
1719 ce062d50 2019-08-21 martijn default:
1720 ce062d50 2019-08-21 martijn port[-1] = ':';
1721 ce062d50 2019-08-21 martijn err(1, "Can't parse address (%s): %s", addr, linedup);
1723 ce062d50 2019-08-21 martijn } else if (strncasecmp(addr, "unix:", 5) == 0) {
1724 ce062d50 2019-08-21 martijn sun = (struct sockaddr_un *)ss;
1725 ce062d50 2019-08-21 martijn sun->sun_len = sizeof(*sun);
1726 ce062d50 2019-08-21 martijn sun->sun_family = AF_UNIX;
1727 ce062d50 2019-08-21 martijn if (strlcpy(sun->sun_path, addr,
1728 ce062d50 2019-08-21 martijn sizeof(sun->sun_path)) >= sizeof(sun->sun_path)) {
1729 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: address too long (%s): "
1730 ce062d50 2019-08-21 martijn "%s", addr, linedup);
1732 ce062d50 2019-08-21 martijn } else {
1733 ce062d50 2019-08-21 martijn sin = (struct sockaddr_in *)ss;
1734 ce062d50 2019-08-21 martijn sin->sin_len = sizeof(*sin);
1735 ce062d50 2019-08-21 martijn sin->sin_family = AF_INET;
1736 ce062d50 2019-08-21 martijn sin->sin_port = 0;
1737 ce062d50 2019-08-21 martijn if (hasport) {
1738 ce062d50 2019-08-21 martijn if ((port = strrchr(addr, ':')) == NULL)
1739 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: invalid "
1740 ce062d50 2019-08-21 martijn "address (%s): %s", addr, linedup);
1741 ce062d50 2019-08-21 martijn port++;
1742 ce062d50 2019-08-21 martijn sin->sin_port = htons(strtonum(port, 0, UINT16_MAX,
1743 ce062d50 2019-08-21 martijn &errstr));
1744 ce062d50 2019-08-21 martijn if (errstr != NULL)
1745 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: invalid "
1746 ce062d50 2019-08-21 martijn "address (%s): %s", addr, linedup);
1747 ce062d50 2019-08-21 martijn port[-1] = '\0';
1749 ce062d50 2019-08-21 martijn switch (inet_pton(AF_INET, addr, &(sin->sin_addr))) {
1750 ce062d50 2019-08-21 martijn case 1:
1752 ce062d50 2019-08-21 martijn case 0:
1753 ce062d50 2019-08-21 martijn port[-1] = ':';
1754 ce062d50 2019-08-21 martijn errx(1, "Invalid line received: invalid address "
1755 ce062d50 2019-08-21 martijn "(%s): %s", addr, linedup);
1756 ce062d50 2019-08-21 martijn default:
1757 ce062d50 2019-08-21 martijn port[-1] = ':';
1758 ce062d50 2019-08-21 martijn err(1, "Can't parse address (%s): %s", addr, linedup);
1763 ce062d50 2019-08-21 martijn static int
1764 ce062d50 2019-08-21 martijn osmtpd_session_cmp(struct osmtpd_session *a, struct osmtpd_session *b)
1766 ce062d50 2019-08-21 martijn return a->ctx.reqid < b->ctx.reqid ? -1 : a->ctx.reqid > b->ctx.reqid;
1769 9e3e8410 2019-08-22 martijn RB_GENERATE_STATIC(osmtpd_sessions, osmtpd_session, entry, osmtpd_session_cmp);
