harnessbridge

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

type CheckAndRecoverSessionDBResult struct {
	DBExists  bool
	Healthy   bool
	Recovered bool
}

type Config struct {
	ConversationID, Agent string
	ConsumeSharedInbound  bool
	OutputTargets         []events.OutputTarget
	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"`
	ConversationID string `json:"conversation_id,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, preSeed bool, 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, seedText string) error
	ThreadAgent(target events.TextConversationTarget) (agent string, handled bool, err error)
	SwitchThreadAgent(target events.TextConversationTarget, agent string) (bool, error)
	PrepareResponseThreadReply(target events.TextConversationTarget) (bool, error)
	SubmitThreadReply(ctx context.Context, target events.TextConversationTarget, inbound *events.InboundMessage) (bool, error)
	SubmitResponseThreadReply(ctx context.Context, target events.TextConversationTarget, inbound *events.InboundMessage) (bool, error)
	SummarizeThread(ctx context.Context, target events.TextConversationTarget) (bool, error)
	RecordResponseCheckpoint(target events.TextConversationTarget, checkpoint events.ResponseCheckpoint) error
}

type PruneStateStats struct {
	Threads, ResponseCheckpoints, 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 ResponseCheckpointState struct {
	ConversationID string `json:"conversation_id,omitempty"`
	SessionEntryID int64  `json:"session_entry_id,omitempty"`
	ResponseID     string `json:"response_id,omitempty"`
	Model          string `json:"model,omitempty"`
	AssistantText  string `json:"assistant_text,omitempty"`
}

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"`
	ResponseCheckpoints         map[string]ResponseCheckpointState `json:"response_checkpoints,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"`
	SeededFromResponse string        `json:"seeded_from_response,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
}