From 828973121de27d237c99cfa45cd96269b49141ba Mon Sep 17 00:00:00 2001
From: dylanbenzi <dylanbenzi@gmail.com>
Date: Mon, 14 Jul 2025 15:42:57 -0400
Subject: [PATCH] update conus storm landfalls query

---
 dashboard.Rmd |  6 ++++--
 queries.R     | 10 ++++++++++
 2 files changed, 14 insertions(+), 2 deletions(-)

diff --git a/dashboard.Rmd b/dashboard.Rmd
index a4568d4..3c063b1 100644
--- a/dashboard.Rmd
+++ b/dashboard.Rmd
@@ -106,6 +106,8 @@ latest_normalized_losses <- get_latest_aggregate_losses()
 
 all_storm_tracks <- get_all_hurdat_tracks()
 
+all_conus_landfalls <- get_all_conus_landfalls()
+
 all_storm_landfalls <- all_storm_tracks %>% 
   filter(record_identifier == "L")
 
@@ -787,7 +789,7 @@ output$all_storms_map <- renderLeaflet({
     #color = "blue"
   #) %>% 
   addCircleMarkers(
-    data = all_storm_landfalls,
+    data = all_conus_landfalls,
     lng = ~lon,
     lat = ~lat,
     radius = 2,
@@ -798,7 +800,7 @@ output$all_storms_map <- renderLeaflet({
     fillOpacity = 0.5
   ) %>% 
   addCircles(
-    data = all_storm_landfalls,
+    data = all_conus_landfalls,
     lng = ~lon,
     lat = ~lat,
     radius = ~rmw_meters,
diff --git a/queries.R b/queries.R
index 474ea0e..c48e043 100644
--- a/queries.R
+++ b/queries.R
@@ -51,6 +51,7 @@ view.all_loss_landfalls <- tbl(con, "all_loss_landfalls")
 view.yearly_normalized_losses <- tbl(con, "yearly_normalized_losses")
 view.simplified_county_geom <- tbl(con, "simplified_county_geom")
 view.all_loss_storms_tracks <- tbl(con, "all_loss_storms_tracks")
+view.all_conus_landfalls <- tbl(con, "all_conus_landfalls")
 
 #qry <- econ.storm_base_loss %>% 
 #  left_join(view.hurdat_track, by = c("storm_basin", "storm_year", "storm_name"))
@@ -181,6 +182,15 @@ get_hurdat_landfalls <- function(storm) {
   return(result)
 }
 
+# returns all tracked storm conus landfalls
+get_all_conus_landfalls <- function() {
+  query <- view.all_conus_landfalls
+  
+  result <- query %>% collect()
+  
+  return(result)
+}
+
 # returns all storm tracks from HURDAT
 get_all_hurdat_tracks <- function() {
   query <- view.all_loss_storms_tracks