R/api_files.R

In flahn/openeo-r-backend: A back-end implementation for openEO with a local filesystem

#
# /files handler functions ====
#

#* @get /api/users/<userid>/files
#* @serializer unboxedJSON
.listUserFiles = function(req,res,user_id) {
  tryCatch({
    if (paste(user_id) == paste(req$user$user_id)) { #TODO revisit if public files are a thing
      return(req$user$fileList())
    } else {
      throwError("FilePathInvalid")
    }
  }, error=handleError)
  
}

#* @get /api/users/<userid>/files/<path>
#* @serializer unboxedJSON
.downloadUserFile = function(req,res,user_id,path) {
  tryCatch({
    if (paste(user_id) == paste(req$user$user_id)) { #TODO revisit if public files are a thing
      path = URLdecode(path)
      
      files = req$user$files
      selection = files[files[,"link"]==path,]
      if (nrow(selection) == 0) {
        throwError("FileNotFound")
      } else {
        path.ext = unlist(strsplit(selection[,"link"], "\\.(?=[^\\.]+$)", perl=TRUE))
        
        sendFile(
          res,
          200,
          file.name = path.ext[1],
          file.ext = paste(".",path.ext[2],sep=""),
          data = readBin(rownames(selection),"raw", n=selection$size)
        )
        
        return(res)
      }
    } else {
      throwError("FilePathInvalid")
      # "Not authorized to access others files"
    }
  },error=handleError)
}

# @put /api/users/<userid>/files/<path>
# @serializer unboxedJSON
.uploadFile = function(req,res,user_id,path) {
  tryCatch({
    if (paste(user_id) == paste(req$user$user_id)) {
      
      path = URLdecode(path)
      
      storedFilePath = paste(req$user$workspace,"files",path,sep="/")
      
      if (file.exists(storedFilePath)) {
        file.remove(storedFilePath)
      }
      
      dir.split = unlist(strsplit(storedFilePath, "/(?=[^/]+$)", perl=TRUE))
      
      if (inherits(req$rook.input,"NullInputStream")) {
        throwError("FileContentInvalid")
      } else {
        req$rook.input$initialize(req$rook.input$.conn,req$rook.input$.length)
      }
      
      dir.create(dir.split[1],recursive = TRUE,showWarnings = FALSE)
      file.create(storedFilePath,showWarnings = FALSE)
      
      outputFile = file(storedFilePath,"wb")
      tryCatch(
        {
          writeBin(req$rook.input$read(req$rook.input$.length), con=outputFile, useBytes = TRUE)
          res$status = 204
        },
        error = function(e) {
          throwError("StorageFailure")
        }, finally={
          close(outputFile,type="wb")
        }
      )
      
      return(res)
    } else {
      throwError("FilePathInvalid")
    }
  },error=handleError)
  
}

#* @delete /api/users/<userid>/files/<path>
#* @serializer unboxedJSON
.deleteUserFile = function(req,res,user_id,path) {
  tryCatch({
    if (paste(user_id) == paste(req$user$user_id)) {
      user = req$user
      path = URLdecode(path)
      
      files = req$user$files
      selection = files[files[,"link"]==path,]
      
      if (nrow(selection) == 0) {
        throwError("FileNotFound")
      } else {
        file = rownames(selection)
        
        unlink(file, recursive = TRUE,force=TRUE)
        
        res$status = 204
        
        return(res)
      }
    } else {
      # Not authorized to delete data of others
      throwError("FilePathInvalid")
    }
  },error=handleError)
  
  
}