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
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
|
//! `public.zig` — the sole exported root of `libpanto`.
//!
//! This file is the **explicit public API allowlist**. Internal modules keep
//! their `pub` declarations (needed for cross-file linking) but are never
//! re-exported here; the public surface is what this file names, not
//! "whatever happens to be `pub`."
//!
//! The surface is organized around two user jobs (see
//! `docs/libpanto-cleanup.md`):
//! 1. Run an agent loop — configure a provider, register tools, submit a
//! turn, consume the pull event stream, persist.
//! 2. Construct & operate on conversations — build a `Conversation` by
//! hand, do context-management surgery.
//!
//! Every name here is a straight alias of an internal decl: the internal
//! types have been shaped to *be* the public API (public methods + a
//! transparent public field or two, every other field underscore-prefixed
//! internal state), so this file selects the surface rather than wrapping
//! it. Three buckets:
//! - **behavioral** (`Agent`, `Stream`, `Conversation`): heap-pinned
//! drivers whose `init` hands back a cheap, movable pointer; the chosen
//! methods plus a transparent field (`Agent.conversation`,
//! `Stream.state`) are the surface.
//! - **data (read/output)** (`Event`, `Usage`, `Pricing`, `SessionInfo`):
//! inspected field-by-field.
//! - **data (constructed)** (`ContentBlock`, `Message`, the block types,
//! the `Config` family): Zig users build them with `ArrayList` directly.
const std = @import("std");
const config_mod = @import("config.zig");
const conversation_mod = @import("conversation.zig");
const agent_mod = @import("agent.zig");
const stream_mod = @import("stream.zig");
const provider_mod = @import("provider.zig");
const tool_mod = @import("tool.zig");
const tool_source_mod = @import("tool_source.zig");
const pricing_mod = @import("pricing.zig");
const session_store_mod = @import("session_store.zig");
const fs_store_mod = @import("file_system_jsonl_store.zig");
const null_store_mod = @import("null_store.zig");
// ===========================================================================
// Process lifecycle
// ===========================================================================
/// Initialize the process-global HTTP client. Call once before any turn.
pub fn init(allocator: std.mem.Allocator, io: std.Io) void {
config_mod.initHttp(allocator, io);
}
/// Tear down the process-global HTTP client. Call once at shutdown.
pub fn deinit() void {
config_mod.deinitHttp();
}
// ===========================================================================
// Config (data, aliased)
// ===========================================================================
pub const Config = config_mod.Config;
pub const ProviderConfig = config_mod.ProviderConfig;
pub const OpenAIChatConfig = config_mod.OpenAIChatConfig;
pub const AnthropicMessagesConfig = config_mod.AnthropicMessagesConfig;
pub const APIStyle = config_mod.APIStyle;
pub const ReasoningEffort = config_mod.ReasoningEffort;
pub const CompactionConfig = config_mod.CompactionConfig;
pub const RetryConfig = config_mod.RetryConfig;
pub const WireIdentity = config_mod.WireIdentity;
// ===========================================================================
// Conversation construction (data, aliased)
// ===========================================================================
pub const ContentBlock = conversation_mod.ContentBlock;
pub const Message = conversation_mod.Message;
pub const MessageRole = conversation_mod.MessageRole;
pub const TextualBlock = conversation_mod.TextualBlock;
pub const ThinkingBlock = conversation_mod.ThinkingBlock;
pub const ToolUseBlock = conversation_mod.ToolUseBlock;
pub const ToolResultBlock = conversation_mod.ToolResultBlock;
pub const ResultPartStored = conversation_mod.ResultPartStored;
pub const StoredMediaPart = conversation_mod.StoredMediaPart;
pub const SystemBlock = conversation_mod.SystemBlock;
pub const SystemMode = conversation_mod.SystemMode;
pub const CompactionSummaryBlock = conversation_mod.CompactionSummaryBlock;
pub const Usage = conversation_mod.Usage;
pub const effectiveSystemBlocks = conversation_mod.effectiveSystemBlocks;
/// The conversation type. Aliased straight through: its interface has been
/// pared down to exactly the public surface (constructors `init`/`deinit`,
/// the `add*`/`replace*` builders, and the `messages`/`allocator` data
/// fields), so no façade is needed. This is what `Session.load` returns,
/// what `Agent.init` adopts, and what `Agent.conversation()` borrows a
/// pointer to (for in-place surgery). Build one standalone with `init` for
/// by-hand construction; once handed to an `Agent` it is owned by the agent.
pub const Conversation = conversation_mod.Conversation;
// ===========================================================================
// Tools (data, aliased)
// ===========================================================================
pub const Tool = tool_mod.Tool;
pub const ToolSource = tool_source_mod.ToolSource;
pub const ToolDecl = tool_mod.ToolDecl;
pub const ToolCall = tool_source_mod.Call;
pub const ToolCallResult = tool_source_mod.CallResult;
pub const MediaPart = tool_mod.MediaPart;
pub const ResultPart = tool_mod.ResultPart;
/// Result-part ergonomics: a thin wrapper around `[]ResultPart` carrying
/// the `fromText`/`fromTextOwned` constructors and `deinit`. Aliased
/// straight through.
pub const ResultParts = tool_mod.ResultParts;
// ===========================================================================
// Stream (behavioral, heap-pinned)
// ===========================================================================
pub const Event = stream_mod.Event;
pub const ContentBlockType = provider_mod.ContentBlockType;
pub const ProviderRetryInfo = provider_mod.ProviderRetryInfo;
/// The pull event stream for one turn. Aliased straight through: its public
/// surface is exactly `next`/`deinit` plus the transparent `state` field
/// (`State`); every other field is underscore-prefixed internal state.
/// `Agent.run` returns a `*Stream` (heap-pinned); the caller owns it and
/// must `deinit` it (which persists the turn tail and frees the allocation).
///
/// `next()` returns `!?Event`: a value is progress (including the terminal
/// event), `null` is exhaustion, an error is a genuine failure.
pub const Stream = agent_mod.Stream;
// ===========================================================================
// Agent (behavioral, heap-pinned)
// ===========================================================================
pub const UserMessage = agent_mod.UserMessage;
pub const CompactionResult = agent_mod.CompactionResult;
/// The agent loop driver. Aliased straight through: its public surface is
/// exactly the chosen methods (`init`/`deinit`, `registerTool`,
/// `registerToolSource`, `setConfig`, `run`, `addSystemMessage`,
/// `setSystemPrompt`, `compact`, `sessionId`) plus the transparent
/// `conversation` field; every other field is underscore-prefixed internal
/// state.
///
/// `init` heap-pins the agent and returns a `*Agent` — a cheap, movable
/// handle out of the gate ("don't move the Agent" stops being a rule anyone
/// can violate). The caller owns it and must `deinit` it. `session` is
/// minted via `store.create()` (fresh) or `resolve`/`latest` (resume); when
/// `maybe_conversation` is non-null it is adopted (ownership transferred) —
/// the resume path hands the value returned by `Session.load`.
///
/// Operate on the live conversation in place via the `conversation` field
/// (valid for the agent's lifetime; do not retain past it).
pub const Agent = agent_mod.Agent;
// ===========================================================================
// Pricing (data, aliased)
// ===========================================================================
pub const Pricing = pricing_mod.Pricing;
pub const PricingRegistry = pricing_mod.Registry;
// ===========================================================================
// Sessions
// ===========================================================================
pub const SessionStore = session_store_mod.SessionStore;
pub const Session = session_store_mod.Session;
pub const SessionInfo = session_store_mod.SessionInfo;
pub const PersistentMessage = session_store_mod.PersistentMessage;
pub const NullStore = null_store_mod.NullStore;
pub const FileSystemJSONLStore = fs_store_mod.FileSystemJSONLStore;
// ===========================================================================
// Tests
// ===========================================================================
const openai_chat_json = @import("openai_chat_json.zig");
const provider_openai_chat = @import("provider_openai_chat.zig");
const anthropic_messages_json = @import("anthropic_messages_json.zig");
const provider_anthropic_messages = @import("provider_anthropic_messages.zig");
const compaction_mod = @import("compaction.zig");
const sse_mod = @import("sse.zig");
const tool_registry_mod = @import("tool_registry.zig");
const session_mod = @import("session.zig");
const turn_persist_mod = @import("turn_persist.zig");
const image_mod = @import("image.zig");
test {
// See the note in the old root.zig: gate test logs at `.err` so expected
// warning-path tests stay quiet.
std.testing.log_level = .err;
std.testing.refAllDecls(@This());
// Internal modules' tests (not part of the public surface, but their
// tests must still run).
std.testing.refAllDecls(config_mod);
std.testing.refAllDecls(conversation_mod);
std.testing.refAllDecls(agent_mod);
std.testing.refAllDecls(stream_mod);
std.testing.refAllDecls(provider_mod);
std.testing.refAllDecls(tool_mod);
std.testing.refAllDecls(tool_source_mod);
std.testing.refAllDecls(tool_registry_mod);
std.testing.refAllDecls(pricing_mod);
std.testing.refAllDecls(session_store_mod);
std.testing.refAllDecls(fs_store_mod);
std.testing.refAllDecls(null_store_mod);
std.testing.refAllDecls(session_mod);
std.testing.refAllDecls(turn_persist_mod);
std.testing.refAllDecls(compaction_mod);
std.testing.refAllDecls(sse_mod);
std.testing.refAllDecls(image_mod);
std.testing.refAllDecls(openai_chat_json);
std.testing.refAllDecls(provider_openai_chat);
std.testing.refAllDecls(anthropic_messages_json);
std.testing.refAllDecls(provider_anthropic_messages);
}
|
