trigger

Jul 25, 2026

Changes in this version

+ const FilesManifestSource

+ var ErrAgentNoImage = errors.New("agent has no image")

+ var ErrAgentStopped = errors.New("agent is stopped")

+ func AgentConfigHash(ag dbq.Agent) string

+ func PostFilesManifest(ctx context.Context, q *dbq.Queries, convID pgtype.UUID, files []wire.FileInfo) error

+ type AgentSlashConv struct

+ func NewAgentSlashConv(q *dbq.Queries, canceler RunCanceler, logger *zap.Logger, agentID uuid.UUID, ...) *AgentSlashConv

+ func (a *AgentSlashConv) Cancel(ctx context.Context, convID pgtype.UUID) bool

+ func (a *AgentSlashConv) Clear(ctx context.Context, convID pgtype.UUID) (bool, error)

+ func (a *AgentSlashConv) Compact(_ context.Context, _ pgtype.UUID) (string, bool, error)

+ func (a *AgentSlashConv) Echo(ctx context.Context, convID pgtype.UUID, args string) (bool, error)

+ func (a *AgentSlashConv) Start(ctx context.Context, convID pgtype.UUID) string

type BridgeEvent

+ ManagedBot *ManagedBotEvent

type BridgeManager

+ func (m *BridgeManager) AttachManagedBotIngest(...)

+ func (m *BridgeManager) AttachSysagent(s SysagentRuntime)

+ func (m *BridgeManager) BotTokenForBridge(ctx context.Context, agentID, bridgeID uuid.UUID) (string, error)

+ func (m *BridgeManager) RemoveBridgesByOwner(ctx context.Context, ownerID uuid.UUID) error

+ func (m *BridgeManager) ResumeSystemConversation(ctx context.Context, conversationID uuid.UUID) error

+ func (m *BridgeManager) StreamToBridge(ctx context.Context, bridgeID uuid.UUID, externalID string, ...) error

+ func (m *BridgeManager) TeardownBridge(bridgeID uuid.UUID)

type Dispatcher

+ func (d *Dispatcher) ForwardA2APrompt(ctx context.Context, agentID uuid.UUID, parentRunID uuid.UUID, ...) (io.ReadCloser, uuid.UUID, error)

+ func (d *Dispatcher) ForwardFire(ctx context.Context, agentID uuid.UUID, event wire.ScheduleFireRequest, ...) (wire.ScheduleFireResponse, uuid.UUID, error)

+ type ManagedBotEvent struct

+ BotID int64

+ ExternalID string

+ SenderID string

+ Username string

type PromptProxy

+ func (p *PromptProxy) TranscribeVoicePlain(ctx context.Context, files []BridgeFile) (text string, hasVoice bool, hasNonVoice bool)

type ResponseEvent

+ CompactionError string

+ Description string

+ TokensFreed int

type Scheduler

+ func (s *Scheduler) ReconcileAgent(ctx context.Context, agentID uuid.UUID, definitions []wire.ScheduleHandlerDef) error

+ type SlashConv interface

+ Cancel func(ctx context.Context, convID pgtype.UUID) bool

+ Clear func(ctx context.Context, convID pgtype.UUID) (suspensionCleared bool, err error)

+ Compact func(ctx context.Context, convID pgtype.UUID) (reply string, forward bool, err error)

+ Echo func(ctx context.Context, convID pgtype.UUID, args string) (on bool, err error)

+ Start func(ctx context.Context, convID pgtype.UUID) string

+ type SysagentRuntime interface

+ CancelRun func(runID uuid.UUID) bool

+ Compact func(ctx context.Context, p authz.Principal, conversationID uuid.UUID) (string, error)

+ NotifyBotCreated func(ctx context.Context, conversationID uuid.UUID, botUsername string) error

+ RunPromptInline func(ctx context.Context, p authz.Principal, conversationID uuid.UUID, ...) (uuid.UUID, error)

+ type SysagentSlashConv struct

