Latest field

DESCRIPTION

@@ -34,7 +34,10 @@ Authors@R: c(
             comment=c(ORCID = "0000-0001-5396-1583")),  
     person("Michael", "Mahoney", role="ctb",
             email = "mjmahoney@usgs.gov",
-            comment=c(ORCID = "0000-0003-2402-304X"))  
+            comment=c(ORCID = "0000-0003-2402-304X")),
+    person("Matthew", "Conlon", role="ctb",
+            email = "mconlon@usgs.gov",
+            comment=c(ORCID = "0000-0001-8266-9610")) 
             )
 Description: Collection of functions to help retrieve U.S. Geological Survey
     and U.S. Environmental Protection Agency water quality and

NAMESPACE

@@ -27,9 +27,6 @@ export(pCodeToName)
 export(parameterCdFile)
 export(parse_WQP)
 export(pcode_to_name)
-export(readNGWMNdata)
-export(readNGWMNlevels)
-export(readNGWMNsites)
 export(readNWISdata)
 export(readNWISdv)
 export(readNWISpCode)
@@ -58,6 +55,7 @@ export(read_waterdata_field_measurements)
 export(read_waterdata_field_meta)
 export(read_waterdata_latest_continuous)
 export(read_waterdata_latest_daily)
+export(read_waterdata_latest_field_measurements)
 export(read_waterdata_metadata)
 export(read_waterdata_monitoring_location)
 export(read_waterdata_parameter_codes)

R/AAA.R

@@ -3,7 +3,9 @@ pkg.env <- new.env()
 .onLoad <- function(libname, pkgname) {
   suppressMessages(setAccess("public"))
   pkg.env$local_sf <- requireNamespace("sf", quietly = TRUE)
-  options("dataRetrieval.nldi_base" = "https://api.water.usgs.gov/nldi/linked-data/")
+  options(
+    "dataRetrieval.nldi_base" = "https://api.water.usgs.gov/nldi/linked-data/"
+  )
   options("dataRetrieval.api_version" = "v0")
   options("dataRetrieval.api_version_stat" = "v0")
   options("dataRetrieval.attach_request" = TRUE)
@@ -21,6 +23,7 @@ pkg.env <- new.env()
     "latest-continuous",
     "field-measurements",
     "latest-daily",
+    "latest-field-measurements",
     "continuous",
     "field-measurements-metadata",
     "combined-metadata",

R/read_waterdata_continuous.R

@@ -8,7 +8,6 @@
 #' for new direct download functions that are expected to be available sometime
 #' in 2026.
 #'
-#' Geometry output is not supported in the continuous data API endpoint.
 #'
 #' @export
 #' @param monitoring_location_id `r get_ogc_params("continuous")$monitoring_location_id`
@@ -35,6 +34,7 @@
 #' @param \dots Not used. Included to help differentiate official Water Data API arguments
 #' from more seldom used, optional dataRetrieval-specific arguments.
 #' @inheritParams check_arguments_non_api
+#' @inheritParams check_arguments_api
 #'
 #' @details
 #' You can also use a vector of length 2 for any time queries (such as time
@@ -120,6 +120,8 @@ read_waterdata_continuous <- function(
   value = NA,
   last_modified = NA_character_,
   time = NA_character_,
+  skipGeometry = TRUE,
+  bbox = NA,
   ...,
   convertType = getOption("dataRetrieval.convertType"),
   limit = getOption("dataRetrieval.limit"),
@@ -132,7 +134,6 @@ read_waterdata_continuous <- function(
   rlang::check_dots_empty()
 
   args <- mget(names(formals()))
-  args[["skipGeometry"]] <- TRUE
 
   return_list <- get_ogc_data(args, output_id, service)
 

R/read_waterdata_latest_field.R

@@ -0,0 +1,81 @@
+#' Get latest USGS field measurement data
+#'
+#' @description `r get_description("latest-field-measurements")`
+#'
+#' @export
+#' @param monitoring_location_id `r get_ogc_params("latest-field-measurements")$monitoring_location_id`
+#' Multiple monitoring_location_ids can be requested as a character vector.
+#' @param parameter_code `r get_ogc_params("latest-field-measurements")$parameter_code`
+#' Multiple parameter_codes can be requested as a character vector.
+#' @param statistic_id `r get_ogc_params("latest-field-measurements")$statistic_id`
+#' Multiple statistic_ids can be requested as a character vector.
+#' @param time `r get_ogc_params("latest-field-measurements")$time`
+#'
+#' See also Details below for more information.
+#' @param value `r get_ogc_params("latest-field-measurements")$value`
+#' @param unit_of_measure `r get_ogc_params("latest-field-measurements")$unit_of_measure`
+#' @param approval_status `r get_ogc_params("latest-field-measurements")$approval_status`
+#' @param last_modified `r get_ogc_params("latest-field-measurements")$last_modified`
+#'
+#' See also Details below for more information.
+#' @param time_series_id `r get_ogc_params("latest-field-measurements")$time_series_id`
+#' Multiple time_series_ids can be requested as a character vector.
+#' @param qualifier `r get_ogc_params("latest-field-measurements")$qualifier`
+#' @param properties A vector of requested columns to be returned from the query.
+#' Available options are:
+#' `r dataRetrieval:::get_properties_for_docs("latest-field-measurements", "latest_field_id")`.
+#' The default (`NA`) will return all columns of the data.
+#'
+#' @inheritParams check_arguments_api
+#' @inheritParams check_arguments_non_api
+#' @inherit read_waterdata_continuous details
+#'
+#' @examplesIf is_dataRetrieval_user()
+#'
+#' \donttest{
+#' site <- "USGS-01435000"
+#'
+#' field_data_sf <- read_waterdata_latest_field_measurements(monitoring_location_id = site)
+#'
+#' dv_data_trim <- read_waterdata_latest_field_measurements(monitoring_location_id = site,
+#'                           properties = c("monitoring_location_id",
+#'                                          "value",
+#'                                          "time"))
+#'
+#' field_data <- read_waterdata_latest_field_measurements(monitoring_location_id = site,
+#'                            skipGeometry = TRUE)
+#'
+#' multi_site <- read_waterdata_latest_field_measurements(monitoring_location_id =  c("USGS-01435000",
+#'                                                                       "USGS-14202650"))
+#'
+#' }
+read_waterdata_latest_field_measurements <- function(
+  monitoring_location_id = NA_character_,
+  parameter_code = NA_character_,
+  statistic_id = NA_character_,
+  properties = NA_character_,
+  time_series_id = NA_character_,
+  approval_status = NA_character_,
+  unit_of_measure = NA_character_,
+  qualifier = NA_character_,
+  value = NA,
+  last_modified = NA_character_,
+  skipGeometry = NA,
+  time = NA_character_,
+  bbox = NA,
+  ...,
+  convertType = getOption("dataRetrieval.convertType"),
+  no_paging = getOption("dataRetrieval.no_paging"),
+  limit = getOption("dataRetrieval.limit"),
+  chunk_size = getOption("dataRetrieval.site_chunk_size_meta"),
+  attach_request = getOption("dataRetrieval.attach_request")
+) {
+  service <- "latest-field-measurements"
+  output_id <- "latest_field_id"
+  rlang::check_dots_empty()
+
+  args <- mget(names(formals()))
+  return_list <- get_ogc_data(args, output_id, service)
+
+  return(return_list)
+}