hippox 0.6.3

🦛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
33
34
35
36
37
38
39
40
41
42

use crate::{DriverScheduler, WorkflowCallback, WorkflowExecutor, WorkflowMode};
use serde::{Deserialize, Serialize};
use std::sync::Arc;
/// Intent analysis result from Step 1
#[derive(Debug, Clone, Deserialize, Serialize)]
pub struct IntentAnalysisResult {
    pub categories: Vec<String>,
    pub clean_intent: String,
}
/// Workflow execution result from Step 2  
#[derive(Debug, Clone)]
pub struct WorkflowExecResult {
    /// The standard JSON output from workflow
    pub json_output: String,
    /// Original user input
    pub original_input: String,
}
/// Format result from Step 3
#[derive(Debug, Clone)]
pub struct FormatResult {
    /// Final output after format conversion
    pub final_output: String,
    /// Whether conversion was performed
    pub was_converted: bool,
}
/// Pipeline trait - defines the three steps of execution
#[async_trait::async_trait]
pub trait Pipeline: Send + Sync {
    /// Step 1: Analyze user intent into driver categories
    async fn intent_analysis(&self, scheduler: &DriverScheduler, input: &str, task_id: &str) -> anyhow::Result<IntentAnalysisResult>;
    /// Step 2: Core workflow execution
    async fn workflow_execution(
        &self,
        mode: WorkflowMode,
        executor: &WorkflowExecutor,
        scheduler: &DriverScheduler,
        input: &str,
        disabled_drivers: Option<&[String]>,
    ) -> WorkflowExecResult;
    /// Step 3: Format conversion based on user's structure requirements
    async fn response_formatting(&self, scheduler: &DriverScheduler, original_input: &str, json_output: &str, task_id: &str) -> FormatResult;
}