fixed issue with malformed json and url in air_insert funciton

.Rbuildignore

@@ -6,3 +6,5 @@
 ^IMG$
 ^readme_cache$
 ^\.travis\.yml$
+^doc$
+^Meta$

.github/ISSUE_TEMPLATE/blank-issue.md

@@ -0,0 +1,10 @@
+---
+name: Blank Issue
+about: Use this issue template for issues that are not bugs or enhancements
+title: ''
+labels: ''
+assignees: ''
+
+---
+
+

.github/ISSUE_TEMPLATE/bug_report.md

@@ -0,0 +1,27 @@
+---
+name: Bug report
+about: Create a report to help us improve
+title: ''
+labels: bug
+assignees: ''
+
+---
+
+**Describe the bug**
+A clear and concise description of what the bug is.
+
+**To Reproduce**
+Code to reproduce the behavior:
+
+**Expected behavior**
+A clear and concise description of what you expected to happen.
+
+
+**Session info (please complete the following information):**
+
+```
+sessionInfo()
+```
+
+**Additional context**
+Add any other context about the problem here.

.github/ISSUE_TEMPLATE/feature_request.md

@@ -0,0 +1,17 @@
+---
+name: Feature request
+about: Suggest an idea for this project
+title: ''
+labels: enhancement
+assignees: ''
+
+---
+
+**Describe why this feature should be added**
+A clear and concise description of what the need is. 
+
+**Describe the behavior you expect**
+A clear and concise description of what you want to happen.
+
+**Additional context**
+Add any other context or screenshots about the feature request here.

.gitignore

@@ -2,3 +2,7 @@
 .Rhistory
 .RData
 readme.html
+testing_script.R
+.env
+/doc/
+/Meta/

DESCRIPTION

@@ -1,17 +1,37 @@
 Package: airtabler
 Type: Package
 Title: Interface to the Airtable API
-Version: 0.1.6
-Date: 2017-09-17
+Version: 0.2.16
+Date: 2023-08-17
 Author: Darko Bergant
-Maintainer: Darko Bergant <darko.bergant@gmail.com>
-Description: Provides access to the Airtable (airtable.com) API.
+Maintainer: Collin Schwantes <schwantes@ecohealthalliance.org>
+Description: Fork from Darko Bergant's package. Provides access to the Airtable (airtable.com) API.
 Depends:
     R (>= 3.2.0)
 License: MIT + file LICENSE
-URL: https://github.com/bergant/airtabler
+URL: https://github.com/ecohealthalliance/airtabler
 LazyData: TRUE
+Encoding: UTF-8
 Imports:
+    glue,
+    dplyr,
     httr,
-    jsonlite
-RoxygenNote: 6.0.1
+    jsonlite,
+    readxl,
+    curl,
+    purrr,
+    utils,
+    snakecase,
+    tidyselect,
+    rlang,
+    stringr,
+    tibble,
+    deposits,
+    assertthat
+Remotes: 
+    ropenscilabs/deposits
+RoxygenNote: 7.2.3
+Suggests: 
+    knitr,
+    rmarkdown
+VignetteBuilder: knitr

NAMESPACE

@@ -1,11 +1,51 @@
 # Generated by roxygen2: do not edit by hand
 
 S3method(print,airtable.base)
+export(air_create_description_table)
+export(air_create_field)
+export(air_create_metadata_table)
+export(air_create_table)
 export(air_delete)
+export(air_download_attachments)
+export(air_dump)
+export(air_dump_to_csv)
+export(air_dump_to_json)
+export(air_expand_csv_arrays)
+export(air_fields_df_template)
+export(air_fields_list_from_template)
+export(air_generate_base_description)
+export(air_generate_metadata_from_api)
+export(air_generate_metadata_from_tables)
 export(air_get)
+export(air_get_attachments)
+export(air_get_base_description_from_table)
+export(air_get_base_id_from_url)
+export(air_get_id_from_url)
+export(air_get_json)
+export(air_get_metadata_from_table)
+export(air_get_record_id_from_url)
+export(air_get_schema)
+export(air_get_table_id_from_url)
+export(air_get_view_id_from_url)
 export(air_insert)
+export(air_insert_data_frame)
+export(air_list_bases)
+export(air_make_json)
+export(air_make_request)
+export(air_post)
 export(air_select)
+export(air_table_template)
 export(air_update)
+export(air_update_data_frame)
+export(air_update_description_table)
+export(air_update_field)
+export(air_update_metadata_table)
 export(airtable)
+export(fetch_all)
+export(fetch_all_json)
+export(flatten_col_to_chr)
 export(get_offset)
+export(get_unique_field_values)
 export(multiple)
