harnessbridge

Jul 8, 2026

Changes in this version

+ func IsBridgeStopped(err error) bool

+ func NoopActivationHook(_ context.Context, _ *events.InboundMessage) error

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

+ type ActiveTurnState struct

+ Checkpoint harness.ActiveTurnCheckpoint

+ CreatedAt time.Time

+ SourceMetadata map[string]string

+ UpdatedAt time.Time

type Bridge

+ func (b *Bridge) RecoverActiveTurn(ctx context.Context, turn *ActiveTurnState) error

+ func (b *Bridge) SubmitWhenActive(ctx context.Context, msg *events.InboundMessage, activation ActivationHook) error

type Config

+ RecoveringActiveTurn bool

type SessionService

+ func (s *SessionService) ActiveTurn(ctx context.Context, turnID string) (ActiveTurnState, bool, error)

+ func (s *SessionService) ClearActiveTurn(ctx context.Context, turnID string) error

+ func (s *SessionService) ClearCompletedActiveTurn(ctx context.Context, turnID string) error

+ func (s *SessionService) RecordActiveTurnCheckpoint(ctx context.Context, checkpoint *harness.ActiveTurnCheckpoint) error

+ func (s *SessionService) RecoverableActiveTurns(ctx context.Context) ([]ActiveTurnState, error)

+ func (s *SessionService) StartActiveTurn(ctx context.Context, checkpoint *harness.ActiveTurnCheckpoint) error

+ func (s *SessionService) UpsertActiveTurn(ctx context.Context, checkpoint *harness.ActiveTurnCheckpoint, ...) error

Jul 5, 2026

Changes in this version

+ type CheckAndRecoverSessionDBResult struct

+ DBExists bool

+ Healthy bool

+ Recovered bool

+ func CheckAndRecoverSessionDB(ctx context.Context, workspace, runtimeDir string, logger *slog.Logger) (CheckAndRecoverSessionDBResult, error)

Jul 5, 2026

Changes in this version

+ func ValidateRuntimeDefinitions(workspace, runtimeDir string) error

type Config

+ RequestReload func(context.Context, string) (string, error)

+ type CronScheduleRun struct

+ DueAt time.Time

+ RelativePath string

+ ScheduleID string

+ type CronScheduleState struct

+ NextDue time.Time

+ RelativePath string

+ ScheduleID string

type RawRunProgress

+ RequestReload func(context.Context, string) (string, error)

type SessionService

+ func (s *SessionService) ActiveGoalThreads() (map[string]ThreadState, error)

+ func (s *SessionService) ClaimCronSchedule(due CronScheduleState, nextDue, now time.Time) (CronScheduleRun, bool, error)

+ func (s *SessionService) ClaimScheduledMessage(id, conversationID string, dueAt, now time.Time) (ScheduledMessageState, bool, error)

+ func (s *SessionService) CompleteCronRun(relativePath string, now time.Time) error

+ func (s *SessionService) DeleteScheduledMessage(id string) error

+ func (s *SessionService) DueCronSchedules(now time.Time, limit int) ([]CronScheduleState, error)

+ func (s *SessionService) ExternalMCPSession(externalConversationID string) (ExternalMCPSessionState, bool, error)

+ func (s *SessionService) PutScheduledMessage(id string, message *ScheduledMessageState) error

+ func (s *SessionService) ResetCronSchedules() error

+ func (s *SessionService) ResetScheduledMessages(conversationID string) error

+ func (s *SessionService) ResponseCheckpoint(key string) (ResponseCheckpointState, bool, error)

+ func (s *SessionService) ScheduledMessages() (map[string]ScheduledMessageState, error)

+ func (s *SessionService) ScheduledMessagesForConversation(conversationID string) (map[string]ScheduledMessageState, error)

+ func (s *SessionService) SetThreadAgentIfExists(conversationID, agent string) (bool, error)

+ func (s *SessionService) SyncCronSchedules(schedules []CronScheduleState, now time.Time) error

+ func (s *SessionService) Thread(conversationID string) (ThreadState, bool, error)

+ func (s *SessionService) ThreadForSeed(seedConversationID string) (conversationID string, thread ThreadState, ok bool, err error)

Jun 26, 2026

Changes in this version

type Bridge

+ func (b *Bridge) SeedThreadFromConversation(ctx context.Context, sourceConversationID string) error

type Config

+ StartNewThread func(context.Context, *events.StartNewThreadRequest) (events.StartNewThreadResult, error)

type SessionService

+ func (s *SessionService) MarkThreadCreatedBy(conversationID string, createdBy ThreadCreator) error

+ type ThreadCreator string

+ const ThreadCreatedByCron

type ThreadState

+ CreatedBy ThreadCreator

Jun 25, 2026

Changes in this version

type PrimaryTextRouter

+ ThreadAgent func(target events.TextConversationTarget) (agent string, handled bool, err error)

Jun 21, 2026

Changes in this version

