inst/bazi.R

# Read a bazi data file
read_bazi_data = function(file.bazi) {
	lines = readLines(file.bazi, warn = FALSE, encoding = "UTF-8")
	stopifnot(all(!grepl("::TOKEN::", lines)))

	vals = .get_token_values(lines)
	vals$filename <- file.bazi

	if(length(unique(names(vals))) == length(vals)) {
		if(strcount(vals$DATEN, "\n\\+") <= 2) {
			vals <- .parse_bazi_single_district(vals)
		} else {
			# district data per party
			vals <- .parse_bazi_single_district_party_fill(vals)
		}
	} else {
		vals <- .parse_bazi_multiple_districts(vals)
	}

	class(vals) <- c("bazi_data", "list")

	return(vals)
}

# parse bazi files ####
.get_token_values = function(lines) {
	lines <- trimws(lines)

	# rename tokens
	lines <- lines |>
		gsub.("=TITLE=", "=TITEL=") |>
		gsub.("=METHOD=", "=METHODE=") |>
		gsub.("=INPUT=", "=EINGABE=") |>
		gsub.("=OUTPUT=", "=AUSGABE=") |>
		gsub.("=DISTRICT=", "=DISTRIKT=") |>
		gsub.("=DISTRICTOPTION=", "=DISTRIKTOPTION=") |>
		gsub.("=SEATS=", "=MANDATE=") |>
		gsub.("=DATA=", "=DATEN=") |>
		gsub.("=END=", "=ENDE=") |>
		gsub.("=ENCODING=", "=KODIERUNG=") |>
		gsub.("=ACCURACY=", "=GENAUIGKEIT=")

	# trim to end
	end_index = which(lines == "=ENDE=")
	stopifnot(length(end_index) == 1)
	lines <- lines[1:end_index]

	# all tokens
	tokens = c("TITEL", "METHODE", "AUSGABE", "EINGABE", "DISTRIKTOPTION",
			   "DISTRIKT", "MANDATE", "MANDATES",
			   "DATEN", "INFO", "PATTS", "KODIERUNG", "GENAUIGKEIT")

	# sanitize info
	info_index = which(startsWith(lines, "=INFO="))
	if(length(info_index) > 0) {
		for(token in tokens) {
			info_range = seq(info_index+1, end_index-1)
			lines[info_range] <- gsub(
				paste0("=", token, "="),
				paste0("", token," \n"),
				lines[info_range], ignore.case = TRUE)
		}
	}

	# find relevant tokens
	txt = paste0(lines, collapse = "\n")
	for(token in tokens) {
		txt <- gsub(paste0("=", token, "="),
					paste0("::TOKEN::",token,"\n"),
					txt, ignore.case = TRUE)
	}
	stopifnot(!any(grepl("\n=[A-Z]+=", gsub("=ENDE=", "", txt))))
	tokenized_lines = strsplit1(txt, "\n")

	# create list from tokens
	token_index = which(startsWith(tokenized_lines, "::TOKEN::"))
	token_index <- c(token_index, length(tokenized_lines))
	stopifnot(tokenized_lines[length(tokenized_lines)] == "=ENDE=")

	token_data_list = list()
	token_names = list()
	for(i in seq(1, length(token_index)-1)) {
		from = token_index[i]+1
		to = token_index[i+1]-1
		data_lines = trimws(tokenized_lines[seq(from, to)])
		data_lines <- data_lines[data_lines != "" & data_lines != " "]

		name = gsub("::TOKEN::", "", tokenized_lines[token_index[i]])
		data = paste(data_lines, collapse = "\n")

		token_names[[length(token_names)+1]] <- name
		token_data_list[[length(token_data_list)+1]] <- data
	}

	names(token_data_list) <- token_names
	return(token_data_list)
}

.parse_bazi_single_district = function(vals) {
	vals$data <- .read.table_bazi(vals$DATEN)
	cns = trimws(strsplit1(vals$EINGABE, ","))
	colnames(vals$data) <- cns[seq(1,ncol(vals$data))]
	vals$seats <- suppressWarnings(as.integer(vals$MANDATE))
	vals
}

.parse_bazi_single_district_party_fill = function(vals) {
	vals$DATEN <- gsub("\n\\+", "\n\\+ ", vals$DATEN)
	vals$data <- .read.table_bazi(vals$DATEN)

	vals$data[[1]] <- fill_plus(vals$data[[1]])
	cns = trimws(strsplit1(vals$EINGABE, ","))
	if(length(cns) == ncol(vals$data) && cns[length(cns)] == "---") {
		cns <- cns[-length(cns)]
	}

	colnames(vals$data) <- c(cns[1], "DISTRIKT",
							 cns[2:length(cns)])

	vals$seats <- suppressWarnings(as.integer(vals$MANDATE))

	vals
}

.parse_bazi_multiple_districts = function(vals) {
	# more than one disctrict data
	distrikt_mandate_daten = vals[names(vals) %in% c("DISTRIKT", "MANDATE", "DATEN")]
	stopifnot(length(unique(table(names(distrikt_mandate_daten)))) == 1)

	# split into sets of three
	district_data_list = split(distrikt_mandate_daten,
							   rep(seq_len(length(distrikt_mandate_daten)/3), each = 3))

	# data votes
	data_list = district_data_list |>
		lapply(\(dmd) {
			x = strsplit1(dmd$DATEN, "\n")
			x <- gsub.(x, "^\\+", "")
			x <- lapply(x, \(x) {
				if(!grepl('"', dmd$DISTRIKT)) {
					return(paste0('"', dmd$DISTRIKT, '" ', x))
				} else if(!grepl("'", dmd$DISTRIKT)) {
					return(paste0("'", dmd$DISTRIKT, "' ", x))
				}
				stop() # nocov
			})
			unlist(x)
		}) |> unlist(use.names = F)

	vals$data <- data_list |>
		lapply(\(txt) {
			read.table(text = txt, fill = TRUE,
					   col.names = c("DISTRIKT", trimws(strsplit1(vals$EINGABE, ","))))
		}) |>
		rbind_list()

	# district seats
	vals$seats <- district_data_list |>
		lapply(\(dmd) {
			data.frame(district = dmd$DISTRIKT, seats = as.integer(dmd$MANDATE))
		}) |>
		rbind_list()

	vals
}

.read.table_bazi = function(text) {
	read.table(text = text, fill = TRUE, header = FALSE, row.names = NULL)
}

# utils ####
strsplit1 = function(x, split, fixed = FALSE) {
	strsplit(x, split, fixed = fixed)[[1]]
}

rbind_list = function(l) {
	do.call(rbind, l)
}

gsub. = function(x, pattern, replacement, ignore.case = TRUE) {
	gsub(pattern, replacement, x, ignore.case = ignore.case)
}

fill_plus = function(x) {
	values = x[x != "+"]
	y = rep(1, length(x))
	y[x == "+"] <- 0
	lvls = cumsum(y)

	values[lvls]
}

strcount = function(x, pattern) {
	length(gregexpr(pattern, x)[[1]])
}
polettif/proporz documentation built on June 13, 2025, 7:12 a.m.