def self.setup(user, openid_prefix, repo_name=nil, vm_uuid=nil)
login_perm_props = {identity_url_prefix: openid_prefix}
- if user[:uuid]
- found = User.find_by_uuid user[:uuid]
- end
-
- if !found
- if !user[:email]
- raise "No email found in the input. Aborting user creation."
- end
-
- if !user.save
- raise "Save failed"
- end
- else
- user = found
- end
- # Check opd_login_perm
- oid_login_perm = Link.where(tail_uuid: user[:email],
- head_kind: 'arvados#user',
- link_class: 'permission',
- name: 'can_login')
+ # Check oid_login_perm
+ oid_login_perms = Link.where(tail_uuid: user.email,
+ head_kind: 'arvados#user',
+ link_class: 'permission',
+ name: 'can_login')
- if !oid_login_perm.any?
+ if !oid_login_perms.any?
# create openid login permission
oid_login_perm = Link.create(link_class: 'permission',
name: 'can_login',
tail_kind: 'email',
- tail_uuid: user[:email],
+ tail_uuid: user.email,
head_kind: 'arvados#user',
- head_uuid: user[:uuid],
+ head_uuid: user.uuid,
properties: login_perm_props
)
logger.info { "openid login permission: " + oid_login_perm[:uuid] }
+ else
+ oid_login_perm = oid_login_perms.first
end
- # create repo, vm, and group links
- response = {user: user, oid_login_perm: oid_login_perm}
-
- user.setup_links(repo_name, vm_uuid, openid_prefix, response)
-
- return response
+ return [oid_login_perm] + user.setup_repo_vm_links(repo_name, vm_uuid)
end
# create links
- def setup_links(repo_name, vm_uuid, openid_prefix, response)
+ def setup_repo_vm_links(repo_name, vm_uuid)
repo_perm = create_user_repo_link repo_name
- if repo_perm
- response[:repo_perm] = repo_perm
+ vm_login_perm = create_vm_login_permission_link vm_uuid, repo_name
+ group_perm = create_user_group_link
+
+ return [repo_perm, vm_login_perm, group_perm, self].compact
+ end
+
+ # delete user signatures, login, repo, and vm perms, and mark as inactive
+ def unsetup
+ # delete oid_login_perms for this user
+ oid_login_perms = Link.where(tail_uuid: self.email,
+ head_kind: 'arvados#user',
+ link_class: 'permission',
+ name: 'can_login')
+ oid_login_perms.each do |perm|
+ Link.delete perm
end
- vm_login_perm = create_vm_login_permission_link vm_uuid, repo_name
- if vm_login_perm
- response[:vm_login_perm] = vm_login_perm
+ # delete repo_perms for this user
+ repo_perms = Link.where(tail_uuid: self.uuid,
+ head_kind: 'arvados#repository',
+ link_class: 'permission',
+ name: 'can_write')
+ repo_perms.each do |perm|
+ Link.delete perm
end
- group_perm = create_user_group_links
- if group_perm
- response[:group_perm] = group_perm
+ # delete vm_login_perms for this user
+ vm_login_perms = Link.where(tail_uuid: self.uuid,
+ head_kind: 'arvados#virtualMachine',
+ link_class: 'permission',
+ name: 'can_login')
+ vm_login_perms.each do |perm|
+ Link.delete perm
+ end
+
+ # delete any signatures by this user
+ signed_uuids = Link.where(link_class: 'signature',
+ tail_kind: 'arvados#user',
+ tail_uuid: self.uuid)
+ signed_uuids.each do |sign|
+ Link.delete sign
end
+
+ # mark the user as inactive
+ self.is_active = false
+ self.save!
+
+ return self
end
protected
logger.info { "vm uuid: " + vm[:uuid] }
- login_perm = Link.where(tail_uuid: self.uuid,
+ login_perms = Link.where(tail_uuid: self.uuid,
head_uuid: vm[:uuid],
head_kind: 'arvados#virtualMachine',
link_class: 'permission',
name: 'can_login')
- if !login_perm.any?
+ if !login_perms.any?
login_perm = Link.create(tail_kind: 'arvados#user',
tail_uuid: self.uuid,
head_kind: 'arvados#virtualMachine',
name: 'can_login',
properties: {username: repo_name})
logger.info { "login permission: " + login_perm[:uuid] }
+ else
+ login_perm = login_perms.first
end
return login_perm
end
# add the user to the 'All users' group
- def create_user_group_links
+ def create_user_group_link
# Look up the "All users" group (we expect uuid *-*-fffffffffffffff).
group = Group.where(name: 'All users').select do |g|
g[:uuid].match /-f+$/
else
logger.info { "\"All users\" group uuid: " + group[:uuid] }
- group_perm = Link.where(tail_uuid: self.uuid,
+ group_perms = Link.where(tail_uuid: self.uuid,
head_uuid: group[:uuid],
head_kind: 'arvados#group',
link_class: 'permission',
name: 'can_read')
- if !group_perm.any?
+ if !group_perms.any?
group_perm = Link.create(tail_kind: 'arvados#user',
tail_uuid: self.uuid,
head_kind: 'arvados#group',
link_class: 'permission',
name: 'can_read')
logger.info { "group permission: " + group_perm[:uuid] }
+ else
+ group_perm = group_perms.first
end
return group_perm