// Matrix Construct // // Copyright (C) Matrix Construct Developers, Authors & Contributors // Copyright (C) 2016-2018 Jason Volk // // Permission to use, copy, modify, and/or distribute this software for any // purpose with or without fee is hereby granted, provided that the above // copyright notice and this permission notice is present in all copies. The // full license for this software is available in the LICENSE file. using namespace ircd; mapi::header IRCD_MODULE { "Webhook Handler" }; conf::item webhook_secret { { "name", "webhook.secret" } }; conf::item webhook_user { { "name", "webhook.user" } }; conf::item webhook_room { { "name", "webhook.room" } }; conf::item webhook_url { { "name", "webhook.url" }, { "default", "/webhook" } }; resource webhook_resource { string_view{webhook_url}, { "Webhook Resource", webhook_resource.DIRECTORY } }; static resource::response post__webhook(client &, const resource::request &); resource::method webhook_post { webhook_resource, "POST", post__webhook }; static void github_handle(client &, const resource::request &); resource::response post__webhook(client &client, const resource::request &request) { if(has(http::headers(request.head.headers), "X-GitHub-Event"_sv)) github_handle(client, request); return resource::response { client, http::OK }; } static bool github_validate(const string_view &sig, const const_buffer &content, const string_view &secret); static string_view github_find_commit_hash(const json::object &content); static string_view github_find_issue_number(const json::object &content); static std::pair github_find_party(const json::object &content); static std::ostream & github_handle__push(std::ostream &, const json::object &content); static std::ostream & github_handle__pull_request(std::ostream &, const json::object &content); static std::ostream & github_handle__issues(std::ostream &, const json::object &content); static std::ostream & github_handle__watch(std::ostream &, const json::object &content); static std::ostream & github_handle__ping(std::ostream &, const json::object &content); static std::ostream & github_heading(std::ostream &, const string_view &type, const json::object &content); void github_handle(client &client, const resource::request &request) { const http::headers &headers { request.head.headers }; const auto sig { headers.at("X-Hub-Signature") }; if(!github_validate(sig, request.content, webhook_secret)) throw http::error { http::UNAUTHORIZED, "X-Hub-Signature verification failed" }; const string_view &type { headers.at("X-GitHub-Event") }; const string_view &delivery { headers.at("X-GitHub-Delivery") }; const unique_buffer buf { 48_KiB }; std::stringstream out; pubsetbuf(out, buf); github_heading(out, type, request.content); if(type == "ping") github_handle__ping(out, request.content); else if(type == "push") github_handle__push(out, request.content); else if(type == "pull_request") github_handle__pull_request(out, request.content); else if(type == "issues") github_handle__issues(out, request.content); else if(type == "watch") github_handle__watch(out, request.content); if(!string_view(webhook_room)) return; const auto room_id { m::room_id(string_view(webhook_room)) }; if(!string_view(webhook_user)) return; const m::user::id::buf user_id { string_view(webhook_user), my_host() }; const auto evid { m::msghtml(room_id, user_id, view(out, buf), "No alt text") }; log::info { "Webhook [%s] '%s' delivered to %s %s", delivery, type, string_view{room_id}, string_view{evid} }; } static std::ostream & github_heading(std::ostream &out, const string_view &type, const json::object &content) { const json::object repository { content["repository"] }; out << "" << unquote(repository["full_name"]) << ""; const string_view commit_hash { github_find_commit_hash(content) }; if(commit_hash && type == "push") out << " "; else if(commit_hash && type == "pull_request") out << " "; else if(commit_hash) out << " "; if(commit_hash) out << commit_hash.substr(0, 8) << ""; const string_view issue_number { github_find_issue_number(content) }; if(issue_number) out << " #" << issue_number << ""; else out << " " << type; const auto party { github_find_party(content) }; out << " by " << "" << party.first << ""; return out; } std::ostream & github_handle__push(std::ostream &out, const json::object &content) { const json::array commits { content["commits"] }; const auto count { size(commits) }; if(!count) { out << " "; if(content["ref"]) out << " " << unquote(content["ref"]); out << " deleted"; return out; } if(content["ref"]) { const auto ref(unquote(content["ref"])); out << " " << " " << token_last(ref, '/'); } out << " " << "" << count << " commits" << ""; if(content["forced"] == "true") out << " (rebase)"; out << "
";
	for(ssize_t i(count - 1); i >= 0; --i)
	{
		const json::object &commit(commits.at(i));
		const auto url(unquote(commit["url"]));
		const auto id(unquote(commit["id"]));
		const auto sid(id.substr(0, 8));
		out << " "
		    << "" << sid << ""
		    << "";

		const json::object author(commit["author"]);
		out << " "
		    << unquote(author["name"])
		    << ""
		    ;

		const json::object committer(commit["committer"]);
		if(committer["email"] != author["email"])
			out << " via "
			    << unquote(committer["name"])
			    << ""
			    ;

		const auto message(unquote(commit["message"]));
		const auto summary
		{
			split(message, "\\n").first
		};

		out << " "
		    << summary
		    ;

		out << "
"; } out << "
"; return out; } static std::ostream & github_handle__pull_request(std::ostream &out, const json::object &content) { const json::object pr { content["pull_request"] }; if(pr["merged"] != "true") out << " " << "" << unquote(content["action"]) << "" ; if(pr["merged"] == "true") out << ' ' << "" << "" << "merged" << "" << "" ; if(pr.has("merged_by") && pr["merged_by"] != "null") { const json::object merged_by{pr["merged_by"]}; out << " " << "by " << "" << unquote(merged_by["login"]) << "" ; } if(pr["merged"] == "false") switch(hash(pr["mergeable"])) { default: case hash("null"): out << " / " << "" << "" << "CHECKING MERGE" << "" << "" ; break; case hash("true"): out << " / " << "" << "" << "MERGEABLE" << "" << "" ; break; case hash("false"): out << " / " << "" << "" << "MERGE CONFLICT" << "" << "" ; break; } if(pr.has("additions")) out << " / " << "" << "" << "++" << "" << pr["additions"] << "" ; if(pr.has("deletions")) out << " / " << "" << "" << "--" << "" << pr["deletions"] << "" ; if(pr.has("changed_files")) out << " / " << "" << pr["changed_files"] << ' ' << "" << "files" << "" << "" ; const json::object head { pr["head"] }; out << " " << "
"
	    << ""
	    << ""
	    << unquote(head["sha"]).substr(0, 8)
	    << ""
	    << ""
	    << " "
	    << ""
	    << unquote(pr["title"])
	    << ""
	    << "
" ; return out; } static std::ostream & github_handle__issues(std::ostream &out, const json::object &content) { out << " " << "" << unquote(content["action"]) << "" ; const json::object issue { content["issue"] }; switch(hash(unquote(content["action"]))) { case "assigned"_: case "unassigned"_: { const json::object assignee { content["assignee"] }; out << " " << "" << unquote(assignee["login"]) << "" ; break; } } out << " " << "" << "" << unquote(issue["title"]) << "" << "" ; if(unquote(content["action"]) == "opened") { out << " " << "
" << "
"
		    ;

		static const auto delim("\\r\\n");
		const auto body(unquote(issue["body"]));
		auto lines(split(body, delim)); do
		{
			out << lines.first
			    << "
" ; lines = split(lines.second, delim); } while(!empty(lines.second)); out << "" << "
" << "
" ; } return out; } std::ostream & github_handle__watch(std::ostream &out, const json::object &content) { const string_view action { unquote(content["action"]) }; if(action == "started") { out << " with a star"; return out; } return out; } std::ostream & github_handle__ping(std::ostream &out, const json::object &content) { out << "
"
	    << unquote(content["zen"])
	    << "
"; return out; } /// Researched from yestifico bot std::pair github_find_party(const json::object &content) { const json::object pull_request { content["pull_request"] }; const json::object user { pull_request["user"] }; if(!empty(user)) return { unquote(user["login"]), unquote(user["html_url"]) }; const json::object sender { content["sender"] }; return { unquote(sender["login"]), unquote(sender["html_url"]) }; } /// Researched from yestifico bot ircd::string_view github_find_issue_number(const json::object &content) { const json::object issue(content["issue"]); if(!empty(issue)) return unquote(issue["number"]); if(content["number"]) return unquote(content["number"]); return {}; } /// Researched from yestifico bot ircd::string_view github_find_commit_hash(const json::object &content) { if(content["sha"]) return unquote(content["sha"]); const json::object commit(content["commit"]); if(!empty(commit)) return unquote(commit["sha"]); const json::object head(content["head"]); if(!empty(head)) return unquote(head["commit"]); const json::object head_commit(content["head_commit"]); if(!empty(head_commit)) return unquote(head_commit["id"]); const json::object comment(content["comment"]); if(!empty(comment)) return unquote(comment["commit_id"]); if(content["commit"]) return unquote(content["commit"]); return {}; } bool github_validate(const string_view &sigheader, const const_buffer &content, const string_view &secret) try { const auto sig { split(sigheader, "=") }; crh::hmac hmac { sig.first, secret }; hmac.update(content); char ubuf[64], abuf[sizeof(ubuf) * 2]; if(unlikely(sizeof(ubuf) < hmac.length())) throw ircd::panic { "HMAC algorithm '%s' digest exceeds buffer size.", sig.first }; const const_buffer hmac_bin { hmac.finalize(ubuf) }; static_assert(sizeof(abuf) >= sizeof(ubuf) * 2); const string_view hmac_hex { u2a(abuf, hmac_bin) }; return hmac_hex == sig.second; } catch(const crh::error &e) { throw http::error { http::NOT_IMPLEMENTED, "The signature algorithm is not supported.", }; }