sdk/R/R/Arvados.R

   1 source("./R/HttpRequest.R")
   2 source("./R/HttpParser.R")
   3
   4 #' Arvados SDK Object
   5 #'
   6 #' All Arvados logic is inside this class
   7 #'
   8 #' @field token Token represents user authentification token.
   9 #' @field host Host represents server name we wish to connect to.
  10 #' @examples arv = Arvados$new("token", "host_name")
  11 #' @export Arvados
  12 Arvados <- R6::R6Class(
  13
  14     "Arvados",
  15
  16     public = list(
  17
  18         initialize = function(auth_token = NULL, host_name = NULL)
  19         {
  20             if(!is.null(host_name))
  21                Sys.setenv(ARVADOS_API_HOST  = host_name)
  22
  23             if(!is.null(auth_token))
  24                 Sys.setenv(ARVADOS_API_TOKEN = auth_token)
  25
  26             host  <- Sys.getenv("ARVADOS_API_HOST");
  27             token <- Sys.getenv("ARVADOS_API_TOKEN");
  28
  29             if(host == "" | token == "")
  30                 stop("Please provide host name and authentification token or set ARVADOS_API_HOST and ARVADOS_API_TOKEN environmental variables.")
  31
  32             discoveryDocumentURL <- paste0("https://", host, "/discovery/v1/apis/arvados/v1/rest")
  33
  34             version <- "v1"
  35             host  <- paste0("https://", host, "/arvados/", version, "/")
  36
  37             private$http       <- HttpRequest$new()
  38             private$httpParser <- HttpParser$new()
  39             private$token      <- token
  40             private$host       <- host
  41
  42             headers <- list(Authorization = paste("OAuth2", private$token))
  43
  44             serverResponse <- private$http$GET(discoveryDocumentURL, headers)
  45
  46             discoveryDocument <- private$httpParser$parseJSONResponse(serverResponse)
  47             private$webDavHostName <- discoveryDocument$keepWebServiceUrl
  48         },
  49
  50         getToken    = function() private$token,
  51         getHostName = function() private$host,
  52
  53         #Todo(Fudo): Hardcoded credentials to WebDAV server. Remove them later
  54         getWebDavHostName = function() private$webDavHostName,
  55
  56         getCollection = function(uuid)
  57         {
  58             collectionURL <- paste0(private$host, "collections/", uuid)
  59             headers <- list(Authorization = paste("OAuth2", private$token))
  60
  61             serverResponse <- private$http$GET(collectionURL, headers)
  62
  63             collection <- private$httpParser$parseJSONResponse(serverResponse)
  64
  65             if(!is.null(collection$errors))
  66                 stop(collection$errors)
  67
  68             collection
  69         },
  70
  71         listCollections = function(filters = NULL, limit = 100, offset = 0)
  72         {
  73             collectionURL <- paste0(private$host, "collections")
  74             headers <- list(Authorization = paste("OAuth2", private$token))
  75
  76             names(filters) <- c("collection")
  77
  78             serverResponse <- private$http$GET(collectionURL, headers, filters, limit, offset)
  79             collection <- private$httpParser$parseJSONResponse(serverResponse)
  80
  81             if(!is.null(collection$errors))
  82                 stop(collection$errors)
  83
  84             collection
  85         },
  86
  87         deleteCollection = function(uuid)
  88         {
  89             collectionURL <- paste0(private$host, "collections/", uuid)
  90             headers <- list("Authorization" = paste("OAuth2", private$token),
  91                             "Content-Type"  = "application/json")
  92
  93             serverResponse <- private$http$DELETE(collectionURL, headers)
  94
  95             collection <- private$httpParser$parseJSONResponse(serverResponse)
  96
  97             if(!is.null(collection$errors))
  98                 stop(collection$errors)
  99
 100             collection
 101         },
 102
 103         updateCollection = function(uuid, body)
 104         {
 105             collectionURL <- paste0(private$host, "collections/", uuid)
 106             headers <- list("Authorization" = paste("OAuth2", private$token),
 107                             "Content-Type"  = "application/json")
 108
 109             names(body) <- c("collection")
 110             body <- jsonlite::toJSON(body, auto_unbox = T)
 111
 112             serverResponse <- private$http$PUT(collectionURL, headers, body)
 113
 114             collection <- private$httpParser$parseJSONResponse(serverResponse)
 115
 116             if(!is.null(collection$errors))
 117                 stop(collection$errors)
 118
 119             collection
 120         },
 121
 122         createCollection = function(body)
 123         {
 124             collectionURL <- paste0(private$host, "collections")
 125             headers <- list("Authorization" = paste("OAuth2", private$token),
 126                             "Content-Type"  = "application/json")
 127
 128             names(body) <- c("collection")
 129             body <- jsonlite::toJSON(body, auto_unbox = T)
 130
 131             serverResponse <- private$http$POST(collectionURL, headers, body)
 132
 133             collection <- private$httpParser$parseJSONResponse(serverResponse)
 134
 135             if(!is.null(collection$errors))
 136                 stop(collection$errors)
 137
 138             collection
 139         },
 140
 141         getProject = function(uuid)
 142         {
 143             projectURL <- paste0(private$host, "groups/", uuid)
 144             headers <- list(Authorization = paste("OAuth2", private$token))
 145
 146             serverResponse <- private$http$GET(projectURL, headers)
 147
 148             project <- private$httpParser$parseJSONResponse(serverResponse)
 149
 150             if(!is.null(project$errors))
 151                 stop(project$errors)
 152
 153             project
 154         },
 155
 156         createProject = function(body)
 157         {
 158             projectURL <- paste0(private$host, "groups")
 159             headers <- list("Authorization" = paste("OAuth2", private$token),
 160                             "Content-Type"  = "application/json")
 161
 162             names(body) <- c("group")
 163             body <- jsonlite::toJSON(body, auto_unbox = T)
 164
 165             serverResponse <- private$http$POST(projectURL, headers, body)
 166
 167             project <- private$httpParser$parseJSONResponse(serverResponse)
 168
 169             if(!is.null(project$errors))
 170                 stop(project$errors)
 171
 172             project
 173         },
 174
 175         updateProject = function(uuid, body)
 176         {
 177             projectURL <- paste0(private$host, "groups/", uuid)
 178             headers <- list("Authorization" = paste("OAuth2", private$token),
 179                             "Content-Type"  = "application/json")
 180
 181             names(body) <- c("group")
 182             body <- jsonlite::toJSON(body, auto_unbox = T)
 183
 184             serverResponse <- private$http$PUT(projectURL, headers, body)
 185
 186             project <- private$httpParser$parseJSONResponse(serverResponse)
 187
 188             if(!is.null(project$errors))
 189                 stop(project$errors)
 190
 191             project
 192         },
 193
 194         listProjects = function(filters = NULL, limit = 100, offset = 0)
 195         {
 196             projectURL <- paste0(private$host, "groups")
 197             headers <- list(Authorization = paste("OAuth2", private$token))
 198
 199             names(filters) <- c("groups")
 200
 201             serverResponse <- private$http$GET(projectURL, headers, filters, limit, offset)
 202             projects <- private$httpParser$parseJSONResponse(serverResponse)
 203
 204             if(!is.null(projects$errors))
 205                 stop(projects$errors)
 206
 207             projects
 208         },
 209
 210         deleteProject = function(uuid)
 211         {
 212             projectURL <- paste0(private$host, "groups/", uuid)
 213             headers <- list("Authorization" = paste("OAuth2", private$token),
 214                             "Content-Type"  = "application/json")
 215
 216             serverResponse <- private$http$DELETE(projectURL, headers)
 217
 218             project <- private$httpParser$parseJSONResponse(serverResponse)
 219
 220             if(!is.null(project$errors))
 221                 stop(project$errors)
 222
 223             project
 224         }
 225     ),
 226
 227     private = list(
 228
 229         token          = NULL,
 230         host           = NULL,
 231         webDavHostName = NULL,
 232         http           = NULL,
 233         httpParser     = NULL
 234     ),
 235
 236     cloneable = FALSE
 237 )