sync

[gitlive] / GitMonitor.vala

diff --git a/GitMonitor.vala b/GitMonitor.vala
index d6fd736..798971c 100644 (file)
--- a/GitMonitor.vala
+++ b/GitMonitor.vala
@@ -1,7 +1,25 @@
+/**
 
+The monitor suffers from various issues - basically event flows while it's running...
+
+normall operations
+
+- monitors for file changes
+ -- adds to QUEUE when occurs.
+ 
+- queue runs in background.
+ - if it's got stuff in it..
+ - COMMIT (normally)
+ - now?? - if on master - try and branch
+   == do user selection, until we have branched
+   == then start monitoring again..
+   
 
 
 
+*/
+
+
 
 
 public class GitMonitor : Monitor
@@ -111,6 +129,12 @@ public class GitMonitor : Monitor
 
        }
        
+       public void restoreQueue( Gee.ArrayList<GitMonitorQueue> queue)
+       {
+               //used to restore teh queue after switch branches?/ - breaks our privte queue idea..
+               this.queue = queue;
+       }
+       
        /*
        public new void resume () {
                this.paused = false;
@@ -224,7 +248,21 @@ public class GitMonitor : Monitor
                if (this.paused || this.queue.size < 1 ) {
                        return;
                }
-               GLib.debug("GitMonitor.runQueue\n");
+               
+               foreach(var q in this.queue) {
+                       if (!q.shouldIgnore() && !q.repo.is_wip_branch() && q.repo.is_auto_branch()) {
+                               var oldq = this.queue;
+                               this.queue =  new Gee.ArrayList<GitMonitorQueue>(); 
+                               NewBranch.singleton().show(q.repo, oldq);
+                               
+                               return;
+                       }
+               
+               }
+               
+                
+               
+               GLib.debug("GitMonitor.runQueue size =%d\n", this.queue.size);
 
                this.queueRunning = true;
 
@@ -261,7 +299,7 @@ public class GitMonitor : Monitor
                        var gitpath = cmd.gitpath; 
                        
                        var repo = GitRepo.get( gitpath );
-                       if ( !repo.is_wip_branch()) {
+                       if ( !repo.is_wip_branch() && repo.is_auto_branch()) {
                                leave_queued.add(cmd);
                                continue;
                        }
@@ -557,11 +595,6 @@ public class GitMonitor : Monitor
                cmd.action = "commit";
                cmd.message = cmd.vname;
                this.queue.add(cmd);
-               
-               
-                if (!cmd.shouldIgnore() && !cmd.repo.is_wip_branch()) {
-                NewBranch.singleton().show(cmd.repo);
-         }
  
                 
        }
@@ -588,11 +621,6 @@ public class GitMonitor : Monitor
                cmd.commit_all = true;
 
                this.queue.add(cmd);
-               
-                if (!cmd.shouldIgnore() && !cmd.repo.is_wip_branch()) {
-                       NewBranch.singleton().show(cmd.repo);
-               }
-               
  
        }
        public override  void onCreated(MonitorNamePathDir src) {
@@ -649,10 +677,6 @@ public class GitMonitor : Monitor
                cmd.action = "commit";
                cmd.message = "Attribute changed " + cmd.vname;
                this.queue.add(cmd);
-               
-               if (!cmd.shouldIgnore() && !cmd.repo.is_wip_branch()) {
-                       NewBranch.singleton().show(cmd.repo);
-        }
        }
  
    public  override void onMoved(MonitorNamePathDir src,MonitorNamePathDir dest)  
@@ -685,12 +709,9 @@ public class GitMonitor : Monitor
                if (cmd_d.shouldIgnore()) {
                        
                        this.onDeleted(src);
- 
-
                        return;
                }
-               
-               
+                
                GLib.debug("RM: %s", cmd_s.vname);
                cmd_s.action = "rm";
                this.queue.add(cmd_s);
@@ -709,17 +730,9 @@ public class GitMonitor : Monitor
                        cmd.message = cmd_d.vname;
                }
                
-               
                this.queue.add(cmd);
 
-               if (!cmd.shouldIgnore() && !cmd.repo.is_wip_branch()) {
-                       NewBranch.singleton().show(cmd.repo);
-        }
-        // this is where it get's complicated...
-        // as we might be moving across repo's...
-        
-        
-        
+
                 
        }