sdk/R/R/HttpRequest.R

   1 source("./R/util.R")
   2
   3 HttpRequest <- R6::R6Class(
   4
   5     "HttrRequest",
   6
   7     public = list(
   8
   9         validContentTypes = NULL,
  10         validVerbs = NULL,
  11
  12         initialize = function()
  13         {
  14             self$validContentTypes <- c("text", "raw")
  15             self$validVerbs <- c("GET", "POST", "PUT", "DELETE", "PROPFIND", "MOVE")
  16         },
  17
  18         exec = function(verb, url, headers = NULL, body = NULL, queryParams = NULL,
  19                         retryTimes = 0)
  20         {
  21             if(!(verb %in% self$validVerbs))
  22                 stop("Http verb is not valid.")
  23
  24             urlQuery <- self$createQuery(queryParams)
  25             url      <- paste0(url, urlQuery)
  26
  27             config <- httr::add_headers(unlist(headers))
  28             if(toString(Sys.getenv("ARVADOS_API_HOST_INSECURE") == "TRUE"))
  29                config$options = list(ssl_verifypeer = FALSE)
  30
  31             # times = 1 regular call + numberOfRetries
  32             response <- httr::RETRY(verb, url = url, body = body,
  33                                     config = config, times = retryTimes + 1)
  34         },
  35
  36         createQuery = function(queryParams)
  37         {
  38             queryParams <- Filter(Negate(is.null), queryParams)
  39
  40             query <- sapply(queryParams, function(param)
  41             {
  42                 if(is.list(param) || length(param) > 1)
  43                     param <- RListToPythonList(param, ",")
  44
  45                 URLencode(as.character(param), reserved = T, repeated = T)
  46
  47             }, USE.NAMES = TRUE)
  48
  49             if(length(query) > 0)
  50             {
  51                 query <- paste0(names(query), "=", query, collapse = "&")
  52
  53                 return(paste0("/?", query))
  54             }
  55
  56             return("")
  57         }
  58     ),
  59
  60     cloneable = FALSE
  61 )