From: Mark Hymers <mhy@debian.org>
Date: Sat, 2 Aug 2008 23:14:07 +0000 (+0000)
Subject: merge Jeroen's lisa_existing_sources_first_and_mtime patch
X-Git-Url: https://git.decadent.org.uk/gitweb/?a=commitdiff_plain;h=93d36869f2334d117d195b01ed7faa14db9c1da8;p=dak.git

merge Jeroen's lisa_existing_sources_first_and_mtime patch

Signed-off-by: Mark Hymers <mhy@debian.org>
---

diff --git a/dak/process_new.py b/dak/process_new.py
index c0bc51f3..dbfe9700 100755
--- a/dak/process_new.py
+++ b/dak/process_new.py
@@ -151,7 +151,7 @@ def indiv_sg_compare (a, b):
 def sg_compare (a, b):
     a = a[1]
     b = b[1]
-    """Sort by have note, time of oldest upload."""
+    """Sort by have note, source already in database, time of oldest upload."""
     # Sort by have note
     a_note_state = a["note_state"]
     b_note_state = b["note_state"]
@@ -159,6 +159,10 @@ def sg_compare (a, b):
         return -1
     elif a_note_state > b_note_state:
         return 1
+    # Sort by source already in database (descending)
+    source_in_database = cmp(a["source_in_database"], b["source_in_database"])
+    if source_in_database:
+        return -source_in_database
 
     # Sort by time of oldest upload
     return cmp(a["oldest"], b["oldest"])
@@ -193,6 +197,9 @@ def sort_changes(changes_files):
         per_source[source]["list"].append(cache[filename])
     # Determine oldest time and have note status for each source group
     for source in per_source.keys():
+        q = projectB.query("SELECT 1 FROM source WHERE source = '%s'" % source)
+        ql = q.getresult()
+        per_source[source]["source_in_database"] = len(ql)>0
         source_list = per_source[source]["list"]
         first = source_list[0]
         oldest = os.stat(first["filename"])[stat.ST_MTIME]