R/delete_file.R

In saurfang/rwebhdfs: WebHDFS REST API for R

#' Rename a File/Directory on a FileSystem
#' 
#' @return \code{TRUE} if successful, \code{FALSE} otherwise
#' @title delete_file: Rename a File/Directory on a FileSystem
#' @param fs FileSystem object
#' @param path a character vector that contains the path renaming from
#' @param recursive whether to delete contents of directory recursively
#' @param trash whether to move path to Trash rather than delete
#' @param ... other arguments
#' @rdname delete_file
#' @export delete_file
delete_file <- function(fs, path, recursive, trash,...){
  UseMethod("delete_file")
}

#' @rdname delete_file
#' @method delete_file default
#' @export
delete_file.default <- function(fs, path, recursive=FALSE, trash=FALSE, ...){
  warning("Unrecognized filesystem, invoking file.remove...")
  file.remove(path, recursive)
}

#' @rdname delete_file
#' @method delete_file webhdfs
#' @importFrom RCurl basicHeaderGatherer
#' @importFrom jsonlite fromJSON
#' @include curl_webhdfs.R
#' @export
delete_file.webhdfs <- function(fs, path, recursive=FALSE, trash=FALSE,...){
  if (trash) {
    response <- curl_webhdfs(fs, paste0(path,"?op=GETTRASHROOT"), "GET", ...)
    trash_path <- fromJSON(response)$Path
    if(!grep("^/", path)) {
      path <- paste0(get_webhdfs_home(fs, ...), "/", path)
    }
    # Need to recereate the directory hierarchy under the Current trash
    result <- mkdir(fs,paste0(trash_path,'/Current',dirname(path)))
    if (result) {
      result <- rename_file(fs,path,paste0(trash_path,'/Current',path))
    }
    return(result)
  } else {
    url <- paste0(path,"?op=DELETE&recursive=",if(isTRUE(recursive)) "true" else "false")
    response <- curl_webhdfs(fs, url, "DELETE" , ...)
    return(fromJSON(response)$boolean)
  }
}