1 files changed, 84 insertions, 0 deletions

diff --git a/email_gateway.py b/email_gateway.py
new file mode 100755
index 0000000..e73e3e2
--- /dev/null
+++ b/email_gateway.py
@@ -0,0 +1,84 @@
+#!/usr/bin/env python2.6
+
+import os
+import smtplib
+import re
+import urlparse
+from cStringIO import StringIO
+from email.mime.text import MIMEText
+from ConfigParser import SafeConfigParser as ConfigParser, NoSectionError
+
+
+config = ConfigParser()
+with open("/etc/email_gateway.cfg") as fp:
+    config.readfp(fp)
+
+
+def send_message(text, subject, to, from_email):
+    msg = MIMEText(text.getvalue(), "plain")
+
+    msg['Subject'] = subject
+    msg['From'] = from_email
+    msg['To'] = to
+
+    p = os.popen("/usr/sbin/sendmail -t", "w")
+    p.write(msg.as_string())
+    p.close()
+
+
+def email_app(environ, start_response):
+    ignored_fields = []
+    useful_fields = []
+    form_key = None
+    message_buffer = StringIO()
+
+    context = {}
+
+    fields = urlparse.parse_qsl(environ["wsgi.input"].read())
+    for key, value in fields:
+        if key == "mailer.form-key":
+            form_key = value
+        elif key == "mailer.redirect":
+            context["redirect"] = value
+        elif key == "mailer.subject":
+            context["subject"] = value
+        elif key == "mailer.message":
+            context["message"] = value
+        elif key == "mailer.fields.ignore":
+            ignored_fields = value.split(",")
+        else:
+            useful_fields.append((key, value))
+
+    try:
+        my_config = dict(config.items(form_key))
+        site_matcher = re.compile(my_config["site"])
+    except NoSectionError:
+        start_response('403 Forbidden', [('Content-Type', 'text/plain')])
+        return "Invalid form key!"
+
+    if not site_matcher.match(environ["HTTP_REFERER"]):
+        start_response('403 Forbidden', [('Content-Type', 'text/plain')])
+        return "Invalid send!"
+
+    useful_fields = ["{0}: {1}".format(*f)
+                     for f in useful_fields
+                     if f[0] not in ignored_fields]
+
+    message_buffer.write(context.get("message", my_config["message"]))
+    message_buffer.write("\n\n")
+    message_buffer.write("\n".join(useful_fields))
+
+    send_message(message_buffer,
+        context.get("subject", my_config["subject"]),
+        my_config["to"],
+        my_config["from"])
+
+    redirect_location = context.get("redirect", my_config["redirect"])
+    start_response('302 Found', [('Location', redirect_location)])
+
+    return ""
+
+
+if __name__ == "__main__":
+    from flup.server.fcgi_fork import WSGIServer
+    WSGIServer(email_app, maxSpare=1).run()