R/utils_update_insert_delete.R

In asiripanich/emdash: e-mission dashboard built with the Shiny framework

#' Inserts a row as a document into the specified collection
#' @param cons connection to mongodb
#' @param collection_name the collection to look in
#' @param df_row the dataframe row to insert
db_insert <- function(cons, collection_name, df_row) {
  cons[[collection_name]]$insert(df_row)
}

#' Updates a document with the row 'df_row'
#' @param cons connection to mongodb
#' @param collection_name the collection to look in
#' @param df_row the dataframe row to update with
db_update <- function(cons, collection_name, df_row) {
  # The format is seen below:
  # db$collection$update('{"name":"jerry"}', '{"$set":{"age": 31}}')
  # Example user_id_string: {"user_id": "Extra_User", "bikeLabel": "WestTower"}

  user_id_string <- paste0('{\"user_id\": \"', df_row$user_id, '\", ', '\"bikeLabel\": \"', df_row$bikeLabel, '\"}') # %>% cat
  new_status <- isTRUE(df_row$status %>% as.character() %>% as.logical())
  logic_string <- ifelse(new_status, "true", "false") # if status is TRUE, output 'true'

  set_string <- paste0('{\"$set":{\"status\":', logic_string, "}}") # %>% cat

  cons[[collection_name]]$update(user_id_string, set_string)
}


#' Deletes a document from Checkinout corresponding to df_row
#' @param cons connection to mongodb
#' @param collection_name the collection to look in
#' @param df_row the dataframe row to telling you which document to delete
db_delete <- function(cons, collection_name, df_row) {
  object_id_string <- sprintf('{\"_id\": {\"$oid\": \"%s\"}}', df_row$`_id`)
  cons[[collection_name]]$remove(object_id_string, just_one = TRUE)
}

# cons <- connect_stage_collections(url = getOption('emdash.mongo_url'))
# t <- cons$Checkinout$find()
## Example
# Setting up extra entries to delete or edit.
# for (j in 1:60){
#   user_id <- paste(j)
#   status <- FALSE
#   bikeLabel <- ifelse(j %% 2, 'WestTower', 'EastTower')
#   ts <- Sys.time() %>% as.POSIXct() %>% as.numeric() + j
#   new_bike <- data.frame(user_id,status,bikeLabel,ts)
#   db_insert(cons,"Checkinout",new_bike)
# }

# user_id <- 'Extra_User'
# status <- T
# bikeLabel <- 'WestTower'
# updated_bike <- data.frame(user_id,status,bikeLabel)

# cons$Checkinout$update('{"user_id": "Extra_User"}','{"$set":{"status": false}}')
#
# db_update(cons,"Checkinout",updated_bike)

# as.POSIXct(x, tz = "", ...)