GitMonitor.vala
[gitlive] / GitMonitor.vala
index e8ff93d..1ca8a2f 100644 (file)
@@ -42,7 +42,7 @@ public class GitMonitorQueue : MonitorNamePathDir {
         
         }
 
-        public bool shouldIgnore(GitMonitor gm)
+        public bool shouldIgnore()
         {
             
             
@@ -158,10 +158,12 @@ public class GitMonitor : Monitor
              
            
             
-            try { 
+            try {
+
+              
                 var notification = new Notify.Notification(
                     "Git Live",
-                    GitMonitor.gitlive + "\nMonitoring " + _this.monitors.length + " Directories",
+                    "%s\nMonitoring %u Directories".printf(GitMonitor.gitlive, this.monitors.length), 
                      "dialog-information"
                 );
         
@@ -175,7 +177,7 @@ public class GitMonitor : Monitor
         
         Timeout.add_full(Priority.LOW, 1000, () => {
             //TIMEOUT", _this.queue.length , _this.queueRunning].join(', '));
-            if (_this.queue.length < 1  || _this.queueRunning) {
+            if (this.queue.length < 1  || this.queueRunning) {
                 return true;
             }
 
@@ -184,8 +186,8 @@ public class GitMonitor : Monitor
             
             //print("LAST RUN?" + last);
             
-            if (last < 5 * Timespan.SECOND) { // wait 1/2 a seconnd before running.
-                return 1;
+            if (last < 5 * TimeSpan.SECOND) { // wait 5 seconds before running. ????
+                return true;
             }
             //_this.lastAdd = new Date();
             //return 1;
@@ -251,7 +253,7 @@ public class GitMonitor : Monitor
 
         var cmds = new Array<GitMonitorQueue>();
         for(var i = 0; i < this.queue.length; i++) {
-            cmds.append_val(this.queue.item(i));
+            cmds.append_val(this.queue.index(i));
         }
 
         this.queue = new Array<GitMonitorQueue>();// empty queue!
@@ -259,7 +261,7 @@ public class GitMonitor : Monitor
         
         string[] success = {};
         string[] failure = {};
-        var repos = new Array<GitRepo>(); //??
+       //var repos = new Array<GitRepo>(); //??
         var done = new Array<GitMonitorQueue>();
         
         // first build a array of repo's to work with
@@ -272,12 +274,13 @@ public class GitMonitor : Monitor
         
         for(var i = 0; i < cmds.length; i++) {
            
+            var cmd = cmds.index(i);
         
             var gitpath = cmd.gitpath; 
-            var ix  = GitRepo.indexOf(this.repos,  cmd.gitpath);
+            var ix  = GitRepo.indexOf(repo_list,  cmd.gitpath);
             if (ix < 0) {
                 repo_list.append_val(new GitRepo( gitpath ));
-                ix = GitRepo.indexOf(this.repos,  cmd.gitpath);
+                ix = GitRepo.indexOf(repo_list,  cmd.gitpath);
             }
             
 
@@ -286,7 +289,7 @@ public class GitMonitor : Monitor
             //    repo_list[gitpath].cmds = [];
              //   repo_list[gitpath].pull();
             //}
-            repo_list.item(ix).cmds.append_val(cmd);
+            repo_list.index(ix).cmds.append_val(cmd);
 
         }
         this.paused = false;
@@ -295,7 +298,7 @@ public class GitMonitor : Monitor
         for(var i = 0;i < repo_list.length;i++) {
     
 
-            var repo = repo_list.item(i);
+            var repo = repo_list.index(i);
 
             var add_files = new Array<GitMonitorQueue>();
             var remove_files = new Array<GitMonitorQueue>();
@@ -303,7 +306,7 @@ public class GitMonitor : Monitor
             //print(JSON.stringify(repo.cmds,null,4));
             
             for(var ii = 0;ii < repo.cmds.length;ii++) {
-                var cmd = repo.cmds.item(ii);
+                var cmd = repo.cmds.index(ii);
     
                 
                 switch(cmd.action) {
@@ -318,12 +321,12 @@ public class GitMonitor : Monitor
                         break;
                     
                     case "rm":
-                        if (GitMonitorQueue.indexOfAdd(add_files, cmd.rm) > -1 ) {
+                        if (GitMonitorQueue.indexOfAdd(add_files, cmd.vname) > -1 ) {
                            break;
                         }
                         
                         // if file exists, do not try and delete it.
-                        if (FileUtils.test(cmd.rm, FileTest.EXISTS)) {
+                        if (FileUtils.test(cmd.vname, FileTest.EXISTS)) {
                             break;
                         }
                         
@@ -346,26 +349,34 @@ public class GitMonitor : Monitor
             
             //repo.debug = 1;
             // these can fail... at present... as we wildcard stuff.
-            stdout.printf("ADD : %d files"  , add_files.length);
+            stdout.printf("ADD : %u files"  , add_files.length);
             
             // make sure added files do not get removed..
 
             var remove_files_f = new Array<GitMonitorQueue>();
             for(var ii = 0;ii < remove_files.length;ii++) {
-                if (GitMonitorQueue.indexOfAdd(add_files,  remove_files.item(ii).rm) > -1 ) {
+                if (GitMonitorQueue.indexOfAdd(add_files,  remove_files.index(ii).vname) > -1 ) {
                      continue;
                 }
-                remove_files_f.append_val(remove_files.item(ii));
+                remove_files_f.append_val(remove_files.index(ii));
             };
-            stdout.printf("REMOVE : %d files"  , remove_files.length);
+            stdout.printf("REMOVE : %u files"  , remove_files.length);
              
             // make sure monitoring is paused so it does not recursively pick up
             // deletions
             
             // -- DO STUFF..
-            
-            repo.add(add_files);
-            repo.remove(remove_files_f);
+            try {
+                repo.add(add_files);
+            } catch(Error e) {
+                failure +=  e.message;
+            }  
+            try {
+                 repo.remove(remove_files_f);
+            } catch(Error e) {
+                failure +=  e.message;
+            }  
+
             this.paused = false;
             
             
@@ -386,7 +397,7 @@ public class GitMonitor : Monitor
          
         try {
             // catch notification failures.. so we can carry on..
-            if (success.length) {
+            if (success.length > 0) {
 
                 
                 var notification = new Notify.Notification(
@@ -400,14 +411,14 @@ public class GitMonitor : Monitor
                 notification.show();   
             }
             
-            if (failure.length) {
+            if (failure.length > 0) {
 
-                var notification = new Notify.Notification({
-                    summary: "Git Live ERROR!!",
+                var notification = new Notify.Notification(
+                      "Git Live ERROR!!",
                     string.joinv("\n",failure),
                     "dialog-information"
                     
-                });
+                );
     
                 notification.set_timeout(5); // show errros for longer
                 notification.show();   
@@ -432,7 +443,7 @@ public class GitMonitor : Monitor
    
 
 
-    public void onChanged(MonitorNamePathDir src) 
+    public new void onChanged(MonitorNamePathDir src) 
     { 
         return; // always ignore this..?
         //this.parsePath(src);
@@ -444,11 +455,11 @@ public class GitMonitor : Monitor
      *  results in  git add  + git commit..
      *
      */
-    public void onChangesDoneHint(MonitorNamePathDir src)  
+    public new void onChangesDoneHint(MonitorNamePathDir src)  
     { 
         
         if (this.paused) {
-            return true;
+            return;
         }
             
 
@@ -485,10 +496,10 @@ public class GitMonitor : Monitor
  
          
     }
-    public void onDeleted(MonitorNamePathDir src) 
+    public new void onDeleted(MonitorNamePathDir src) 
    { 
         if (this.paused) {
-            return true;
+            return;
         }
         this.lastAdd = new DateTime.now(new TimeZone.local()); 
         var cmd = new GitMonitorQueue(src);
@@ -509,10 +520,10 @@ public class GitMonitor : Monitor
         this.queue.append_val(cmd);
  
     }
-    public void onCreated(MonitorNamePathDir src) {
+    public new void onCreated(MonitorNamePathDir src) {
 
         if (this.paused) {
-            return true;
+            return;
         }
         this.lastAdd = new DateTime.now(new TimeZone.local()); 
         var cmd = new GitMonitorQueue(src);
@@ -539,10 +550,10 @@ public class GitMonitor : Monitor
 
     }
 
-    public void onAttributeChanged(MonitorNamePathDir src) { 
+    public new void onAttributeChanged(MonitorNamePathDir src) { 
 
         if (this.paused) {
-            return true;
+            return;
         }
         this.lastAdd = new DateTime.now(new TimeZone.local()); 
         var cmd = new GitMonitorQueue(src);
@@ -559,8 +570,11 @@ public class GitMonitor : Monitor
     }
 
 
-   public void onMoved(MonitorNamePathDir src,MonitorNamePathDir dest)  
+   public new void onMoved(MonitorNamePathDir src,MonitorNamePathDir dest)  
     { 
+        if (this.paused) {
+            return;
+        }
         this.lastAdd = new DateTime.now(new TimeZone.local()); 
         var cmd_s = new GitMonitorQueue(src);