send_email_worker.lua

dofile(assert(arg[1], "No config file specified"));
local config = assert(config, "No config!");

local beanstalk = require "beanstalk".new();
local smtp = require "socket.smtp";
local json = require "json";

local email_format = "%s <%s>";

beanstalk:connect();

-- A function that strips indentation and
-- replaces $variables with entries from the data table.
local function preprocess_message(data, message)
	local indentation = message:match("^%s*");
	return (("\n"..message):gsub("\n"..indentation, "\n"):gsub("%$([%a_]+)", data):gsub("%s+$", ""));
end


repeat local job, err = beanstalk:reserve();
	if not job then
		print("EE", err);
	else
		local data = json.decode(job.data);
		assert(smtp.send {
			from = email_format:format(config.from_name, config.from_address);
			rcpt = data.address;
			source = smtp.message {
				headers = {
					to = email_format:format(data.name or "", data.address);
					from = email_format:format(config.from_name, config.from_address);
					subject = config.subject;
				};
				body = preprocess_message(data, config.message);
			};
			user = config.smtp_username;
			password = config.smtp_password;
			server = config.smtp_server;
			port = config.smtp_port;
		});
	end
until false;