rqjs-cli 0.1.1

rqjs-cli
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
106
107

// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
// SPDX-License-Identifier: Apache-2.0
use rquickjs::{function::Opt, Ctx, Object, Result};
use tokio::fs;

use crate::utils::result::ResultExt;

#[allow(clippy::manual_async_fn)]
pub async fn rmdir<'js>(ctx: Ctx<'js>, path: String, options: Opt<Object<'js>>) -> Result<()> {
    let recursive = get_params_rm_dir(options);

    if recursive {
        fs::remove_dir_all(&path).await
    } else {
        fs::remove_dir(&path).await
    }
    .or_throw_msg(&ctx, &format!("Can't remove dir \"{}\"", &path))?;

    Ok(())
}

#[allow(clippy::manual_async_fn)]
pub fn rmdir_sync<'js>(ctx: Ctx<'js>, path: String, options: Opt<Object<'js>>) -> Result<()> {
    let recursive = get_params_rm_dir(options);

    if recursive {
        std::fs::remove_dir_all(&path)
    } else {
        std::fs::remove_dir(&path)
    }
    .or_throw_msg(&ctx, &format!("Can't remove dir \"{}\"", &path))?;

    Ok(())
}

pub async fn rmfile<'js>(ctx: Ctx<'js>, path: String, options: Opt<Object<'js>>) -> Result<()> {
    let (recursive, force) = get_params_rm(options);

    let res = async move {
        let is_dir = fs::metadata(&path)
            .await
            .map(|metadata| metadata.is_dir())
            .or_throw(&ctx)?;

        (if is_dir && recursive {
            fs::remove_dir_all(&path).await
        } else if is_dir && !recursive {
            fs::remove_dir(&path).await
        } else {
            fs::remove_file(&path).await
        })
        .or_throw_msg(&ctx, &format!("Can't remove file \"{}\"", &path))?;

        Ok(())
    }
    .await;

    if !force {
        return res;
    }

    Ok(())
}

pub fn rmfile_sync<'js>(_ctx: Ctx<'js>, path: String, options: Opt<Object<'js>>) -> Result<()> {
    let (recursive, force) = get_params_rm(options);

    let res = (|| -> Result<()> {
        let is_dir = std::fs::metadata(&path).map(|metadata| metadata.is_dir())?;

        (if is_dir && recursive {
            std::fs::remove_dir_all(&path)
        } else if is_dir && !recursive {
            std::fs::remove_dir(&path)
        } else {
            std::fs::remove_file(&path)
        })?;

        Ok(())
    })();

    if !force {
        return res;
    }

    Ok(())
}

fn get_params_rm_dir(options: Opt<Object>) -> bool {
    let mut recursive = false;

    if let Some(options) = options.0 {
        recursive = options.get("recursive").unwrap_or_default();
    }
    recursive
}

fn get_params_rm(options: Opt<Object>) -> (bool, bool) {
    let mut recursive = false;
    let mut force = false;

    if let Some(options) = options.0 {
        recursive = options.get("recursive").unwrap_or_default();
        force = options.get("force").unwrap_or_default();
    }
    (recursive, force)
}