+
−# -*- coding: UTF-8 -*-
+
−# Copyright (c) 2007 - 2010, Pascal Volk
+
−# See COPYING for distribution information.
+
−
+
−"""
+
−    VirtualMailManager.Alias
+
−
+
−    Virtual Mail Manager's Alias class to manage e-mail aliases.
+
−"""
+
−
+
−from VirtualMailManager.Domain import get_gid
+
−from VirtualMailManager.EmailAddress import EmailAddress
+
−from VirtualMailManager.errors import AliasError as AErr
+
−from VirtualMailManager.pycompat import all
+
−from VirtualMailManager.constants.ERROR import \
+
−     ALIAS_EXCEEDS_EXPANSION_LIMIT, NO_SUCH_ALIAS, NO_SUCH_DOMAIN
+
−
+
−
+
−_ = lambda msg: msg
+
−
+
−
+
−class Alias(object):
+
−    """Class to manage e-mail aliases."""
+
−    __slots__ = ('_addr', '_dests', '_gid', '_dbh')
+
−
+
−    def __init__(self, dbh, address):
+
−        assert isinstance(address, EmailAddress)
+
−        self._addr = address
+
−        self._dbh = dbh
+
−        self._gid = get_gid(self._dbh, self._addr.domainname)
+
−        if not self._gid:
+
−            raise AErr(_(u"The domain %r doesn't exist.") %
+
−                       self._addr.domainname, NO_SUCH_DOMAIN)
+
−        self._dests = []
+
−
+
−        self.__load_dests()
+
−
+
−    def __load_dests(self):
+
−        """Loads all known destination addresses into the _dests list."""
+
−        dbc = self._dbh.cursor()
+
−        dbc.execute(
+
−                'SELECT destination FROM alias WHERE gid=%s AND address=%s',
+
−                    self._gid, self._addr.localpart)
+
−        dests = iter(dbc.fetchall())
+
−        if dbc.rowcount > 0:
+
−            self._dests.extend(EmailAddress(dest[0]) for dest in dests)
+
−        dbc.close()
+
−
+
−    def __check_expansion(self, count_new, limit):
+
−        """Checks the current expansion limit of the alias."""
+
−        dcount = len(self._dests)
+
−        failed = False
+
−        if dcount == limit or dcount + count_new > limit:
+
−            failed = True
+
−            errmsg = _(
+
−u"""Can't add %(count_new)i new destination(s) to alias %(address)r.
+
−Currently this alias expands into %(count)i/%(limit)i recipients.
+
−%(count_new)i additional destination(s) will render this alias unusable.
+
−Hint: Increase Postfix' virtual_alias_expansion_limit""")
+
−        elif dcount > limit:
+
−            failed = True
+
−            errmsg = _(
+
−u"""Can't add %(count_new)i new destination(s) to alias %(address)r.
+
−This alias already exceeds it's expansion limit (%(count)i/%(limit)i).
+
−So its unusable, all messages addressed to this alias will be bounced.
+
−Hint: Delete some destination addresses.""")
+
−        if failed:
+
−            raise AErr(errmsg % {'address': str(self._addr), 'count': dcount,
+
−                                 'limit': limit, 'count_new': count_new},
+
−                       ALIAS_EXCEEDS_EXPANSION_LIMIT)
+
−
+
−    def __delete(self, destination=None):
+
−        """Deletes a destination from the alias, if ``destination`` is
+
−        not ``None``.  If ``destination`` is None, the alias with all
+
−        it's destination addresses will be deleted.
+
−
+
−        """
+
−        dbc = self._dbh.cursor()
+
−        if not destination:
+
−            dbc.execute("DELETE FROM alias WHERE gid=%s AND address=%s",
+
−                        self._gid, self._addr.localpart)
+
−        else:
+
−            dbc.execute("DELETE FROM alias WHERE gid=%s AND address=%s AND \
+
− destination=%s",
+
−                        self._gid, self._addr.localpart, str(destination))
+
−        if dbc.rowcount > 0:
+
−            self._dbh.commit()
+
−        dbc.close()
+
−
+
−    def __len__(self):
+
−        """Returns the number of destinations of the alias."""
+
−        return len(self._dests)
+
−
+
−    def add_destinations(self, destinations, expansion_limit, warnings=None):
+
−        """Adds the `EmailAddress`es from *destinations* list to the
+
−        destinations of the alias.
+
−
+
−        Destinations, that are already assigned to the alias, will be
+
−        removed from *destinations*.  When done, this method will return
+
−        a set with all destinations, that was saved in the database.
+
−        """
+
−        destinations = set(destinations)
+
−        assert destinations and \
+
−                all(isinstance(dest, EmailAddress) for dest in destinations)
+
−        if not warnings is None:
+
−            assert isinstance(warnings, list)
+
−        if self._addr in destinations:
+
−            destinations.remove(self._addr)
+
−            if not warnings is None:
+
−                warnings.append(self._addr)
+
−        duplicates = destinations.intersection(set(self._dests))
+
−        if duplicates:
+
−            destinations.difference_update(set(self._dests))
+
−            if not warnings is None:
+
−                warnings.extend(duplicates)
+
−        if not destinations:
+
−            return destinations
+
−        self.__check_expansion(len(destinations), expansion_limit)
+
−        dbc = self._dbh.cursor()
+
−        dbc.executemany("INSERT INTO alias VALUES (%d, '%s', %%s)" %
+
−                        (self._gid, self._addr.localpart),
+
−                        (str(destination) for destination in destinations))
+
−        self._dbh.commit()
+
−        dbc.close()
+
−        self._dests.extend(destinations)
+
−        return destinations
+
−
+
−    def del_destination(self, destination):
+
−        """Deletes the specified ``destination`` address from the alias."""
+
−        assert isinstance(destination, EmailAddress)
+
−        if not self._dests:
+
−            raise AErr(_(u"The alias %r doesn't exist.") % str(self._addr),
+
−                       NO_SUCH_ALIAS)
+
−        if not destination in self._dests:
+
−            raise AErr(_(u"The address %(d)r isn't a destination of \
+
−the alias %(a)r.") %
+
−                       {'a': str(self._addr), 'd': str(destination)},
+
−                       NO_SUCH_ALIAS)
+
−        self.__delete(destination)
+
−        self._dests.remove(destination)
+
−
+
−    def get_destinations(self):
+
−        """Returns an iterator for all destinations of the alias."""
+
−        if not self._dests:
+
−            raise AErr(_(u"The alias %r doesn't exist.") % str(self._addr),
+
−                       NO_SUCH_ALIAS)
+
−        return iter(self._dests)
+
−
+
−    def delete(self):
+
−        """Deletes the alias with all its destinations."""
+
−        if not self._dests:
+
−            raise AErr(_(u"The alias %r doesn't exist.") % str(self._addr),
+
−                       NO_SUCH_ALIAS)
+
−        self.__delete()
+
−        del self._dests[:]
+
−
+
−
+
−del _