|
a |
|
b/mail/app/handlers/amqp.py |
|
|
1 |
import logging
|
|
|
2 |
from lamson.routing import route, route_like, stateless
|
|
|
3 |
from config.settings import relay
|
|
|
4 |
from lamson import view
|
|
|
5 |
|
|
|
6 |
|
|
|
7 |
@route("(address)@(host)", address=".+")
|
|
|
8 |
def START(message, address=None, host=None):
|
|
|
9 |
return NEW_USER
|
|
|
10 |
|
|
|
11 |
|
|
|
12 |
@route_like(START)
|
|
|
13 |
def NEW_USER(message, address=None, host=None):
|
|
|
14 |
return NEW_USER
|
|
|
15 |
|
|
|
16 |
|
|
|
17 |
@route_like(START)
|
|
|
18 |
def END(message, address=None, host=None):
|
|
|
19 |
return NEW_USER(message, address, host)
|
|
|
20 |
|
|
|
21 |
|
|
|
22 |
@route_like(START)
|
|
|
23 |
@stateless
|
|
|
24 |
def FORWARD(message, address=None, host=None):
|
|
|
25 |
relay.deliver(message)
|
|
|
26 |
|
|
|
27 |
@route("(post_name)@osb\\.(host)")
|
|
|
28 |
def POSTING(message, post_name=None, host=None):
|
|
|
29 |
# do the regular posting to blog thing
|
|
|
30 |
name, address = parseaddr(message['from'])
|
|
|
31 |
post.post(post_name, address, message)
|
|
|
32 |
msg = view.respond('page_ready.msg', locals())
|
|
|
33 |
relay.deliver(msg)
|
|
|
34 |
|
|
|
35 |
# drop the message off into the 'posts' queue for later
|
|
|
36 |
index_q = queue.Queue("run/posts")
|
|
|
37 |
index_q.push(message)
|
|
|
38 |
|
|
|
39 |
return POSTING
|