1 class UsersController < ApplicationController
2 skip_before_filter :find_object_by_uuid, :only => [:welcome, :activity, :storage]
3 skip_around_filter :thread_with_mandatory_api_token, :only => :welcome
4 before_filter :ensure_current_user_is_admin, only: [:sudo, :unsetup, :setup]
8 params[:action] = 'home'
14 @breadcrumb_page_name = nil
15 @users = User.limit(params[:limit] || 1000).all
20 pipeline_instances: {}
23 @spans = [['This week', Time.now.beginning_of_week, Time.now],
25 Time.now.beginning_of_week.advance(weeks:-1),
26 Time.now.beginning_of_week],
27 ['This month', Time.now.beginning_of_month, Time.now],
29 1.month.ago.beginning_of_month,
30 Time.now.beginning_of_month]]
31 @spans.each do |span, threshold_start, threshold_end|
32 @activity[:logins][span] = Log.
33 filter([[:event_type, '=', 'login'],
34 [:object_kind, '=', 'arvados#user'],
35 [:created_at, '>=', threshold_start],
36 [:created_at, '<', threshold_end]])
37 @activity[:jobs][span] = Job.
38 filter([[:created_at, '>=', threshold_start],
39 [:created_at, '<', threshold_end]])
40 @activity[:pipeline_instances][span] = PipelineInstance.
41 filter([[:created_at, '>=', threshold_start],
42 [:created_at, '<', threshold_end]])
43 @activity.each do |type, act|
46 @user_activity[u.uuid] ||= {}
47 @user_activity[u.uuid][span + ' ' + type.to_s] ||= 0
49 records.each do |record|
50 @user_activity[record.modified_by_user_uuid] ||= {}
51 @user_activity[record.modified_by_user_uuid][span + ' ' + type.to_s] ||= 0
52 @user_activity[record.modified_by_user_uuid][span + ' ' + type.to_s] += 1
53 @total_activity[span + ' ' + type.to_s] ||= 0
54 @total_activity[span + ' ' + type.to_s] += 1
58 @users = @users.sort_by do |a|
59 [-@user_activity[a.uuid].values.inject(:+), a.full_name]
61 # Prepend a "Total" pseudo-user to the sorted list
62 @user_activity[nil] = @total_activity
63 @users = [OpenStruct.new(uuid: nil)] + @users
67 @breadcrumb_page_name = nil
68 @users = User.limit(params[:limit] || 1000).all
71 @user_storage[u.uuid] ||= {}
73 # filter([[:object_uuid, '=', u.uuid],
74 # [:event_type, '=', 'user-storage-report']])
75 filter([[:object_uuid, '=', u.uuid],
76 [:event_type, '=', 'user-storage-report']]).
77 order(:created_at => :desc).
79 storage_log.each do |log_entry|
80 @user_storage[u.uuid] = log_entry['properties']
83 @users = @users.sort_by do |u|
84 [-@user_storage[u.uuid].values.push(0).inject(:+), u.full_name]
89 if current_user.andand.is_admin
97 if current_user.andand.is_admin
105 resp = $arvados_api_client.api(ApiClientAuthorization, '', {
106 api_client_authorization: {
107 owner_uuid: @object.uuid
110 redirect_to root_url(api_token: resp[:api_token])
114 @showallalerts = false
115 @my_ssh_keys = AuthorizedKey.where(authorized_user_uuid: current_user.uuid)
120 order('created_at desc').
121 where(created_by: current_user.uuid)
123 @my_collections = Collection.
125 order('created_at desc').
126 where(created_by: current_user.uuid)
128 Link.limit(1000).where(head_uuid: @my_collections.collect(&:uuid),
129 link_class: 'tag').each do |link|
130 (@my_tag_links[link.head_uuid] ||= []) << link
133 @my_pipelines = PipelineInstance.
135 order('created_at desc').
136 where(created_by: current_user.uuid)
139 # A Tutorial is a Link which has link_class "resources" and name
140 # "wants", and is owned by the Tutorials Group (i.e., named
141 # "Arvados Tutorials" and owned by the system user).
142 @tutorial_group = Group.where(owner_uuid: User.system.uuid,
143 name: 'Arvados Tutorials').first
145 @tutorial_links = Link.where(tail_uuid: @tutorial_group.uuid,
146 link_class: 'resources',
151 @tutorial_complete = {
152 'Run a job' => @my_last_job
155 f.js { render template: 'users/home.js' }
156 f.html { render template: 'users/home' }
161 if current_user.andand.is_admin
168 respond_to do |format|
169 if current_user.andand.is_admin
171 setup_params[:send_notification_email] = "#{Rails.configuration.send_user_setup_notification_email}"
172 if params['user_uuid'] && params['user_uuid'].size>0
173 setup_params[:uuid] = params['user_uuid']
175 if params['email'] && params['email'].size>0
176 user = {email: params['email']}
177 setup_params[:user] = user
179 if params['openid_prefix'] && params['openid_prefix'].size>0
180 setup_params[:openid_prefix] = params['openid_prefix']
182 if params['repo_name'] && params['repo_name'].size>0
183 setup_params[:repo_name] = params['repo_name']
185 if params['vm_uuid'] && params['vm_uuid'].size>0
186 setup_params[:vm_uuid] = params['vm_uuid']
189 if User.setup setup_params
192 self.render_error status: 422
195 self.render_error status: 422
201 @vms = VirtualMachine.all.results
203 @current_selections = find_current_links @object
205 respond_to do |format|
213 def find_current_links user
214 current_selections = {}
217 return current_selections
221 oid_login_perms = Link.where(tail_uuid: user.email,
222 head_kind: 'arvados#user',
223 link_class: 'permission',
226 if oid_login_perms.any?
227 prefix_properties = oid_login_perms.first.properties
228 current_selections[:identity_url_prefix] = prefix_properties[:identity_url_prefix]
232 repo_perms = Link.where(tail_uuid: user.uuid,
233 head_kind: 'arvados#repository',
234 link_class: 'permission',
237 repo_uuid = repo_perms.first.head_uuid
238 repos = Repository.where(head_uuid: repo_uuid)
240 repo_name = repos.first.name
241 current_selections[:repo_name] = repo_name
246 vm_login_perms = Link.where(tail_uuid: user.uuid,
247 head_kind: 'arvados#virtualMachine',
248 link_class: 'permission',
250 if vm_login_perms.any?
251 vm_uuid = vm_login_perms.first.head_uuid
252 current_selections[:vm_uuid] = vm_uuid
255 return current_selections