Struct WasmEngine 

pub struct WasmEngine { /* private fields */ }

A WebAssembly-compatible workflow engine.

Wraps the dataflow-rs Engine to provide async message processing that returns JavaScript Promises.

Implementations

impl WasmEngine

pub fn new(workflows_json: &str) -> Result<WasmEngine, String>

Create a new WasmEngine from a JSON array of workflow definitions.

Arguments

• workflows_json - JSON string containing an array of workflow definitions

Example

const workflows = JSON.stringify([{
    id: "workflow1",
    name: "My Workflow",
    priority: 1,
    tasks: [...]
}]);
const engine = new WasmEngine(workflows);

pub fn process(&self, payload: &str) -> Promise

Process a payload through the engine’s workflows.

This is an async operation that returns a Promise. The payload is stored as a raw string and should be parsed by a parse plugin in the workflow if JSON parsing is needed.

Arguments

• payload - Raw string payload to process (not parsed by the engine)

Returns

A Promise that resolves to the processed message as a JSON string

Example

const payload = '{"name": "John", "email": "john@example.com"}';
const result = await engine.process(payload);
const processed = JSON.parse(result);
console.log(processed.context.data);

pub fn process_with_trace(&self, payload: &str) -> Promise

Process a payload with step-by-step execution tracing.

This is an async operation that returns a Promise with the execution trace. The trace contains message snapshots after each step, including which workflows/tasks were executed or skipped. The payload is stored as a raw string and should be parsed by a parse plugin.

Arguments

• payload - Raw string payload to process (not parsed by the engine)

Returns

A Promise that resolves to the execution trace as a JSON string

Example

const payload = '{"name": "John", "email": "john@example.com"}';
const trace = await engine.process_with_trace(payload);
const traceData = JSON.parse(trace);
console.log(traceData.steps); // Array of execution steps

pub fn workflow_count(&self) -> usize

Get the number of workflows registered in the engine.

pub fn workflow_ids(&self) -> String

Get the list of workflow IDs.

Returns

JSON array of workflow IDs as a string

Trait Implementations

impl From<WasmEngine> for JsValue

fn from(value: WasmEngine) -> Self

Converts to this type from the input type.

impl FromWasmAbi for WasmEngine

type Abi = u32

The Wasm ABI type that this converts from when coming back out from the ABI boundary.

unsafe fn from_abi(js: u32) -> Self

Recover a Self from Self::Abi.

impl IntoWasmAbi for WasmEngine

type Abi = u32

The Wasm ABI type that this converts into when crossing the ABI boundary.

fn into_abi(self) -> u32

Convert self into Self::Abi so that it can be sent across the wasm ABI boundary.

impl LongRefFromWasmAbi for WasmEngine

type Abi = u32

Same as RefFromWasmAbi::Abi

type Anchor = RcRef<WasmEngine>

Same as RefFromWasmAbi::Anchor

unsafe fn long_ref_from_abi(js: Self::Abi) -> Self::Anchor

Same as RefFromWasmAbi::ref_from_abi

impl OptionFromWasmAbi for WasmEngine

fn is_none(abi: &Self::Abi) -> bool

Tests whether the argument is a “none” instance. If so it will be deserialized as None, and otherwise it will be passed to FromWasmAbi.

impl OptionIntoWasmAbi for WasmEngine

fn none() -> Self::Abi

Returns an ABI instance indicating “none”, which JS will interpret as the None branch of this option.

impl RefFromWasmAbi for WasmEngine

type Abi = u32

The Wasm ABI type references to Self are recovered from.

type Anchor = RcRef<WasmEngine>

The type that holds the reference to Self for the duration of the invocation of the function that has an &Self parameter. This is required to ensure that the lifetimes don’t persist beyond one function call, and so that they remain anonymous.

unsafe fn ref_from_abi(js: Self::Abi) -> Self::Anchor

Recover a Self::Anchor from Self::Abi.

impl RefMutFromWasmAbi for WasmEngine

type Abi = u32

Same as RefFromWasmAbi::Abi

type Anchor = RcRefMut<WasmEngine>

Same as RefFromWasmAbi::Anchor

unsafe fn ref_mut_from_abi(js: Self::Abi) -> Self::Anchor

Same as RefFromWasmAbi::ref_from_abi

impl TryFromJsValue for WasmEngine

fn try_from_js_value(value: JsValue) -> Result<Self, JsValue>

Performs the conversion.

fn try_from_js_value_ref(value: &JsValue) -> Option<Self>

Performs the conversion.

impl VectorFromWasmAbi for WasmEngine

type Abi = <Box<[JsValue]> as FromWasmAbi>::Abi

unsafe fn vector_from_abi(js: Self::Abi) -> Box<[WasmEngine]>

impl VectorIntoWasmAbi for WasmEngine

type Abi = <Box<[JsValue]> as IntoWasmAbi>::Abi

fn vector_into_abi(vector: Box<[WasmEngine]>) -> Self::Abi

impl WasmDescribe for WasmEngine

fn describe()

impl WasmDescribeVector for WasmEngine

fn describe_vector()

impl SupportsConstructor for WasmEngine

impl SupportsInstanceProperty for WasmEngine

impl SupportsStaticProperty for WasmEngine