Mirrors/nushell
2
0
Fork 0
mirror of https://github.com/nushell/nushell synced 2024-12-28 22:13:10 +00:00
Code Issues Projects Releases Packages Wiki Activity

Update the rest of into

Browse source
This commit is contained in:
JT 2021-11-05 17:57:24 +13:00
parent 183d200b9f
commit 5837cdb3f1
3 changed files with 86 additions and 100 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

47
crates/nu-command/src/conversions/into/binary.rs
View file

@ -1,5 +1,6 @@
use nu_engine::CallExt;
use nu_protocol::{ use nu_protocol::{
ast::Call, ast::{Call, CellPath},
engine::{Command, EngineState, Stack}, engine::{Command, EngineState, Stack},
Example, PipelineData, ShellError, Signature, Span, SyntaxShape, Value, Example, PipelineData, ShellError, Signature, Span, SyntaxShape, Value,
}; };
@ -27,11 +28,11 @@ impl Command for SubCommand {
fn run( fn run(
&self, &self,
engine_state: &EngineState, engine_state: &EngineState,
_stack: &mut Stack, stack: &mut Stack,
call: &Call, call: &Call,
input: PipelineData, input: PipelineData,
) -> Result<nu_protocol::PipelineData, nu_protocol::ShellError> { ) -> Result<nu_protocol::PipelineData, nu_protocol::ShellError> {
into_binary(engine_state, call, input) into_binary(engine_state, stack, call, input)
} }
fn examples(&self) -> Vec<Example> { fn examples(&self) -> Vec<Example> {
@ -87,27 +88,29 @@ impl Command for SubCommand {
fn into_binary( fn into_binary(
engine_state: &EngineState, engine_state: &EngineState,
stack: &mut Stack,
call: &Call, call: &Call,
input: PipelineData, input: PipelineData,
) -> Result<nu_protocol::PipelineData, nu_protocol::ShellError> { ) -> Result<nu_protocol::PipelineData, nu_protocol::ShellError> {
let head = call.head; let head = call.head;
// let column_paths: Vec<CellPath> = call.rest(context, 0)?; let column_paths: Vec<CellPath> = call.rest(engine_state, stack, 0)?;
input.map( input.map(
move |v| { move |v| {
action(v, head) if column_paths.is_empty() {
// FIXME: Add back in cell_path support action(&v, head)
// if column_paths.is_empty() { } else {
// action(v, head) let mut ret = v;
// } else { for path in &column_paths {
// let mut ret = v; let r =
// for path in &column_paths { ret.update_cell_path(&path.members, Box::new(move |old| action(old, head)));
// ret = if let Err(error) = r {
// ret.swap_data_by_cell_path(path, Box::new(move |old| action(old, old.tag())))?; return Value::Error { error };
// } }
}
// Ok(ret) ret
// } }
}, },
engine_state.ctrlc.clone(), engine_state.ctrlc.clone(),
) )
@ -129,19 +132,19 @@ fn float_to_endian(n: f64) -> Vec<u8> {
} }
} }
pub fn action(input: Value, span: Span) -> Value { pub fn action(input: &Value, span: Span) -> Value {
match input { match input {
Value::Binary { .. } => input, Value::Binary { .. } => input.clone(),
Value::Int { val, .. } => Value::Binary { Value::Int { val, .. } => Value::Binary {
val: int_to_endian(val), val: int_to_endian(*val),
span, span,
}, },
Value::Float { val, .. } => Value::Binary { Value::Float { val, .. } => Value::Binary {
val: float_to_endian(val), val: float_to_endian(*val),
span, span,
}, },
Value::Filesize { val, .. } => Value::Binary { Value::Filesize { val, .. } => Value::Binary {
val: int_to_endian(val), val: int_to_endian(*val),
span, span,
}, },
Value::String { val, .. } => Value::Binary { Value::String { val, .. } => Value::Binary {
@ -149,7 +152,7 @@ pub fn action(input: Value, span: Span) -> Value {
span, span,
}, },
Value::Bool { val, .. } => Value::Binary { Value::Bool { val, .. } => Value::Binary {
val: int_to_endian(if val { 1i64 } else { 0 }), val: int_to_endian(if *val { 1i64 } else { 0 }),
span, span,
}, },
Value::Date { val, .. } => Value::Binary { Value::Date { val, .. } => Value::Binary {

94
crates/nu-command/src/conversions/into/filesize.rs
View file

@ -1,5 +1,6 @@
use nu_engine::CallExt;
use nu_protocol::{ use nu_protocol::{
ast::Call, ast::{Call, CellPath},
engine::{Command, EngineState, Stack}, engine::{Command, EngineState, Stack},
Example, PipelineData, ShellError, Signature, Span, SyntaxShape, Value, Example, PipelineData, ShellError, Signature, Span, SyntaxShape, Value,
}; };
@ -27,56 +28,20 @@ impl Command for SubCommand {
fn run( fn run(
&self, &self,
engine_state: &EngineState, engine_state: &EngineState,
_stack: &mut Stack, stack: &mut Stack,
call: &Call, call: &Call,
input: PipelineData, input: PipelineData,
) -> Result<nu_protocol::PipelineData, nu_protocol::ShellError> { ) -> Result<nu_protocol::PipelineData, nu_protocol::ShellError> {
into_filesize(engine_state, call, input) into_filesize(engine_state, stack, call, input)
} }
fn examples(&self) -> Vec<Example> { fn examples(&self) -> Vec<Example> {
vec![ vec![
// Example { Example {
// description: "Convert string to filesize in table", description: "Convert string to filesize in table",
// example: "[[bytes]; ['5'] [3.2] [4] [2kb]] | into filesize bytes", example: "[[bytes]; ['5'] [3.2] [4] [2kb]] | into filesize bytes",
// result: Some(Value::List { result: None,
// vals: vec![ },
// Value::Record {
// cols: vec!["bytes".to_string()],
// vals: vec![Value::Filesize {
// val: 5,
// span: Span::unknown(),
// }],
// span: Span::unknown(),
// },
// Value::Record {
// cols: vec!["bytes".to_string()],
// vals: vec![Value::Filesize {
// val: 3,
// span: Span::unknown(),
// }],
// span: Span::unknown(),
// },
// Value::Record {
// cols: vec!["bytes".to_string()],
// vals: vec![Value::Filesize {
// val: 4,
// span: Span::unknown(),
// }],
// span: Span::unknown(),
// },
// Value::Record {
// cols: vec!["bytes".to_string()],
// vals: vec![Value::Filesize {
// val: 2000,
// span: Span::unknown(),
// }],
// span: Span::unknown(),
// },
// ],
// span: Span::unknown(),
// }),
// },
Example { Example {
description: "Convert string to filesize", description: "Convert string to filesize",
example: "'2' | into filesize", example: "'2' | into filesize",
@ -115,44 +80,43 @@ impl Command for SubCommand {
fn into_filesize( fn into_filesize(
engine_state: &EngineState, engine_state: &EngineState,
stack: &mut Stack,
call: &Call, call: &Call,
input: PipelineData, input: PipelineData,
) -> Result<nu_protocol::PipelineData, nu_protocol::ShellError> { ) -> Result<nu_protocol::PipelineData, nu_protocol::ShellError> {
let head = call.head; let head = call.head;
// let call_paths: Vec<ColumnPath> = args.rest(0)?; let column_paths: Vec<CellPath> = call.rest(engine_state, stack, 0)?;
input.map( input.map(
move |v| { move |v| {
action(v, head) if column_paths.is_empty() {
action(&v, head)
} else {
let mut ret = v;
for path in &column_paths {
let r =
ret.update_cell_path(&path.members, Box::new(move |old| action(old, head)));
if let Err(error) = r {
return Value::Error { error };
}
}
// FIXME: Add back cell_path support ret
// if column_paths.is_empty() { }
// action(&v, v.tag())
// } else {
// let mut ret = v;
// for path in &column_paths {
// ret = ret.swap_data_by_column_path(
// path,
// Box::new(move |old| action(old, old.tag())),
// )?;
// }
// Ok(ret)
// }
}, },
engine_state.ctrlc.clone(), engine_state.ctrlc.clone(),
) )
} }
pub fn action(input: Value, span: Span) -> Value { pub fn action(input: &Value, span: Span) -> Value {
match input { match input {
Value::Filesize { .. } => input, Value::Filesize { .. } => input.clone(),
Value::Int { val, .. } => Value::Filesize { val, span }, Value::Int { val, .. } => Value::Filesize { val: *val, span },
Value::Float { val, .. } => Value::Filesize { Value::Float { val, .. } => Value::Filesize {
val: val as i64, val: *val as i64,
span, span,
}, },
Value::String { val, .. } => match int_from_string(&val, span) { Value::String { val, .. } => match int_from_string(val, span) {
Ok(val) => Value::Filesize { val, span }, Ok(val) => Value::Filesize { val, span },
Err(error) => Value::Error { error }, Err(error) => Value::Error { error },
}, },

45
crates/nu-command/src/conversions/into/string.rs
View file

@ -1,6 +1,6 @@
use nu_engine::CallExt; use nu_engine::CallExt;
use nu_protocol::{ use nu_protocol::{
ast::Call, ast::{Call, CellPath},
engine::{Command, EngineState, Stack}, engine::{Command, EngineState, Stack},
Example, PipelineData, ShellError, Signature, Span, SyntaxShape, Value, Example, PipelineData, ShellError, Signature, Span, SyntaxShape, Value,
}; };
@ -18,11 +18,11 @@ impl Command for SubCommand {
fn signature(&self) -> Signature { fn signature(&self) -> Signature {
Signature::build("into string") Signature::build("into string")
// FIXME - need to support column paths // FIXME - need to support column paths
// .rest( .rest(
// "rest", "rest",
// SyntaxShape::ColumnPaths(), SyntaxShape::CellPath,
// "column paths to convert to string (for table input)", "column paths to convert to string (for table input)",
// ) )
.named( .named(
"decimals", "decimals",
SyntaxShape::Int, SyntaxShape::Int,
@ -135,6 +135,7 @@ fn string_helper(
let decimals = call.has_flag("decimals"); let decimals = call.has_flag("decimals");
let head = call.head; let head = call.head;
let decimals_value: Option<i64> = call.get_flag(engine_state, stack, "decimals")?; let decimals_value: Option<i64> = call.get_flag(engine_state, stack, "decimals")?;
let column_paths: Vec<CellPath> = call.rest(engine_state, stack, 0)?;
if decimals && decimals_value.is_some() && decimals_value.unwrap().is_negative() { if decimals && decimals_value.is_some() && decimals_value.unwrap().is_negative() {
return Err(ShellError::UnsupportedInput( return Err(ShellError::UnsupportedInput(
@ -144,13 +145,30 @@ fn string_helper(
} }
input.map( input.map(
move |v| action(v, head, decimals, decimals_value, false), move |v| {
if column_paths.is_empty() {
action(&v, head, decimals, decimals_value, false)
} else {
let mut ret = v;
for path in &column_paths {
let r = ret.update_cell_path(
&path.members,
Box::new(move |old| action(old, head, decimals, decimals_value, false)),
);
if let Err(error) = r {
return Value::Error { error };
}
}
ret
}
},
engine_state.ctrlc.clone(), engine_state.ctrlc.clone(),
) )
} }
pub fn action( pub fn action(
input: Value, input: &Value,
span: Span, span: Span,
decimals: bool, decimals: bool,
digits: Option<i64>, digits: Option<i64>,
@ -159,7 +177,7 @@ pub fn action(
match input { match input {
Value::Int { val, .. } => { Value::Int { val, .. } => {
let res = if group_digits { let res = if group_digits {
format_int(val) // int.to_formatted_string(*locale) format_int(*val) // int.to_formatted_string(*locale)
} else { } else {
val.to_string() val.to_string()
}; };
@ -188,12 +206,13 @@ pub fn action(
val: val.format("%c").to_string(), val: val.format("%c").to_string(),
span, span,
}, },
Value::String { val, .. } => Value::String { val, span }, Value::String { val, .. } => Value::String {
val: val.to_string(),
span,
},
// FIXME - we do not have a FilePath type anymore. Do we need to support this?
// Value::FilePath(a_filepath) => a_filepath.as_path().display().to_string(),
Value::Filesize { val: _, .. } => Value::String { Value::Filesize { val: _, .. } => Value::String {
val: input.into_string(), val: input.clone().into_string(),
span, span,
}, },
Value::Nothing { .. } => Value::String { Value::Nothing { .. } => Value::String {