Format with Air (#629)

* Air setup

* Format `R/`

* Format `inst/`

* Format `tests/`

* Set the `defaultFormatter`

Author: DavisVaughan

.Rbuildignore

@@ -17,3 +17,4 @@
 ^appveyor\.yml$
 ^internal$
 ^CRAN-SUBMISSION$
+^air.toml$

.vscode/settings.json

@@ -0,0 +1,6 @@
+{
+    "[r]": {
+        "editor.formatOnSave": true,
+        "editor.defaultFormatter": "Posit.air-vscode"
+    }
+}

R/bq-auth.R

@@ -7,11 +7,11 @@
 ## The roxygen comments for these functions are mostly generated from data
 ## in this list and template text maintained in gargle.
 gargle_lookup_table <- list(
-  PACKAGE     = "bigrquery",
-  YOUR_STUFF  = "your BigQuery projects",
-  PRODUCT     = "Google BigQuery",
-  API         = "BigQuery API",
-  PREFIX      = "bq"
+  PACKAGE = "bigrquery",
+  YOUR_STUFF = "your BigQuery projects",
+  PRODUCT = "Google BigQuery",
+  API = "BigQuery API",
+  PREFIX = "bq"
 )
 
 #' Authorize bigrquery
@@ -48,15 +48,17 @@ gargle_lookup_table <- list(
 #' }
 #'
 #' @importFrom gargle token_fetch
-bq_auth <- function(email = gargle::gargle_oauth_email(),
-                    path = NULL,
-                    scopes = c(
-                      "https://www.googleapis.com/auth/bigquery",
-                      "https://www.googleapis.com/auth/cloud-platform"
-                    ),
-                    cache = gargle::gargle_oauth_cache(),
-                    use_oob = gargle::gargle_oob_default(),
-                    token = NULL) {
+bq_auth <- function(
+  email = gargle::gargle_oauth_email(),
+  path = NULL,
+  scopes = c(
+    "https://www.googleapis.com/auth/bigquery",
+    "https://www.googleapis.com/auth/cloud-platform"
+  ),
+  cache = gargle::gargle_oauth_cache(),
+  use_oob = gargle::gargle_oob_default(),
+  token = NULL
+) {
   if (!missing(email) && !missing(path)) {
     cli::cli_warn(c(
       "It is very unusual to provide both {.arg email} and \\
@@ -249,8 +251,9 @@ bq_user <- function() {
 #' @export
 bq_oauth_app <- function() {
   lifecycle::deprecate_warn(
-    "1.4.2", "bq_oauth_app()", "bq_oauth_client()"
+    "1.4.2",
+    "bq_oauth_app()",
+    "bq_oauth_client()"
   )
   bq_oauth_client()
 }
-

R/bq-dataset.R

@@ -95,7 +95,13 @@ bq_dataset_delete <- function(x, delete_contents = FALSE) {
 
 #' @export
 #' @rdname api-dataset
-bq_dataset_tables <- function(x, page_size = 50, max_pages = Inf, warn = TRUE, ...) {
+bq_dataset_tables <- function(
+  x,
+  page_size = 50,
+  max_pages = Inf,
+  warn = TRUE,
+  ...
+) {
   x <- as_bq_dataset(x)
   url <- bq_path(x$project, x$dataset, "")
 

R/bq-download.R

@@ -73,16 +73,18 @@
 #' @examplesIf bq_testable()
 #' df <- bq_table_download("publicdata.samples.natality", n_max = 35000, billing = bq_test_project())
 bq_table_download <-
-  function(x,
-           n_max = Inf,
-           page_size = NULL,
-           start_index = 0L,
-           max_connections = 6L,
-           quiet = NA,
-           bigint = c("integer", "integer64", "numeric", "character"),
-           api = c("json", "arrow"),
-           billing = x$project,
-           max_results = deprecated()) {
+  function(
+    x,
+    n_max = Inf,
+    page_size = NULL,
+    start_index = 0L,
+    max_connections = 6L,
+    quiet = NA,
+    bigint = c("integer", "integer64", "numeric", "character"),
+    api = c("json", "arrow"),
+    billing = x$project,
+    max_results = deprecated()
+  ) {
     x <- as_bq_table(x)
     check_number_whole(n_max, min = 0, allow_infinite = TRUE)
     check_number_whole(start_index, min = 0)
@@ -93,13 +95,18 @@ bq_table_download <-
 
     if (lifecycle::is_present(max_results)) {
       lifecycle::deprecate_warn(
-        "1.4.0", "bq_table_download(max_results)", "bq_table_download(n_max)"
+        "1.4.0",
+        "bq_table_download(max_results)",
+        "bq_table_download(n_max)"
       )
       n_max <- max_results
     }
 
     if (api == "arrow") {
-      check_installed("bigrquerystorage", "required to download using arrow API")
+      check_installed(
+        "bigrquerystorage",
+        "required to download using arrow API"
+      )
       if (!missing(page_size)) {
         cli::cli_warn(
           '{.arg page_size} is ignored when {.code api == "arrow"}',
@@ -264,7 +271,6 @@ check_api <- function(api = c("json", "arrow"), error_call = caller_env()) {
 # This function is a modified version of
 # https://github.com/r-dbi/RPostgres/blob/master/R/PqResult.R
 parse_postprocess <- function(df, bigint) {
-
   df <- col_apply(
     df,
     function(x) identical(attr(x, "bq_type"), "DATE"),
@@ -337,15 +343,17 @@ set_row_params <- function(nrow, n_max = Inf, start_index = 0L) {
   list(n_max = n_max, start_index = start_index)
 }
 
-bq_download_plan <- function(n_max,
-                             chunk_size = NULL,
-                             n_chunks = NULL,
-                             start_index = 0) {
+bq_download_plan <- function(
+  n_max,
+  chunk_size = NULL,
+  n_chunks = NULL,
+  start_index = 0
+) {
   params <- set_chunk_params(n_max, chunk_size, n_chunks)
   list(
-    n_max      = n_max,
+    n_max = n_max,
     chunk_size = params$chunk_size,
-    n_chunks   = params$n_chunks,
+    n_chunks = params$n_chunks,
     dat = set_chunk_plan(
       n_max,
       params$chunk_size,
@@ -373,7 +381,10 @@ set_chunk_plan <- function(n_max, chunk_size, n_chunks, start_index = 0) {
     chunk_begin,
     chunk_rows,
     path = sort(
-      tempfile(rep_len("bq-download-", length.out = n_chunks), fileext = ".json")
+      tempfile(
+        rep_len("bq-download-", length.out = n_chunks),
+        fileext = ".json"
+      )
     )
   )
 }
@@ -390,7 +401,10 @@ bq_download_chunk_handle <- function(x, begin = 0L, max_results = 1e4) {
     maxResults = format(max_results, scientific = FALSE)
   )
 
-  url <- paste0(base_url, bq_path(x$project, dataset = x$dataset, table = x$table, data = ""))
+  url <- paste0(
+    base_url,
+    bq_path(x$project, dataset = x$dataset, table = x$table, data = "")
+  )
   url <- httr::modify_url(url, query = prepare_bq_query(query))
 
   if (bq_has_token()) {

R/bq-field.R

@@ -30,7 +30,13 @@
 #'
 #' # as_bq_fields() can also take a data frame
 #' as_bq_fields(mtcars)
-bq_field <- function(name, type, mode = "NULLABLE", fields = list(), description = NULL) {
+bq_field <- function(
+  name,
+  type,
+  mode = "NULLABLE",
+  fields = list(),
+  description = NULL
+) {
   check_string(name)
   check_string(type)
   check_string(mode)

R/bq-job.R

@@ -71,10 +71,12 @@ bq_job_show_statistics <- function(x) {
 #' @export
 #' @name api-job
 #' @inheritParams rlang::args_error_context
-bq_job_wait <- function(x,
-                        quiet = getOption("bigrquery.quiet"),
-                        pause = 0.5,
-                        call = caller_env()) {
+bq_job_wait <- function(
+  x,
+  quiet = getOption("bigrquery.quiet"),
+  pause = 0.5,
+  call = caller_env()
+) {
   x <- as_bq_job(x)
   quiet <- check_quiet(quiet)
   check_number_decimal(pause)
@@ -102,15 +104,16 @@ bq_job_wait <- function(x,
   }
   if (!quiet) cli::cli_progress_done()
 
-
   errors <- status$errors
   if (length(errors) > 0) {
     if (length(errors) > 1) {
       # First error says to look in errors[]
       errors <- errors[-1]
     }
 
-    bullets <- map_chr(errors, function(x) paste0(x$message, " [", x$reason, "]"))
+    bullets <- map_chr(errors, function(x) {
+      paste0(x$message, " [", x$reason, "]")
+    })
     bullets <- set_names(bullets, "x")
     cli::cli_abort(c("Job {x} failed", bullets), call = call)
   }