Struct InternalHookEvent 

pub struct InternalHookEvent {
    pub event_type: InternalHookEventType,
    pub action: InternalHookAction,
    pub session_key: Option<String>,
    pub context: Value,
    pub timestamp: DateTime<Utc>,
    pub messages: Vec<String>,
}

内部钩子事件

表示系统中发生的一个内部事件，包含事件类型、动作、上下文数据等信息。 事件可以被注册的处理器监听和处理。

字段

• event_type: 事件类型（Agent、Session、Tool、Command、Gateway）
• action: 事件动作（如 Start、Stop、Create 等）
• session_key: 可选的会话键，用于关联特定会话
• context: JSON 格式的上下文数据，包含事件相关的详细信息
• timestamp: 事件发生的 UTC 时间戳
• messages: 消息列表，处理器可以向其中推送消息

事件键

事件键格式为 type:action（如 agent:start、session:create）， 用于在注册表中匹配处理器。

示例

use aster::hooks::internal::{InternalHookEvent, InternalHookEventType, InternalHookAction};
use serde_json::json;

// 创建一个 Agent 启动事件
let event = InternalHookEvent::new(
    InternalHookEventType::Agent,
    InternalHookAction::Start,
    Some("user:session:123".to_string()),
    json!({
        "agent_id": "agent-001",
        "agent_type": "coding"
    }),
);

assert_eq!(event.event_key(), "agent:start");

Fields

event_type: InternalHookEventType

事件类型

标识事件所属的系统组件类别。

action: InternalHookAction

事件动作

描述事件的具体动作，如启动、停止、创建等。

session_key: Option<String>

会话键（可选）

用于关联特定会话的标识符。对于与会话相关的事件， 此字段通常包含会话的唯一标识。

context: Value

上下文数据

JSON 格式的上下文数据，包含事件相关的详细信息。 不同类型的事件有不同的上下文结构：

• Agent 事件：agent_id、agent_type、workspace_dir、error
• Session 事件：session_id、session_key、source、reason
• Command 事件：command_name、command_args、raw_input
• Gateway 事件：connection_id、channel、message

timestamp: DateTime<Utc>

时间戳

事件发生的 UTC 时间戳，由 new() 构造函数自动填充。

messages: Vec<String>

消息列表

处理器可以向此列表推送消息，用于向用户反馈信息。 初始为空列表。

Implementations

impl InternalHookEvent

pub fn new( event_type: InternalHookEventType, action: InternalHookAction, session_key: Option<String>, context: Value, ) -> Self

创建新的内部钩子事件

自动填充 timestamp 为当前 UTC 时间，messages 初始化为空列表。

参数

• event_type: 事件类型
• action: 事件动作
• session_key: 可选的会话键
• context: 上下文数据（JSON 格式）

示例

use aster::hooks::internal::{InternalHookEvent, InternalHookEventType, InternalHookAction};
use serde_json::json;

let event = InternalHookEvent::new(
    InternalHookEventType::Agent,
    InternalHookAction::Start,
    None,
    json!({"agent_id": "agent-001"}),
);

assert!(event.timestamp <= chrono::Utc::now());
assert!(event.messages.is_empty());

pub fn event_key(&self) -> String

获取事件键

返回格式为 type:action 的事件键，用于在注册表中匹配处理器。

返回值

事件键字符串，如 "agent:start"、"session:create"。

示例

use aster::hooks::internal::{InternalHookEvent, InternalHookEventType, InternalHookAction};
use serde_json::json;

let event = InternalHookEvent::new(
    InternalHookEventType::Session,
    InternalHookAction::Create,
    None,
    json!({}),
);

assert_eq!(event.event_key(), "session:create");

Trait Implementations

impl Clone for InternalHookEvent

fn clone(&self) -> InternalHookEvent

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for InternalHookEvent

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for InternalHookEvent

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for InternalHookEvent

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.