Revision d0c13affeb1def1f728f0e57c64e55fc9dc7cb25 authored by Alexey Sergushichev on 21 December 2019, 15:46:32 UTC, committed by Alexey Sergushichev on 21 December 2019, 15:46:32 UTC
1 parent d227226
loadSession.R
sessionExists <- function(sessionName) {
ocpuRoot <- strsplit(getwd(), 'ocpu-temp')[[1]][1]
sessionPath <- file.path(ocpuRoot, 'ocpu-store', sessionName)
savedPath <- file.path(sessionPath, 'sess.bin')
RDataPath <- file.path(sessionPath, '.RData')
if (file.exists(savedPath)) {
return (jsonlite::toJSON(list(result=TRUE), auto_unbox = TRUE))
}
#-----------------LEGACY----------------------------------- DELETE AFTER 3 JUNE 2019
if (file.exists(RDataPath)) {
env <- new.env()
load(RDataPath, envir = env)
validForLoading = !is.null(env$es) && !is.null(attr(env$es, 'published'))
return (jsonlite::toJSON(list(result=validForLoading), auto_unbox = TRUE))
}
return (jsonlite::toJSON(list(result=FALSE), auto_unbox = TRUE))
}
publishSession <- function (sessionName, datasetName = sessionName, heatmapJson = NULL) {
ocpuRoot <- strsplit(getwd(), 'ocpu-temp')[[1]][1]
sessionPath <- file.path(ocpuRoot, 'ocpu-store', sessionName)
RDataPath <- paste(sessionPath, '.RData', sep=.Platform$file.sep)
if (file.exists(RDataPath)) {
env <- new.env()
load(RDataPath, envir = env)
if (!is.null(env$es)) { # this session is for actual dataset
result <- list()
datasetName <- ifelse(nchar(datasetName) > 0, datasetName, sessionName)
result[[datasetName]] <- writeToList(env$es)
binaryFile <- file.path(getwd(), 'sess.bin')
writeBin(protolite::serialize_pb(result), binaryFile)
assign("es", env$es, envir = parent.frame())
if (!is.null(heatmapJson)) {
heatmapPath <- file.path(getwd(), 'heatmap.json')
write(jsonlite::toJSON(heatmapJson, auto_unbox = TRUE, null = 'null'), heatmapPath)
}
return (jsonlite::toJSON(basename(binaryFile)))
}
}
stop('Invalid session')
}
loadSession <- function (sessionName) {
ocpuRoot <- strsplit(getwd(), 'ocpu-temp')[[1]][1]
sessionPath <- file.path(ocpuRoot, 'ocpu-store', sessionName)
savedPath <- paste(sessionPath, 'sess.bin', sep=.Platform$file.sep)
if (file.exists(savedPath)) {
return (jsonlite::toJSON(basename(savedPath)))
}
#---------------------LEGACY------------------------------------- DELETE AFTER 3 JUNE 2019
RDataPath <- paste(sessionPath, '.RData', sep=.Platform$file.sep)
if (file.exists(RDataPath)) {
savedEnv <- load(RDataPath)
if (!("es" %in% savedEnv) || is.null(attr(es, 'published'))) {
stop('Invalid session key')
}
result <- list()
result[[sessionName]] <- writeToList(es)
writeBin(protolite::serialize_pb(result), savedPath)
return (jsonlite::toJSON(basename(savedPath)))
}
stop('Invalid session key')
}
heatmapSettings <- function (sessionName) {
ocpuRoot <- strsplit(getwd(), 'ocpu-temp')[[1]][1]
sessionPath <- file.path(ocpuRoot, 'ocpu-store', sessionName)
heatmapPath <- file.path(sessionPath, 'heatmap.json')
if (file.exists(heatmapPath)) {
heatmap <- fromJSON(heatmapPath)
return (jsonlite::toJSON(list(result=heatmap), auto_unbox = TRUE, null = 'null'))
}
return (jsonlite::toJSON(list(result=FALSE), auto_unbox = TRUE))
}
Computing file changes ...