lockfile_status_tracker

insightsengineering · Jul 10, 2024 · 3c480a7 · 3c480a7
1 parent a7f0666
commit 3c480a7
Show file tree

Hide file tree

Showing 2 changed files with 18 additions and 14 deletions.
diff --git a/R/init.R b/R/init.R
@@ -231,8 +231,7 @@ init <- function(data,
       if (!is.null(landing_module)) {
         do.call(landing_module$server, c(list(id = "landing_module_shiny_id"), landing_module$server_args))
       }
-      session$userData$lockfile_process <- process
-      reactivePoll(1000, session, checkFunc = lockfile_status, valueFunc = function() {})
+      lockfile_status_tracker(process)
       srv_teal_with_splash(id = id, data = data, modules = modules, filter = deep_copy_filter(filter))
     }
   )

diff --git a/R/teal_lockfile.R b/R/teal_lockfile.R
@@ -96,18 +96,23 @@ teal_lockfile_downloadhandler <- function() {
   )
 }
 
-lockfile_status <- function() {
-  process <- session$userData$lockfile_process
-  if (!process$is_alive()) {
-    renv_logs <- process$read_output()
-
-    if (any(grepl("Lockfile written", renv_logs))) {
-      logger::log_trace("lockfile created successfully.")
-    } else {
-      logger::log_trace("lockfile created with issues.")
-    }
-    TRUE
+lockfile_status <- function(process) {
+  renv_logs <- process$read_output()
+  if (any(grepl("Lockfile written", renv_logs))) {
+    logger::log_trace("lockfile created successfully.")
   } else {
-    FALSE
+    logger::log_trace("lockfile created with issues.")
   }
 }
+
+lockfile_status_tracker <- function(process) {
+  timer <- reactiveTimer(1000)
+
+  tracker <- observe({
+    timer()
+    if (!process$is_alive()) {
+      lockfile_status(process)
+      tracker$destroy()
+    }
+  })
+}