X-Git-Url: https://git.decadent.org.uk/gitweb/?a=blobdiff_plain;ds=sidebyside;f=dak%2Fshow_new.py;fp=dak%2Fshow_new.py;h=513129f9c5d34f91623878ce8e305410bb38a89d;hb=475051efae41a30723cdc1ab82c521cd1accf75b;hp=3b052c18307be406181eef8d2c5e308101998339;hpb=e2baddaa67c0f22d42aff35dde78f09c72ab63a5;p=dak.git diff --git a/dak/show_new.py b/dak/show_new.py index 3b052c18..513129f9 100755 --- a/dak/show_new.py +++ b/dak/show_new.py @@ -154,23 +154,39 @@ def do_pkg(changes_file): session = DBConn().session() u = Upload() u.pkg.changes_file = changes_file - (u.pkg.changes["fingerprint"], rejects) = utils.check_signature(changes_file) + # We can afoord not to check the signature before loading the changes file + # as we've validated it already (otherwise it couldn't be in new) + # and we can more quickly skip over already processed files this way u.load_changes(changes_file) - new_queue = get_policy_queue('new', session ); - u.pkg.directory = new_queue.path - u.update_subst() + origchanges = os.path.abspath(u.pkg.changes_file) - files = u.pkg.files - changes = u.pkg.changes - htmlname = changes["source"] + "_" + changes["version"] + ".html" - sources.add(htmlname) - htmlfile = os.path.join(cnf["Show-New::HTMLPath"], htmlname) + # Still be cautious in case paring the changes file went badly + if u.pkg.changes.has_key('source') and u.pkg.changes.has_key('version'): + htmlname = u.pkg.changes["source"] + "_" + u.pkg.changes["version"] + ".html" + htmlfile = os.path.join(cnf["Show-New::HTMLPath"], htmlname) + else: + # Changes file was bad + print "Changes file %s missing source or version field" % changes_file + session.close() + return + + # Have we already processed this? if os.path.exists(htmlfile) and \ os.stat(htmlfile).st_mtime > os.stat(origchanges).st_mtime: + sources.add(htmlname) session.close() return (PROC_STATUS_SUCCESS, '%s already up-to-date' % htmlfile) + # Now we'll load the fingerprint + (u.pkg.changes["fingerprint"], rejects) = utils.check_signature(changes_file, session=session) + new_queue = get_policy_queue('new', session ); + u.pkg.directory = new_queue.path + u.update_subst() + files = u.pkg.files + changes = u.pkg.changes + sources.add(htmlname) + for deb_filename, f in files.items(): if deb_filename.endswith(".udeb") or deb_filename.endswith(".deb"): u.binary_file_checks(deb_filename, session) @@ -259,6 +275,7 @@ def main(): continue print "\n" + changes_file pool.apply_async(do_pkg, (changes_file,)) + do_pkg(changes_file) pool.close() pool.join()