mirror of
https://github.com/haiwen/seahub.git
synced 2025-08-11 03:42:16 +00:00
71 lines
2.5 KiB
Python
71 lines
2.5 KiB
Python
# Copyright (c) 2012-2019 Seafile Ltd.
|
|
# encoding: utf-8
|
|
|
|
import logging
|
|
|
|
from django.utils.translation import ugettext as _
|
|
from rest_framework.authentication import SessionAuthentication
|
|
from rest_framework.permissions import IsAuthenticated
|
|
from rest_framework.response import Response
|
|
from rest_framework.views import APIView
|
|
from rest_framework import status
|
|
|
|
from seahub.api2.throttling import UserRateThrottle
|
|
from seahub.api2.authentication import TokenAuthentication
|
|
from seahub.api2.utils import api_error
|
|
from seahub.views import check_folder_permission
|
|
from seaserv import seafile_api
|
|
from seahub.utils.repo import is_repo_owner
|
|
from seahub.constants import PERMISSION_READ_WRITE
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
|
class RepoCommitRevertView(APIView):
|
|
authentication_classes = (TokenAuthentication, SessionAuthentication)
|
|
permission_classes = (IsAuthenticated,)
|
|
throttle_classes = (UserRateThrottle,)
|
|
|
|
def post(self, request, repo_id, commit_id, format=None):
|
|
""" revert commit in repo history
|
|
|
|
Permission checking:
|
|
1. only repo owner can perform this action.
|
|
"""
|
|
username = request.user.username
|
|
|
|
# resource check
|
|
repo = seafile_api.get_repo(repo_id)
|
|
if not repo:
|
|
error_msg = 'Library %s not found.' % repo_id
|
|
return api_error(status.HTTP_404_NOT_FOUND, error_msg)
|
|
|
|
commit = seafile_api.get_commit(repo.id, repo.version, commit_id)
|
|
if not commit:
|
|
error_msg = 'Commit %s not found.' % commit_id
|
|
return api_error(status.HTTP_404_NOT_FOUND, error_msg)
|
|
|
|
# permission check
|
|
if not is_repo_owner(request, repo_id, username) or \
|
|
check_folder_permission(request, repo_id, '/') != PERMISSION_READ_WRITE:
|
|
error_msg = 'Permission denied.'
|
|
return api_error(status.HTTP_403_FORBIDDEN, error_msg)
|
|
|
|
# main
|
|
if repo.encrypted:
|
|
ret = seafile_api.is_password_set(repo_id, username)
|
|
is_decrypted = False if ret == 0 else True
|
|
|
|
if not is_decrypted:
|
|
error_msg = _('This library has not been decrypted.')
|
|
return api_error(status.HTTP_403_FORBIDDEN, error_msg)
|
|
|
|
try:
|
|
seafile_api.revert_repo(repo_id, commit_id, username)
|
|
except Exception as e:
|
|
logger.error(e)
|
|
error_msg = 'Internal Server Error'
|
|
return api_error(status.HTTP_500_INTERNAL_SERVER_ERROR, error_msg)
|
|
|
|
return Response({'success': True})
|