90045d3d25e35646fd827c1e954c094b9b7289d1
[gitlive] / GitRepo.vala
1
2 /**
3  * @class Scm.Git.Repo
4  *
5  * @extends Scm.Repo
6  * 
7  *
8  *
9  */
10 static GitRepo  _GitRepo; 
11  
12 public class GitRepo : Object
13 {
14      
15     public Gee.ArrayList<GitMonitorQueue> cmds;
16
17     public string name;
18     public string gitdir;
19     public string git_working_dir;
20     public bool debug = false;
21     public bool has_local_changes = false;
22     public string host = "";
23     public string git_status;    
24     public string git_diff;        
25     public string ahead_or_behind = "";
26     
27     public Gee.HashMap<string,bool> ignore_files;
28     public GitBranch currentBranch;
29     public Gee.HashMap<string,GitBranch> branches; // accessed in GitBranch..
30         public RooTicket? activeTicket;
31     public  Gee.HashMap<string,GitRepo> cache;
32     
33     
34     
35         public static GitRepo singleton()
36     {
37         if (_GitRepo == null) {
38             _GitRepo = new GitRepo.single();
39             _GitRepo.cache = new Gee.HashMap<string,GitRepo>();
40         }
41         return _GitRepo;
42     }
43  
44     /**
45     * index of.. matching gitpath..
46     */
47     public static int indexOf( Array<GitRepo> repos, string gitpath) {
48         // make a fake object to compare against..
49         var test_repo = GitRepo.get(gitpath);
50         
51         for(var i =0; i < repos.length; i++) {
52             if (repos.index(i).gitdir == test_repo.gitdir) {
53                 return i;
54             }
55         }
56         return -1;
57     
58     }
59     
60
61     
62     
63     
64     public static   Array<GitRepo> list()
65     {
66
67         //if (GitRepo.list_cache !=  null) {
68         //    unowned  Array<GitRepo>    ret = GitRepo.list_cache;
69          //   return ret;
70         //}
71         var cache = GitRepo.singleton().cache;
72         var list_cache = new Array<GitRepo>();
73         
74         var dir = Environment.get_home_dir() + "/gitlive";
75         
76         var f = File.new_for_path(dir);
77         FileEnumerator file_enum;
78         try {
79             file_enum = f.enumerate_children(
80                 FileAttribute.STANDARD_DISPLAY_NAME + ","+ 
81                 FileAttribute.STANDARD_TYPE,
82                 FileQueryInfoFlags.NONE,
83                 null);
84         } catch (Error e) {
85             
86             return list_cache;
87             
88         }
89         
90         FileInfo next_file; 
91         
92         while (true) {
93             
94             try {
95                 next_file = file_enum.next_file(null);
96                 if (next_file == null) {
97                     break;
98                 }
99                 
100             } catch (Error e) {
101                 GLib.debug("Error: %s",e.message);
102                 break;
103             }
104          
105             //print("got a file " + next_file.sudo () + '?=' + Gio.FileType.DIRECTORY);
106             
107             if (next_file.get_file_type() !=  FileType.DIRECTORY) {
108                 next_file = null;
109                 continue;
110             }
111             
112             if (next_file.get_file_type() ==  FileType.SYMBOLIC_LINK) {
113                 next_file = null;
114                 continue;
115             }
116             
117             if (next_file.get_display_name()[0] == '.') {
118                 next_file = null;
119                 continue;
120             }
121             var sp = dir+"/"+next_file.get_display_name();
122            
123             var gitdir = dir + "/" + next_file.get_display_name() + "/.git";
124             
125             if (!FileUtils.test(gitdir, FileTest.IS_DIR)) {
126                 continue;
127             }
128             
129                 var rep =  GitRepo.get(  sp );
130                 list_cache.append_val(rep);             
131             
132         }
133     
134         return list_cache;
135          
136         }
137         
138         public static GitRepo get(string path) 
139         {
140                 var cache = GitRepo.singleton().cache;
141                 if (cache.has_key(path)) {
142                         return cache.get(path);
143                 }
144                 return new GitRepo(path);
145         }
146         
147     private GitRepo.single() {
148                 // used to create the signleton
149         }
150     /**
151      * constructor:
152      * 
153      * @param {Object} cfg - Configuration
154      *     (basically repopath is currently only critical one.)
155      *
156      */
157      
158     private GitRepo(string path) {
159         // cal parent?
160         this.name =   File.new_for_path(path).get_basename();
161         this.ignore_files = new Gee.HashMap<string,bool>();
162         
163         this.git_working_dir = path;
164         this.gitdir = path + "/.git";
165         if (!FileUtils.test(this.gitdir , FileTest.IS_DIR)) {
166             this.gitdir = path; // naked...
167         }
168         this.cmds = new  Gee.ArrayList<GitMonitorQueue> ();
169         
170                 var cache = GitRepo.singleton().cache;
171         //Repo.superclass.constructor.call(this,cfg);
172                 if ( !cache.has_key(path) ) {
173                         cache.set( path, this);
174         }
175         
176         var r = this.git({ "remote" , "get-url" , "--push" , "origin"});
177         var uri = new Soup.URI(r);      
178         this.host = uri.get_host();
179                 this.init_config();
180         
181         this.loadBranches();
182         this.loadActiveTicket();
183         this.loadStatus();
184     } 
185     
186     public bool is_master_branch()
187     {
188         // special branches that do not allow autopushing now...
189         return this.currentBranch.name == "master" || this.currentBranch.name == "roojs";
190                 
191     }
192     public void init_config()
193     {
194         // managed = 
195         if (this.get_config("managed") == "") {
196                 this.set_config("managed", this.host == "git.roojs.com" ? "1" : "0");
197                 }
198         if (this.get_config("autocommit") == "") {
199                 this.set_config("autocommit", this.host == "git.roojs.com" ? "1" : "0");
200                 }
201         if (this.get_config("autopush") == "") {
202                 this.set_config("autopush", this.host == "git.roojs.com" ? "1" : "0");
203                 }
204     }
205     
206     
207     
208     public string get_config(string key) {
209         return this.git({ "config" , "gitlive." + key });
210         }
211     public string set_config(string key, string value) {
212         return this.git({ "config" , "gitlive." + key, value });
213         }
214     
215     public bool is_managed()
216     {
217         return this.get_config("managed") == "1";
218     }
219     
220     
221     public bool is_autocommit ()
222     {           
223         return this.get_config("autocommit") == "1";            
224     }
225     
226     public void set_autocommit(bool val)
227     {
228                 this.set_config("autocommit", val ? "1" : "0");
229     
230     }
231     
232     public bool is_auto_branch ()
233     {
234         if (this.name == "gitlog") {
235                 return false;
236                 }
237                 // check remote...
238         if (this.is_managed()) {
239                 return true;
240                 }
241         return false;
242         
243  
244     }
245     
246     public void set_auto_branch(bool val)
247     {
248                 if (this.name == "gitlog") {
249                 return;
250                 }
251                 this.set_config("managed", val ? "1" : "0");
252     
253     }
254     public bool is_autopush ()
255     {
256         return this.get_config("autopush") == "1";
257     }
258     public void set_autopush(bool val)
259     {
260                 this.set_config("autopush", val ? "1" : "0");
261     }
262     
263     
264         public void loadStatus()
265         {
266                 var r = this.git({ "status" , "--porcelain" });
267                 this.git_status = r;
268                 this.has_local_changes = r.length > 0;
269                 
270                 var rs = this.git({ "status" , "-sb" });
271
272                 this.ahead_or_behind = rs.contains("[ahead") ? "A" : (rs.contains("[behind") ? "B" : "");
273                 
274                 
275                 this.git_diff  = this.git({ "diff" , "HEAD", "--no-color" });
276         }    
277
278     
279     public void loadBranches()
280     {
281
282         GitBranch.loadBranches(this);
283     }
284      
285     
286     
287     
288     public string branchesToString()
289     {
290         var ret = "";
291                 foreach( var br in this.branches.values) {
292                         if (br.name == "") {
293                                 continue; 
294                         }
295                         ret += ret.length > 0 ? "\n"  : "";
296                         ret += br.name;
297                 
298                 }
299                 return ret;
300         
301     }
302      public static void doMerges(string action, string ticket_id, string commit_message)
303     {
304        GitMonitor.gitmonitor.stop();
305        
306        var commitrevs = "";
307        var sucess = true;
308        foreach(var  repo in GitRepo.singleton().cache.values) {
309                if (repo.activeTicket != null && repo.activeTicket.id == ticket_id) {
310                        var res = repo.doMerge(action,ticket_id, commit_message);
311                        if (!res) {
312                                sucess = false;
313                                continue;
314                        }
315                        commitrevs += commitrevs.length > 0 ? " " : "";
316                        commitrevs += repo.currentBranch.lastrev;
317                }
318        }
319        if (sucess && action == "CLOSE") {
320                RooTicket.singleton().getById(ticket_id).close(commitrevs);
321        }
322        GitMonitor.gitmonitor.start();
323     }
324      
325
326     public bool doMerge(string action, string ticket_id, string commit_message)
327     {
328        // in theory we should check to see if other repo's have got the same branch and merge all them at the same time.
329        // also need to decide which branch we will merge into?
330                    var ret = "";
331                    if (action == "CLOSE" || action == "LEAVE") {
332                                    
333                try {
334                    var oldbranch = this.currentBranch.name;
335                    this.setActiveTicket(null, "master");
336                            string [] cmd = { "merge",   "--squash",  oldbranch };
337                            this.git( cmd );
338                            cmd = { "commit",   "-a" , "-m",  commit_message };
339                            this.git( cmd );
340                            this.push();
341                            this.loadBranches(); // updates lastrev..
342                
343                        var notification = new Notify.Notification(
344                                "Merged branch %s to master".printf(oldbranch),
345                                "",
346                                 "dialog-information"
347                                
348                        );
349
350                        notification.set_timeout(5);
351                        notification.show();   
352                
353                // close ticket..
354                return true; 
355                
356            } catch (Error e) {
357
358                GitMonitor.gitmonitor.pauseError(e.message);
359                return false;
360            }
361            // error~?? -- show the error dialog...
362                    return false;
363        }
364        if (action == "MASTER") {
365                // merge master into ours..
366                        try {
367                        string[] cmd = { "merge",  "master" };
368                        this.git( cmd );
369                        var notification = new Notify.Notification(
370                                        "Merged code from master to %s".printf(this.currentBranch.name),
371                                        "",
372                                         "dialog-information"
373                                        
374                                );
375                                notification.set_timeout(5);
376                                notification.show();   
377                       
378                        return true;
379                        } catch (Error e) {
380                        GitMonitor.gitmonitor.pauseError(e.message);
381                        return false;
382                    }
383            }
384        if (action == "EXIT") {
385                        try {
386                        var oldbranch  = this.currentBranch.name;
387                          this.setActiveTicket(null, "master");
388                        this.loadBranches();
389                        var notification = new Notify.Notification(
390                                        "Left branch %s".printf(oldbranch),
391                                        "",
392                                         "dialog-information"
393                                        
394                                );
395                                notification.set_timeout(5);
396                                notification.show();   
397                        
398                        return true;
399                    } catch (Error e) {
400                        GitMonitor.gitmonitor.pauseError(e.message);
401
402                        return false;                   
403                    }
404                    // error~?? -- show the error dialog...
405
406        }
407        return false;
408     }
409         
410     public void loadActiveTicket()
411     {
412         this.activeTicket = null;
413                 var ticket_id = this.get_config("ticket");
414         
415         if (ticket_id.length < 1) {
416                 return;
417                 }
418                 this.activeTicket = RooTicket.singleton().getById(ticket_id.strip());
419         
420         
421     }
422     
423     
424     
425     public bool setActiveTicket(RooTicket? ticket, string branchname)
426     {
427         this.set_config("ticket", "");
428         if (!this.createBranchNamed(branchname)) {
429                 return false;
430                 }
431                 this.set_config("ticket", ticket == null ? "": ticket.id);
432         this.activeTicket = ticket;
433         return true;
434     }
435     
436     public bool createBranchNamed(string branchname)
437     {   
438                 
439
440                      if (this.branches.has_key(branchname)) {
441                         this.switchToExistingBranchNamed(branchname);
442                     
443                     } else {
444                                  this.createNewBranchNamed(branchname); 
445                             
446                     }
447                        var notification = new Notify.Notification(
448                        "Changed to branch %s".printf(branchname),
449                        "",
450                         "dialog-information"
451                        
452                );
453
454                notification.set_timeout(5);
455                notification.show();   
456        
457          
458          this.loadBranches(); // update branch list...
459          //GitMonitor.gitmonitor.runQueue(); // no point - we have hidden the queue..
460          return true;
461     }
462      bool switchToExistingBranchNamed(string branchname)
463      {
464                 var stash = false;
465                                          // this is where it get's tricky...
466                 string files = "";
467                 try {                   
468                                 string[] cmd = { "ls-files" ,  "-m" };                   // list the modified files..
469                                 files = this.git(cmd);
470                                 stash = files.length> 1 ;
471                                 
472                                 
473                                 cmd = { "stash" };                      
474                                 if (stash) { this.git(cmd); }
475                                 
476                                 this.pull();
477                                 
478                                 cmd = { "checkout", branchname  };
479                                 this.git(cmd);
480                   } catch(Error e) {
481                                 GitMonitor.gitmonitor.pauseError(e.message);
482                                 return false;           
483                   }
484                 try {
485                    if (branchname != "master") {
486                        string[] cmd = { "merge", "master"  };
487                             this.git(cmd);
488                             this.push();
489                        
490                     }
491                     
492                 } catch(Error e) {
493                     string[] cmd = { "checkout", "master"  };
494                     this.git(cmd);
495                         GitMonitor.gitmonitor.pauseError(
496                                 "Use\n\na) git checkout %s\nb) git mergetool\nc) git commit\nd) git push\n d) stash pop \ne) start gitlive again\n".printf(
497                                         branchname)
498                                  + e.message
499                         );
500                         return false;           
501                  
502                 }
503                 try {                                   
504                     string[]  cmd = { "stash", "pop"  };
505                     if (stash) { 
506                         this.git(cmd); 
507                         var fl = files.split("\n");
508                         cmd = { "commit", "-m" , "Changed " + string.joinv("",fl) };
509                         foreach(var f in fl) {
510                                 if (f.length < 1) continue;
511                                 cmd += f;
512                         }
513                         this.git(cmd);                              
514                 }
515              
516
517                    
518                 } catch(Error ee) {
519                         GitMonitor.gitmonitor.pauseError(ee.message);
520                         return false;           
521                 }
522        this.push();
523        return true;                             
524                  
525      }
526     
527     
528     
529      bool createNewBranchNamed(string branchname)
530      {
531                 var stash = false;
532                  try {                                  
533                                 string[] cmd = { "ls-files" ,  "-m" };                   // list the modified files..
534                                 var files = this.git(cmd);
535                                 stash = files.length> 1 ;
536                         
537                          cmd = { "checkout", "-b" , branchname  };
538                         this.git(cmd);
539
540                cmd = { "push", "-u" , "origin" ,"HEAD"  };
541                         this.git(cmd);
542                                 if (stash) { 
543
544                                 var fl = files.split("\n");
545                                 cmd = { "commit", "-m" , "Changed " + string.joinv("",fl) };
546                                 foreach(var f in fl) {
547                                         if (f.length < 1) continue;
548                                         cmd += f;
549                                 }
550                                 this.git(cmd);  
551                                 this.push();                        
552                         }
553
554              
555                 } catch(Error ee) {
556                                 GitMonitor.gitmonitor.pauseError(ee.message);
557                                 return false;           
558                         }
559                         return true;
560      
561      }
562     
563     
564     
565     /**
566      * add:
567      * add files to track.
568      *
569      * @argument {Array} files the files to add.
570      */
571     public string add ( Gee.ArrayList<GitMonitorQueue> files ) throws Error, SpawnError
572     {
573         // should really find out if these are untracked files each..
574         // we run multiple versions to make sure that if one failes, it does not ignore the whole lot..
575         // not sure if that is how git works.. but just be certian.
576         var ret = "";
577         for (var i = 0; i < files.size;i++) {
578             var f = files.get(i).vname;
579             try {
580                 string[] cmd = { "add",    f  };
581                 this.git( cmd );
582             } catch (Error e) {
583                 ret += e.message  + "\n";
584             }        
585
586         }
587         return ret;
588     }
589         
590     public bool is_ignore(string fname) throws Error, SpawnError
591     {
592                 if (fname == ".gitignore") {
593                         this.ignore_files.clear();
594                 }
595                 
596                 if (this.ignore_files.has_key(fname)) {
597                         return this.ignore_files.get(fname);
598                 }
599                 
600                 try {
601                         var ret = this.git( { "check-ignore" , fname } );
602                         this.ignore_files.set(fname, ret.length >  0);
603                         return ret.length > 0;
604                 } catch (SpawnError e) {
605                         this.ignore_files.set(fname, false);
606                         return false;
607                 }
608                  
609     } 
610     
611     
612       /**
613      * remove:
614      * remove files to track.
615      *
616      * @argument {Array} files the files to add.
617      */
618     public string remove  ( Gee.ArrayList<GitMonitorQueue> files ) throws Error, SpawnError
619     {
620         // this may fail if files do not exist..
621         // should really find out if these are untracked files each..
622         // we run multiple versions to make sure that if one failes, it does not ignore the whole lot..
623         // not sure if that is how git works.. but just be certian.
624         var ret = "";
625
626         for (var i = 0; i < files.size;i++) {
627             var f = files.get(i).vname;
628             try {
629                 string[] cmd = { "rm",  "-f" ,  f  };
630                 this.git( cmd );
631             } catch (Error e) {
632                 ret += e.message  + "\n";
633             }        
634         }
635
636         return ret;
637
638     }
639     
640     
641     /**
642      * commit:
643      * perform a commit.
644      *
645      * @argument {Object} cfg commit configuration
646      * 
647      * @property {String} name (optional)
648      * @property {String} email (optional)
649      * @property {String} changed (date) (optional)
650      * @property {String} reason (optional)
651      * @property {Array} files - the files that have changed. 
652      * 
653      */
654      
655     public string commit ( string message, Gee.ArrayList<GitMonitorQueue> files  ) throws Error, SpawnError
656     {
657         
658
659         /*
660         var env = [];
661
662         if (typeof(cfg.name) != 'undefined') {
663             args.push( {
664                 'author' : cfg.name + ' <' + cfg.email + '>'
665             });
666             env.push(
667                 "GIT_COMMITTER_NAME" + cfg.name,
668                 "GIT_COMMITTER_EMAIL" + cfg.email
669             );
670         }
671
672         if (typeof(cfg.changed) != 'undefined') {
673             env.push("GIT_AUTHOR_DATE= " + cfg.changed )
674             
675         }
676         */
677         string[] args = { "commit", "-m" };
678         args +=  (message.length > 0  ? message : "Changed" );
679         for (var i = 0; i< files.size ; i++ ) {
680             args += files.get(i).vname; // full path?
681         }
682          
683         return this.git(args);
684     }
685     
686     /**
687      * pull:
688      * Fetch and merge remote repo changes into current branch..
689      *
690      * At present we just need this to update the current working branch..
691      * -- maybe later it will have a few options and do more stuff..
692      *
693      */
694     public string pull () throws Error, SpawnError
695     {
696         // should probably hand error conditions better... 
697         string[] cmd = { "pull" , "--no-edit" };
698         return this.git( cmd );
699
700         
701     }
702     
703     public delegate void GitAsyncCallback (GitRepo repo, int err, string str);
704     public void pull_async(GitAsyncCallback cb) 
705     {
706     
707          string[] cmd = { "pull" , "--no-edit" };
708          this.git_async( cmd , cb);
709          
710     
711     }
712     
713     /**
714      * push:
715      * Send local changes to remote repo(s)
716      *
717      * At present we just need this to push the current branch.
718      * -- maybe later it will have a few options and do more stuff..
719      *
720      */
721     public string push () throws Error, SpawnError
722     {
723         // should 
724         return this.git({ "push"  });
725         
726     }
727     
728     
729     
730      /**
731      * git:
732      * The meaty part.. run spawn.. with git..
733      *
734      *
735      */
736     
737     public string git(string[] args_in ) throws Error, SpawnError
738     {
739         // convert arguments.
740         
741         string[]  args = { "git" };
742         //args +=  "--git-dir";
743         //args +=  this.gitdir;
744         args +=  "--no-pager";
745  
746  
747         //if (this.gitdir != this.repopath) {
748         //    args +=   "--work-tree";
749          //   args += this.repopath; 
750         //}
751         for (var i = 0; i < args_in.length;i++) {
752             args += args_in[i];
753         }            
754
755         //this.lastCmd = args.join(" ");
756         //if(this.debug) {
757             GLib.debug( "CWD=%s",  this.git_working_dir ); 
758             GLib.debug( "cmd: %s", string.joinv (" ", args)); 
759         //}
760
761         string[]   env = {};
762         string  home = "HOME=" + Environment.get_home_dir() ;
763         env +=  home ;
764         // do not need to set gitpath..
765         //if (File.exists(this.repo + '/.git/config')) {
766             //env.push("GITPATH=" + this.repo );
767         //}
768           
769         var cfg = new SpawnConfig(this.git_working_dir , args , env);
770         //cfg.debug = true;
771
772        // may throw error...
773         var sp = new Spawn(cfg);
774       
775         // diff output is a bit big..
776                 if (args_in[0] != "diff") {
777                 GLib.debug( "GOT: %s" , sp.output);
778         }
779         // parse output for some commands ?
780         return sp.output;
781     }
782         
783    unowned GitAsyncCallback git_async_on_callback;
784         public void  git_async( string[] args_in,   GitAsyncCallback cb ) throws Error, SpawnError
785     {
786         // convert arguments.
787        this.git_async_on_callback = cb;
788         string[]  args = { "git" };
789         //args +=  "--git-dir";
790         //args +=  this.gitdir;
791         args +=  "--no-pager";
792  
793  
794         //if (this.gitdir != this.repopath) {
795         //    args +=   "--work-tree";
796          //   args += this.repopath; 
797         //}
798         for (var i = 0; i < args_in.length;i++) {
799             args += args_in[i];
800         }            
801
802         //this.lastCmd = args.join(" ");
803         //if(this.debug) {
804             GLib.debug( "CWD=%s",  this.git_working_dir ); 
805             //print( "cmd: %s\n", string.joinv (" ", args)); 
806         //}
807
808         string[]   env = {};
809         string  home = "HOME=" + Environment.get_home_dir() ;
810         env +=  home ;
811         // do not need to set gitpath..
812         //if (File.exists(this.repo + '/.git/config')) {
813             //env.push("GITPATH=" + this.repo );
814         //}
815         
816
817         var cfg = new SpawnConfig(this.git_working_dir , args , env);
818         cfg.async = true;
819        
820
821        // may throw error...
822         var sp = new Spawn(cfg);
823                 //sp.ref();
824         //this.ref();
825         sp.run(this.git_async_on_complete); 
826          
827     }
828     
829     void git_async_on_complete(int err, string output)
830     {
831                 GLib.debug("GOT %d : %s", err, output);
832                 this.git_async_on_callback(this, err, output);
833 //              this.unref();   
834         //      sp.unref();             
835     
836     
837     }
838     
839  
840          
841     
842  
843     public void update_async(GitAsyncCallback cb) 
844     {
845          string[] cmd = { "fetch" , "--all" };
846          this.git_async( cmd , cb);
847          
848     }
849     
850     
851     static uint update_all_total = 0;
852     static string update_all_after = "";
853      
854     public static void updateAll(string after)
855     {
856                 update_all_after = after;
857                 var tr =  GitRepo.singleton().cache;
858             
859         
860        update_all_total = tr.size;
861        foreach(var repo  in tr.values) {
862                 if (!repo.is_managed()) {
863                         update_all_total--;                     
864                         continue;
865                 }
866            repo.update_async(updateAllCallback); 
867         } 
868
869     }
870     public static void  updateAllCallback(GitRepo repo, int err, string res)
871     {
872         repo.loadBranches();
873         repo.loadStatus();
874         
875         update_all_total--;
876         if (update_all_total > 0 ) {
877                 return;
878                 }
879                 switch (update_all_after) {
880                         case "show_clones":
881                                 Clones.singleton().show();
882                                 break;
883                         default:
884                                 break;
885                 }
886                 return;
887     }
888     
889     
890     
891 }