arora-engine 0.1.0

The Arora engine: loads and executes Arora modules (wasm and native hosts).
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

use std::{collections::HashMap, rc::Rc};

use rand::{rng, Rng};
use uuid::Uuid;

use arora_buffers::serde_uuid::serialize;
pub use arora_types::call::{Call, CallBridge, CallError, CallResult, Callable, CallableId};
use arora_types::value::{Structure, Value};

use crate::module::DispatchError;

pub fn serialize_to_arg(call: Call) -> Box<[u8]> {
    serialize(&Value::Structure(Structure {
        id: call.id,
        fields: call.args,
    }))
}

// `Callable`, `CallBridge`, `CallError`, and `CallableId` now live in
// `arora-types` (re-exported above) so module-shaped libraries can use the
// call boundary without depending on the engine crate. The engine-internal
// machinery below stays here.

/// Maps the engine's internal [`DispatchError`] onto the public
/// [`CallError`].
impl From<DispatchError> for CallError {
    fn from(e: DispatchError) -> Self {
        match e {
            DispatchError::ModuleNotFound { id } => CallError::ModuleNotFound { id },
            DispatchError::FunctionNotFound { id } => CallError::FunctionNotFound { id },
            DispatchError::Trap { message } => CallError::Trap { message },
            DispatchError::Internal { message } => CallError::Internal { message },
            DispatchError::Guest { message } => CallError::Guest { message },
        }
    }
}

lazy_static::lazy_static! {
  pub static ref CALLABLE_ID_TYPE_ID: Uuid = Uuid::parse_str("6dd7f535-8245-4bf2-b081-81fd4636fa90").unwrap();
  pub static ref CALLABLE_ID_ID_FIELD_ID: Uuid = Uuid::parse_str("d799be14-e12a-4539-ac56-f7dc4634161b").unwrap();
}

pub struct CallableRegistry {
    callables_by_id: HashMap<CallableId, Rc<dyn Callable>>,
}

impl Default for CallableRegistry {
    fn default() -> Self {
        Self::new()
    }
}

impl CallableRegistry {
    pub fn new() -> Self {
        Self {
            callables_by_id: HashMap::new(),
        }
    }

    pub fn register_callable(
        &mut self,
        callable: Rc<dyn Callable>,
    ) -> Result<CallableId, CallError> {
        let tick_id: CallableId = self.generate_unique_callable_id();
        if let Some(existing_one) = self.callables_by_id.insert(tick_id.clone(), callable) {
            self.callables_by_id.insert(tick_id.clone(), existing_one);
            return Err(CallError::Generic {
                message: "another callable is already associated to the id".to_string(),
            });
        }
        Ok(tick_id)
    }

    pub fn find_callable(&self, id: &CallableId) -> Result<Rc<dyn Callable>, CallError> {
        let callable = self.callables_by_id.get(id).ok_or(CallError::Generic {
            message: "cannot find callable".to_string(),
        })?;
        Ok(callable.clone())
    }

    pub fn unregister_callable(&mut self, id: &CallableId) -> Result<(), CallError> {
        self.callables_by_id.remove(id).ok_or(CallError::Generic {
            message: "cannot find callable".to_string(),
        })?;
        Ok(())
    }

    fn generate_unique_callable_id(&self) -> CallableId {
        let mut rng = rng();
        let mut tick_id = CallableId { id: rng.next_u64() };
        while self.callables_by_id.contains_key(&tick_id) {
            tick_id.id = rng.next_u64();
        }
        tick_id
    }
}