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
|
#!/usr/bin/env python
# -*- encoding: utf-8 -*-
# alias_resolver.py
# Copyright (C) 2013 LEAP
#
# This program 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.
#
# This program 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 this program. If not, see <http://www.gnu.org/licenses/>.
"""
Classes for resolving postfix aliases.
The resolver is queried by the mail server before delivery to the mail spool
directory, and should return the user uuid. This way, we get rid from the user
address early and the mail server will delivery the message to
"<uuid>@<domain>". Later, the mail receiver part of MX will parse the
"Delivered-To" header to extract the uuid and fetch the user's pgp public key.
Test this with postmap -v -q "foo" tcp:localhost:4242
TODO:
o Look into using twisted.protocols.postfix.policies classes for
controlling concurrent connections and throttling resource consumption.
o We should probably use twisted.mail.alias somehow.
"""
from twisted.protocols import postfix
from leap.mx.tcp_map import LEAPPostfixTCPMapServerFactory
from leap.mx.tcp_map import TCP_MAP_CODE_SUCCESS
from leap.mx.tcp_map import TCP_MAP_CODE_PERMANENT_FAILURE
class LEAPPostfixTCPMapAliasServer(postfix.PostfixTCPMapServer):
"""
A postfix tcp map alias resolver server.
"""
def _cbGot(self, user_data):
"""
Return a code and message depending on the result of the factory's
get().
:param user_data: The user's uuid and pgp public key.
:type user_data: list
"""
uuid, _ = user_data
if uuid is None:
self.sendCode(
TCP_MAP_CODE_PERMANENT_FAILURE,
postfix.quote("NOT FOUND SRY"))
else:
# properly encode uuid, otherwise twisted complains when replying
if isinstance(uuid, unicode):
uuid = uuid.encode("utf8")
self.sendCode(
TCP_MAP_CODE_SUCCESS,
postfix.quote(uuid))
class AliasResolverFactory(LEAPPostfixTCPMapServerFactory):
"""
A factory for postfix tcp map alias resolver servers.
"""
protocol = LEAPPostfixTCPMapAliasServer
@property
def _query_message(self):
return "Resolving alias for"
|
