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
60
61
62
63
64
65
66
67
68
69
|
import type { AgentEvent } from "../contracts/events.js";
import type { Usage } from "../contracts/provider.js";
export function textDeltaEvent(conversationId: string, turnId: string, delta: string): AgentEvent {
return { type: "text-delta", conversationId, turnId, delta };
}
export function reasoningDeltaEvent(
conversationId: string,
turnId: string,
delta: string,
): AgentEvent {
return { type: "reasoning-delta", conversationId, turnId, delta };
}
export function toolCallEvent(
conversationId: string,
turnId: string,
toolCallId: string,
toolName: string,
input: unknown,
): AgentEvent {
return { type: "tool-call", conversationId, turnId, toolCallId, toolName, input };
}
export function toolResultEvent(
conversationId: string,
turnId: string,
toolCallId: string,
toolName: string,
content: string,
isError: boolean,
): AgentEvent {
return { type: "tool-result", conversationId, turnId, toolCallId, toolName, content, isError };
}
export function toolOutputEvent(
conversationId: string,
turnId: string,
toolCallId: string,
data: string,
stream: "stdout" | "stderr",
): AgentEvent {
return { type: "tool-output", conversationId, turnId, toolCallId, data, stream };
}
export function usageEvent(conversationId: string, turnId: string, usage: Usage): AgentEvent {
return { type: "usage", conversationId, turnId, usage };
}
export function turnStartEvent(conversationId: string, turnId: string): AgentEvent {
return { type: "turn-start", conversationId, turnId };
}
export function doneEvent(conversationId: string, turnId: string, reason: string): AgentEvent {
return { type: "done", conversationId, turnId, reason };
}
export function errorEvent(
conversationId: string,
turnId: string,
message: string,
code?: string,
): AgentEvent {
if (code !== undefined) {
return { type: "error", conversationId, turnId, message, code };
}
return { type: "error", conversationId, turnId, message };
}
|
