import exception
from action.action import Action
from action.user import UserBase


class RepoBase(UserBase):
  def parse_repository_id(self, request):
    repository_id = 0
    try:
      repository_id = int(request.postvars.get('repository_id', 0))
    except Exception:
      raise exception.ActionError( request.t('Repository Id incorrect') )
    if not repository_id:
      raise exception.ActionError( request.t('Repository Id incorrect') )
    return repository_id
  
  def redirect_to_repo(self, request, repo, path = None):
    if path is None: path = list()
    return self.redirect_to_user(request, repo.get_user(), ['repo', str(repo.name)] + path)


class RepoCreate(RepoBase):
  def process(self, request):
    user_id = self.parse_user_id(request)
    name = str(request.postvars.get('name', ''))
    repotype = str(request.postvars.get('type', ''))
    title = str(request.postvars.get('title', ''))
    description = str(request.postvars.get('description', ''))
    
    user = request.model.users.get_by_id(user_id)
    if not user:
      raise exception.ActionError( request.t('User not found') )

    repo = None
    try:
      repo = request.model.repositories.create(user, name, repotype, title, description)
    except Exception as e:
      self.propagate_exception(e)

    request.connection.commit()
    return self.redirect_to_repo(request, repo)


class RepoUpdate(RepoBase):
  def process(self, request):
    repository_id = self.parse_repository_id(request)
    title = str(request.postvars.get('title', ''))
    description = str(request.postvars.get('description', ''))
    
    repo = request.model.repositories.get_by_id(repository_id)
    if not repo:
      raise exception.ActionError( request.t('Repository not found') )
    
    try:
      repo.update(title, description)
    except Exception as e:
      self.propagate_exception(e)

    request.connection.commit()
    return self.redirect_to_repo(request, repo)
    

class RepoDelete(RepoBase):
  def process(self, request):
    repository_id = self.parse_repository_id(request)
    
    repo = request.model.repositories.get_by_id(repository_id)
    if not repo:
      raise exception.ActionError( request.t('Repository not found') )
    user = repo.get_user()
    
    try:
      repo.delete()
    except Exception as e:
      self.propagate_exception(e)

    request.connection.commit()
    return self.redirect_to_user(request, user, ['repos'])
    

class RepoSetUserRight(RepoBase):
  def process(self, request):
    repository_id = self.parse_repository_id(request)
    repo = request.model.repositories.get_by_id(repository_id)
    if not repo:
      raise exception.ActionError( request.t('Repository not found') )

    allowed = bool(request.postvars.get('allowed', False))
    mode = str(request.postvars.get('mode', ''))
    
    try:
      user_id = int(request.postvars.get('user_id', 0))
    except Exception:
      raise exception.ActionError( request.t('User Id incorrect') )
    user_login = str(request.postvars.get('user_login', ''))
    all_users = bool(request.postvars.get('all_users', False))
    
    if user_id and user_login:
      raise exception.ActionError( request.t('Both user id and user login was set') )
    if all_users and (user_id or user_login):
      raise exception.ActionError( request.t('All users flag was set with selection of concrete user') )
    
    user = None
    if user_id:
      user = request.model.users.get_by_id(user_id)
    elif user_login:
      user = request.model.users.get_by_login(user_login)
      user_id = user.id
    
    if not all_users and not user:
      raise exception.ActionError( request.t('User not found') )
      
    try:
      repo.set_user_right(user_id, mode, allowed, all_users = all_users)
    except Exception as e:
      self.propagate_exception(e)

    request.connection.commit()
    return self.redirect_to_repo(request, repo, ['edit'])


actions = {
  'create'       : RepoCreate(),
  'update'       : RepoUpdate(),
  'delete'       : RepoDelete(),
  'setuserright' : RepoSetUserRight(),
}