## ----setup, include=FALSE-----------------------------------------------------
knitr::opts_chunk$set(echo = TRUE)

withr::local_envvar(
  R_USER_CACHE_DIR = tempfile(),
  EUNOMIA_DATA_FOLDER = Sys.getenv("EUNOMIA_DATA_FOLDER", unset = tempfile())
)

## ----message=FALSE, eval=require("CDMConnector", quietly = TRUE, warn.conflicts = FALSE, character.only = TRUE)----
library(dplyr)
library(CDMConnector)

cohortSet <- readCohortSet(
  path = system.file(package = "TreatmentPatterns", "exampleCohorts")
)

cohorts <- cohortSet %>%
  # Remove 'cohort' and 'json' columns
  select(-"cohort", -"json", -"cohort_name_snakecase") %>%
  mutate(type = c("event", "event", "event", "event", "exit", "event", "event", "target")) %>%
  rename(
    cohortId = "cohort_definition_id",
    cohortName = "cohort_name",
  )

cohorts

## ----eval=require("CDMConnector", quietly = TRUE, warn.conflicts = FALSE, character.only = TRUE)----
library(DBI)
library(duckdb)
con <- dbConnect(
  drv = duckdb(),
  dbdir = eunomiaDir()
)

cdm <- cdmFromCon(
  con = con,
  cdmSchema = "main",
  writeSchema = "main"
)

cdm <- generateCohortSet(
  cdm = cdm,
  cohortSet = cohortSet,
  name = "cohort_table",
  overwrite = TRUE
)

## ----eval=FALSE---------------------------------------------------------------
#  outputEnv <- computePathways(
#    cohorts = cohorts,
#    cohortTableName = "cohort_table",
#    cdm = cdm
#  )

## ----eval=FALSE---------------------------------------------------------------
#  library(DatabaseConnector)
#  
#  connectionDetails <- createConnectionDetails(
#    dbms = "postgres",
#    user = "user",
#    password = "password",
#    server = "some-server.database.net",
#    port = 1337,
#    pathToDriver = "./path/to/jdbc/"
#  )
#  
#  outputEnv <- computePathways(
#    cohorts = cohorts,
#    cohortTableName = "cohort_table",
#    connectionDetails = connectionDetails,
#    cdmSchema = "main",
#    resultSchema = "main",
#    tempEmulationSchema = NULL,
#  )

## ----eval=FALSE---------------------------------------------------------------
#  outputEnv <- computePathways(
#    cohorts = cohorts,
#    cohortTableName = "cohort_table",
#    cdm = cdm,
#    analysisId = 1,
#    description = "My First Treatment Patterns Analysis"
#  )

## ----eval=FALSE---------------------------------------------------------------
#  computePathways(
#    cohorts = cohorts,
#    cohortTableName = "cohort_table",
#    cdm = cdm,
#    minEraDuration = 30,
#    eraCollapseSize = 30,
#    filterTreatments = "First"
#  )

## ----eval=FALSE---------------------------------------------------------------
#  computePathways(
#    cohorts = cohorts,
#    cohortTableName = "cohort_table",
#    cdm = cdm,
#    combinationWindow = 30,
#    minPostCombinationDuration = 30
#  )

## ----eval=FALSE---------------------------------------------------------------
#  outputEnv <- computePathways(
#    cohorts = cohorts,
#    cohortTableName = "cohort_table",
#    cdm = cdm,
#    overlapMethod = "truncate"
#  )

## ----eval=FALSE---------------------------------------------------------------
#  outputEnv <- computePathways(
#    cohorts = cohorts,
#    cohortTableName = "cohort_table",
#    cdm = cdm,
#    overlapMethod = "keep"
#  )

## ----eval=FALSE---------------------------------------------------------------
#  outputEnv <- computePathways(
#    cohorts = cohorts,
#    cohortTableName = "cohort_table",
#    cdm = cdm,
#    splitEventCohorts = c(1, 2),
#    splitTime = 30
#  )

## ----eval=FALSE---------------------------------------------------------------
#  outputEnv <- computePathways(
#    cohorts = cohorts,
#    cohortTableName = "cohort_table",
#    cdm = cdm,
#    startAnchor = "startDate",
#    windowStart = 0,
#    endAnchor = "endDate",
#    windowEnd = 0
#  )

## ----eval=FALSE---------------------------------------------------------------
#  outputEnv <- computePathways(
#    cohorts = cohorts,
#    cohortTableName = "cohort_table",
#    cdm = cdm,
#    startAnchor = "startDate",
#    windowStart = -30,
#    endAnchor = "endDate",
#    windowEnd = 30
#  )

## ----eval=FALSE---------------------------------------------------------------
#  outputEnv <- computePathways(
#    cohorts = cohorts,
#    cohortTableName = "cohort_table",
#    cdm = cdm,
#    startAnchor = "startDate",
#    windowStart = -30,
#    endAnchor = "startDate",
#    windowEnd = 0
#  )

## ----setup_analysis, eval=require("CDMConnector", quietly = TRUE, warn.conflicts = FALSE, character.only = TRUE), warning=FALSE, error=FALSE----
library(TreatmentPatterns)

# Computing pathways
outputEnv <- computePathways(
  cohorts = cohorts,
  cohortTableName = "cohort_table",
  cdm = cdm,
  analysisId = 1,
  description = "My Treatment Pathway analysis",

  # Window
  startAnchor = "startDate",
  windowStart = 0,
  endAnchor = "endDate",
  windowEnd = 0,

  # Acute / Therapy
  splitEventCohorts = NULL,
  splitTime = NULL,

  # Events
  minEraDuration = 7,
  filterTreatments = "All",
  eraCollapseSize = 3,

  # Combinations
  combinationWindow = 7,
  minPostCombinationDuration = 7,
  overlapMethod = "truncate",

  # Pathways
  maxPathLength = 10,
  concatTargets = FALSE
)