From 4ec483a1f221f0ce317154899678b0824b4fb25f Mon Sep 17 00:00:00 2001
From: pat-s <patrick.schratz@gmail.com>
Date: Fri, 30 Aug 2024 09:40:19 +0200
Subject: [PATCH] smarter update processing

---
 R/process_cran_updates.R | 21 ++++++++++++++-------
 1 file changed, 14 insertions(+), 7 deletions(-)

diff --git a/R/process_cran_updates.R b/R/process_cran_updates.R
index c13ad00..916ac38 100644
--- a/R/process_cran_updates.R
+++ b/R/process_cran_updates.R
@@ -5,6 +5,10 @@
 #'
 #' @importFrom dplyr bind_rows
 #' @importFrom purrr walk2
+#' @examples
+#' process_cran_updates(interval = lubridate::interval(lubridate::today() - 2, lubridate::today() - 20),
+#'   process_updated = FALSE, process_new = FALSE)
+#'
 #' @export
 process_cran_updates <- function(
     package_name,
@@ -12,14 +16,16 @@ process_cran_updates <- function(
     platform,
     local_clone_dir,
     interval = lubridate::today(),
-    prune = TRUE,
     build_for_minor = FALSE,
     codename = NULL,
     r_minor_version = NULL,
     local_build_root = ".",
     endpoint = "https://s3.eu-central-003.backblazeb2.com",
     region = "eu-central-003",
-    bucket = "devxy-arm64-r-binaries") {
+    bucket = "devxy-arm64-r-binaries",
+    process_updated = TRUE,
+    process_new = TRUE,
+    process_removed = TRUE) {
   # Get list of updated and new packages for a specific day
   updated_pkgs <- get_updated_cran_packages(interval)
   new_pkgs <- get_new_cran_packages(interval)
@@ -31,13 +37,14 @@ process_cran_updates <- function(
 
   all_pkgs <- dplyr::bind_rows(updated_pkgs, new_pkgs)
 
-  purrr::walk2(all_pkgs$name, all_pkgs$version, ~ {
-    build_binary_package(.x, .y, platform = platform)
-    archive_package(.x)
+  if (any(c(process_updated, process_new))) {
+    purrr::walk2(all_pkgs$name, all_pkgs$version, ~ {
+      build_binary_package(.x, .y, platform = platform)
+      archive_package(.x)
+    })
   }
-  )
 
-  if (prune) {
+  if (process_removed) {
     removed_pkgs <- get_removed_cran_packages(interval)
     cli::cli_alert_success("{.fun process_cran_updates}: Removed packages:")
     print(removed_pkgs)