mirror of
https://github.com/Noratrieb/service-manager.git
synced 2026-01-17 01:45:05 +01:00
testing things (rollback to here if it breaks again)
This commit is contained in:
parent
2a2759c020
commit
072deb19c1
1 changed files with 40 additions and 1 deletions
41
src/main.rs
41
src/main.rs
|
|
@ -7,7 +7,9 @@ use crossterm::execute;
|
||||||
use crossterm::terminal::{
|
use crossterm::terminal::{
|
||||||
disable_raw_mode, enable_raw_mode, EnterAlternateScreen, LeaveAlternateScreen,
|
disable_raw_mode, enable_raw_mode, EnterAlternateScreen, LeaveAlternateScreen,
|
||||||
};
|
};
|
||||||
use std::io::StdoutLock;
|
use std::io::{ErrorKind, Read, StdoutLock};
|
||||||
|
use std::process::Stdio;
|
||||||
|
use std::time::Duration;
|
||||||
use std::{env, fs, io};
|
use std::{env, fs, io};
|
||||||
use tui::backend::CrosstermBackend;
|
use tui::backend::CrosstermBackend;
|
||||||
use tui::Terminal;
|
use tui::Terminal;
|
||||||
|
|
@ -16,6 +18,43 @@ use crate::model::config::Config;
|
||||||
use crate::model::App;
|
use crate::model::App;
|
||||||
|
|
||||||
fn main() {
|
fn main() {
|
||||||
|
///// ------------------------ TEST START ------------------------
|
||||||
|
|
||||||
|
let mut cmd = std::process::Command::new("sh");
|
||||||
|
|
||||||
|
let mut child = cmd
|
||||||
|
.stdout(Stdio::piped())
|
||||||
|
.args(&["-c", "echo hello"])
|
||||||
|
.spawn()
|
||||||
|
.unwrap();
|
||||||
|
|
||||||
|
let mut stdout = child.stdout.take().unwrap(); // std::fs::File::open("config.toml").unwrap();
|
||||||
|
std::thread::spawn(move || {
|
||||||
|
let mut buf = [0; 1024];
|
||||||
|
|
||||||
|
println!("{}", buf.len());
|
||||||
|
|
||||||
|
// stdout.read_to_end(&mut buf);
|
||||||
|
|
||||||
|
// println!("{}", String::from_utf8_lossy(&buf).as_ref());
|
||||||
|
|
||||||
|
// return;
|
||||||
|
|
||||||
|
loop {
|
||||||
|
match stdout.read(&mut buf) {
|
||||||
|
Ok(0) => break,
|
||||||
|
Ok(_) => println!("READ: now `{}`", String::from_utf8(buf.to_vec()).unwrap()),
|
||||||
|
Err(e) if e.kind() == ErrorKind::Interrupted => continue,
|
||||||
|
Err(e) => eprintln!("error: {}", e),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
println!("done!");
|
||||||
|
});
|
||||||
|
|
||||||
|
std::thread::sleep(Duration::from_secs(3454233));
|
||||||
|
|
||||||
|
///// ------------------------ TEST END ------------------------
|
||||||
|
|
||||||
let file_path = env::args()
|
let file_path = env::args()
|
||||||
.nth(1)
|
.nth(1)
|
||||||
.or_else(|| env::var("SERVICE_MANAGER_CONFIG_PATH").ok())
|
.or_else(|| env::var("SERVICE_MANAGER_CONFIG_PATH").ok())
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue