93 lines
2.6 KiB
JavaScript
93 lines
2.6 KiB
JavaScript
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) {
|
|
// accept all incoming messages
|
|
req.on("to", function(to, ack) {
|
|
console.log("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) {
|
|
var msg;
|
|
|
|
http.post({
|
|
url: serverOpts.endpoint,
|
|
json: email
|
|
}, function(err, res, body) {
|
|
if (err) {
|
|
msg = "error".red + " " + err.message;
|
|
console.error(msg);
|
|
}
|
|
|
|
else if (res.statusCode < 200 || res.statusCode > 299) {
|
|
msg = res.statusCode + " -----------";
|
|
console.error(msg.magenta);
|
|
console.error(body);
|
|
console.error("---------------".magenta);
|
|
}
|
|
|
|
else {
|
|
console.log("passed message successfully");
|
|
}
|
|
})
|
|
}).on("error", function(err) {
|
|
console.error(err);
|
|
}));
|
|
|
|
ack.accept();
|
|
});
|
|
}).listen(process.env.NODE_PORT || 25);
|
|
|