haiwen/seahub
1
0
Fork 0
mirror of https://github.com/haiwen/seahub.git synced 2025-09-17 15:53:28 +00:00
Code Issues Releases Wiki Activity

[api]change delete copy and move api for batch processing

Browse Source
This commit is contained in:
poetwang
2012-09-08 01:43:49 +08:00
parent 32eb8580aa
commit 1292826626
1 changed files with 82 additions and 60 deletions
Download Patch File Download Diff File Expand all files Collapse all files

142
api/views.py
View File

@@ -195,7 +195,7 @@ def set_repo_password(request, repo, password):
elif e.msg == 'Internal server error': elif e.msg == 'Internal server error':
return api_error(request, '500') return api_error(request, '500')
else: else:
return api_error(request, '417', "SearpcError:"+e.msg) return api_error(request, '417', "SearpcError:" + e.msg)
def check_repo_access_permission(request, repo): def check_repo_access_permission(request, repo):
if not repo: if not repo:
@@ -211,7 +211,7 @@ def check_repo_access_permission(request, repo):
if ret == 1: if ret == 1:
password_set = True password_set = True
except SearpcError, e: except SearpcError, e:
return api_error(request, '405', "SearpcError:"+e.msg) return api_error(request, '405', "SearpcError:" + e.msg)
if not password_set: if not password_set:
password = request.REQUEST['password'] password = request.REQUEST['password']
@@ -388,7 +388,7 @@ class RepoDirPathView(ResponseMixin, View):
dir_id = seafserv_threaded_rpc.get_dirid_by_path(current_commit.id, dir_id = seafserv_threaded_rpc.get_dirid_by_path(current_commit.id,
path.encode('utf-8')) path.encode('utf-8'))
except SearpcError, e: except SearpcError, e:
return api_error(request, "411", "SearpcError:"+e.msg) return api_error(request, "411", "SearpcError:" + e.msg)
if not dir_id: if not dir_id:
return api_error(request, '410') return api_error(request, '410')
@@ -532,7 +532,7 @@ class RepoFilePathView(ResponseMixin, View):
file_id = seafserv_threaded_rpc.get_file_by_path(repo_id, file_id = seafserv_threaded_rpc.get_file_by_path(repo_id,
path.encode('utf-8')) path.encode('utf-8'))
except SearpcError, e: except SearpcError, e:
return api_error(request, '412', "SearpcError:"+e.msg) return api_error(request, '412', "SearpcError:" + e.msg)
if not file_id: if not file_id:
return api_error(request, '410') return api_error(request, '410')
@@ -561,6 +561,29 @@ class RepoFilePathView(ResponseMixin, View):
return api_error(request, '415') return api_error(request, '415')
def reloaddir_if_neccessary (request, repo_id, path):
reloaddir = False
s = request.GET.get('reloaddir', None)
if s and s.lower() == 'true':
reloaddir = True
if not reloaddir:
return HttpResponse(json.dumps('success'), status='200',
content_type=json_content_type)
current_commit = get_commits(repo_id, 0, 1)[0]
try:
dir_id = seafserv_threaded_rpc.get_dirid_by_path(current_commit.id,
parent_dir.encode('utf-8'))
except SearpcError, e:
return api_error(request, "411", "SearpcError:" + e.msg)
if not dir_id:
return api_error(request, '410')
return get_dir_entrys_by_id(request, dir_id)
class OpDeleteView(ResponseMixin, View): class OpDeleteView(ResponseMixin, View):
@api_login_required @api_login_required
@@ -569,23 +592,25 @@ class OpDeleteView(ResponseMixin, View):
@api_login_required @api_login_required
def post(self, request, repo_id): def post(self, request, repo_id):
path = request.GET.get('p') resp = check_repo_access_permission(request, get_repo(repo_id))
if not path or path[0] != '/': if resp:
return resp
parent_dir = request.GET.get('p', '/')
file_names = request.POST.get("file_names")
if not parent_dir or not file_names:
return api_error(request, '400') return api_error(request, '400')
parent_dir = os.path.dirname(path) names = file_names.split(':')
file_name = os.path.basename(path) for file_name in names:
try:
seafserv_threaded_rpc.del_file(repo_id, parent_dir,
file_name, request.user.username)
except SearpcError,e:
return api_error(request, '418', 'SearpcError:' + e.msg)
try: return reloaddir_if_neccessary (request, repo_id, parent_dir)
ret = seafserv_threaded_rpc.del_file(repo_id, parent_dir,
file_name, request.user.username)
except SearpcError,e:
return api_error(request, '418', e.msg)
if ret < 0:
return api_error(request, '418')
return HttpResponse(json.dumps('success'), status='200',
content_type=json_content_type)
class OpMkdirView(ResponseMixin, View): class OpMkdirView(ResponseMixin, View):
@@ -596,25 +621,25 @@ class OpMkdirView(ResponseMixin, View):
@api_login_required @api_login_required
def post(self, request, repo_id): def post(self, request, repo_id):
resp = check_repo_access_permission(request, get_repo(repo_id))
if resp:
return resp
path = request.GET.get('p') path = request.GET.get('p')
if not path or path[0] != '/': if not path or path[0] != '/':
return api_error(request, '400') return api_error(request, '400')
parent_dir = os.path.dirname(path) parent_dir = os.path.dirname(path)
new_dir_name = os.path.basename(path) new_dir_name = os.path.basename(path)
new_dir_name = check_filename_with_rename(repo_id, parent_dir, new_dir_name) new_dir_name = check_filename_with_rename(repo_id, parent_dir, new_dir_name)
try: try:
ret = seafserv_threaded_rpc.post_dir(repo_id, parent_dir, new_dir_name, seafserv_threaded_rpc.post_dir(repo_id, parent_dir, new_dir_name,
request.user.username) request.user.username)
except SearpcError, e: except SearpcError, e:
return api_error(request, '421', e.msg) return api_error(request, '421', e.msg)
if ret < 0: return reloaddir_if_neccessary (request, repo_id, parent_dir)
return api_error(request, '421')
return HttpResponse(json.dumps('success'), status='200',
content_type=json_content_type)
class OpRenameView(ResponseMixin, View): class OpRenameView(ResponseMixin, View):
@@ -625,6 +650,10 @@ class OpRenameView(ResponseMixin, View):
@api_login_required @api_login_required
def post(self, request, repo_id): def post(self, request, repo_id):
resp = check_repo_access_permission(request, get_repo(repo_id))
if resp:
return resp
path = request.GET.get('p') path = request.GET.get('p')
newname = request.POST.get("newname") newname = request.POST.get("newname")
if not path or path[0] != '/' or not newname: if not path or path[0] != '/' or not newname:
@@ -642,15 +671,13 @@ class OpRenameView(ResponseMixin, View):
newname = check_filename_with_rename(repo_id, parent_dir, newname) newname = check_filename_with_rename(repo_id, parent_dir, newname)
try: try:
ret = seafserv_threaded_rpc.rename_file (repo_id, parent_dir, oldname, seafserv_threaded_rpc.rename_file (repo_id, parent_dir, oldname,
newname, request.user.username) newname, request.user.username)
except SearpcError,e: except SearpcError,e:
return api_error(request, '420', "SearpcError:"+e.msg) return api_error(request, '420', "SearpcError:" + e.msg)
return reloaddir_if_neccessary (request, repo_id, parent_dir)
if ret < 0:
return api_error(request, '420')
return HttpResponse(json.dumps('success'), status='200',
content_type=json_content_type)
class OpMoveView(ResponseMixin, View): class OpMoveView(ResponseMixin, View):
@@ -661,44 +688,39 @@ class OpMoveView(ResponseMixin, View):
@api_login_required @api_login_required
def post(self, request): def post(self, request):
src_repo_id = request.POST.get('src_repo') src_repo_id = request.POST.get('src_repo')
src_path = request.POST.get('src_path') src_dir = request.POST.get('src_dir')
dst_repo_id = request.POST.get('dst_repo') dst_repo_id = request.POST.get('dst_repo')
dst_dir = request.POST.get('dst_dir') dst_dir = request.POST.get('dst_dir')
obj_type = request.POST.get('obj_type') # dir or file
op = request.POST.get('operation') op = request.POST.get('operation')
obj_names = request.POST.get('obj_names')
if not (src_repo_id and src_path and src_path[0] == '/' and dst_repo_id \ if not (src_repo_id and src_dir and dst_repo_id \
and dst_dir and obj_type and op): and dst_dir and op and obj_names):
return api_error(request, '400') return api_error(request, '400')
src_dir = os.path.dirname(src_path)
obj_name = os.path.basename(src_path)
if src_repo_id == dst_repo_id and src_dir == dst_dir: if src_repo_id == dst_repo_id and src_dir == dst_dir:
return api_error(request, '419', 'The src_dir is same to dst_dir') return api_error(request, '419', 'The src_dir is same to dst_dir')
if obj_type == 'dir': names = obj_names.split(':')
if dst_dir.startswith(src_path): if dst_dir.startswith(src_dir):
return api_error(request, '419', 'Can not move a dirctory to its subdir') for obj_name in names:
if dst_dir.startswith('/'.join([src_dir, obj_name])):
return api_error(request, '419', 'Can not move a dirctory to its subdir')
new_obj_name = check_filename_with_rename(dst_repo_id, dst_dir, obj_name) for obj_name in names:
new_obj_name = check_filename_with_rename(dst_repo_id, dst_dir, obj_name)
ret = 0 try:
try: if op == 'cp':
if op == 'cp': seafserv_threaded_rpc.copy_file (src_repo_id, src_dir, obj_name,
ret = seafserv_threaded_rpc.copy_file (src_repo_id, src_dir, obj_name, dst_repo_id, dst_dir, new_obj_name,
dst_repo_id, dst_dir, new_obj_name, request.user.username)
request.user.username) elif op == 'mv':
elif op == 'mv': seafserv_threaded_rpc.move_file (src_repo_id, src_dir, obj_name,
ret = seafserv_threaded_rpc.move_file (src_repo_id, src_dir, obj_name, dst_repo_id, dst_dir, new_obj_name,
dst_repo_id, dst_dir, new_obj_name, request.user.username)
request.user.username) except SearpcError, e:
except SearpcError, e: return api_error(request, '419', "SearpcError:" + e.msg)
return api_error(request, '419', "SearpcError:"+e.msg)
if ret < 0:
return api_error(request, '419')
return HttpResponse(json.dumps('success'), status='200',
content_type=json_content_type)
return reloaddir_if_neccessary (request, dst_repo_id, dst_dir)