From c93a8f53a19b4946ad867082bc3b48fd694244f0 Mon Sep 17 00:00:00 2001 From: Francois Kritzinger Date: Fri, 9 Feb 2024 11:52:42 +0200 Subject: Post-review changes --- mod/mod-ci-github.cxx | 131 ++++++++++++++++++++++++-------------------------- mod/mod-ci-github.hxx | 5 -- 2 files changed, 64 insertions(+), 72 deletions(-) (limited to 'mod') diff --git a/mod/mod-ci-github.cxx b/mod/mod-ci-github.cxx index b7bd15f..0a28b63 100644 --- a/mod/mod-ci-github.cxx +++ b/mod/mod-ci-github.cxx @@ -139,16 +139,6 @@ init (scanner& s) s, unknown_mode::fail, unknown_mode::fail); } -bool brep::ci_github:: -respond (response& rs, status_code status, const string& message) -{ - ostream& os (rs.content (status, "text/plain;charset=utf-8")); - - os << message; - - return true; -} - // The "check_suite" object within a check_quite webhook request. // struct check_suite @@ -170,6 +160,10 @@ struct repository string name; string full_name; string default_branch; + + explicit repository (json::parser&); + + repository () = default; }; struct check_suite_event @@ -177,8 +171,21 @@ struct check_suite_event string action; ::check_suite check_suite; ::repository repository; + + explicit check_suite_event (json::parser&); + + check_suite_event () = default; }; +static ostream& +operator<< (ostream&, const check_suite&); + +static ostream& +operator<< (ostream&, const repository&); + +static ostream& +operator<< (ostream&, const check_suite_event&); + bool brep::ci_github:: handle (request& rq, response& rs) { @@ -188,7 +195,7 @@ handle (request& rq, response& rs) // @@ TODO if (false) - return respond (rs, 404, "CI request submission disabled"); + throw invalid_request (404, "CI request submission disabled"); // Process headers. // @@ -206,26 +213,31 @@ handle (request& rq, response& rs) else if (icasecmp (h.name, "content-type") == 0) { if (!h.value) - return respond (rs, 400, "missing content-type value"); + throw invalid_request (400, "missing content-type value"); if (icasecmp (*h.value, "application/json") != 0) - return respond (rs, 400, - "invalid content-type value: '" + *h.value + '\''); + { + throw invalid_request (400, + "invalid content-type value: '" + *h.value + + '\''); + } + + content_type = true; } else if (icasecmp (h.name, "x-github-event") == 0) { if (!h.value) - return respond (rs, 400, "missing x-github-event value"); + throw invalid_request (400, "missing x-github-event value"); event = *h.value; } } if (!content_type) - return respond (rs, 400, "missing content-type header"); + throw invalid_request (400, "missing content-type header"); if (event.empty ()) - return respond (rs, 400, "missing x-github-event header"); + throw invalid_request (400, "missing x-github-event header"); } // There is an event (specified in the x-github-event header) and each event @@ -243,7 +255,6 @@ handle (request& rq, response& rs) { json::parser p (rq.content (64 * 1024), "check_suite webhook"); - p.next_expect (event::begin_object); // @@ Let's move into ctor (everywhere). check_suite_event cs (p); // @@ TODO: log and ignore unknown. @@ -263,7 +274,7 @@ handle (request& rq, response& rs) // ignore? } else - return respond (rs, 400, "unsupported action: " + cs.action); + throw invalid_request (400, "unsupported action: " + cs.action); cout << "" << endl << cs << endl; @@ -271,31 +282,29 @@ handle (request& rq, response& rs) } else if (event == "pull_request") { - return respond (rs, 501, "pull request events not implemented yet"); + throw invalid_request (501, "pull request events not implemented yet"); } else - respond (rs, 400, "unexpected event: '" + event + "'"); + throw invalid_request (400, "unexpected event: '" + event + "'"); } catch (const json::invalid_json_input& e) { // @@ TODO: should we write more detailed diagnostics to log? Maybe we // should do this for all unsuccessful calls to respond(). - - return respond (rs, 400, "malformed JSON in request body"); + // + // @@ TMP These exceptions end up in the apache error log. + // + throw invalid_request (400, "malformed JSON in request body"); } } using event = json::event; -// check_suite_obj +// check_suite // - -// @@ Let's make then constructors. -// -static check_suite_obj -parse_check_suite_obj (json::parser& p) +check_suite::check_suite (json::parser& p) { - check_suite_obj r; + p.next_expect (event::begin_object); // Skip unknown/uninteresting members. // @@ -303,19 +312,17 @@ parse_check_suite_obj (json::parser& p) { const string& n (p.name ()); - if (n == "id") r.id = p.next_expect_number (); - else if (n == "head_branch") r.head_branch = p.next_expect_string (); - else if (n == "head_sha") r.head_sha = p.next_expect_string (); - else if (n == "before") r.before = p.next_expect_string (); - else if (n == "after") r.after = p.next_expect_string (); + if (n == "id") id = p.next_expect_number (); + else if (n == "head_branch") head_branch = p.next_expect_string (); + else if (n == "head_sha") head_sha = p.next_expect_string (); + else if (n == "before") before = p.next_expect_string (); + else if (n == "after") after = p.next_expect_string (); else p.next_expect_value_skip (); } - - return r; } static ostream& -operator<< (ostream& os, const check_suite_obj& cs) +operator<< (ostream& os, const check_suite& cs) { os << "id: " << cs.id << endl << "head_branch: " << cs.head_branch << endl @@ -326,12 +333,11 @@ operator<< (ostream& os, const check_suite_obj& cs) return os; } -// repository_obj +// repository // -static repository_obj -parse_repository_obj (json::parser& p) +repository::repository (json::parser& p) { - repository_obj r; + p.next_expect (event::begin_object); // Skip unknown/uninteresting members. // @@ -339,17 +345,15 @@ parse_repository_obj (json::parser& p) { const string& n (p.name ()); - if (n == "name") r.name = p.next_expect_string (); - else if (n == "full_name") r.full_name = p.next_expect_string (); - else if (n == "default_branch") r.default_branch = p.next_expect_string (); + if (n == "name") name = p.next_expect_string (); + else if (n == "full_name") full_name = p.next_expect_string (); + else if (n == "default_branch") default_branch = p.next_expect_string (); else p.next_expect_value_skip (); } - - return r; } static ostream& -operator<< (ostream& os, const repository_obj& rep) +operator<< (ostream& os, const repository& rep) { os << "name: " << rep.name << endl << "full_name: " << rep.full_name << endl @@ -358,34 +362,27 @@ operator<< (ostream& os, const repository_obj& rep) return os; } -// check_suite_req +// check_suite_event // -static check_suite_req -parse_check_suite_webhook (json::parser& p) +check_suite_event::check_suite_event (json::parser& p) { - check_suite_req r; - - // @@ Let's not assume order. - - r.action = p.next_expect_member_string ("action"); - - // Parse the check_suite object. - // - p.next_expect_name ("check_suite"); p.next_expect (event::begin_object); - r.check_suite = parse_check_suite_obj (p); - // Parse the repository object. + // Skip unknown/uninteresting members. // - p.next_expect_name ("repository", true /* skip_unknown */); - p.next_expect (event::begin_object); - r.repository = parse_repository_obj (p); + while (p.next_expect (event::name, event::end_object)) + { + const string& n (p.name ()); - return r; + if (n == "action") action = p.next_expect_string (); + else if (n == "check_suite") check_suite = ::check_suite (p); + else if (n == "repository") repository = ::repository (p); + else p.next_expect_value_skip (); + } } static ostream& -operator<< (ostream& os, const check_suite_req& cs) +operator<< (ostream& os, const check_suite_event& cs) { os << "action: " << cs.action << endl; os << "" << endl << cs.check_suite; diff --git a/mod/mod-ci-github.hxx b/mod/mod-ci-github.hxx index 0896c0b..a869878 100644 --- a/mod/mod-ci-github.hxx +++ b/mod/mod-ci-github.hxx @@ -35,11 +35,6 @@ namespace brep virtual void init (cli::scanner&); - // @@ Can it be static in .cxx file? - // - bool - respond (response&, status_code, const string& message); - private: shared_ptr options_; }; -- cgit v1.1