Update app.R

app.R

@@ -2034,7 +2034,6 @@ observeEvent(input$upload_hf_btn, {
   hf_token <- Sys.getenv("HF_WRITE_TOKEN")
   repo_id <- "CoastalBaseball/2026MasterDataset"
   
-  # Helper: download existing, merge, dedupe, upload
   upload_to_hf <- function(new_data, filename, label) {
     scrape_status_msg(paste0("Downloading existing ", label, "..."))
     
@@ -2050,7 +2049,10 @@ observeEvent(input$upload_hf_btn, {
       } else { NULL }
     }, error = function(e) { NULL })
     
-    if (!is.null(existing) && nrow(existing) > 0) {
+    existing_rows <- if (!is.null(existing)) nrow(existing) else 0
+    scraped_rows <- nrow(new_data)
+    
+    if (existing_rows > 0) {
       scrape_status_msg(paste0("Merging ", label, "..."))
       combined <- bind_rows(existing, new_data)
       if ("PitchUID" %in% names(combined)) {
@@ -2062,6 +2064,8 @@ observeEvent(input$upload_hf_btn, {
       combined <- new_data
     }
     
+    new_rows <- nrow(combined) - existing_rows
+    
     scrape_status_msg(paste0("Uploading ", label, " (", nrow(combined), " rows)..."))
     
     tmp <- tempfile(fileext = ".parquet")
@@ -2077,7 +2081,7 @@ observeEvent(input$upload_hf_btn, {
         repo_type = "dataset",
         token = hf_token
       )
-      paste0(label, ": ", nrow(combined), " rows uploaded.")
+      paste0(label, ": ", scraped_rows, " rows scraped, ", new_rows, " new rows added (", nrow(combined), " total)")
     }, error = function(e) {
       paste0(label, " upload error: ", e$message)
     })
@@ -2087,11 +2091,9 @@ observeEvent(input$upload_hf_btn, {
     return(result)
   }
   
-  # 1. Upload main dataset
   main_file <- paste0(input$scrape_source, "_2026_master.parquet")
   msg1 <- upload_to_hf(scraped_data(), main_file, "Master Dataset")
   
-  # 2. If PBP, also upload Coastal filtered datasets
   if (input$scrape_source == "pbp") {
     coastal_pitchers <- scraped_data() %>% filter(PitcherTeam == "COA_CHA")
     coastal_hitters  <- scraped_data() %>% filter(BatterTeam == "COA_CHA")