3504: Support copy and moving collections on new apiserver
[arvados.git] / apps / workbench / app / controllers / projects_controller.rb
1 class ProjectsController < ApplicationController
2   def model_class
3     Group
4   end
5
6   def find_object_by_uuid
7     if current_user and params[:uuid] == current_user.uuid
8       @object = current_user.dup
9       @object.uuid = current_user.uuid
10       class << @object
11         def name
12           'Home'
13         end
14         def description
15           ''
16         end
17         def attribute_editable? attr, *args
18           case attr
19           when 'description', 'name'
20             false
21           else
22             super
23           end
24         end
25       end
26     else
27       super
28     end
29   end
30
31   def index_pane_list
32     %w(Projects)
33   end
34
35   def show_pane_list
36     if @user_is_manager
37       %w(Data_collections Jobs_and_pipelines Pipeline_templates Subprojects Other_objects Sharing Advanced)
38     else
39       %w(Data_collections Jobs_and_pipelines Pipeline_templates Subprojects Other_objects Advanced)
40     end
41   end
42
43   def remove_item
44     params[:item_uuids] = [params[:item_uuid]]
45     remove_items
46     render template: 'projects/remove_items'
47   end
48
49   def remove_items
50     @removed_uuids = []
51     links = []
52     params[:item_uuids].collect { |uuid| ArvadosBase.find uuid }.each do |item|
53       if (item.class == Link and
54           item.link_class == 'name' and
55           item.tail_uuid == @object.uuid)
56         # Given uuid is a name link, linking an object to this
57         # project. First follow the link to find the item we're removing,
58         # then delete the link.
59         links << item
60         item = ArvadosBase.find item.head_uuid
61       else
62         # Given uuid is an object. Delete all names.
63         links += Link.where(tail_uuid: @object.uuid,
64                             head_uuid: item.uuid,
65                             link_class: 'name')
66       end
67       links.each do |link|
68         @removed_uuids << link.uuid
69         link.destroy
70       end
71       if item.owner_uuid == @object.uuid
72         # Object is owned by this project. Remove it from the project by
73         # changing owner to the current user.
74         item.update_attributes owner_uuid: current_user.uuid
75         @removed_uuids << item.uuid
76       end
77     end
78   end
79
80   def move_items
81     target_uuid = params['target']
82     uuids_to_add = session[:selected_move_items]
83
84     uuids_to_add.
85       collect { |x| ArvadosBase::resource_class_for_uuid(x) }.
86       uniq.
87       each do |resource_class|
88       resource_class.filter([['uuid','in',uuids_to_add]]).each do |dst|
89         if resource_class == Collection and not Collection.attribute_info.include?(:name)
90           dst = Link.new(owner_uuid: target_uuid,
91                          tail_uuid: target_uuid,
92                          head_uuid: dst.uuid,
93                          link_class: 'name',
94                          name: target_uuid)
95         else
96           dst.owner_uuid = target_uuid
97           dst.tail_uuid = target_uuid if dst.class == Link
98         end
99         dst.save!
100       end
101     end
102     session[:selected_move_items] = nil
103     redirect_to @object
104   end
105
106   def destroy
107     while (objects = Link.filter([['owner_uuid','=',@object.uuid],
108                                   ['tail_uuid','=',@object.uuid]])).any?
109       objects.each do |object|
110         object.destroy
111       end
112     end
113     while (objects = @object.contents(include_linked: false)).any?
114       objects.each do |object|
115         object.update_attributes! owner_uuid: current_user.uuid
116       end
117     end
118     if ArvadosBase::resource_class_for_uuid(@object.owner_uuid) == Group
119       params[:return_to] ||= group_path(@object.owner_uuid)
120     else
121       params[:return_to] ||= projects_path
122     end
123     super
124   end
125
126   def find_objects_for_index
127     @objects = all_projects
128     super
129   end
130
131   def load_contents_objects kinds=[]
132     kind_filters = @filters.select do |attr,op,val|
133       op == 'is_a' and val.is_a? Array and val.count > 1
134     end
135     if /^created_at\b/ =~ @order[0] and kind_filters.count == 1
136       # If filtering on multiple types and sorting by date: Get the
137       # first page of each type, sort the entire set, truncate to one
138       # page, and use the last item on this page as a filter for
139       # retrieving the next page. Ideally the API would do this for
140       # us, but it doesn't (yet).
141       nextpage_operator = /\bdesc$/i =~ @order[0] ? '<' : '>'
142       @objects = []
143       @name_link_for = {}
144       kind_filters.each do |attr,op,val|
145         (val.is_a?(Array) ? val : [val]).each do |type|
146           objects = @object.contents(order: @order,
147                                      limit: @limit,
148                                      include_linked: true,
149                                      filters: (@filters - kind_filters + [['uuid', 'is_a', type]]),
150                                      offset: @offset)
151           objects.each do |object|
152             @name_link_for[object.andand.uuid] = objects.links_for(object, 'name').first
153           end
154           @objects += objects
155         end
156       end
157       @objects = @objects.to_a.sort_by(&:created_at)
158       @objects.reverse! if nextpage_operator == '<'
159       @objects = @objects[0..@limit-1]
160       @next_page_filters = @filters.reject do |attr,op,val|
161         attr == 'created_at' and op == nextpage_operator
162       end
163       if @objects.any?
164         @next_page_filters += [['created_at',
165                                 nextpage_operator,
166                                 @objects.last.created_at]]
167         @next_page_href = url_for(partial: :contents_rows,
168                                   filters: @next_page_filters.to_json)
169       else
170         @next_page_href = nil
171       end
172     else
173       @objects = @object.contents(order: @order,
174                                   limit: @limit,
175                                   include_linked: true,
176                                   filters: @filters,
177                                   offset: @offset)
178       @next_page_href = next_page_href(partial: :contents_rows)
179     end
180
181     preload_links_for_objects(@objects.to_a)
182   end
183
184   def show
185     if !@object
186       return render_not_found("object not found")
187     end
188
189     @user_is_manager = false
190     @share_links = []
191     if @object.uuid != current_user.uuid
192       begin
193         @share_links = Link.permissions_for(@object)
194         @user_is_manager = true
195       rescue ArvadosApiClient::AccessForbiddenException,
196         ArvadosApiClient::NotFoundException
197       end
198     end
199
200     if params[:partial]
201       load_contents_objects
202       respond_to do |f|
203         f.json {
204           render json: {
205             content: render_to_string(partial: 'show_contents_rows.html',
206                                       formats: [:html]),
207             next_page_href: @next_page_href
208           }
209         }
210       end
211     else
212       @objects = []
213       super
214     end
215   end
216
217   def create
218     @new_resource_attrs = (params['project'] || {}).merge(group_class: 'project')
219     @new_resource_attrs[:name] ||= 'New project'
220     super
221   end
222
223   def update
224     @updates = params['project']
225     super
226   end
227
228   helper_method :get_objects_and_names
229   def get_objects_and_names(objects=nil)
230     objects = @objects if objects.nil?
231     objects_and_names = []
232     objects.each do |object|
233       if objects.respond_to? :links_for and
234           !(name_links = objects.links_for(object, 'name')).empty?
235         name_links.each do |name_link|
236           objects_and_names << [object, name_link]
237         end
238       elsif @name_link_for.andand[object.uuid]
239         objects_and_names << [object, @name_link_for[object.uuid]]
240       elsif object.respond_to? :name
241         objects_and_names << [object, object]
242       else
243         objects_and_names << [object,
244                                Link.new(owner_uuid: @object.uuid,
245                                         tail_uuid: @object.uuid,
246                                         head_uuid: object.uuid,
247                                         link_class: "name",
248                                         name: "")]
249       end
250     end
251     objects_and_names
252   end
253
254   def share_with
255     if not params[:uuids].andand.any?
256       @errors = ["No user/group UUIDs specified to share with."]
257       return render_error(status: 422)
258     end
259     results = {"success" => [], "errors" => []}
260     params[:uuids].each do |shared_uuid|
261       begin
262         Link.create(tail_uuid: shared_uuid, link_class: "permission",
263                     name: "can_read", head_uuid: @object.uuid)
264       rescue ArvadosApiClient::ApiError => error
265         error_list = error.api_response.andand[:errors]
266         if error_list.andand.any?
267           results["errors"] += error_list.map { |e| "#{shared_uuid}: #{e}" }
268         else
269           error_code = error.api_status || "Bad status"
270           results["errors"] << "#{shared_uuid}: #{error_code} response"
271         end
272       else
273         results["success"] << shared_uuid
274       end
275     end
276     if results["errors"].empty?
277       results.delete("errors")
278       status = 200
279     else
280       status = 422
281     end
282     respond_to do |f|
283       f.json { render(json: results, status: status) }
284     end
285   end
286 end