Update app.R

app.R

@@ -1999,29 +1999,19 @@ observeEvent(input$upload_hf_btn, {
   arrow::write_parquet(combined, tmp)
   
 result <- tryCatch({
-    header_file <- tempfile(fileext = ".json")
-    cat(sprintf(
-      '{"summary":"Update %s","operations":[{"key":"file0","path_in_repo":"%s"}]}',
-      filename, filename
-    ), file = header_file)
-    
-    resp <- system2("/usr/bin/curl", args = c(
-      "-s",
-      "-X", "POST",
-      "-H", paste0("Authorization: Bearer ", hf_token),
-      "-F", paste0("header=@", header_file, ";type=application/json"),
-      "-F", paste0("file0=@", tmp, ";type=application/octet-stream"),
-      paste0("https://huggingface.co/api/datasets/", repo_id, "/commit/main")
-    ), stdout = TRUE, stderr = TRUE)
-    
-    file.remove(header_file)
-    resp_text <- paste(resp, collapse = "\n")
-    
-    if (grepl("commitOid", resp_text)) {
-      paste0("Done! ", nrow(combined), " total rows in dataset.")
-    } else {
-      paste0("Upload response: ", resp_text)
-    }
+    library(reticulate)
+    hf <- import("huggingface_hub")
+    api <- hf$HfApi()
+    api$token <- hf_token
+    
+    api$upload_file(
+      path_or_fileobj = tmp,
+      path_in_repo = filename,
+      repo_id = repo_id,
+      repo_type = "dataset"
+    )
+    
+    paste0("Done! ", nrow(combined), " total rows in dataset.")
   }, error = function(e) {
     paste("Upload error:", e$message)
   })