agentremote

type Aborter interface {
	Abort(reason string)
}

type ApprovalDecisionPayload struct {
	ApprovalID  string
	Approved    bool
	Always      bool
	Reason      string
	ReactionKey string
	ResolvedBy  ApprovalResolutionOrigin
}

type ApprovalDetail struct {
	Label string `json:"label"`
	Value string `json:"value"`
}

type ApprovalFlow[D any] struct {
	// contains filtered or unexported fields
}

type ApprovalFlowConfig[D any] struct {
	// Login returns the current UserLogin. Required.
	Login func() *bridgev2.UserLogin

	// Sender returns the EventSender to use for a given portal (e.g. the agent ghost).
	Sender func(portal *bridgev2.Portal) bridgev2.EventSender

	// BackgroundContext optionally returns a context detached from the request lifecycle.
	BackgroundContext func(ctx context.Context) context.Context

	// RoomIDFromData extracts the stored room ID from pending data for validation.
	// Return "" to skip the room check.
	RoomIDFromData func(data D) id.RoomID

	// DeliverDecision is called for non-channel flows when a valid reaction resolves
	// an approval. The flow has already validated owner, expiration, and room.
	// If nil, the flow is channel-based: decisions are delivered via an internal
	// channel and retrieved with Wait().
	DeliverDecision func(ctx context.Context, portal *bridgev2.Portal, pending *Pending[D], decision ApprovalDecisionPayload) error

	// SendNotice sends a system notice to a portal. Used for error toasts.
	SendNotice func(ctx context.Context, portal *bridgev2.Portal, msg string)

	// DBMetadata produces bridge-specific metadata for the approval prompt message.
	// If nil, a default *BaseMessageMetadata is used.
	DBMetadata func(prompt ApprovalPromptMessage) any

	IDPrefix    string
	LogKey      string
	SendTimeout time.Duration
}

type ApprovalOption struct {
	ID          string `json:"id"`
	Key         string `json:"key"`
	FallbackKey string `json:"fallback_key,omitempty"`
	Label       string `json:"label,omitempty"`
	Approved    bool   `json:"approved"`
	Always      bool   `json:"always,omitempty"`
	Reason      string `json:"reason,omitempty"`
}

type ApprovalPromptMessage struct {
	Content       *event.MessageEventContent
	TopLevelExtra map[string]any
	Body          string
	UIMessage     map[string]any
	Presentation  ApprovalPromptPresentation
	Options       []ApprovalOption
}

type ApprovalPromptMessageParams struct {
	ApprovalID        string
	ToolCallID        string
	ToolName          string
	TurnID            string
	Presentation      ApprovalPromptPresentation
	ReplyToEventID    id.EventID
	ThreadRootEventID id.EventID
	ExpiresAt         time.Time
	Options           []ApprovalOption
}

type ApprovalPromptPresentation struct {
	Title       string           `json:"title"`
	Details     []ApprovalDetail `json:"details,omitempty"`
	AllowAlways bool             `json:"allowAlways,omitempty"`
}

type ApprovalPromptReactionCleanupOptions struct {
	PreserveSenderID networkid.UserID
	PreserveKey      string
}

type ApprovalPromptReactionMatch struct {
	KnownPrompt            bool
	ShouldResolve          bool
	ApprovalID             string
	Decision               ApprovalDecisionPayload
	RejectReason           string
	Prompt                 ApprovalPromptRegistration
	MirrorDecisionReaction bool
	RedactResolvedReaction bool
}

type ApprovalPromptRegistration struct {
	ApprovalID              string
	RoomID                  id.RoomID
	OwnerMXID               id.UserID
	ToolCallID              string
	ToolName                string
	TurnID                  string
	PromptVersion           uint64
	Presentation            ApprovalPromptPresentation
	ExpiresAt               time.Time
	Options                 []ApprovalOption
	ReactionTargetMessageID networkid.MessageID
	PromptMessageID         networkid.MessageID
	PromptSenderID          networkid.UserID
}

type ApprovalReactionHandler interface {
	HandleReaction(ctx context.Context, msg *bridgev2.MatrixReaction) bool
}

type ApprovalReactionRemoveHandler interface {
	HandleReactionRemove(ctx context.Context, msg *bridgev2.MatrixReactionRemove) bool
}

type ApprovalResolutionOrigin string

