R/http-methods.R

In etseed: Client for 'etcd', a 'Key-value' Database

etcd_GET <- function(url, args, ...) {
  if (length(args) == 0) args <- NULL
  res <- GET(url, query = args, ...)
  if (res$status_code > 201) {
    stop(content(res)$message, call. = FALSE)
  }
  contutf8(res)
}

etcd_PUT <- function(url, value, ttl=NULL, dir=FALSE, file=NULL, ...){
  if (missing(value) && is.null(file)) {
    res <- PUT(url, query = list(dir = TRUE), ...)
  } else {
    args <- etc(list(ttl = ttl, dir = dir))
    if (length(args) == 0) args <- NULL

    if (is.null(file)) {
      res <- PUT(url, body = list(value = value), query = args, encode = "form", ...)
    } else {
      stop("not working yet from files", call. = FALSE)
      # res <- PUT(url, body = list(value = upload_file(file)), query = args, encode = "form", ...)
    }
  }
  stop_for_status(res)
  contutf8(res)
}

etcd_POST <- function(url, value, ttl=NULL, ...) {
  args <- etc(list(ttl = ttl))
  if (length(args) == 0) args <- NULL
  res <- POST(url, body = list(value = value), query = args, encode = "form", ...)
  stop_for_status(res)
  contutf8(res)
}

etcd_DELETE <- function(url, args, ...) {
  if (length(args) == 0) args <- NULL
  res <- DELETE(url, query = args, ...)
  if (res$status_code > 201) {
    warning(content(res)$message, call. = FALSE)
    content(res)
  }
  contutf8(res)
}

auth_PUT <- function(url, ...) {
  tt <- PUT(url, ..., encode = "json")
  if (tt$status_code > 201) {
    stop(content(tt)$message, call. = FALSE)
  }
  contutf8(tt)
}

auth_PUT2 <- function(url, ...) {
  tt <- PUT(url, ..., encode = "form")
  if (tt$status_code > 201) {
    stop(content(tt)$message, call. = FALSE)
  }
  contutf8(tt)
}

auth_DELETE <- function(url, args, ...) {
  if (length(args) == 0) args <- NULL
  res <- DELETE(url, query = args, ...)
  if (res$status_code > 201) {
    stop(content(res)$message, call. = FALSE)
  }
  contutf8(res)
}

member_POST <- function(url, ...) {
  res <- POST(url, encode = "json", ...)
  stop_for_status(res)
  contutf8(res)
}

member_PUT <- function(url, ...) {
  res <- PUT(url, encode = "json", ...)
  stop_for_status(res)
  contutf8(res)
}

member_DELETE <- function(url, ...) {
  res <- DELETE(url, encode = "json", ...)
  stop_for_status(res)
  contutf8(res)
}

user_PUT <- function(url, ...) {
  tt <- PUT(url, ..., encode = "json")
  if (tt$status_code > 201) {
    stop(content(tt)$message, call. = FALSE)
  }
  res <- contutf8(tt)
  jsonlite::fromJSON(res)
}