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

# Copyright (c) 2008 - 2011, Pascal Volk

# See COPYING for distribution information.

"""

    VirtualMailManager.relocated

    ~~~~~~~~~~~~~~~~~~~~~~~~~~~~

    Virtual Mail Manager's Relocated class to handle relocated users.

"""

from VirtualMailManager.domain import get_gid

from VirtualMailManager.emailaddress import EmailAddress, \

     DestinationEmailAddress

from VirtualMailManager.errors import RelocatedError as RErr

from VirtualMailManager.constants import DOMAIN_INVALID, NO_SUCH_DOMAIN, \

     NO_SUCH_RELOCATED, RELOCATED_ADDR_DEST_IDENTICAL, RELOCATED_EXISTS

_ = lambda msg: msg

class Relocated(object):

    """Class to handle e-mail addresses of relocated users."""

    __slots__ = ('_addr', '_dest', '_gid', '_dbh')

    def __init__(self, dbh, address):

        """Creates a new *Relocated* instance.  The ``address`` is the

        old e-mail address of the user.

        Use `setDestination()` to set/update the new address, where the

        user has moved to.

        """

        assert isinstance(address, EmailAddress)

        self._addr = address

        self._dbh = dbh

        self._gid = get_gid(self._dbh, self._addr.domainname)

        if not self._gid:

            raise RErr(_(u"The domain '%s' does not exist.") %

                       self._addr.domainname, NO_SUCH_DOMAIN)

        self._dest = None

        self._load()

    def __nonzero__(self):

        """Returns `True` if the Relocated is known, `False` if it's new."""

        return self._dest is not None

    def _load(self):

        """Loads the destination address from the database into the

        `_dest` attribute.

        """

        dbc = self._dbh.cursor()

        dbc.execute('SELECT destination FROM relocated WHERE gid = %s AND '

                    'address = %s', (self._gid, self._addr.localpart))

        destination = dbc.fetchone()

        dbc.close()

        if destination:

            destination = DestinationEmailAddress(destination[0], self._dbh)

            if destination.at_localhost:

                raise RErr(_(u"The destination address' domain name must not "

                             u"be localhost."), DOMAIN_INVALID)

            self._dest = destination

    @property

    def address(self):

        """The Relocated's EmailAddress instance."""

        return self._addr

    def set_destination(self, destination):

        """Sets/updates the new address of the relocated user."""

        update = False

        assert isinstance(destination, DestinationEmailAddress)

        if destination.at_localhost:

            raise RErr(_(u"The destination address' domain name must not be "

                         u"localhost."), DOMAIN_INVALID)

        if self._addr == destination:

            raise RErr(_(u'Address and destination are identical.'),

                       RELOCATED_ADDR_DEST_IDENTICAL)

        if self._dest:

            if self._dest == destination:

                raise RErr(_(u"The relocated user '%s' already exists.") %

                           self._addr, RELOCATED_EXISTS)

            else:

                self._dest = destination

                update = True

        else:

            self._dest = destination

        dbc = self._dbh.cursor()

        if not update:

            dbc.execute('INSERT INTO relocated (gid, address, destination) '

                        'VALUES (%s, %s, %s)',

                        (self._gid, self._addr.localpart, str(self._dest)))

        else:

            dbc.execute('UPDATE relocated SET destination = %s WHERE gid = %s '

                        'AND address = %s',

                        (str(self._dest), self._gid, self._addr.localpart))

        self._dbh.commit()

        dbc.close()

    def get_info(self):

        """Returns the address to which mails should be sent."""

        if not self._dest:

            raise RErr(_(u"The relocated user '%s' does not exist.") %

                       self._addr, NO_SUCH_RELOCATED)

        return self._dest

    def delete(self):

        """Deletes the relocated entry from the database."""

        if not self._dest:

            raise RErr(_(u"The relocated user '%s' does not exist.") %

                       self._addr, NO_SUCH_RELOCATED)

        dbc = self._dbh.cursor()

        dbc.execute('DELETE FROM relocated WHERE gid = %s AND address = %s',

                    (self._gid, self._addr.localpart))

        if dbc.rowcount > 0:

            self._dbh.commit()

        dbc.close()

        self._dest = None

del _