Commit 30091a5

committed

Implement pipe handling

1 parent 0d68c73 commit 30091a5Copy full SHA for 30091a5

File tree

+22

-3

lines changed

+22

-3

lines changed

Lines changed: 3 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -48,3 +48,6 @@ features = ["precommit-hook", "user-hooks"]`
`48`	`48`
`49`	`49`	`[features]`
`50`	`50`	`pym = ["pyo3"]`
	`51`	`+`
	`52`	`+[target.'cfg(target_family = "unix")'.dependencies]`
	`53`	`+nix = "0.17.0"`

Lines changed: 16 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -9,8 +9,24 @@ use crate::{`
`9`	`9`	`};`
`10`	`10`	`use clap::{crate_name, crate_version, App, AppSettings};`
`11`	`11`
	`12`	`+/// This should be called before calling any cli method or printing any output.`
	`13`	`+pub fn reset_signal_pipe_handler() -> Result<(), ()> {`
	`14`	`+ #[cfg(target_family = "unix")]`
	`15`	`+ {`
	`16`	`+ use nix::sys::signal;`
	`17`	`+`
	`18`	`+ unsafe {`
	`19`	`+ signal::signal(signal::Signal::SIGPIPE, signal::SigHandler::SigDfl)`
	`20`	`+ .map_err(\|e\| println!("{:?}", e))?;`
	`21`	`+ }`
	`22`	`+ }`
	`23`	`+`
	`24`	`+ Ok(())`
	`25`	`+}`
	`26`	`+`
`12`	`27`	`/// Get maches`
`13`	`28`	`pub async fn main() -> Result<(), Error> {`
	`29`	`+ let _ = reset_signal_pipe_handler();`
`14`	`30`	`let m = App::new(crate_name!())`
`15`	`31`	`.version(crate_version!())`
`16`	`32`	`.about("May the Code be with You 👻")`

Lines changed: 3 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -37,6 +37,7 @@ use super::Command;`
`37`	`37`	`use crate::{cache::Cache, err::Error, helper::Digit};`
`38`	`38`	`use async_trait::async_trait;`
`39`	`39`	`use clap::{App, Arg, ArgMatches, SubCommand};`
	`40`	`+use std::io::{self, Write};`
`40`	`41`	/// Abstract `list` command
`41`	`42`	`///`
`42`	`43`	`/// ## handler`
`@@ -168,9 +169,8 @@ impl Command for ListCommand {`
`168`	`169`	`ps.retain(\|x\| x.name.contains(&keyword));`
`169`	`170`	`}`
`170`	`171`
`171`		`- for p in &ps {`
`172`		`- println!("{}", p);`
`173`		`- }`
	`172`	`+ let out: Vec<String> = ps.iter().map(ToString::to_string).collect();`
	`173`	`+ io::stdout().write_all(out.join("\n").as_bytes())?;`
`174`	`174`
`175`	`175`	`// one more thing, filter stat`
`176`	`176`	`if m.is_present("stat") {`

Comments

(0)