module:depends("http");

local st = require "util.stanza";

local json = require "util.json";

local formdecode = require "net.http".formdecode;

local hmac_md5 = require "util.hashes".hmac_md5;

local st = require "util.stanza";

local json = require "util.json";

local datetime = require "util.datetime".datetime;

local pubsub_service = module:depends("pubsub").service;

local node = module:get_option_string("googlecode_node", "googlecode");

local auth_key = module:get_option_string("googlecode_auth_key");

if not auth_key then

	module:log("warn", "Specify googlecode_auth_key to prevent commit spoofing!");

end

function handle_POST(event)

	local request = event.request;

	local body = request.body;

	if auth_key then

		local digest_header = request.headers["google-code-project-hosting-hook-hmac"];

		local digest = hmac_md5(auth_key, body, true);

		if digest ~= digest_header then

			module:log("warn", "Commit POST failed authentication check, sender gave %s, we got %s, body was:\n%s", tostring(digest_header), tostring(digest), tostring(body));

			return "No thanks.";

		end

	end

	local data = json.decode(body);

	local project = data.project_name or "somewhere";

	for _, rev in ipairs(data.revisions) do

		if rev.url:match("^http://wiki.") then

			local what;

			for _, page in ipairs(rev.added) do

				what = page:match("^/(.-)%.wiki");

				if what then break; end

			end

			if not what then

				for _, page in ipairs(rev.modified) do

					what = page:match("^/(.-)%.wiki");

					if what then break; end

				end

			end

			rev.message = "wiki ("..(what or "unknown page").."): "..rev.message;

		end

		local name = rev.author;

		local email = name:match("<([^>]+)>$");

		if email then

			name = name:gsub("%s*<[^>]+>$", "");

		end

		local ok, err = pubsub_service:publish(node, true, project,

			st.stanza("item", { xmlns = "http://jabber.org/protocol/pubsub", id = project })

			:tag("entry", { xmlns = "http://www.w3.org/2005/Atom" })

				:tag("id"):text(tostring(rev.revision)):up()

				:tag("title"):text(rev.message):up()

				:tag("link", { rel = "alternate", href = rev.url }):up()

				:tag("published"):text(datetime(rev.timestamp)):up()

				:tag("author")

					:tag("name"):text(name):up()

					:tag("email"):text(email):up()

					:up()

		);

	end

	module:log("debug", "Handled POST: \n%s\n", tostring(body));

	return "Thank you Google!";

end

module:provides("http", {

	route = {

		POST = handle_POST;

	};

});

function module.load()

	if not pubsub_service.nodes[node] then

		local ok, err = pubsub_service:create(node, true);

		if not ok then

			module:log("error", "Error creating node: %s", err);

		else

			module:log("debug", "Node %q created", node);

		end

	end

end