|
 |
e5b0ac |
|
|
|
e5b0ac |
|
|
|
e5b0ac |
import exception
|
|
|
e5b0ac |
from action.action import Action
|
|
|
e5b0ac |
from action.user import UserBase
|
|
|
e5b0ac |
|
|
|
e5b0ac |
|
|
|
e5b0ac |
class RepoBase(UserBase):
|
|
|
e5b0ac |
def parse_repository_id(self, request):
|
|
|
e5b0ac |
repository_id = 0
|
|
|
e5b0ac |
try:
|
|
|
e5b0ac |
repository_id = int(request.postvars.get('repository_id', 0))
|
|
|
e5b0ac |
except Exception:
|
|
|
e5b0ac |
raise exception.ActionError( request.t('Repository Id incorrect') )
|
|
|
e5b0ac |
if not repository_id:
|
|
|
e5b0ac |
raise exception.ActionError( request.t('Repository Id incorrect') )
|
|
|
e5b0ac |
return repository_id
|
|
|
e5b0ac |
|
|
|
e5b0ac |
|
|
|
e5b0ac |
class RepoCreate(RepoBase):
|
|
|
e5b0ac |
def process(self, request):
|
|
|
e5b0ac |
user_id = self.parse_user_id(request)
|
|
|
e5b0ac |
name = str(request.postvars.get('name', ''))
|
|
|
e5b0ac |
repotype = str(request.postvars.get('type', ''))
|
|
|
e5b0ac |
title = str(request.postvars.get('title', ''))
|
|
|
e5b0ac |
description = str(request.postvars.get('description', ''))
|
|
|
e5b0ac |
|
|
|
e5b0ac |
repo = None
|
|
|
e5b0ac |
try:
|
|
|
e5b0ac |
repo = request.model.repositories.create(user_id, name, repotype, title, description)
|
|
|
e5b0ac |
except Exception as e:
|
|
|
e5b0ac |
self.propagate_exception(e)
|
|
|
e5b0ac |
|
|
|
e5b0ac |
request.connection.commit()
|
|
|
e5b0ac |
return request.answer.complete_redirect(['user', str(repo.get_user().login), 'repo', str(repo.name)])
|
|
|
e5b0ac |
|
|
|
e5b0ac |
|
|
|
e5b0ac |
class RepoUpdate(RepoBase):
|
|
|
e5b0ac |
def process(self, request):
|
|
|
e5b0ac |
repository_id = self.parse_repository_id(request)
|
|
|
e5b0ac |
title = str(request.postvars.get('title', ''))
|
|
|
e5b0ac |
description = str(request.postvars.get('description', ''))
|
|
|
e5b0ac |
|
|
|
e5b0ac |
repo = request.model.repositories.get_by_id(repository_id)
|
|
|
e5b0ac |
if not repo:
|
|
|
e5b0ac |
raise exception.ActionError( request.t('Repository not found') )
|
|
|
e5b0ac |
|
|
|
e5b0ac |
try:
|
|
|
e5b0ac |
repo.update(title, description)
|
|
|
e5b0ac |
except Exception as e:
|
|
|
e5b0ac |
self.propagate_exception(e)
|
|
|
e5b0ac |
|
|
|
e5b0ac |
request.connection.commit()
|
|
|
e5b0ac |
return request.answer.complete_redirect(['user', str(repo.get_user().login), 'repo', str(repo.name)])
|
|
|
e5b0ac |
|
|
|
e5b0ac |
|
|
|
e5b0ac |
class RepoDelete(RepoBase):
|
|
|
e5b0ac |
def process(self, request):
|
|
|
e5b0ac |
repository_id = self.parse_repository_id(request)
|
|
|
e5b0ac |
|
|
|
e5b0ac |
repo = request.model.repositories.get_by_id(repository_id)
|
|
|
e5b0ac |
if not repo:
|
|
|
e5b0ac |
raise exception.ActionError( request.t('Repository not found') )
|
|
|
e5b0ac |
login = repo.get_user().login
|
|
|
e5b0ac |
|
|
|
e5b0ac |
try:
|
|
|
e5b0ac |
repo.delete()
|
|
|
e5b0ac |
except Exception as e:
|
|
|
e5b0ac |
self.propagate_exception(e)
|
|
|
e5b0ac |
|
|
|
e5b0ac |
request.connection.commit()
|
|
|
e5b0ac |
return request.answer.complete_redirect(['user', login, 'repos'])
|
|
|
e5b0ac |
|
|
|
e5b0ac |
|
|
|
e5b0ac |
actions = {
|
|
|
e5b0ac |
'create' : RepoCreate(),
|
|
|
e5b0ac |
'update' : RepoUpdate(),
|
|
|
e5b0ac |
'delete' : RepoDelete(),
|
|
|
e5b0ac |
}
|
|
|
e5b0ac |
|
|
|
e5b0ac |
|