validate_signature_field now raises a ValidationError if it finds an issue.
This commit is contained in:
+32
-34
@@ -105,6 +105,10 @@ class ParameterError(DKIMException):
|
|||||||
"""Input parameter error."""
|
"""Input parameter error."""
|
||||||
pass
|
pass
|
||||||
|
|
||||||
|
class ValidationError(DKIMException):
|
||||||
|
"""Validation error."""
|
||||||
|
pass
|
||||||
|
|
||||||
def _remove(s, t):
|
def _remove(s, t):
|
||||||
i = s.find(t)
|
i = s.find(t)
|
||||||
assert i >= 0
|
assert i >= 0
|
||||||
@@ -134,10 +138,11 @@ def hash_headers(hasher, canonicalize_headers, headers, include_headers,
|
|||||||
hasher.update(x[1])
|
hasher.update(x[1])
|
||||||
|
|
||||||
|
|
||||||
def validate_signature_fields(sig, debuglog=None):
|
def validate_signature_fields(sig):
|
||||||
"""Validate DKIM-Signature fields.
|
"""Validate DKIM-Signature fields.
|
||||||
|
|
||||||
Basic checks for presence and correct formatting of mandatory fields.
|
Basic checks for presence and correct formatting of mandatory fields.
|
||||||
|
Raises a ValidationError if checks fail, otherwise returns None.
|
||||||
|
|
||||||
@param sig: A dict mapping field keys to values.
|
@param sig: A dict mapping field keys to values.
|
||||||
@param debuglog: A file-like object to which details will be written
|
@param debuglog: A file-like object to which details will be written
|
||||||
@@ -146,48 +151,37 @@ def validate_signature_fields(sig, debuglog=None):
|
|||||||
mandatory_fields = ('v', 'a', 'b', 'bh', 'd', 'h', 's')
|
mandatory_fields = ('v', 'a', 'b', 'bh', 'd', 'h', 's')
|
||||||
for field in mandatory_fields:
|
for field in mandatory_fields:
|
||||||
if field not in sig:
|
if field not in sig:
|
||||||
if debuglog is not None:
|
raise ValidationError("signature missing %s=" % field)
|
||||||
print >>debuglog, "signature missing %s=" % field
|
|
||||||
return False
|
|
||||||
|
|
||||||
if sig['v'] != "1":
|
if sig['v'] != "1":
|
||||||
if debuglog is not None:
|
raise ValidationError("v= value is not 1 (%s)" % sig['v'])
|
||||||
print >>debuglog, "v= value is not 1 (%s)" % sig['v']
|
|
||||||
return False
|
|
||||||
if re.match(r"[\s0-9A-Za-z+/]+=*$", sig['b']) is None:
|
if re.match(r"[\s0-9A-Za-z+/]+=*$", sig['b']) is None:
|
||||||
if debuglog is not None:
|
raise ValidationError("b= value is not valid base64 (%s)" % sig['b'])
|
||||||
print >>debuglog, "b= value is not valid base64 (%s)" % sig['b']
|
|
||||||
return False
|
|
||||||
if re.match(r"[\s0-9A-Za-z+/]+=*$", sig['bh']) is None:
|
if re.match(r"[\s0-9A-Za-z+/]+=*$", sig['bh']) is None:
|
||||||
if debuglog is not None:
|
raise ValidationError(
|
||||||
print >>debuglog, "bh= value is not valid base64 (%s)" % sig['bh']
|
"bh= value is not valid base64 (%s)" % sig['bh'])
|
||||||
return False
|
if 'i' in sig and (
|
||||||
if 'i' in sig and (not sig['i'].endswith(sig['d']) or sig['i'][-len(sig['d'])-1] not in "@."):
|
not sig['i'].endswith(sig['d']) or
|
||||||
if debuglog is not None:
|
sig['i'][-len(sig['d'])-1] not in "@."):
|
||||||
print >>debuglog, "i= domain is not a subdomain of d= (i=%s d=%d)" % (sig['i'], sig['d'])
|
raise ValidationError(
|
||||||
return False
|
"i= domain is not a subdomain of d= (i=%s d=%d)" %
|
||||||
|
(sig['i'], sig['d']))
|
||||||
if 'l' in sig and re.match(r"\d{,76}$", sig['l']) is None:
|
if 'l' in sig and re.match(r"\d{,76}$", sig['l']) is None:
|
||||||
if debuglog is not None:
|
raise ValidationError(
|
||||||
print >>debuglog, "l= value is not a decimal integer (%s)" % sig['l']
|
"l= value is not a decimal integer (%s)" % sig['l'])
|
||||||
return False
|
|
||||||
if 'q' in sig and sig['q'] != "dns/txt":
|
if 'q' in sig and sig['q'] != "dns/txt":
|
||||||
if debuglog is not None:
|
raise ValidationError("q= value is not dns/txt (%s)" % sig['q'])
|
||||||
print >>debuglog, "q= value is not dns/txt (%s)" % sig['q']
|
|
||||||
return False
|
|
||||||
if 't' in sig and re.match(r"\d+$", sig['t']) is None:
|
if 't' in sig and re.match(r"\d+$", sig['t']) is None:
|
||||||
if debuglog is not None:
|
raise ValidationError(
|
||||||
print >>debuglog, "t= value is not a decimal integer (%s)" % sig['t']
|
"t= value is not a decimal integer (%s)" % sig['t'])
|
||||||
return False
|
|
||||||
if 'x' in sig:
|
if 'x' in sig:
|
||||||
if re.match(r"\d+$", sig['x']) is None:
|
if re.match(r"\d+$", sig['x']) is None:
|
||||||
if debuglog is not None:
|
raise ValidationError(
|
||||||
print >>debuglog, "x= value is not a decimal integer (%s)" % sig['x']
|
"x= value is not a decimal integer (%s)" % sig['x'])
|
||||||
return False
|
|
||||||
if int(sig['x']) < int(sig['t']):
|
if int(sig['x']) < int(sig['t']):
|
||||||
if debuglog is not None:
|
raise ValidationError(
|
||||||
print >>debuglog, "x= value is less than t= value (x=%s t=%s)" % (sig['x'], sig['t'])
|
"x= value is less than t= value (x=%s t=%s)" %
|
||||||
return False
|
(sig['x'], sig['t']))
|
||||||
return True
|
|
||||||
|
|
||||||
def rfc822_parse(message):
|
def rfc822_parse(message):
|
||||||
"""Parse a message in RFC822 format.
|
"""Parse a message in RFC822 format.
|
||||||
@@ -349,7 +343,11 @@ def verify(message, debuglog=None, dnsfunc=dnstxt):
|
|||||||
if debuglog is not None:
|
if debuglog is not None:
|
||||||
print >>debuglog, "sig:", sig
|
print >>debuglog, "sig:", sig
|
||||||
|
|
||||||
if not validate_signature_fields(sig, debuglog):
|
try:
|
||||||
|
validate_signature_fields(sig)
|
||||||
|
except ValidationError, e:
|
||||||
|
if debuglog is not None:
|
||||||
|
print >>debuglog, str(e)
|
||||||
return False
|
return False
|
||||||
|
|
||||||
m = re.match("(\w+)(?:/(\w+))?$", sig['c'])
|
m = re.match("(\w+)(?:/(\w+))?$", sig['c'])
|
||||||
|
|||||||
Reference in New Issue
Block a user