1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78
use crate::prelude::*; use nu_engine::WholeStreamCommand; use nu_errors::ShellError; use nu_protocol::{Signature, SyntaxShape, UntaggedValue, Value}; use nu_source::Tagged; pub struct Compact; pub struct CompactArgs { columns: Vec<Tagged<String>>, } impl WholeStreamCommand for Compact { fn name(&self) -> &str { "compact" } fn signature(&self) -> Signature { Signature::build("compact").rest(SyntaxShape::Any, "the columns to compact from the table") } fn usage(&self) -> &str { "Creates a table with non-empty rows." } fn run(&self, args: CommandArgs) -> Result<OutputStream, ShellError> { compact(args) } fn examples(&self) -> Vec<Example> { vec![Example { description: "Filter out all directory entries having no 'target'", example: "ls -la | compact target", result: None, }] } } pub fn compact(args: CommandArgs) -> Result<OutputStream, ShellError> { let (args, input) = ( CompactArgs { columns: args.rest(0)?, }, args.input, ); Ok(input .filter(move |item| { if args.columns.is_empty() { !item.is_empty() } else if let Value { value: UntaggedValue::Row(ref r), .. } = item { args.columns .iter() .all(|field| r.get_data(field).borrow().is_some()) } else { false } }) .into_output_stream()) } #[cfg(test)] mod tests { use super::Compact; use super::ShellError; #[test] fn examples_work_as_expected() -> Result<(), ShellError> { use crate::examples::test as test_examples; test_examples(Compact {}) } }