R/finnotech/getting_realtime.R

In pooya1991/BillioR: Billionaire Startup

library(httr)
library(jsonlite)
load("data/finnotech/token.rda")

getting_realtime_minutely <- function() {
  service <- "trades/realtime"
  
  address <- "https://api.finnotech.ir"
  clientID <- "Billionaire"
  finnotech_version <- "v1"
  token <- content_token[["access_token"]][["value"]]
  
  national_number = "2740370733"
  
  service_url <- paste(address, "bourse", finnotech_version, "clients", clientID, service, sep = "/")
  realtime_req <- GET(service_url, add_headers(Authorization = paste("Bearer", token)))
  realtime_content <- jsonlite::fromJSON(content(realtime_req, "text"),simplifyVector = FALSE)
  if(status_code(realtime_req) == 200) {
    realtime <- realtime_content[["result"]]
    l_realtime <- lapply(realtime, realtime_parser)
    df_realtime <- do.call(rbind, l_realtime)
    return(df_realtime)
  } else {
    if(status_code(realtime_req) == 401) {
      refresh_token(content_token$access_token$refreshToken)
      load("data/finnotech/token.rda")
      getting_realtime_minutely()
    } else {
      
    }
  }
}



realtime_parser <- function(realtime_element){
  result <- data.frame(CoID = realtime_element$CoID, Symbol = realtime_element$TseSymbolCode,
                       Date = realtime_element$TradeDateGre, Date_fa = realtime_element$TradeDate,
                       Open = realtime_element$OpeningPrice, Close = realtime_element$ClosingPrice,
                       High = realtime_element$MaxPrice, Low = realtime_element$minPrice,
                       Last = realtime_element$LastPrice, Volume = realtime_element$TradeVolume,
                       Value = realtime_element$TradeValue, Qty = realtime_element$TradeQty)
  return(result)
}