Models

type Model = {
  complete(input: ModelInput): Promise<ModelOutput>;
  stream(input: ModelInput): AsyncIterable<ModelToken>;
};

import type { Model } from "stateweave";

export const model: Model = {
  async complete(input) {
    const response = await provider.generate({
      system: input.system,
      prompt: input.prompt,
      signal: input.signal
    });
    return { text: response.text, usage: response.usage };
  },

  async *stream(input) {
    yield { type: "token", token: (await this.complete(input)).text };
  }
};

import { AnthropicModel, createModelFromEnv, MockModel } from "stateweave";

input.prompt   the compiled causal view
input.system   the action protocol and tool list
signal         an abort signal
parameters     adapter-specific

for await (const event of agent.streamEvents("Inspect the workspace")) {
  if (event.type === "model_token") process.stdout.write(event.token);
  if (event.type === "model_metadata") console.log(event.metadata);
  if (event.type === "final") console.log(event.result.finalAnswer);
}