isola 0.4.2

Isola runtime
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

use std::sync::Arc;

use parking_lot::Mutex;
use wasmtime::Store;

use crate::{
    host::{BoxError, Host, OutputSink},
    internal::sandbox::InstanceState,
    sandbox::CallOutput,
    value::Value as IsolaValue,
};

/// RAII guard that clears the output sink when dropped, even if the call panics
/// or returns early.
pub struct CallCleanup<'a, H: Host> {
    pub store: &'a mut Store<InstanceState<H>>,
}

impl<'a, H: Host> CallCleanup<'a, H> {
    pub const fn new(store: &'a mut Store<InstanceState<H>>) -> Self {
        Self { store }
    }

    pub fn set_sink(&mut self, sink: Arc<dyn OutputSink>) {
        self.store.data_mut().set_sink(Some(sink));
    }
}

impl<H: Host> Drop for CallCleanup<'_, H> {
    fn drop(&mut self) {
        // Cleanup only; explicit flush is handled by call sites.
        self.store.data_mut().set_sink(None);
    }
}

impl<H: Host> std::ops::Deref for CallCleanup<'_, H> {
    type Target = Store<InstanceState<H>>;

    fn deref(&self) -> &Self::Target {
        self.store
    }
}

impl<H: Host> std::ops::DerefMut for CallCleanup<'_, H> {
    fn deref_mut(&mut self) -> &mut Self::Target {
        self.store
    }
}

impl<H: Host> wasmtime::AsContext for CallCleanup<'_, H> {
    type Data = InstanceState<H>;

    fn as_context(&self) -> wasmtime::StoreContext<'_, Self::Data> {
        wasmtime::AsContext::as_context(&*self.store)
    }
}

impl<H: Host> wasmtime::AsContextMut for CallCleanup<'_, H> {
    fn as_context_mut(&mut self) -> wasmtime::StoreContextMut<'_, Self::Data> {
        wasmtime::AsContextMut::as_context_mut(&mut *self.store)
    }
}

#[async_trait::async_trait]
impl OutputSink for Mutex<CallOutput> {
    async fn on_item(&self, value: IsolaValue) -> core::result::Result<(), BoxError> {
        self.lock().items.push(value);
        Ok(())
    }

    async fn on_complete(&self, value: Option<IsolaValue>) -> core::result::Result<(), BoxError> {
        self.lock().result = value;
        Ok(())
    }
}