inst/actions/geonode4R_publish_ogc_services.R

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

function(action, entity, config){
  
  if(!requireNamespace("geonode4R", quietly = TRUE)){
    stop("The 'geonode4R-publish-ogc-services' action requires the 'geonode4R' package")
  }
  
  #shortcut for geonode config
  GEONODE_CONFIG <- config$software$output$geonode_config
  GEONODE <- config$software$output$geonode
  if(is.null(GEONODE)){
    errMsg <- "This action requires a GeoNode software to be declared in the configuration"
    config$logger$ERROR(errMsg)
    stop(errMsg)
  }
  
  #TODO to check behavior of multiple objects on GeoNode, in principle not elegible to multi-upload
  data_objects <- list()
  if(length(entity$data$getData())==0){
    data_objects <- list(entity$data)
  }else{
    data_objects <- entity$data$getData()
  }
  
  if(length(data_objects)>0) for(data_object in data_objects){
  
    #datasource
    datasource <- data_object$uploadSource[[1]]
    datasource_name <- NULL
    datasource_file <- NULL
    if(!is.null(datasource)){
      datasource_name <- unlist(strsplit(datasource, "\\."))[1]
      datasource_file <- attr(datasource, "uri")
      attributes(datasource) <- NULL
    }else{
      if(data_object$upload){
        errMsg <- sprintf("Upload source is missing!")
        stop(errMsg)
      }
    }
    
    #layername/sourcename
    layername <- if(!is.null(data_object$layername)) data_object$layername else entity$identifiers$id
    
    #check if resources already exists
    #-------------------------------------------------------------------------------------------------
    resource = GEONODE$getResourceByUUID(uuid = entity$identifiers[["uuid"]])
    if(!is.null(resource)){
      config$logger$WARN(sprintf("Resource '%s' (id = %s) already exists! Deleting it...", resource$uuid, resource$pk))
      deleted = GEONODE$deleteResource(id = resource$pk)
      if(deleted) config$logger$WARN(sprintf("Resource '%s' (id = %s) deleted!", resource$uuid, resource$pk))
    }
    
    #upload
    #-------------------------------------------------------------------------------------------------
    if(data_object$upload){
      
      config$logger$INFO("Upload mode is set to true")
      if(startsWith(data_object$uploadType,"db") || data_object$uploadType == "other"){
        warnMsg <- "Skipping upload: Upload mode is only valid for types 'shp', 'spatialite' or 'h2'"
        config$logger$WARN(warnMsg)
      }else{
        uploaded <- FALSE
        config$logger$INFO("Upload from local file(s)")
        filepath <- file.path(getwd(), "data", datasource)
        config$logger$INFO("File to upload to GeoNode: %s", filepath)
        if(file.exists(filepath)){
          config$logger$INFO("Upload file '%s' [%s] to GeoNode...", filepath, data_object$uploadType)
          files = list.files(path = "data", pattern = datasource_name, full.names = TRUE)
          files = files[!endsWith(files, ".zip")]
          dir.create("data/temp")
          for(file in files){
            file_ext = unlist(strsplit(file, "\\."))[2]
            target = file.path(getwd(), "data/temp", paste0(layername, ".", file_ext))
            file.copy(from = file, to = target, copy.mode = T)
            if(file_ext == "xml"){
              #post-process metadata identifier if existing to match entity uuid
              md = geometa::readISO19139(target)
              md$fileIdentifier <- entity$identifiers[["uuid"]]
              md$save(target)
            }
          }
          created = GEONODE$upload(files = list.files(path = "data/temp", pattern = layername, full.names = TRUE))
          uploaded = !is.null(created$dataset)
          unlink("data/temp",recursive = TRUE, force = TRUE)
        }else{
          errMsg <- sprintf("Upload from local file(s): no zipped file found for source '%s' (%s)", filepath, datasource)
          config$logger$ERROR(errMsg)
          stop(errMsg)
        }
        
        if(uploaded){
          infoMsg <- sprintf("Successful GeoNode upload for file '%s' (%s)", datasource_file, data_object$uploadType)
          config$logger$INFO(infoMsg)
        }else{
          errMsg <- "Error during GeoNode file upload. Aborting 'geonode4R' action!"
          config$logger$ERROR(errMsg)
          stop(errMsg)
        }
      }
    }
    
  }
  
}