type ApprovalResponsePromptMessageParams struct {
	ApprovalID   string
	ToolCallID   string
	ToolName     string
	TurnID       string
	Presentation ApprovalPromptPresentation
	Options      []ApprovalOption
	Decision     ApprovalDecisionPayload
	ExpiresAt    time.Time
}

type AssistantMessageMetadata struct {
	CompletionID       string `json:"completion_id,omitempty"`
	Model              string `json:"model,omitempty"`
	HasToolCalls       bool   `json:"has_tool_calls,omitempty"`
	Transcript         string `json:"transcript,omitempty"`
	FirstTokenAtMs     int64  `json:"first_token_at_ms,omitempty"`
	ThinkingTokenCount int    `json:"thinking_token_count,omitempty"`
}

type AssistantMetadataParams struct {
	Body              string
	FinishReason      string
	TurnID            string
	AgentID           string
	StartedAtMs       int64
	CompletedAtMs     int64
	ThinkingContent   string
	PromptTokens      int64
	CompletionTokens  int64
	ReasoningTokens   int64
	ToolCalls         []ToolCallMetadata
	GeneratedFiles    []GeneratedFileRef
	CanonicalTurnData map[string]any
}

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

type BaseMessageMetadata struct {
	Role               string             `json:"role,omitempty"`
	Body               string             `json:"body,omitempty"`
	FinishReason       string             `json:"finish_reason,omitempty"`
	PromptTokens       int64              `json:"prompt_tokens,omitempty"`
	CompletionTokens   int64              `json:"completion_tokens,omitempty"`
	ReasoningTokens    int64              `json:"reasoning_tokens,omitempty"`
	TurnID             string             `json:"turn_id,omitempty"`
	AgentID            string             `json:"agent_id,omitempty"`
	CanonicalTurnData  map[string]any     `json:"canonical_turn_data,omitempty"`
	StartedAtMs        int64              `json:"started_at_ms,omitempty"`
	CompletedAtMs      int64              `json:"completed_at_ms,omitempty"`
	ThinkingContent    string             `json:"thinking_content,omitempty"`
	ToolCalls          []ToolCallMetadata `json:"tool_calls,omitempty"`
	GeneratedFiles     []GeneratedFileRef `json:"generated_files,omitempty"`
	ExcludeFromHistory bool               `json:"exclude_from_history,omitempty"`
}

type BaseReactionHandler struct {
	Target ReactionTarget
}

type BaseStreamState struct {
	StreamMu                  sync.Mutex
	StreamSessions            map[string]*turns.StreamSession
	StreamFallbackToDebounced atomic.Bool
	// contains filtered or unexported fields
}

type BrokenLoginClient struct {
	UserLogin *bridgev2.UserLogin
	Reason    string
	OnLogout  func(context.Context, *bridgev2.UserLogin)
}

type ClientBase struct {
	BaseReactionHandler
	BaseStreamState

	HumanUserIDPrefix string
	MessageIDPrefix   string
	MessageLogKey     string
	// contains filtered or unexported fields
}

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

type ConnectorSpec struct {
	ProtocolID string
	AIRoomKind string

	Init  func(*bridgev2.Bridge)
	Start func(context.Context) error
	Stop  func(context.Context)

	Name        func() bridgev2.BridgeName
	Config      func() (example string, data any, upgrader configupgrade.Upgrader)
	DBMeta      func() database.MetaTypes
	LoadLogin   func(context.Context, *bridgev2.UserLogin) error
	LoginFlows  func() []bridgev2.LoginFlow
	CreateLogin func(context.Context, *bridgev2.User, string) (bridgev2.LoginProcess, error)

	Capabilities      func() *bridgev2.NetworkGeneralCapabilities
	BridgeInfoVersion func() (info, capabilities int)
	FillBridgeInfo    func(*bridgev2.Portal, *event.BridgeEventContent)
}

type DMChatInfoParams struct {
	Title          string
	HumanUserID    networkid.UserID
	LoginID        networkid.UserLoginID
	BotUserID      networkid.UserID
	BotDisplayName string
	CanBackfill    bool
}

type EventTiming struct {
	Timestamp   time.Time
	StreamOrder int64
}

type GeneratedFileRef struct {
	URL      string `json:"url"`
	MimeType string `json:"mime_type"`
}

