[857985]: ForgeMail / forgemail / app / command.py History

Parent: [a55eb0] (diff)

Child: [3abb2e] (diff)

Download this file

command.py    48 lines (39 with data), 1.5 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
37
38
39
40
41
42
43
44
45
46
47
import smtpd

import asyncore

import email.feedparser

from pprint import pformat



import tg

import pylons

from paste.script import command



import pyforge.command

from pyforge.lib.helpers import find_project

from pyforge.command import base



from paste.deploy.converters import asint



M = None



class SMTPServerCommand(pyforge.command.Command):

    min_args=1

    max_args=1

    usage = 'NAME <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):

        global M

        self.basic_setup()

        from pyforge import model

        M = model

        server = 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))

        pylons.g.publish('audit', 'forgemail.received_email',

                         dict(peer=peer, mailfrom=mailfrom,

                              rcpttos=rcpttos, data=data),

                         serializer='pickle')

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