R/testColumnsCosistency.R

In filipcyprowski/GetProcessVisualise: Cohesive and testable BI pipelines in functional programming paradigm

#' @importFrom purrr detect_index
#' @importFrom dplyr filter_

#' @title Test data.frame based on some conditions
#'
#' @param data data.frame
#' @param conditions character.vector "filter_ like" conditions, e.g. "Sepal.Length > 0"
#'
#' @return the same data.frame or raise error (what conditions were not met)
#' @export testColumnsCosistency
#'
#' @examples
#' testColumnsCosistency(iris, "Sepal.Length > 0")
#' iris$Sepal.Length[5:10] = NA
#' testColumnsCosistency(iris, "is.na(Sepal.Length)")
testColumnsCosistency = function(data, conditions) {
  # create function for data~result comparison
  other_than_data = partial(other_than_data_, data = data)
  # run first conditions
  conditions %>%
    map(~filter_(data, .)) -> result
  # create function for throw the message
  conditions_that_gives_results = partial(
    conditions_that_gives_results_,
    conditions = conditions,
    result = result
  )
  # now at last throw it or pass it
  result  %>%
    keep(~other_than_data(.)) %>%
    when(length(.) == 0 ~TRUE, ~FALSE) %>%
    raiseErrorOrPassForward(
      data,
      conditions_that_gives_results(other_than_data)
    )
    
}
other_than_data_ = function(results, data) {
  nrow(results) != nrow(data) 
}
conditions_that_gives_results_ = function(fun, conditions, result) {
  paste0(
    'Condition ', conditions[detect_index(result, fun)],
    ' not fulfilled.'
  ) %>%
    paste(collapse = ';\n')
}