From: Alan Knowles <alan@akbkhome.com>
Date: Thu, 26 Dec 2013 21:56:36 +0000 (+0800)
Subject: Monitor.vala
X-Git-Url: http://git.roojs.org/?p=gitlive;a=commitdiff_plain;h=d96dd769fa4ac8b1bde0f7a4f3aaea296512b647

Monitor.vala
---

diff --git a/Monitor.vala b/Monitor.vala
new file mode 100644
index 00000000..b51c73ac
--- /dev/null
+++ b/Monitor.vala
@@ -0,0 +1,307 @@
+//<Script type="text/javascript">
+//var Gio     = imports.gi.Gio;
+//var GLib    = imports.gi.GLib;
+
+//var XObject = imports.XObject.XObject;
+//var File    = imports.File.File;
+
+ 
+using Gee; // for array list?
+
+static int main (string[] args) {
+    // A reference to our file
+    var file = File.new_for_path ("data.txt");
+
+
+}
+
+
+class  MonitorNamePathDir {
+    
+    public string name;
+    public string path;
+    public string dir;
+    
+    public MonitorNamePathDir(string name, string path, string dir)
+    {
+        this.name = name;
+        this.path = path;
+        this.dir = dir;
+        
+    }
+}
+
+/**
+ * Monitor class - handles monitor managment for a large tree...
+ *
+ *
+ * This 
+ * 
+ * usage : 
+ * x = new Monitor({
+     change : function () {
+         * ....
+         *}
+  }
+ * x.add('/somepath')
+ * x.stop() // stops all scanning.
+ * x.play(); // starts the scanning
+ * 
+ * 
+ * 
+ * 
+ */
+ 
+public class Monitor : Object
+{
+
+
+
+    public Monitor()
+    {
+       
+     
+        this.monitors = new ArrayList<FileMonitor> ();
+        this.top = new ArrayList<string> ();
+        this.paused = false;
+    }
+     
+    public ArrayList<FileMonitor> monitors;// Array of GioFileMonitors
+    public ArrayList<string> top; // list of top level directories..
+    public bool paused;
+    /**
+     * add a directory or file to monitor
+     */
+    public void add (string add)
+    {
+        this.top.add(add);
+    }
+    /**
+     * start monitoring
+     */
+    public void start()
+    {
+        foreach(var in in this.top) {
+            this.monitor(this.top[i]);
+        }
+    }
+    /**
+     * stop / pause monitoring
+     * 
+     */
+    public void stop()
+    {
+        
+        foreach(var i in  this.monitors) {
+            this.monitors[i].cancel();
+        } 
+        this.monitors = new ArrayList<FileMonitor>(); // clean /destroy/ kill old?
+    }
+    /**
+     * pause monitoring - without changing what's monitored 
+     */
+    public void pause()
+    {
+        this.paused = true;
+    }
+    /**
+     * resume monitoring - without changing what's monitored 
+     */
+    public void resume()
+    {
+        this.paused = false;
+    }
+    /**
+     * monitor a file or directory (privatish)
+     *
+     * initially called with ~/gitlive  null 0 (effectvely)
+     * 
+     * 
+     */
+    public void monitor(string path, string fn, int depth)
+    {
+         
+       // print("ADD: " + path)
+        
+        //depth = typeof(depth) == 'number'  ? depth *1 : 0;
+        depth = depth > 0  ? depth *1 : 0;
+        
+        
+        //fn = fn || function (fm, f, of, event_type, uh) {
+        //    _this.onEvent(fm, f, of, event_type, uh);
+        //}
+       
+          
+        var f = File.new_for_path(path);
+            //var cancel = new Gio.Cancellable ();
+        if (depth > 0) {     
+            var fm = f.monitor(FileMonitorFlags.SEND_MOVED,null); //Gio.FileMonitorFlags.SEND_MOVED
+            
+            fm.changed.connect(onEvent);
+            this.monitors.add(fm);
+            // print("ADD path " + depth + ' ' + path);
+        }
+        // iterate children?
+        // - this is not used.
+        //if (GLib.file_test(path + '/.git' , GLib.FileTest.IS_DIR) && this.initRepo) {
+            
+        //    this.initRepo(path);
+        //}
+        
+        var enumerator = directory.enumerate_children (FILE_ATTRIBUTE_STANDARD_NAME, 0, null);
+
+ 
+         var file_enum = f.enumerate_children(
+            FILE_ATTRIBUTE_STANDARD_DISPLAY_NAME + ','+    FILE_ATTRIBUTE_STANDARD_TYPE,
+            0, // FileQueryInfoFlags.NONE,
+            null);
+        
+        FileInfo next_file;
+        
+        while ((next_file = file_enum.next_file(null)) != null) {
+         
+            //print("got a file " + next_file.sudo () + '?=' + Gio.FileType.DIRECTORY);
+            
+            if (next_file.get_file_type() != FILETYPE_DIRECTORY) {
+                next_file = null;
+                continue;
+            }
+            
+            if (next_file.get_file_type() == FILETYPE_SYMBOLIC_LINK) {
+                next_file = null;
+                continue;
+            }
+            
+            if (next_file.get_display_name()[0] == '.') {
+                next_file = null;
+                continue;
+            }
+            var sp = path+'/'+next_file.get_display_name();
+            // skip modules.
+            //print("got a file : " + sp);
+         
+            next_file = null;
+            
+            
+            
+            this.monitor(sp, fn, depth + 1);
+            
+        }
+    
+        file_enum.close(null);
+    }
+    
+    
+    
+    public File realpath(File file)
+    {
+        if (file != null) {
+            return file;
+        }
+        
+        if (FileUtils.test(file.get_path(), FileTest.EXISTS)) {
+            var rp = File.realpath(file.get_path());
+            return File.new_for_path(rp);  
+            
+        }
+        // file does not currently exist..
+        // check parent.
+        
+// FIX ME - string split?/? 
+        var bn = file.get_basename();
+        var ar = file.get_path().split('/');
+        ar.pop();
+        var dirname = ar.join('/');
+        var rp = File.realpath(dirname);
+        return File.new_for_path(rp + '/' + bn);
+        
+    }
+   
+    
+    
+     
+    public void onEvent(FileMonitor fm, File f_orig, File of_orig, FileMonitorEvent event_type)
+    {
+        if (this.paused) {
+            return;
+        }
+        
+        var f = this.realpath(f_orig);
+        
+        var of = this.realpath(of_orig);
+ 
+        
+ 
+        MonitorNamePathDir src = new MonitorNamePathDir( f.get_basename(), f.get_path() , GLib.path_get_dirname(f.get_path()));
+        MonitorNamePathDir dest = null;
+        
+        if (of) {
+            dest = new MonitorNamePathDir( of.get_basename(), of.get_path(),  GLib.path_get_dirname(of.get_path()));
+            
+        }
+        string event_name = "UKNOWN";
+        
+        
+        // extract the event names ... - not sure if introspection is feasible in vala..
+        //for(var i in Gio.FileMonitorEvent) {
+         //    if (Gio.FileMonitorEvent[i] == event_type) {
+         //        event_name = i;
+         //    }
+         //}
+        
+        //print (JSON.stringify([event_name , f.get_path(), of ? of.get_path() : false ] ));
+        //print ("got src: " + src.toString());
+        //print ("got event: " + src.toString());
+        try {
+                
+            switch(event_type) {
+                case Gio.FileMonitorEvent.CHANGED:
+                    this.onChanged(src);
+                    return; // ingore thise?? -wait for changes_done_htin?
+                    
+                case Gio.FileMonitorEvent.CHANGES_DONE_HINT:
+                    this.onChangesDoneHint(src);
+                    return;
+                    
+                case Gio.FileMonitorEvent.DELETED:
+                    this.onDeleted(src);
+                    return;
+                    
+                case Gio.FileMonitorEvent.CREATED:
+                    this.onCreated(src);
+                    return;
+                
+                case Gio.FileMonitorEvent.ATTRIBUTE_CHANGED: // eg. chmod/chatt
+                    this.onAttributeChanged(src);
+                    return;
+                
+                case Gio.FileMonitorEvent.MOVED: // eg. chmod/chatt
+                    this.onMoved(src,dest);
+                    return; 
+                
+                // rest are mount related - not really relivant.. maybe add later..
+            } 
+        } catch(Error e) {
+            print(e.message);
+        }
+        
+    }
+    
+    /** override these to do stuff.. */
+    public void initRepo(MonitorNamePathDir src) { } // called on startup at the top level repo dir.
+    public void onChanged(MonitorNamePathDir src) { }
+    public void onChangesDoneHint(MonitorNamePathDir src) { }
+    public void onDeleted(MonitorNamePathDir src) { }
+    public void onCreated(MonitorNamePathDir src) { }
+    public void onAttributeChanged(MonitorNamePathDir src) { }
+    public void onMoved(MonitorNamePathDir src) { }
+          
+    
+}
+ 
+ 
+
+
+
+
+