diff options
author | Rob Austein <sra@hactrn.net> | 2007-12-22 23:41:27 +0000 |
---|---|---|
committer | Rob Austein <sra@hactrn.net> | 2007-12-22 23:41:27 +0000 |
commit | 8a65f4d8166d946a6a10fd4c869eb1b005d24879 (patch) | |
tree | 3dcec68d2000afe01a1146606cc60118117859b3 /scripts/rpki/sql.py | |
parent | 6a2b0a47212bb2213ff207972100508a9816c9b4 (diff) |
Checkpoint
svn path=/scripts/rpki/left_right.py; revision=1425
Diffstat (limited to 'scripts/rpki/sql.py')
-rw-r--r-- | scripts/rpki/sql.py | 19 |
1 files changed, 11 insertions, 8 deletions
diff --git a/scripts/rpki/sql.py b/scripts/rpki/sql.py index 865ef5a2..ffeca909 100644 --- a/scripts/rpki/sql.py +++ b/scripts/rpki/sql.py @@ -1,6 +1,6 @@ # $Id$ -import MySQLdb, time +import MySQLdb, time, traceback import rpki.x509, rpki.resource_set, rpki.sundial def connect(cfg, section="sql"): @@ -88,10 +88,9 @@ class sql_persistant(object): elif len(results) == 1: return results[0] else: - if args is not None: - where = where % args raise rpki.exceptions.DBConsistancyError, \ - "Database contained multiple matches for %s where %s" % (cls.__name__, where) + "Database contained multiple matches for %s where %s" % \ + (cls.__name__, where % tuple(repr(a) for a in args)) @classmethod def sql_fetch_all(cls, gctx): @@ -498,7 +497,8 @@ class ca_detail_obj(sql_persistant): serial = ca.next_serial_number(), aia = self.ca_cert_uri, crldp = self.crl_uri(ca), - sia = sia, + sia = ((rpki.oids.name2oid["id-ad-caRepository"], ("uri", ca.sia_uri)), + (rpki.oids.name2oid["id-ad-rpkiManifest"], ("uri", self.manifest_uri(ca)))), resources = resources, notAfter = resources.valid_until) @@ -622,6 +622,9 @@ class child_cert_obj(sql_persistant): must_revoke = old_resources.oversized(resources) or old_resources.valid_until > resources.valid_until + if resources.valid_until != old_resources.valid_until: + rpki.log.debug("Validity changed: %s %s" % ( old_resources.valid_until, resources.valid_until)) + if must_revoke: child_cert = None else: @@ -652,10 +655,10 @@ class child_cert_obj(sql_persistant): """ args = [] + where = "revoked IS" if revoked: - where = "revoked IS NOT NULL" - else: - where = "revoked IS NULL" + where += " NOT" + where += " NULL" if child: where += " AND child_id = %s" args.append(child.child_id) |