nu_plugin_cloud 0.2.11+0.110.0

A nushell plugin for working with cloud storage services
Documentation 
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
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105

use crate::CloudPlugin;

mod clear;
mod ls;
mod open;
mod rm;
mod save;
mod stub;

pub fn commands() -> Vec<Box<dyn nu_plugin::PluginCommand<Plugin = CloudPlugin>>> {
    vec![
        Box::new(clear::Clear),
        Box::new(ls::Ls),
        Box::new(open::Open),
        Box::new(rm::Remove),
        Box::new(save::Save),
        Box::new(stub::Stub),
    ]
}

#[cfg(test)]
mod tests {
    use crate::CloudPlugin;
    use nu_command::{FromCsv, Select, ToCsv};
    use nu_plugin_test_support::PluginTest;
    use nu_protocol::{PipelineData, Span, Value, record};

    #[test]
    fn test_save_open() -> Result<(), Box<dyn std::error::Error>> {
        let plugin = CloudPlugin::default();
        let mut plugin_test = PluginTest::new("polars", plugin.into())?;
        let _ = plugin_test.add_decl(Box::new(ToCsv))?;
        let _ = plugin_test.add_decl(Box::new(FromCsv))?;
        let result = plugin_test.eval_with(
            "[[a b]; [1 2]] | cloud save memory:/foo.csv | cloud open memory:/foo.csv",
            PipelineData::Empty,
        )?;
        let value = result.into_value(Span::test_data())?;
        assert_eq!(
            value,
            Value::test_list(vec![Value::test_record(record!(
                "a" => Value::test_int(1),
                "b" => Value::test_int(2),
            ))])
        );
        Ok(())
    }

    #[test]
    fn test_save_open_raw() -> Result<(), Box<dyn std::error::Error>> {
        let plugin = CloudPlugin::default();
        let mut plugin_test = PluginTest::new("polars", plugin.into())?;
        let _ = plugin_test.add_decl(Box::new(ToCsv))?;
        let _ = plugin_test.add_decl(Box::new(FromCsv))?;
        let result = plugin_test.eval_with(
            "[[a b]; [1 2]] | cloud save memory:/foo.csv | cloud open --raw memory:/foo.csv",
            PipelineData::Empty,
        )?;
        let value = result.into_value(Span::test_data())?;
        assert_eq!(value, Value::test_string("a,b\n1,2\n"));
        Ok(())
    }

    #[test]
    fn test_save_raw_open() -> Result<(), Box<dyn std::error::Error>> {
        let plugin = CloudPlugin::default();
        let mut plugin_test = PluginTest::new("polars", plugin.into())?;
        let _ = plugin_test.add_decl(Box::new(ToCsv))?;
        let _ = plugin_test.add_decl(Box::new(FromCsv))?;
        let result = plugin_test.eval_with(
            "[[a b]; [1 2]] | to csv | cloud save --raw memory:/foo.csv | cloud open memory:/foo.csv",
            PipelineData::Empty,
        )?;
        let value = result.into_value(Span::test_data())?;
        assert_eq!(
            value,
            Value::test_list(vec![Value::test_record(record!(
                "a" => Value::test_int(1),
                "b" => Value::test_int(2),
            ))])
        );
        Ok(())
    }

    #[test]
    fn test_list() -> Result<(), Box<dyn std::error::Error>> {
        let plugin = CloudPlugin::default();
        let mut plugin_test = PluginTest::new("polars", plugin.into())?;
        let _ = plugin_test.add_decl(Box::new(ToCsv))?;
        let _ = plugin_test.add_decl(Box::new(Select))?;
        let result = plugin_test.eval_with(
            "[[a b]; [1 2]] | cloud save memory:/foo.csv | cloud ls memory:/ | select name size",
            PipelineData::Empty,
        )?;
        let value = result.into_value(Span::test_data())?;
        assert_eq!(
            value,
            Value::test_list(vec![Value::test_record(record!(
                "name" => Value::test_string("foo.csv"),
                "size" => Value::test_filesize(8),
            ))])
        );
        Ok(())
    }
}