zeph-core 0.15.2

Core agent loop, configuration, context builder, metrics, and vault for Zeph
Documentation 
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
43
44
45
46
47
48
49
50

// SPDX-FileCopyrightText: 2026 Andrei G <bug-ops>
// SPDX-License-Identifier: MIT OR Apache-2.0

use zeph_tools::executor::ToolCall;

use super::{Agent, error::AgentError};
use crate::channel::Channel;

impl<C: Channel> Agent<C> {
    /// Dispatch `/scheduler [subcommand]` slash command.
    ///
    /// # Errors
    ///
    /// Returns an error if the channel send fails or the tool executor returns an error.
    pub async fn handle_scheduler_command(&mut self, input: &str) -> Result<(), AgentError> {
        let args = input.strip_prefix("/scheduler").unwrap_or("").trim();

        if args.is_empty() || args == "list" {
            return self.handle_scheduler_list().await;
        }

        self.channel
            .send("Unknown /scheduler subcommand. Available: /scheduler list")
            .await?;
        Ok(())
    }

    async fn handle_scheduler_list(&mut self) -> Result<(), AgentError> {
        let call = ToolCall {
            tool_id: "list_tasks".to_owned(),
            params: serde_json::Map::new(),
        };
        match self.tool_executor.execute_tool_call_erased(&call).await {
            Ok(Some(output)) => {
                self.channel.send(&output.summary).await?;
            }
            Ok(None) => {
                self.channel
                    .send("Scheduler is not enabled or list_tasks tool is unavailable.")
                    .await?;
            }
            Err(e) => {
                self.channel
                    .send(&format!("Failed to list scheduled tasks: {e}"))
                    .await?;
            }
        }
        Ok(())
    }
}