apps/workbench/app/controllers/actions_controller.rb

   1 class ActionsController < ApplicationController
   2
   3   skip_filter :require_thread_api_token, only: [:report_issue_popup, :report_issue]
   4   skip_filter :check_user_agreements, only: [:report_issue_popup, :report_issue]
   5
   6   @@exposed_actions = {}
   7   def self.expose_action method, &block
   8     @@exposed_actions[method] = true
   9     define_method method, block
  10   end
  11
  12   def model_class
  13     ArvadosBase::resource_class_for_uuid(params[:uuid])
  14   end
  15
  16   def show
  17     @object = model_class.andand.find(params[:uuid])
  18     if @object.is_a? Link and
  19         @object.link_class == 'name' and
  20         ArvadosBase::resource_class_for_uuid(@object.head_uuid) == Collection
  21       redirect_to collection_path(id: @object.uuid)
  22     elsif @object
  23       redirect_to @object
  24     else
  25       raise ActiveRecord::RecordNotFound
  26     end
  27   end
  28
  29   def post
  30     params.keys.collect(&:to_sym).each do |param|
  31       if @@exposed_actions[param]
  32         return self.send(param)
  33       end
  34     end
  35     redirect_to :back
  36   end
  37
  38   expose_action :copy_selections_into_project do
  39     move_or_copy :copy
  40   end
  41
  42   expose_action :move_selections_into_project do
  43     move_or_copy :move
  44   end
  45
  46   def move_or_copy action
  47     uuids_to_add = params["selection"]
  48     uuids_to_add = [ uuids_to_add ] unless uuids_to_add.is_a? Array
  49     uuids_to_add.
  50       collect { |x| ArvadosBase::resource_class_for_uuid(x) }.
  51       uniq.
  52       each do |resource_class|
  53       resource_class.filter([['uuid','in',uuids_to_add]]).each do |src|
  54         if resource_class == Collection and not Collection.attribute_info.include?(:name)
  55           dst = Link.new(owner_uuid: @object.uuid,
  56                          tail_uuid: @object.uuid,
  57                          head_uuid: src.uuid,
  58                          link_class: 'name',
  59                          name: src.uuid)
  60         else
  61           case action
  62           when :copy
  63             dst = src.dup
  64             if dst.respond_to? :'name='
  65               if dst.name
  66                 dst.name = "Copy of #{dst.name}"
  67               else
  68                 dst.name = "Copy of unnamed #{dst.class_for_display.downcase}"
  69               end
  70             end
  71             if resource_class == Collection
  72               dst.manifest_text = Collection.select([:manifest_text]).where(uuid: src.uuid).first.manifest_text
  73             end
  74           when :move
  75             dst = src
  76           else
  77             raise ArgumentError.new "Unsupported action #{action}"
  78           end
  79           dst.owner_uuid = @object.uuid
  80           dst.tail_uuid = @object.uuid if dst.class == Link
  81         end
  82         begin
  83           dst.save!
  84         rescue
  85           dst.name += " (#{Time.now.localtime})" if dst.respond_to? :name=
  86           dst.save!
  87         end
  88       end
  89     end
  90     redirect_to @object
  91   end
  92
  93   def arv_normalize mt, *opts
  94     r = ""
  95     env = Hash[ENV].
  96       merge({'ARVADOS_API_HOST' =>
  97               arvados_api_client.arvados_v1_base.
  98               sub(/\/arvados\/v1/, '').
  99               sub(/^https?:\/\//, ''),
 100               'ARVADOS_API_TOKEN' => 'x',
 101               'ARVADOS_API_HOST_INSECURE' =>
 102               Rails.configuration.arvados_insecure_https ? 'true' : 'false'
 103             })
 104     IO.popen([env, 'arv-normalize'] + opts, 'w+b') do |io|
 105       io.write mt
 106       io.close_write
 107       while buf = io.read(2**16)
 108         r += buf
 109       end
 110     end
 111     r
 112   end
 113
 114   expose_action :combine_selected_files_into_collection do
 115     lst = []
 116     files = []
 117     params["selection"].each do |s|
 118       a = ArvadosBase::resource_class_for_uuid s
 119       m = nil
 120       if a == Link
 121         begin
 122           m = CollectionsHelper.match(Link.find(s).head_uuid)
 123         rescue
 124         end
 125       else
 126         m = CollectionsHelper.match(s)
 127       end
 128
 129       if m and m[1] and m[2]
 130         lst.append(m[1] + m[2])
 131         files.append(m)
 132       end
 133     end
 134
 135     collections = Collection.where(uuid: lst)
 136
 137     chash = {}
 138     collections.each do |c|
 139       c.reload()
 140       chash[c.uuid] = c
 141     end
 142
 143     combined = ""
 144     files.each do |m|
 145       mt = chash[m[1]+m[2]].manifest_text
 146       if m[4]
 147         combined += arv_normalize mt, '--extract', m[4][1..-1]
 148       else
 149         combined += chash[m[1]+m[2]].manifest_text
 150       end
 151     end
 152
 153     normalized = arv_normalize combined
 154     newc = Collection.new({:manifest_text => normalized})
 155     newc.save!
 156
 157     chash.each do |k,v|
 158       l = Link.new({
 159                      tail_uuid: k,
 160                      head_uuid: newc.uuid,
 161                      link_class: "provenance",
 162                      name: "provided"
 163                    })
 164       l.save!
 165     end
 166
 167     redirect_to controller: 'collections', action: :show, id: newc.uuid
 168   end
 169
 170   def report_issue_popup
 171     respond_to do |format|
 172       format.js
 173       format.html
 174     end
 175   end
 176
 177   def report_issue
 178     logger.warn "report_issue: #{params.inspect}"
 179
 180     respond_to do |format|
 181       IssueReporter.send_report(current_user, params).deliver
 182       format.js {render nothing: true}
 183     end
 184   end
 185
 186 end