unmaintained/gpgwrapper

   1 #!/usr/bin/env python
   2 # -*- mode: python -*-
   3 #
   4 # Check and decode PGP signed emails.
   5 # This script implements a wrapper around another program. It takes a mail
   6 # on stdin and processes off a PGP signature, verifying it and seperating
   7 # out the checked plaintext. It then invokes a sub process and feeds it
   8 # the verified plain text and sets environment vairables indicating the
   9 # result of the PGP check. If PGP checking fails then the subprocess is
  10 # is never run and a bounce message is generated. The wrapper can understand
  11 # PGP-MIME and all signatures supported by GPG. It completely decodes
  12 # PGP-MIME before running the subprocess. It also can do optional
  13 # anti-replay checking on the signatures.
  14 #
  15 # If enabled it can also do LDAP checking to determine the uniq UID owner
  16 # of the key.
  17 #
  18 # Options:
  19 #  -r  Replay cache file, if unset replay checking is disabled
  20 #  -e  Bounce error message template file, if unset very ugly bounces are
  21 #      made
  22 #  -k  Colon seperated list of keyrings to use
  23 #  -a  Reply to address (mail daemon administrator)
  24 #  -d  LDAP search base DN
  25 #  -l  LDAP server
  26 #  -m  Email address to use when prettying up LDAP_EMAIL
  27 #
  28 # It exports the following environment variables:
  29 #  LDAP_EMAIL="Adam Di Carlo <aph@debian.org>"
  30 #  LDAP_UID="aph"
  31 #  PGP_FINGERPRINT="E21E5D13FAD42A54F1AA5A00D801CE55"
  32 #  PGP_KEYID="8FFC405EFD5A67CD"
  33 #  PGP_KEYNAME="Adam Di Carlo <aph@debian.org> "
  34 #  SENDER (from mailer - envelope sender for bounces)
  35 #  REPLYTO (generated from message headers)
  36 #
  37 # Typical Debian invokation may look like:
  38 # ./gpgwrapper -k /usr/share/keyrings/debian-keyring.gpg:/usr/share/keyrings/debian-keyring.pgp \
  39 #      -d ou=users,dc=debian,dc=org -l db.debian.org \
  40 #      -m debian.org -a admin@db.debian.org \
  41 #      -e /etc/userdir-ldap/templtes/error-reply -- test.sh
  42
  43 import sys, traceback, time, os;
  44 import pwd, getopt;
  45 from userdir_gpg import *;
  46
  47 EX_TEMPFAIL = 75;
  48 EX_PERMFAIL = 65;      # EX_DATAERR
  49 Error = 'Message Error';
  50 ReplyTo = "admin@db";
  51
  52 # Configuration
  53 ReplayCacheFile = None;
  54 ErrorTemplate = None;
  55 LDAPDn = None;
  56 LDAPServer = None;
  57 EmailAppend = "";
  58
  59 # Safely get an attribute from a tuple representing a dn and an attribute
  60 # list. It returns the first attribute if there are multi.
  61 def GetAttr(DnRecord,Attribute,Default = ""):
  62    try:
  63       return DnRecord[1][Attribute][0];
  64    except IndexError:
  65       return Default;
  66    except KeyError:
  67       return Default;
  68    return Default;
  69
  70 # Return a printable email address from the attributes.
  71 def EmailAddress(DnRecord):
  72    cn = GetAttr(DnRecord,"cn");
  73    sn = GetAttr(DnRecord,"sn");
  74    uid = GetAttr(DnRecord,"uid");
  75    if cn == "" and sn == "":
  76       return "<" + uid + "@" + EmailAppend + ">";
  77    return cn + " " + sn + " <" + uid + "@" + EmailAppend + ">"
  78
  79 # Match the key fingerprint against an LDAP directory
  80 def CheckLDAP(FingerPrint):
  81    import ldap;
  82
  83    # Connect to the ldap server
  84    global ErrTyp, ErrMsg;
  85    ErrType = EX_TEMPFAIL;
  86    ErrMsg = "An error occured while performing the LDAP lookup";
  87    global l;
  88    l = connectLDAP(LDAPServer);
  89    l.simple_bind_s("","");
  90
  91    # Search for the matching key fingerprint
  92    Attrs = l.search_s(LDAPDn,ldap.SCOPE_ONELEVEL,"keyfingerprint=" + FingerPrint);
  93    if len(Attrs) == 0:
  94       raise Error, "Key not found"
  95    if len(Attrs) != 1:
  96       raise Error, "Oddly your key fingerprint is assigned to more than one account.."
  97
  98    os.environ["LDAP_UID"] = GetAttr(Attrs[0],"uid");
  99    os.environ["LDAP_EMAIL"] = EmailAddress(Attrs[0]);
 100
 101 # Start of main program
 102 # Process options
 103 (options, arguments) = getopt.getopt(sys.argv[1:], "r:e:k:a:d:l:m:");
 104 for (switch, val) in options:
 105    if (switch == '-r'):
 106       ReplayCacheFile = val;
 107    elif (switch == '-e'):
 108       ErrorTemplate  = val;
 109    elif (switch == '-k'):
 110       SetKeyrings(val.split(":"));
 111    elif (switch == '-a'):
 112       ReplyTo = val;
 113    elif (switch == '-d'):
 114       LDAPDn = val;
 115    elif (switch == '-l'):
 116       LDAPServer = val;
 117    elif (switch == '-m'):
 118       EmailAppend = val;
 119
 120 # Drop messages from a mailer daemon. (empty sender)
 121 if os.environ.has_key('SENDER') == 0 or len(os.environ['SENDER']) == 0:
 122    sys.exit(0);
 123
 124 ErrMsg = "Indeterminate Error";
 125 ErrType = EX_TEMPFAIL;
 126 try:
 127    # Startup the replay cache
 128    ErrType = EX_TEMPFAIL;
 129    if ReplayCacheFile != None:
 130       ErrMsg = "Failed to initialize the replay cache:";
 131       RC = ReplayCache(ReplayCacheFile);
 132       RC.Clean();
 133
 134    # Get the email
 135    ErrType = EX_PERMFAIL;
 136    ErrMsg = "Failed to understand the email or find a signature:";
 137    Email = mimetools.Message(sys.stdin,0);
 138    Msg = GetClearSig(Email);
 139
 140    ErrMsg = "Message is not PGP signed:"
 141    if Msg[0].find("-----BEGIN PGP SIGNED MESSAGE-----") == -1:
 142       raise Error, "No PGP signature";
 143
 144    # Check the signature
 145    ErrMsg = "Unable to check the signature or the signature was invalid:";
 146    Res = GPGCheckSig(Msg[0]);
 147
 148    if Res[0] != None:
 149       raise Error, Res[0];
 150
 151    if Res[3] == None:
 152       raise Error, "Null signature text";
 153
 154    # Extract the plain message text in the event of mime encoding
 155    global PlainText;
 156    ErrMsg = "Problem stripping MIME headers from the decoded message"
 157    if Msg[1] == 1:
 158       try:
 159          Index = Res[3].index("\n\n") + 2;
 160       except ValueError:
 161          Index = Res[3].index("\n\r\n") + 3;
 162       PlainText = Res[3][Index:];
 163    else:
 164       PlainText = Res[3];
 165
 166    # Check the signature against the replay cache
 167    if ReplayCacheFile != None:
 168       ErrMsg = "The replay cache rejected your message. Check your clock!";
 169       Rply = RC.Check(Res[1]);
 170       if Rply != None:
 171          raise Error, Rply;
 172       RC.Add(Res[1]);
 173
 174    # Do LDAP stuff
 175    if LDAPDn != None:
 176       CheckLDAP(Res[2][1]);
 177
 178    # Determine the sender address
 179    ErrType = EX_PERMFAIL;
 180    ErrMsg = "A problem occured while trying to formulate the reply";
 181    Sender = Email.getheader("Reply-To");
 182    if Sender == None:
 183       Sender = Email.getheader("From");
 184    if Sender == None:
 185       raise Error, "Unable to determine the sender's address";
 186
 187    # Setup the environment
 188    ErrType = EX_TEMPFAIL;
 189    ErrMsg = "Problem calling the child process"
 190    os.environ["PGP_KEYID"] = Res[2][0];
 191    os.environ["PGP_FINGERPRINT"] = Res[2][1];
 192    os.environ["PGP_KEYNAME"] = Res[2][2];
 193    os.environ["REPLYTO"] = Sender;
 194
 195    # Invoke the child
 196    Child = os.popen(" ".join(arguments),"w");
 197    Child.write(PlainText);
 198    if Child.close() != None:
 199       raise Error, "Child gave a non-zero return code";
 200
 201 except:
 202    # Error Reply Header
 203    Date = time.strftime("%a, %d %b %Y %H:%M:%S +0000",time.gmtime(time.time()));
 204    ErrReplyHead = "To: %s\nReply-To: %s\nDate: %s\n" % (os.environ['SENDER'],ReplyTo,Date);
 205
 206    # Error Body
 207    Subst = {};
 208    Subst["__ERROR__"] = ErrMsg;
 209    Subst["__ADMIN__"] = ReplyTo;
 210
 211    Trace = "==> %s: %s\n" %(sys.exc_type,sys.exc_value);
 212    List = traceback.extract_tb(sys.exc_traceback);
 213    if len(List) >= 1:
 214       Trace = Trace + "Python Stack Trace:\n";
 215       for x in List:
 216          Trace = Trace +  "   %s %s:%u: %s\n" %(x[2],x[0],x[1],x[3]);
 217
 218    Subst["__TRACE__"] = Trace;
 219
 220    # Try to send the bounce
 221    try:
 222       if ErrorTemplate != None:
 223          ErrReply = TemplateSubst(Subst,open(ErrorTemplate,"r").read());
 224       else:
 225          ErrReply = "\n"+str(Subst)+"\n";
 226
 227       Child = os.popen("/usr/sbin/sendmail -t","w");
 228       Child.write(ErrReplyHead);
 229       Child.write(ErrReply);
 230       if Child.close() != None:
 231          raise Error, "Sendmail gave a non-zero return code";
 232    except:
 233       sys.exit(EX_TEMPFAIL);
 234
 235    if ErrType != EX_PERMFAIL:
 236       sys.exit(ErrType);
 237    sys.exit(0);
 238