mirror of
https://github.com/haiwen/seahub.git
synced 2025-08-22 16:56:57 +00:00
admin-rename-lib
This commit is contained in:
wangjianhui
parent
8d196077bf
commit
06c9fb65cc
@ -278,7 +278,7 @@ class AdminLibrary(APIView):
|
|||||||
return Response({'success': True})
|
return Response({'success': True})
|
||||||
|
|
||||||
def put(self, request, repo_id, format=None):
|
def put(self, request, repo_id, format=None):
|
||||||
""" transfer a library
|
""" transfer a library, rename a library
|
||||||
|
|
||||||
Permission checking:
|
Permission checking:
|
||||||
1. only admin can perform this action.
|
1. only admin can perform this action.
|
||||||
@ -288,100 +288,113 @@ class AdminLibrary(APIView):
|
|||||||
error_msg = 'Library %s not found.' % repo_id
|
error_msg = 'Library %s not found.' % repo_id
|
||||||
return api_error(status.HTTP_404_NOT_FOUND, error_msg)
|
return api_error(status.HTTP_404_NOT_FOUND, error_msg)
|
||||||
|
|
||||||
new_owner = request.data.get('owner', None)
|
new_repo_name = request.data.get('name', None)
|
||||||
if not new_owner:
|
if new_repo_name:
|
||||||
error_msg = 'owner invalid.'
|
|
||||||
return api_error(status.HTTP_400_BAD_REQUEST, error_msg)
|
|
||||||
|
|
||||||
try:
|
|
||||||
new_owner_obj = User.objects.get(email=new_owner)
|
|
||||||
except User.DoesNotExist:
|
|
||||||
error_msg = 'User %s not found.' % new_owner
|
|
||||||
return api_error(status.HTTP_404_NOT_FOUND, error_msg)
|
|
||||||
|
|
||||||
if not new_owner_obj.permissions.can_add_repo():
|
|
||||||
error_msg = 'Transfer failed: role of %s is %s, can not add library.' % \
|
|
||||||
(new_owner, new_owner_obj.role)
|
|
||||||
return api_error(status.HTTP_403_FORBIDDEN, error_msg)
|
|
||||||
|
|
||||||
if MULTI_TENANCY:
|
|
||||||
try:
|
try:
|
||||||
if seafile_api.get_org_id_by_repo_id(repo_id) > 0:
|
res = seafile_api.edit_repo(repo_id, new_repo_name, '', None)
|
||||||
error_msg = 'Can not transfer organization library.'
|
|
||||||
return api_error(status.HTTP_403_FORBIDDEN, error_msg)
|
|
||||||
|
|
||||||
if ccnet_api.get_orgs_by_user(new_owner):
|
|
||||||
error_msg = 'Can not transfer library to organization user %s' % new_owner
|
|
||||||
return api_error(status.HTTP_403_FORBIDDEN, error_msg)
|
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
logger.error(e)
|
logger.error(e)
|
||||||
error_msg = 'Internal Server Error'
|
error_msg = 'Internal Server Error'
|
||||||
return api_error(status.HTTP_500_INTERNAL_SERVER_ERROR, error_msg)
|
return api_error(status.HTTP_500_INTERNAL_SERVER_ERROR, error_msg)
|
||||||
|
|
||||||
repo_owner = seafile_api.get_repo_owner(repo_id)
|
if res == -1:
|
||||||
|
e = 'Admin rename failed: ID of library is %s, edit_repo api called failed.' % \
|
||||||
|
repo_id
|
||||||
|
logger.error(e)
|
||||||
|
error_msg = 'Internal Server Error'
|
||||||
|
return api_error(status.HTTP_500_INTERNAL_SERVER_ERROR, error_msg)
|
||||||
|
|
||||||
# get repo shared to user/group list
|
new_owner = request.data.get('owner', None)
|
||||||
shared_users = seafile_api.list_repo_shared_to(
|
if new_owner:
|
||||||
repo_owner, repo_id)
|
try:
|
||||||
shared_groups = seafile_api.list_repo_shared_group_by_user(
|
new_owner_obj = User.objects.get(email=new_owner)
|
||||||
repo_owner, repo_id)
|
except User.DoesNotExist:
|
||||||
|
error_msg = 'User %s not found.' % new_owner
|
||||||
|
return api_error(status.HTTP_404_NOT_FOUND, error_msg)
|
||||||
|
|
||||||
# get all pub repos
|
if not new_owner_obj.permissions.can_add_repo():
|
||||||
pub_repos = []
|
error_msg = 'Transfer failed: role of %s is %s, can not add library.' % \
|
||||||
if not request.cloud_mode:
|
(new_owner, new_owner_obj.role)
|
||||||
pub_repos = seafile_api.list_inner_pub_repos_by_owner(repo_owner)
|
return api_error(status.HTTP_403_FORBIDDEN, error_msg)
|
||||||
|
|
||||||
# transfer repo
|
if MULTI_TENANCY:
|
||||||
seafile_api.set_repo_owner(repo_id, new_owner)
|
try:
|
||||||
|
if seafile_api.get_org_id_by_repo_id(repo_id) > 0:
|
||||||
|
error_msg = 'Can not transfer organization library.'
|
||||||
|
return api_error(status.HTTP_403_FORBIDDEN, error_msg)
|
||||||
|
|
||||||
# reshare repo to user
|
if ccnet_api.get_orgs_by_user(new_owner):
|
||||||
for shared_user in shared_users:
|
error_msg = 'Can not transfer library to organization user %s' % new_owner
|
||||||
shared_username = shared_user.user
|
return api_error(status.HTTP_403_FORBIDDEN, error_msg)
|
||||||
|
except Exception as e:
|
||||||
|
logger.error(e)
|
||||||
|
error_msg = 'Internal Server Error'
|
||||||
|
return api_error(status.HTTP_500_INTERNAL_SERVER_ERROR, error_msg)
|
||||||
|
|
||||||
if new_owner == shared_username:
|
repo_owner = seafile_api.get_repo_owner(repo_id)
|
||||||
continue
|
|
||||||
|
|
||||||
seafile_api.share_repo(repo_id, new_owner,
|
# get repo shared to user/group list
|
||||||
shared_username, shared_user.perm)
|
shared_users = seafile_api.list_repo_shared_to(
|
||||||
|
repo_owner, repo_id)
|
||||||
|
shared_groups = seafile_api.list_repo_shared_group_by_user(
|
||||||
|
repo_owner, repo_id)
|
||||||
|
|
||||||
# reshare repo to group
|
# get all pub repos
|
||||||
for shared_group in shared_groups:
|
pub_repos = []
|
||||||
shared_group_id = shared_group.group_id
|
if not request.cloud_mode:
|
||||||
|
pub_repos = seafile_api.list_inner_pub_repos_by_owner(repo_owner)
|
||||||
|
|
||||||
if not is_group_member(shared_group_id, new_owner):
|
# transfer repo
|
||||||
continue
|
seafile_api.set_repo_owner(repo_id, new_owner)
|
||||||
|
|
||||||
seafile_api.set_group_repo(repo_id, shared_group_id,
|
# reshare repo to user
|
||||||
new_owner, shared_group.perm)
|
for shared_user in shared_users:
|
||||||
|
shared_username = shared_user.user
|
||||||
|
|
||||||
# reshare repo to links
|
if new_owner == shared_username:
|
||||||
try:
|
continue
|
||||||
UploadLinkShare.objects.filter(username=repo_owner, repo_id=repo_id).update(username=new_owner)
|
|
||||||
FileShare.objects.filter(username=repo_owner, repo_id=repo_id).update(username=new_owner)
|
|
||||||
except Exception as e:
|
|
||||||
logger.error(e)
|
|
||||||
error_msg = 'Internal Server Error'
|
|
||||||
return api_error(status.HTTP_500_INTERNAL_SERVER_ERROR, error_msg)
|
|
||||||
|
|
||||||
# check if current repo is pub-repo
|
seafile_api.share_repo(repo_id, new_owner,
|
||||||
# if YES, reshare current repo to public
|
shared_username, shared_user.perm)
|
||||||
for pub_repo in pub_repos:
|
|
||||||
if repo_id != pub_repo.id:
|
|
||||||
continue
|
|
||||||
|
|
||||||
seafile_api.add_inner_pub_repo(repo_id, pub_repo.permission)
|
# reshare repo to group
|
||||||
|
for shared_group in shared_groups:
|
||||||
|
shared_group_id = shared_group.group_id
|
||||||
|
|
||||||
break
|
if not is_group_member(shared_group_id, new_owner):
|
||||||
|
continue
|
||||||
|
|
||||||
# send admin operation log signal
|
seafile_api.set_group_repo(repo_id, shared_group_id,
|
||||||
admin_op_detail = {
|
new_owner, shared_group.perm)
|
||||||
"id": repo_id,
|
|
||||||
"name": repo.name,
|
# reshare repo to links
|
||||||
"from": repo_owner,
|
try:
|
||||||
"to": new_owner,
|
UploadLinkShare.objects.filter(username=repo_owner, repo_id=repo_id).update(username=new_owner)
|
||||||
}
|
FileShare.objects.filter(username=repo_owner, repo_id=repo_id).update(username=new_owner)
|
||||||
admin_operation.send(sender=None, admin_name=request.user.username,
|
except Exception as e:
|
||||||
operation=REPO_TRANSFER, detail=admin_op_detail)
|
logger.error(e)
|
||||||
|
error_msg = 'Internal Server Error'
|
||||||
|
return api_error(status.HTTP_500_INTERNAL_SERVER_ERROR, error_msg)
|
||||||
|
|
||||||
|
# check if current repo is pub-repo
|
||||||
|
# if YES, reshare current repo to public
|
||||||
|
for pub_repo in pub_repos:
|
||||||
|
if repo_id != pub_repo.id:
|
||||||
|
continue
|
||||||
|
|
||||||
|
seafile_api.add_inner_pub_repo(repo_id, pub_repo.permission)
|
||||||
|
|
||||||
|
break
|
||||||
|
|
||||||
|
# send admin operation log signal
|
||||||
|
admin_op_detail = {
|
||||||
|
"id": repo_id,
|
||||||
|
"name": repo.name,
|
||||||
|
"from": repo_owner,
|
||||||
|
"to": new_owner,
|
||||||
|
}
|
||||||
|
admin_operation.send(sender=None, admin_name=request.user.username,
|
||||||
|
operation=REPO_TRANSFER, detail=admin_op_detail)
|
||||||
|
|
||||||
repo = seafile_api.get_repo(repo_id)
|
repo = seafile_api.get_repo(repo_id)
|
||||||
repo_info = get_repo_info(repo)
|
repo_info = get_repo_info(repo)
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user