Struct SyncChildTestHarness 

pub struct SyncChildTestHarness<C: RunnableChild> { /* private fields */ }

Test harness for synchronous RunnableChild implementations.

Provides run() testing with automatic time measurement.

Example

use orcs_component::testing::SyncChildTestHarness;
use orcs_component::{Child, RunnableChild, ChildResult, Identifiable, SignalReceiver, Statusable, Status};
use orcs_event::{Signal, SignalResponse};
use serde_json::{json, Value};

struct Worker {
    id: String,
    status: Status,
}

impl Identifiable for Worker {
    fn id(&self) -> &str { &self.id }
}

impl SignalReceiver for Worker {
    fn on_signal(&mut self, signal: &Signal) -> SignalResponse {
        if signal.is_veto() {
            self.abort();
            SignalResponse::Abort
        } else {
            SignalResponse::Handled
        }
    }
    fn abort(&mut self) { self.status = Status::Aborted; }
}

impl Statusable for Worker {
    fn status(&self) -> Status { self.status }
}

impl Child for Worker {}

impl RunnableChild for Worker {
    fn run(&mut self, input: Value) -> ChildResult {
        ChildResult::Ok(json!({"echo": input}))
    }
}

let worker = Worker { id: "worker".into(), status: Status::Idle };
let mut harness = SyncChildTestHarness::new(worker);

let result = harness.run(json!({"task": "test"}));
assert!(result.is_ok());
assert_eq!(harness.run_log().len(), 1);

Implementations

impl<C: RunnableChild> SyncChildTestHarness<C>

pub fn new(child: C) -> Self

Creates a new test harness for the given runnable child.

Time measurement is enabled by default.

pub fn without_time_measurement(self) -> Self

Disables time measurement.

pub fn run(&mut self, input: Value) -> ChildResult

Executes run() on the child with the given input.

pub fn run_json<T: Serialize>(&mut self, input: T) -> ChildResult

Executes run() with a serializable input.

pub fn run_log(&self) -> &[RunRecord]

Returns the run log for snapshot testing.

pub fn clear_all_logs(&mut self)

Clears all logs (both run and signal).

pub fn child(&self) -> &C

Returns a reference to the child under test.

pub fn child_mut(&mut self) -> &mut C

Returns a mutable reference to the child under test.

pub fn id(&self) -> &str

Returns the child’s ID.

pub fn status(&self) -> Status

Returns the current status of the child.

pub fn send_signal(&mut self, signal: Signal) -> SignalResponse

Sends a signal to the child.

pub fn veto(&mut self) -> SignalResponse

Sends a Veto signal to the child.

pub fn cancel(&mut self) -> SignalResponse

Sends a Cancel signal to the child.

pub fn abort(&mut self)

Calls abort() on the child.

pub fn signal_log(&self) -> &[SignalRecord]

Returns the signal log.