/* * lmtp2nntp.c * * The lmtp2nntp program reads mail as a LMTP server and posts it to one or * more newsgroups using NNTP. It delivers the message immediately or fails. * * The OSSP Project, Cable & Wireless Deutschland GmbH * Thomas Lotterer, * */ #include #include #include #include #include #include #include /* third party */ #include "str.h" #include "argz.h" #include "shpat_match.h" /* own headers */ #ifdef HAVE_CONFIG_H #include "config.h" #endif #if defined(HAVE_DMALLOC_H) && defined(DMALLOC) #include "dmalloc.h" #endif #include "lmtp.h" #include "nntp.h" #include "sa.h" #include "msg.h" #include "trace.h" #define _VERSION_C_AS_HEADER_ #include "version.c" #undef _VERSION_C_AS_HEADER_ #ifndef FALSE #define FALSE (1 != 1) #endif #ifndef TRUE #define TRUE (!FALSE) #endif #ifndef NUL #define NUL '\0' #endif #define ERR_EXECUTION -1 #define ERR_DELIVERY -2 #define STDSTRLEN 128 #define MAXNEWSSERVICES 3 extern void lmtp_debug_dumplmtp(lmtp_t *lmtp); static lmtp_rc_t lmtp_cb_lhlo (lmtp_t *lmtp, lmtp_io_t *io, lmtp_req_t *req, void *ctx); static lmtp_rc_t lmtp_cb_mail (lmtp_t *lmtp, lmtp_io_t *io, lmtp_req_t *req, void *ctx); static lmtp_rc_t lmtp_cb_rcpt (lmtp_t *lmtp, lmtp_io_t *io, lmtp_req_t *req, void *ctx); static lmtp_rc_t lmtp_cb_data (lmtp_t *lmtp, lmtp_io_t *io, lmtp_req_t *req, void *ctx); static lmtp_rc_t lmtp_cb_noop (lmtp_t *lmtp, lmtp_io_t *io, lmtp_req_t *req, void *ctx); static lmtp_rc_t lmtp_cb_rset (lmtp_t *lmtp, lmtp_io_t *io, lmtp_req_t *req, void *ctx); static lmtp_rc_t lmtp_cb_quit (lmtp_t *lmtp, lmtp_io_t *io, lmtp_req_t *req, void *ctx); static int helo_rfc0821domain(char *msg, char **domain); static int helo_rfc1035domain(char *msg, char **domain); struct session { int lhlo_seen; char *lhlo_domain; }; static void initsession(struct session *session); static void resetsession(struct session *session); int groupmatch(char *, size_t, char *); struct ns { char *h; /* host */ char *p; /* port */ sa_t *sa; int s; /* socket */ nntp_t *nntp; nntp_rc_t rc; }; typedef struct { int option_verbose; int option_tracing; int option_groupmode; int option_deliverymode; char *option_deliverymodefakestatus; char *option_deliverymodefakedsn; int option_maxmessagesize; int nsc; struct ns ns[MAXNEWSSERVICES]; char *azGroupargs; size_t asGroupargs; struct session session; msg_t *msg; struct utsname uname; } lmtp2nntp_t; static void lmtp_gfs_lhlo(lmtp2nntp_t *ctx); static void lmtp_gfs_rset(lmtp2nntp_t *ctx); static void lmtp_gfs_quit(lmtp2nntp_t *ctx); enum { GROUPMODE_ARG, GROUPMODE_ENVELOPE, GROUPMODE_HEADER }; enum { DELIVERYMODE_FAKE, DELIVERYMODE_POST, DELIVERYMODE_FEED }; /* * print usage information */ static void usage(char *command) { /* use * perl ) { if(m/\/\*POD (.*) .*\*\//) { $_=$1; s/.<(.*?)>/$1/g ; print "$_ " };}' * to pull the USAGE string out of this source */ fprintf(stderr, "USAGE: %s " "[-d deliverymode] [-g groupmode] [-h host[:port]] " "[-m maxmessagesize] [-t tracefile] [-v] [-V] newsgroup [newsgroup ...]" "\n", command); return; } int main(int argc, char **argv) { int rc = 0; lmtp_t *lmtp; lmtp_io_t lmtp_io; lmtp2nntp_t *ctx; int i; /* general purpose scratch int, index ... */ char *cp; /* general purpose character pointer */ char *progname; char *azHosts; size_t asHosts; char *cpHost; char *cpPort; sa_t *sa; progname = argv[0]; /* create application context */ if ((ctx = (lmtp2nntp_t *)malloc(sizeof(lmtp2nntp_t))) == NULL) exit(ERR_EXECUTION); ctx->option_verbose = FALSE; ctx->option_tracing = FALSE; ctx->option_groupmode = GROUPMODE_ARG; ctx->option_deliverymode = DELIVERYMODE_FAKE; ctx->option_deliverymodefakestatus = "553"; /* Requested action not taken: mailbox name not allowed */ ctx->option_deliverymodefakedsn = "5.7.1"; /* Delivery not authorized, message refused */ ctx->option_maxmessagesize = 8 * 1024 * 1024; ctx->nsc = 0; for (i=0; i < MAXNEWSSERVICES; i++) { ctx->ns[i].h = NULL; ctx->ns[i].p = NULL; ctx->ns[i].sa = NULL; ctx->ns[i].s = -1; ctx->ns[i].nntp = NULL; ctx->ns[i].rc = LMTP_ERR_UNKNOWN; } ctx->azGroupargs = NULL; ctx->asGroupargs = 0; initsession(&ctx->session); ctx->msg = NULL; if (uname(&ctx->uname) == -1) { fprintf(stderr, "%s:Error: uname failed \"%s\"\n", progname, strerror(errno)); exit(ERR_EXECUTION); } #if 1 { char buf[1000]; int bufused = 0; int tracefile; for (i=0; i */ /* use * perl ) { if(m/\/\*POD (.*) .*\*\//) { $_=$1; print "$_\n" };}' * to pull the POD SYNOPSIS header directly out of this source */ /* read in the arguments */ while ((i = getopt(argc, argv, "d:g:h:m:t:vV")) != -1) { switch (i) { case 'd': /*POD [B<-d> I] */ if (strcasecmp(optarg, "post") == 0) ctx->option_deliverymode = DELIVERYMODE_POST; else if (strcasecmp(optarg, "feed") == 0) ctx->option_deliverymode = DELIVERYMODE_FEED; else { if (strlen(optarg) != 9) { fprintf(stderr, "%s:Error: Invalid format or length \"%s\" to option -d\n", progname, optarg); exit(ERR_EXECUTION); } if (optarg[3] != '/') { fprintf(stderr, "%s:Error: Invalid format or missing slash \"%s\" to option -d\n", progname, optarg); exit(ERR_EXECUTION); } optarg[3] = NUL; ctx->option_deliverymodefakestatus = &optarg[0]; ctx->option_deliverymodefakedsn = &optarg[4]; if ( strlen(ctx->option_deliverymodefakestatus) != 3 || !isdigit((int)ctx->option_deliverymodefakestatus[0]) || !isdigit((int)ctx->option_deliverymodefakestatus[1]) || !isdigit((int)ctx->option_deliverymodefakestatus[2])) { fprintf(stderr, "%s:Error: Invalid status in format \"%s\" to option -d\n", progname, optarg); exit(ERR_EXECUTION); } if ( (strlen(ctx->option_deliverymodefakedsn) != 5) || !isdigit((int)ctx->option_deliverymodefakedsn[0]) || (ctx->option_deliverymodefakedsn[1] != '.') || !isdigit((int)ctx->option_deliverymodefakedsn[2]) || (ctx->option_deliverymodefakedsn[3] != '.') || !isdigit((int)ctx->option_deliverymodefakedsn[4]) || (ctx->option_deliverymodefakedsn[0] != ctx->option_deliverymodefakestatus[0])) { fprintf(stderr, "%s:Error: Invalid dsn in format \"%s\" to option -d\n", progname, optarg); exit(ERR_EXECUTION); } } break; case 'g': /*POD [B<-g> I] */ if (strcasecmp(optarg, "arg") == 0) ctx->option_groupmode = GROUPMODE_ARG; else if (strcasecmp(optarg, "envelope") == 0) ctx->option_groupmode = GROUPMODE_ENVELOPE; else if (strcasecmp(optarg, "header") == 0) ctx->option_groupmode = GROUPMODE_HEADER; else { fprintf(stderr, "%s:Error: Invalid mode \"%s\" to option -g\n", progname, optarg); exit(ERR_EXECUTION); } break; case 'h': /*POD [B<-h> I[I<:port>]] */ if (argz_create_sep(optarg, ',', &azHosts, &asHosts) != 0) exit(ERR_EXECUTION); cp = NULL; while ((cp = argz_next(azHosts, asHosts, cp)) != NULL) { if (ctx->nsc >= MAXNEWSSERVICES) { fprintf(stderr, "%s:Error: Too many services (%d) using option -h\n", progname, ctx->nsc); exit(ERR_EXECUTION); } /* parse host[:port] string into host and port */ cpHost = strdup(cp); if ((cpPort = strrchr(cpHost, ':')) != NULL) { *cpPort++ = NUL; cpPort = strdup(cpPort); } else cpPort = strdup("nntp"); ctx->ns[ctx->nsc].h = cpHost; ctx->ns[ctx->nsc].p = cpPort; if ((sa = sa_create(SA_IP, "tcp", ctx->ns[ctx->nsc].h, ctx->ns[ctx->nsc].p)) == NULL) { fprintf(stderr, "%s:Error: creating TCP socket address failed for \"%s:%s\": %s\n", progname, ctx->ns[ctx->nsc].h, ctx->ns[ctx->nsc].p, strerror(errno)); exit(ERR_EXECUTION); } ctx->ns[ctx->nsc].sa = sa; if ((ctx->ns[ctx->nsc].s = socket(sa->sa_buf->sa_family, SOCK_STREAM, sa->sa_proto)) == -1) { fprintf(stderr, "%s:Error: Creating TCP socket failed for \"%s:%s\": %s\n", progname, ctx->ns[ctx->nsc].h, ctx->ns[ctx->nsc].p, strerror(errno)); exit(ERR_EXECUTION); } ctx->ns[ctx->nsc].nntp = NULL; ctx->nsc++; } free(azHosts); break; case 'm': /*POD [B<-m> I] */ ctx->option_maxmessagesize = atoi(optarg); if(ctx->option_maxmessagesize < 64) { fprintf(stderr, "%s:Error: maximum message size is unacceptable small.\n", progname); exit(ERR_EXECUTION); } break; case 't': /*POD [B<-t> I] */ ctx->option_tracing = TRUE; trace_read (-1, optarg, 0); trace_write(-1, optarg, 0); break; case 'v': /*POD [B<-v>] (verbose)*/ ctx->option_verbose = TRUE; break; case 'V': /*POD [B<-V>] (version)*/ fprintf(stdout, "%s\n", lmtp2nntp_version.v_gnu); exit(0); break; case '?': default: usage(progname); exit(ERR_EXECUTION); } } /*POD I [I ...] */ for (i = optind; i < argc; i++) { argz_add(&ctx->azGroupargs, &ctx->asGroupargs, argv[i]); } /* initialize LMTP context */ lmtp_io.select = NULL; lmtp_io.read = trace_read; lmtp_io.write = trace_write; if ((lmtp = lmtp_create(STDIN_FILENO, STDOUT_FILENO, ctx->option_tracing ? &lmtp_io : NULL)) == NULL) { fprintf(stderr, "%s:Error: Unable to initialize LMTP library\n", progname); exit(ERR_EXECUTION); } /* RFC0821, 4.5.1. MINIMUM IMPLEMENTATION * In order to make SMTP workable, the following minimum implementation * is required for all receivers: [...] * RFC0821, 4.1.2. COMMAND SYNTAX * * Verb Parameter * ----+------------------------------- * HELO * MAIL FROM: * RCPT TO: * DATA * RSET * NOOP * QUIT */ lmtp_register(lmtp, "LHLO", lmtp_cb_lhlo, ctx, NULL, NULL); lmtp_register(lmtp, "MAIL", lmtp_cb_mail, ctx, NULL, NULL); lmtp_register(lmtp, "RCPT", lmtp_cb_rcpt, ctx, NULL, NULL); lmtp_register(lmtp, "DATA", lmtp_cb_data, ctx, NULL, NULL); lmtp_register(lmtp, "RSET", lmtp_cb_rset, ctx, NULL, NULL); lmtp_register(lmtp, "NOOP", lmtp_cb_noop, ctx, NULL, NULL); lmtp_register(lmtp, "QUIT", lmtp_cb_quit, ctx, NULL, NULL); /* loop for LMTP protocol */ lmtp_loop(lmtp); /* graceful shutdown */ lmtp_gfs_quit(ctx); lmtp_gfs_lhlo(ctx); lmtp_destroy(lmtp); if (ctx->azGroupargs != NULL) free(ctx->azGroupargs); if (ctx != NULL) free(ctx); str_parse(NULL, NULL); return rc; } static void resetsession(struct session *session) { if (session->lhlo_domain != NULL) free(session->lhlo_domain); initsession(session); return; } static void initsession(struct session *session) { session->lhlo_seen = FALSE; session->lhlo_domain = NULL; return; } static lmtp_rc_t lmtp_cb_lhlo(lmtp_t *lmtp, lmtp_io_t *io, lmtp_req_t *req, void *_ctx) { /* * RFC0821 [excerpt] 4.1. SMTP COMMANDS * 4.1.1. COMMAND SEMANTICS, HELO * This command and an OK reply to it confirm that both the sender-SMTP * and the receiver-SMTP are in the initial state, that is, there is no * transaction in progress and all state tables and buffers are cleared. * * The first command in a session must be the HELO command. The HELO * command may be used later in a session as well. If the HELO command * argument is not acceptable a 501 failure reply must be returned and * the receiver-SMTP must stay in the same state. * * If the transaction beginning command argument is not acceptable a 501 * failure reply must be returned and the receiver-SMTP must stay in the * same state. If the commands in a transaction are out of order a 503 * failure reply must be returned and the receiver-SMTP must stay in the * same state. * * HELO */ lmtp2nntp_t *ctx = (lmtp2nntp_t *)_ctx; lmtp_res_t res; nntp_rc_t rc; char str[STDSTRLEN]; int bOk; int i; nntp_io_t nntp_io; nntp_io.select = NULL; nntp_io.read = trace_read; nntp_io.write = trace_write; /* RFC0821 4.2.1. REPLY CODES BY FUNCTION GROUPS 503 Bad sequence of commands * RFC1893 2. Status Codes 5.X.X Permanent Failure * RFC1893 3.5 Network and Routing Status X.0.0 Other undefined Status */ if (ctx->session.lhlo_seen) { res.statuscode = "503"; res.dsncode = "5.0.0"; res.statusmsg = "Duplicate LHLO."; lmtp_response(lmtp, &res); return LMTP_OK; } /* RFC0821 4.2.1. REPLY CODES BY FUNCTION GROUPS 501 Syntax error in parameters or arguments * RFC1893 2. Status Codes 5.X.X Permanent Failure * RFC1893 3.5 Network and Routing Status X.0.0 Other undefined Status */ if (! ( helo_rfc0821domain(req->msg, &ctx->session.lhlo_domain) > 0 || helo_rfc1035domain(req->msg, &ctx->session.lhlo_domain) > 0)) { res.statuscode = "501"; res.dsncode = "5.0.0"; res.statusmsg = "Please identify yourself. Domain must match RFC0821/RFC1035."; lmtp_response(lmtp, &res); return LMTP_OK; } /* RFC0821 4.2.1. REPLY CODES BY FUNCTION GROUPS 451 Requested action aborted: local error in processing * RFC1893 2. Status Codes 4.X.X Persistent Transient Failure * RFC1893 3.5 Network and Routing Status X.3.5 System incorrectly configured */ if (ctx->nsc == 0) { res.statuscode = "451"; res.dsncode = "4.3.5"; res.statusmsg = "No valid NNTP services configured."; lmtp_response(lmtp, &res); return LMTP_OK; } i = 0; do { bOk = TRUE; if (connect(ctx->ns[i].s, ctx->ns[i].sa->sa_buf, ctx->ns[i].sa->sa_len) < 0) { bOk = FALSE; } if (bOk && ((ctx->ns[i].nntp = nntp_create(ctx->ns[i].s, ctx->ns[i].s, ctx->option_tracing ? &nntp_io : NULL)) == NULL)) { bOk = FALSE; } if (bOk && ((rc = nntp_init(ctx->ns[i].nntp)) != NNTP_OK)) { bOk = FALSE; } if (bOk) i++; else { if (i < --ctx->nsc) { memcpy(&ctx->ns[i], &ctx->ns[i+1], (ctx->nsc - i ) * sizeof(struct ns)); } } } while (i < ctx->nsc); /* RFC0821 4.2.1. REPLY CODES BY FUNCTION GROUPS 421 Service not available * RFC1893 2. Status Codes 4.X.X Persistent Transient Failure * RFC1893 3.5 Network and Routing Status X.4.1 No answer from host */ if (ctx->nsc == 0) { res.statuscode = "421"; res.dsncode = "4.4.1"; res.statusmsg = "All attempts connecting to NNTP services failed."; lmtp_response(lmtp, &res); return LMTP_OK; } ctx->session.lhlo_seen = TRUE; /* RFC0821 4.2.1. REPLY CODES BY FUNCTION GROUPS 250 Requested mail action okay, completed */ str_format(str, sizeof(str), "%s Hello %s, pleased to meet you.\n" /* RFC2821 4.1.1.1 */ "ENHANCEDSTATUSCODES\n" /* RFC2034 */ "DSN\n" /* RFC1894 */ "PIPELINING\n" /* RFC1854 */ "8BITMIME", /* RFC1652 */ ctx->uname.nodename, ctx->session.lhlo_domain); res.statuscode = "250"; res.dsncode = NULL; /* DSN not used for greeting */ res.statusmsg = str; lmtp_response(lmtp, &res); return LMTP_OK; } static void lmtp_gfs_lhlo(lmtp2nntp_t *ctx) { /* graceful shutdown */ int i; for (i = 0; i < ctx->nsc; i++) { if (ctx->ns[i].nntp != NULL) nntp_destroy(ctx->ns[i].nntp); if (ctx->ns[i].s != -1) close(ctx->ns[i].s); if (ctx->ns[i].sa != NULL) sa_destroy(ctx->ns[i].sa); if (ctx->ns[i].p != NULL) free(ctx->ns[i].p); if (ctx->ns[i].h != NULL) free(ctx->ns[i].h); } } static int helo_rfc0821domain(char *msg, char **domain) { int rc; rc = str_parse(msg, "^.+ (" /* ## ## The mega Perl regular expression below is generated ## with the following Perl program. This is only possible ## because the given grammar is Chomsky-3 (right or left ## linear grammar, but noth both). ## # BNF grammar for according to RFC0821: # ::= one, two, or three digits representing a decimal integer value in the range 0 through 255 # ::= any one of the 52 alphabetic characters A through Z in upper case and a through z in lower case # ::= any one of the ten digits 0 through 9 # ::= | | "-" # ::= | # ::= | # ::= "." "." "." # ::= | # ::= # ::= | "#" | "[" "]" # ::= | "." # # corresponding Perl regular expression ($domain) $snum = "(?:[0-9]|[0-9]{2}|[0-1][0-9]{2}|2[0-4][0-9]|25[0-5])"; $d = "[0-9]"; $a = "[A-Za-z]"; $let_dig_hyp = "(?:$a|$d|-)"; $let_dig = "(?:$a|$d)"; $ldh_str = "${let_dig_hyp}+"; $dotnum = "$snum\\.$snum\\.$snum\\.$snum"; $number = "$d+"; $name = "$a$ldh_str$let_dig"; $element = "(?:$name|#$number|\\[$dotnum\\])"; $domain = "(?:$element\.)*$element"; # # translate into C string block suitable for passing to the Perl # Compatible Regular Expressions (PCRE) based string library Str. my $cregex = $domain; $cregex .= "\n"; $cregex =~ s|\\|\\\\|sg; $cregex =~ s|(.{17})|$1\n|sg; $cregex =~ s|([^\n]+)\n|"$1"\n|sg; $cregex =~ s|\n\n|\n|sg; print "$cregex"; */ "(?:(?:[A-Za-z](?:[A-Za-z]|[0-9]|-)+(?:[A-Za-z]|[0-9])|#[0-9]+|\\[(?:[0" "-9]|[0-9]{2}|[0-1][0-9]{2}|2[0-4][0-9]|25[0-5])\\.(?:[0-9]|[0-9]{2}|[0" "-1][0-9]{2}|2[0-4][0-9]|25[0-5])\\.(?:[0-9]|[0-9]{2}|[0-1][0-9]{2}|2[0" "-4][0-9]|25[0-5])\\.(?:[0-9]|[0-9]{2}|[0-1][0-9]{2}|2[0-4][0-9]|25[0-5" "])\\]).)*(?:[A-Za-z](?:[A-Za-z]|[0-9]|-)+(?:[A-Za-z]|[0-9])|#[0-9]+|\\" "[(?:[0-9]|[0-9]{2}|[0-1][0-9]{2}|2[0-4][0-9]|25[0-5])\\.(?:[0-9]|[0-9]" "{2}|[0-1][0-9]{2}|2[0-4][0-9]|25[0-5])\\.(?:[0-9]|[0-9]{2}|[0-1][0-9]{" "2}|2[0-4][0-9]|25[0-5])\\.(?:[0-9]|[0-9]{2}|[0-1][0-9]{2}|2[0-4][0-9]|" "25[0-5])\\])" ")$", domain); return rc; } static int helo_rfc1035domain(char *msg, char **domain) { int rc; rc = str_parse(msg, "^.+ (" /* ## ## The mega Perl regular expression below is generated ## with the following Perl program. This is only possible ## because the given grammar is Chomsky-3 (right or left ## linear grammar, but noth both). ## # BNF grammar for according to RFC1035: # ::= any one of the 52 alphabetic characters A through Z in upper case and a through z in lower case # ::= any one of the ten digits 0 through 9 # ::= | # ::= | "-" # ::= | #