Factor out standard save or exit

R/gathertweet_actions.R

     saveRDS(tweets, file)
   } else {
     tweets <- dplyr::bind_rows(tweets)
-
-    if (nrow(tweets) == 0) {
-      log_info("No new tweets.")
-      exit()
-    }
-
-    tweets <- tweets[!duplicated(tweets$status_id), ]
-    tweets <- tweets[order(tweets$status_id), ]
-
-    log_info("Gathered {nrow(tweets)} tweets")
-    tweets <- save_tweets(tweets, file)
-
-    log_info("Total of {nrow(tweets)} tweets in {file}")
+    save_tweets_or_exit(tweets, file)
   }
 
   tweets
     include_rts = isTRUE(include_rts)
   )
 
-  if (!nrow(tweets)) {
-    log_fatal("No new tweets.")
-  }
-
-  tweets <- tweets[!duplicated(tweets$status_id), ]
-  tweets <- tweets[order(tweets$status_id), ]
-
-  log_info("Gathered {nrow(tweets)} tweets from {length(users)} users")
-  tweets <- save_tweets(tweets, file)
-
-  log_info("Total of {nrow(tweets)} tweets in {file}")
+  save_tweets_or_exit(tweets, file)
   tweets
 }
 
     token       = token
   )
 
-  if (!nrow(tweets)) {
-    log_fatal("No new tweets.")
-  }
-
-  tweets <- tweets[!duplicated(tweets$status_id), ]
-  tweets <- tweets[order(tweets$status_id), ]
-
-  log_info("Gathered {nrow(tweets)} tweets from {length(users)} users")
-  tweets <- save_tweets(tweets, file)
-
-  log_info("Total of {nrow(tweets)} tweets in {file}")
+  save_tweets_or_exit(tweets, file)
   tweets
 }
 
   if (!is.null(max_id)) log_info("Tweets up to {max_id}")
   since_id
 }
+
+
+save_tweets_or_exit <- function(tweets, file) {
+  if (nrow(tweets) == 0) {
+    log_info("---- No new tweets. ----")
+    exit()
+  }
+
+  tweets <- tweets[!duplicated(tweets$status_id), ]
+  tweets <- tweets[order(tweets$status_id), ]
+
+  log_info("Gathered {nrow(tweets)} tweets")
+  tweets <- save_tweets(tweets, file)
+
+  log_info("Total of {nrow(tweets)} tweets in {file}")
+}