Remove events support.

bin/cuirass.in

@@ -64,7 +64,6 @@ exec ${GUILE:-@GUILE@} --no-auto-compile -e main -s "$0" "$@"
   -I, --interval=N          Wait N seconds between each poll
       --build-remote        Use the remote build mechanism
       --use-substitutes     Allow usage of pre-built substitutes
-      --record-events       Record events for distribution
       --threads=N           Use up to N kernel threads
   -V, --version             Display version
   -h, --help                Display this help message")
@@ -85,7 +84,6 @@ exec ${GUILE:-@GUILE@} --no-auto-compile -e main -s "$0" "$@"
     (use-substitutes                  (value #f))
     (threads                          (value #t))
     (fallback                         (value #f))
-    (record-events                    (value #f))
     (ttl                              (value #t))
     (version        (single-char #\V) (value #f))
     (help           (single-char #\h) (value #f))))
@@ -114,7 +112,6 @@ exec ${GUILE:-@GUILE@} --no-auto-compile -e main -s "$0" "$@"
          (%build-remote? (option-ref opts 'build-remote #f))
          (%use-substitutes? (option-ref opts 'use-substitutes #f))
          (%fallback? (option-ref opts 'fallback #f))
-         (%record-events? (option-ref opts 'record-events #f))
          (%gc-root-ttl
           (time-second (string->duration (option-ref opts 'ttl "30d")))))
       (cond

src/cuirass/database.scm

@@ -106,7 +106,6 @@
             %package-database
             %package-schema-file
             %db-channel
-            %record-events?
             ;; Macros.
             exec-query/bind
             with-database
@@ -238,9 +237,6 @@ parameters matches the number of arguments to bind."
 (define %db-channel
   (make-parameter #f))
 
-(define %record-events?
-  (make-parameter #f))
-
 (define-syntax-rule (with-database body ...)
   "Run BODY with %DB-CHANNEL being dynamically bound to a channel providing a
 worker thread that allows database operations to run without interfering with
@@ -467,17 +463,6 @@ priority, systems FROM Specifications ORDER BY name ASC;")))
   (failed            1)
   (aborted           2))
 
-(define (db-add-event type timestamp details)
-  (with-db-worker-thread db
-    (when (%record-events?)
-      (exec-query/bind db "\
-INSERT INTO Events (type, timestamp, event_json) VALUES ("
-                       (symbol->string type) ", "
-                       timestamp ", "
-                       (object->json-string details)
-                       ");")
-      #t)))
-
 (define* (db-add-evaluation spec-name instances
                             #:key
                             (checkouttime 0)
@@ -507,12 +492,7 @@ RETURNING id;"))
       (if (null? new-instances)
           (begin (exec-query db "ROLLBACK;")
                  #f)
-          (begin (db-add-event 'evaluation
-                               (time-second (current-time time-utc))
-                               `((#:evaluation    . ,eval-id)
-                                 (#:specification . ,spec-name)
-                                 (#:in_progress   . #t)))
-                 (exec-query db "COMMIT;")
+          (begin (exec-query db "COMMIT;")
                  eval-id)))))
 
 (define (db-abort-pending-evaluations)
@@ -583,14 +563,6 @@ ON CONFLICT ON CONSTRAINT builds_derivation_key DO NOTHING;"))
          (outputs (assq-ref build #:outputs))
          (new-outputs (filter-map (cut db-add-output derivation <>)
                                   outputs)))
-    (db-add-event 'build
-                  (assq-ref build #:timestamp)
-                  `((#:derivation . ,derivation)
-                    ;; TODO Ideally this would use the value
-                    ;; from build, with a default of scheduled,
-                    ;; but it's hard to convert to the symbol,
-                    ;; so just hard code scheduled for now.
-                    (#:event       . scheduled)))
     derivation))
 
 (define (db-add-build-product product)
@@ -766,18 +738,13 @@ log file for DRV."
   (with-db-worker-thread db
     (if (or (= status (build-status started))
             (= status (build-status submitted)))
-        (begin
-          (if log-file
-              (exec-query/bind db "UPDATE Builds SET starttime=" now
-                               ",status=" status ",log=" log-file
-                               "WHERE derivation=" drv ";")
-              (exec-query/bind db "UPDATE Builds SET starttime=" now
-                               ",status="
-                               status "WHERE derivation=" drv ";"))
-          (db-add-event 'build
-                        now
-                        `((#:derivation . ,drv)
-                          (#:event      . started))))
+        (if log-file
+            (exec-query/bind db "UPDATE Builds SET starttime=" now
+                             ",status=" status ",log=" log-file
+                             "WHERE derivation=" drv ";")
+            (exec-query/bind db "UPDATE Builds SET starttime=" now
+                             ",status="
+                             status "WHERE derivation=" drv ";"))
 
         ;; Update only if we're switching to a different status; otherwise
         ;; leave things unchanged.  This ensures that 'stoptime' remains valid
@@ -1170,48 +1137,6 @@ ORDER BY ~a;"
   (let ((key (if (number? derivation-or-id) 'id 'derivation)))
     (expect-one-row (db-get-builds `((,key . ,derivation-or-id))))))
 
-(define (db-get-events filters)
-  (with-db-worker-thread db
-    (let* ((query "\
-SELECT Events.id,
-       Events.type,
-       Events.timestamp,
-       Events.event_json
-FROM Events
-WHERE (:type = Events.type OR :type IS NULL)
-  AND (((:borderlowtime, :borderlowid) <
-        (Events.timestamp, Events.id)) OR
-       :borderlowtime IS NULL OR
-       :borderlowid IS NULL)
-  AND (((:borderhightime, :borderhighid) >
-        (Events.timestamp, Events.id)) OR
-       :borderhightime IS NULL OR
-       :borderhighid IS NULL)
-ORDER BY Events.id ASC
-LIMIT :nr;")
-           (params `((#:type . ,(and=> (assq-ref filters 'type)
-                                       symbol->string))
-                     (#:nr . ,(match (assq-ref filters 'nr)
-                                (#f -1)
-                                (x x)))))
-           (events (exec-query/bind-params db query params)))
-      (let loop ((events events)
-                 (result '()))
-        (match events
-          (() (reverse result))
-          (((id type timestamp event_json)
-            . rest)
-           (loop rest
-                 (cons `((#:id . ,(string->number id))
-                         (#:type . ,(string->symbol type))
-                         (#:timestamp . ,(string->number timestamp))
-                         (#:event_json . ,event_json))
-                       result))))))))
-
-(define (db-delete-events-with-ids-<=-to id)
-  (with-db-worker-thread db
-    (exec-query/bind db "DELETE FROM Events WHERE id <= " id ";")))
-
 (define (db-get-pending-derivations)
   "Return the list of derivation file names corresponding to pending builds in
 the database.  The returned list is guaranteed to not have any duplicates."

tests/database.scm

@@ -103,7 +103,6 @@
    (systems '("a" "b"))
    (last-seen 1)))
 
-(%record-events? #t)
 
 (test-group-with-cleanup "database"
   (test-assert "db-init"