bridgeadapter

type ApprovalDecisionPayload struct {
	ApprovalID string
	Approved   bool
	Always     bool
	Reason     string
}

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 {
	Body      string
	UIMessage map[string]any
	Raw       map[string]any
	Options   []ApprovalOption
}

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

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

type ApprovalPromptRegistration struct {
	ApprovalID    string
	RoomID        id.RoomID
	OwnerMXID     id.UserID
	ToolCallID    string
	ToolName      string
	TurnID        string
	ExpiresAt     time.Time
	Options       []ApprovalOption
	PromptEventID id.EventID
}

type ApprovalReactionHandler interface {
	HandleReaction(ctx context.Context, msg *bridgev2.MatrixReaction, targetEventID id.EventID, emoji string) bool
}

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

	// Canonical prompt schema (used by pkg/connector).
	CanonicalPromptSchema   string
	CanonicalPromptMessages []map[string]any

	// Canonical UI message schema (used by codex, opencode).
	CanonicalSchema    string
	CanonicalUIMessage map[string]any
}

type BaseConnectorMethods struct {
	ProtocolID string // e.g. "ai-opencode"
}

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"`
	CanonicalPromptSchema   string             `json:"canonical_prompt_schema,omitempty"`
	CanonicalPromptMessages []map[string]any   `json:"canonical_prompt_messages,omitempty"`
	CanonicalSchema         string             `json:"canonical_schema,omitempty"`
	CanonicalUIMessage      map[string]any     `json:"canonical_ui_message,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]*streamtransport.StreamSession
	StreamFallbackToDebounced atomic.Bool
	// contains filtered or unexported fields
}

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

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

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

	// 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 Pending[D any] struct {
	ExpiresAt time.Time
	Data      D
	// contains filtered or unexported fields
}

type ReactionContext struct {
	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
	PreBuilt      *bridgev2.ConvertedEdit

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

type RemoteMessage struct {
	Portal    networkid.PortalKey
	ID        networkid.MessageID
	Sender    bridgev2.EventSender
	Timestamp time.Time
	PreBuilt  *bridgev2.ConvertedMessage

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

type RemoteReaction struct {
	Portal        networkid.PortalKey
	Sender        bridgev2.EventSender
	TargetMessage networkid.MessageID
	Emoji         string
	EmojiID       networkid.EmojiID
	Timestamp     time.Time
	DBMeta        *database.Reaction
	ExtraContent  map[string]any

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

type RemoteReactionRemove struct {
	Portal        networkid.PortalKey
	Sender        bridgev2.EventSender
	TargetMessage networkid.MessageID
	EmojiID       networkid.EmojiID

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

type SendDebouncedStreamEditParams struct {
	Login            *bridgev2.UserLogin
	Portal           *bridgev2.Portal
	Sender           bridgev2.EventSender
	NetworkMessageID networkid.MessageID
	SuppressSend     bool
	VisibleBody      string
	FallbackBody     string
	LogKey           string
	Force            bool
	UIMessage        map[string]any
}

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
	Converted *bridgev2.ConvertedMessage
}

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 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
}