backend

type ActiveTurnState struct {
	Checkpoint     harness.ActiveTurnCheckpoint `json:"checkpoint"`
	SourceMetadata map[string]string            `json:"source_metadata,omitempty"`
	PendingSteers  []protocol.PendingSteer      `json:"pending_steers,omitempty"`
	CreatedAt      time.Time                    `json:"created_at,omitzero"`
	UpdatedAt      time.Time                    `json:"updated_at,omitzero"`
}

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

type Config struct {
	ConversationID, Agent, AgentAfterRecovery, ManagedConversationID, ExternalConversationID string
	OutputTargets                                                                            []protocol.OutputTarget
	RecoveringActiveTurn                                                                     bool
	RequestRestart                                                                           func(context.Context, string) (string, error)
	RequestReload                                                                            func(context.Context, string) (string, error)
	UserQuestionAsker                                                                        protocol.UserQuestionAsker
	StartNewThread                                                                           func(context.Context, *protocol.StartNewThreadRequest) (protocol.StartNewThreadResult, error)
	SessionService                                                                           *SessionService
	SteerDrain                                                                               rocketcode.SteerDrain
	EnqueueActivation                                                                        EnqueueActivation
}

type CronScheduleRun struct {
	ScheduleID   string
	RelativePath string
	DueAt        time.Time
}

type CronScheduleState struct {
	ScheduleID   string
	RelativePath string
	NextDue      time.Time
}

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

type DevelopmentTurnResult struct {
	Thinking, Answer string
}

type EnqueueActivation struct {
	Fn func(context.Context, *protocol.ThreadQueueItem, *protocol.InboundMessage) error
}

type ExternalMCPSessionState struct {
	Agent                 string `json:"agent,omitempty"`
	PrivateConversationID string `json:"private_conversation_id,omitempty"`
	ManagedConversationID string `json:"managed_conversation_id,omitempty"`
	SlackChannel          string `json:"slack_channel,omitempty"`
}

type GoalState struct {
	Objective            string    `json:"objective,omitempty"`
	CheckScript          string    `json:"check_script,omitempty"`
	MaxTurns             int       `json:"max_turns,omitempty"`
	TurnsUsed            int       `json:"turns_used,omitempty"`
	Status               string    `json:"status,omitempty"`
	Note                 string    `json:"note,omitempty"`
	SlackRecipientTeamID string    `json:"slack_recipient_team_id,omitempty"`
	SlackRecipientUserID string    `json:"slack_recipient_user_id,omitempty"`
	CreatedAt            time.Time `json:"created_at,omitzero"`
	UpdatedAt            time.Time `json:"updated_at,omitzero"`
}

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

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

type ObservedSessionEntry struct {
	ID    int64
	Entry harness.SessionEntry
}

type PruneStateStats struct {
	Threads, ExternalMCPSessions int
	SessionRows                  int64
}

type RawRunProgress struct {
	SessionService *SessionService
	ConversationID string

	Thinking, Message func(context.Context, string) error
	RequestRestart    func(context.Context, string) (string, error)
	RequestReload     func(context.Context, string) (string, error)
	StartNewThread    func(context.Context, *protocol.StartNewThreadRequest) (protocol.StartNewThreadResult, error)
	TextChannel       string
}

type RawRunResult struct {
	Text, VerbatimMessage string
	Attachments           []protocol.OutboundAttachment
}

type RunFunc func(context.Context, string, string, *slog.Logger, *RawRunProgress) (protocol.CronRunResult, error)

type Runtime struct {
	Cfg                      *config.Config
	ConfigPath               string
	Log                      *slog.Logger
	RunCtx                   context.Context
	Channels                 protocol.Channels
	Sessions                 *SessionService
	Cron                     *Manager
	OverlayMu                *sync.Mutex
	Reload                   func(context.Context, string) (string, error)
	Restart                  func(context.Context, string) (string, error)
	RecoveredTurns           []ActiveTurnState
	CannotResume             []cannotResumeItem
	ExternalMCPUsers         map[string]string
	RefreshExternalMCPAgents *func() error

	TextRouter protocol.PrimaryTextRouter
	// contains filtered or unexported fields
}

type SessionListOptions struct {
	Since, Until time.Time
	Limit        int
}

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

type SessionSummary struct {
	ConversationID, LastUserMessage, LastAssistantMessage string
	Turns                                                 int
	LastUpdated                                           time.Time
}

type SideAskRunner struct {
	Config   *config.Config
	Sessions *SessionService
	Logger   *slog.Logger
}

type SlackFrontend interface {
	HandleBroadcast(context.Context, *protocol.Broadcast) protocol.BroadcastAcknowledgement
	Start(context.Context) error
	Stop(context.Context) error
	SendResponse(context.Context, *protocol.OutboundMessage) error
	AbortResponse(*protocol.OutboundMessage)
	StartNewThreadRoot(context.Context, *protocol.StartNewThreadRequest) (protocol.StartNewThreadRootResult, error)
	AskUserQuestion(context.Context, *protocol.AskUserQuestionRequest) (protocol.AskUserQuestionAnswer, error)
	DrainSteers(context.Context, string) []string
	ActivateEnqueue(context.Context, *protocol.ThreadQueueItem, *protocol.InboundMessage) error
	SetPendingSteersSink(protocol.PendingSteersSink)
	RestorePendingSteers(string, []protocol.PendingSteer)
	DiscardPendingSteers(context.Context, []protocol.PendingSteer)
}

type ThreadCreator string

type ThreadState struct {
	Agent     string        `json:"agent,omitempty"`
	CreatedBy ThreadCreator `json:"created_by,omitempty"`
}