#!/usr/bin/env python

# -*- coding: UTF-8 -*-

# Copyright 2007-2008 VEB IT

# See COPYING for distribution information.

# $Id$

"""Virtual Mail Manager's Account class to manage e-mail accounts."""

from constants.VERSION import VERSION

__author__ = 'Pascal Volk <p.volk@veb-it.de>'

__version__ = VERSION

__revision__ = 'rev '+'$Rev$'.split()[1]

__date__ = '$Date$'.split()[1]

from Exceptions import VMMAccountException as AccE

from Domain import Domain

from Transport import Transport

from MailLocation import MailLocation

import VirtualMailManager as VMM

import constants.ERROR as ERR

class Account:

    """Class to manage e-mail accounts."""

    def __init__(self, dbh, address, password=None):

        self._dbh = dbh

        self._base = None

        self._addr = VMM.VirtualMailManager.chkEmailAddress(address)

        self._localpart = None

        self._name = None

        self._uid = 0

        self._gid = 0

        self._mid = 0

        self._tid = 0

        self._passwd = password

        self._setAddr()

        self._exists()

        if self._isAlias():

            raise AccE(_(u"There is already an alias with the address »%s«.") %\

                    address, ERR.ALIAS_EXISTS)

    def _exists(self):

        dbc = self._dbh.cursor()

        dbc.execute("SELECT uid, mid, tid FROM users \

WHERE gid=%s AND local_part=%s",

                self._gid, self._localpart)

        result = dbc.fetchone()

        dbc.close()

        if result is not None:

            self._uid, self._mid, self._tid = result

            return True

        else:

            return False

    def _isAlias(self):

        dbc = self._dbh.cursor()

        dbc.execute("SELECT gid FROM alias WHERE gid=%s AND address=%s",

                self._gid, self._localpart)

        gid = dbc.fetchone()

        dbc.close()

        if gid is not None:

            return True

        else:

            return False

    def _setAddr(self):

        self._localpart, d = self._addr.split('@')

        dom = Domain(self._dbh, d)

        self._gid = dom.getID()

        if self._gid == 0:

            raise AccE(_(u"The domain »%s« doesn't exist yet.") % d,

                ERR.NO_SUCH_DOMAIN)

        self._base = dom.getDir()

        self._tid = dom.getTransportID()

    def _setID(self):

        dbc = self._dbh.cursor()

        dbc.execute("SELECT nextval('users_uid')")

        self._uid = dbc.fetchone()[0]

        dbc.close()

    def _prepare(self, maillocation):

        self._setID()

        self._mid = MailLocation(self._dbh, maillocation=maillocation).getID()

    def _switchState(self, state, service):

        if not isinstance(state, bool):

            return False

        if not service in ['smtp', 'pop3', 'imap', 'managesieve', 'all', None]:

            raise AccE(_(u"Unknown service »%s«.") % service,

                    ERR.UNKNOWN_SERVICE)

        if self._uid < 1:

            raise AccE(_(u"The account »%s« doesn't exists.") % self._addr,

                    ERR.NO_SUCH_ACCOUNT)

        dbc = self._dbh.cursor()

        if service in ['smtp', 'pop3', 'imap', 'managesieve']:

            dbc.execute(

                    "UPDATE users SET %s=%s WHERE local_part='%s' AND gid=%s"

                    % (service, state, self._localpart, self._gid))

        elif state:

            dbc.execute("UPDATE users SET smtp = TRUE, pop3 = TRUE,\

 imap = TRUE, managesieve = TRUE WHERE local_part = %s AND gid = %s",

                self._localpart, self._gid)

        else:

            dbc.execute("UPDATE users SET smtp = FALSE, pop3 = FALSE,\

 imap = FALSE, managesieve = FALSE WHERE local_part = %s AND gid = %s",

                self._localpart, self._gid)

        if dbc.rowcount > 0:

            self._dbh.commit()

        dbc.close()

    def __aliaseCount(self):

        dbc = self._dbh.cursor()

        q = "SELECT COUNT(destination) FROM alias WHERE destination = '%s'"\

            %self._addr

        dbc.execute(q)

        a_count = dbc.fetchone()[0]

        dbc.close()

        return a_count

    def setPassword(self, password):

        self._passwd = password

    def getUID(self):

        return self._uid

    def getGID(self):

        return self._gid

    def getDir(self, directory):

        if directory == 'domain':

            return '%s' % self._base

        elif directory == 'home':

            return '%s/%i' % (self._base, self._uid)

    def enable(self, service=None):

        self._switchState(True, service)

    def disable(self, service=None):

        self._switchState(False, service)

    def save(self, maillocation, smtp, pop3, imap, managesieve):

        if self._uid < 1:

            self._prepare(maillocation)

            dbc = self._dbh.cursor()

            dbc.execute("""INSERT INTO users (local_part, passwd, uid, gid,\

 mid, tid, smtp, pop3, imap, managesieve)\

 VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s)""",

                self._localpart, self._passwd, self._uid, self._gid, self._mid,

                self._tid, smtp, pop3, imap, managesieve)

            self._dbh.commit()

            dbc.close()

        else:

            raise AccE(_(u'The account »%s« already exists.') % self._addr,

                    ERR.ACCOUNT_EXISTS)

    def modify(self, what, value):

        if self._uid == 0:

            raise AccE(_(u"The account »%s« doesn't exists.") % self._addr,

                    ERR.NO_SUCH_ACCOUNT)

        if what not in ['name', 'password', 'transport']:

            return False

        dbc = self._dbh.cursor()

        if what == 'password':

            dbc.execute("UPDATE users SET passwd=%s WHERE local_part=%s AND\

 gid=%s", value, self._localpart, self._gid)

        elif what == 'transport':

            self._tid = Transport(self._dbh, transport=value).getID()

            dbc.execute("UPDATE users SET tid=%s WHERE local_part=%s AND\

 gid=%s", self._tid, self._localpart, self._gid)

        else:

            dbc.execute("UPDATE users SET name=%s WHERE local_part=%s AND\

 gid=%s", value, self._localpart, self._gid)

        if dbc.rowcount > 0:

            self._dbh.commit()

        dbc.close()

    def getInfo(self):

        dbc = self._dbh.cursor()

        dbc.execute("SELECT name, uid, gid, mid, tid, smtp, pop3, imap, \

 managesieve FROM users WHERE local_part=%s AND gid=%s",

            self._localpart, self._gid)

        info = dbc.fetchone()

        dbc.close()

        if info is None:

            raise AccE(_(u"The account »%s« doesn't exists.") % self._addr,

                    ERR.NO_SUCH_ACCOUNT)

        else:

            keys = ['name', 'uid', 'gid', 'maildir', 'transport', 'smtp',

                    'pop3', 'imap', 'managesieve']

            info = dict(zip(keys, info))

            for service in ['smtp', 'pop3', 'imap', 'managesieve']:

                if bool(info[service]):

                    info[service] = _('enabled')

                else:

                    info[service] = _('disabled')

            info['address'] = self._addr

            info['maildir'] = '%s/%s/%s' % (self._base, info['uid'],

                    MailLocation(self._dbh,

                        mid=info['maildir']).getMailLocation())

            info['transport'] = Transport(self._dbh,

                    tid=info['transport']).getTransport()

            return info

    def delete(self, delalias):

        if self._uid < 1:

            raise AccE(_(u"The account »%s« doesn't exists.") % self._addr,

                    ERR.NO_SUCH_ACCOUNT)

        dbc = self._dbh.cursor()

        if delalias == 'delalias':

            dbc.execute("DELETE FROM users WHERE gid=%s AND local_part=%s",

                    self._gid, self._localpart)

            u_rc = dbc.rowcount

            # delete also all aliases where the destination address is the same

            # as for this account.

            dbc.execute("DELETE FROM alias WHERE destination = %s", self._addr)

            if u_rc > 0 or dbc.rowcount > 0:

                self._dbh.commit()

        else: # check first for aliases

            a_count = self.__aliaseCount()

            if a_count == 0:

                dbc.execute("DELETE FROM users WHERE gid=%s AND local_part=%s",

                        self._gid, self._localpart)

                if dbc.rowcount > 0:

                    self._dbh.commit()

            else:

                dbc.close()

                raise AccE(

                  _(u"There are %(count)d aliases with the destination address\

 »%(address)s«.") %{'count': a_count, 'address': self._addr}, ERR.ALIAS_PRESENT)

        dbc.close()

def getAccountByID(uid, dbh):

    try:

        uid = long(uid)

    except ValueError:

        raise AccE(_(u'uid must be an int/long.'), ERR.INVALID_AGUMENT)

    if uid < 1:

        raise AccE(_(u'uid must be greater than 0.'), ERR.INVALID_AGUMENT)

    dbc = dbh.cursor()

    dbc.execute("SELECT local_part||'@'|| domain_name.domainname AS address,\

 uid, users.gid FROM users LEFT JOIN domain_name ON (domain_name.gid \

 = users.gid AND is_primary) WHERE uid = %s;", uid)

    info = dbc.fetchone()

    dbc.close()

    if info is None:

        raise AccE(_(u"There is no account with the UID »%d«.") % uid, 

                ERR.NO_SUCH_ACCOUNT)

    keys = ['address', 'uid', 'gid']

    info = dict(zip(keys, info))

    return info