+ func NewSysagentSlashConv(svc SysagentRuntime, q *dbq.Queries, p authz.Principal, logger *zap.Logger) *SysagentSlashConv

+ func (s *SysagentSlashConv) Cancel(ctx context.Context, convID pgtype.UUID) bool

+ func (s *SysagentSlashConv) Clear(ctx context.Context, convID pgtype.UUID) (bool, error)

+ func (s *SysagentSlashConv) Compact(ctx context.Context, convID pgtype.UUID) (string, bool, error)

+ func (s *SysagentSlashConv) Echo(ctx context.Context, convID pgtype.UUID, args string) (bool, error)

+ func (s *SysagentSlashConv) Start(ctx context.Context, convID pgtype.UUID) string

type TelegramDriver

+ func (d *TelegramDriver) GetManagedBotToken(ctx context.Context, managerToken string, botUserID int64) (string, error)

+ func (d *TelegramDriver) GetMeFull(ctx context.Context, token string) (username, name string, botUserID int64, canManageBots bool, err error)

+ func (d *TelegramDriver) GetMenuButton(ctx context.Context, token string) (TelegramMenuButton, error)

+ func (d *TelegramDriver) SetMenuButton(ctx context.Context, token, url string) error

+ type TelegramMenuButton struct

+ Type string

+ WebAppURL string

May 6, 2026

Changes in this version

+ const CancelButtonAfter

+ const DefaultPublicPromptTimeoutSeconds

type BridgeCallback

+ MessageID string

type BridgeDriver

+ RemoveButtons func(ctx context.Context, br dbq.Bridge, externalID, messageID string) error

type BridgeSettings

+ PublicPromptTimeoutSeconds int

type DiscordDriver

+ func (d *DiscordDriver) RemoveButtons(ctx context.Context, br dbq.Bridge, externalID, messageID string) error

+ type RunCanceler interface

+ CancelRun func(runID uuid.UUID) bool

type TelegramDriver

+ func (d *TelegramDriver) RemoveButtons(ctx context.Context, br dbq.Bridge, externalID, messageID string) error

May 5, 2026

Changes in this version

+ const BridgeReferenceForward

+ const BridgeReferenceReply

+ const DefaultPublicSessionTTLSeconds

+ const ExtendIncrement

+ const MaxExtensions

+ const PromptBaseDuration

+ const PromptHTTPCeiling

+ const PublicSessionModeOneShot

+ const PublicSessionModeSession

+ var ErrExtensionCeiling = errors.New("max extensions reached")

+ var ErrRunNotInFlight = errors.New("run not in flight")

+ func StartPublicSweeper(ctx context.Context, database *db.DB, mgr *BridgeManager, ...)

+ func SweepExpiredPublicConversations(ctx context.Context, database *db.DB, mgr *BridgeManager, logger *zap.Logger)

type BridgeEvent

+ ReferencedMessage *BridgeReferencedMessage

+ type BridgeReferencedMessage struct

+ AuthoredAt time.Time

+ FromBot bool

+ Kind string

+ SenderName string

+ Text string

+ type BridgeSettings struct

+ AllowPublicDMs bool

+ PublicSessionMode string

+ PublicSessionTTLSeconds int

+ func DecodeBridgeSettings(raw []byte) BridgeSettings

+ func DefaultBridgeSettings() BridgeSettings

+ type DiscordDriver struct

+ func NewDiscordDriver(logger *zap.Logger) *DiscordDriver

+ func NewDiscordDriverWithBase(apiBase string, client *http.Client) *DiscordDriver

+ func (d *DiscordDriver) Activate(ctx context.Context, br dbq.Bridge) error

+ func (d *DiscordDriver) CreateDMChannel(ctx context.Context, token, recipientID string) (string, error)

+ func (d *DiscordDriver) DefaultEcho() bool

+ func (d *DiscordDriver) FetchUser(ctx context.Context, token, userID string) (DiscordUserInfo, error)

+ func (d *DiscordDriver) GetMe(ctx context.Context, token string) (string, error)

