Register job status using API

api.R

@@ -61,6 +61,39 @@ cors <- function(req, res) {
 
 }
 
+#* @filter secret
+function(req, res) {
+
+  secret <- identical(req[["argsQuery"]][["secret"]], Sys.getenv("JOB_SECRET"))
+
+  if (grepl("job", req[["PATH_INFO"]]) && !secret) {
+
+    res[["status"]] <- 401
+    list(error = "Access token required")
+
+  } else {
+
+    forward()
+
+  }
+
+}
+
+#* Register result of job
+#* @tag status
+#* @get /healthz
+#* @response 200 A json object response
+#* @serializer unboxedJSON
+function(status) {
+
+  cat(status, file = "var/status/success.txt")
+
+  cat(format(Sys.time(), usetz = TRUE), file = "status/last-update.txt")
+
+  "success"
+
+}
+
 #* Check the liveness of the API
 #* @tag status
 #* @head /healthz

template.yml

@@ -102,6 +102,10 @@ parameters:
     required: true
     generate: expression
     from: "[a-zA-Z0-9]{20}"
+  - name: JOB_SECRET
+    required: true
+    generate: expression
+    from: "[a-zA-Z0-9]{64}"
 metadata:
   name: ${APP}
 objects:
@@ -203,6 +207,8 @@ objects:
             value: ${FINBIF_WAREHOUSE_QUERY}
           - name: FINBIF_EMAIL
             value: ${FINBIF_EMAIL}
+          - name: JOB_SECRET
+            value: ${JOB_SECRET}
         volumes:
         - name: ${TMP_DIR}
           emptyDir:
@@ -362,4 +368,10 @@ objects:
                 value: ${DB}-${BRANCH}
               - name: TIMEOUT_IN_HOURS
                 value: ${TIMEOUT_IN_HOURS}
+              - name: JOB_SECRET
+                value: ${JOB_SECRET}
+              - name: APP_HOSTNAME
+                value: ${BRANCH}-${APP}.${APP}.svc
+              - name: APP_PORT
+                value: ${APP_PORT}
             restartPolicy: Never

update_indices.R

@@ -1,4 +1,4 @@
-tryCatch(
+res <- tryCatch(
 
   {
 
@@ -239,3 +239,8 @@ tryCatch(
   }
 
 )
+
+httr::GET(
+  paste0(Sys.getenv("APP_HOSTNAME"), ":", Sys.getenv("APP_PORT")),
+  query = list(job = res)
+)