args_all <- commandArgs(trailingOnly = FALSE)
script_arg <- args_all[grep("^--file=", args_all)]
if (length(script_arg) > 0) {
script_path <- dirname(sub("--file=", "", script_arg))
original_wd <- getwd()
setwd(script_path)
} else {
original_wd <- getwd()
}
user_lib <- file.path(Sys.getenv("USERPROFILE"), "Documents", "R", "win-library", "4.4")
if (dir.exists(user_lib)) {
.libPaths(c(user_lib, .libPaths()))
}
if (!require("jsonlite", quietly = TRUE)) {
stop("Package 'jsonlite' is required. Install with: install.packages('jsonlite')")
}
convert_categorical_to_numeric <- function(data, dataset_name) {
non_numeric_cols <- names(data)[sapply(data, function(x) !is.numeric(x))]
if (length(non_numeric_cols) > 0) {
cat(paste0("INFO: Dataset '", dataset_name, "' contains non-numeric columns: ",
paste(non_numeric_cols, collapse = ", "), "\n"))
cat("Converting categorical variables to numeric representations...\n")
for (col in non_numeric_cols) {
if (is.factor(data[[col]])) {
data[[col]] <- as.numeric(data[[col]])
} else if (is.character(data[[col]])) {
temp_numeric <- as.numeric(data[[col]])
if (any(is.na(temp_numeric))) {
data[[col]] <- as.numeric(as.factor(data[[col]]))
} else {
data[[col]] <- temp_numeric
}
}
}
}
return(data)
}
resolve_path <- function(path) {
is_absolute <- grepl("^(/|[A-Za-z]:)", path)
if (!is_absolute) {
file.path(original_wd, path)
} else {
path
}
}
args <- commandArgs(trailingOnly = TRUE)
default_csv <- "../../../datasets/csv/mtcars.csv"
default_output <- "../../../results/r"
csv_path_raw <- ifelse(length(args) >= 1, args[1], default_csv)
output_dir_raw <- ifelse(length(args) >= 2, args[2], default_output)
csv_path <- resolve_path(csv_path_raw)
output_dir <- resolve_path(output_dir_raw)
if (!file.exists(csv_path)) {
stop(paste("CSV file not found:", csv_path))
}
dataset_name <- tools::file_path_sans_ext(basename(csv_path))
cat(sprintf("Running WLS regression test on dataset: %s\n", dataset_name))
data <- read.csv(csv_path)
data <- convert_categorical_to_numeric(data, dataset_name)
response_col <- names(data)[1]
predictor_cols <- names(data)[-1]
formula_str <- paste(response_col, "~", paste(predictor_cols, collapse = " + "))
formula <- as.formula(formula_str)
weights <- rep(1, nrow(data))
fit <- lm(formula, data = data, weights = weights)
summary_fit <- summary(fit)
coefs <- summary_fit$coefficients
n_coef <- nrow(coefs)
coefficients <- as.vector(coefs[, 1]) std_errors <- as.vector(coefs[, 2]) t_stats <- as.vector(coefs[, 3]) p_values <- as.vector(coefs[, 4])
variable_names <- c("Intercept", rownames(coefs)[-1])
n <- length(fitted(fit))
k <- length(coefficients) - 1 df_residual <- fit$df.residual
df_model <- k
r_squared <- summary_fit$r.squared
adj_r_squared <- summary_fit$adj.r.squared
f_statistic <- summary_fit$fstatistic[1]
f_p_value <- pf(f_statistic, k, df_residual, lower.tail = FALSE)
residuals <- as.vector(residuals(fit))
fitted_values <- as.vector(fitted(fit))
mse <- sum(residuals^2) / df_residual
rmse <- sqrt(mse)
mae <- mean(abs(residuals))
residual_std_error <- summary_fit$sigma
log_likelihood <- as.numeric(logLik(fit))
aic_val <- AIC(fit)
bic_val <- BIC(fit)
ci <- confint(fit, level = 0.95)
conf_int_lower <- as.vector(ci[, 1])
conf_int_upper <- as.vector(ci[, 2])
result <- list(
test = "wls",
method = "lm",
dataset = dataset_name,
formula = formula_str,
n = n,
k = k,
df_residual = as.integer(df_residual),
df_model = as.integer(df_model),
variable_names = variable_names,
coefficients = coefficients,
std_errors = std_errors,
t_stats = t_stats,
p_values = p_values,
r_squared = r_squared,
adj_r_squared = adj_r_squared,
f_statistic = f_statistic,
f_p_value = f_p_value,
mse = mse,
rmse = rmse,
mae = mae,
residual_std_error = residual_std_error,
log_likelihood = log_likelihood,
aic = aic_val,
bic = bic_val,
conf_int_lower = conf_int_lower,
conf_int_upper = conf_int_upper,
fitted_values = fitted_values,
residuals = residuals,
weights = weights
)
if (!dir.exists(output_dir)) {
dir.create(output_dir, recursive = TRUE)
}
output_file <- file.path(output_dir, paste0(dataset_name, "_wls.json"))
write_json(result, output_file, pretty = TRUE, auto_unbox = TRUE, digits = 22)
cat(sprintf("Wrote: %s\n", normalizePath(output_file)))