split jobs into provenance chart and job list

[arvados.git] / app / controllers / collections_controller.rb

diff --git a/app/controllers/collections_controller.rb b/app/controllers/collections_controller.rb
index 09d4fe5c884ef5bb3c1796dce8fadcb342a3e088..e76dfbadca18fac70902ff0cdea243661999d8b1 100644 (file)
--- a/app/controllers/collections_controller.rb
+++ b/app/controllers/collections_controller.rb
@@ -1,14 +1,18 @@
 class CollectionsController < ApplicationController
   before_filter :ensure_current_user_is_admin
+  skip_before_filter :find_object_by_uuid, :only => [:graph]
 
   def graph
     index
   end
 
   def index
-    @links = Link.eager.where(head_kind: 'orvos#collection') |
-      Link.eager.where(tail_kind: 'orvos#collection')
+    @links = Link.eager.limit(100).where(head_kind: 'orvos#collection') |
+      Link.eager.limit(100).where(tail_kind: 'orvos#collection')
     @collections = {}
+    Collection.limit(100).where({}).each do |c|
+      @collections[c.uuid] = {uuid: c.uuid}
+    end
     @links.each do |l|
       if l.head_kind == 'orvos#collection'
         c = (@collections[l.head_uuid] ||= {uuid: l.head_uuid})
@@ -34,4 +38,48 @@ class CollectionsController < ApplicationController
       end
     end
   end
+
+  def show
+    return super if !@object
+    @provenance = []
+    @output2job = {}
+    @output2colorindex = {}
+    @sourcedata = {params[:uuid] => {uuid: params[:uuid]}}
+    @protected = {}
+    whence = `whence #{params[:uuid]}`
+    colorindex = -1
+    whence.split("\n").each do |line|
+      if line.match /^(\#\d+@\S+)$/
+        job = Job.where(submit_id: line).first
+        @provenance << {job: job, target: line}
+      elsif (re = line.match /^ +output *= *(\S+)/)
+        if !@provenance.empty?
+          @provenance[-1][:output] = re[1]
+          @output2job[re[1]] = @provenance[-1][:job]
+          if !@output2colorindex[re[1]]
+            @output2colorindex[re[1]] = (colorindex += 1) % 10
+          end
+          @sourcedata.delete re[1]
+        end
+      elsif (re = line.match /^([0-9a-f]{32}\b)/)
+        @sourcedata[re[1]] ||= {uuid: re[1]}
+      end
+    end
+    Link.where(head_uuid: @sourcedata.keys | @output2job.keys).each do |link|
+      if link.link_class == 'resources' and link.name == 'wants'
+        @protected[link.head_uuid] = true
+      end
+    end
+    Link.where(tail_uuid: @sourcedata.keys).each do |link|
+      if link.link_class == 'data_origin'
+        @sourcedata[link.tail_uuid][:data_origins] ||= []
+        @sourcedata[link.tail_uuid][:data_origins] << [link.name, link.head_kind, link.head_uuid]
+      end
+    end
+    Collection.where(uuid: @sourcedata.keys).each do |collection|
+      if @sourcedata[collection.uuid]
+        @sourcedata[collection.uuid][:collection] = collection
+      end
+    end
+  end
 end