type Config

+ AskUserQuestion func(context.Context, *events.AskUserQuestionRequest) (events.AskUserQuestionAnswer, error)

Jun 16, 2026

Changes in this version

type Bridge

+ func (b *Bridge) SwitchAgent(agent string)

type PrimaryTextRouter

+ SwitchThreadAgent func(target events.TextConversationTarget, agent string) (bool, error)

Jun 15, 2026

Changes in this version

+ const GoalStatusActive

+ const GoalStatusBlocked

+ const GoalStatusBudgetExhausted

+ const GoalStatusComplete

+ const GoalStatusProgress

+ const GoalStatusStopped

+ var ErrGoalAlreadyActive = errors.New("goal already active")

+ func DiscordThreadTarget(conversationID string) (threadID string, ok bool)

+ func SlackThreadTarget(conversationID string) (channelID, threadTS string, ok bool)

+ func ValidateGoalCheckScriptStart(cfg *config.Config, agentName, script string) error

type Bridge

+ func (b *Bridge) InterruptActiveTurn() *events.InboundMessage

+ type GoalRequest struct

+ CheckScript string

+ MaxTurns int

+ Objective string

+ func ParseGoalRequest(text string) (GoalRequest, string, bool)

+ type GoalState struct

+ CheckScript string

+ CreatedAt time.Time

+ MaxTurns int

+ Note string

+ Objective string

+ Status string

+ TurnsUsed int

+ UpdatedAt time.Time

+ type PrimaryTextRouter interface

+ InterruptThread func(target events.TextConversationTarget) (*events.InboundMessage, error)

+ PrepareResponseThreadReply func(target events.TextConversationTarget) (bool, error)

+ PrepareThreadReply func(target events.TextConversationTarget) (bool, error)

+ RecordResponseCheckpoint func(target events.TextConversationTarget, checkpoint events.ResponseCheckpoint) error

+ RegisterCronThread func(ctx context.Context, target events.TextConversationTarget, ...) error

+ StartGoalInThread func(ctx context.Context, agent, objective, checkScript string, maxTurns int, ...) error

+ StartThread func(ctx context.Context, agent string, preSeed bool, ...) error

+ SubmitResponseThreadReply func(ctx context.Context, target events.TextConversationTarget, ...) (bool, error)

+ SubmitThreadReply func(ctx context.Context, target events.TextConversationTarget, ...) (bool, error)

+ SummarizeThread func(ctx context.Context, target events.TextConversationTarget) (bool, error)

+ type SessionListOptions struct

+ Limit int

+ Since time.Time

+ Until time.Time

type SessionService

+ func (s *SessionService) AccountGoalTurn(conversationID string) (GoalState, bool, error)

+ func (s *SessionService) ActiveGoals() (map[string]GoalState, error)

+ func (s *SessionService) BeginGoal(conversationID, objective, checkScript string, maxTurns int) error

+ func (s *SessionService) Goal(conversationID string) (GoalState, bool, error)

+ func (s *SessionService) StopGoal(conversationID string) error

+ func (s *SessionService) UpdateGoalStatus(conversationID, status, note string) (GoalState, error)

type SessionSummary

+ func ListSessionsInOptions(ctx context.Context, workspace, workDir string, options SessionListOptions) ([]SessionSummary, error)

type State

+ Goals map[string]GoalState

Jun 7, 2026

Changes in this version

+ const RawRunExposedToolName

+ var ErrStateStoreLocked = errors.New("rocketclaw state store is locked")

+ func AppendSessionEntryID(ctx context.Context, dbPath, conversationID string, ...) (int64, error)

+ func DeleteSession(ctx context.Context, workspace, conversationID string) (int64, error)

+ func DeleteSessionIn(ctx context.Context, workspace, workDir, conversationID string) (int64, error)

+ func DiscordResponseCheckpointKey(channelID, messageID string) string

+ func DiscordThreadConversationID(threadID string) string

+ func ExternalMCPAgents(workspace string) ([]string, error)

+ func ExternalMCPAgentsIn(workspace, workDir string) ([]string, error)

+ func RecoverSessionDBIfCorrupt(ctx context.Context, workspace, workDir string) (bool, error)

+ func SessionDBPath(workspace string) string

+ func SessionDBPathIn(workspace, workDir string) string

+ func SlackResponseCheckpointKey(channelID, messageTS string) string

+ func SlackThreadConversationID(channelID, threadTS string) string

+ type Bridge struct

+ func NewConversation(cfg *config.Config, bus *events.Bus, bridgeConfig *Config, logger *slog.Logger) *Bridge

+ func (b *Bridge) ResetScheduledMessages() error

+ func (b *Bridge) ScheduleMessage(delay time.Duration, message string, recurring bool) error

+ func (b *Bridge) SeedResponseThread(ctx context.Context, checkpoint events.ResponseCheckpoint, _ string) error

+ func (b *Bridge) SeedThreadFromCron(ctx context.Context, seedText string) error

