nu-command 0.29.0

use crate::prelude::*;
use nu_engine::WholeStreamCommand;
use nu_errors::ShellError;
use nu_protocol::{
    merge_descriptors, ColumnPath, ReturnSuccess, Signature, SyntaxShape, TaggedDictBuilder,
    UntaggedValue,
};
use nu_source::{SpannedItem, Tagged};
use nu_value_ext::ValueExt;

pub struct SubCommand;

#[derive(Deserialize)]
pub struct Arguments {
    rest: Vec<Tagged<String>>,
}

#[async_trait]
impl WholeStreamCommand for SubCommand {
    fn name(&self) -> &str {
        "rotate counter-clockwise"
    }

    fn signature(&self) -> Signature {
        Signature::build("rotate counter-clockwise").rest(
            SyntaxShape::String,
            "the names to give columns once rotated",
        )
    }

    fn usage(&self) -> &str {
        "Rotates the table by 90 degrees counter clockwise."
    }

    async fn run(&self, args: CommandArgs) -> Result<OutputStream, ShellError> {
        rotate(args).await
    }
}

pub async fn rotate(args: CommandArgs) -> Result<OutputStream, ShellError> {
    let name = args.call_info.name_tag.clone();
    let (Arguments { rest }, input) = args.process().await?;

    let input = input.into_vec().await;
    let descs = merge_descriptors(&input);
    let total_rows = input.len();

    if total_rows == 0 {
        return Ok(OutputStream::empty());
    }

    let mut headers: Vec<String> = vec![];
    for i in 0..=total_rows {
        headers.push(format!("Column{}", i + 1));
    }

    let first = input[0].clone();

    let name = if first.tag.anchor().is_some() {
        first.tag
    } else {
        name
    };

    let values = UntaggedValue::table(&input).into_value(&name);

    let values = nu_data::utils::group(
        &values,
        &Some(Box::new(move |row_number: usize, _| {
            Ok(match headers.get(row_number) {
                Some(name) => name.clone(),
                None => String::new(),
            })
        })),
        &name,
    )?;

    Ok(futures::stream::iter(
        (0..descs.len())
            .rev()
            .map(move |row_number| {
                let mut row = TaggedDictBuilder::new(&name);

                row.insert_value(
                    rest.get(0)
                        .map(|c| c.item.clone())
                        .unwrap_or_else(|| String::from("Column0")),
                    UntaggedValue::string(descs.get(row_number).unwrap_or(&String::new()))
                        .into_untagged_value(),
                );

                for (current_numbered_column, (column_name, _)) in values.row_entries().enumerate()
                {
                    let raw_column_path =
                        format!("{}.0.{}", column_name, &descs[row_number]).spanned_unknown();
                    let path = ColumnPath::build(&raw_column_path);

                    match &values.get_data_by_column_path(&path, Box::new(move |_, _, error| error))
                    {
                        Ok(x) => {
                            row.insert_value(
                                rest.get(current_numbered_column + 1)
                                    .map(|c| c.item.clone())
                                    .unwrap_or_else(|| column_name.to_string()),
                                x.clone(),
                            );
                        }
                        Err(_) => {}
                    }
                }

                ReturnSuccess::value(row.into_value())
            })
            .collect::<Vec<_>>(),
    )
    .to_output_stream())
}