summaryrefslogtreecommitdiff
path: root/mailman/pipeline/to_outgoing.py
blob: 9ff7ab88a4ce471102e9e40eecb59b8ada95bda9 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
# Copyright (C) 1998-2009 by the Free Software Foundation, Inc.
#
# This file is part of GNU Mailman.
#
# GNU Mailman is free software: you can redistribute it and/or modify it under
# the terms of the GNU General Public License as published by the Free
# Software Foundation, either version 3 of the License, or (at your option)
# any later version.
#
# GNU Mailman is distributed in the hope that it will be useful, but WITHOUT
# ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
# FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License for
# more details.
#
# You should have received a copy of the GNU General Public License along with
# GNU Mailman.  If not, see <http://www.gnu.org/licenses/>.

"""Re-queue the message to the outgoing queue.

This module is only for use by the IncomingRunner for delivering messages
posted to the list membership.  Anything else that needs to go out to some
recipient should just be placed in the out queue directly.
"""

__metaclass__ = type
__all__ = [
    'ToOutgoing',
    ]


from lazr.config import as_boolean
from zope.interface import implements

from mailman.config import config
from mailman.i18n import _
from mailman.interfaces.handler import IHandler
from mailman.interfaces.mailinglist import Personalization



class ToOutgoing:
    """Send the message to the outgoing queue."""

    implements(IHandler)

    name = 'to-outgoing'
    description = _('Send the message to the outgoing queue.')

    def process(self, mlist, msg, msgdata):
        """See `IHandler`."""
        interval = int(config.mta.verp_delivery_interval)
        # Should we VERP this message?  If personalization is enabled for this
        # list and VERP_PERSONALIZED_DELIVERIES is true, then yes we VERP it.
        # Also, if personalization is /not/ enabled, but
        # VERP_DELIVERY_INTERVAL is set (and we've hit this interval), then
        # again, this message should be VERPed. Otherwise, no.
        #
        # Note that the verp flag may already be set, e.g. by mailpasswds
        # using VERP_PASSWORD_REMINDERS.  Preserve any existing verp flag.
        if 'verp' in  msgdata:
            pass
        elif mlist.personalize <> Personalization.none:
            if as_boolean(config.mta.verp_personalized_deliveries):
                msgdata['verp'] = True
        elif interval == 0:
            # Never VERP
            pass
        elif interval == 1:
            # VERP every time
            msgdata['verp'] = True
        else:
            # VERP every `interval' number of times
            msgdata['verp'] = not (int(mlist.post_id) % interval)
        # And now drop the message in qfiles/out
        config.switchboards['out'].enqueue(
            msg, msgdata, listname=mlist.fqdn_listname)