mirrors/envision
0
0
Fork 0
mirror of https://gitlab.com/gabmus/envision.git synced 2025-08-12 19:18:58 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

chore: remove unused code

Browse source
This commit is contained in:
Gabriele Musco 2024-08-11 09:09:34 +02:00
commit 1113b78be5
2 changed files with 0 additions and 94 deletions
Download patch file Download diff file Expand all files Collapse all files

1
src/main.rs
View file

@ -39,7 +39,6 @@ pub mod paths;
pub mod profile;
pub mod profiles;
pub mod runner;
pub mod runner_pipeline;
pub mod steam_linux_runtime_injector;
pub mod steamvr_utils;
pub mod termcolor;

93
src/runner_pipeline.rs
View file

@ -1,93 +0,0 @@
use crate::runner::{Runner, RunnerStatus};
use std::cell::RefCell;
pub struct RunnerPipeline {
runners: Vec<RefCell<Box<dyn Runner>>>,
current_index: usize,
last_exit_status: Option<i32>,
has_started: bool,
pub log: Vec<String>,
}
impl RunnerPipeline {
pub fn new(runners: Vec<Box<dyn Runner>>) -> Self {
let mut c_runners: Vec<RefCell<Box<dyn Runner>>> = vec![];
for runner in runners {
c_runners.push(RefCell::new(runner));
}
Self {
runners: c_runners,
current_index: 0,
has_started: false,
last_exit_status: None,
log: vec![],
}
}
pub fn get_current_runner(&self) -> Option<&RefCell<Box<dyn Runner>>> {
self.runners.get(self.current_index)
}
pub fn start(&mut self) {
if self.has_started {
return;
}
self.has_started = true;
if let Some(runner) = self.get_current_runner() {
runner.borrow_mut().start();
}
}
pub fn update(&mut self) {
if !self.has_started {
return;
}
match self.get_current_runner() {
None => {}
Some(c_runner) => {
let (status, log) = {
let mut runner = c_runner.borrow_mut();
(runner.status(), runner.consume_rows())
};
self.log.extend(log);
match status {
RunnerStatus::Running => {}
RunnerStatus::Stopped(ecode) => {
match ecode {
None => {} // should never get here
Some(0) => {
self.last_exit_status = Some(0);
self.current_index += 1;
match self.get_current_runner() {
None => {}
Some(c_runner) => {
c_runner.borrow_mut().start();
}
}
}
Some(nonzero) => {
self.last_exit_status = Some(nonzero);
// interrupting pipeline by going past last runner
self.current_index = self.runners.len();
}
}
}
}
}
}
}
pub fn get_log(&mut self) -> Vec<String> {
let log = self.log.to_owned();
self.log = vec![];
log
}
pub fn status(&self) -> RunnerStatus {
match self.get_current_runner() {
None => RunnerStatus::Stopped(self.last_exit_status),
Some(_) => RunnerStatus::Running,
}
}
}