+ func (b *Bridge) SeedThreadFromMain(ctx context.Context) error

+ func (b *Bridge) Start(ctx context.Context) error

+ func (b *Bridge) Stop(context.Context) error

+ func (b *Bridge) Submit(ctx context.Context, msg *events.InboundMessage) error

+ func (b *Bridge) Summarize(ctx context.Context, prompt string) (string, error)

+ func (b *Bridge) WaitIdle(ctx context.Context) error

+ type Config struct

+ Agent string

+ ConsumeSharedInbound bool

+ ConversationID string

+ OutputTargets []events.OutputTarget

+ RequestRestart func(context.Context, string) (string, error)

+ SessionService *SessionService

+ type ExternalMCPSessionState struct

+ Agent string

+ ConversationID string

+ type ObservedSessionEntry struct

+ Entry harness.SessionEntry

+ ID int64

+ func ObserveSessionEntries(ctx context.Context, dbPath, conversationID string, lastID int64) ([]ObservedSessionEntry, error)

+ type PruneStateStats struct

+ ExternalMCPSessions int

+ ResponseCheckpoints int

+ SessionRows int64

+ Threads int

+ type RawRunProgress struct

+ ConversationID string

+ Message func(context.Context, string) error

+ RequestRestart func(context.Context, string) (string, error)

+ ResetScheduledMessages func() error

+ ScheduleMessage func(time.Duration, string, bool) error

+ SessionService *SessionService

+ Thinking func(context.Context, string) error

+ type RawRunResult struct

+ Attachments []events.OutboundAttachment

+ Text string

+ VerbatimMessage string

+ func RunRawWithProgress(ctx context.Context, cfg *config.Config, agent, prompt string, ...) (RawRunResult, error)

+ type ResponseCheckpointState struct

+ AssistantText string

+ ConversationID string

+ Model string

+ ResponseID string

+ SessionEntryID int64

+ type ScheduledMessageState struct

+ Agent string

+ ConversationID string

+ DueAt time.Time

+ Interval time.Duration

+ Message string

+ Recurring bool

+ type SessionService struct

+ func NewSessionService(workspace string) (*SessionService, error)

+ func NewSessionServiceIn(workspace, workDir string) (*SessionService, error)

+ func (s *SessionService) AppendEntryID(ctx context.Context, conversationID string, entry *harness.SessionEntry) (int64, error)

+ func (s *SessionService) ApplyPendingRestartNotifications(ctx context.Context) error

+ func (s *SessionService) CheckpointWAL(ctx context.Context) (WALCheckpointStats, error)

+ func (s *SessionService) Load() (State, error)

+ func (s *SessionService) MarkRestartRequester(ctx context.Context, conversationID string) error

+ func (s *SessionService) MarkThreadSeeded(conversationID, seedKey string) error

+ func (s *SessionService) ObserveEntries(ctx context.Context, conversationID string, lastID int64) ([]ObservedSessionEntry, error)

+ func (s *SessionService) PruneStateBefore(ctx context.Context, cutoff time.Time) (PruneStateStats, error)

+ func (s *SessionService) Stop(context.Context) error

+ func (s *SessionService) UpsertExternalMCPSession(externalConversationID string, session ExternalMCPSessionState) error

+ func (s *SessionService) UpsertResponseCheckpoint(key string, checkpoint ResponseCheckpointState) error

+ func (s *SessionService) UpsertThread(conversationID, agent string) error

+ func (s *SessionService) Vacuum(ctx context.Context) (VacuumStats, error)

+ type SessionSummary struct

+ ConversationID string

+ LastAssistantMessage string

+ LastUpdated time.Time

+ LastUserMessage string

+ Turns int

+ func ListSessions(ctx context.Context, workspace string) ([]SessionSummary, error)

+ func ListSessionsIn(ctx context.Context, workspace, workDir string) ([]SessionSummary, error)

+ type State struct

+ ExternalMCPSessions map[string]ExternalMCPSessionState

+ PendingRestartNotifications map[string]bool

+ ResponseCheckpoints map[string]ResponseCheckpointState

+ ScheduledMessages map[string]ScheduledMessageState

+ Threads map[string]ThreadState

+ type StateStoreLock struct

+ func AcquireStateStoreLock(workspace, workDir string) (*StateStoreLock, error)

+ func (l *StateStoreLock) Close() error

+ type ThreadState struct

+ Agent string

+ SeededFromResponse string

+ type VacuumStats struct

+ AfterFreePages int64

+ AfterPageCount int64

+ BeforeFreePages int64

+ BeforePageCount int64

+ DBExists bool

+ func VacuumSessions(ctx context.Context, workspace string) (VacuumStats, error)

+ func VacuumSessionsIn(ctx context.Context, workspace, workDir string) (VacuumStats, error)

+ type WALCheckpointStats struct

+ Busy int64

+ CheckpointedFrames int64

+ LogFrames int64