Partial Fix #5560 - Gitlive - branching wip
[gitlive] / RooTicket.vala
index c4c71bd..d675621 100644 (file)
@@ -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>();
+            _RooTicket.projects = new Gee.ArrayList<RooProject>();
+            _RooTicket.repos = new Gee.ArrayList<RooRepo>();
+            _RooTicket.loadRepos(); // initalize it..        
         }
         return _RooTicket;
     }
        public Gee.ArrayList<RooTicket> tickets; // only available for singletonn.
+       public Gee.ArrayList<RooProject> projects; // only available for singletonn.    
+       public Gee.ArrayList<RooRepo> 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<string, string>(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<string, string>(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<RooTicket>();
         
                
                var table = new GLib.HashTable<string, string>(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<RooProject>();
+        
+               
+               var table = new GLib.HashTable<string, string>(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<RooRepo>();
+        
+               
+               var table = new GLib.HashTable<string, string>(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
 
        
 }
+