inst/tinytest/test_TALFs.R

In gisler/DTSg: A Class for Working with Time Series Data Based on 'data.table' and 'R6' with Largely Optional Reference Semantics

source("data.R")

for (approach in c("base", "fasttime", "RcppCCTZ")) {
  options(DTSgFunbyApproach = approach)

  expect_identical(
    getOption("DTSgFunbyApproach"),
    approach,
    '"DTSgFunbyApproach" is set correctly'
  )

  #### UTC, multiplier == 1L ####
  expect_identical(
    DTSg$new(UTChourlyData)$aggregate(byY_____, sum)$values(TRUE)[["value"]],
    UTChourlyData[, .(value = sum(value)), by = "year"][["value"]],
    info = '"byY_____" works as expected (UTC, multiplier == 1L)'
  )

  expect_identical(
    DTSg$new(UTChourlyData)$aggregate(byYQ____, sum)$values(TRUE)[["value"]],
    UTChourlyData[, .(value = sum(value)), by = "quarter"][["value"]],
    info = '"byYQ____" works as expected (UTC, multiplier == 1L)'
  )

  expect_identical(
    DTSg$new(UTChourlyData)$aggregate(byYm____, sum)$values(TRUE)[["value"]],
    UTChourlyData[, .(value = sum(value)), by = "month"][["value"]],
    info = '"byYm____" works as expected (UTC, multiplier == 1L)'
  )

  expect_identical(
    DTSg$new(UTChourlyData)$aggregate(byYmd___, sum)$values(TRUE)[["value"]],
    UTChourlyData[, .(value = sum(value)), by = "day"][["value"]],
    info = '"byYmd___" works as expected (UTC, multiplier == 1L)'
  )

  expect_identical(
    DTSg$new(UTCfractionalSecondData)$aggregate(byYmdH__, sum)$values(TRUE)[["value"]],
    UTCfractionalSecondData[, .(value = sum(value)), by = "hour"][["value"]],
    info = '"byYmdH__" works as expected (UTC, multiplier == 1L)'
  )

  expect_identical(
    DTSg$new(UTCfractionalSecondData)$aggregate(byYmdHM_, sum)$values(TRUE)[["value"]],
    UTCfractionalSecondData[, .(value = sum(value)), by = "minute"][["value"]],
    info = '"byYmdHM_" works as expected (UTC, multiplier == 1L)'
  )

  expect_identical(
    DTSg$new(UTCfractionalSecondData)$aggregate(byYmdHMS, sum)$values(TRUE)[["value"]],
    UTCfractionalSecondData[, .(value = sum(value)), by = "second"][["value"]],
    info = '"byYmdHMS" works as expected (UTC, multiplier == 1L)'
  )

  expect_identical(
    DTSg$new(UTChourlyData)$aggregate(by______, sum)$values(TRUE)[["value"]],
    UTChourlyData[, .(value = sum(value))][["value"]],
    info = '"by______" works as expected (UTC, multiplier == 1L)'
  )

  expect_identical(
    DTSg$new(UTChourlyData)$aggregate(by_Q____, sum)$values(TRUE)[["value"]],
    UTChourlyData[, .(value = sum(value)), keyby = "quarter"][["value"]],
    info = '"by_Q____" works as expected (UTC, multiplier == 1L)'
  )

  expect_identical(
    DTSg$new(UTChourlyData)$aggregate(by_m____, sum)$values(TRUE)[["value"]],
    UTChourlyData[, .(value = sum(value)), keyby = "month"][["value"]],
    info = '"by_m____" works as expected (UTC, multiplier == 1L)'
  )

  expect_identical(
    DTSg$new(UTCfractionalSecondData)$aggregate(by___H__, sum)$values(TRUE)[["value"]],
    UTCfractionalSecondData[, .(value = sum(value)), by = "hour"][["value"]],
    info = '"by___H__" works as expected (UTC, multiplier == 1L)'
  )

  expect_identical(
    DTSg$new(UTCfractionalSecondData)$aggregate(by____M_, sum)$values(TRUE)[["value"]],
    UTCfractionalSecondData[, .(value = sum(value)), by = "hourMinute"][["value"]],
    info = '"by____M_" works as expected (UTC, multiplier == 1L)'
  )

  expect_identical(
    DTSg$new(UTCfractionalSecondData)$aggregate(by_____S, sum)$values(TRUE)[["value"]],
    UTCfractionalSecondData[, .(value = sum(value)), by = "minuteSecond"][["value"]],
    info = '"by_____S" works as expected (UTC, multiplier == 1L)'
  )

  #### UTC, multiplier > 1L ####
  expect_identical(
    DTSg$new(UTChourlyData)$aggregate(byY_____, sum, multiplier = 2L)$values(TRUE)[["value"]],
    UTChourlyData[, .(value = sum(value)), by = .(year %/% 2L * 2L)][["value"]],
    info = '"byY_____" works as expected (UTC, multiplier > 1L)'
  )

  expect_identical(
    DTSg$new(UTChourlyData)$aggregate(byYm____, sum, multiplier = 3L)$values(TRUE)[["value"]],
    UTChourlyData[, .(value = sum(value)), by = .((yearMonth - 1L) %/% 3L * 3L + 1L)][["value"]],
    info = '"byYm____" works as expected (UTC, multiplier > 1L)'
  )

  expect_identical(
    DTSg$new(UTCfractionalSecondData)$aggregate(byYmdH__, sum, multiplier = 2L)$values(TRUE)[["value"]],
    UTCfractionalSecondData[, .(value = sum(value)), by = .(hour %/% 2L * 2L)][["value"]],
    info = '"byYmdH__" works as expected (UTC, multiplier > 1L)'
  )

  expect_identical(
    DTSg$new(UTCfractionalSecondData)$aggregate(byYmdHM_, sum, multiplier = 6L)$values(TRUE)[["value"]],
    UTCfractionalSecondData[, .(value = sum(value)), by = .(minute %/% 6L * 6L)][["value"]],
    info = '"byYmdHM_" works as expected (UTC, multiplier > 1L)'
  )

  expect_identical(
    DTSg$new(UTCfractionalSecondData)$aggregate(byYmdHMS, sum, multiplier = 20L)$values(TRUE)[["value"]],
    UTCfractionalSecondData[, .(value = sum(value)), by = .(second %/% 20L * 20L)][["value"]],
    info = '"byYmdHMS" works as expected (UTC, multiplier > 1L)'
  )

  expect_identical(
    DTSg$new(UTChourlyData)$aggregate(by_m____, sum, multiplier = 2L)$values(TRUE)[["value"]],
    UTChourlyData[, .(value = sum(value)), keyby = .((month - 1L) %/% 2L * 2L + 1L)][["value"]],
    info = '"by_m____" works as expected (UTC, multiplier > 1L)'
  )

  expect_identical(
    DTSg$new(UTCfractionalSecondData)$aggregate(by___H__, sum, multiplier = 2L)$values(TRUE)[["value"]],
    UTCfractionalSecondData[, .(value = sum(value)), by = .(hour %/% 2L * 2L)][["value"]],
    info = '"by___H__" works as expected (UTC, multiplier > 1L)'
  )

  expect_identical(
    DTSg$new(UTCfractionalSecondData)$aggregate(by____M_, sum, multiplier = 10L)$values(TRUE)[["value"]],
    UTCfractionalSecondData[, .(value = sum(value)), by = .(hourMinute %/% 10L * 10L)][["value"]],
    info = '"by____M_" works as expected (UTC, multiplier > 1L)'
  )

  expect_identical(
    DTSg$new(UTCfractionalSecondData)$aggregate(by_____S, sum, multiplier = 12L)$values(TRUE)[["value"]],
    UTCfractionalSecondData[, .(value = sum(value)), by = .(minuteSecond %/% 12L * 12L)][["value"]],
    info = '"by_____S" works as expected (UTC, multiplier > 1L)'
  )
}

