90 lines
2.7 KiB
JavaScript
90 lines
2.7 KiB
JavaScript
#!/usr/bin/env node
|
|
var squabble = require("squabble").createParser(),
|
|
smtp = require("smtp-protocol"),
|
|
http = require("request"),
|
|
readFile = require("fs").readFileSync,
|
|
MailParser = require("mailparser").MailParser,
|
|
args, tlsTokens, serverOpts = {};
|
|
|
|
// enable color support
|
|
require("colors");
|
|
|
|
// setup CLI argument parsing
|
|
squabble.shortOpts().longOpts().stopper()
|
|
.option("-T", "--tls")
|
|
.flag("-s", "-q", "--silent", "--quiet")
|
|
.flag("-v", "--verbose")
|
|
.required("ENDPOINT");
|
|
|
|
// parse arguments
|
|
args = squabble.parse();
|
|
serverOpts.endpoint = args.named.ENDPOINT;
|
|
|
|
// configure console output
|
|
if (args.named["--quiet"]) {
|
|
console.log = function() {};
|
|
console.error = function() {};
|
|
} else if (!args.named["--verbose"]) {
|
|
console.log = function() {};
|
|
}
|
|
|
|
if (args.named["--tls"]) {
|
|
tlsTokens = args.named["--tls"].split(":");
|
|
switch (tlsTokens.length) {
|
|
case 1:
|
|
serverOpts.pfx = readFile(tlsTokens.shift());
|
|
break;
|
|
case 2:
|
|
serverOpts.cert = readFile(tlsTokens.shift());
|
|
serverOpts.key = readFile(tlsTokens.shift());
|
|
break;
|
|
case 3:
|
|
serverOpts.cert = readFile(tlsTokens.shift());
|
|
serverOpts.key = readFile(tlsTokens.shift());
|
|
serverOpts.ca = readFile(tlsTokens.shift());
|
|
break;
|
|
default:
|
|
throw new Error("unrecognized --tls argument");
|
|
}
|
|
}
|
|
|
|
// create and start SMTP server
|
|
smtp.createServer(serverOpts, function(req) {
|
|
var id;
|
|
|
|
// accept all incoming messages
|
|
req.on("to", function(to, ack) {
|
|
id = to;
|
|
console.log("-->".yellow + "incoming message to " + to);
|
|
ack.accept();
|
|
});
|
|
|
|
// send message to web endpoint
|
|
req.on("message", function(stream, ack) {
|
|
stream.pipe(new MailParser().on("end", function(email) {
|
|
http.post({
|
|
url: serverOpts.endpoint,
|
|
json: email
|
|
}, function(err, res, body) {
|
|
var msg;
|
|
|
|
if (err) return console.error("error".red + " " + err.message);
|
|
|
|
msg = String(res.statusCode);
|
|
if (res.statusCode >= 500) {
|
|
console.error(msg.red + " " + body.replace("\n", "\\n"));
|
|
} else if (res.statusCode >= 200 && res.statusCode < 300) {
|
|
console.log(msg.green + " message passed " + id);
|
|
} else {
|
|
console.error(msg.magenta + " unexpected");
|
|
}
|
|
})
|
|
}).on("error", function(err) {
|
|
console.error(err);
|
|
}));
|
|
|
|
ack.accept();
|
|
});
|
|
}).listen(process.env.NODE_PORT || 25);
|
|
|