R/transmission_parse_periodpoint.R

In krose/entsoeR: Entsoe-e API R Wrapper

transmission_parse_period <- function(ts_individual){

  period_start <-
    ts_individual %>%
    rvest::html_node(xpath = "period") %>%
    rvest::html_node(xpath = "timeinterval") %>%
    rvest::html_node("start") %>%
    rvest::html_text()

  resolution <-
    ts_individual %>%
    rvest::html_node(xpath = "period") %>%
    rvest::html_node(xpath = "resolution") %>%
    rvest::html_text()

  resolution_qty <- stringr::str_extract(resolution, "[0-9]{1,4}") %>% as.integer()
  resolution_hm <- stringr::str_sub(string = resolution, start = -1L)

  # Parse the position and then convert it to POSIXct based on the resolution and
  # and period start
  datetime <-
    ts_individual %>%
    rvest::html_node(xpath = "period") %>%
    rvest::html_nodes(xpath = "point") %>%
    rvest::html_nodes(xpath = "position") %>%
    rvest::html_text() %>%
    as.numeric()

  if(resolution_hm == "M"){
    datetime <-
      lubridate::ymd_hm(period_start, tz = "UTC") +
      lubridate::minutes(datetime * resolution_qty - 1 * resolution_qty)
  } else if(resolution_hm == "H"){
    datetime <-
      lubridate::ymd_hm(period_start, tz = "UTC") +
      lubridate::hours(datetime * resolution_qty - 1 * resolution_qty)
  } else {
    stop("The date resolution is not supported")
  }


  quantity <-
    ts_individual %>%
    rvest::html_node(xpath = "period") %>%
    rvest::html_nodes(xpath = "point") %>%
    rvest::html_nodes(xpath = "quantity") %>%
    rvest::html_text() %>%
    as.numeric()

  point_df <- tibble::tibble(datetime = datetime, quantity = quantity)

  congestioncost_price.amount <-
    ts_individual %>%
    rvest::html_node(xpath = "period") %>%
    rvest::html_nodes(xpath = "point") %>%
    rvest::html_nodes(xpath = "congestioncost_price.amount") %>%
    rvest::html_text() %>%
    as.numeric()
  if(length(congestioncost_price.amount) > 0){
    point_df$congestioncost_price.amount <- congestioncost_price.amount
  }

  point_df
}