Backported getRecentBuildsets from buildbot 0.8.8 (to use it in RietveldPollerWithCache)

third_party/buildbot_8_4p1/buildbot/db/buildsets.py

 # This file is part of Buildbot.  Buildbot is free software: you can
 # redistribute it and/or modify it under the terms of the GNU General Public
 # License as published by the Free Software Foundation, version 2.
 #
 # This program is distributed in the hope that it will be useful, but WITHOUT
 # ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
 # FOR A PARTICULAR PURPOSE.  See the GNU General Public License for more
 # details.
 #
 # You should have received a copy of the GNU General Public License along with
@@ skipping 172 matching lines @@
             if complete is not None:
                 if complete:
                     q = q.where(bs_tbl.c.complete != 0)
                 else:
                     q = q.where((bs_tbl.c.complete == 0) |
                                 (bs_tbl.c.complete == None))
             res = conn.execute(q)
             return [ self._row2dict(row) for row in res.fetchall() ]
         return self.db.pool.do(thd)
 
+    def getRecentBuildsets(self, count, branch=None, repository=None,
+                           complete=None):
+        def thd(conn):
+            bs_tbl = self.db.model.buildsets
+            ch_tbl = self.db.model.changes
+            j = sa.join(self.db.model.buildsets,
+                        self.db.model.sourcestamps)
+            j = j.join(self.db.model.sourcestamp_changes)
+            j = j.join(ch_tbl)
+            q = sa.select(columns=[bs_tbl], from_obj=[j],
+                          distinct=True)
+            q = q.order_by(sa.desc(bs_tbl.c.id))
+            q = q.limit(count)
+
+            if complete is not None:
+                if complete:
+                    q = q.where(bs_tbl.c.complete != 0)
+                else:
+                    q = q.where((bs_tbl.c.complete == 0) |
+                                (bs_tbl.c.complete == None))
+            if branch:
+              q = q.where(ch_tbl.c.branch == branch)
+            if repository:
+              q = q.where(ch_tbl.c.repository == repository)
+            res = conn.execute(q)
+            return list(reversed([self._row2dict(row)
+                                  for row in res.fetchall()]))
+        return self.db.pool.do(thd)
+
     def getBuildsetProperties(self, buildsetid):
         """
         Return the properties for a buildset, in the same format they were
         given to L{addBuildset}.
 
         Note that this method does not distinguish a nonexistent buildset from
         a buildset with no properties, and returns C{{}} in either case.
 
         @param buildsetid: buildset ID
 
@@ skipping 83 matching lines @@
     def _row2dict(self, row):
         def mkdt(epoch):
             if epoch:
                 return epoch2datetime(epoch)
         return BsDict(external_idstring=row.external_idstring,
                 reason=row.reason, sourcestampid=row.sourcestampid,
                 submitted_at=mkdt(row.submitted_at),
                 complete=bool(row.complete),
                 complete_at=mkdt(row.complete_at), results=row.results,
                 bsid=row.id)