Merge branch '13306-arvados-cwl-runner-py3-support'
[arvados.git] / apps / workbench / app / controllers / trash_items_controller.rb
1 # Copyright (C) The Arvados Authors. All rights reserved.
2 #
3 # SPDX-License-Identifier: AGPL-3.0
4
5 class TrashItemsController < ApplicationController
6   def model_class
7     Collection
8   end
9
10   def index_pane_list
11     %w(Trashed_collections Trashed_projects)
12   end
13
14   def find_objects_for_index
15     # If it's not the index rows partial display, just return
16     # The /index request will again be invoked to display the
17     # partial at which time, we will be using the objects found.
18     return if !params[:partial]
19
20     trashed_items
21
22     if @objects.any?
23       @objects = @objects.sort_by { |obj| obj.modified_at }.reverse
24       @next_page_filters = next_page_filters('<=')
25       @next_page_href = url_for(partial: params[:partial],
26                                 filters: @next_page_filters.to_json)
27     else
28       @next_page_href = nil
29     end
30   end
31
32   def next_page_href with_params={}
33     @next_page_href
34   end
35
36   def next_page_filters nextpage_operator
37     next_page_filters = @filters.reject do |attr, op, val|
38       (attr == 'modified_at' and op == nextpage_operator) or
39       (attr == 'uuid' and op == 'not in')
40     end
41
42     if @objects.any?
43       last_trash_at = @objects.last.modified_at
44
45       last_uuids = []
46       @objects.each do |obj|
47         last_uuids << obj.uuid if obj.trash_at.eql?(last_trash_at)
48       end
49
50       next_page_filters += [['modified_at', nextpage_operator, last_trash_at]]
51       next_page_filters += [['uuid', 'not in', last_uuids]]
52     end
53
54     next_page_filters
55   end
56
57   def trashed_items
58     if params[:partial] == "trashed_collection_rows"
59       query_on = Collection
60     elsif params[:partial] == "trashed_project_rows"
61       query_on = Group
62     end
63
64     last_mod_at = nil
65     last_uuids = []
66
67     # API server index doesn't return manifest_text by default, but our
68     # callers want it unless otherwise specified.
69     #@select ||= query_on.columns.map(&:name) - %w(id updated_at)
70     limit = if params[:limit] then params[:limit].to_i else 100 end
71     offset = if params[:offset] then params[:offset].to_i else 0 end
72
73     @objects = []
74     while !@objects.any?
75       base_search = query_on
76
77       if !last_mod_at.nil?
78         base_search = base_search.filter([["modified_at", "<=", last_mod_at], ["uuid", "not in", last_uuids]])
79       end
80
81       base_search = base_search.include_trash(true).limit(limit).offset(offset)
82
83       if params[:filters].andand.length.andand > 0
84         tags = Link.filter(params[:filters])
85         tagged = []
86         if tags.results.length > 0
87           tagged = query_on.include_trash(true).where(uuid: tags.collect(&:head_uuid))
88         end
89         @objects = (tagged | base_search.filter(params[:filters])).uniq(&:uuid)
90       else
91         @objects = base_search.where(is_trashed: true)
92       end
93
94       if @objects.any?
95         owner_uuids = @objects.collect(&:owner_uuid).uniq
96         @owners = {}
97         @not_trashed = {}
98         Group.filter([["uuid", "in", owner_uuids]]).include_trash(true).each do |grp|
99           @owners[grp.uuid] = grp
100         end
101         User.filter([["uuid", "in", owner_uuids]]).include_trash(true).each do |grp|
102           @owners[grp.uuid] = grp
103           @not_trashed[grp.uuid] = true
104         end
105         Group.filter([["uuid", "in", owner_uuids]]).select([:uuid]).each do |grp|
106           @not_trashed[grp.uuid] = true
107         end
108       else
109         return
110       end
111
112       last_mod_at = @objects.last.modified_at
113       last_uuids = []
114       @objects.each do |obj|
115         last_uuids << obj.uuid if obj.modified_at.eql?(last_mod_at)
116       end
117
118       @objects = @objects.select {|item| item.is_trashed || @not_trashed[item.owner_uuid].nil? }
119     end
120   end
121
122   def untrash_items
123     @untrashed_uuids = []
124
125     updates = {trash_at: nil}
126
127     if params[:selection].is_a? Array
128       klass = resource_class_for_uuid(params[:selection][0])
129     else
130       klass = resource_class_for_uuid(params[:selection])
131     end
132
133     first = nil
134     klass.include_trash(1).where(uuid: params[:selection]).each do |c|
135       first = c
136       c.untrash
137       @untrashed_uuids << c.uuid
138     end
139
140     respond_to do |format|
141       format.js
142       format.html do
143         redirect_to first
144       end
145     end
146   end
147 end