# library(testthat)
# library(TreatmentPatterns)
# library(dplyr)
# 
# test_that("fetchCohortTable", {
#   skip_on_cran()
#   skip_on_ci()
# 
#   aCG <- Andromeda::andromeda()
#   aCDMC <- Andromeda::andromeda()
# 
#   dbcInterface <- TreatmentPatterns:::CDMInterface$new(
#     connectionDetails = .CG$connectionDetails,
#     cdmSchema = "main",
#     resultSchema = "main"
#   )
# 
#   cdmcInterface <- TreatmentPatterns:::CDMInterface$new(
#     cdm = .CM$cdm
#   )
# 
#   minEraDuration <- 120
# 
#   x <- dbcInterface$fetchCohortTable(
#     cohorts = .CG$cohorts,
#     cohortTableName = .CG$cohortTableName,
#     andromeda = aCG,
#     andromedaTableName = .CG$cohortTableName,
#     minEraDuration = minEraDuration
#   )
# 
#   x <- cdmcInterface$fetchCohortTable(
#     cohorts = .CM$cohorts,
#     cohortTableName = .CM$cohortTableName,
#     andromeda = aCDMC,
#     andromedaTableName = .CM$cohortTableName,
#     minEraDuration = minEraDuration
#   )
# 
#   # Check nRows
#   expect_identical(
#     aCG$cohort_table %>% collect() %>% nrow(),
#     aCDMC$cohort_table %>% collect() %>% nrow()
#   )
# 
#   # check n > 1 treatments
#   expect_identical(
#     aCG$cohort_table %>%
#       group_by(.data$subject_id) %>%
#       summarize(n = n()) %>%
#       filter(n > 1) %>%
#       collect() %>%
#       mutate(subject_id = as.numeric(subject_id)) %>%
#       pull(n) %>%
#       sum(),
#     aCDMC$cohort_table %>%
#       group_by(.data$subject_id) %>%
#       summarize(n = n()) %>%
#       filter(n > 1) %>%
#       collect() %>%
#       mutate(subject_id = as.numeric(subject_id)) %>%
#       pull(n) %>%
#       sum()
#   )
# 
#   # check n == 1 treatments
#   expect_identical(
#     aCG$cohort_table %>%
#       group_by(.data$subject_id) %>%
#       summarize(n = n()) %>%
#       filter(n == 1) %>%
#       collect() %>%
#       mutate(subject_id = as.numeric(subject_id)) %>%
#       pull(n) %>%
#       sum(),
#     aCDMC$cohort_table %>%
#       group_by(.data$subject_id) %>%
#       summarize(n = n()) %>%
#       filter(n == 1) %>%
#       collect() %>%
#       mutate(subject_id = as.numeric(subject_id)) %>%
#       pull(n) %>%
#       sum()
#   )
# 
#   Andromeda::close(aCG)
#   Andromeda::close(aCDMC)
# })