controlplane

type BranchNameInput struct {
	ModelSelection TextGenerationModelSelection
	Summary        string
	Metadata       map[string]any
}

type BranchNameOutput struct {
	Name     string
	Metadata map[string]any
}

type CommitMessageInput struct {
	ModelSelection TextGenerationModelSelection
	Diff           string
	Instruction    string
	Metadata       map[string]any
}

type CommitMessageOutput struct {
	Message  string
	Metadata map[string]any
}

type ModelOptions struct {
	ReasoningEffort string `json:"reasoning_effort,omitempty"`
	ThinkingLevel   string `json:"thinking_level,omitempty"`
	ThinkingBudget  *int   `json:"thinking_budget,omitempty"`
}

type PrContentInput struct {
	ModelSelection TextGenerationModelSelection
	Diff           string
	Title          string
	Instruction    string
	Metadata       map[string]any
}

type PrContentOutput struct {
	Title    string
	Body     string
	Metadata map[string]any
}

type Provider interface {
	Runtime() string
	Describe() contract.RuntimeDescriptor
	StartSession(context.Context, StartSessionRequest) (*contract.RuntimeSession, error)
	ResumeSession(context.Context, ResumeSessionRequest) (*contract.RuntimeSession, error)
	SendInput(context.Context, SendInputRequest) (*contract.RuntimeEvent, error)
	Interrupt(context.Context, string) (*contract.RuntimeEvent, error)
	Respond(context.Context, RespondRequest) (*contract.RuntimeEvent, error)
	StopSession(context.Context, string) (*contract.RuntimeEvent, error)
	ListSessions(context.Context) ([]contract.RuntimeSession, error)
}

type RespondRequest struct {
	SessionID string
	RequestID string
	Action    contract.RespondAction
	Text      string
	OptionID  string
	Answers   []contract.RequestAnswer
	Metadata  map[string]any
}

type ResumeSessionRequest struct {
	SessionID         string
	ProviderSessionID string
	CWD               string
	Model             string
	ModelOptions      ModelOptions
	Metadata          map[string]any
}

type RuntimeMetadata struct {
	Title    string
	System   string
	Agent    string
	Model    string
	Provider string
	Labels   map[string]string
	Extra    map[string]any
}

type SendInputRequest struct {
	SessionID string
	Text      string
	Metadata  map[string]any
}

type SessionController interface {
	ListSessions(context.Context, string) ([]contract.RuntimeSession, error)
	ResumeSession(context.Context, string, ResumeSessionRequest) (*contract.RuntimeSession, error)
}

type StartSessionRequest struct {
	SessionID    string
	CWD          string
	Model        string
	ModelOptions ModelOptions
	Prompt       string
	Metadata     map[string]any
}

type StructuredResultExtractor func(values ...string) (rendered string, normalisedJSON string)

type StructuredSessionController interface {
	SubscribeEvents(buffer int) (<-chan contract.RuntimeEvent, func())
	StartSession(context.Context, string, StartSessionRequest) (*contract.RuntimeSession, error)
	SendInput(context.Context, SendInputRequest) (*contract.RuntimeEvent, error)
}

type StructuredSessionOptions struct {
	EventBuffer int
	TickEvery   time.Duration

	Extract StructuredResultExtractor

	RepairPrompt   string
	RepairMetadata map[string]any
	MaxRepairTurns int

	OnSessionStarted          func(context.Context, *contract.RuntimeSession) error
	OnTick                    func(context.Context, string) error
	OnEvent                   func(context.Context, contract.RuntimeEvent) error
	OnTurnEvents              func(context.Context, string) error
	OnMissingStructuredResult func(context.Context) error
}

type StructuredSessionResult struct {
	Session       *contract.RuntimeSession
	Text          string
	JSON          string
	Repaired      bool
	RepairAttempt int
}

type TextGenerationModelSelection struct {
	Provider  string
	Model     string
	Options   ModelOptions
	Fallbacks []string
}

type TextGenerationProvider interface {
	GenerateCommitMessage(context.Context, CommitMessageInput) (*CommitMessageOutput, error)
	GeneratePrContent(context.Context, PrContentInput) (*PrContentOutput, error)
	GenerateBranchName(context.Context, BranchNameInput) (*BranchNameOutput, error)
	GenerateThreadTitle(context.Context, ThreadTitleInput) (*ThreadTitleOutput, error)
}

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

type ThreadTitleInput struct {
	ModelSelection TextGenerationModelSelection
	Prompt         string
	Metadata       map[string]any
}

type ThreadTitleOutput struct {
	Title    string
	Metadata map[string]any
}

type TurnAccumulator struct {
	EventLines  []string
	JoinedText  strings.Builder
	LatestDelta string
	FinalText   string
}