R/faasr_s3_check.R

In FaaSr: FaaS (Function as a Service) Package

#' @name faasr_s3_check
#' @title faasr_s3_check
#' @description 
#' Check 
#' 1. server's Endpoint&Region and Endpoint has a valid form(http).
#' 2. send a req for the head of the bucket to check the status of s3 servers.
#' 3. Check that the bucket name exists.
#' @param faasr list with parsed and validated Payload
#' @return faasr list with parsed and validated payload
#' @importFrom "paws.storage" "s3"
#' @keywords internal

globalVariables(".faasr")
faasr_s3_check <- function(faasr){
  for(server in names(faasr$DataStores)){
    endpoint_check <- faasr$DataStores[[server]]$Endpoint
    region_check <- faasr$DataStores[[server]]$Region
    if (length(endpoint_check)==0 || endpoint_check=="") {
      faasr$DataStores[[server]]$Endpoint <- ""
    }else{
      if (!(startsWith(endpoint_check, "http"))){
        msg <- paste0('{\"faasr_s3_check\":\"Invalid Data store server endpoint ',server,'\"}', "\n")
        message(msg)
        stop()
      }
    }
    if (length(region_check)==0 || region_check==""){
      faasr$DataStores[[server]]$Region <- "us-east-1"
    }
    if (!is.null(faasr$DataStores[[server]]$Anonymous)){
      if (isTRUE(as.logical(faasr$DataStores[[server]]$Anonymous))){
        next
      }
    }
    s3<-paws.storage::s3(
      config=list(
        credentials=list(
          creds=list(
            access_key_id=faasr$DataStores[[server]]$AccessKey,
            secret_access_key=faasr$DataStores[[server]]$SecretKey
          )
        ),
        endpoint=faasr$DataStores[[server]]$Endpoint,
        region=faasr$DataStores[[server]]$Region
      )
    )
    check <- try(s3$head_bucket(Bucket = faasr$DataStores[[server]]$Bucket), silent=TRUE)
    if(is.list(check)){
      next
    }else{
      msg <- paste0('{\"faasr_s3_check\":\"S3 server ',server,' failed with message: Data store server unreachable\"}', "\n")
      message(msg)
      stop()
    }
  }
  return(faasr)
}