agent

Documentation

Index

• func BuildSystemPrompt(workspaceDir string, files []string) (string, error)
• func CreateAgent(ctx context.Context, cfg Config, systemPrompt string, ...) (fantasy.Agent, fantasy.LanguageModel, error)
• type ChatStreamOptions
• type Config
• type Service
  • func NewService(agent fantasy.Agent, model fantasy.LanguageModel, store *memory.Store, ...) *Service
  • func (s *Service) Chat(ctx context.Context, sessionID, prompt string) (string, error)
  • func (s *Service) ChatStream(ctx context.Context, sessionID, prompt string, cb StreamCallback, ...) (string, error)
  • func (s *Service) DeleteSession(ctx context.Context, sessionID string) error
  • func (s *Service) ListSessionMessages(ctx context.Context, sessionID string, _ int) ([]SessionMessage, error)
  • func (s *Service) ListSessions(ctx context.Context) ([]memory.SessionInfo, error)
  • func (s *Service) PromptObject(ctx context.Context, prompt string, schemaJSON []byte, ...) ([]byte, string, error)
• type SessionMessage
• type StoredPart
• type StreamCallback
• type StreamEvent

Functions

func BuildSystemPrompt

func BuildSystemPrompt(workspaceDir string, files []string) (string, error)

func CreateAgent

func CreateAgent(
	ctx context.Context, cfg Config, systemPrompt string,
	tools []fantasy.AgentTool, logger *zap.Logger,
) (fantasy.Agent, fantasy.LanguageModel, error)

Types

type ChatStreamOptions

type ChatStreamOptions struct {
	// Regenerate signals the runtime to attach the produced parts
	// as a new branch onto the most recent assistant turn for the
	// session. Falls back to a fresh row if no prior assistant
	// turn exists.
	Regenerate bool
}

ChatStreamOptions modulates a ChatStream invocation.

type Config

type Config struct {
	Provider      string
	ModelName     string
	APIKey        string
	APIBase       string
	MaxTokens     int
	MaxIterations int
}

type Service

type Service struct {
	// contains filtered or unexported fields
}

func NewService

func NewService(
	agent fantasy.Agent, model fantasy.LanguageModel,
	store *memory.Store, compactor *memory.Compactor, logger *zap.Logger,
) *Service

func (*Service) Chat

func (s *Service) Chat(ctx context.Context, sessionID, prompt string) (string, error)

func (*Service) ChatStream

func (s *Service) ChatStream(
	ctx context.Context, sessionID, prompt string, cb StreamCallback, opts ChatStreamOptions,
) (string, error)

ChatStream runs one streamed turn against the configured model and persists the assistant's structured parts. When opts.Regenerate is true and a prior assistant turn exists for the session, the new parts get appended as a branch to that turn instead of inserting a new row, so refresh recovers all alternatives.

func (*Service) DeleteSession

func (s *Service) DeleteSession(ctx context.Context, sessionID string) error

func (*Service) ListSessionMessages

func (s *Service) ListSessionMessages(ctx context.Context, sessionID string, _ int) ([]SessionMessage, error)

ListSessionMessages returns the recent messages stored for sessionID in role/content form suitable for gRPC transport. limit <= 0 means "use the store default" (LIMIT 50 today).

func (*Service) ListSessions

func (s *Service) ListSessions(ctx context.Context) ([]memory.SessionInfo, error)

func (*Service) PromptObject

func (s *Service) PromptObject(
	ctx context.Context,
	prompt string, schemaJSON []byte, schemaName, schemaDesc string,
) ([]byte, string, error)

PromptObject runs a one-shot, stateless structured-output query against the underlying LanguageModel. No session memory is loaded or saved, no tool loop is run — just prompt + schema in, parsed object out. Matches fantasy.LanguageModel.GenerateObject one-to-one and exists so the runtime's gRPC surface has a place to hang the call without exposing the model type through Service's public API.

schemaJSON must be a JSON Schema document that unmarshals into fantasy/schema.Schema (common subset: type, properties, required, items, enum, format, min/max). schemaName and schemaDesc surface in tool-mode providers as the synthetic tool's name/description.

ObjectMode (JSON / tool / text / auto) is provider-level — set when the LanguageModel is constructed via e.g. anthropic.WithObjectMode(...). This method doesn't override it per-call because fantasy.ObjectCall has no per-call mode field.

Returns (objectJSON, rawText). rawText is the model's unparsed reply — useful for debugging when repair was needed.

type SessionMessage

type SessionMessage struct {
	Role         string
	Content      string
	BranchesJSON string
	ActiveBranch int32
	CreatedAt    int64
}

SessionMessage is the plain wire-ready view of a stored chat message: role, text, and its creation time. Compacted or summarised entries already flow through the store as role=assistant, so callers get a post-compaction view.

type StoredPart

type StoredPart struct {
	Kind   string `json:"kind"`              // "text" | "tool"
	Text   string `json:"text,omitempty"`    // kind=text
	ToolID string `json:"tool_id,omitempty"` // kind=tool, runtime-issued id
	Name   string `json:"name,omitempty"`    // kind=tool
	Input  string `json:"input,omitempty"`   // kind=tool, raw JSON the model produced
	Output string `json:"output,omitempty"`  // kind=tool
	State  string `json:"state,omitempty"`   // "input-available" | "output-available"
}

StoredPart is the on-disk shape of one piece of an assistant response. The dashboard rendering layer mirrors this exactly — kind=text accumulates streamed text deltas; kind=tool captures one tool call + its result, parsed via the runtime's stream callbacks. Stored as an array of StoredPart inside the messages row's `content` column for assistant turns.

type StreamCallback

type StreamCallback func(event StreamEvent)

type StreamEvent

type StreamEvent struct {
	Type     string
	Step     int
	ToolName string
	ToolID   string
	Content  string
}