turnexecutors

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

type AudioFormat int

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

type MediaErrorType string

type MediaLoadError struct {
	Type        MediaErrorType // Error category
	Index       int            // Content part index where error occurred
	Source      string         // Media source (file path or URL)
	ContentType string         // Content type (image, audio, video)
	Message     string         // Human-readable error message
	Cause       error          // Underlying error (if any)
}

type MessageStreamChunk struct {
	// All messages accumulated so far (user + assistant + tool results)
	Messages []types.Message

	// Content delta from this specific chunk
	Delta string

	// Which message is being updated (index in Messages array)
	MessageIndex int

	// Token count (accumulated)
	TokenCount int

	// Finish reason (only in final chunk)
	FinishReason *string

	// Error if streaming failed
	Error error

	// Metadata
	Metadata map[string]interface{}
}

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

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

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

type StateStoreConfig struct {
	Store    interface{}            // State store implementation (statestore.Store)
	UserID   string                 // User identifier (optional)
	Metadata map[string]interface{} // Additional metadata to store (optional)
}

type TurnExecutor interface {
	ExecuteTurn(ctx context.Context, req TurnRequest) error
	ExecuteTurnStream(ctx context.Context, req TurnRequest) (<-chan MessageStreamChunk, error)
}

type TurnRequest struct {
	// Provider and configuration
	Provider    providers.Provider
	Scenario    *config.Scenario
	Temperature float64
	MaxTokens   int
	Seed        *int
	Metadata    map[string]interface{} // Optional execution metadata (e.g., judge targets/defaults)

	// Prompt assembly (moved to pipeline)
	PromptRegistry *prompt.Registry
	TaskType       string
	Region         string
	PromptVars     map[string]string // Variable overrides from arena.yaml prompt_configs[].vars

	// Base directory for resolving relative file paths in media content
	BaseDir string

	// State management (StateStore handles all history)
	StateStoreConfig *StateStoreConfig // State store configuration
	ConversationID   string            // Conversation identifier for state persistence

	// Executor-specific fields (only one should be set depending on executor type)
	ScriptedContent string                   // ScriptedExecutor: text-only user message (legacy)
	ScriptedParts   []config.TurnContentPart // ScriptedExecutor: multimodal parts (precedence)
	SelfPlayRole    string                   // SelfPlayExecutor: the self-play role
	SelfPlayPersona string                   // SelfPlayExecutor: the persona to use

	// Assertions to validate after turn execution
	Assertions []assertions.AssertionConfig

	// Observability
	EventBus *events.EventBus
	RunID    string
}