waterbody outlet pois for #153

workspace/00_get_data.Rmd

@@ -26,7 +26,8 @@ if(!dir.exists("data")) {dir.create("data")}
 if(!dir.exists("bin")) {dir.create("bin")}
 
 data_dir <- "data"
-out_list <- list("data_dir" = data_dir)
+out_list <- list("data_dir" = data_dir,
+                 nhdplushr_dir = file.path(data_dir, "nhdplushr"))
 out_file <- file.path("cache", "data_paths.json")
 
 sevenz <- "7z"

workspace/_targets/02_POI_creation_targets.R

 library(targets)
 
-tar_option_set(packages = c("dplyr", "sf", "hyfabric", "hydroloom"),
+tar_option_set(packages = c("dplyr", "sf", "hyfabric", "hydroloom", "nhdplusTools"),
                memory = "transient", garbage_collection = TRUE, error = "null", 
                storage = "worker", retrieval = "worker", deployment = "main")
 
@@ -63,5 +63,22 @@ list(tar_target(data_paths_file, "cache/data_paths.json", format = "file"),
                                                   hilarri_data, 
                                                   resops_pois$wb_pois,
                                                   flowline, "hilarri"),
-                pattern = map(resops_pois, flowline), deployment = "worker")
+                pattern = map(resops_pois, flowline), deployment = "worker"),
+     # TODO: work on cleaning up parameters of this function
+     tar_target(wb_outlet_pois, create_wb_outlet_pois(hilarri_pois$tmp_POIs,
+                                                      filter(combined_waterbodies, layer == "NHDArea"),
+                                                      hilarri_pois$wb_pois,
+                                                      resops_pois$wb_resops,
+                                                      flowline,
+                                                      gage_pois$events,
+                                                      nav_gpkg,
+                                                      data_paths,
+                                                      proj_crs,
+                                                      read_sf(gage_info_gpkg_file, "Gages"),
+                                                      "wb_id"),
+                pattern = map(hilarri_pois, resops_pois, gage_pois,flowline, nav_gpkg), 
+                deployment = "worker"),
+     tar_target(write_wb_flowline_mod, write_sf(wb_outlet_pois$updated_flowline, 
+                                                nav_gpkg, nhd_flowline),
+                pattern = map(wb_outlet_pois, nav_gpkg))
      )
\ No newline at end of file

workspace/cache/data_paths.json

 {
   "data_dir": "data",
+  "nhdplushr_dir": "data/nhdplushr",
   "hu12_points_path": "data/102020wbd_outlets.gpkg",
   "SWIM_points_path": "data/SWIM_gage_loc",
   "SWIM_dbf": "data/SWIMGFinfo.dbf",