aion-nif 0.3.0

Native function declaration helpers for Gleam and Elixir Aion workflows.
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
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139

//! NIF descriptor, `Determinism` tag, and dirty flag.

use beamr::native::NativeFn;

/// Classifies how the engine is allowed to bind and execute a NIF.
///
/// The engine registration path reads this tag to decide binding mode:
/// [`Determinism::Pure`] functions may be bound inline and re-executed during
/// replay, while [`Determinism::SideEffectful`] functions are activity bodies
/// only and are never bound inline.
#[derive(Clone, Copy, Debug, PartialEq, Eq)]
pub enum Determinism {
    /// Deterministic helper that may be called inline from workflow code.
    Pure,
    /// Side-effectful native activity that must be invoked through the activity contract.
    SideEffectful,
}

/// Descriptor emitted by `aion-nif` for the engine runtime to register.
#[derive(Clone, Debug)]
pub struct Nif {
    module: String,
    function: String,
    arity: u8,
    native: NativeFn,
    dirty: bool,
    determinism: Determinism,
}

impl Nif {
    /// Creates a descriptor for a native function declaration.
    #[must_use]
    pub(crate) fn new(
        module: impl Into<String>,
        function: impl Into<String>,
        arity: u8,
        native: NativeFn,
        dirty: bool,
        determinism: Determinism,
    ) -> Self {
        Self {
            module: module.into(),
            function: function.into(),
            arity,
            native,
            dirty,
            determinism,
        }
    }

    /// Creates a pure deterministic helper descriptor.
    #[must_use]
    pub fn pure(
        module: impl Into<String>,
        function: impl Into<String>,
        arity: u8,
        native: NativeFn,
    ) -> Self {
        Self::new(module, function, arity, native, false, Determinism::Pure)
    }

    /// Creates a side-effectful activity descriptor that should run dirty.
    #[must_use]
    pub fn side_effectful(
        module: impl Into<String>,
        function: impl Into<String>,
        arity: u8,
        native: NativeFn,
    ) -> Self {
        Self::new(
            module,
            function,
            arity,
            native,
            true,
            Determinism::SideEffectful,
        )
    }

    /// Gleam or Elixir module atom-name.
    #[must_use]
    pub fn module(&self) -> &str {
        &self.module
    }

    /// Gleam or Elixir function atom-name.
    #[must_use]
    pub fn function(&self) -> &str {
        &self.function
    }

    /// Declared function arity.
    #[must_use]
    pub const fn arity(&self) -> u8 {
        self.arity
    }

    /// Native shim invoked by the engine's beamr registration boundary.
    #[must_use]
    pub const fn native(&self) -> NativeFn {
        self.native
    }

    /// Whether the engine should register this NIF on beamr's dirty scheduler.
    #[must_use]
    pub const fn is_dirty(&self) -> bool {
        self.dirty
    }

    /// Determinism tag used by the engine to choose inline vs activity binding.
    #[must_use]
    pub const fn determinism(&self) -> Determinism {
        self.determinism
    }
}

#[cfg(test)]
mod tests {
    use beamr::{native::ProcessContext, term::Term};

    use super::{Determinism, Nif};

    fn identity_native(args: &[Term], ctx: &mut ProcessContext) -> Result<Term, Term> {
        let _ = ctx;
        args.first().copied().ok_or(Term::NIL)
    }

    #[test]
    fn descriptor_exposes_identity_dirty_flag_and_determinism() {
        let nif = Nif::pure("example/module", "identity", 1, identity_native);

        assert_eq!(nif.module(), "example/module");
        assert_eq!(nif.function(), "identity");
        assert_eq!(nif.arity(), 1);
        assert!(!nif.is_dirty());
        assert_eq!(nif.determinism(), Determinism::Pure);
        assert_eq!(nif.native() as usize, identity_native as usize);
    }
}