[6718ec]: Allura / allura / command / smtp_server.py History

Child: [ddf08c] (diff)

Download this file

smtp_server.py    37 lines (29 with data), 1.2 kB 

 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
import smtpd

import asyncore



import tg

from paste.script import command



import allura.tasks

from allura.command import base



from paste.deploy.converters import asint



class SMTPServerCommand(base.Command):

    min_args=1

    max_args=1

    usage = '<ini file>'

    summary = 'Handle incoming emails, routing them to RabbitMQ'

    parser = command.Command.standard_parser(verbose=True)

    parser.add_option('-c', '--context', dest='context',

                      help=('The context of the message (path to the project'

                            ' and/or tool'))



    def command(self):

        self.basic_setup()

        MailServer((tg.config.get('forgemail.host', '0.0.0.0'),

                    asint(tg.config.get('forgemail.port', 8825))),

                   None)

        asyncore.loop()



class MailServer(smtpd.SMTPServer):



    def process_message(self, peer, mailfrom, rcpttos, data):

        base.log.info('Msg Received from %s for %s', mailfrom, rcpttos)

        base.log.info(' (%d bytes)', len(data))

        allura.tasks.mail_tasks.route_email(

            peer=peer, mailfrom=mailfrom, rcpttos=rcpttos, data=data)

        base.log.info('Msg passed along')