R/check_dataproduct_exists.R

In rDataPipeline: Functions to Interact with the 'FAIR Data Pipeline'

#' check_dataproduct_exists
#'
#' If a data product already exists with the same name, version, and
#' namespace, throw an error
#'
#' @param write_dataproduct write_dataproduct
#' @param write_version write_version
#' @param write_namespace_id write_namespace_id
#' @param endpoint endpoint
#'
check_dataproduct_exists <- function(write_dataproduct,
                                     write_version,
                                     write_namespace_id,
                                     endpoint) {

  check_exists <- get_entry("data_product",
                            list(name = write_dataproduct,
                                 version = write_version,
                                 namespace = write_namespace_id),
                            endpoint = endpoint)

  write_namespace_url <- file.path("http://localhost:8000", "api",
                                   "namespace", write_namespace_id)
  write_namespace <- get_entity(write_namespace_url)$name

  if (!is.null(check_exists)) {
    msg <- paste("A data product with the same name ({write_dataproduct}),",
                 "version ({write_version}), and namespace ({write_namespace})",
                 "already exists")
    usethis::ui_stop(msg)
  }
}