tests/testthat/test_Operator-pipe.R

In bdpar: Big Data Preprocessing Architecture

testthat::context("Operator-pipe")

testthat::setup({
  bdpar.Options$reset()
  bdpar.Options$configureLog()
})

testthat::test_that("'cache.folder' field error",{

  testthat::skip_if_not_installed("stringi")

  path <- file.path("testFiles",
                    "testOperator-pipe",
                    "files",
                    "_ham_",
                    "testFile.tsms")

  instance <- ExtractorSms$new(path)
  bdpar.Options$set("cache", FALSE)
  bdpar.Options$set("verbose", TRUE)
  pipeline <- DynamicPipeline$new()
  pipeline$add(list(File2Pipe$new()))
  testthat::expect_message(pipeline$execute(instance),
                           "[pipeOperator][ERROR] Bad compatibility between Pipes on File2Pipe",
                           fixed = TRUE)
})

testthat::teardown({
  bdpar.Options$reset()
  bdpar.Options$configureLog()
})

testthat::setup({
  bdpar.Options$reset()
  bdpar.Options$configureLog()

})

testthat::test_that("'cache' field error",{

  testthat::skip_if_not_installed("stringi")

  path <- file.path("testFiles",
                    "testOperator-pipe",
                    "files",
                    "_ham_",
                    "testFile.tsms")

  instance <- ExtractorSms$new(path)

  bdpar.Options$set("cache", NULL)
  bdpar.Options$set("verbose", TRUE)
  pipeline <- DynamicPipeline$new()
  pipeline$add(list(TargetAssigningPipe$new(), StoreFileExtPipe$new()))
  testthat::expect_message(pipeline$execute(instance),
                         "[-\\[\\]:0-9 ]+\\[DynamicPipeline\\]\\[execute\\]\\[ERROR\\] testFiles\\/testOperator-pipe\\/files\\/_ham_\\/testFile\\.tsms :Error: [-\\[\\]:0-9 ]+\\[FATAL\\] Cache status is not defined in bdpar\\.Options",
                         perl = TRUE)
})

testthat::teardown({
  bdpar.Options$reset()
  bdpar.Options$configureLog()
})

testthat::setup({
  bdpar.Options$reset()
  bdpar.Options$configureLog()
})

testthat::test_that("'cache.folder' field error",{

  testthat::skip_if_not_installed("stringi")

  path <- file.path("testFiles",
                    "testOperator-pipe",
                    "files",
                    "_ham_",
                    "testFile.tsms")

  instance <- ExtractorSms$new(path)
  bdpar.Options$set("cache", TRUE)
  bdpar.Options$set("cache.folder", NULL)
  bdpar.Options$set("verbose", TRUE)
  pipeline <- DynamicPipeline$new()
  pipeline$add(list(TargetAssigningPipe$new(), StoreFileExtPipe$new()))
  testthat::expect_message(pipeline$execute(instance),
                           "[-\\[\\]:0-9 ]+\\[DynamicPipeline\\]\\[execute\\]\\[ERROR\\] testFiles\\/testOperator-pipe\\/files\\/_ham_\\/testFile\\.tsms :Error: [-\\[\\]:0-9 ]+\\[FATAL\\] Cache folder is not defined in bdpar.Options",
                           perl = TRUE)
})

testthat::teardown({
  bdpar.Options$reset()
  bdpar.Options$configureLog()
})

testthat::setup({
  bdpar.Options$reset()
  bdpar.Options$configureLog()
  if (dir.exists(file.path("testFiles",
                           "testOperator-pipe",
                           ".cache"))) {
    unlink(file.path("testFiles",
                     "testOperator-pipe",
                     ".cache"),
           recursive = T)
  }
})

testthat::test_that("'cache' functionality works",{

  testthat::skip_if_not_installed("stringi")

  path <- file.path("testFiles",
                    "testOperator-pipe",
                    "files",
                    "_ham_",
                    "testFile.tsms")

  instance <- ExtractorSms$new(path)
  bdpar.Options$set("cache",
                    TRUE)
  bdpar.Options$set("cache.folder",
                    file.path("testFiles",
                              "testOperator-pipe",
                              ".cache"))
  pipeline <- DynamicPipeline$new()
  pipeline$add(list(TargetAssigningPipe$new(), StoreFileExtPipe$new()))
  pipeline$execute(instance)
  testthat::expect_true(dir.exists(file.path("testFiles",
                                             "testOperator-pipe",
                                             ".cache",
                                             "7ca200ced299")))

  testthat::expect_true(file.exists(file.path("testFiles",
                                              "testOperator-pipe",
                                              ".cache",
                                              "7ca200ced299",
                                              "1-0935fceb2d55-101e954308b7.z")))

  testthat::expect_true(file.exists(file.path("testFiles",
                                              "testOperator-pipe",
                                              ".cache",
                                              "7ca200ced299",
                                              "2-397465549696-039d3e4f119b.z")))
})

testthat::teardown({
  bdpar.Options$reset()
  bdpar.Options$configureLog()
  if (dir.exists(file.path("testFiles",
                           "testOperator-pipe",
                           ".cache"))) {
    unlink(file.path("testFiles",
                     "testOperator-pipe",
                     ".cache"),
           recursive = T)
  }
})