/usr/share/pyshared/zope/sendmail/delivery.py is in python-zope.sendmail 3.7.5-0ubuntu1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
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 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 | ##############################################################################
#
# Copyright (c) 2003 Zope Corporation and Contributors.
# All Rights Reserved.
#
# This software is subject to the provisions of the Zope Public License,
# Version 2.1 (ZPL). A copy of the ZPL should accompany this distribution.
# THIS SOFTWARE IS PROVIDED "AS IS" AND ANY AND ALL EXPRESS OR IMPLIED
# WARRANTIES ARE DISCLAIMED, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
# WARRANTIES OF TITLE, MERCHANTABILITY, AGAINST INFRINGEMENT, AND FITNESS
# FOR A PARTICULAR PURPOSE.
#
##############################################################################
"""Mail Delivery utility implementation
This module contains various implementations of `MailDeliverys`.
$Id: delivery.py 108107 2010-01-13 13:32:26Z kobold $
"""
__docformat__ = 'restructuredtext'
import os
import rfc822
from cStringIO import StringIO
from random import randrange
from time import strftime
from socket import gethostname
from zope.interface import implements
from zope.sendmail.interfaces import IDirectMailDelivery, IQueuedMailDelivery
from zope.sendmail.maildir import Maildir
from transaction.interfaces import IDataManager
import transaction
# BBB: this import is needed for backward compatibility with older versions of
# zope.sendmail which defined QueueProcessorThread in this module
from zope.sendmail.queue import QueueProcessorThread
class MailDataManager(object):
implements(IDataManager)
def __init__(self, callable, args=(), onAbort=None):
self.callable = callable
self.args = args
self.onAbort = onAbort
# Use the default thread transaction manager.
self.transaction_manager = transaction.manager
def commit(self, transaction):
pass
def abort(self, transaction):
if self.onAbort:
self.onAbort()
def sortKey(self):
return id(self)
# No subtransaction support.
def abort_sub(self, transaction):
pass
commit_sub = abort_sub
def beforeCompletion(self, transaction):
pass
afterCompletion = beforeCompletion
def tpc_begin(self, transaction, subtransaction=False):
assert not subtransaction
def tpc_vote(self, transaction):
pass
def tpc_finish(self, transaction):
self.callable(*self.args)
tpc_abort = abort
class AbstractMailDelivery(object):
def newMessageId(self):
"""Generates a new message ID according to RFC 2822 rules"""
randmax = 0x7fffffff
left_part = '%s.%d.%d' % (strftime('%Y%m%d%H%M%S'),
os.getpid(),
randrange(0, randmax))
return "%s@%s" % (left_part, gethostname())
def send(self, fromaddr, toaddrs, message):
parser = rfc822.Message(StringIO(message))
messageid = parser.getheader('Message-Id')
if messageid:
if not messageid.startswith('<') or not messageid.endswith('>'):
raise ValueError('Malformed Message-Id header')
messageid = messageid[1:-1]
else:
messageid = self.newMessageId()
message = 'Message-Id: <%s>\n%s' % (messageid, message)
transaction.get().join(
self.createDataManager(fromaddr, toaddrs, message))
return messageid
class DirectMailDelivery(AbstractMailDelivery):
__doc__ = IDirectMailDelivery.__doc__
implements(IDirectMailDelivery)
def __init__(self, mailer):
self.mailer = mailer
def createDataManager(self, fromaddr, toaddrs, message):
return MailDataManager(self.mailer.send,
args=(fromaddr, toaddrs, message))
class QueuedMailDelivery(AbstractMailDelivery):
__doc__ = IQueuedMailDelivery.__doc__
implements(IQueuedMailDelivery)
def __init__(self, queuePath):
self._queuePath = queuePath
queuePath = property(lambda self: self._queuePath)
def createDataManager(self, fromaddr, toaddrs, message):
maildir = Maildir(self.queuePath, True)
msg = maildir.newMessage()
msg.write('X-Zope-From: %s\n' % fromaddr)
msg.write('X-Zope-To: %s\n' % ", ".join(toaddrs))
msg.write(message)
msg.close()
return MailDataManager(msg.commit, onAbort=msg.abort)
|