kit/internal/agent/steer.go

package agent

import (
	"context"

	"charm.land/fantasy"
)

// SteerMessage carries a steering prompt and optional file attachments
// (e.g. clipboard images) through the steer channel.
type SteerMessage struct {
	Text  string
	Files []fantasy.FilePart
}

// steerChKey is the context key for the steer channel.
type steerChKey struct{}

// steerConsumedKey is the context key for the steer-consumed callback.
type steerConsumedKey struct{}

// ContextWithSteerCh returns a new context with the steer channel attached.
// The agent's PrepareStep function checks this channel between steps and
// injects any pending steer messages as user messages before the next LLM call.
func ContextWithSteerCh(ctx context.Context, ch <-chan SteerMessage) context.Context {
	return context.WithValue(ctx, steerChKey{}, ch)
}

// ContextWithSteerConsumed returns a new context with a callback that fires
// when steer messages are consumed by PrepareStep. The count argument is the
// number of messages injected in this batch.
func ContextWithSteerConsumed(ctx context.Context, fn func(count int)) context.Context {
	return context.WithValue(ctx, steerConsumedKey{}, fn)
}

// steerChFromContext extracts the steer channel from the context, or nil.
func steerChFromContext(ctx context.Context) <-chan SteerMessage {
	ch, _ := ctx.Value(steerChKey{}).(<-chan SteerMessage)
	return ch
}

// steerConsumedFromContext extracts the steer-consumed callback, or nil.
func steerConsumedFromContext(ctx context.Context) func(int) {
	fn, _ := ctx.Value(steerConsumedKey{}).(func(int))
	return fn
}