R/utils.R

In daqapo: Data Quality Assessment for Process-Oriented Data

#' @importFrom magrittr %>%
#' @export
magrittr::`%>%`


#' @importFrom lubridate ymd_hms
#' @export
lubridate::ymd_hms
#' @importFrom lubridate ymd_hm
#' @export
lubridate::ymd_hm
#' @importFrom lubridate ymd_h
#' @export
lubridate::ymd_h
#' @importFrom lubridate ymd
#' @export
lubridate::ymd
#' @importFrom lubridate dmy_hms
#' @export
lubridate::dmy_hms
#' @importFrom lubridate dmy_hm
#' @export
lubridate::dmy_hm
#' @importFrom lubridate dmy_h
#' @export
lubridate::dmy_h
#' @importFrom lubridate dmy
#' @export
lubridate::dmy
#' @importFrom lubridate mdy_hms
#' @export
lubridate::mdy_hms
#' @importFrom lubridate mdy_hm
#' @export
lubridate::mdy_hm
#' @importFrom lubridate mdy_h
#' @export
lubridate::mdy_h
#' @importFrom lubridate mdy
#' @export
lubridate::mdy


#' @importFrom readr read_csv
#' @export
readr::read_csv
#' @importFrom readr read_csv2
#' @export
readr::read_csv2

#' @importFrom dplyr rename
#' @export
dplyr::rename

#' @importFrom rlang sym
#'
case_id_ <- function(eventlog) sym(case_id(eventlog))
activity_id_ <- function(eventlog) sym(activity_id(eventlog))
activity_instance_id_ <- function(eventlog) sym(activity_instance_id(eventlog))
resource_id_ <- function(eventlog) sym(resource_id(eventlog))
timestamp_ <- function(eventlog) sym(timestamp(eventlog))
lifecycle_id_ <- function(eventlog) sym(lifecycle_id(eventlog))


APPLY_FILTER <- function(activity_log, filter_condition_q) {
  warning.filtercondition <- FALSE

  tryCatch({
    activity_log <- activity_log %>% filter(!!filter_condition_q)
  }, error = function(e) {
    warning.filtercondition <<- TRUE
  }
  )


  if(warning.filtercondition) {
    warning("The condition '", expr_text(filter_condition_q), "'  is invalid. No filtering performed on the dataset.")
    #Make sure we don't pretend as if it is filtered later
    filter_specified <- F
  } else {
    filter_specified <- T
    }

  if(filter_specified) {
    message("Applied filtering condition:", expr_text(filter_condition_q), "\n", "\n")
  }
  return(activity_log)
}