R/plenarias.R

In rOpenSpain/senadoRES: Information About the Senate of Spain

# Pleno y diputación permanente

#' Plenary sessions
#'
#' How many session have been.
#' @export
#' @inheritParams grupos
#' @return A data.frame with the information available.
#' @examples
#' if (interactive()) {
#'     head(plenarias(10))
#' }
plenarias <- function(legislatura = 10) {
    stopifnot(legislatura >= 10)
    url <- compose_url(tipoFich = 14, legis = legislatura)
    x <- read_xml(url)
    sesion <- xml_find_all(x, "//sesionPlenaria")
    l <- lapply(sesion, xml2matrix)
    out <- do.call(rbind, l)
    out <- as.data.frame(out)

    out$sesionHoraInicio <- as.difftime(out$sesionHoraInicio, format = '%H:%M')

    # Deal with dates and locales
    locale <- Sys.getlocale("LC_TIME")
    on.exit(Sys.setlocale("LC_TIME", locale))
    # Check is locale is Spanish
    sl <- set_locale() # change locale
    if (startsWith(sl,"es_ES")) {
        out$sesionFechaInicio <- as.Date(out$sesionFechaInicio,
                                         format = "%d de %B de %Y")
    }
    out
}


helper <- function(x, path) {
    y <- xml2ch(xml_children(xml_find_all(x, paste0("./", path))))
    if (!is.null(y) && length(y) != 0) {
        names(y) <- paste0(path, "_", names(y))
        y
    }
}

tidy_asunto <- function(asunto) {

    omit <- omit_xml(c("intervencion", "punto", "expediente"))
    m <- xml2matrix2(xml_find_all(asunto, paste0("./", omit)))
    colnames(m) <- paste0("asunto_", colnames(m))
    punto <- xml_find_all(asunto, "./punto")
    if (length(punto) != 0) {
        punto <- tidy_punto(xml_children(punto))
    } else {
        punto <- NULL
    }
    int <- xml_find_all(asunto, "./intervencion")
    if (length(int) != 0) {
        l <- lapply(int, tidy_intervencion)
        l2 <- Reduce(merger, l)
        colnames(l2) <- paste0("intervencion_", colnames(l2))
    } else {
        l2 <- NULL
    }
    if ("expediente" %in% xml_name(asunto)) {
        expediente <- t(as.matrix(helper(asunto, "expediente")))
    } else {
        expediente <- NULL
    }

    # Merge output
    if (!is.null(expediente)) {
        m <- cbind.data.frame(add_rows(m, expediente), expediente)
    }
    if (!is.null(l2)) {
        m <- cbind.data.frame(add_rows(m, l2), l2)
    }
    if (!is.null(punto)) {
        m <- cbind.data.frame(add_rows(m, punto), punto)
    }
    m
}

tidy_punto <- function(x) {
    punto <- xml2matrix2(x)
    colnames(punto) <- paste0("punto_", colnames(punto))
    punto
}



tidy_intervencion <- function(x) {

    orador <- helper(x, "orador")
    fase <- helper(x, "fase")
    cargo <- helper(x, "cargo")
    grupo <- helper(x, "grupo")
    path <- "./id|asunto|hora_inicio|offset_inicio|hora_fin|duracion_mseg|duracion_texto|path1|path0"
    data <- xml2ch(xml_find_all(x, path))
    out <- c(data, orador, fase, cargo, grupo)
    as.data.frame(t(as.matrix(out)))
}

#' Check individual session
#' @param url A url path to a session.
#' @return A [data.frame] with all the information about a session.
#' @seealso [plenarias()]
#' @export
#' @examples
#' if (interactive()) {
#'     pl <- plenarias(10)
#'     detalles(pl$fichUrlDetalleSesion[1])
#' }
detalles <- function(url) {
    if (missing(url)) {
        url <- compose_url()
    }
    x <- read_xml(url)
    meta <- xml_find_all(x, "/sesion/update|fecha|legis")
    meta <- xml2matrix2(meta)
    asuntos <- xml_find_all(x, "/sesion/asunto")
    l <- lapply(asuntos, tidy_asunto)
    Reduce(merger, l)
}


set_locale <- function() {
    tryCatch(Sys.setlocale(category = "LC_TIME", locale = "es_ES.utf-8"))
    Sys.getlocale("LC_TIME")
}