type LoadUserLoginConfig[C bridgev2.NetworkAPI] struct {
	Mu         *sync.Mutex
	Clients    map[networkid.UserLoginID]bridgev2.NetworkAPI
	ClientsRef *map[networkid.UserLoginID]bridgev2.NetworkAPI

	// BridgeName is used in error messages (e.g. "OpenCode").
	BridgeName string

	// MakeBroken returns a BrokenLoginClient for the given reason.
	// If nil, a default BrokenLoginClient is used.
	MakeBroken func(login *bridgev2.UserLogin, reason string) *BrokenLoginClient

	Update func(existing C, login *bridgev2.UserLogin)
	Create func(login *bridgev2.UserLogin) (C, error)

	// AfterLoad is called after a client is successfully loaded or created.
	// Optional — use for post-load setup like scheduling bootstrap.
	AfterLoad func(client C)
}

type LoginDMChatInfoParams struct {
	Title             string
	Login             *bridgev2.UserLogin
	HumanUserIDPrefix string
	BotUserID         networkid.UserID
	BotDisplayName    string
	CanBackfill       bool
}

type Pending[D any] struct {
	ExpiresAt time.Time
	Data      D
	// contains filtered or unexported fields
}

type ReactionContext struct {
	TargetMessageID networkid.MessageID
	Emoji           string
	TargetEventID   id.EventID
}

type ReactionTarget interface {
	GetUserLogin() *bridgev2.UserLogin
	GetApprovalHandler() ApprovalReactionHandler
}

type RemoteEdit struct {
	Portal        networkid.PortalKey
	Sender        bridgev2.EventSender
	TargetMessage networkid.MessageID
	Timestamp     time.Time
	// StreamOrder overrides timestamp-based ordering when the caller has a stable upstream order.
	StreamOrder int64
	PreBuilt    *bridgev2.ConvertedEdit

	// LogKey is the zerolog field name used in AddLogContext (e.g. "ai_edit_target", "codex_edit_target").
	LogKey string
}

type RoomFeaturesParams struct {
	ID                  string
	File                event.FileFeatureMap
	MaxTextLength       int
	Reply               event.CapabilitySupportLevel
	Thread              event.CapabilitySupportLevel
	Edit                event.CapabilitySupportLevel
	Delete              event.CapabilitySupportLevel
	Reaction            event.CapabilitySupportLevel
	ReadReceipts        bool
	TypingNotifications bool
	DeleteChat          bool
}

type SendPromptParams struct {
	ApprovalPromptMessageParams
	RoomID    id.RoomID
	OwnerMXID id.UserID
}

type SendViaPortalParams struct {
	Login     *bridgev2.UserLogin
	Portal    *bridgev2.Portal
	Sender    bridgev2.EventSender
	IDPrefix  string // e.g. "ai", "codex", "opencode"
	LogKey    string // zerolog field name, e.g. "ai_msg_id"
	MsgID     networkid.MessageID
	Timestamp time.Time
	// StreamOrder is optional explicit ordering for events that share a timestamp.
	StreamOrder int64
	Converted   *bridgev2.ConvertedMessage
}

type StreamTurnHost[S any] struct {
	// contains filtered or unexported fields
}

type StreamTurnHostCallbacks[S any] struct {
	// GetAborter returns the aborter (typically an *sdk.Turn) from the state, or nil.
	GetAborter func(state *S) Aborter
}

type ToolCallMetadata struct {
	CallID        string         `json:"call_id"`
	ToolName      string         `json:"tool_name"`
	ToolType      string         `json:"tool_type"`
	Input         map[string]any `json:"input,omitempty"`
	Output        map[string]any `json:"output,omitempty"`
	Status        string         `json:"status"`
	ResultStatus  string         `json:"result_status,omitempty"`
	ErrorMessage  string         `json:"error_message,omitempty"`
	StartedAtMs   int64          `json:"started_at_ms,omitempty"`
	CompletedAtMs int64          `json:"completed_at_ms,omitempty"`

	// Event IDs for timeline events (if emitted as separate events)
	CallEventID   string `json:"call_event_id,omitempty"`
	ResultEventID string `json:"result_event_id,omitempty"`
}

type TypedClientLoaderSpec[C bridgev2.NetworkAPI] struct {
	LoadUserLoginConfig[C]
	Accept func(*bridgev2.UserLogin) (ok bool, reason string)
}

type UpsertAssistantMessageParams struct {
	Login            *bridgev2.UserLogin
	Portal           *bridgev2.Portal
	SenderID         networkid.UserID
	NetworkMessageID networkid.MessageID
	InitialEventID   id.EventID
	Metadata         any // must satisfy database.MetaMerger
	Logger           zerolog.Logger
}