Schedule should use UTC; fixed name job (#310)

* Schedule should use UTC; fixed name job

* Remove initial repl config option

* Check schedule working hour in Clojure where timezone is known

.github/workflows/test-rio.yml

@@ -2,10 +2,10 @@ name: Check if RIO queue is up or down
 
 on:
   schedule:
-    - cron: '6 9-17 * * 1-5' # every hour on weekdays during working hours
+    - cron: '6 7-18 * * 1-5' # every hour on weekdays during working hours. Code will to a timezone check.
 
 jobs:
-  deps:
+  riotest:
     runs-on: ubuntu-latest
 
     steps:
@@ -54,4 +54,4 @@ jobs:
           TOKEN_ENDPOINT: ${{ secrets.TOKEN_ENDPOINT }}
           TRUSTSTORE: truststore.jks
           TRUSTSTORE_PASSWORD: ${{ secrets.TRUSTSTORE_PASSWORD }}
-        run: lein mapper test-rio rio-mapper-dev.jomco.nl
+        run: lein mapper test-rio rio-mapper-dev.jomco.nl cron

project.clj

@@ -90,6 +90,4 @@
   :test-selectors {:default #(not-any? % [:e2e :redis])
                    :redis   :redis
                    :e2e     :e2e
-                   :all     (constantly true)}
-
-  :repl-options {:init-ns nl.surf.eduhub-rio-mapper.ooapi})
+                   :all     (constantly true)})

src/nl/surf/eduhub_rio_mapper/cli_commands.clj

@@ -28,7 +28,8 @@
             [nl.surf.eduhub-rio-mapper.specs.ooapi :as ooapi]
             [nl.surf.eduhub-rio-mapper.specs.rio :as rio]
             [nl.surf.eduhub-rio-mapper.worker :as worker])
-  (:import [java.util UUID]))
+  (:import [java.time LocalTime]
+           [java.util UUID]))
 
 (defn- parse-getter-args [[type id & [pagina]]]
   {:pre [type id (string? type)]}
@@ -73,28 +74,31 @@
         (worker/start-worker! config)))
 
     "test-rio"
-    (let [[client-info _] (parse-client-info-args args clients)
+    (let [[client-info args] (parse-client-info-args args clients)
+          cron    (= "cron" (first args))
+          working (< 9 (.getHour (LocalTime/now)) 17)       ; only run between 9:00 and 17:00 local time
           uuid    (UUID/randomUUID)
           eduspec (-> "../test/fixtures/ooapi/education-specification-template.json"
                       io/resource
                       slurp
                       (json/read-str :key-fn keyword)
                       (assoc :educationSpecificationId uuid))]
 
-      (try
-        (insert! {:institution-oin        (:institution-oin client-info)
-                  :institution-schac-home (:institution-schac-home client-info)
-                  ::ooapi/type            "education-specification"
-                  ::ooapi/id              uuid
-                  ::ooapi/entity          eduspec})
-        (println "The RIO Queue is UP")
-        (catch Exception ex
-          (when-let [ex-data (ex-data ex)]
-            (when (= :down (:rio-queue-status ex-data))
-              (println "The RIO Queue is DOWN")
-              (System/exit -1)))
-          (println "An unexpected exception has occurred: " ex)
-          (System/exit -2))))
+      (when (or working (not cron))
+        (try
+          (insert! {:institution-oin        (:institution-oin client-info)
+                    :institution-schac-home (:institution-schac-home client-info)
+                    ::ooapi/type            "education-specification"
+                    ::ooapi/id              uuid
+                    ::ooapi/entity          eduspec})
+          (println "The RIO Queue is UP")
+          (catch Exception ex
+            (when-let [ex-data (ex-data ex)]
+              (when (= :down (:rio-queue-status ex-data))
+                (println "The RIO Queue is DOWN")
+                (System/exit -1)))
+            (println "An unexpected exception has occurred: " ex)
+            (System/exit -2)))))
 
     "get"
     (let [[client-info rest-args] (parse-client-info-args args clients)]