comparison ogc_api_processes_wrapper.R @ 2:bcb6009d5af7 draft default tip

planemo upload for repository https://github.com/galaxyecology/tools-ecology/tree/master/tools/ogc_api_processes_wrapper commit e03f4d27ec44d873aacdf406d7a26ec8038e9b05

1:099d42f5804c

library("getopt")

cat("start generic wrapper service \n")

getParameters <- function(){
    args <- commandArgs(trailingOnly = TRUE)
    con <- file("inputs.json", "r")
    line <- readLines(con, n = 1)
    json <- fromJSON(line)
    close(con)
    return(json$conditional_process)

                result <- getResult(server, jobID)
                if (result$status_code == 200) {
                  resultBody <- parseResponseBody(result$body)
                  urls <- unname(unlist(lapply(resultBody, function(x) x$href)))
                  urls_with_newline <- paste(urls, collapse = "\n")
                  sink(paste0(outputData, "_result_urls.txt"))
                    cat(urls_with_newline, "\n")
                  sink()
                }
            } else if (jobStatus == "failed") {
              status <- jobStatus
            }
        Sys.sleep(3)

server <- "https://ospd.geolabs.fr:8300/ogc-api/"

inputParameters <- getParameters()

outputLocation <- inputParameters$outputData

outputs <- getOutputs(inputParameters, outputLocation, server)

for (key in names(inputParameters)) {
  print(inputParameters[[key]])

2:bcb6009d5af7

library("getopt")

cat("start generic wrapper service \n")

getParameters <- function(){
    con <- file("inputs.json", "r")
    line <- readLines(con, n = 1)
    json <- fromJSON(line)
    close(con)
    return(json$conditional_process)

                result <- getResult(server, jobID)
                if (result$status_code == 200) {
                  resultBody <- parseResponseBody(result$body)
                  urls <- unname(unlist(lapply(resultBody, function(x) x$href)))
                  urls_with_newline <- paste(urls, collapse = "\n")
                  con <- file(outputData, "w")
                  writeLines(urls_with_newline, con = con)
                  close(con)
                }
            } else if (jobStatus == "failed") {
              status <- jobStatus
            }
        Sys.sleep(3)

server <- "https://ospd.geolabs.fr:8300/ogc-api/"

inputParameters <- getParameters()

args <- commandArgs(trailingOnly = TRUE)
outputLocation <- args[2]

outputs <- getOutputs(inputParameters, outputLocation, server)

for (key in names(inputParameters)) {
  print(inputParameters[[key]])