sync
[gitlive] / RooTicket.vala
1 /**
2
3 code to fetch ticket info...
4
5 */
6 static RooTicket  _RooTicket;
7
8
9
10 public class RooTicket : Object
11 {
12         
13    const string baseurl = "https://roojs.com/admin.php/Roo/mtrack_ticket"; 
14         
15         public static RooTicket singleton()
16     {
17         if (_RooTicket == null) {
18             _RooTicket = new RooTicket();
19             _RooTicket.tickets = new Gee.ArrayList<RooTicket>();
20         }
21         return _RooTicket;
22     }
23         public Gee.ArrayList<RooTicket> tickets; // only available for singletonn.
24         public string username = ""; // only available for singletonn.
25         public string password = ""; // only available for singletonn.
26
27
28         public string  id; // not really important that they are numbers..
29         public string summary;
30         public string description;
31         public string project_id_name;
32
33
34         public string summaryToBranchName()
35         {
36                 // first 5 words of summary..
37                 var  regex = new Regex ("[^A-Za-z0-9 ]+");
38                 var str = regex.replace(this.summary, this.summary.length,0, "");
39                 string[] words = Regex.split_simple ("[ \t]+", str);
40                 var ret = "";
41                 for (var i =0; i< (words.length > 5 ? 5 : words.length); i++) {
42                         ret += ret.length > 0 ? "_" : "";
43                         ret += words[i];
44                 }
45                 return ret;
46         }
47         public string usernameLocal()
48         {
49                 // git username is an email addres... - so this reutrns the local part..
50                 //?? assumes that all members are under the same domain... normally the case......
51                 return RooTicket.singleton().username.split("@")[0];
52         
53         }
54
55
56         public RooTicket addTicket(Json.Object t)
57         {
58                 var add = new RooTicket();
59                 add.id = t.get_string_member("id");
60                 add.summary = t.get_string_member("summary");
61                 add.description = t.get_string_member("description");
62                 add.project_id_name = t.get_string_member("project_id_name");                                           
63                 this.tickets.add(add);
64                 GLib.debug("ADD ticket  %s : %s : %s", add.id, add.summary, add.project_id_name);
65                 return add;
66         }
67  
68         public RooTicket? getById(string id)
69         {
70                 foreach(var t in this.tickets) {
71                         if (t.id == id) {
72                                 return t;
73                         }
74                 }
75         return this.loadTicket(id);
76
77  
78         }
79
80
81        public RooTicket? loadTicket(string id)
82        {
83        
84                var table = new GLib.HashTable<string, string>(str_hash, str_equal);
85                table.insert("_id",id);         
86                
87                var params = Soup.Form.encode_hash(table);              
88                var url = "%s?%s" . printf(baseurl, params);
89                GLib.debug("request %s", url);
90                
91                var session = new Soup.Session ();
92                session.timeout = 0;
93                var message = new Soup.Message ("GET", url);
94                RooTicket.setAuth(message);
95                session.send_message (message);
96                
97                
98                var data = (string) message.response_body.flatten().data;
99                GLib.debug("got %s", data);
100                try {
101                        var parser = new Json.Parser ();
102                        parser.load_from_data (data, -1);
103
104                        var response = parser.get_root().get_object();
105                        var status = response.get_boolean_member("success");
106                
107                        if(!status){
108                                GLib.error(response.get_string_member("errorMsg"));
109                                return null;
110                        }
111                        var rd = response.get_object_member ("data");
112                        
113                        return this.addTicket(rd);
114                        
115                         
116                
117                } catch (Error e) {
118                        GLib.error(e.message);
119                        return null;
120                }
121         }
122
123         public void loadTickets()
124         {
125                 RooTicket.singleton().tickets = new Gee.ArrayList<RooTicket>();
126          
127                 
128                 var table = new GLib.HashTable<string, string>(str_hash, str_equal);
129          
130                 table.insert("query[viewtype]","me");
131                 table.insert("limit","999");
132                 table.insert("sort","summary");
133                 table.insert("dir","ASC");
134
135                 var params = Soup.Form.encode_hash(table);
136                 
137                 var url = "%s?%s" . printf(baseurl, params);
138                 
139                 GLib.debug("request %s", url);
140                 
141                 var session = new Soup.Session ();
142                 session.timeout = 0;
143                 var message = new Soup.Message ("GET", url);
144                 
145                 
146                 RooTicket.setAuth(message);
147                 
148                 session.send_message (message);
149                 
150                 var data = (string) message.response_body.flatten().data;
151                 GLib.debug("got %s", data);
152                 try {
153                         var parser = new Json.Parser ();
154                         parser.load_from_data (data, -1);
155
156                         var response = parser.get_root().get_object();
157                         var status = response.get_boolean_member("success");
158                 
159                         if(!status){
160                                 GLib.error(response.get_string_member("errorMsg"));
161                                 return;
162                         }
163                         var rd = response.get_array_member ("data");
164                         
165                         // got a valid result...
166                         var _this = RooTicket.singleton();
167                         for(var i = 0; i < rd.get_length(); i++) {
168                                 _this.addTicket(rd.get_object_element(i));
169                         }
170                          
171                 
172                 } catch (Error e) {
173                         GLib.error(e.message);
174                         return;
175                 }
176                 
177         }
178         
179         public  static void setAuth(Soup.Message message) 
180         {
181                 var rs =  RooTicket.singleton();                
182                 if (rs.username.length < 1) {
183                         string str;
184                         GLib.FileUtils.get_contents(GLib.Environment.get_home_dir() + "/.netrc", out str);
185                         var lines = str.split("\n");
186                         for(var i=0; i< lines.length; i++) {
187                         // assumes one line per entry.. if not we are buggered...
188                                         GLib.debug("got %s" , lines[i]);
189                         
190                                 var bits =  Regex.split_simple ("[ \t]+", lines[i].strip());
191                                 if (bits.length < 6 || bits[0] != "machine" || bits[1] != "git.roojs.com") {
192                                         continue;
193                                 }
194                                         GLib.debug("found password?");
195                                 // we are gussing.... 
196
197                                 RooTicket.singleton().username  = bits[3];
198                                 RooTicket.singleton().password  = bits[5];              
199                         }
200                 }
201
202
203                 var authCode = Base64.encode ("%s:%s".printf(rs.username, rs.password).data);
204                 message.request_headers.append("Authorization", "Basic %s".printf(authCode));
205         
206         
207         }
208
209
210        public void close(string commits)
211        {
212                var table = new GLib.HashTable<string, string>(str_hash, str_equal);
213                table.insert("id",id);
214                table.insert("status_name","resolved");
215                table.insert("reason","fixed by Commits: %s".printf(commits));  
216                var params = Soup.Form.encode_hash(table);              
217
218                GLib.debug("request POST %s / %s", baseurl, id);
219                
220                var session = new Soup.Session ();
221                session.timeout = 0;
222                var message = new Soup.Message ("POST", baseurl);
223                RooTicket.setAuth(message);
224                 
225                message.set_request ("application/x-www-form-urlencoded", Soup.MemoryUse.STATIC, params.data);
226                session.send_message (message);
227                
228                
229                var data = (string) message.response_body.flatten().data;
230                GLib.debug("got %s", data);
231                try {
232                        var parser = new Json.Parser ();
233                        parser.load_from_data (data, -1);
234
235                        var response = parser.get_root().get_object();
236                        var status = response.get_boolean_member("success");
237                
238                        if(!status){
239                                GLib.error(response.get_string_member("errorMsg"));
240                                return ;
241                        }
242                         
243                        
244                         
245                
246                } catch (Error e) {
247                        GLib.error(e.message);
248                        return ;
249                }
250        
251        }
252
253
254         
255         
256  }