hippox 0.6.1

🦛A reliable, autonomous LLM runtime and skill orchestration engine, Capable of processing natural language and automatically executing OS-native atomic skills, fundamentally enabling the LLM to truly take over the computer.
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

//! Signal bus module for task and step control
//!
//! This module provides two global signal buses for controlling task execution:
//! - Task signal bus: controls entire tasks (pause, stop)
//! - Task Step signal bus: controls individual steps within a task

use hippox_drivers::DriverSignal;
use once_cell::sync::Lazy;
use std::collections::HashMap;
use std::sync::RwLock;

/// Signal state enumeration
#[derive(Debug, Clone, PartialEq, Eq)]
pub enum TaskSignalStatus {
    Pause,
    Stop,
}

#[derive(Debug, Clone, PartialEq, Eq)]
pub struct TaskSignal {
    status: TaskSignalStatus,
    msg: Option<String>,
}

/// Task signal bus: task_id -> Signal
pub(crate) static TASK_SIGNAL_BUS: Lazy<RwLock<HashMap<String, TaskSignal>>> =
    Lazy::new(|| RwLock::new(HashMap::new()));

/// Task Step signal bus: task_id -> (step_index -> Signal)
pub(crate) static TASK_STEP_SIGNAL_BUS: Lazy<
    RwLock<HashMap<String, HashMap<usize, DriverSignal>>>,
> = Lazy::new(|| RwLock::new(HashMap::new()));