obeli-sk-wasm-workers 0.22.4

Internal package of obeli-sk
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

use super::wasi::cli::{environment, exit, stderr, stdin, stdout};
use crate::workflow::workflow_ctx::WorkflowCtx;
use concepts::{
    storage::{DbConnection, DbPool},
    time::ClockFn,
};
use wasmtime::Result;
use wasmtime::component::Resource;
use wasmtime_wasi::{StdinStream as _, pipe};
use wasmtime_wasi_io::streams::{DynInputStream, DynOutputStream};

impl<C: ClockFn, DB: DbConnection, P: DbPool<DB>> environment::Host for WorkflowCtx<C, DB, P> {
    fn get_arguments(&mut self) -> Result<Vec<String>> {
        Ok(Vec::new())
    }
    fn get_environment(&mut self) -> Result<Vec<(String, String)>> {
        Ok(Vec::new())
    }
    fn initial_cwd(&mut self) -> Result<Option<String>> {
        Ok(None)
    }
}

impl<C: ClockFn, DB: DbConnection, P: DbPool<DB>> exit::Host for WorkflowCtx<C, DB, P> {
    fn exit(&mut self, _code: Result<(), ()>) -> Result<()> {
        Err(wasmtime::Error::msg("wasi:cli/exit is stubbed"))
    }
    fn exit_with_code(&mut self, _status_code: u8) -> Result<()> {
        Err(wasmtime::Error::msg("wasi:cli/exit is stubbed"))
    }
}
// see WasiCtxBuilder
impl<C: ClockFn, DB: DbConnection, P: DbPool<DB>> stdin::Host for WorkflowCtx<C, DB, P> {
    fn get_stdin(&mut self) -> Result<Resource<DynInputStream>> {
        let stdin = pipe::ClosedInputStream;
        let stream = stdin.stream();
        Ok(self.resource_table.push(stream)?)
    }
}
// see WasiCtxBuilder
impl<C: ClockFn, DB: DbConnection, P: DbPool<DB>> stdout::Host for WorkflowCtx<C, DB, P> {
    fn get_stdout(&mut self) -> Result<Resource<DynOutputStream>> {
        let stdout: DynOutputStream = Box::new(pipe::SinkOutputStream);
        Ok(self.resource_table.push(stdout)?)
    }
}
// see WasiCtxBuilder
impl<C: ClockFn, DB: DbConnection, P: DbPool<DB>> stderr::Host for WorkflowCtx<C, DB, P> {
    fn get_stderr(&mut self) -> Result<Resource<DynOutputStream>> {
        let stderr: DynOutputStream = Box::new(pipe::SinkOutputStream);
        Ok(self.resource_table.push(stderr)?)
    }
}