[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[PATCH 2/2] Support publishing evaluation events
From: |
Christopher Baines |
Subject: |
[PATCH 2/2] Support publishing evaluation events |
Date: |
Mon, 28 Oct 2019 08:10:26 +0000 |
---
src/cuirass/base.scm | 5 +++++
src/cuirass/database.scm | 6 +++++-
src/cuirass/http.scm | 9 +++++++++
3 files changed, 19 insertions(+), 1 deletion(-)
diff --git a/src/cuirass/base.scm b/src/cuirass/base.scm
index fd10e35..943a4f2 100644
--- a/src/cuirass/base.scm
+++ b/src/cuirass/base.scm
@@ -724,6 +724,11 @@ started)."
(checkouts (fetch-inputs spec))
(eval-id (db-add-evaluation name checkouts)))
(when eval-id
+ (db-add-event 'evaluation
+ (time-second (current-time time-utc))
+ `((#:evalutaion . ,eval-id)
+ (#:specification . ,name)
+ (#:in_progress . #t)))
(compile-checkouts spec (filter compile? checkouts))
(spawn-fiber
(lambda ()
diff --git a/src/cuirass/database.scm b/src/cuirass/database.scm
index 83c0c5a..05382d7 100644
--- a/src/cuirass/database.scm
+++ b/src/cuirass/database.scm
@@ -408,7 +408,11 @@ VALUES (" spec-name ", true);")
(define (db-set-evaluation-done eval-id)
(with-db-critical-section db
(sqlite-exec db "UPDATE Evaluations SET in_progress = false
-WHERE id = " eval-id ";")))
+WHERE id = " eval-id ";")
+ (db-add-event 'evaluation
+ (time-second (current-time time-utc))
+ `((#:evaluation . ,eval-id)
+ (#:in_progress . #f)))))
(define-syntax-rule (with-database body ...)
"Run BODY with %DB-CHANNEL being dynamically bound to a channel implementing
diff --git a/src/cuirass/http.scm b/src/cuirass/http.scm
index 35e3d7f..4a3214d 100644
--- a/src/cuirass/http.scm
+++ b/src/cuirass/http.scm
@@ -347,6 +347,15 @@ Hydra format."
(specifications-table
(db-get-specifications))
'())))
+ (("api" "evaluation-events")
+ (let* ((params (request-parameters request))
+ ;; 'nr parameter is mandatory to limit query size.
+ (valid-params? (assq-ref params 'nr)))
+ (if valid-params?
+ (respond-json
+ (object->json-string
+ (handle-events-request 'evaluation params)))
+ (respond-json-with-error 500 "Parameter not defined!"))))
(("jobset" name)
(respond-html
--
2.23.0