X-Git-Url: http://git.roojs.org/?p=gitlive;a=blobdiff_plain;f=RooTicket.vala;h=d675621c7e2816fcd023a8bac5a84838a8263af3;hp=c4c71bd4946301bed803fd4c8e8d18dd068c1f53;hb=2ac46b7e5e54b5382df0c55b865e47a9937e15f8;hpb=2d3bb6db4cf59fb23b8774360ee0f15ffb7dc975 diff --git a/RooTicket.vala b/RooTicket.vala index c4c71bd4..d675621c 100644 --- a/RooTicket.vala +++ b/RooTicket.vala @@ -3,24 +3,61 @@ code to fetch ticket info... */ + +public class RooRepo : Object +{ + + + + public string id; // not really important that they are numbers.. + public string project_id; + public string description; + public string shortname; + + +} + +public class RooProject : Object +{ + public string id; // not really important that they are numbers.. + public string code; + public string name; + public string type; + +} + + static RooTicket _RooTicket; public class RooTicket : Object { - - const string baseurl = "https://roojs.com/admin.php/Roo/mtrack_ticket"; - + public enum NotMe { + TRUE, + FALSE + } + public enum Closed { + TRUE, + FALSE + } + + //const string baseurl = "https://roojs.com/admin.php/Ro/mtrack_ticket"; + const string roourl = "https://roojs.com/admin.php/Roo"; public static RooTicket singleton() { if (_RooTicket == null) { _RooTicket = new RooTicket(); _RooTicket.tickets = new Gee.ArrayList(); + _RooTicket.projects = new Gee.ArrayList(); + _RooTicket.repos = new Gee.ArrayList(); + _RooTicket.loadRepos(); // initalize it.. } return _RooTicket; } public Gee.ArrayList tickets; // only available for singletonn. + public Gee.ArrayList projects; // only available for singletonn. + public Gee.ArrayList repos; // only available for singletonn. public string username = ""; // only available for singletonn. public string password = ""; // only available for singletonn. @@ -64,6 +101,64 @@ public class RooTicket : Object GLib.debug("ADD ticket %s : %s : %s", add.id, add.summary, add.project_id_name); return add; } + public RooProject addProject(Json.Object t) + { + var add = new RooProject(); + add.id = t.get_string_member("id"); + add.name = t.get_string_member("name"); + add.type = t.get_string_member("type"); + add.code = t.get_string_member("code"); + this.projects.add(add); + GLib.debug("ADD project %s : %s : %s", add.id, add.code, add.name); + return add; + } + + public RooRepo addRepo(Json.Object t) + { + var add = new RooRepo(); + add.id = t.get_string_member("id"); + add.shortname = t.get_string_member("shortname"); + add.description = t.get_string_member("description"); + add.project_id = t.get_string_member("project_id"); + this.repos.add(add); + GLib.debug("ADD project %s : %s : %s", add.id, add.shortname, add.project_id); + return add; + } + + public RooProject? getProjectByRepo(GitRepo repo) + { + var rt = RooTicket.singleton(); + + if (rt.repos.size < 1) { + rt.loadRepos(); + } + if (rt.projects.size < 1) { + rt.loadProjects(); + } + + var pid = ""; + foreach(var roo_repo in rt.repos) { + if (roo_repo.shortname == repo.name) { + pid = roo_repo.project_id; + break; + } + } + if (pid == "") { + GLib.debug("getProjectByRepo: repo has no project"); + return null; + } + // get project by id... + foreach(var roo_project in rt.projects) { + if (roo_project.id == pid) { + GLib.debug("getProjectByRepo: project_id = %s", pid); + return roo_project; + } + } + GLib.debug("getProjectByRepo: can not find project"); + return null; + + } + public static RooTicket fakeTicket() { @@ -94,63 +189,77 @@ public class RooTicket : Object } - public RooTicket? loadTicket(string id) - { - - var table = new GLib.HashTable(str_hash, str_equal); - table.insert("_id",id); - - var params = Soup.Form.encode_hash(table); - var url = "%s?%s" . printf(baseurl, params); - GLib.debug("request %s", url); - - var session = new Soup.Session (); - session.timeout = 0; - var message = new Soup.Message ("GET", url); - RooTicket.setAuth(message); - session.send_message (message); - - - var data = (string) message.response_body.flatten().data; - GLib.debug("got %s", data); - try { - var parser = new Json.Parser (); - parser.load_from_data (data, -1); - - var response = parser.get_root().get_object(); - var status = response.get_boolean_member("success"); - - if(!status){ - GLib.error(response.get_string_member("errorMsg")); - return null; - } - var rd = response.get_object_member ("data"); - - return this.addTicket(rd); - - - - } catch (Error e) { - GLib.error(e.message); - return null; - } - } + public RooTicket? loadTicket(string id) + { + + var table = new GLib.HashTable(str_hash, str_equal); + table.insert("_id",id); + + var params = Soup.Form.encode_hash(table); + var url = "%s/%s?%s" . printf(roourl, "mtrack_ticket", params); + GLib.debug("request %s", url); + + var session = new Soup.Session (); + session.timeout = 0; + var message = new Soup.Message ("GET", url); + RooTicket.setAuth(message); + session.send_message (message); + + + var data = (string) message.response_body.flatten().data; + GLib.debug("got %s", data); + try { + var parser = new Json.Parser (); + parser.load_from_data (data, -1); + + var response = parser.get_root().get_object(); + var status = response.get_boolean_member("success"); + + if(!status){ + GLib.error(response.get_string_member("errorMsg")); + return null; + } + var rd = response.get_object_member ("data"); + + return this.addTicket(rd); + + + + } catch (Error e) { + GLib.error(e.message); + return null; + } + } - public void loadTickets() + public void loadTickets(string project_id, NotMe not_me, Closed closed) { RooTicket.singleton().tickets = new Gee.ArrayList(); var table = new GLib.HashTable(str_hash, str_equal); - - table.insert("query[viewtype]","me"); + if (not_me == NotMe.FALSE) { + table.insert("query[viewtype]","me"); + } else { + + } + if (closed == Closed.TRUE) { + table.insert("query[viewtype]","me"); + } else { + + } + table.insert("limit","999"); table.insert("sort","summary"); table.insert("dir","ASC"); + + if (project_id != "") { + table.insert("project_id",project_id); + } + var params = Soup.Form.encode_hash(table); - var url = "%s?%s" . printf(baseurl, params); + var url = "%s/%s?%s" . printf(roourl, "mtrack_ticket", params); GLib.debug("request %s", url); @@ -164,7 +273,7 @@ public class RooTicket : Object session.send_message (message); var data = (string) message.response_body.flatten().data; - GLib.debug("got %s", data); + //GLib.debug("got %s", data); try { var parser = new Json.Parser (); parser.load_from_data (data, -1); @@ -192,6 +301,119 @@ public class RooTicket : Object } + + public void loadProjects() + { + RooTicket.singleton().projects = new Gee.ArrayList(); + + + var table = new GLib.HashTable(str_hash, str_equal); + + table.insert("query[project_filter]","P,N,U"); + table.insert("limit","999"); + table.insert("sort","name"); + table.insert("dir","ASC"); + + var params = Soup.Form.encode_hash(table); + + var url = "%s/%s?%s" . printf(roourl, "core_project", params); + + GLib.debug("request %s", url); + + var session = new Soup.Session (); + session.timeout = 0; + var message = new Soup.Message ("GET", url); + + + RooTicket.setAuth(message); + + session.send_message (message); + + var data = (string) message.response_body.flatten().data; + //GLib.debug("got %s", data); + try { + var parser = new Json.Parser (); + parser.load_from_data (data, -1); + + var response = parser.get_root().get_object(); + var status = response.get_boolean_member("success"); + + if(!status){ + GLib.error(response.get_string_member("errorMsg")); + return; + } + var rd = response.get_array_member ("data"); + + // got a valid result... + var _this = RooTicket.singleton(); + for(var i = 0; i < rd.get_length(); i++) { + _this.addProject(rd.get_object_element(i)); + } + + + } catch (Error e) { + GLib.error(e.message); + return; + } + + } + public void loadRepos() + { + RooTicket.singleton().repos = new Gee.ArrayList(); + + + var table = new GLib.HashTable(str_hash, str_equal); + + + table.insert("limit","999"); + table.insert("sort","shortname"); + table.insert("dir","ASC"); + + var params = Soup.Form.encode_hash(table); + + var url = "%s/%s?%s" . printf(roourl, "mtrack_repos", params); + + GLib.debug("request %s", url); + + var session = new Soup.Session (); + session.timeout = 0; + var message = new Soup.Message ("GET", url); + + + RooTicket.setAuth(message); + + session.send_message (message); + + var data = (string) message.response_body.flatten().data; + //GLib.debug("got %s", data); + try { + var parser = new Json.Parser (); + parser.load_from_data (data, -1); + + var response = parser.get_root().get_object(); + var status = response.get_boolean_member("success"); + + if(!status){ + GLib.error(response.get_string_member("errorMsg")); + return; + } + var rd = response.get_array_member ("data"); + + // got a valid result... + var _this = RooTicket.singleton(); + for(var i = 0; i < rd.get_length(); i++) { + _this.addRepo(rd.get_object_element(i)); + } + + + } catch (Error e) { + GLib.error(e.message); + return; + } + + } + + public static void setAuth(Soup.Message message) { var rs = RooTicket.singleton(); @@ -234,11 +456,11 @@ public class RooTicket : Object table.insert("reason","fixed by Commits: %s".printf(commits)); var params = Soup.Form.encode_hash(table); - GLib.debug("request POST %s / %s", baseurl, id); + GLib.debug("request POST %s / %s", roourl, id); var session = new Soup.Session (); session.timeout = 0; - var message = new Soup.Message ("POST", baseurl); + var message = new Soup.Message ("POST", roourl + "/mtrack_ticket"); RooTicket.setAuth(message); message.set_request ("application/x-www-form-urlencoded", Soup.MemoryUse.STATIC, params.data); @@ -271,3 +493,4 @@ public class RooTicket : Object } +