/** 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 { 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. public string id; // not really important that they are numbers.. public string summary; public string description; public string project_id_name; public string summaryToBranchName() { // first 5 words of summary.. var regex = new Regex ("[^A-Za-z0-9 ]+"); var str = regex.replace(this.summary, this.summary.length,0, ""); string[] words = Regex.split_simple ("[ \t]+", str); var ret = ""; for (var i =0; i< (words.length > 5 ? 5 : words.length); i++) { ret += ret.length > 0 ? "_" : ""; ret += words[i]; } return ret; } public string usernameLocal() { // git username is an email addres... - so this reutrns the local part.. //?? assumes that all members are under the same domain... normally the case...... return RooTicket.singleton().username.split("@")[0]; } public RooTicket addTicket(Json.Object t) { var add = new RooTicket(); add.id = t.get_string_member("id"); add.summary = t.get_string_member("summary"); add.description = t.get_string_member("description"); add.project_id_name = t.get_string_member("project_id_name"); this.tickets.add(add); 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() { var t = new RooTicket(); t.id = "-1"; t.summary = ""; t.description = ""; t.project_id_name = ""; RooTicket.singleton().tickets.add(t); return t; } public RooTicket? getById(string id) { foreach(var t in this.tickets) { if (t.id == id) { return t; } } if (id == "-1") { return RooTicket.fakeTicket(); } return this.loadTicket(id); } 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(string project_id, NotMe not_me, Closed closed) { RooTicket.singleton().tickets = new Gee.ArrayList(); var table = new GLib.HashTable(str_hash, str_equal); 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?%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; } 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.addTicket(rd.get_object_element(i)); } } catch (Error e) { GLib.error(e.message); return; } } 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(); if (rs.username.length < 1) { string str; GLib.FileUtils.get_contents(GLib.Environment.get_home_dir() + "/.netrc", out str); var lines = str.split("\n"); for(var i=0; i< lines.length; i++) { // assumes one line per entry.. if not we are buggered... GLib.debug("got %s" , lines[i]); var bits = Regex.split_simple ("[ \t]+", lines[i].strip()); if (bits.length < 6 || bits[0] != "machine" || bits[1] != "git.roojs.com") { continue; } GLib.debug("found password?"); // we are gussing.... RooTicket.singleton().username = bits[3]; RooTicket.singleton().password = bits[5]; } } var authCode = Base64.encode ("%s:%s".printf(rs.username, rs.password).data); message.request_headers.append("Authorization", "Basic %s".printf(authCode)); } public void close(string commits) { if (this.id == "-1") { return; } var table = new GLib.HashTable(str_hash, str_equal); table.insert("id",id); table.insert("status_name","resolved"); table.insert("reason","fixed by Commits: %s".printf(commits)); var params = Soup.Form.encode_hash(table); GLib.debug("request POST %s / %s", roourl, id); var session = new Soup.Session (); session.timeout = 0; 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); 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 ; } } catch (Error e) { GLib.error(e.message); return ; } } }