newton-regorus 0.2.0

A fast, lightweight Rego (OPA policy language) interpreter with Newton extensions
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

// Copyright (c) Microsoft Corporation.
// Licensed under the MIT License.
#![allow(clippy::indexing_slicing)]

use crate::{
    ast::{Expr, Ref},
    builtins,
    builtins::{
        time,
        utils::{ensure_args_count, ensure_string},
    },
    lexer::Span,
    value::Value,
    *,
};

use std::thread;

use anyhow::{Ok, Result};

pub fn register(m: &mut builtins::BuiltinsMap<&'static str, builtins::BuiltinFcn>) {
    m.insert("test.sleep", (sleep, 1));
}

fn sleep(span: &Span, params: &[Ref<Expr>], args: &[Value], _strict: bool) -> Result<Value> {
    let name = "test.sleep";
    ensure_args_count(span, name, params, args, 1)?;

    let val = ensure_string(name, &params[0], &args[0])?;
    let dur = time::compat::parse_duration(val.as_ref())
        .map_err(|e| params[0].span().error(&format!("{e}")))?;

    let std_dur = dur
        .to_std()
        .map_err(|err| anyhow::anyhow!("Failed to convert to std::time::Duration: {err}"))?;

    thread::sleep(std_dur);

    Ok(Value::Null)
}