#!/usr/bin/env python # -*- encoding: utf-8 -*- # check_recipient_access.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 . """ Classes for resolving postfix recipient access Test this with postmap -v -q "foo" tcp:localhost:2244 """ 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_TEMPORARY_FAILURE from leap.mx.tcp_map import TCP_MAP_CODE_PERMANENT_FAILURE class LEAPPostFixTCPMapAccessServer(postfix.PostfixTCPMapServer): """ A postfix tcp map recipient access checker server. The server potentially receives the uuid and a PGP key for the user, which are looked up by the factory, and will return a permanent or a temporary failure in case either the user or the key don't exist, respectivelly. """ def _cbGot(self, value): """ Return a code and message depending on the result of the factory's get(). For more info, see: http://www.postfix.org/access.5.html :param value: The uuid and public key. :type value: list """ uuid, pubkey = value if uuid is None: self.sendCode( TCP_MAP_CODE_PERMANENT_FAILURE, postfix.quote("REJECT")) elif pubkey is None: self.sendCode( TCP_MAP_CODE_TEMPORARY_FAILURE, postfix.quote("4.7.13 USER ACCOUNT DISABLED")) else: self.sendCode( TCP_MAP_CODE_SUCCESS, postfix.quote("OK")) class CheckRecipientAccessFactory(LEAPPostfixTCPMapServerFactory): """ A factory for the recipient access checker. When queried, the factory looks up the user's uuid and a PGP key for that user and returns the result to the server's _cbGot() method. """ protocol = LEAPPostFixTCPMapAccessServer @property def _query_message(self): return "Checking recipient access for"