Add Joey and me to Uploaders:
[mirror/userdir-ldap.git] / ud-mailgate
1 #!/usr/bin/env python
2 # -*- mode: python -*-
3
4 #   Prior copyright probably rmurray, troup, joey, jgg -- weasel 2008
5 #   Copyright (c) 2008 Peter Palfrader <peter@palfrader.org>
6 #   Copyright (c) 2008 Joerg Jaspert <joerg@debian.org>
7
8 import userdir_gpg, userdir_ldap, sys, traceback, time, ldap, os, commands
9 import pwd, tempfile
10
11 from userdir_gpg import *
12 from userdir_ldap import *
13
14 # Error codes from /usr/include/sysexits.h
15 ReplyTo = ConfModule.replyto;
16 PingFrom = ConfModule.pingfrom;
17 ChPassFrom = ConfModule.chpassfrom;
18 ChangeFrom = ConfModule.changefrom;
19 ReplayCacheFile = ConfModule.replaycachefile;
20 SSHFingerprintFile = ConfModule.fingerprintfile
21
22 UUID_FORMAT = '[0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12}'
23
24 EX_TEMPFAIL = 75;
25 EX_PERMFAIL = 65;      # EX_DATAERR
26 Error = 'Message Error';
27 SeenKey = 0;
28 SeenDNS = 0;
29 mailRBL = {}
30 mailRHSBL = {}
31 mailWhitelist = {}
32 SeenList = {}
33 DNS = {}
34 SudoPasswd = {}
35
36 SSHFingerprint = re.compile('^(\d+) ([0-9a-f\:]{47}) (.+)$')
37 SSHRSA1Match = re.compile('^^(.* )?\d+ \d+ \d+')
38
39 GenderTable = {"male": 1,
40                "1": 1,
41                "female": 2,
42                "2": 2,
43                "unspecified": 9,
44                "9": 9,
45 };
46
47 ArbChanges = {"c": "..",
48               "l": ".*",
49               "facsimileTelephoneNumber": ".*",
50               "telephoneNumber": ".*",
51               "postalAddress": ".*",
52               "postalCode": ".*",
53               "loginShell": ".*",
54               "emailForward": "^([^<>@]+@.+)?$",
55               "jabberJID": "^([^<>@]+@.+)?$",
56               "ircNick": ".*",
57               "icqUin": "^[0-9]*$",
58               "onVacation": ".*",
59               "labeledURI": ".*",
60               "birthDate": "^([0-9]{4})([01][0-9])([0-3][0-9])$",
61               "mailDisableMessage": ".*",
62               "mailGreylisting": "^(TRUE|FALSE)$",
63               "mailCallout": "^(TRUE|FALSE)$",
64               "VoIP": ".*",
65               "gender": "^(1|2|9|male|female|unspecified)$",
66 };
67
68 DelItems = {"c": None,
69             "l": None,
70             "facsimileTelephoneNumber": None,
71             "telephoneNumber": None,
72             "postalAddress": None,
73             "postalCode": None,
74             "emailForward": None,
75             "ircNick": None,
76             "onVacation": None,
77             "labeledURI": None,
78             "latitude": None,
79             "longitude": None,
80             "icqUin": None,
81             "jabberJID": None,
82             "jpegPhoto": None,
83             "dnsZoneEntry": None,
84             "sshRSAAuthKey": None,
85             "birthDate" : None,
86             "mailGreylisting": None,
87             "mailCallout": None,
88             "mailRBL": None,
89             "mailRHSBL": None,
90             "mailWhitelist": None,
91             "mailDisableMessage": None,
92             "VoIP": None,
93             };
94
95
96 # Decode a GPS location from some common forms
97 def LocDecode(Str,Dir):
98    # Check for Decimal degrees, DGM, or DGMS
99    if re.match("^[+-]?[\d.]+$",Str) != None:
100       return Str;
101
102    Deg = '0'; Min = None; Sec = None; Dr = Dir[0];
103    
104    # Check for DDDxMM.MMMM where x = [nsew]
105    Match = re.match("^(\d+)(["+Dir+"])([\d.]+)$",Str);
106    if Match != None:
107       G = Match.groups();
108       Deg = G[0]; Min = G[2]; Dr = G[1];
109
110    # Check for DD.DD x 
111    Match = re.match("^([\d.]+) ?(["+Dir+"])$",Str);
112    if Match != None:
113       G = Match.groups();
114       Deg = G[0]; Dr = G[1];
115
116    # Check for DD:MM.MM x 
117    Match = re.match("^(\d+):([\d.]+) ?(["+Dir+"])$",Str);
118    if Match != None:
119       G = Match.groups();
120       Deg = G[0]; Min = G[1]; Dr = G[2];
121
122    # Check for DD:MM:SS.SS x
123    Match = re.match("^(\d+):(\d+):([\d.]+) ?(["+Dir+"])$",Str);
124    if Match != None:
125       G = Match.groups();
126       Deg = G[0]; Min = G[1]; Sec = G[2]; Dr = G[3];
127       
128    # Some simple checks
129    if float(Deg) > 180:
130       raise "Failed","Bad degrees";
131    if Min != None and float(Min) > 60:
132       raise "Failed","Bad minutes";
133    if Sec != None and float(Sec) > 60:
134       raise "Failed","Bad seconds";
135       
136    # Pad on an extra leading 0 to disambiguate small numbers
137    if len(Deg) <= 1 or Deg[1] == '.':
138       Deg = '0' + Deg;
139    if Min != None and (len(Min) <= 1 or Min[1] == '.'):
140       Min = '0' + Min;
141    if Sec != None and (len(Sec) <= 1 or Sec[1] == '.'):
142       Sec = '0' + Sec;
143    
144    # Construct a DGM/DGMS type value from the components.
145    Res = "+"
146    if Dr == Dir[1]:
147       Res = "-";
148    Res = Res + Deg;
149    if Min != None:
150       Res = Res + Min;
151    if Sec != None:
152       Res = Res + Sec;
153    return Res;
154               
155 # Handle changing a set of arbitary fields
156 #  <field>: value
157 def DoArbChange(Str,Attrs):
158    Match = re.match("^([^ :]+): (.*)$",Str);
159    if Match == None:
160       return None;
161    G = Match.groups();
162
163    attrName = G[0].lower();
164    for i in ArbChanges.keys():
165       if i.lower() == attrName:
166          attrName = i;
167          break;
168    if ArbChanges.has_key(attrName) == 0:
169       return None;
170
171    if re.match(ArbChanges[attrName],G[1]) == None:
172       raise Error, "Item does not match the required format"+ArbChanges[attrName];
173
174    value = G[1];
175    if attrName == 'gender':
176       if G[1] not in GenderTable:
177          raise Error, "Gender not found in table"
178       value = GenderTable[G[1]]
179
180 #   if attrName == 'birthDate':
181 #      (re.match("^([0-9]{4})([01][0-9])([0-3][0-9])$",G[1]) {
182 #    $bd_yr = $1; $bd_mo = $2; $bd_day = $3;
183 #    if ($bd_mo > 0 and $bd_mo <= 12 and $bd_day > 0) {
184 #      if ($bd_mo == 2) {
185 #        if ($bd_day == 29 and ($bd_yr == 0 or ($bd_yr % 4 == 0 && ($bd_yr % 100 != 0 || $bd_yr % 400 == 0)))) {
186 #          $bd_ok = 1;
187 #        } elsif ($bd_day <= 28) {
188 #          $bd_ok = 1;
189 #        }
190 #      } elsif ($bd_mo == 4 or $bd_mo == 6 or $bd_mo == 9 or $bd_mo == 11) {
191 #       if ($bd_day <= 30) {
192 #         $bd_ok = 1;
193 #       }
194 #      } else {
195 #       if ($bd_day <= 31) {
196 #         $bd_ok = 1;
197 #       }
198 #      }
199 #    }
200 #  } elsif (not defined($query->param('birthdate')) or $query->param('birthdate') =~ /^\s*$/) {
201 #    $bd_ok = 1;
202 #  }
203    Attrs.append((ldap.MOD_REPLACE,attrName,value));
204    return "Changed entry %s to %s"%(attrName,value);
205
206 # Handle changing a set of arbitary fields
207 #  <field>: value
208 def DoDel(Str,Attrs):
209    Match = re.match("^del (.*)$",Str);
210    if Match == None:
211       return None;
212    G = Match.groups();
213
214    attrName = G[0].lower();
215    for i in DelItems.keys():
216       if i.lower() == attrName:
217          attrName = i;
218          break;
219    if DelItems.has_key(attrName) == 0:
220       return "Cannot erase entry %s"%(attrName);
221
222    Attrs.append((ldap.MOD_DELETE,attrName,None));
223    return "Removed entry %s"%(attrName);
224
225 # Handle a position change message, the line format is:
226 #  Lat: -12412.23 Long: +12341.2342
227 def DoPosition(Str,Attrs):
228    Match = re.match("^lat: ([+\-]?[\d:.ns]+(?: ?[ns])?) long: ([+\-]?[\d:.ew]+(?: ?[ew])?)$", Str.lower())
229    if Match == None:
230       return None;
231
232    G = Match.groups();
233    try:
234       sLat = LocDecode(G[0],"ns");
235       sLong = LocDecode(G[1],"ew");
236       Lat = DecDegree(sLat,1);
237       Long = DecDegree(sLong,1);
238    except:
239       raise Error, "Positions were found, but they are not correctly formed";
240
241    Attrs.append((ldap.MOD_REPLACE,"latitude",sLat));
242    Attrs.append((ldap.MOD_REPLACE,"longitude",sLong));
243    return "Position set to %s/%s (%s/%s decimal degrees)"%(sLat,sLong,Lat,Long);
244
245 # Load bad ssh fingerprints
246 def LoadBadSSH():
247    f = open(SSHFingerprintFile, "r")
248    bad = []
249    FingerprintLine = re.compile('^([0-9a-f\:]{47}).*$')
250    for line in f.readlines():
251       Match = FingerprintLine.match(line)
252       if Match is not None:
253          g = Match.groups()
254          bad.append(g[0])
255    return bad
256
257 # Handle an SSH authentication key, the line format is:
258 #  [options] 1024 35 13188913666680[..] [comment]
259 def DoSSH(Str, Attrs, badkeys, uid):
260    Match = SSH2AuthSplit.match(Str);
261    if Match == None:
262       return None;
263    g = Match.groups()
264    typekey = g[1]
265    if Match == None:
266       Match = SSHRSA1Match.match(Str)
267       if Match is not None:
268          return "RSA1 keys not supported anymore"
269       return None;
270
271    (fd, path) = tempfile.mkstemp(".pub", "sshkeytry", "/tmp")
272    f = open(path, "w")
273    f.write("%s\n" % (Str))
274    f.close()
275    cmd = "/usr/bin/ssh-keygen -l -f %s < /dev/null" % (path)
276    (result, output) = commands.getstatusoutput(cmd)
277    os.remove(path)
278    if (result != 0):
279       raise Error, "ssh-keygen -l invocation failed!\n%s\n" % (output)
280
281
282    # Head
283    Date = time.strftime("%a, %d %b %Y %H:%M:%S +0000",time.gmtime(time.time()))
284    ErrReplyHead = "From: %s\nCc: %s\nReply-To: %s\nDate: %s\n" % (os.environ['SENDER'],os.environ['SENDER'],ReplyTo,Date)
285    Subst = {}
286    Subst["__ADMIN__"] = ReplyTo
287    Subst["__USER__"] = uid
288
289    Match = SSHFingerprint.match(output)
290    g = Match.groups()
291
292    if int(g[0]) < 1024:
293       try:
294          # Body
295          Subst["__ERROR__"] = "SSH keysize %s is below limit 1024" % (g[0])
296          ErrReply = TemplateSubst(Subst,open(TemplatesDir+"admin-info","r").read())
297
298          Child = os.popen("/usr/sbin/sendmail -t","w")
299          Child.write(ErrReplyHead)
300          Child.write(ErrReply)
301          if Child.close() != None:
302             raise Error, "Sendmail gave a non-zero return code"
303       except:
304          sys.exit(EX_TEMPFAIL)
305
306       # And now break and stop processing input, which sends a reply to the user.
307       raise Error, "SSH keys must have at least 1024 bits, processing halted, NOTHING MODIFIED AT ALL"
308    elif g[1] in badkeys:
309       try:
310          # Body
311          Subst["__ERROR__"] = "SSH key with fingerprint %s known as bad key" % (g[1])
312          ErrReply = TemplateSubst(Subst,open(TemplatesDir+"admin-info","r").read())
313
314          Child = os.popen("/usr/sbin/sendmail -t","w")
315          Child.write(ErrReplyHead)
316          Child.write(ErrReply)
317          if Child.close() != None:
318             raise Error, "Sendmail gave a non-zero return code"
319       except:
320          sys.exit(EX_TEMPFAIL)
321
322       # And now break and stop processing input, which sends a reply to the user.
323       raise Error, "Submitted SSH Key known to be bad and insecure, processing halted, NOTHING MODIFIED AT ALL"
324
325    if (typekey == "dss"):
326       return "DSA keys not accepted anymore"
327
328    global SeenKey;
329    if SeenKey:
330      Attrs.append((ldap.MOD_ADD,"sshRSAAuthKey",Str));
331      return "SSH Key added "+FormatSSHAuth(Str);
332       
333    Attrs.append((ldap.MOD_REPLACE,"sshRSAAuthKey",Str));
334    SeenKey = 1;
335    return "SSH Keys replaced with "+FormatSSHAuth(Str);
336
337 # Handle changing a dns entry
338 #  host IN A     12.12.12.12
339 #  host IN AAAA  1234::5678
340 #  host IN CNAME foo.bar.    <- Trailing dot is required
341 #  host IN MX    foo.bar.    <- Trailing dot is required
342 def DoDNS(Str,Attrs,DnRecord):
343    cnamerecord = re.match("^[-\w]+\s+IN\s+CNAME\s+([-\w.]+\.)$",Str,re.IGNORECASE)
344    arecord     = re.match('^[-\w]+\s+IN\s+A\s+(\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3})$',Str,re.IGNORECASE)
345    mxrecord    = re.match("^[-\w]+\s+IN\s+MX\s+(\d{1,3})\s+([-\w.]+\.)$",Str,re.IGNORECASE)
346    #aaaarecord  = re.match('^[-\w]+\s+IN\s+AAAA\s+((?:[0-9a-f]{1,4})(?::[0-9a-f]{1,4})*(?::(?:(?::[0-9a-f]{1,4})*|:))?)$',Str,re.IGNORECASE)
347    aaaarecord  = re.match('^[-\w]+\s+IN\s+AAAA\s+([A-F0-9:]{2,39})$',Str,re.IGNORECASE)
348
349    if cnamerecord == None and\
350       arecord == None and\
351       mxrecord == None and\
352       aaaarecord == None:
353      return None;
354
355    # Check if the name is already taken
356    G = re.match('^([-\w+]+)\s',Str)
357    if G == None:
358      raise Error, "Hostname not found although we already passed record syntax checks"
359    hostname = G.group(1)
360
361    # Check for collisions
362    global l;
363    # [JT 20070409 - search for both tab and space suffixed hostnames
364    #  since we accept either.  It'd probably be better to parse the
365    #  incoming string in order to construct what we feed LDAP rather
366    #  than just passing it through as is.]
367    filter = "(|(dnsZoneEntry=%s *)(dnsZoneEntry=%s *))" % (hostname, hostname)
368    Rec = l.search_s(BaseDn,ldap.SCOPE_ONELEVEL,filter,["uid"]);
369    for x in Rec:
370       if GetAttr(x,"uid") != GetAttr(DnRecord,"uid"):
371          return "DNS entry is already owned by " + GetAttr(x,"uid")
372
373    global SeenDNS;
374    global DNS;
375
376    if cnamerecord:
377      if DNS.has_key(hostname):
378        return "CNAME and other RR types not allowed: "+Str
379      else:
380        DNS[hostname] = 2
381    else:
382      if DNS.has_key(hostname) and DNS[hostname] == 2:
383        return "CNAME and other RR types not allowed: "+Str
384      else:
385        DNS[hostname] = 1
386
387    if cnamerecord != None:
388      sanitized = "%s IN CNAME %s" % (hostname, cnamerecord.group(1))
389    elif arecord != None:
390      ipaddress = arecord.group(1)
391      for quad in ipaddress.split('.'):
392        if not (int(quad) >=0 and int(quad) <= 255):
393          return "Invalid quad %s in IP address %s in line %s" %(quad, ipaddress, Str)
394      sanitized = "%s IN A %s"% (hostname, ipaddress)
395    elif mxrecord != None:
396      priority = mxrecord.group(1)
397      mx = mxrecord.group(2)
398      sanitized = "%s IN MX %s %s" % (hostname, priority, mx)
399    elif aaaarecord != None:
400      ipv6address = aaaarecord.group(1)
401      parts = ipv6address.split(':')
402      if len(parts) > 8:
403        return "Invalid IPv6 address (%s): too many parts"%(ipv6address)
404      if len(parts) <= 2:
405        return "Invalid IPv6 address (%s): too few parts"%(ipv6address)
406      if parts[0] == "":
407        parts.pop(0)
408      if parts[-1] == "":
409        parts.pop(-1)
410      seenEmptypart = False
411      for p in parts:
412        if len(p) > 4:
413          return "Invalid IPv6 address (%s): part %s is longer than 4 characters"%(ipv6address, p)
414        if p == "":
415          if seenEmptypart:
416            return "Invalid IPv6 address (%s): more than one :: (nothing in between colons) is not allowed"%(ipv6address)
417          seenEmptypart = True
418      sanitized = "%s IN AAAA %s" % (hostname, ipv6address)
419    else:
420      raise Error, "None of the types I recognize was it.  I shouldn't be here.  confused."
421
422    if SeenDNS:
423      Attrs.append((ldap.MOD_ADD,"dnsZoneEntry",sanitized));
424      return "DNS Entry added "+sanitized;
425
426    Attrs.append((ldap.MOD_REPLACE,"dnsZoneEntry",sanitized));
427    SeenDNS = 1;
428    return "DNS Entry replaced with "+sanitized;
429
430 # Handle an RBL list (mailRBL, mailRHSBL, mailWhitelist)
431 def DoRBL(Str,Attrs):
432    Match = re.compile('^mail(rbl|rhsbl|whitelist) ([-a-z0-9.]+)$').match(Str.lower())
433    if Match == None:
434       return None
435    
436    if Match.group(1) == "rbl":
437       Key = "mailRBL"
438    if Match.group(1) == "rhsbl":
439       Key = "mailRHSBL"
440    if Match.group(1) == "whitelist":
441       Key = "mailWhitelist"
442    Host = Match.group(2)
443
444    global SeenList
445    if SeenList.has_key(Key):
446      Attrs.append((ldap.MOD_ADD,Key,Host))
447      return "%s added %s" % (Key,Host)
448       
449    Attrs.append((ldap.MOD_REPLACE,Key,Host))
450    SeenList[Key] = 1;
451    return "%s replaced with %s" % (Key,Host)
452
453 # Handle a ConfirmSudoPassword request
454 def DoConfirmSudopassword(Str):
455    Match = re.compile('^confirm sudopassword ('+UUID_FORMAT+') ([a-z0-9.,*]+) ([0-9a-f]{40})$').match(Str)
456    if Match == None:
457       return None
458
459    uuid = Match.group(1)
460    hosts = Match.group(2)
461    hmac = Match.group(3)
462
463    global SudoPasswd
464    SudoPasswd[uuid] = (hosts, hmac)
465    return "got confirm for sudo password %s on host(s) %s, auth code %s" % (uuid,hosts, hmac)
466
467 def FinishConfirmSudopassword(l, uid, Attrs):
468    global SudoPasswd
469    result = "\n"
470
471    res = l.search_s(BaseDn,ldap.SCOPE_ONELEVEL,"uid="+uid, ['sudoPassword']);
472    if len(res) != 1:
473       raise Error, "Not exactly one hit when searching for user"
474    if res[0][1].has_key('sudoPassword'):
475       inldap = res[0][1]['sudoPassword']
476    else:
477       inldap = []
478
479    newldap = []
480    for entry in inldap:
481       Match = re.compile('^('+UUID_FORMAT+') (confirmed:[0-9a-f]{40}|unconfirmed) ([a-z0-9.,*]+) ([^ ]+)$').match(entry)
482       if Match == None:
483          raise Error, "Could not parse existing sudopasswd entry"
484       uuid = Match.group(1)
485       status = Match.group(2)
486       hosts = Match.group(3)
487       cryptedpass = Match.group(4)
488
489       if SudoPasswd.has_key(uuid):
490          confirmedHosts = SudoPasswd[uuid][0]
491          confirmedHmac = SudoPasswd[uuid][1]
492          if status.startswith('confirmed:'):
493             if status == 'confirmed:'+make_passwd_hmac('password-is-confirmed', 'sudo', uid, uuid, hosts, cryptedpass):
494                result = result + "Entry %s for sudo password on hosts %s already confirmed.\n"%(uuid, hosts)
495             else:
496                result = result + "Entry %s for sudo password on hosts %s is listed as confirmed, but HMAC does not verify.\n"%(uuid, hosts)
497          elif confirmedHosts != hosts:
498             result = result + "Entry %s hostlist mismatch (%s vs. %s).\n"%(uuid, hosts, confirmedHosts)
499          elif make_passwd_hmac('confirm-new-password', 'sudo', uid, uuid, hosts, cryptedpass) == confirmedHmac:
500             result = result + "Entry %s for sudo password on hosts %s now confirmed.\n"%(uuid, hosts)
501             status = 'confirmed:'+make_passwd_hmac('password-is-confirmed', 'sudo', uid, uuid, hosts, cryptedpass)
502          else:
503             result = result + "Entry %s for sudo password on hosts %s HMAC verify failed.\n"%(uuid, hosts)
504          del SudoPasswd[uuid]
505
506       newentry = " ".join([uuid, status, hosts, cryptedpass])
507       if len(newldap) == 0:
508          newldap.append((ldap.MOD_REPLACE,"sudoPassword",newentry))
509       else:
510          newldap.append((ldap.MOD_ADD,"sudoPassword",newentry))
511
512    for entry in SudoPasswd:
513       result = result + "Entry %s that you confirm is not listed in ldap."%(entry)
514
515    for entry in newldap:
516       Attrs.append(entry)
517
518    return result
519
520 # Handle an [almost] arbitary change
521 def HandleChange(Reply,DnRecord,Key):
522    global PlainText;
523    Lines = re.split("\n *\r?",PlainText);
524
525    Result = "";
526    Attrs = [];
527    Show = 0;
528    CommitChanges = 1
529    for Line in Lines: 
530       Line = Line.strip()
531       if Line == "":
532          continue;
533
534       # Try to process a command line
535       Result = Result + "> "+Line+"\n";
536       try:
537          if Line == "show":
538             Show = 1;
539             Res = "OK";
540          else:
541             badkeys = LoadBadSSH()
542             Res = DoPosition(Line,Attrs) or DoDNS(Line,Attrs,DnRecord) or \
543                   DoArbChange(Line,Attrs) or DoSSH(Line,Attrs,badkeys,GetAttr(DnRecord,"uid")) or \
544                   DoDel(Line,Attrs) or DoRBL(Line,Attrs) or DoConfirmSudopassword(Line)
545       except:
546          Res = None;
547          Result = Result + "==> %s: %s\n" %(sys.exc_type,sys.exc_value);
548
549       # Fail, if someone tries to send someone elses signed email to the
550       # daemon then we want to abort ASAP.
551       if Res == None:
552          CommitChanges = 0
553          Result = Result + "Command is not understood. Halted - no changes committed\n";
554          break;
555       Result = Result + Res + "\n";
556
557    # Connect to the ldap server
558    l = connectLDAP()
559    F = open(PassDir+"/pass-"+pwd.getpwuid(os.getuid())[0],"r");
560    AccessPass = F.readline().strip().split(" ")
561    F.close();
562
563    l.simple_bind_s("uid="+AccessPass[0]+","+BaseDn,AccessPass[1]);
564    oldAttrs = l.search_s(BaseDn,ldap.SCOPE_ONELEVEL,"uid="+GetAttr(DnRecord,"uid"));
565    if ((GetAttr(oldAttrs[0],"userPassword").find("*LK*") != -1) 
566        or GetAttr(oldAttrs[0],"userPassword").startswith("!")):
567       raise Error, "This account is locked";
568
569    if CommitChanges == 1: # only if we are still good to go
570       try:
571          Res = FinishConfirmSudopassword(l, GetAttr(DnRecord,"uid"), Attrs)
572          Result = Result + Res + "\n";
573       except Error, e:
574          CommitChanges = 0
575          Result = Result + "FinishConfirmSudopassword raised an error (%s) - no changes committed\n"%(e);
576
577    # Modify the record
578    if CommitChanges == 1:
579       Dn = "uid=" + GetAttr(DnRecord,"uid") + "," + BaseDn;
580       l.modify_s(Dn,Attrs);
581
582    Attribs = "";
583    if Show == 1:
584       Attrs = l.search_s(BaseDn,ldap.SCOPE_ONELEVEL,"uid="+GetAttr(DnRecord,"uid"));
585       if len(Attrs) == 0:
586          raise Error, "User not found"
587       Attribs = GPGEncrypt(PrettyShow(Attrs[0])+"\n","0x"+Key[1],Key[4]);
588
589    Subst = {};
590    Subst["__FROM__"] = ChangeFrom;
591    Subst["__EMAIL__"] = EmailAddress(DnRecord);
592    Subst["__ADMIN__"] = ReplyTo;
593    Subst["__RESULT__"] = Result;
594    Subst["__ATTR__"] = Attribs;
595
596    return Reply + TemplateSubst(Subst,open(TemplatesDir+"change-reply","r").read());
597    
598 # Handle ping handles an email sent to the 'ping' address (ie this program
599 # called with a ping argument) It replies with a dump of the public records.
600 def HandlePing(Reply,DnRecord,Key):
601    Subst = {};
602    Subst["__FROM__"] = PingFrom;
603    Subst["__EMAIL__"] = EmailAddress(DnRecord);
604    Subst["__LDAPFIELDS__"] = PrettyShow(DnRecord);
605    Subst["__ADMIN__"] = ReplyTo;
606
607    return Reply + TemplateSubst(Subst,open(TemplatesDir+"ping-reply","r").read());
608
609 # Handle a change password email sent to the change password address
610 # (this program called with the chpass argument)
611 def HandleChPass(Reply,DnRecord,Key):
612    # Generate a random password
613    Password = GenPass();
614    Pass = HashPass(Password);
615       
616    # Use GPG to encrypt it      
617    Message = GPGEncrypt("Your new password is '" + Password + "'\n",\
618                         "0x"+Key[1],Key[4]);
619    Password = None;
620
621    if Message == None:
622       raise Error, "Unable to generate the encrypted reply, gpg failed.";
623
624    if (Key[4] == 1):
625       Type = "Your message was encrypted using PGP 2.x\ncompatibility mode.";
626    else:
627       Type = "Your message was encrypted using GPG (OpenPGP)\ncompatibility "\
628              "mode, without IDEA. This message cannot be decoded using PGP 2.x";
629    
630    Subst = {};
631    Subst["__FROM__"] = ChPassFrom;
632    Subst["__EMAIL__"] = EmailAddress(DnRecord);
633    Subst["__CRYPTTYPE__"] = Type;
634    Subst["__PASSWORD__"] = Message;
635    Subst["__ADMIN__"] = ReplyTo;
636    Reply = Reply + TemplateSubst(Subst,open(TemplatesDir+"passwd-changed","r").read());
637    
638    # Connect to the ldap server
639    l = connectLDAP()
640    F = open(PassDir+"/pass-"+pwd.getpwuid(os.getuid())[0],"r");
641    AccessPass = F.readline().strip().split(" ")
642    F.close();
643    l.simple_bind_s("uid="+AccessPass[0]+","+BaseDn,AccessPass[1]);
644
645    # Check for a locked account
646    Attrs = l.search_s(BaseDn,ldap.SCOPE_ONELEVEL,"uid="+GetAttr(DnRecord,"uid"));
647    if (GetAttr(Attrs[0],"userPassword").find("*LK*") != -1) \
648              or GetAttr(Attrs[0],"userPassword").startswith("!"):
649       raise Error, "This account is locked";
650
651    # Modify the password
652    Rec = [(ldap.MOD_REPLACE,"userPassword","{crypt}"+Pass),
653           (ldap.MOD_REPLACE,"shadowLastChange",str(int(time.time()/24/60/60)))];
654    Dn = "uid=" + GetAttr(DnRecord,"uid") + "," + BaseDn;
655    l.modify_s(Dn,Rec);
656
657    return Reply;
658       
659 # Start of main program
660
661 # Drop messages from a mailer daemon.
662 if os.environ.has_key('SENDER') == 0 or len(os.environ['SENDER']) == 0:
663    sys.exit(0);
664
665 ErrMsg = "Indeterminate Error";
666 ErrType = EX_TEMPFAIL;
667 try:
668    # Startup the replay cache
669    ErrType = EX_TEMPFAIL;
670    ErrMsg = "Failed to initialize the replay cache:";
671    RC = ReplayCache(ReplayCacheFile);
672    RC.Clean();
673
674    # Get the email 
675    ErrType = EX_PERMFAIL;
676    ErrMsg = "Failed to understand the email or find a signature:";
677    Email = mimetools.Message(sys.stdin,0);
678    Msg = GetClearSig(Email);
679
680    ErrMsg = "Message is not PGP signed:"
681    if Msg[0].find("-----BEGIN PGP SIGNED MESSAGE-----") == -1 and \
682       Msg[0].find("-----BEGIN PGP MESSAGE-----") == -1:
683       raise Error, "No PGP signature";
684    
685    # Check the signature
686    ErrMsg = "Unable to check the signature or the signature was invalid:";
687    Res = GPGCheckSig(Msg[0]);
688
689    if Res[0] != None:
690       raise Error, Res[0];
691       
692    if Res[3] == None:
693       raise Error, "Null signature text";
694
695    # Extract the plain message text in the event of mime encoding
696    global PlainText;
697    ErrMsg = "Problem stripping MIME headers from the decoded message"
698    if Msg[1] == 1:
699       try:
700          Index = Res[3].index("\n\n") + 2;
701       except ValueError:
702          Index = Res[3].index("\n\r\n") + 3;
703       PlainText = Res[3][Index:];
704    else:
705       PlainText = Res[3];   
706
707    # Check the signature against the replay cache
708    ErrMsg = "The replay cache rejected your message. Check your clock!";
709    Rply = RC.Check(Res[1]);
710    if Rply != None:
711       raise Error, Rply;
712
713    # Connect to the ldap server
714    ErrType = EX_TEMPFAIL;
715    ErrMsg = "An error occured while performing the LDAP lookup";
716    global l;
717    l = connectLDAP()
718    l.simple_bind_s("","");
719
720    # Search for the matching key fingerprint
721    Attrs = l.search_s(BaseDn,ldap.SCOPE_ONELEVEL,"keyFingerPrint=" + Res[2][1]);
722
723    ErrType = EX_PERMFAIL;
724    if len(Attrs) == 0:
725       raise Error, "Key not found"
726    if len(Attrs) != 1:
727       raise Error, "Oddly your key fingerprint is assigned to more than one account.."
728
729    RC.Add(Res[1]);
730
731    # Determine the sender address
732    ErrMsg = "A problem occured while trying to formulate the reply";
733    Sender = Email.getheader("Reply-To");
734    if Sender == None:
735       Sender = Email.getheader("From");
736    if Sender == None:
737       raise Error, "Unable to determine the sender's address";
738
739    # Formulate a reply
740    Date = time.strftime("%a, %d %b %Y %H:%M:%S +0000",time.gmtime(time.time()));
741    Reply = "To: %s\nReply-To: %s\nDate: %s\n" % (Sender,ReplyTo,Date);
742
743    # Dispatch
744    if sys.argv[1] == "ping":
745       Reply = HandlePing(Reply,Attrs[0],Res[2]);
746    elif sys.argv[1] == "chpass":
747       if PlainText.strip().find("Please change my Debian password") != 0:
748          raise Error,"Please send a signed message where the first line of text is the string 'Please change my Debian password'";
749       Reply = HandleChPass(Reply,Attrs[0],Res[2]);
750    elif sys.argv[1] == "change":
751       Reply = HandleChange(Reply,Attrs[0],Res[2]);
752    else:
753       print sys.argv;
754       raise Error, "Incorrect Invokation";
755
756    # Send the message through sendmail      
757    ErrMsg = "A problem occured while trying to send the reply";
758    Child = os.popen("/usr/sbin/sendmail -t","w");
759 #   Child = os.popen("cat","w");
760    Child.write(Reply);
761    if Child.close() != None:
762       raise Error, "Sendmail gave a non-zero return code";
763
764 except:
765    # Error Reply Header
766    Date = time.strftime("%a, %d %b %Y %H:%M:%S +0000",time.gmtime(time.time()));
767    ErrReplyHead = "To: %s\nReply-To: %s\nDate: %s\n" % (os.environ['SENDER'],ReplyTo,Date);
768
769    # Error Body
770    Subst = {};
771    Subst["__ERROR__"] = ErrMsg;
772    Subst["__ADMIN__"] = ReplyTo;
773
774    Trace = "==> %s: %s\n" %(sys.exc_type,sys.exc_value);
775    List = traceback.extract_tb(sys.exc_traceback);
776    if len(List) > 1:
777       Trace = Trace + "Python Stack Trace:\n";
778       for x in List:
779          Trace = Trace +  "   %s %s:%u: %s\n" %(x[2],x[0],x[1],x[3]);
780
781    Subst["__TRACE__"] = Trace;
782
783    # Try to send the bounce
784    try:
785       ErrReply = TemplateSubst(Subst,open(TemplatesDir+"error-reply","r").read());
786
787       Child = os.popen("/usr/sbin/sendmail -t","w");
788       Child.write(ErrReplyHead);
789       Child.write(ErrReply);
790       if Child.close() != None:
791          raise Error, "Sendmail gave a non-zero return code";
792    except:
793       sys.exit(EX_TEMPFAIL);
794       
795    if ErrType != EX_PERMFAIL:
796       sys.exit(ErrType);
797    sys.exit(0);
798
799 # vim:set et:
800 # vim:set ts=3:
801 # vim:set shiftwidth=3: