inst/actions/ocs4R_upload_data.R

In geoflow: Orchestrate Geospatial (Meta)Data Management Workflows and Manage FAIR Services

function(action, entity, config){
  
  if(!requireNamespace("ocs4R", quietly = TRUE)){
    stop("The 'ocs4R-upload' action requires the 'ocs4R' package")
  }
  
  OCS_CONFIG = config$software$output$ocs_config
  OCS = config$software$output$ocs
  if(is.null(OCS)){
    errMsg <- "This action requires a OCS software to be declared in the configuration"
    config$logger$ERROR(errMsg)
    stop(errMsg)
  }
  cloud_path <- OCS_CONFIG$properties$cloud_path
  if(is.null(cloud_path)) if(!is.null(entity$data$cloud_path)) cloud_path <- entity$data$cloud_path
  if(is.null(cloud_path)){
    errMsg <- "The OCS configuration requires a 'cloud_path' for publishing action"
    config$logger$ERROR(errMsg)
    stop(errMsg)
  }    
  if(!startsWith(cloud_path, "/")) cloud_path = paste0("/", cloud_path)

  #upload
  #-------------------------------------------------------------------------------------------------
  if(entity$data$upload){
    #try to create collection (remote folder)
    cloud_path_name = substring(cloud_path, 2, nchar(cloud_path))
    try(OCS$makeCollection(name = cloud_path_name))
    
    config$logger$INFO("Upload mode is set to true")
    fileName = entity$data$uploadSource[[1]]
    filePath = file.path(getwd(),"data",fileName)
    if(startsWith(entity$data$uploadType,"db")){
      errMsg <- "Skipping upload: Upload mode is no valid for 'database' type"
      config$logger$ERROR(errMsg)
      stop(errMsg)
    }else{
      config$logger$INFO("Trying to upload %s to cloud folder %s", fileName, cloud_path)
      OCS$uploadFile(filename = filePath, relPath = cloud_path, delete_if_existing = FALSE)
      config$logger$INFO("File %s successfully uploaded to the cloud folder %s", fileName, cloud_path)
    }
  }
  
  #enrish with relation
  #-------------------------------------------------------------------------------------------------
  cloud_link_url = try(OCS$shareAsPublicLink(cloud_path, filePath, permissions = "read"), silent = TRUE)
  if(!is(cloud_link_url, "try-error")){
    new_cloud_link<- geoflow_relation$new()
    new_cloud_link$setKey("http")
    new_cloud_link$setName(fileName)
    new_cloud_link$setDescription(paste0(entity$titles[['title']]," - Cloud Data Download (",entity$data$uploadType,")"))
    new_cloud_link$setLink(cloud_link_url)
    entity$addRelation(new_cloud_link)
  }
  
}