metabox: metabox

#'Set database location
getDbInfo <- function(){
  if(length(Sys.glob(file.path(Sys.getenv("HOME"),"*","database.R")))>0){#for mac and linux = /Users/myname/subfolder/database.R
    source(Sys.glob(file.path(Sys.getenv("HOME"),"*","database.R")))
  }else if(length(Sys.glob(file.path(Sys.getenv("HOME"),"database.R")))>0){#for windows = = Drive:/Users/myname/Documents/database.R
    source(Sys.glob(file.path(Sys.getenv("HOME"),"database.R")))
  }else{
    assign("database.location", nld, envir = .GlobalEnv)
  }
}
#'Execute query
#'@description execute query using the function \code{\link{curlPerform}} from \pkg{RCurl} for sending HTTP request to the database.
#'@return list or data frame. Return no data if found nothing.
#'@author Kwanjeera W \email{kwanich@@ucdavis.edu}
#'@references The RCurl package \url{http://www.inside-r.org/packages/cran/RCurl}
#'@seealso \code{\link{curlPerform}}, \url{http://neo4j.com/docs/milestone/introduction.html}
#'@examples
#'# Query by neo4j id
#'#querystring <- "MATCH (n) WHERE ID(n) = 0 RETURN n"
#'#result <- curlRequest.TRANSACTION(querystring)
#'# Query by url
#'#url <- "http://localhost:7474/db/data/node/306/relationships/out"
#'#result <- curlRequest.URL(url)
#legacy HTTP endpoint
curlRequest <- function(cypher){
  h = RCurl::basicTextGatherer()
  tryCatch({
    getDbInfo()
    url = paste0(database.location,"cypher")
    #url = paste0("http://localhost:7474/db/data/","cypher")
    RCurl::curlPerform(url=url,
                       userpwd = neu,
                       httpheader = c(Authorization = paste("Basic",RCurl::base64(neu))),
                       postfields=paste('query',RCurl::curlEscape(cypher), sep='='),
                       writefunction = h$update,
                       verbose = FALSE
    )
    result <- jsonlite::fromJSON(h$value())$data
  }, error = function(err) {
    message(err)
    result <- list() #return empty if not found
  })
}
#transaction HTTP endpoint return graph format
#note: execute multiple statements available in neo4j 2.3.3
curlRequest.TRANSACTION <- function(cypher){
  h = RCurl::basicTextGatherer()
  tryCatch({
    getDbInfo()
    url = paste0(database.location,"transaction/commit")
    #url = paste0("http://localhost:7474/db/data/","transaction/commit")
    body = paste0("{\"statements\":[{\"statement\":\"",cypher,"\",\"resultDataContents\":[\"graph\"]}]}")
    RCurl::curlPerform(url=url,
                       userpwd = neu,
                       httpheader = c(Authorization = paste("Basic",RCurl::base64(neu)), 'Content-Type' = "application/json"),
                       postfields=body,
                       writefunction = h$update,
                       verbose = FALSE
    )
    result <- jsonlite::fromJSON(h$value(), simplifyDataFrame=FALSE)$results[[1]]$data
  }, error = function(err) {
    message(err)
    result <- list() #return empty if not found
  })
}
#transaction HTTP endpoint return row format
#note: execute multiple statements available in neo4j 2.3.3
curlRequest.TRANSACTION.row <- function(cypher){
  h = RCurl::basicTextGatherer()
  tryCatch({
    getDbInfo()
    url = paste0(database.location,"transaction/commit")
    #url = paste0("http://localhost:7474/db/data/","transaction/commit")
    body = paste0("{\"statements\":[{\"statement\":\"",cypher,"\",\"resultDataContents\":[\"row\"]}]}")
    RCurl::curlPerform(url=url,
                       userpwd = neu,
                       httpheader = c(Authorization = paste("Basic",RCurl::base64(neu)), 'Content-Type' = "application/json"),
                       postfields=body,
                       writefunction = h$update,
                       verbose = FALSE
    )
    result <- jsonlite::fromJSON(h$value(), simplifyDataFrame=FALSE)$results[[1]]$data
  }, error = function(err) {
    message(err)
    result <- list() #return empty if not found
  })
}
#url request to list
curlRequest.URL <- function(url){
  h = RCurl::basicTextGatherer()
  tryCatch({
    RCurl::curlPerform(url=url,
                       userpwd = neu,
                       httpheader = c(Authorization = paste("Basic",RCurl::base64(neu))),
                       writefunction = h$update,
                       verbose = FALSE
    )
    result <- jsonlite::fromJSON(h$value(), simplifyVector = FALSE) #return as list
  }, error = function(err) {
    message(err)
    result <- list() #return empty if not found
  })
}
#url request to data frame
curlRequest.URL.DFrame <- function(url){
  h = RCurl::basicTextGatherer()
  tryCatch({
    RCurl::curlPerform(url=url,
                       userpwd = neu,
                       httpheader = c(Authorization = paste("Basic",RCurl::base64(neu))),
                       writefunction = h$update,
                       verbose = FALSE
    )
    result <- jsonlite::fromJSON(h$value()) #return as data.frame
  }, error = function(err) {
    message(err)
    result <- data.frame() #return empty if not found
  })
}
#transaction HTTP endpoint return graph format
#note: execute multiple statements available in neo4j 2.3.3
curlRequest.TRANSACTIONS <- function(listOfCypher){
  h = RCurl::basicTextGatherer()
  tryCatch({
    getDbInfo()
    url = paste0(database.location,"transaction/commit")
    #url = paste0("http://localhost:7474/db/data/","transaction/commit")
    #body = paste0("{\"statements\":[{\"statement\":\"",cypher,"\",\"resultDataContents\":[\"graph\"]}]}")
    body = paste0("{\"statements\":[",paste0(listOfCypher, collapse = ","),"]}")
    RCurl::curlPerform(url=url,
                       userpwd = neu,
                       httpheader = c(Authorization = paste("Basic",RCurl::base64(neu)), 'Content-Type' = "application/json"),
                       postfields=body,
                       writefunction = h$update,
                       verbose = FALSE
    )
    result <- jsonlite::fromJSON(h$value(), simplifyDataFrame=FALSE)$results
  }, error = function(err) {
    message(err)
    result <- list() #return empty if not found
  })
}
###testing fetchNode()
# nodes = lapply(txtinput,function(x){
#   qstring = gsub("keyword", x, querystring)
#   cat(qstring,"\n")
#   paste0("{\"statement\":\"",qstring,"\",\"resultDataContents\":[\"graph\"]}")
# })
# nodels = curlRequest.TRANSACTIONS(nodes)
# attb = plyr::rbind.fill(lapply(nodels,function(x) {
#   if(length(x$data) > 1){
#     plyr::ldply(lapply(x$data, function(y){
#       formatNode.TRANSACTION.ALL(y$graph$nodes)
#     }),data.frame)
#   }else{
#     formatNode.TRANSACTION.ALL(x$data[[1]]$graph$nodes)
#   }
# }))
###end testing