for (approach in c("base", "RcppCCTZ")) {
  options(DTSgFunbyApproach = approach)

  #### CETtoFromDST, multiplier == 1L ####
  expect_identical(
    DTSg$new(CEThourlyData)$aggregate(byY_____, sum, ignoreDST = TRUE)$values(TRUE)[["value"]],
    CEThourlyData[, .(value = sum(value)), by = "year"][["value"]],
    info = '"byY_____" works as expected (CETtoFromDST, multiplier == 1L)'
  )

  expect_identical(
    DTSg$new(CEThourlyData)$aggregate(byYQ____, sum, ignoreDST = TRUE)$values(TRUE)[["value"]],
    CEThourlyData[, .(value = sum(value)), by = "quarter"][["value"]],
    info = '"byYQ____" works as expected (CETtoFromDST, multiplier == 1L)'
  )

  expect_identical(
    DTSg$new(CEThourlyData)$aggregate(byYm____, sum, ignoreDST = TRUE)$values(TRUE)[["value"]],
    CEThourlyData[, .(value = sum(value)), by = "month"][["value"]],
    info = '"byYm____" works as expected (CETtoFromDST, multiplier == 1L)'
  )

  expect_identical(
    DTSg$new(CEThourlyData)$aggregate(byYmd___, sum, ignoreDST = TRUE)$values(TRUE)[["value"]],
    CEThourlyData[, .(value = sum(value)), by = "day"][["value"]],
    info = '"byYmd___" works as expected (CETtoFromDST, multiplier == 1L)'
  )

  expect_identical(
    DTSg$new(CETtoDSTfractionalSecondData)$aggregate(byYmdH__, sum)$values(TRUE)[["value"]],
    CETtoDSTfractionalSecondData[, .(value = sum(value)), by = "hour"][["value"]],
    info = '"byYmdH__" works as expected (CETtoDST, multiplier == 1L)'
  )

  expect_identical(
    DTSg$new(CETtoDSTfractionalSecondData)$aggregate(byYmdHM_, sum)$values(TRUE)[["value"]],
    CETtoDSTfractionalSecondData[, .(value = sum(value)), by = "minute"][["value"]],
    info = '"byYmdHM_" works as expected (CETtoDST, multiplier == 1L)'
  )

  expect_identical(
    DTSg$new(CETtoDSTfractionalSecondData)$aggregate(byYmdHMS, sum)$values(TRUE)[["value"]],
    CETtoDSTfractionalSecondData[, .(value = sum(value)), by = "second"][["value"]],
    info = '"byYmdHMS" works as expected (CETtoDST, multiplier == 1L)'
  )

  expect_identical(
    DTSg$new(CEThourlyData)$aggregate(by______, sum)$values(TRUE)[["value"]],
    CEThourlyData[, .(value = sum(value))][["value"]],
    info = '"by______" works as expected (CETtoFromDST, multiplier == 1L)'
  )

  expect_identical(
    DTSg$new(CEThourlyData)$aggregate(by_Q____, sum, ignoreDST = TRUE)$values(TRUE)[["value"]],
    CEThourlyData[, .(value = sum(value)), keyby = "quarter"][["value"]],
    info = '"by_Q____" works as expected (CETtoFromDST, multiplier == 1L)'
  )

  expect_identical(
    DTSg$new(CEThourlyData)$aggregate(by_m____, sum, ignoreDST = TRUE)$values(TRUE)[["value"]],
    CEThourlyData[, .(value = sum(value)), keyby = "month"][["value"]],
    info = '"by_m____" works as expected (CETtoFromDST, multiplier == 1L)'
  )

  expect_identical(
    DTSg$new(CETtoDSTfractionalSecondData)$aggregate(by___H__, sum, ignoreDST = TRUE)$values(TRUE),
    setkey(data.table(
      .dateTime = as.POSIXct(c("2199-01-01 01:00:00", "2199-01-01 02:00:00"), tz = "Europe/Vienna"),
      value = CETtoDSTfractionalSecondData[, .(value = sum(value)), by = "hour"][["value"]]
    ), ".dateTime"),
    info = '"by___H__" works as expected (CETtoDST, multiplier == 1L)'
  )

  expect_identical(
    DTSg$new(CETtoDSTfractionalSecondData)$aggregate(by____M_, sum)$values(TRUE)[["value"]],
    CETtoDSTfractionalSecondData[, .(value = sum(value)), by = "hourMinute"][["value"]],
    info = '"by____M_" works as expected (CETtoDST, multiplier == 1L)'
  )

  expect_identical(
    DTSg$new(CETtoDSTfractionalSecondData)$aggregate(by_____S, sum)$values(TRUE)[["value"]],
    CETtoDSTfractionalSecondData[, .(value = sum(value)), by = "minuteSecond"][["value"]],
    info = '"by_____S" works as expected (CETtoDST, multiplier == 1L)'
  )

  #### CETfromDST, multiplier == 1L ####
  expect_identical(
    DTSg$new(CETfromDSTfractionalSecondData)$aggregate(byYmdH__, sum)$values(TRUE)[["value"]],
    CETfromDSTfractionalSecondData[, .(value = sum(value)), by = "hour"][["value"]],
    info = '"byYmdH__" works as expected (CETfromDST, multiplier == 1L)'
  )

  expect_identical(
    DTSg$new(CETfromDSTfractionalSecondData)$aggregate(byYmdHM_, sum)$values(TRUE)[["value"]],
    CETfromDSTfractionalSecondData[, .(value = sum(value)), by = "minute"][["value"]],
    info = '"byYmdHM_" works as expected (CETfromDST, multiplier == 1L)'
  )

  expect_identical(
    DTSg$new(CETfromDSTfractionalSecondData)$aggregate(byYmdHMS, sum)$values(TRUE)[["value"]],
    CETfromDSTfractionalSecondData[, .(value = sum(value)), by = "second"][["value"]],
    info = '"byYmdHMS" works as expected (CETfromDST, multiplier == 1L)'
  )

  expect_identical(
    DTSg$new(CETfromDSTfractionalSecondData)$aggregate(by___H__, sum, ignoreDST = TRUE)$values(TRUE),
    setkey(data.table(
      .dateTime = as.POSIXct(c("2199-01-01 01:00:00", "2199-01-01 02:00:00", "2199-01-01 03:00:00"), tz = "Europe/Vienna"),
      value = CETfromDSTfractionalSecondData[, .(value = sum(value)), by = "hour"][["value"]]
    ), ".dateTime"),
    info = '"by___H__" works as expected (CETfromDST, multiplier == 1L)'
  )

  expect_identical(
    DTSg$new(CETfromDSTfractionalSecondData)$aggregate(by____M_, sum)$values(TRUE)[["value"]],
    CETfromDSTfractionalSecondData[, .(value = sum(value)), by = "hourMinute"][["value"]],
    info = '"by____M_" works as expected (CETfromDST, multiplier == 1L)'
  )

  expect_identical(
    DTSg$new(CETfromDSTfractionalSecondData)$aggregate(by_____S, sum)$values(TRUE)[["value"]],
    CETfromDSTfractionalSecondData[, .(value = sum(value)), by = "minuteSecond"][["value"]],
    info = '"by_____S" works as expected (CETfromDST, multiplier == 1L)'
  )

  #### CETtoFromDST, multiplier > 1L ####
  expect_identical(
    DTSg$new(CEThourlyData)$aggregate(byY_____, sum, ignoreDST = TRUE, multiplier = 2L)$values(TRUE),
    setkey(data.table(
      .dateTime = as.POSIXct(c("1998-01-01", "2000-01-01"), tz = "Europe/Vienna"),
      value = CEThourlyData[, .(value = sum(value)), by = .(year %/% 2L * 2L)][["value"]]
    ), ".dateTime"),
    info = '"byY_____" works as expected (CETtoFromDST, multiplier > 1L)'
  )

  expect_identical(
    DTSg$new(CEThourlyData)$aggregate(byYm____, sum, ignoreDST = TRUE, multiplier = 3L)$values(TRUE)[["value"]],
    CEThourlyData[, .(value = sum(value)), by = .((yearMonth - 1L) %/% 3L * 3L + 1L)][["value"]],
    info = '"byYm____" works as expected (CETtoFromDST, multiplier > 1L)'
  )

  expect_identical(
    DTSg$new(CETtoDSTfractionalSecondData)$aggregate(byYmdHM_, sum, multiplier = 5L)$values(TRUE)[["value"]],
    CETtoDSTfractionalSecondData[, .(value = sum(value)), by = .(minute %/% 5L * 5L)][["value"]],
    info = '"byYmdHM_" works as expected (CETtoDST, multiplier > 1L)'
  )

  expect_identical(
    DTSg$new(CETtoDSTfractionalSecondData)$aggregate(byYmdHMS, sum, multiplier = 4L)$values(TRUE)[["value"]],
    CETtoDSTfractionalSecondData[, .(value = sum(value)), by = .(second %/% 4L * 4L)][["value"]],
    info = '"byYmdHMS" works as expected (CETtoDST, multiplier > 1L)'
  )

  expect_identical(
    DTSg$new(CEThourlyData)$aggregate(by_m____, sum, ignoreDST = TRUE, multiplier = 3L)$values(TRUE)[["value"]],
    CEThourlyData[, .(value = sum(value)), keyby = .((month - 1L) %/% 3L * 3L + 1L)][["value"]],
    info = '"by_m____" works as expected (CETtoFromDST, multiplier > 1L)'
  )

  expect_identical(
    DTSg$new(CETtoDSTfractionalSecondData)$aggregate(by____M_, sum, multiplier = 15L)$values(TRUE)[["value"]],
    CETtoDSTfractionalSecondData[, .(value = sum(value)), by = .(hourMinute %/% 15L * 15L)][["value"]],
    info = '"by____M_" works as expected (CETtoDST, multiplier > 1L)'
  )

  expect_identical(
    DTSg$new(CETtoDSTfractionalSecondData)$aggregate(by_____S, sum, multiplier = 5L)$values(TRUE)[["value"]],
    CETtoDSTfractionalSecondData[, .(value = sum(value)), by = .(minuteSecond %/% 5L * 5L)][["value"]],
    info = '"by_____S" works as expected (CETtoDST, multiplier > 1L)'
  )

  #### CETfromDST, multiplier > 1L ####
  expect_identical(
    DTSg$new(CETfromDSTfractionalSecondData)$aggregate(byYmdHM_, sum, multiplier = 15L)$values(TRUE)[["value"]],
    CETfromDSTfractionalSecondData[, .(value = sum(value)), by = .(minute %/% 15L * 15L)][["value"]],
    info = '"byYmdHM_" works as expected (CETfromDST, multiplier > 1L)'
  )

  expect_identical(
    DTSg$new(CETfromDSTfractionalSecondData)$aggregate(byYmdHMS, sum, multiplier = 10L)$values(TRUE)[["value"]],
    CETfromDSTfractionalSecondData[, .(value = sum(value)), by = .(second %/% 10L * 10L)][["value"]],
    info = '"byYmdHMS" works as expected (CETfromDST, multiplier > 1L)'
  )

  expect_identical(
    DTSg$new(CETfromDSTfractionalSecondData)$aggregate(by____M_, sum, multiplier = 20L)$values(TRUE)[["value"]],
    CETfromDSTfractionalSecondData[, .(value = sum(value)), by = .(hourMinute %/% 20L * 20L)][["value"]],
    info = '"by____M_" works as expected (CETfromDST, multiplier > 1L)'
  )

  expect_identical(
    DTSg$new(CETfromDSTfractionalSecondData)$aggregate(by_____S, sum, multiplier = 12L)$values(TRUE)[["value"]],
    CETfromDSTfractionalSecondData[, .(value = sum(value)), by = .(minuteSecond %/% 12L * 12L)][["value"]],
    info = '"by_____S" works as expected (CETfromDST, multiplier > 1L)'
  )
}