Struct ContextWatchdog 

pub struct ContextWatchdog { /* private fields */ }

Watches for context changes by diffing consecutive snapshots.

Implementations

impl ContextWatchdog

pub fn new() -> Self

Examples found in repository

examples/dump_context.rs (line 49)

fn main() {
    let mut merger = ContextMerger::new().with_defaults("Example App", "Main");
    merger.push(ContextContribution::new(
        "test_source",
        vec![ContextElement {
            id: "button:submit".into(),
            label: Some("Submit".into()),
            description: None,
            element_type: "button".into(),
            value: None,
            bounds: Some(Bounds {
                x: 100,
                y: 200,
                width: 120,
                height: 32,
            }),
            state: ElementState {
                focused: true,
                ..Default::default()
            },
            parent_id: None,
            actions: Vec::new(),
            confidence: 0.0,
            source: ContextSource::NativeApi,
            content_role: ContentRole::Interactive,
            properties: Default::default(),
        }],
    ));

    let ctx = merger.build();
    println!("{}", serde_json::to_string_pretty(&ctx).unwrap());

    let reference = ctx.elements[0].to_reference(1920, 1080);
    let resolved = cel_context::resolve_reference(&ctx, &reference);
    println!(
        "resolved reference: {:?}",
        resolved.map(|el| el.id.as_str())
    );

    let mut watchdog = ContextWatchdog::new();
    assert!(watchdog.tick(&ctx, true).is_empty());

    let mut changed = ctx.clone();
    changed.elements[0].state.focused = false;
    let events = watchdog.tick(&changed, true);
    println!("watchdog events: {events:?}");
}

pub fn tick( &mut self, context: &ScreenContext, network_idle: bool, ) -> Vec<CelEvent>

Compare the current context against the previous snapshot and emit events.

context: The current screen context. network_idle: Whether the network monitor reports idle state.

Returns a list of events that occurred since the last tick.

Examples found in repository

examples/dump_context.rs (line 50)

fn main() {
    let mut merger = ContextMerger::new().with_defaults("Example App", "Main");
    merger.push(ContextContribution::new(
        "test_source",
        vec![ContextElement {
            id: "button:submit".into(),
            label: Some("Submit".into()),
            description: None,
            element_type: "button".into(),
            value: None,
            bounds: Some(Bounds {
                x: 100,
                y: 200,
                width: 120,
                height: 32,
            }),
            state: ElementState {
                focused: true,
                ..Default::default()
            },
            parent_id: None,
            actions: Vec::new(),
            confidence: 0.0,
            source: ContextSource::NativeApi,
            content_role: ContentRole::Interactive,
            properties: Default::default(),
        }],
    ));

    let ctx = merger.build();
    println!("{}", serde_json::to_string_pretty(&ctx).unwrap());

    let reference = ctx.elements[0].to_reference(1920, 1080);
    let resolved = cel_context::resolve_reference(&ctx, &reference);
    println!(
        "resolved reference: {:?}",
        resolved.map(|el| el.id.as_str())
    );

    let mut watchdog = ContextWatchdog::new();
    assert!(watchdog.tick(&ctx, true).is_empty());

    let mut changed = ctx.clone();
    changed.elements[0].state.focused = false;
    let events = watchdog.tick(&changed, true);
    println!("watchdog events: {events:?}");
}

pub fn merge_events(&self, events: Vec<CelEvent>) -> Vec<CelEvent>

Merge source-specific push events that have already been normalized to CEL events.

pub fn merge_ax_events<T>(&self, _events: Vec<T>) -> Vec<CelEvent>

Compatibility shim for runtimes that still receive source-specific accessibility events. Convert those events before calling merge_events if push-event fidelity matters.

pub fn reset(&mut self)

Reset the watchdog state (e.g., when restarting monitoring).

Trait Implementations

impl Default for ContextWatchdog

fn default() -> Self

Returns the “default value” for a type.