Add support for processing branch updated emails

guix-data-service/branch-updated-emails.scm

@@ -0,0 +1,40 @@
+;;; Guix Data Service -- Information about Guix over time
+;;; Copyright © 2019 Christopher Baines <mail@cbaines.net>
+;;;
+;;; This program is free software: you can redistribute it and/or
+;;; modify it under the terms of the GNU Affero General Public License
+;;; as published by the Free Software Foundation, either version 3 of
+;;; the License, or (at your option) any later version.
+;;;
+;;; 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
+;;; Affero General Public License for more details.
+;;;
+;;; You should have received a copy of the GNU Affero General Public
+;;; License along with this program.  If not, see
+;;; <http://www.gnu.org/licenses/>.
+
+(define-module (guix-data-service branch-updated-emails)
+  #:use-module (email email)
+  #:use-module (guix-data-service jobs load-new-guix-revision)
+  #:export (enqueue-job-for-email))
+
+(define %repository-url-for-repo
+  '(("guix" . "https://git.savannah.gnu.org/git/guix.git")))
+
+(define (enqueue-job-for-email conn email)
+  (let* ((headers       (email-headers email))
+         (x-git-repo    (assq-ref headers 'x-git-repo))
+         (x-git-reftype (assq-ref headers 'x-git-reftype))
+         (x-git-refname (assq-ref headers 'x-git-refname))
+         (x-git-newrev  (assq-ref headers 'x-git-newrev)))
+    (when (and (string=? x-git-reftype "branch")
+               (string=? x-git-repo "guix")
+               (string? x-git-newrev))
+      (enqueue-load-new-guix-revision-job
+       conn
+       (assoc-ref %repository-url-for-repo
+                  x-git-repo)
+       x-git-newrev
+       (string-append x-git-repo " " x-git-refname " updated")))))

guix-data-service/jobs/load-new-guix-revision.scm

@@ -20,6 +20,7 @@
   #:use-module (guix-data-service model derivation)
   #:export (process-next-load-new-guix-revision-job
             select-job-for-commit
+            enqueue-load-new-guix-revision-job
             most-recent-n-load-new-guix-revision-jobs))
 
 (define inferior-package-id
@@ -314,6 +315,18 @@
           (and store-item
                (extract-information-from store conn url commit store-item))))))
 
+(define (enqueue-load-new-guix-revision-job conn url commit source)
+  (define query
+    "
+INSERT INTO load_new_guix_revision_jobs (url, commit, source)
+VALUES ($1, $2, $3)
+RETURNING id;")
+
+  (first
+   (exec-query conn
+               query
+               (list url commit source))))
+
 (define (select-job-for-commit conn commit)
   (let ((result
          (exec-query