list_batches

src/main/ruby/lib/merritt_zk_batch.rb

@@ -191,5 +191,24 @@ def delete(zk)
       # puts "DELETE #{path}"
       zk.rm_rf(path)
     end
+
+    def self.list_batches_as_json(zk)
+      batches = []
+      zk.children(DIR).sort.each do |cp|
+
+        begin
+          batch = Batch.new(cp)
+          batch.load(zk)
+          batchjson = batch.data
+          batchjson[:id] = batch.id
+          batchjson[:status] = batch.status_name
+          batches.append(batchjson)
+        rescue StandardError => e
+          puts "List Batch #{cp} exception: #{e}"
+        end
+      end
+      batches
+    end
   end
+
 end

src/main/ruby/spec/zk_spec.rb

@@ -446,6 +446,10 @@ def make_batch_json(s = 'bar', u = 'bid-uuid')
       expect(arr.length).to eq(1)
       expect(arr[0].id).to eq(@remap['jid1'])
 
+      # Only for Ruby interface
+      arr = MerrittZK::Batch.list_batches_as_json(@zk)
+      expect(arr.length).to eq(1)
+
       jj.set_status(@zk, MerrittZK::JobState::Deleted)
 
       bbbb.set_status(@zk, MerrittZK::BatchState::Deleted)