R/api_delete_timeseries.R

In KWB-R/fhpredict: R Package for the Project Flusshygiene

# api_delete_timeseries --------------------------------------------------------
api_delete_timeseries <- function(
  user_id, spot_id, path_function, ids = NULL, subject = "timeseries",
  series_id = NULL, dbg = TRUE
)
{
  # Request a token to be reused
  token <- get_postgres_api_token()

  # Get all available ids if no ids are given
  if (is.null(ids)) {

    path <- if (is.null(series_id)) {
      path_function(user_id, spot_id)
    } else {
      path_function(user_id, spot_id, series_id)
    }

    df <- api_get_timeseries(path, subject, token = token)

    if (nrow(df) == 0) {

      message(get_text(
        "no_data", subject = subject, user_id = user_id, spot_id = spot_id
      ))

      return()
    }

    ids <- kwb.utils::selectColumns(df, "id")
  }

  # Delete all records given their ids
  kwb.utils::catAndRun(
    get_text("deleting_data_points", n = length(ids), subject = subject),
    dbg = dbg, {

      for (id in ids) {

        path <- if (is.null(series_id)) {
          path_function(user_id, spot_id, id)
        } else {
          path_function(user_id, spot_id, series_id, id)
        }

        safe_postgres_delete(path, token = token)
      }
    }
  )
}