use super::super::super::values::{Column, NuDataFrame}; use nu_protocol::{ ast::Call, engine::{Command, EngineState, Stack}, Category, Example, PipelineData, ShellError, Signature, Span, Type, Value, }; use polars::prelude::{DatetimeMethods, IntoSeries}; #[derive(Clone)] pub struct GetWeek; impl Command for GetWeek { fn name(&self) -> &str { "dfr get-week" } fn usage(&self) -> &str { "Gets week from date." } fn signature(&self) -> Signature { Signature::build(self.name()) .input_output_type( Type::Custom("dataframe".into()), Type::Custom("dataframe".into()), ) .category(Category::Custom("dataframe".into())) } fn examples(&self) -> Vec { vec![Example { description: "Returns week from a date", example: r#"let dt = ('2020-08-04T16:39:18+00:00' | into datetime --timezone 'UTC'); let df = ([$dt $dt] | dfr into-df); $df | dfr get-week"#, result: Some( NuDataFrame::try_from_columns(vec![Column::new( "0".to_string(), vec![Value::test_int(32), Value::test_int(32)], )]) .expect("simple df for test should not fail") .into_value(Span::test_data()), ), }] } fn run( &self, engine_state: &EngineState, stack: &mut Stack, call: &Call, input: PipelineData, ) -> Result { command(engine_state, stack, call, input) } } fn command( _engine_state: &EngineState, _stack: &mut Stack, call: &Call, input: PipelineData, ) -> Result { let df = NuDataFrame::try_from_pipeline(input, call.head)?; let series = df.as_series(call.head)?; let casted = series.datetime().map_err(|e| { ShellError::GenericError( "Error casting to datetime type".into(), e.to_string(), Some(call.head), None, Vec::new(), ) })?; let res = casted.week().into_series(); NuDataFrame::try_from_series(vec![res], call.head) .map(|df| PipelineData::Value(NuDataFrame::into_value(df, call.head), None)) } #[cfg(explore_refactor_IntoDatetime)] mod test { use super::super::super::super::super::IntoDatetime; use super::super::super::super::test_dataframe::test_dataframe; use super::*; #[test] fn test_examples() { test_dataframe(vec![Box::new(GetWeek {}), Box::new(IntoDatetime {})]) } }