+ func (d *DiscordDriver) Init(ctx context.Context, br *dbq.Bridge) error

+ func (d *DiscordDriver) Poll(ctx context.Context, br *dbq.Bridge) ([]BridgeEvent, error)

+ func (d *DiscordDriver) RegisterCommands(ctx context.Context, br dbq.Bridge, cmds []SlashCommand) error

+ func (d *DiscordDriver) SendDM(ctx context.Context, token, recipientID, content string) error

+ func (d *DiscordDriver) SendParts(ctx context.Context, token, channelID string, parts []agentsdk.DisplayPart) error

+ func (d *DiscordDriver) SendStream(ctx context.Context, br dbq.Bridge, externalID string, echo bool, ...) (string, error)

+ func (d *DiscordDriver) Teardown(_ context.Context, br dbq.Bridge) error

+ type DiscordUserInfo struct

+ AvatarURL string

+ GlobalName string

+ ID string

+ Username string

type Dispatcher

+ func (d *Dispatcher) CancelRun(runID uuid.UUID) bool

+ func (d *Dispatcher) ExtendRun(runID uuid.UUID, by time.Duration) (time.Time, int, error)

+ func (d *Dispatcher) InFlightIDs() []uuid.UUID

Apr 29, 2026

Changes in this version

+ var ErrTranscriptionNotConfigured = errors.New("transcription not configured")

+ var Registry = []SlashCommand

+ func ResolveAgentAccess(ctx context.Context, q *dbq.Queries, agentID, userID uuid.UUID) agentsdk.Access

+ func ResolveEcho(settingsJSON []byte, driverDefault bool) bool

+ func StreamNDJSONResponse(body io.Reader, runID string, events chan<- ResponseEvent) (string, []message.Message, *usageInfo, error)

+ type BridgeCallback struct

+ AckID string

+ Data string

+ type BridgeDriver interface

+ Activate func(ctx context.Context, br dbq.Bridge) error

+ DefaultEcho func() bool

+ Init func(ctx context.Context, br *dbq.Bridge) error

+ Poll func(ctx context.Context, br *dbq.Bridge) ([]BridgeEvent, error)

+ SendStream func(ctx context.Context, br dbq.Bridge, externalID string, echo bool, ...) (string, error)

+ Teardown func(ctx context.Context, br dbq.Bridge) error

+ type BridgeEvent struct

+ BridgeID uuid.UUID

+ Callback *BridgeCallback

+ ExternalID string

+ Files []BridgeFile

+ RawPayload []byte

+ SenderID string

+ SenderName string

+ Text string

+ type BridgeFile struct

+ ContentType string

+ Data []byte

+ FileID string

+ Filename string

+ IsVoiceNote bool

+ Size int64

+ type BridgeManager struct

+ func NewBridgeManager(drivers map[string]BridgeDriver, prompter *PromptProxy, database *db.DB, ...) *BridgeManager

+ func (m *BridgeManager) AddBridge(bridgeID uuid.UUID)

+ func (m *BridgeManager) HandleEvent(ctx context.Context, event BridgeEvent) error

+ func (m *BridgeManager) RemoveBridge(bridgeID uuid.UUID)

+ func (m *BridgeManager) SendMessage(ctx context.Context, bridgeID uuid.UUID, externalID, text string) error

+ func (m *BridgeManager) SendParts(ctx context.Context, bridgeID uuid.UUID, externalID string, ...) error

+ func (m *BridgeManager) Start(ctx context.Context) error

+ func (m *BridgeManager) Stop()

+ type CommandRegistrar interface

+ RegisterCommands func(ctx context.Context, br dbq.Bridge, cmds []SlashCommand) error

+ type Dispatcher struct

+ func NewDispatcher(cfg *config.Config, db *db.DB, containers container.ContainerManager, ...) *Dispatcher

+ func (d *Dispatcher) EnsureRunning(ctx context.Context, agentID uuid.UUID) (*container.Container, error)

