1 files changed, 86 insertions, 0 deletions
diff --git a/src/mailman_pgp/mta/personalized.py b/src/mailman_pgp/mta/personalized.py
new file mode 100644
index 0000000..0d58328
--- /dev/null
+++ b/src/mailman_pgp/mta/personalized.py
@@ -0,0 +1,86 @@
+# Copyright (C) 2017 Jan Jancar
+#
+# This file is a part of the Mailman PGP plugin.
+#
+# 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/>.
+
+""""""
+from mailman.mta.base import IndividualDelivery
+from mailman.mta.decorating import DecoratingMixin
+from mailman.mta.personalized import PersonalizedMixin
+from mailman.mta.verp import VERPMixin
+from public import public
+
+from mailman_pgp.model.address import PGPAddress
+from mailman_pgp.model.list import PGPMailingList
+from mailman_pgp.pgp.mime import MIMEWrapper
+from mailman_pgp.utils.email import overwrite_message
+
+
+class PGPIndividualMixin:
+    def sign_encrypt(self, mlist, msg, msgdata):
+        """
+
+        :param mlist:
+        :type mlist: mailman.model.mailinglist.MailingList
+        :param msg:
+        :type msg: mailman.email.message.Message
+        :param msgdata:
+        :type msgdata: dict
+        """
+        pgp_list = PGPMailingList.for_list(mlist)
+        if not pgp_list:
+            return
+        if not pgp_list.encrypt_outgoing and not pgp_list.sign_outgoing:
+            # nothing to do
+            return
+
+        recipient = msgdata['recipient']
+        pgp_address = PGPAddress.for_email(recipient)
+        if pgp_address is None:
+            # TODO: log failure here
+            return
+        if pgp_address.key is None or not pgp_address.key_confirmed:
+            # TODO: log failure here?
+            return
+
+        key = pgp_address.key
+        wrapped = MIMEWrapper(msg)
+        out = msg
+        if pgp_list.sign_outgoing:
+            if pgp_list.encrypt_outgoing:
+                out = wrapped.sign_encrypt(pgp_list.key, key, pgp_list.pubkey)
+            else:
+                out = wrapped.sign(pgp_list.key)
+        else:
+            if pgp_list.encrypt_outgoing:
+                out = wrapped.encrypt(key, pgp_list.pubkey)
+
+        if out is not msg:
+            overwrite_message(out, msg)
+
+
+@public
+class PGPPersonalizedDelivery(VERPMixin, DecoratingMixin, PersonalizedMixin,
+                              IndividualDelivery, PGPIndividualMixin):
+    """"""
+
+    def __init__(self):
+        super().__init__()
+        self.callbacks.extend([
+            self.avoid_duplicates,
+            self.decorate,
+            self.personalize_to,
+            self.sign_encrypt
+        ])