vrl 0.32.0

Vector Remap Language
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

use std::fmt;

use crate::compiler::state::{TypeInfo, TypeState};
use crate::compiler::{
    Context, Expression, TypeDef,
    expression::{Expr, Resolved},
};
use crate::value::Kind;

#[derive(Debug, Clone, PartialEq)]
pub struct Block {
    inner: Vec<Expr>,

    // false - This is just an inline block of code
    // true - This is a block of code nested in a child scope
    new_scope: bool,
}

impl Block {
    #[must_use]
    fn new(inner: Vec<Expr>, new_scope: bool) -> Self {
        Self { inner, new_scope }
    }

    #[must_use]
    pub fn new_scoped(inner: Vec<Expr>) -> Self {
        Self::new(inner, true)
    }

    #[must_use]
    pub fn new_inline(inner: Vec<Expr>) -> Self {
        Self::new(inner, false)
    }

    #[must_use]
    pub fn into_inner(self) -> Vec<Expr> {
        self.inner
    }

    #[must_use]
    pub fn exprs(&self) -> &Vec<Expr> {
        &self.inner
    }
}

impl Expression for Block {
    fn resolve(&self, ctx: &mut Context) -> Resolved {
        // Variables are checked at compile-time to ensure only variables
        // in scope can be accessed here, so it doesn't need to be checked at runtime.
        let (last, other) = self.inner.split_last().expect("at least one expression");

        other
            .iter()
            .try_for_each(|expr| expr.resolve(ctx).map(|_| ()))?;

        last.resolve(ctx)
    }

    fn type_info(&self, state: &TypeState) -> TypeInfo {
        let parent_locals = state.local.clone();

        let mut state = state.clone();
        let mut result = TypeDef::null();
        let mut fallible = false;
        let mut returns = Kind::never();
        let mut after_never_expression = false;

        for expr in &self.inner {
            result = expr.apply_type_info(&mut state);

            if !after_never_expression && result.is_fallible() {
                fallible = true;
            }
            if result.is_never() {
                after_never_expression = true;
            }
            returns.merge_keep(result.returns().clone(), false);
        }

        if self.new_scope {
            state.local = parent_locals.apply_child_scope(state.local);
        }

        TypeInfo::new(state, result.maybe_fallible(fallible).with_returns(returns))
    }
}

impl fmt::Display for Block {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        f.write_str("{\n")?;

        let mut iter = self.inner.iter().peekable();
        while let Some(expr) = iter.next() {
            f.write_str("\t")?;
            expr.fmt(f)?;
            if iter.peek().is_some() {
                f.write_str("\n")?;
            }
        }

        f.write_str("\n}")
    }
}