harnessbridge

type ActivationHook func(context.Context, *events.InboundMessage) error

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

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

type CheckAndRecoverSessionDBResult struct {
	DBExists  bool
	Healthy   bool
	Recovered bool
}

type Config struct {
	ConversationID, Agent, AgentAfterRecovery, ManagedConversationID, ExternalConversationID string
	OutputTargets                                                                            []events.OutputTarget
	RecoveringActiveTurn                                                                     bool
	RequestRestart                                                                           func(context.Context, string) (string, error)
	RequestReload                                                                            func(context.Context, string) (string, error)
	AskUserQuestion                                                                          func(context.Context, *events.AskUserQuestionRequest) (events.AskUserQuestionAnswer, error)
	StartNewThread                                                                           func(context.Context, *events.StartNewThreadRequest) (events.StartNewThreadResult, error)
	SessionService                                                                           *SessionService
}

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

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

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

type GoalRequest struct {
	Objective, CheckScript string
	MaxTurns               int
}

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"`
	CreatedAt   time.Time `json:"created_at,omitzero"`
	UpdatedAt   time.Time `json:"updated_at,omitzero"`
}

type ObservedSessionEntry struct {
	ID    int64
	Entry harness.SessionEntry
}

type PrimaryTextRouter interface {
	StartThread(ctx context.Context, agent string, target events.TextConversationTarget, inbound *events.InboundMessage) error
	StartGoalInThread(ctx context.Context, agent, objective, checkScript string, maxTurns int, target events.TextConversationTarget, inbound *events.InboundMessage) error
	InterruptThread(target events.TextConversationTarget) (*events.InboundMessage, error)
	RegisterCronThread(ctx context.Context, target events.TextConversationTarget, agent string) error
	ThreadAgent(target events.TextConversationTarget) (agent string, handled bool, err error)
	SwitchThreadAgent(target events.TextConversationTarget, agent string) (bool, error)
	SubmitThreadReply(ctx context.Context, target events.TextConversationTarget, inbound *events.InboundMessage) (bool, error)
}

type PruneStateStats struct {
	Threads, ExternalMCPSessions int
	SessionRows                  int64
}

type RawRunProgress struct {
	SessionService *SessionService
	ConversationID string

	Thinking, Message      func(context.Context, string) error
	ScheduleMessage        func(time.Duration, string, bool) error
	ResetScheduledMessages func() error
	RequestRestart         func(context.Context, string) (string, error)
	RequestReload          func(context.Context, string) (string, error)
}

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

type ScheduledMessageState struct {
	ConversationID string        `json:"conversation_id,omitempty"`
	Agent          string        `json:"agent,omitempty"`
	Message        string        `json:"message,omitempty"`
	DueAt          time.Time     `json:"due_at,omitzero"`
	Recurring      bool          `json:"recurring,omitempty"`
	Interval       time.Duration `json:"interval,omitempty"`
}

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 State struct {
	Threads                     map[string]ThreadState             `json:"threads,omitempty"`
	ExternalMCPSessions         map[string]ExternalMCPSessionState `json:"external_mcp_sessions,omitempty"`
	ScheduledMessages           map[string]ScheduledMessageState   `json:"scheduled_messages,omitempty"`
	Goals                       map[string]GoalState               `json:"goals,omitempty"`
	PendingRestartNotifications map[string]bool                    `json:"pending_restart_notifications,omitempty"`
}

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

type ThreadCreator string

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

type VacuumStats struct {
	DBExists                         bool
	BeforePageCount, BeforeFreePages int64
	AfterPageCount, AfterFreePages   int64
}

type WALCheckpointStats struct {
	Busy, LogFrames, CheckpointedFrames int64
}