R/zzz.R

In dipterix/restbatch: A Simple 'RESTful' Web Service to Schedule R Batch Jobs

# To pass checks and to prevent failures
# In the run time, .globals will be replaced with fastmap2
.globals <- list()


.onLoad <- function(libname, pkgname){
  pkg <- getNamespace(pkgname)
  sess_str <- rand_string(15)
  assign('.session_string', sess_str, envir = pkg)
  s <- load_setting(reset_temp = TRUE)
  assign('.settings', s, envir = pkg)

  .globals <- dipsaus::fastmap2()
  .globals$servers <- dipsaus::fastmap2()
  .globals$tasks <- dipsaus::fastqueue2()
  .globals$running <- dipsaus::fastmap2()
  .globals$paused <- TRUE
  .globals$watchers <- 0
  .globals$sql_conn <- NULL

  assign('.globals', .globals, envir = pkg)

  options("restbatch.anonymous_request" = getOption("restbatch.anonymous_request", FALSE))

  # Check database
  try({ db_validate() }, silent = TRUE)
}

.onAttach <- function(libname, pkgname){
  if(length(.globals$db_bkup) && isTRUE(file.exists(file.path(.globals$db_bkup, 'DB','restbatch.sqlite')))){
    packageStartupMessage(
      '`restbatch`: your database is broken or is too old. It has been fixed automatically.',
      " However, your previous database hasn't been merged to the new database yet.",
      ' To migrate merge the previous database into the new one, please run:\n',
      sprintf('\n\tdatabase_restore("%s")', .globals$db_bkup)
    )
  }
}

#' @export
print.restbatch.result <- function(x, ...){
  task <- attr(x, 'task')
  cat(sprintf("Results from task [%s]\n", task$task_name))
  print(task$local_status())
  cat("Display details:\n\n")
  attributes(x) <- NULL
  print(x)
}