microagents-events 0.1.0

Typed-, JSONRPC-compatible events definitions for the microagents framework
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
51
52
53
54
55
56
57
58
59

# microagents-events

Event types and JSON-RPC serialization for the [microagents](https://github.com/AstraBert/microagents) framework.

## Overview

This crate defines the core event types that flow through an agent session: initialization, user prompts, streaming deltas, tool calls, skill loading and assistant responses. Each event can be converted to and from a JSON-RPC 2.0 notification for transport over a wire or between processes.

## Event Types

| Event | Method | Description |
|-------|--------|-------------|
| `SessionInitEvent` | `session.init` | A new or resumed session starts |
| `SessionStopEvent` | `session.stop` | A session ends with success or error |
| `UserPromptSubmitEvent` | `user.prompt.submit` | The user sends a prompt |
| `StreamDeltaEvent` | `stream.delta` | A chunk of streaming response (text or thinking) |
| `ToolCallEvent` | `tool.call` | The model requests a tool invocation |
| `ToolResultEvent` | `tool.result` | A tool returns its output |
| `SkillLoadEvent` | `skill.load` | A skill is loaded into the session |
| `AssistantResponseEvent` | `assistant.response` | The model produces a complete response |

## Usage

```rust
use microagents_events::*;
use chrono::Utc;

let event = SessionInitEvent {
    session_id: "sess-1".into(),
    model: "gpt-4".into(),
    provider: "openai".into(),
    system: "You are a helpful assistant.".into(),
    init_type: SessionInitType::Start,
    timestamp: Utc::now(),
};

let rpc = event.to_jsonrpc();
// rpc.method == "session.init"
// rpc.params["session_id"] == "sess-1"
```

## Round-trip

```rust
use chrono::Utc;

let rpc = JsonRpcNotification::builder()
    .method("user.prompt.submit".into())
    .add_param("session_id".into(), "s1".into())
    .add_param("turn_id".into(), "t1".into())
    .add_param("prompt".into(), "Hello!".into())
    .add_param("timestamp", serde_json::to_value(Utc::now()).unwrap());

let any = AgentEventAny::try_from(rpc)?;
```

## License

MIT