calculate_interaction_zscores.R 44 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106
  1. suppressMessages({
  2. library(ggplot2)
  3. library(plotly)
  4. library(htmlwidgets)
  5. library(dplyr)
  6. library(ggthemes)
  7. library(data.table)
  8. library(unix)
  9. })
  10. options(warn = 2)
  11. options(width = 10000)
  12. # Set the memory limit to 30GB (30 * 1024 * 1024 * 1024 bytes)
  13. soft_limit <- 30 * 1024 * 1024 * 1024
  14. hard_limit <- 30 * 1024 * 1024 * 1024
  15. rlimit_as(soft_limit, hard_limit)
  16. # Constants for configuration
  17. plot_width <- 14
  18. plot_height <- 9
  19. base_size <- 14
  20. parse_arguments <- function() {
  21. args <- if (interactive()) {
  22. c(
  23. "/home/bryan/documents/develop/hartmanlab/qhtcp-workflow/out/20240116_jhartman2_DoxoHLD/20240116_jhartman2_DoxoHLD",
  24. "/home/bryan/documents/develop/hartmanlab/qhtcp-workflow/apps/r/SGD_features.tab",
  25. "/home/bryan/documents/develop/hartmanlab/qhtcp-workflow/out/20240116_jhartman2_DoxoHLD/easy/20240116_jhartman2_DoxoHLD/results_std.txt",
  26. "/home/bryan/documents/develop/hartmanlab/qhtcp-workflow/out/20240116_jhartman2_DoxoHLD/20240822_jhartman2_DoxoHLD/exp1",
  27. "Experiment 1: Doxo versus HLD",
  28. 3,
  29. "/home/bryan/documents/develop/hartmanlab/qhtcp-workflow/out/20240116_jhartman2_DoxoHLD/20240822_jhartman2_DoxoHLD/exp2",
  30. "Experiment 2: HLD versus Doxo",
  31. 3
  32. )
  33. } else {
  34. commandArgs(trailingOnly = TRUE)
  35. }
  36. # Extract paths, names, and standard deviations
  37. paths <- args[seq(4, length(args), by = 3)]
  38. names <- args[seq(5, length(args), by = 3)]
  39. sds <- as.numeric(args[seq(6, length(args), by = 3)])
  40. # Normalize paths
  41. normalized_paths <- normalizePath(paths, mustWork = FALSE)
  42. # Create named list of experiments
  43. experiments <- list()
  44. for (i in seq_along(paths)) {
  45. experiments[[names[i]]] <- list(
  46. path = normalized_paths[i],
  47. sd = sds[i]
  48. )
  49. }
  50. list(
  51. out_dir = normalizePath(args[1], mustWork = FALSE),
  52. sgd_gene_list = normalizePath(args[2], mustWork = FALSE),
  53. easy_results_file = normalizePath(args[3], mustWork = FALSE),
  54. experiments = experiments
  55. )
  56. }
  57. args <- parse_arguments()
  58. # Should we keep output in exp dirs or combine in the study output dir?
  59. # dir.create(file.path(args$out_dir, "zscores"), showWarnings = FALSE)
  60. # dir.create(file.path(args$out_dir, "zscores", "qc"), showWarnings = FALSE)
  61. # Define themes and scales
  62. theme_publication <- function(base_size = 14, base_family = "sans", legend_position = "bottom") {
  63. theme_foundation <- ggplot2::theme_grey(base_size = base_size, base_family = base_family)
  64. theme_foundation %+replace%
  65. theme(
  66. plot.title = element_text(face = "bold", size = rel(1.2), hjust = 0.5),
  67. text = element_text(),
  68. panel.background = element_rect(colour = NA),
  69. plot.background = element_rect(colour = NA),
  70. panel.border = element_rect(colour = NA),
  71. axis.title = element_text(face = "bold", size = rel(1)),
  72. axis.title.y = element_text(angle = 90, vjust = 2),
  73. axis.title.x = element_text(vjust = -0.2),
  74. axis.line = element_line(colour = "black"),
  75. panel.grid.major = element_line(colour = "#f0f0f0"),
  76. panel.grid.minor = element_blank(),
  77. legend.key = element_rect(colour = NA),
  78. legend.position = legend_position,
  79. legend.direction = ifelse(legend_position == "right", "vertical", "horizontal"),
  80. plot.margin = unit(c(10, 5, 5, 5), "mm"),
  81. strip.background = element_rect(colour = "#f0f0f0", fill = "#f0f0f0"),
  82. strip.text = element_text(face = "bold")
  83. )
  84. }
  85. scale_fill_publication <- function(...) {
  86. discrete_scale("fill", "Publication", manual_pal(values = c(
  87. "#386cb0", "#fdb462", "#7fc97f", "#ef3b2c", "#662506",
  88. "#a6cee3", "#fb9a99", "#984ea3", "#ffff33"
  89. )), ...)
  90. }
  91. scale_colour_publication <- function(...) {
  92. discrete_scale("colour", "Publication", manual_pal(values = c(
  93. "#386cb0", "#fdb462", "#7fc97f", "#ef3b2c", "#662506",
  94. "#a6cee3", "#fb9a99", "#984ea3", "#ffff33"
  95. )), ...)
  96. }
  97. # Load the initial dataframe from the easy_results_file
  98. load_and_process_data <- function(easy_results_file, sd = 3) {
  99. df <- read.delim(easy_results_file, skip = 2, as.is = TRUE, row.names = 1, strip.white = TRUE)
  100. df <- df %>%
  101. filter(!(.[[1]] %in% c("", "Scan"))) %>%
  102. filter(!is.na(ORF) & ORF != "" & !Gene %in% c("BLANK", "Blank", "blank") & Drug != "BMH21") %>%
  103. # Rename columns
  104. rename(L = l, num = Num., AUC = AUC96, scan = Scan, last_bg = LstBackgrd, first_bg = X1stBackgrd) %>%
  105. mutate(
  106. across(c(Col, Row, num, L, K, r, scan, AUC, last_bg, first_bg), as.numeric),
  107. delta_bg = last_bg - first_bg,
  108. delta_bg_tolerance = mean(delta_bg, na.rm = TRUE) + (sd * sd(delta_bg, na.rm = TRUE)),
  109. NG = if_else(L == 0 & !is.na(L), 1, 0),
  110. DB = if_else(delta_bg >= delta_bg_tolerance, 1, 0),
  111. SM = 0,
  112. OrfRep = if_else(ORF == "YDL227C", "YDL227C", OrfRep), # should these be hardcoded?
  113. conc_num = as.numeric(gsub("[^0-9\\.]", "", Conc)),
  114. conc_num_factor = as.numeric(as.factor(conc_num)) - 1
  115. )
  116. return(df)
  117. }
  118. # Update Gene names using the SGD gene list
  119. update_gene_names <- function(df, sgd_gene_list) {
  120. # Load SGD gene list
  121. genes <- read.delim(file = sgd_gene_list,
  122. quote = "", header = FALSE,
  123. colClasses = c(rep("NULL", 3), rep("character", 2), rep("NULL", 11)))
  124. # Create a named vector for mapping ORF to GeneName
  125. gene_map <- setNames(genes$V5, genes$V4)
  126. # Vectorized match to find the GeneName from gene_map
  127. mapped_genes <- gene_map[df$ORF]
  128. # Replace NAs in mapped_genes with original Gene names (preserves existing Gene names if ORF is not found)
  129. updated_genes <- ifelse(is.na(mapped_genes) | df$OrfRep == "YDL227C", df$Gene, mapped_genes)
  130. # Ensure Gene is not left blank or incorrectly updated to "OCT1"
  131. df <- df %>%
  132. mutate(Gene = ifelse(updated_genes == "" | updated_genes == "OCT1", OrfRep, updated_genes))
  133. return(df)
  134. }
  135. # Calculate summary statistics for all variables
  136. calculate_summary_stats <- function(df, variables, group_vars = c("OrfRep", "conc_num", "conc_num_factor")) {
  137. # Summarize the variables within the grouped data
  138. summary_stats <- df %>%
  139. group_by(across(all_of(group_vars))) %>%
  140. summarise(
  141. N = sum(!is.na(L)),
  142. across(all_of(variables), list(
  143. mean = ~mean(., na.rm = TRUE),
  144. median = ~median(., na.rm = TRUE),
  145. max = ~ ifelse(all(is.na(.)), NA, max(., na.rm = TRUE)),
  146. min = ~ ifelse(all(is.na(.)), NA, min(., na.rm = TRUE)),
  147. sd = ~sd(., na.rm = TRUE),
  148. se = ~ ifelse(all(is.na(.)), NA, sd(., na.rm = TRUE) / sqrt(sum(!is.na(.)) - 1))
  149. ), .names = "{.fn}_{.col}")
  150. )
  151. print(summary_stats)
  152. # Prevent .x and .y suffix issues by renaming columns
  153. df_cleaned <- df %>%
  154. select(-any_of(setdiff(names(summary_stats), group_vars))) # Avoid duplicate columns in the final join
  155. # Join the stats back to the original dataframe
  156. df_with_stats <- left_join(df_cleaned, summary_stats, by = group_vars)
  157. return(list(summary_stats = summary_stats, df_with_stats = df_with_stats))
  158. }
  159. calculate_interaction_scores <- function(df, max_conc, variables, group_vars = c("OrfRep", "Gene", "num")) {
  160. # Calculate total concentration variables
  161. total_conc_num <- length(unique(df$conc_num))
  162. num_non_removed_concs <- total_conc_num - sum(df$DB, na.rm = TRUE) - 1
  163. # Pull the background means and standard deviations from zero concentration
  164. bg_means <- list(
  165. L = df %>% filter(conc_num_factor == 0) %>% pull(mean_L) %>% first(),
  166. K = df %>% filter(conc_num_factor == 0) %>% pull(mean_K) %>% first(),
  167. r = df %>% filter(conc_num_factor == 0) %>% pull(mean_r) %>% first(),
  168. AUC = df %>% filter(conc_num_factor == 0) %>% pull(mean_AUC) %>% first()
  169. )
  170. bg_sd <- list(
  171. L = df %>% filter(conc_num_factor == 0) %>% pull(sd_L) %>% first(),
  172. K = df %>% filter(conc_num_factor == 0) %>% pull(sd_K) %>% first(),
  173. r = df %>% filter(conc_num_factor == 0) %>% pull(sd_r) %>% first(),
  174. AUC = df %>% filter(conc_num_factor == 0) %>% pull(sd_AUC) %>% first()
  175. )
  176. calculations <- df %>%
  177. mutate(
  178. WT_L = df$mean_L,
  179. WT_K = df$mean_K,
  180. WT_r = df$mean_r,
  181. WT_AUC = df$mean_AUC,
  182. WT_sd_L = df$sd_L,
  183. WT_sd_K = df$sd_K,
  184. WT_sd_r = df$sd_r,
  185. WT_sd_AUC = df$sd_AUC
  186. ) %>%
  187. group_by(across(all_of(group_vars)), conc_num, conc_num_factor) %>%
  188. mutate(
  189. N = sum(!is.na(L)),
  190. NG = sum(NG, na.rm = TRUE),
  191. DB = sum(DB, na.rm = TRUE),
  192. SM = sum(SM, na.rm = TRUE),
  193. across(all_of(variables), list(
  194. mean = ~mean(., na.rm = TRUE),
  195. median = ~median(., na.rm = TRUE),
  196. max = ~max(., na.rm = TRUE),
  197. min = ~min(., na.rm = TRUE),
  198. sd = ~sd(., na.rm = TRUE),
  199. se = ~sd(., na.rm = TRUE) / sqrt(sum(!is.na(.)) - 1)
  200. ), .names = "{.fn}_{.col}")
  201. ) %>%
  202. ungroup()
  203. calculations <- calculations %>%
  204. group_by(across(all_of(group_vars))) %>%
  205. mutate(
  206. Raw_Shift_L = mean_L[[1]] - bg_means$L,
  207. Raw_Shift_K = mean_K[[1]] - bg_means$K,
  208. Raw_Shift_r = mean_r[[1]] - bg_means$r,
  209. Raw_Shift_AUC = mean_AUC[[1]] - bg_means$AUC,
  210. Z_Shift_L = Raw_Shift_L[[1]] / bg_sd$L,
  211. Z_Shift_K = Raw_Shift_K[[1]] / bg_sd$K,
  212. Z_Shift_r = Raw_Shift_r[[1]] / bg_sd$r,
  213. Z_Shift_AUC = Raw_Shift_AUC[[1]] / bg_sd$AUC
  214. )
  215. calculations <- calculations %>%
  216. mutate(
  217. Exp_L = WT_L + Raw_Shift_L,
  218. Delta_L = mean_L - Exp_L,
  219. Exp_K = WT_K + Raw_Shift_K,
  220. Delta_K = mean_K - Exp_K,
  221. Exp_r = WT_r + Raw_Shift_r,
  222. Delta_r = mean_r - Exp_r,
  223. Exp_AUC = WT_AUC + Raw_Shift_AUC,
  224. Delta_AUC = mean_AUC - Exp_AUC
  225. )
  226. calculations <- calculations %>%
  227. mutate(
  228. Delta_L = if_else(NG == 1, mean_L - WT_L, Delta_L),
  229. Delta_K = if_else(NG == 1, mean_K - WT_K, Delta_K),
  230. Delta_r = if_else(NG == 1, mean_r - WT_r, Delta_r),
  231. Delta_AUC = if_else(NG == 1, mean_AUC - WT_AUC, Delta_AUC),
  232. Delta_L = if_else(SM == 1, mean_L - WT_L, Delta_L)
  233. )
  234. interactions <- calculations %>%
  235. mutate(
  236. lm_L = lm(Delta_L ~ conc_num_factor),
  237. lm_K = lm(Delta_K ~ conc_num_factor),
  238. lm_r = lm(Delta_r ~ conc_num_factor),
  239. lm_AUC = lm(Delta_AUC ~ conc_num_factor),
  240. Zscore_L = Delta_L / WT_sd_L,
  241. Zscore_K = Delta_K / WT_sd_K,
  242. Zscore_r = Delta_r / WT_sd_r,
  243. Zscore_AUC = Delta_AUC / WT_sd_AUC
  244. )
  245. interactions <- interactions %>%
  246. mutate(
  247. lm_Score_L = max_conc * coef(lm_L)[2] + coef(lm_L)[1],
  248. lm_Score_K = max_conc * coef(lm_K)[2] + coef(lm_K)[1],
  249. lm_Score_r = max_conc * coef(lm_r)[2] + coef(lm_r)[1],
  250. lm_Score_AUC = max_conc * coef(lm_AUC)[2] + coef(lm_AUC)[1],
  251. r_squared_L = summary(lm_L)$r.squared,
  252. r_squared_K = summary(lm_K)$r.squared,
  253. r_squared_r = summary(lm_r)$r.squared,
  254. r_squared_AUC = summary(lm_AUC)$r.squared,
  255. Sum_Zscore_L = sum(Zscore_L, na.rm = TRUE),
  256. Sum_Zscore_K = sum(Zscore_K, na.rm = TRUE),
  257. Sum_Zscore_r = sum(Zscore_r, na.rm = TRUE),
  258. Sum_Zscore_AUC = sum(Zscore_AUC, na.rm = TRUE)
  259. )
  260. interactions <- interactions %>%
  261. mutate(
  262. Avg_Zscore_L = Sum_Zscore_L / num_non_removed_concs,
  263. Avg_Zscore_K = Sum_Zscore_K / num_non_removed_concs,
  264. Avg_Zscore_r = Sum_Zscore_r / (total_conc_num - 1),
  265. Avg_Zscore_AUC = Sum_Zscore_AUC / (total_conc_num - 1),
  266. Z_lm_L = (lm_Score_L - mean(lm_Score_L, na.rm = TRUE)) / sd(lm_Score_L, na.rm = TRUE),
  267. Z_lm_K = (lm_Score_K - mean(lm_Score_K, na.rm = TRUE)) / sd(lm_Score_K, na.rm = TRUE),
  268. Z_lm_r = (lm_Score_r - mean(lm_Score_r, na.rm = TRUE)) / sd(lm_Score_r, na.rm = TRUE),
  269. Z_lm_AUC = (lm_Score_AUC - mean(lm_Score_AUC, na.rm = TRUE)) / sd(lm_Score_AUC, na.rm = TRUE)
  270. )
  271. # Declare column order for output
  272. calculations <- calculations %>%
  273. select("OrfRep", "Gene", "num", "conc_num", "conc_num_factor",
  274. "mean_L", "mean_K", "mean_r", "mean_AUC",
  275. "median_L", "median_K", "median_r", "median_AUC",
  276. "sd_L", "sd_K", "sd_r", "sd_AUC",
  277. "se_L", "se_K", "se_r", "se_AUC",
  278. "Raw_Shift_L", "Raw_Shift_K", "Raw_Shift_r", "Raw_Shift_AUC",
  279. "Z_Shift_L", "Z_Shift_K", "Z_Shift_r", "Z_Shift_AUC",
  280. "WT_L", "WT_K", "WT_r", "WT_AUC", "WT_sd_L", "WT_sd_K", "WT_sd_r", "WT_sd_AUC",
  281. "Exp_L", "Exp_K", "Exp_r", "Exp_AUC", "Delta_L", "Delta_K", "Delta_r", "Delta_AUC",
  282. "Zscore_L", "Zscore_K", "Zscore_r", "Zscore_AUC",
  283. "NG", "SM", "DB") %>%
  284. ungroup()
  285. # Also arrange results by Z_lm_L and NG
  286. interactions <- interactions %>%
  287. select("OrfRep", "Gene", "num", "Raw_Shift_L", "Raw_Shift_K", "Raw_Shift_AUC", "Raw_Shift_r",
  288. "Z_Shift_L", "Z_Shift_K", "Z_Shift_r", "Z_Shift_AUC",
  289. "lm_Score_L", "lm_Score_K", "lm_Score_AUC", "lm_Score_r",
  290. "R_Squared_L", "R_Squared_K", "R_Squared_r", "R_Squared_AUC",
  291. "Sum_Z_Score_L", "Sum_Z_Score_K", "Sum_Z_Score_r", "Sum_Z_Score_AUC",
  292. "Avg_Zscore_L", "Avg_Zscore_K", "Avg_Zscore_r", "Avg_Zscore_AUC",
  293. "Z_lm_L", "Z_lm_K", "Z_lm_r", "Z_lm_AUC",
  294. "NG", "SM", "DB") %>%
  295. arrange(desc(lm_Score_L)) %>%
  296. arrange(desc(NG)) %>%
  297. ungroup()
  298. return(list(calculations = calculations, interactions = interaction))
  299. }
  300. generate_and_save_plots <- function(output_dir, file_name, plot_configs, grid_layout = NULL) {
  301. message("Generating html and pdf plots for: ", file_name, ".pdf|html")
  302. plots <- lapply(plot_configs, function(config) {
  303. # Log details and setup
  304. df <- config$df
  305. aes_mapping <-
  306. if (is.null(config$y_var))
  307. aes(x = !!sym(config$x_var), color = as.factor(!!sym(config$color_var)))
  308. else
  309. aes(x = !!sym(config$x_var), y = !!sym(config$y_var), color = as.factor(!!sym(config$color_var)))
  310. plot <- ggplot(df, aes_mapping)
  311. # Plot type handling
  312. plot <- switch(config$plot_type,
  313. "scatter" = {
  314. plot <- if (!is.null(config$delta_bg_point) && config$delta_bg_point) {
  315. plot + geom_point(aes(ORF = ORF, Gene = Gene, delta_bg = delta_bg), config$shape %||% 3)
  316. } else if (!is.null(config$gene_point) && config$gene_point) {
  317. plot + geom_point(aes(ORF = ORF, Gene = Gene, Gene = Gene), shape = config$shape %||% 3, position = "jitter")
  318. } else if (!is.null(config$position) && config$position == "jitter") {
  319. plot + geom_point(shape = config$shape %||% 3, size = config$size %||% 0.2, position = "jitter")
  320. } else {
  321. plot + geom_point(shape = config$shape %||% 3, size = config$size %||% 0.2)
  322. }
  323. if (!is.null(config$add_smooth) && config$add_smooth) {
  324. if (!is.null(config$lm_line)) {
  325. # Use precomputed linear model values if available
  326. plot <- plot + geom_abline(intercept = config$lm_line$intercept, slope = config$lm_line$slope)
  327. } else {
  328. # Fallback to dynamically calculating the smooth line
  329. plot <- plot + geom_smooth(method = "lm", se = FALSE)
  330. }
  331. }
  332. if (!is.null(config$x_breaks) && !is.null(config$x_labels) && !is.null(config$x_label) && config$plot_type != "box") {
  333. plot <- plot + scale_x_continuous(
  334. name = config$x_label,
  335. breaks = config$x_breaks,
  336. labels = config$x_labels
  337. )
  338. }
  339. if (!is.null(config$ylim_vals)) {
  340. plot <- plot + scale_y_continuous(limits = config$ylim_vals)
  341. }
  342. if (!is.null(config$delta_bg_point) && config$delta_bg_point) {
  343. plot <- plot +
  344. geom_errorbar(aes(
  345. ymin = !!sym(paste0("mean_", config$y_var)) - !!sym(paste0("sd_", config$y_var)),
  346. ymax = !!sym(paste0("mean_", config$y_var)) + !!sym(paste0("sd_", config$y_var))),
  347. width = 0.1) +
  348. geom_point(aes(y = !!sym(paste0("mean_", config$y_var))), size = 0.6)
  349. }
  350. plot
  351. },
  352. "rank" = {
  353. plot <- plot + geom_point(size = config$size %||% 0.1, shape = config$shape %||% 3)
  354. if (!is.null(config$sd_band)) {
  355. for (i in seq_len(config$sd_band)) {
  356. plot <- plot +
  357. annotate("rect", xmin = -Inf, xmax = Inf, ymin = i, ymax = Inf, fill = "#542788", alpha = 0.3) +
  358. annotate("rect", xmin = -Inf, xmax = Inf, ymin = -i, ymax = -Inf, fill = "orange", alpha = 0.3) +
  359. geom_hline(yintercept = c(-i, i), color = "gray")
  360. }
  361. }
  362. if (!is.null(config$enhancer_label)) {
  363. plot <- plot + annotate("text", x = config$enhancer_label$x, y = config$enhancer_label$y, label = config$enhancer_label$label)
  364. }
  365. if (!is.null(config$suppressor_label)) {
  366. plot <- plot + annotate("text", x = config$suppressor_label$x, y = config$suppressor_label$y, label = config$suppressor_label$label)
  367. }
  368. plot
  369. },
  370. "correlation" = plot + geom_point(shape = config$shape %||% 3, color = "gray70") +
  371. geom_abline(intercept = config$lm_line$intercept, slope = config$lm_line$slope, color = "tomato3") +
  372. annotate("text", x = 0, y = 0, label = config$correlation_text),
  373. "box" = {
  374. plot <- plot + geom_boxplot()
  375. if (!is.null(config$x_breaks) && !is.null(config$x_labels) && !is.null(config$x_label) && config$plot_type == "box") {
  376. plot <- plot + scale_x_discrete(
  377. name = config$x_label,
  378. breaks = config$x_breaks,
  379. labels = config$x_labels
  380. )
  381. }},
  382. "density" = plot + geom_density(),
  383. "bar" = plot + geom_bar()
  384. )
  385. plot
  386. })
  387. # Save plots to PDF and HTML
  388. pdf(file.path(output_dir, paste0(file_name, ".pdf")), width = 14, height = 9)
  389. lapply(plots, print)
  390. dev.off()
  391. plotly_plots <- lapply(plots, function(plot) suppressWarnings(ggplotly(plot) %>% layout(legend = list(orientation = "h"))))
  392. combined_plot <- subplot(plotly_plots, nrows = grid_layout$nrow %||% length(plots), margin = 0.05)
  393. saveWidget(combined_plot, file = file.path(output_dir, paste0(file_name, ".html")), selfcontained = TRUE)
  394. }
  395. generate_interaction_plot_configs <- function(df, variables) {
  396. configs <- list()
  397. # Define common y-limits and other attributes for each variable dynamically
  398. limits_map <- list(L = c(-65, 65), K = c(-65, 65), r = c(-0.65, 0.65), AUC = c(-6500, 6500))
  399. # Define annotation positions based on the variable being plotted
  400. annotation_positions <- list(
  401. L = list(ZShift = 45, lm_ZScore = 25, NG = -25, DB = -35, SM = -45),
  402. K = list(ZShift = 45, lm_ZScore = 25, NG = -25, DB = -35, SM = -45),
  403. r = list(ZShift = 0.45, lm_ZScore = 0.25, NG = -0.25, DB = -0.35, SM = -0.45),
  404. AUC = list(ZShift = 4500, lm_ZScore = 2500, NG = -2500, DB = -3500, SM = -4500)
  405. )
  406. # Define which annotations to include for each plot
  407. annotation_labels <- list(
  408. ZShift = function(df, var) paste("ZShift =", round(df[[paste0("Z_Shift_", var)]], 2)),
  409. lm_ZScore = function(df, var) paste("lm ZScore =", round(df[[paste0("Z_lm_", var)]], 2)),
  410. NG = function(df, var) paste("NG =", df$NG),
  411. DB = function(df, var) paste("DB =", df$DB),
  412. SM = function(df, var) paste("SM =", df$SM)
  413. )
  414. for (variable in variables) {
  415. # Dynamically generate the names of the columns
  416. var_info <- list(
  417. ylim = limits_map[[variable]],
  418. lm_model = df[[paste0("lm_", variable)]][[1]], # Access the precomputed linear model
  419. sd_col = paste0("WT_sd_", variable),
  420. delta_var = paste0("Delta_", variable)
  421. )
  422. # Extract the precomputed linear model coefficients
  423. lm_line <- list(
  424. intercept = coef(var_info$lm_model)[1],
  425. slope = coef(var_info$lm_model)[2]
  426. )
  427. # Dynamically create annotations based on variable
  428. annotations <- lapply(names(annotation_positions[[variable]]), function(annotation_name) {
  429. y_pos <- annotation_positions[[variable]][[annotation_name]]
  430. label <- annotation_labels[[annotation_name]](df, variable)
  431. list(x = 1, y = y_pos, label = label)
  432. })
  433. # Add scatter plot configuration for this variable
  434. configs[[length(configs) + 1]] <- list(
  435. df = df,
  436. x_var = "conc_num_factor",
  437. y_var = var_info$delta_var,
  438. plot_type = "scatter",
  439. title = sprintf("%s %s", df$OrfRep[1], df$Gene[1]),
  440. ylim_vals = var_info$ylim,
  441. annotations = annotations,
  442. lm_line = lm_line, # Precomputed linear model
  443. error_bar = list(
  444. ymin = 0 - (2 * df[[var_info$sd_col]][1]),
  445. ymax = 0 + (2 * df[[var_info$sd_col]][1])
  446. ),
  447. x_breaks = unique(df$conc_num_factor),
  448. x_labels = unique(as.character(df$conc_num)),
  449. x_label = unique(df$Drug[1]),
  450. shape = 3,
  451. size = 0.6,
  452. position = "jitter"
  453. )
  454. # Add box plot configuration for this variable
  455. configs[[length(configs) + 1]] <- list(
  456. df = df,
  457. x_var = "conc_num_factor",
  458. y_var = variable,
  459. plot_type = "box",
  460. title = sprintf("%s %s (Boxplot)", df$OrfRep[1], df$Gene[1]),
  461. ylim_vals = var_info$ylim,
  462. annotations = annotations,
  463. error_bar = FALSE, # Boxplots typically don't need error bars
  464. x_breaks = unique(df$conc_num_factor),
  465. x_labels = unique(as.character(df$conc_num)),
  466. x_label = unique(df$Drug[1])
  467. )
  468. }
  469. return(configs)
  470. }
  471. # Adjust missing values and calculate ranks
  472. adjust_missing_and_rank <- function(df, variables) {
  473. # Adjust missing values in Avg_Zscore and Z_lm columns, and apply rank to the specified variables
  474. df <- df %>%
  475. mutate(across(all_of(variables), list(
  476. Avg_Zscore = ~ if_else(is.na(get(paste0("Avg_Zscore_", cur_column()))), 0.001, get(paste0("Avg_Zscore_", cur_column()))),
  477. Z_lm = ~ if_else(is.na(get(paste0("Z_lm_", cur_column()))), 0.001, get(paste0("Z_lm_", cur_column()))),
  478. Rank = ~ rank(get(paste0("Avg_Zscore_", cur_column()))),
  479. Rank_lm = ~ rank(get(paste0("Z_lm_", cur_column())))
  480. ), .names = "{fn}_{col}"))
  481. return(df)
  482. }
  483. generate_rank_plot_configs <- function(df, rank_var, zscore_var, var, is_lm = FALSE) {
  484. configs <- list()
  485. # Adjust titles for _lm plots if is_lm is TRUE
  486. plot_title_prefix <- if (is_lm) "Interaction Z score vs. Rank for" else "Average Z score vs. Rank for"
  487. # Annotated version (with text)
  488. for (sd_band in c(1, 2, 3)) {
  489. configs[[length(configs) + 1]] <- list(
  490. df = df,
  491. x_var = rank_var,
  492. y_var = zscore_var,
  493. plot_type = "rank",
  494. title = paste(plot_title_prefix, var, "above", sd_band, "SD"),
  495. sd_band = sd_band,
  496. enhancer_label = list(
  497. x = nrow(df) / 2, y = 10,
  498. label = paste("Deletion Enhancers =", nrow(df[df[[zscore_var]] >= sd_band, ]))
  499. ),
  500. suppressor_label = list(
  501. x = nrow(df) / 2, y = -10,
  502. label = paste("Deletion Suppressors =", nrow(df[df[[zscore_var]] <= -sd_band, ]))
  503. ),
  504. shape = 3,
  505. size = 0.1,
  506. position = "jitter"
  507. )
  508. }
  509. # Non-annotated version (_notext)
  510. for (sd_band in c(1, 2, 3)) {
  511. configs[[length(configs) + 1]] <- list(
  512. df = df,
  513. x_var = rank_var,
  514. y_var = zscore_var,
  515. plot_type = "rank",
  516. title = paste(plot_title_prefix, var, "above", sd_band, "SD"),
  517. sd_band = sd_band,
  518. enhancer_label = NULL, # No annotations for _notext
  519. suppressor_label = NULL, # No annotations for _notext
  520. shape = 3,
  521. size = 0.1,
  522. position = "jitter"
  523. )
  524. }
  525. return(configs)
  526. }
  527. generate_correlation_plot_configs <- function(df, variables) {
  528. configs <- list()
  529. for (variable in variables) {
  530. z_lm_var <- paste0("Z_lm_", variable)
  531. avg_zscore_var <- paste0("Avg_Zscore_", variable)
  532. lm_r_squared_col <- paste0("lm_R_squared_", variable)
  533. configs[[length(configs) + 1]] <- list(
  534. df = df,
  535. x_var = avg_zscore_var,
  536. y_var = z_lm_var,
  537. plot_type = "correlation",
  538. title = paste("Avg Zscore vs lm", variable),
  539. color_var = "Overlap",
  540. correlation_text = paste("R-squared =", round(df[[lm_r_squared_col]][1], 2)),
  541. shape = 3,
  542. geom_smooth = TRUE,
  543. legend_position = "right"
  544. )
  545. }
  546. return(configs)
  547. }
  548. main <- function() {
  549. lapply(names(args$experiments), function(exp_name) {
  550. exp <- args$experiments[[exp_name]]
  551. exp_path <- exp$path
  552. exp_sd <- exp$sd
  553. out_dir <- file.path(exp_path, "zscores")
  554. out_dir_qc <- file.path(exp_path, "zscores", "qc")
  555. dir.create(out_dir, recursive = TRUE, showWarnings = FALSE)
  556. dir.create(out_dir_qc, recursive = TRUE, showWarnings = FALSE)
  557. summary_vars <- c("L", "K", "r", "AUC", "delta_bg") # fields to filter and calculate summary stats across
  558. group_vars <- c("OrfRep", "conc_num", "conc_num_factor") # default fields to group by
  559. print_vars <- c("OrfRep", "Plate", "scan", "Col", "Row", "num", "OrfRep", "conc_num", "conc_num_factor",
  560. "delta_bg_tolerance", "delta_bg", "Gene", "L", "K", "r", "AUC", "NG", "DB")
  561. message("Loading and filtering data")
  562. df <- load_and_process_data(args$easy_results_file, sd = exp_sd)
  563. df <- update_gene_names(df, args$sgd_gene_list)
  564. df <- as_tibble(df)
  565. # Filter rows that are above tolerance for quality control plots
  566. df_above_tolerance <- df %>% filter(DB == 1)
  567. # Set L, r, K, AUC (and delta_bg?) to NA for rows that are above tolerance
  568. df_na <- df %>% mutate(across(all_of(summary_vars), ~ ifelse(DB == 1, NA, .)))
  569. # Remove rows with 0 values in L
  570. df_no_zeros <- df_na %>% filter(L > 0)
  571. # Save some constants
  572. max_conc <- max(df$conc_num_factor)
  573. l_half_median <- (median(df_above_tolerance$L, na.rm = TRUE)) / 2
  574. k_half_median <- (median(df_above_tolerance$K, na.rm = TRUE)) / 2
  575. message("Calculating summary statistics before quality control")
  576. ss <- calculate_summary_stats(df, summary_vars, group_vars = group_vars)
  577. df_ss <- ss$summary_stats
  578. df_stats <- ss$df_with_stats
  579. df_filtered_stats <- df_stats %>%
  580. {
  581. non_finite_rows <- filter(., if_any(c(L), ~ !is.finite(.)))
  582. if (nrow(non_finite_rows) > 0) {
  583. message("Removed the following non-finite rows:")
  584. print(non_finite_rows %>% select(any_of(print_vars)), n = 200)
  585. }
  586. filter(., if_all(c(L), is.finite))
  587. }
  588. message("Calculating summary statistics after quality control")
  589. ss <- calculate_summary_stats(df_na, summary_vars, group_vars = group_vars)
  590. df_na_ss <- ss$summary_stats
  591. df_na_stats <- ss$df_with_stats
  592. write.csv(df_na_ss, file = file.path(out_dir, "summary_stats_all_strains.csv"), row.names = FALSE)
  593. # Filter out non-finite rows for plotting
  594. df_na_filtered_stats <- df_na_stats %>%
  595. {
  596. non_finite_rows <- filter(., if_any(c(L), ~ !is.finite(.)))
  597. if (nrow(non_finite_rows) > 0) {
  598. message("Removed the following non-finite rows:")
  599. print(non_finite_rows %>% select(any_of(print_vars)), n = 200)
  600. }
  601. filter(., if_all(c(L), is.finite))
  602. }
  603. message("Calculating summary statistics after quality control excluding zero values")
  604. ss <- calculate_summary_stats(df_no_zeros, summary_vars, group_vars = group_vars)
  605. df_no_zeros_stats <- ss$df_with_stats
  606. df_no_zeros_filtered_stats <- df_no_zeros_stats %>%
  607. {
  608. non_finite_rows <- filter(., if_any(c(L), ~ !is.finite(.)))
  609. if (nrow(non_finite_rows) > 0) {
  610. message("Removed the following non-finite rows:")
  611. print(non_finite_rows %>% select(any_of(print_vars)), n = 200)
  612. }
  613. filter(., if_all(c(L), is.finite))
  614. }
  615. message("Filtering by 2SD of K")
  616. df_na_within_2sd_k <- df_na_stats %>%
  617. filter(K >= (mean_K - 2 * sd_K) & K <= (mean_K + 2 * sd_K))
  618. df_na_outside_2sd_k <- df_na_stats %>%
  619. filter(K < (mean_K - 2 * sd_K) | K > (mean_K + 2 * sd_K))
  620. message("Calculating summary statistics for L within 2SD of K")
  621. # TODO We're omitting the original z_max calculation, not sure if needed?
  622. ss <- calculate_summary_stats(df_na_within_2sd_k, "L", group_vars = c("conc_num", "conc_num_factor"))
  623. l_within_2sd_k_ss <- ss$summary_stats
  624. df_na_l_within_2sd_k_stats <- ss$df_with_stats
  625. write.csv(l_within_2sd_k_ss,
  626. file = file.path(out_dir_qc, "max_observed_L_vals_for_spots_within_2sd_K.csv"), row.names = FALSE)
  627. message("Calculating summary statistics for L outside 2SD of K")
  628. ss <- calculate_summary_stats(df_na_outside_2sd_k, "L", group_vars = c("conc_num", "conc_num_factor"))
  629. l_outside_2sd_k_ss <- ss$summary_stats
  630. df_na_l_outside_2sd_k_stats <- ss$df_with_stats
  631. write.csv(l_outside_2sd_k_ss,
  632. file = file.path(out_dir, "max_observed_L_vals_for_spots_outside_2sd_K.csv"), row.names = FALSE)
  633. # Each plots list corresponds to a file
  634. message("Generating QC plot configurations")
  635. l_vs_k_plots <- list(
  636. list(
  637. df = df,
  638. x_var = "L",
  639. y_var = "K",
  640. plot_type = "scatter",
  641. delta_bg_point = TRUE,
  642. title = "Raw L vs K before quality control",
  643. color_var = "conc_num",
  644. error_bar = FALSE,
  645. legend_position = "right"
  646. )
  647. )
  648. frequency_delta_bg_plots <- list(
  649. list(
  650. df = df_filtered_stats,
  651. x_var = "delta_bg",
  652. y_var = NULL,
  653. plot_type = "density",
  654. title = "Plate analysis by Drug Conc for Delta Background before quality control",
  655. color_var = "conc_num",
  656. x_label = "Delta Background",
  657. y_label = "Density",
  658. error_bar = FALSE,
  659. legend_position = "right"),
  660. list(
  661. df = df_filtered_stats,
  662. x_var = "delta_bg",
  663. y_var = NULL,
  664. plot_type = "bar",
  665. title = "Plate analysis by Drug Conc for Delta Background before quality control",
  666. color_var = "conc_num",
  667. x_label = "Delta Background",
  668. y_label = "Count",
  669. error_bar = FALSE,
  670. legend_position = "right")
  671. )
  672. above_threshold_plots <- list(
  673. list(
  674. df = df_above_tolerance,
  675. x_var = "L",
  676. y_var = "K",
  677. plot_type = "scatter",
  678. delta_bg_point = TRUE,
  679. title = paste("Raw L vs K for strains above Delta Background threshold of",
  680. df_above_tolerance$delta_bg_tolerance[[1]], "or above"),
  681. color_var = "conc_num",
  682. position = "jitter",
  683. annotations = list(
  684. x = l_half_median,
  685. y = k_half_median,
  686. label = paste("# strains above Delta Background tolerance =", nrow(df_above_tolerance))
  687. ),
  688. error_bar = FALSE,
  689. legend_position = "right"
  690. )
  691. )
  692. plate_analysis_plots <- list()
  693. for (var in summary_vars) {
  694. for (stage in c("before", "after")) {
  695. if (stage == "before") {
  696. df_plot <- df_filtered_stats
  697. } else {
  698. df_plot <- df_na_filtered_stats
  699. }
  700. config <- list(
  701. df = df_plot,
  702. x_var = "scan",
  703. y_var = var,
  704. plot_type = "scatter",
  705. title = paste("Plate analysis by Drug Conc for", var, stage, "quality control"),
  706. error_bar = TRUE,
  707. color_var = "conc_num",
  708. position = "jitter")
  709. plate_analysis_plots <- append(plate_analysis_plots, list(config))
  710. }
  711. }
  712. plate_analysis_boxplots <- list()
  713. for (var in summary_vars) {
  714. for (stage in c("before", "after")) {
  715. if (stage == "before") {
  716. df_plot <- df_filtered_stats
  717. } else {
  718. df_plot <- df_na_filtered_stats
  719. }
  720. config <- list(
  721. df = df_plot,
  722. x_var = "scan",
  723. y_var = var,
  724. plot_type = "box",
  725. title = paste("Plate analysis by Drug Conc for", var, stage, "quality control"),
  726. error_bar = FALSE, color_var = "conc_num")
  727. plate_analysis_boxplots <- append(plate_analysis_boxplots, list(config))
  728. }
  729. }
  730. plate_analysis_no_zeros_plots <- list()
  731. for (var in summary_vars) {
  732. config <- list(
  733. df = df_no_zeros_filtered_stats,
  734. x_var = "scan",
  735. y_var = var,
  736. plot_type = "scatter",
  737. title = paste("Plate analysis by Drug Conc for", var, "after quality control"),
  738. error_bar = TRUE,
  739. color_var = "conc_num",
  740. position = "jitter")
  741. plate_analysis_no_zeros_plots <- append(plate_analysis_no_zeros_plots, list(config))
  742. }
  743. plate_analysis_no_zeros_boxplots <- list()
  744. for (var in summary_vars) {
  745. config <- list(
  746. df = df_no_zeros_filtered_stats,
  747. x_var = "scan",
  748. y_var = var,
  749. plot_type = "box",
  750. title = paste("Plate analysis by Drug Conc for", var, "after quality control"),
  751. error_bar = FALSE,
  752. color_var = "conc_num"
  753. )
  754. plate_analysis_no_zeros_boxplots <- append(plate_analysis_no_zeros_boxplots, list(config))
  755. }
  756. l_outside_2sd_k_plots <- list(
  757. list(
  758. df = df_na_l_outside_2sd_k_stats,
  759. x_var = "L",
  760. y_var = "K",
  761. plot_type = "scatter",
  762. delta_bg_point = TRUE,
  763. title = "Raw L vs K for strains falling outside 2SD of the K mean at each Conc",
  764. color_var = "conc_num",
  765. position = "jitter",
  766. legend_position = "right"
  767. )
  768. )
  769. delta_bg_outside_2sd_k_plots <- list(
  770. list(
  771. df = df_na_l_outside_2sd_k_stats,
  772. x_var = "delta_bg",
  773. y_var = "K",
  774. plot_type = "scatter",
  775. gene_point = TRUE,
  776. title = "Delta Background vs K for strains falling outside 2SD of the K mean at each Conc",
  777. color_var = "conc_num",
  778. position = "jitter",
  779. legend_position = "right"
  780. )
  781. )
  782. message("Generating QC plots")
  783. generate_and_save_plots(out_dir_qc, "L_vs_K_before_quality_control", l_vs_k_plots)
  784. generate_and_save_plots(out_dir_qc, "frequency_delta_background", frequency_delta_bg_plots)
  785. generate_and_save_plots(out_dir_qc, "L_vs_K_above_threshold", above_threshold_plots)
  786. generate_and_save_plots(out_dir_qc, "plate_analysis", plate_analysis_plots)
  787. generate_and_save_plots(out_dir_qc, "plate_analysis_boxplots", plate_analysis_boxplots)
  788. generate_and_save_plots(out_dir_qc, "plate_analysis_no_zeros", plate_analysis_no_zeros_plots)
  789. generate_and_save_plots(out_dir_qc, "plate_analysis_no_zeros_boxplots", plate_analysis_no_zeros_boxplots)
  790. generate_and_save_plots(out_dir_qc, "L_vs_K_for_strains_2SD_outside_mean_K", l_outside_2sd_k_plots)
  791. generate_and_save_plots(out_dir_qc, "delta_background_vs_K_for_strains_2sd_outside_mean_K", delta_bg_outside_2sd_k_plots)
  792. # Clean up
  793. rm(df, df_above_tolerance, df_no_zeros)
  794. # TODO: Originally this filtered L NA's
  795. # Let's try to avoid for now since stats have already been calculated
  796. # Process background strains
  797. bg_strains <- c("YDL227C")
  798. lapply(bg_strains, function(strain) {
  799. message("Processing background strain: ", strain)
  800. # Handle missing data by setting zero values to NA
  801. # and then removing any rows with NA in L col
  802. df_bg <- df_na %>%
  803. filter(OrfRep == strain) %>%
  804. mutate(
  805. L = if_else(L == 0, NA, L),
  806. K = if_else(K == 0, NA, K),
  807. r = if_else(r == 0, NA, r),
  808. AUC = if_else(AUC == 0, NA, AUC)
  809. ) %>%
  810. filter(!is.na(L))
  811. # Recalculate summary statistics for the background strain
  812. message("Calculating summary statistics for background strain")
  813. ss_bg <- calculate_summary_stats(df_bg, summary_vars, group_vars = group_vars)
  814. summary_stats_bg <- ss_bg$summary_stats
  815. # df_bg_stats <- ss_bg$df_with_stats
  816. write.csv(summary_stats_bg,
  817. file = file.path(out_dir, paste0("SummaryStats_BackgroundStrains_", strain, ".csv")),
  818. row.names = FALSE)
  819. # Filter reference and deletion strains
  820. # Formerly X2_RF (reference strains)
  821. df_reference <- df_na_stats %>%
  822. filter(OrfRep == strain) %>%
  823. mutate(SM = 0)
  824. # Formerly X2 (deletion strains)
  825. df_deletion <- df_na_stats %>%
  826. filter(OrfRep != strain) %>%
  827. mutate(SM = 0)
  828. # Set the missing values to the highest theoretical value at each drug conc for L
  829. # Leave other values as 0 for the max/min
  830. reference_strain <- df_reference %>%
  831. group_by(conc_num) %>%
  832. mutate(
  833. max_l_theoretical = max(max_L, na.rm = TRUE),
  834. L = ifelse(L == 0 & !is.na(L) & conc_num > 0, max_l_theoretical, L),
  835. SM = ifelse(L >= max_l_theoretical & !is.na(L) & conc_num > 0, 1, SM),
  836. L = ifelse(L >= max_l_theoretical & !is.na(L) & conc_num > 0, max_l_theoretical, L)) %>%
  837. ungroup()
  838. # Ditto for deletion strains
  839. deletion_strains <- df_deletion %>%
  840. group_by(conc_num) %>%
  841. mutate(
  842. max_l_theoretical = max(max_L, na.rm = TRUE),
  843. L = ifelse(L == 0 & !is.na(L) & conc_num > 0, max_l_theoretical, L),
  844. SM = ifelse(L >= max_l_theoretical & !is.na(L) & conc_num > 0, 1, SM),
  845. L = ifelse(L >= max_l_theoretical & !is.na(L) & conc_num > 0, max_l_theoretical, L)) %>%
  846. ungroup()
  847. # Calculate interactions
  848. interaction_vars <- c("L", "K", "r", "AUC")
  849. message("Calculating interaction scores")
  850. # print("Reference strain:")
  851. # print(head(reference_strain))
  852. reference_results <- calculate_interaction_scores(reference_strain, max_conc, interaction_vars)
  853. # print("Deletion strains:")
  854. # print(head(deletion_strains))
  855. deletion_results <- calculate_interaction_scores(deletion_strains, max_conc, interaction_vars)
  856. zscores_calculations_reference <- reference_results$calculations
  857. zscores_interactions_reference <- reference_results$interactions
  858. zscores_calculations <- deletion_results$calculations
  859. zscores_interactions <- deletion_results$interactions
  860. # Writing Z-Scores to file
  861. write.csv(zscores_calculations_reference, file = file.path(out_dir, "RF_ZScores_Calculations.csv"), row.names = FALSE)
  862. write.csv(zscores_calculations, file = file.path(out_dir, "ZScores_Calculations.csv"), row.names = FALSE)
  863. write.csv(zscores_interactions_reference, file = file.path(out_dir, "RF_ZScores_Interaction.csv"), row.names = FALSE)
  864. write.csv(zscores_interactions, file = file.path(out_dir, "ZScores_Interaction.csv"), row.names = FALSE)
  865. # Create interaction plots
  866. reference_plot_configs <- generate_interaction_plot_configs(df_reference, interaction_vars)
  867. deletion_plot_configs <- generate_interaction_plot_configs(df_deletion, interaction_vars)
  868. generate_and_save_plots(out_dir, "RF_interactionPlots", reference_plot_configs, grid_layout = list(ncol = 4, nrow = 3))
  869. generate_and_save_plots(out_dir, "InteractionPlots", deletion_plot_configs, grid_layout = list(ncol = 4, nrow = 3))
  870. # Define conditions for enhancers and suppressors
  871. # TODO Add to study config file?
  872. threshold <- 2
  873. enhancer_condition_L <- zscores_interactions$Avg_Zscore_L >= threshold
  874. suppressor_condition_L <- zscores_interactions$Avg_Zscore_L <= -threshold
  875. enhancer_condition_K <- zscores_interactions$Avg_Zscore_K >= threshold
  876. suppressor_condition_K <- zscores_interactions$Avg_Zscore_K <= -threshold
  877. # Subset data
  878. enhancers_L <- zscores_interactions[enhancer_condition_L, ]
  879. suppressors_L <- zscores_interactions[suppressor_condition_L, ]
  880. enhancers_K <- zscores_interactions[enhancer_condition_K, ]
  881. suppressors_K <- zscores_interactions[suppressor_condition_K, ]
  882. # Save enhancers and suppressors
  883. message("Writing enhancer/suppressor csv files")
  884. write.csv(enhancers_L, file = file.path(out_dir, "ZScores_Interaction_Deletion_Enhancers_L.csv"), row.names = FALSE)
  885. write.csv(suppressors_L, file = file.path(out_dir, "ZScores_Interaction_Deletion_Suppressors_L.csv"), row.names = FALSE)
  886. write.csv(enhancers_K, file = file.path(out_dir, "ZScores_Interaction_Deletion_Enhancers_K.csv"), row.names = FALSE)
  887. write.csv(suppressors_K, file = file.path(out_dir, "ZScores_Interaction_Deletion_Suppressors_K.csv"), row.names = FALSE)
  888. # Combine conditions for enhancers and suppressors
  889. enhancers_and_suppressors_L <- zscores_interactions[enhancer_condition_L | suppressor_condition_L, ]
  890. enhancers_and_suppressors_K <- zscores_interactions[enhancer_condition_K | suppressor_condition_K, ]
  891. # Save combined enhancers and suppressors
  892. write.csv(enhancers_and_suppressors_L,
  893. file = file.path(out_dir, "ZScores_Interaction_Deletion_Enhancers_and_Suppressors_L.csv"), row.names = FALSE)
  894. write.csv(enhancers_and_suppressors_K,
  895. file = file.path(out_dir, "ZScores_Interaction_Deletion_Enhancers_and_Suppressors_K.csv"), row.names = FALSE)
  896. # Handle linear model based enhancers and suppressors
  897. lm_threshold <- 2
  898. enhancers_lm_L <- zscores_interactions[zscores_interactions$Z_lm_L >= lm_threshold, ]
  899. suppressors_lm_L <- zscores_interactions[zscores_interactions$Z_lm_L <= -lm_threshold, ]
  900. enhancers_lm_K <- zscores_interactions[zscores_interactions$Z_lm_K >= lm_threshold, ]
  901. suppressors_lm_K <- zscores_interactions[zscores_interactions$Z_lm_K <= -lm_threshold, ]
  902. # Save linear model based enhancers and suppressors
  903. message("Writing linear model enhancer/suppressor csv files")
  904. write.csv(enhancers_lm_L,
  905. file = file.path(out_dir, "ZScores_Interaction_Deletion_Enhancers_L_lm.csv"), row.names = FALSE)
  906. write.csv(suppressors_lm_L,
  907. file = file.path(out_dir, "ZScores_Interaction_Deletion_Suppressors_L_lm.csv"), row.names = FALSE)
  908. write.csv(enhancers_lm_K,
  909. file = file.path(out_dir, "ZScores_Interaction_Deletion_Enhancers_K_lm.csv"), row.names = FALSE)
  910. write.csv(suppressors_lm_K,
  911. file = file.path(out_dir, "ZScores_Interaction_Deletion_Suppressors_K_lm.csv"), row.names = FALSE)
  912. # TODO needs explanation
  913. zscores_interactions_adjusted <- adjust_missing_and_rank(zscores_interactions)
  914. rank_plot_configs <- c(
  915. generate_rank_plot_configs(zscores_interactions_adjusted, "Rank_L", "Avg_Zscore_L", "L"),
  916. generate_rank_plot_configs(zscores_interactions_adjusted, "Rank_K", "Avg_Zscore_K", "K")
  917. )
  918. generate_and_save_plots(output_dir = out_dir, file_name = "RankPlots",
  919. plot_configs = rank_plot_configs, grid_layout = list(ncol = 3, nrow = 2))
  920. rank_lm_plot_config <- c(
  921. generate_rank_plot_configs(zscores_interactions_adjusted, "Rank_lm_L", "Z_lm_L", "L", is_lm = TRUE),
  922. generate_rank_plot_configs(zscores_interactions_adjusted, "Rank_lm_K", "Z_lm_K", "K", is_lm = TRUE)
  923. )
  924. generate_and_save_plots(output_dir = out_dir, file_name = "RankPlots_lm",
  925. plot_configs = rank_lm_plot_config, grid_layout = list(ncol = 3, nrow = 2))
  926. # Formerly X_NArm
  927. zscores_interactions_filtered <- zscores_interactions %>%
  928. group_by(across(all_of(group_vars))) %>%
  929. filter(!is.na(Z_lm_L) | !is.na(Avg_Zscore_L))
  930. # Final filtered correlation calculations and plots
  931. zscores_interactions_filtered <- zscores_interactions_filtered %>%
  932. mutate(
  933. Overlap = case_when(
  934. Z_lm_L >= 2 & Avg_Zscore_L >= 2 ~ "Deletion Enhancer Both",
  935. Z_lm_L <= -2 & Avg_Zscore_L <= -2 ~ "Deletion Suppressor Both",
  936. Z_lm_L >= 2 & Avg_Zscore_L <= 2 ~ "Deletion Enhancer lm only",
  937. Z_lm_L <= -2 & Avg_Zscore_L >= -2 ~ "Deletion Suppressor lm only",
  938. Z_lm_L >= 2 & Avg_Zscore_L <= -2 ~ "Deletion Enhancer lm, Deletion Suppressor Avg Z score",
  939. Z_lm_L <= -2 & Avg_Zscore_L >= 2 ~ "Deletion Suppressor lm, Deletion Enhancer Avg Z score",
  940. TRUE ~ "No Effect"
  941. ),
  942. lm_R_squared_L = summary(lm(Z_lm_L ~ Avg_Zscore_L))$r.squared,
  943. lm_R_squared_K = summary(lm(Z_lm_K ~ Avg_Zscore_K))$r.squared,
  944. lm_R_squared_r = summary(lm(Z_lm_r ~ Avg_Zscore_r))$r.squared,
  945. lm_R_squared_AUC = summary(lm(Z_lm_AUC ~ Avg_Zscore_AUC))$r.squared
  946. ) %>%
  947. ungroup()
  948. rank_plot_configs <- c(
  949. generate_rank_plot_configs(zscores_interactions_filtered, "Rank_L", "Avg_Zscore_L", "L"),
  950. generate_rank_plot_configs(zscores_interactions_filtered, "Rank_K", "Avg_Zscore_K", "K")
  951. )
  952. generate_and_save_plots(output_dir = out_dir, file_name = "RankPlots",
  953. plot_configs = rank_plot_configs, grid_layout = list(ncol = 3, nrow = 2))
  954. rank_lm_plot_configs <- c(
  955. generate_rank_plot_configs(zscores_interactions_filtered, "Rank_lm_L", "Z_lm_L", "L", is_lm = TRUE),
  956. generate_rank_plot_configs(zscores_interactions_filtered, "Rank_lm_K", "Z_lm_K", "K", is_lm = TRUE)
  957. )
  958. generate_and_save_plots(output_dir = out_dir, file_name = "RankPlots_lm",
  959. plot_configs = rank_lm_plot_configs, grid_layout = list(ncol = 3, nrow = 2))
  960. correlation_plot_configs <- generate_correlation_plot_configs(zscores_interactions_filtered, interaction_vars)
  961. generate_and_save_plots(output_dir = out_dir, file_name = "Avg_Zscore_vs_lm_NA_rm",
  962. plot_configs = correlation_plot_configs, grid_layout = list(ncol = 2, nrow = 2))
  963. })
  964. })
  965. }
  966. main()