add basic sink operation

lib/gorg.rb

@@ -13,6 +13,10 @@ def initialize(opts)
     @path = opts[:path]
   end
 
+  def write(file, r)
+    file.puts(JSON.dump({"path" => r.path, "value" => r.value, "rev" => r.rev}))
+  end
+
   def dump
     log("dump event=open")
     file = @path ? File.open(@path, "w") : $stdout
@@ -23,7 +27,7 @@ def dump
       log("dump event=req")
       client.walk(nil, "/**") do |r|
         log("dump event=res path=#{r.path}")
-        file.puts(JSON.dump({"path" => r.path, "value" => r.value, "rev" => r.rev}))
+        write(file, r)
       end.done do
         log("dump event=stop")
         EM.stop
@@ -34,6 +38,31 @@ def dump
     end
   end
 
+  def sink
+    log("sink event=open")
+    file = @path ? File.open(@path, "w") : $stdout
+    log("sink event=run")
+    EM.run do
+      log("sink event=connect")
+      client = Fraggle.connect
+      log("sink event=rev")
+      client.rev do |r|
+        rev = r.rev
+        log("sink event=walk rev=#{rev}")
+        client.walk(rev, "/**") do |r|
+          log("sink event=res path=#{r.path}")
+          write(file, r)
+        end.done do
+          log("sink event=watch rev=#{rev+1}")
+          client.watch(rev+1, "/**") do |r|
+            log("sink event=res path=#{r.path}")
+            write(file, r)
+          end
+        end
+      end
+    end
+  end
+
   def load
     log("load event=open")
     file = @path ? File.open(@path, "r") : $stdin
@@ -65,10 +94,6 @@ def load
     end
   end
 
-  def sink
-    raise("sink'ing, how does it work?")
-  end
-
   def log(msg)
     $stderr.puts("gorg #{msg}") if @log
   end