+export(read_excel_url)
+export(set_diff)

R/air_download_attachments.R

@@ -0,0 +1,141 @@
+#' Download Airtable file attachments
+#'
+#' Download an attachment stored in air tables. Returns original dataframe
+#' with an additional field called attachment_file_paths. The attachment_file_paths
+#' field is of class list so it can handle multiple attachments per record. File
+#' paths are prepended with record ids so that all file names are unique.
+#'
+#' @param x Data frame. Output from air_get or fetch_all.
+#' @param field String. Name of field with file attachments in base
+#' @param dir_name String. Where should files be downloaded to?
+#' Will create the folder if it does not exist. Folders created are recursively.
+#' @param ... reserved for additional arguments.
+#' @param include_attachment_id Logical. Should you include the airtable attachment
+#' ID to guarantee all file names are unique? Default is true.
+#'
+#' @return Returns x with an additional field called attachment_file_paths
+#' @export air_download_attachments
+#'
+#' @examples
+#' \dontrun{
+#'
+#' base <- "appXXXXXXXXX"
+#' table_name <- "Table With Attachments"
+#'
+#' table_original  <- air_get(base,table_name)
+#'
+#' table_with_file_paths <- air_download_attachments(x = table_with_attachments,
+#'                         field = "attachment_field",
+#'                         dir_name = "downloads")
+#'
+#' table_with_file_paths$attachment_file_paths
+#'
+#' }
+#'
+air_download_attachments <- function(x, field, dir_name = "downloads",include_attachment_id = TRUE,...){
+  #browser()
+
+  if(!is.data.frame(x)){
+    rlang::abort("x is not a dataframe")
+  }
+
+  if(!field %in% names(x)){
+    error_msg <- glue::glue("{field} not found in names(x). Check the name of the column
+                            used to store attachments in airtable")
+
+    rlang::abort(error_msg)
+  }
+
+  if(!is.list(x[,field])){
+    error_msg <- glue::glue("{field} is not of class list. Verify the name of
+    the column used to store attachments in airtable")
+    rlang::warn(error_msg)
+
+    field_file_paths <- sprintf("%s_file_paths",field)
+
+    x$file_path <- NA
+
+    # using dynamic names in case a base has multiple file attachment
+    # columns
+    x <- dplyr::rename(x,{{field_file_paths}} := file_path)
+    return(x)
+  }
+
+  ### subset to necessary records ----
+
+  # get files
+  xfield <- purrr::pluck(x,field)
+
+  ### get files ----
+    dir.create(path = dir_name,recursive = TRUE)
+
+    xlist <- purrr::map(xfield, function(x){
+
+      if(is.null(x$url)){
+        ID <- x$id
+        warning(sprintf("Record ID %s is null",ID))
+        return(NULL)
+      }
+
+      # prepending attachment id in case the file naming convention
+      # of the user does not preclude duplicate file names for files
+      # with different contents - e.g. original file generation was
+      # structured like sample_1234/fasta.file sample_1235/fasta.file
+
+      filename_dest <- x$filename
+
+      if(include_attachment_id){
+        filename_dest <- sprintf("%s_%s", x$id,filename_dest)
+      } else {
+        message("include_attachement_id = FALSE. If file names are repeated,
+        only the first file with that name will be downloaded.")
+      }
+
+      dest <- sprintf("%s/%s", dir_name,filename_dest)
+
+      # sometimes the same file is attached multiple times
+      # if the file is already downloaded, don't add it again
+      # each attachment gets a unique id, so if the file changes,
+      # that id changes
+
+
+      if(all(file.exists(dest))){
+        not_downloaded_message <- glue::glue("\nFile already exists, not downloaded\n{dest}\n.")
+        print(not_downloaded_message)
+        return(dest)
+      }
+
+      # wrap in a map so that it works on linux systems where urls must explicitly
+      # be a length one character vector
+      purrr::map2(x$url, dest, function(url_item, dest_item){
+        if(is.character(url_item)& length(url_item )==1){
+        a <- utils::download.file(url = url_item,destfile = dest_item)
+        print(a)
+        } else {
+          print("url item not character or length greater than one")
+          print(url_item)
+        }
+      })
+
+
+      return(dest)
+    })
+
+    down_load_message <- glue::glue("Files downloaded here {dir_name}")
+
+    message(down_load_message)
+
+    field_file_paths <- sprintf("%s_file_paths",field)
+
+    x$file_path <- xlist
+
+    # using dynamic names in case a base has multiple file attachment
+    # columns
+    x <- dplyr::rename(x,{{field_file_paths}} := file_path)
+    return(x)
+
+}
+
+
+
+