+ func (d *Dispatcher) ForwardCron(ctx context.Context, agentID uuid.UUID, cronName string, timeout time.Duration) (io.ReadCloser, uuid.UUID, error)

+ func (d *Dispatcher) ForwardPrompt(ctx context.Context, agentID uuid.UUID, input agentsdk.PromptInput, ...) (io.ReadCloser, uuid.UUID, error)

+ func (d *Dispatcher) ForwardWebhook(ctx context.Context, agentID uuid.UUID, path string, body []byte, ...) (io.ReadCloser, uuid.UUID, error)

+ func (d *Dispatcher) RefreshAgent(ctx context.Context, agentID uuid.UUID) error

+ type PromptProxy struct

+ func NewPromptProxy(dispatcher *Dispatcher, database *db.DB, s3 *storage.S3Client, ...) *PromptProxy

+ func (p *PromptProxy) HandleCallback(ctx context.Context, agentID, bridgeID, userID uuid.UUID, ...) (staleRun bool, err error)

+ func (p *PromptProxy) HandleMessage(ctx context.Context, agentID, bridgeID, userID uuid.UUID, externalID string, ...) (string, error)

+ type ResponseEvent struct

+ Code string

+ Patterns []string

+ Permission string

+ Raw []byte

+ RunID string

+ Text string

+ ToolCallID string

+ ToolError string

+ ToolInput string

+ ToolName string

+ ToolOutput string

+ Type string

+ type Scheduler struct

+ func NewScheduler(dispatcher *Dispatcher, db *db.DB, logger *zap.Logger) *Scheduler

+ func (s *Scheduler) ReloadAgent(ctx context.Context, agentID uuid.UUID) error

+ func (s *Scheduler) Start(ctx context.Context) error

+ func (s *Scheduler) Stop()

+ type SlashCommand struct

+ Access agentsdk.Access

+ Description string

+ Name string

+ type SlashCommandResult struct

+ ForwardAsCompact bool

+ Handled bool

+ Reply string

+ func TrySlashCommand(ctx context.Context, q *dbq.Queries, convID pgtype.UUID, agentID uuid.UUID, ...) (SlashCommandResult, error)

+ type TelegramChatInfo struct

+ FirstName string

+ LastName string

+ Username string

+ type TelegramDriver struct

+ func NewTelegramDriver(logger *zap.Logger) *TelegramDriver

+ func NewTelegramDriverWithBaseURL(baseURL string, client *http.Client) *TelegramDriver

+ func (d *TelegramDriver) Activate(ctx context.Context, br dbq.Bridge) error

+ func (d *TelegramDriver) AnswerCallbackQuery(ctx context.Context, token, callbackID, text string) error

+ func (d *TelegramDriver) DefaultEcho() bool

+ func (d *TelegramDriver) GetChat(ctx context.Context, token, chatID string) (TelegramChatInfo, error)

+ func (d *TelegramDriver) GetMe(ctx context.Context, token string) (string, error)

+ func (d *TelegramDriver) Init(ctx context.Context, br *dbq.Bridge) error

+ func (d *TelegramDriver) Poll(ctx context.Context, br *dbq.Bridge) ([]BridgeEvent, error)

+ func (d *TelegramDriver) RegisterCommands(ctx context.Context, br dbq.Bridge, cmds []SlashCommand) error

+ func (d *TelegramDriver) SendMessage(ctx context.Context, token string, chatID int64, text string) error

+ func (d *TelegramDriver) SendParts(ctx context.Context, token string, chatID int64, parts []agentsdk.DisplayPart) error

+ func (d *TelegramDriver) SendStream(ctx context.Context, br dbq.Bridge, externalID string, echo bool, ...) (string, error)

+ func (d *TelegramDriver) Teardown(_ context.Context, _ dbq.Bridge) error

+ type TranscriptionResolver func(ctx context.Context) (model.TranscriptionModel, error)

+ func NewTranscriptionResolver(database *db.DB, encryptor *crypto.Encryptor) TranscriptionResolver