Add datastore-for-each-build

2 files changed, 25 insertions, 0 deletions

diff --git a/guix-build-coordinator/datastore.scm b/guix-build-coordinator/datastore.scm
index e888387..eecff9c 100644
--- a/guix-build-coordinator/datastore.scm
+++ b/guix-build-coordinator/datastore.scm
@@ -32,6 +32,7 @@
 (re-export datastore-new-agent-password)
 (re-export datastore-agent-password-exists?)
 (re-export datastore-count-builds)
+(re-export datastore-for-each-build)
 (re-export datastore-find-build)
 (re-export datastore-find-build-result)
 (re-export datastore-list-builds-for-derivation)
diff --git a/guix-build-coordinator/datastore/sqlite.scm b/guix-build-coordinator/datastore/sqlite.scm
index e8d1ee2..9c9172a 100644
--- a/guix-build-coordinator/datastore/sqlite.scm
+++ b/guix-build-coordinator/datastore/sqlite.scm
@@ -18,6 +18,7 @@
             datastore-list-builds-for-derivation-recursive-inputs
             datastore-store-build
             datastore-count-builds
+            datastore-for-each-build
             datastore-find-build
             datastore-find-build-result
             datastore-list-builds-for-derivation
@@ -807,6 +808,29 @@ GROUP BY derivations.system")))
 
          result)))))
 
+(define-method (datastore-for-each-build
+                (datastore <sqlite-datastore>)
+                proc)
+  (call-with-worker-thread
+   (slot-ref datastore 'worker-reader-thread-channel)
+   (lambda (db)
+     (let ((statement
+            (sqlite-prepare
+             db
+             "
+SELECT uuid FROM builds ORDER BY uuid")))
+
+       (let loop ((row (sqlite-step statement)))
+         (match row
+           (#(uuid)
+            (proc uuid)
+
+            (loop (sqlite-step statement)))
+           (#f
+            (sqlite-reset statement)
+
+            #t)))))))
+
 (define-method (datastore-find-build
                 (datastore <sqlite-datastore>)
                 uuid)