apps/workbench/app/controllers/projects_controller.rb

   1 class ProjectsController < ApplicationController
   2   before_filter :set_share_links, if: -> { defined? @object and @object}
   3   skip_around_filter :require_thread_api_token, if: proc { |ctrl|
   4     Rails.configuration.anonymous_user_token and
   5     %w(show tab_counts public).include? ctrl.action_name
   6   }
   7
   8   def model_class
   9     Group
  10   end
  11
  12   def find_object_by_uuid
  13     if (current_user and params[:uuid] == current_user.uuid) or
  14        (resource_class_for_uuid(params[:uuid]) == User)
  15       if params[:uuid] != current_user.uuid
  16         @object = User.find(params[:uuid])
  17       else
  18         @object = current_user.dup
  19         @object.uuid = current_user.uuid
  20       end
  21
  22       class << @object
  23         def name
  24           if current_user.uuid == self.uuid
  25             'Home'
  26           else
  27             "Home for #{self.email}"
  28           end
  29         end
  30         def description
  31           ''
  32         end
  33         def attribute_editable? attr, *args
  34           case attr
  35           when 'description', 'name'
  36             false
  37           else
  38             super
  39           end
  40         end
  41       end
  42     else
  43       super
  44     end
  45   end
  46
  47   def index_pane_list
  48     %w(Projects)
  49   end
  50
  51   # Returning an array of hashes instead of an array of strings will allow
  52   # us to tell the interface to get counts for each pane (using :filters).
  53   # It also seems to me that something like these could be used to configure the contents of the panes.
  54   def show_pane_list
  55     pane_list = []
  56     if @object.uuid != current_user.andand.uuid
  57       pane_list << 'Description'
  58     end
  59     pane_list <<
  60       {
  61         :name => 'Data_collections',
  62         :filters => [%w(uuid is_a arvados#collection)]
  63       }
  64     pane_list <<
  65       {
  66         :name => 'Jobs_and_pipelines',
  67         :filters => [%w(uuid is_a) + [%w(arvados#job arvados#pipelineInstance)]]
  68       }
  69     pane_list <<
  70       {
  71         :name => 'Pipeline_templates',
  72         :filters => [%w(uuid is_a arvados#pipelineTemplate)]
  73       }
  74     pane_list <<
  75       {
  76         :name => 'Subprojects',
  77         :filters => [%w(uuid is_a arvados#group)]
  78       }
  79     pane_list <<
  80       {
  81         :name => 'Other_objects',
  82         :filters => [%w(uuid is_a) + [%w(arvados#human arvados#specimen arvados#trait)]]
  83       } if current_user
  84     pane_list << { :name => 'Sharing',
  85                    :count => @share_links.count } if @user_is_manager
  86     pane_list << { :name => 'Advanced' }
  87   end
  88
  89   # Called via AJAX and returns Javascript that populates tab counts into tab titles.
  90   # References #show_pane_list action which should return an array of hashes each with :name
  91   # and then optionally a :filters to run or a straight up :count
  92   #
  93   # This action could easily be moved to the ApplicationController to genericize the tab_counts behaviour,
  94   # but one or more new routes would have to be created, the js.erb would also have to be moved
  95   def tab_counts
  96     @tab_counts = {}
  97     show_pane_list.each do |pane|
  98       if pane.is_a?(Hash)
  99         if pane[:count]
 100           @tab_counts[pane[:name]] = pane[:count]
 101         elsif pane[:filters]
 102           @tab_counts[pane[:name]] = @object.contents(filters: pane[:filters]).items_available
 103         end
 104       end
 105     end
 106   end
 107
 108   def remove_item
 109     params[:item_uuids] = [params[:item_uuid]]
 110     remove_items
 111     render template: 'projects/remove_items'
 112   end
 113
 114   def remove_items
 115     @removed_uuids = []
 116     links = []
 117     params[:item_uuids].collect { |uuid| ArvadosBase.find uuid }.each do |item|
 118       if (item.class == Link and
 119           item.link_class == 'name' and
 120           item.tail_uuid == @object.uuid)
 121         # Given uuid is a name link, linking an object to this
 122         # project. First follow the link to find the item we're removing,
 123         # then delete the link.
 124         links << item
 125         item = ArvadosBase.find item.head_uuid
 126       else
 127         # Given uuid is an object. Delete all names.
 128         links += Link.where(tail_uuid: @object.uuid,
 129                             head_uuid: item.uuid,
 130                             link_class: 'name')
 131       end
 132       links.each do |link|
 133         @removed_uuids << link.uuid
 134         link.destroy
 135       end
 136
 137       # If this object has the 'expires_at' attribute, then simply mark it
 138       # expired.
 139       if item.attributes.include?("expires_at")
 140         item.update_attributes expires_at: Time.now
 141         @removed_uuids << item.uuid
 142       elsif item.owner_uuid == @object.uuid
 143         # Object is owned by this project. Remove it from the project by
 144         # changing owner to the current user.
 145         begin
 146           item.update_attributes owner_uuid: current_user.uuid
 147           @removed_uuids << item.uuid
 148         rescue ArvadosApiClient::ApiErrorResponseException => e
 149           if e.message.include? '_owner_uuid_name_unique'
 150             rename_to = item.name + ' removed from ' +
 151                         (@object.name ? @object.name : @object.uuid) +
 152                         ' at ' + Time.now.to_s
 153             updates = {}
 154             updates[:name] = rename_to
 155             updates[:owner_uuid] = current_user.uuid
 156             item.update_attributes updates
 157             @removed_uuids << item.uuid
 158           else
 159             raise
 160           end
 161         end
 162       end
 163     end
 164   end
 165
 166   def destroy
 167     while (objects = Link.filter([['owner_uuid','=',@object.uuid],
 168                                   ['tail_uuid','=',@object.uuid]])).any?
 169       objects.each do |object|
 170         object.destroy
 171       end
 172     end
 173     while (objects = @object.contents).any?
 174       objects.each do |object|
 175         object.update_attributes! owner_uuid: current_user.uuid
 176       end
 177     end
 178     if ArvadosBase::resource_class_for_uuid(@object.owner_uuid) == Group
 179       params[:return_to] ||= group_path(@object.owner_uuid)
 180     else
 181       params[:return_to] ||= projects_path
 182     end
 183     super
 184   end
 185
 186   def find_objects_for_index
 187     @objects = all_projects
 188     super
 189   end
 190
 191   def load_contents_objects kinds=[]
 192     kind_filters = @filters.select do |attr,op,val|
 193       op == 'is_a' and val.is_a? Array and val.count > 1
 194     end
 195     if /^created_at\b/ =~ @order[0] and kind_filters.count == 1
 196       # If filtering on multiple types and sorting by date: Get the
 197       # first page of each type, sort the entire set, truncate to one
 198       # page, and use the last item on this page as a filter for
 199       # retrieving the next page. Ideally the API would do this for
 200       # us, but it doesn't (yet).
 201
 202       # To avoid losing items that have the same created_at as the
 203       # last item on this page, we retrieve an overlapping page with a
 204       # "created_at <= last_created_at" filter, then remove duplicates
 205       # with a "uuid not in [...]" filter (see below).
 206       nextpage_operator = /\bdesc$/i =~ @order[0] ? '<=' : '>='
 207
 208       @objects = []
 209       @name_link_for = {}
 210       kind_filters.each do |attr,op,val|
 211         (val.is_a?(Array) ? val : [val]).each do |type|
 212           objects = @object.contents(order: @order,
 213                                      limit: @limit,
 214                                      filters: (@filters - kind_filters + [['uuid', 'is_a', type]]),
 215                                     )
 216           objects.each do |object|
 217             @name_link_for[object.andand.uuid] = objects.links_for(object, 'name').first
 218           end
 219           @objects += objects
 220         end
 221       end
 222       @objects = @objects.to_a.sort_by(&:created_at)
 223       @objects.reverse! if nextpage_operator == '<='
 224       @objects = @objects[0..@limit-1]
 225       @next_page_filters = @filters.reject do |attr,op,val|
 226         (attr == 'created_at' and op == nextpage_operator) or
 227           (attr == 'uuid' and op == 'not in')
 228       end
 229
 230       if @objects.any?
 231         last_created_at = @objects.last.created_at
 232
 233         last_uuids = []
 234         @objects.each do |obj|
 235           last_uuids << obj.uuid if obj.created_at.eql?(last_created_at)
 236         end
 237
 238         @next_page_filters += [['created_at',
 239                                 nextpage_operator,
 240                                 last_created_at]]
 241         @next_page_filters += [['uuid', 'not in', last_uuids]]
 242         @next_page_href = url_for(partial: :contents_rows,
 243                                   limit: @limit,
 244                                   filters: @next_page_filters.to_json)
 245       else
 246         @next_page_href = nil
 247       end
 248     else
 249       @objects = @object.contents(order: @order,
 250                                   limit: @limit,
 251                                   filters: @filters,
 252                                   offset: @offset)
 253       @next_page_href = next_page_href(partial: :contents_rows,
 254                                        filters: @filters.to_json,
 255                                        order: @order.to_json)
 256     end
 257
 258     preload_links_for_objects(@objects.to_a)
 259   end
 260
 261   def show
 262     if !@object
 263       return render_not_found("object not found")
 264     end
 265
 266     if params[:partial]
 267       load_contents_objects
 268       respond_to do |f|
 269         f.json {
 270           render json: {
 271             content: render_to_string(partial: 'show_contents_rows.html',
 272                                       formats: [:html]),
 273             next_page_href: @next_page_href
 274           }
 275         }
 276       end
 277     else
 278       @objects = []
 279       super
 280     end
 281   end
 282
 283   def create
 284     @new_resource_attrs = (params['project'] || {}).merge(group_class: 'project')
 285     @new_resource_attrs[:name] ||= 'New project'
 286     super
 287   end
 288
 289   def update
 290     @updates = params['project']
 291     super
 292   end
 293
 294   helper_method :get_objects_and_names
 295   def get_objects_and_names(objects=nil)
 296     objects = @objects if objects.nil?
 297     objects_and_names = []
 298     objects.each do |object|
 299       if objects.respond_to? :links_for and
 300           !(name_links = objects.links_for(object, 'name')).empty?
 301         name_links.each do |name_link|
 302           objects_and_names << [object, name_link]
 303         end
 304       elsif @name_link_for.andand[object.uuid]
 305         objects_and_names << [object, @name_link_for[object.uuid]]
 306       elsif object.respond_to? :name
 307         objects_and_names << [object, object]
 308       else
 309         objects_and_names << [object,
 310                                Link.new(owner_uuid: @object.uuid,
 311                                         tail_uuid: @object.uuid,
 312                                         head_uuid: object.uuid,
 313                                         link_class: "name",
 314                                         name: "")]
 315
 316       end
 317     end
 318     objects_and_names
 319   end
 320
 321   def public  # Yes 'public' is the name of the action for public projects
 322     return render_not_found if not Rails.configuration.anonymous_user_token or not Rails.configuration.enable_public_projects_page
 323     @objects = using_specific_api_token Rails.configuration.anonymous_user_token do
 324       Group.where(group_class: 'project').order("updated_at DESC")
 325     end
 326   end
 327 end