Add tests for delayed discharges extract (#760)

* Add tests for delayed discharges extract

* Style code

* Change calculation to TRUE/FALSE

Co-authored-by: James McMahon <[email protected]>

* Remove TODO and add DD tests to targets pipeline

---------

Co-authored-by: Jennit07 <[email protected]>
Co-authored-by: James McMahon <[email protected]>

NAMESPACE

@@ -115,6 +115,7 @@ export(process_tests_ae)
 export(process_tests_alarms_telecare)
 export(process_tests_care_home)
 export(process_tests_cmh)
+export(process_tests_delayed_discharges)
 export(process_tests_district_nursing)
 export(process_tests_episode_file)
 export(process_tests_gp_ooh)

R/process_tests_delayed_discharges.R

@@ -0,0 +1,50 @@
+#' Process Delayed Discharges tests
+#'
+#' @description Takes the processed Delayed Discharges extract and produces
+#' a test comparison with the previous data. This is written to disk as a CSV.
+#'
+#' @param data a [tibble][tibble::tibble-package] of the processed data extract.
+#' @param year the financial year of the extract in the format '1718'.
+#'
+#' @return a [tibble][tibble::tibble-package] containing a test comparison.
+#'
+#' @export
+process_tests_delayed_discharges <- function(data, year) {
+  old_data <- get_existing_data_for_tests(data)
+
+  comparison <- produce_test_comparison(
+    old_data = produce_source_dd_tests(old_data),
+    new_data = produce_source_dd_tests(data)
+  ) %>%
+    write_tests_xlsx(sheet_name = "DD", year)
+
+  return(comparison)
+}
+
+#' Delayed Discharges extract tests
+#'
+#' @description Produce tests for the delayed discharges extract.
+#'
+#' @param data new or old data for testing summary flags
+#' (data is from [get_source_extract_path()])
+#'
+#' @return a dataframe with a count of each flag
+#' from [calculate_measures()]
+#'
+#' @family extract test functions
+#' for creating test flags
+#' @seealso calculate_measures
+produce_source_dd_tests <- function(data) {
+  test_flags <- data %>%
+    dplyr::mutate(
+      n_delay_episodes = 1L,
+      code9_episodes = .data$primary_delay_reason == "9"
+    ) %>%
+    create_hb_test_flags(.data$hbtreatcode) %>%
+    # keep variables for comparison
+    dplyr::select(c("n_delay_episodes":dplyr::last_col())) %>%
+    # use function to sum new test flags
+    calculate_measures(measure = "sum")
+
+  return(test_flags)
+}

_targets.R

@@ -310,12 +310,18 @@ list(
         year
       )
     ),
-    # TODO add tests for the Delayed Discharges extract
     tar_target(source_dd_extract, process_extract_delayed_discharges(
       dd_data,
       year,
       write_to_disk = write_to_disk
     )),
+    tar_target(
+      tests_source_dd_extract,
+      process_tests_delayed_discharges(
+        source_dd_extract,
+        year
+      )
+    ),
     tar_target(source_dn_extract, process_extract_district_nursing(
       dn_data,
       year,