mirror of
https://github.com/earendil-works/pi.git
synced 2026-10-28 09:44:37 +08:00
Mario Zechner
0104fef1e9
Moves chord2 (contracts, objects, cells, roots, plugins, hot reload, memory/IPC/WebSocket links) from p2 into packages/chord, with its tests (now on vitest) and docs. The root export is the new runtime plus the shared base (Context, JsonValue, JsonRepresentation, Draft, copyJson, isJsonValue, replicatedState and its types). ./node now holds the host manager, child control, process locks, and nodeLoader. ./context and ./delta are unchanged; ./bundler is removed. replicatedState stays a standalone module with the same exports. It no longer exposes the exact-op subscription the removed service provider used, so listener failures of mutable states are always reported asynchronously. The package depends on typebox instead of esbuild. The wire format stays JSON.
27 lines
1.0 KiB
TypeScript
27 lines
1.0 KiB
TypeScript
import { createHost, memoryLinkPair, replicatedState } from "@earendil-works/chord";
|
|
import { createAssistantMessageEventStream, Type } from "@earendil-works/pi-ai";
|
|
import { complete, getModel, getProviders, streamSimple } from "@earendil-works/pi-ai/compat";
|
|
import { Agent, streamProxy } from "@earendil-works/pi-agent-core";
|
|
|
|
// Keep this entry browser-safe. It is bundled by scripts/check-browser-smoke.mjs
|
|
// to catch accidental Node-only runtime imports in browser-facing package exports.
|
|
const model = getModel("google", "gemini-2.5-flash");
|
|
const schema = Type.Object({ prompt: Type.String() });
|
|
const stream = createAssistantMessageEventStream();
|
|
|
|
const agent = new Agent({ initialState: { model }, streamFn: streamSimple });
|
|
agent.steer({ role: "user", content: [{ type: "text", text: "queued" }], timestamp: 0 });
|
|
|
|
console.log(
|
|
model.id,
|
|
getProviders().length,
|
|
typeof complete,
|
|
schema.type,
|
|
typeof stream.push,
|
|
agent.hasQueuedMessages(),
|
|
typeof streamProxy,
|
|
typeof createHost,
|
|
typeof memoryLinkPair,
|
|
replicatedState({ browser: true }).value.browser,
|
|
);
|