|
|
|
@@ -34,7 +34,11 @@ parse_metadata <- function(metadata) {
|
|
|
|
#' @return A \code{character} containing the gene sequence
|
|
|
|
#' @return A \code{character} containing the gene sequence
|
|
|
|
match_id_sequence <- function(names, vdj_segments, id) {
|
|
|
|
match_id_sequence <- function(names, vdj_segments, id) {
|
|
|
|
matches <- grep(names, pattern = id)
|
|
|
|
matches <- grep(names, pattern = id)
|
|
|
|
|
|
|
|
if(id == "TRBJ2-2"){
|
|
|
|
|
|
|
|
row <- matches[2]
|
|
|
|
|
|
|
|
} else {
|
|
|
|
row <- matches[1]
|
|
|
|
row <- matches[1]
|
|
|
|
|
|
|
|
}
|
|
|
|
return(as.character(vdj_segments[row]))
|
|
|
|
return(as.character(vdj_segments[row]))
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@@ -106,8 +110,9 @@ get_cys_coordinates <- function(alignment) {
|
|
|
|
insertion <- unlist(Biostrings::insertion(alignment))
|
|
|
|
insertion <- unlist(Biostrings::insertion(alignment))
|
|
|
|
deletion <- unlist(Biostrings::deletion(alignment))
|
|
|
|
deletion <- unlist(Biostrings::deletion(alignment))
|
|
|
|
delta_coordinates <- handle_indels(insertion, deletion, cys, alignment)
|
|
|
|
delta_coordinates <- handle_indels(insertion, deletion, cys, alignment)
|
|
|
|
cys_start <- cys$start + delta_coordinates$start
|
|
|
|
read_start <- unlist(start(Biostrings::Views(alignment)))
|
|
|
|
cys_end <- cys$end + delta_coordinates$end
|
|
|
|
cys_start <- cys$start + delta_coordinates$start + read_start - 1
|
|
|
|
|
|
|
|
cys_end <- cys$end + delta_coordinates$end + read_start
|
|
|
|
return(list("start" = cys_start, "end" = cys_end))
|
|
|
|
return(list("start" = cys_start, "end" = cys_end))
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@@ -126,7 +131,7 @@ get_hvr_sequences <- function(sequences, vdj_segments, cores = detectCores()) {
|
|
|
|
)
|
|
|
|
)
|
|
|
|
cys_coordinates <- parallel::mclapply(v_alignment, FUN = get_cys_coordinates)
|
|
|
|
cys_coordinates <- parallel::mclapply(v_alignment, FUN = get_cys_coordinates)
|
|
|
|
cys_df <- as.data.frame(do.call(rbind, cys_coordinates))
|
|
|
|
cys_df <- as.data.frame(do.call(rbind, cys_coordinates))
|
|
|
|
remaining <- Biostrings::subseq(sequences, start = unlist(cys_df$end))
|
|
|
|
remaining <- Biostrings::subseq(sequences, start = unlist(cys_df$end) + 1)
|
|
|
|
j_alignment <- parallel::mcmapply(remaining,
|
|
|
|
j_alignment <- parallel::mcmapply(remaining,
|
|
|
|
df$j_seq,
|
|
|
|
df$j_seq,
|
|
|
|
FUN = align_sequence,
|
|
|
|
FUN = align_sequence,
|
|
|
|
@@ -145,4 +150,4 @@ get_hvr_sequences <- function(sequences, vdj_segments, cores = detectCores()) {
|
|
|
|
|
|
|
|
|
|
|
|
data <- parse_data(file = "data/curesim_sequence.fastq")
|
|
|
|
data <- parse_data(file = "data/curesim_sequence.fastq")
|
|
|
|
hvr <- get_hvr_sequences(sequences = data[[1]], vdj_segments = data[[2]])
|
|
|
|
hvr <- get_hvr_sequences(sequences = data[[1]], vdj_segments = data[[2]])
|
|
|
|
Biostrings::writeXStringSet(hvr, "data/CuReSim-HVR.fastq", format = "fastq")
|
|
|
|
Biostrings::writeXStringSet(hvr, "data/curesim-HVR.fastq", format = "fastq")
|
|
|
|
|