R/file_service.R

In tercen/teRcenApi: Tercen R api

#' FileService
#'
#' @export
#' @format \code{\link{R6Class}} object.
#' @section Methods:
#' \describe{
#'    \item{\code{upload(file,bytes)}}{method}
#'    \item{\code{append(file,bytes)}}{method}
#'    \item{\code{download(fileDocumentId)}}{method}
#' }
#' 
FileService <- R6::R6Class("FileService", inherit = HttpClientService, public = list(initialize = function(baseRestUri,
    client) {
    super$initialize(baseRestUri, client)
    self$uri = "api/v1/file"
}, findFileByWorkflowIdAndStepId = function(startKey = NULL, endKey = NULL, limit = 20,
    skip = 0, descending = TRUE, useFactory = FALSE) {
    return(self$findStartKeys("findFileByWorkflowIdAndStepId", startKey = startKey,
        endKey = endKey, limit = limit, skip = skip, descending = descending, useFactory = useFactory))
}, findByDataUri = function(startKey = NULL, endKey = NULL, limit = 20, skip = 0,
    descending = TRUE, useFactory = FALSE) {
    return(self$findStartKeys("findByDataUri", startKey = startKey, endKey = endKey,
        limit = limit, skip = skip, descending = descending, useFactory = useFactory))
}, upload = function(file, bytes) {
    answer = NULL
    response = NULL
    uri = paste0("api/v1/file", "/", "upload")
    parts = list()
    parts[[1]] = MultiPart$new(list(`content-type` = tson.scalar("application/json")),
        content = list(file$toTson()))
    if (is.raw(bytes)) {
        parts[[2]] = MultiPart$new(list(`content-type` = tson.scalar("application/octet-stream")),
            content = bytes)
    } else {
        parts[[2]] = MultiPart$new(list(`content-type` = tson.scalar("application/tson")),
            content = bytes)
    }
    response = self$client$multipart(self$getServiceUri(uri), body = lapply(parts,
        function(part) part$toTson()))
    if (response$status != 200) {
        self$onResponseError(response, "upload")
    } else {
        answer = createObjectFromJson(response$content)
    }
    return(answer)
}, append = function(file, bytes) {
    answer = NULL
    response = NULL
    uri = paste0("api/v1/file", "/", "append")
    parts = list()
    parts[[1]] = MultiPart$new(list(`content-type` = tson.scalar("application/json")),
        content = list(file$toTson()))
    if (is.raw(bytes)) {
        parts[[2]] = MultiPart$new(list(`content-type` = tson.scalar("application/octet-stream")),
            content = bytes)
    } else {
        parts[[2]] = MultiPart$new(list(`content-type` = tson.scalar("application/tson")),
            content = bytes)
    }
    response = self$client$multipart(self$getServiceUri(uri), body = lapply(parts,
        function(part) part$toTson()))
    if (response$status != 200) {
        self$onResponseError(response, "append")
    } else {
        answer = createObjectFromJson(response$content)
    }
    return(answer)
}, download = function(fileDocumentId) {
    answer = NULL
    response = NULL
    uri = paste0("api/v1/file", "/", "download")
    params = list()
    params[["fileDocumentId"]] = unbox(fileDocumentId)
    url = self$getServiceUri(uri)
    response = self$client$get(url, query = list(params = toJSON(params)))
    if (response$status != 200) {
        self$onResponseError(response, "download")
    } else {
        answer = response$content
    }
    return(answer)
}))