Support duckspatial native GeoArrow streams

R/addSource.R

@@ -3,7 +3,7 @@
 #' @param map the [mapgl::maplibre()] or [mapgl::mapboxgl()] map to add the
 #' data source to.
 #' @param id a unique `ID` for the data source.
-#' @param data a `sf`, `wk`, `geos` or `SpatVector` object.
+#' @param data a `sf`, `wk`, `geos`, `SpatVector` or `duckspatial_df` object.
 #' @param file a valid local file path to a `geoarrow` or `geoparquet` file to be
 #' added to the map. Ignored if `data` is supplied.
 #' @param url a URL to a remotely hosted `geoarrow` or `geoparquet` file to be
@@ -34,6 +34,23 @@
 #' ## <link id="pt-geoarrowWidget-attachment" rel="attachment" href="lib/pt-0.0.1/pt.arrow"/>
 #' m
 #'
+#' @tests tinytest
+#'
+#' stream_method = function(x, ..., native = FALSE) native
+#' registerS3method(
+#'   "as_nanoarrow_array_stream"
+#'   , "deckglgeoarrow_test_duckspatial_df"
+#'   , stream_method
+#'   , envir = asNamespace("nanoarrow")
+#' )
+#'
+#' data = structure(
+#'   list()
+#'   , class = c("deckglgeoarrow_test_duckspatial_df", "duckspatial_df")
+#' )
+#'
+#' expect_identical(deckglgeoarrow:::parseGeoarrow(data), TRUE)
+#'
 #' @export
 #'
 addSource = function(

R/internals.R

@@ -15,6 +15,10 @@ parseGeoarrow = function(
     return(data)
   }
 
+  if (inherits(data, "duckspatial_df")) {
+    return(nanoarrow::as_nanoarrow_array_stream(data, native = TRUE))
+  }
+
   if (inherits(data, "SpatVector")) {
     stopifnot(
       "need package 'terra' to handle 'SpatVector'" =

inst/tinytest/test-addSource.R

@@ -0,0 +1,19 @@
+# File created by roxut; edit the function definition file, not this file
+
+# Test found in addSource.R:37 (file:line)
+
+
+stream_method = function(x, ..., native = FALSE) native
+registerS3method(
+  "as_nanoarrow_array_stream"
+  , "deckglgeoarrow_test_duckspatial_df"
+  , stream_method
+  , envir = asNamespace("nanoarrow")
+)
+
+data = structure(
+  list()
+  , class = c("deckglgeoarrow_test_duckspatial_df", "duckspatial_df")
+)
+
+expect_identical(deckglgeoarrow:::parseGeoarrow(data), TRUE)