webexmessagehandler

type AttachmentAction struct {
	// ID is the activity ID.
	ID string

	// MessageID is the ID of the message the card was attached to.
	MessageID string

	// PersonID is the ID of the person who submitted the card.
	PersonID string

	// PersonEmail is the email of the person who submitted the card.
	PersonEmail string

	// RoomID is the conversation/space ID.
	RoomID string

	// Inputs contains the card form input values.
	Inputs map[string]interface{}

	// Created is the ISO 8601 timestamp.
	Created string

	// Raw is the full raw activity for advanced use.
	Raw *MercuryActivity
}

type AuthError struct {
	WebexError
}

type Config struct {
	// Token is the Webex bot or user access token (required).
	Token string

	// Mode is the networking mode: "native" or "injected" (default: "native").
	Mode NetworkMode

	// Logger is an optional logger implementation (silent by default).
	Logger Logger

	// HTTPClient is an optional HTTP client for proxy support (native mode only).
	// If nil, http.DefaultClient is used.
	HTTPClient *http.Client

	// Fetch is a custom fetch function for all HTTP requests (injected mode).
	Fetch FetchFunc

	// WebSocketFactory is a custom WebSocket factory (injected mode).
	WebSocketFactory WebSocketFactory

	// PingInterval is the Mercury ping interval in seconds (default: 15).
	PingInterval float64

	// PongTimeout is the pong response timeout in seconds (default: 14).
	PongTimeout float64

	// ReconnectBackoffMax is the max reconnect backoff in seconds (default: 32).
	ReconnectBackoffMax float64

	// MaxReconnectAttempts is the max consecutive reconnection attempts (default: 10).
	MaxReconnectAttempts int

	// ReconnectStabilitySeconds is how long a connection must hold before the
	// reconnect-attempt counter resets (default: 60). Without this window a flap
	// storm — repeated connections that succeed and then drop seconds later —
	// zeroes the counter every cycle, so MaxReconnectAttempts never trips and the
	// handler retries forever instead of surfacing max-attempts-exceeded.
	ReconnectStabilitySeconds float64

	// IgnoreSelfMessages filters out messages sent by this bot to prevent loops (default: true).
	// Set to false explicitly via IgnoreSelfMessagesPtr if you need to receive bot's own messages.
	IgnoreSelfMessages *bool

	// MetricsCallback is an optional callback for receiving timing metrics (no overhead if not set).
	MetricsCallback MetricsCallback
}

type ConnectionStatus string

type DecryptedMessage struct {
	// ID is the Mercury activity UUID. Works as parentId for threaded replies.
	ID string

	// URL is the full Conversation-service activity URL, when present on the
	// raw Mercury activity (e.g. for an outbound "acknowledge" read-receipt).
	// Empty if Mercury did not include it.
	URL string

	// ParentID is the parent activity UUID for threaded replies. Empty if not a thread reply.
	ParentID string

	// MentionedPeople contains person UUIDs mentioned via @mention in the message.
	MentionedPeople []string

	// MentionedGroups contains group mention types (e.g. "all") in the message.
	MentionedGroups []string

	// RoomID is the conversation/space ID.
	RoomID string

	// PersonID is the sender's user ID.
	PersonID string

	// PersonEmail is the sender's email address.
	PersonEmail string

	// Text is the decrypted plain text.
	Text string

	// HTML is the decrypted HTML content (rich text messages).
	HTML string

	// Created is the ISO 8601 timestamp.
	Created string

	// RoomType is "direct", "group", or empty.
	RoomType string

	// Files contains file URLs attached to the message.
	Files []string

	// Raw is the full decrypted activity for advanced use.
	Raw *MercuryActivity
}

type DecryptionError struct {
	WebexError
}

type DeletedMessage struct {
	MessageID string
	RoomID    string
	PersonID  string
}

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

type DeviceRegistration struct {
	// WebSocketURL is the Mercury WebSocket URL.
	WebSocketURL string `json:"webSocketUrl"`

	// DeviceURL is the device URL (used as clientId for KMS).
	DeviceURL string `json:"url"`

	// UserID is the bot's user ID.
	UserID string `json:"userId"`

	// Services is the service catalog from WDM.
	Services map[string]string `json:"services"`

	// EncryptionServiceURL is extracted from Services.
	EncryptionServiceURL string `json:"-"`
}

type DeviceRegistrationError struct {
	WebexError
	StatusCode int
}

type FetchFunc func(ctx context.Context, req FetchRequest) (*FetchResponse, error)

type FetchRequest struct {
	URL     string
	Method  string
	Headers map[string]string
	Body    string
}

type FetchResponse struct {
	Status int
	OK     bool
	Body   io.ReadCloser
}

type HandlerStatus struct {
	// Status is the overall connection state.
	Status ConnectionStatus

	// WebSocketOpen indicates whether the Mercury WebSocket is currently open.
	WebSocketOpen bool

	// KmsInitialized indicates whether the KMS encryption context has been established.
	KmsInitialized bool

	// DeviceRegistered indicates whether the device is registered with WDM.
	DeviceRegistered bool

	// ReconnectAttempt is the current auto-reconnect attempt number (0 if not reconnecting).
	ReconnectAttempt int
}

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

type KmsClientConfig struct {
	Token                string
	DeviceURL            string
	UserID               string
	EncryptionServiceURL string
	Logger               Logger
	HTTPDo               fetchDoFn
}

type KmsError struct {
	WebexError
}

type Logger interface {
	Debug(msg string, args ...any)
	Info(msg string, args ...any)
	Warn(msg string, args ...any)
	Error(msg string, args ...any)
}

type MembershipActivity struct {
	// ID is the activity ID.
	ID string

	// ActorID is the ID of the person who performed the action.
	ActorID string

	// PersonID is the ID of the member affected.
	PersonID string

	// RoomID is the conversation/space ID.
	RoomID string

	// Action is the membership action: "add", "leave", "assignModerator", or "unassignModerator".
	Action string

	// Created is the ISO 8601 timestamp.
	Created string

	// RoomType is "direct", "group", or empty.
	RoomType string

	// Raw is the full raw activity for advanced use.
	Raw *MercuryActivity
}

type MercuryActivity struct {
	ID               string         `json:"id"`
	URL              string         `json:"url,omitempty"`
	Verb             string         `json:"verb"`
	Actor            MercuryActor   `json:"actor"`
	Object           MercuryObject  `json:"object"`
	Target           MercuryTarget  `json:"target"`
	Published        string         `json:"published"`
	EncryptionKeyURL string         `json:"encryptionKeyUrl,omitempty"`
	Parent           *MercuryParent `json:"parent,omitempty"`
}

type MercuryActor struct {
	ID           string `json:"id"`
	ObjectType   string `json:"objectType"`
	EmailAddress string `json:"emailAddress,omitempty"`
}

type MercuryConnectionError struct {
	WebexError
	CloseCode int
}

type MercuryEnvelope struct {
	ID             string                 `json:"id"`
	Data           map[string]interface{} `json:"data"`
	Timestamp      int64                  `json:"timestamp"`
	TrackingID     string                 `json:"trackingId"`
	SequenceNumber *int64                 `json:"sequenceNumber,omitempty"`
}

type MercuryObject struct {
	ID               string `json:"id"`
	ObjectType       string `json:"objectType"`
	DisplayName      string `json:"displayName,omitempty"`
	Content          string `json:"content,omitempty"`
	EncryptionKeyURL string `json:"encryptionKeyUrl,omitempty"`
	// Inputs holds the decrypted card-action form values on cardAction/submit
	// activities. On the wire object.inputs is a JWE-encrypted string (see
	// InputsEncrypted); it is decrypted into this map by the message decryptor.
	Inputs map[string]interface{} `json:"inputs,omitempty"`
	// InputsEncrypted holds the raw JWE ciphertext of object.inputs as delivered
	// by Mercury, before decryption. Card-action inputs are encrypted under the
	// activity's encryptionKeyUrl (same KMS key path as message content), so the
	// decryptor must resolve the key and decrypt this into Inputs.
	InputsEncrypted string   `json:"-"`
	Files           []string `json:"files,omitempty"`
}

type MercuryParent struct {
	ID   string `json:"id"`
	Type string `json:"type"`
}

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

type MercurySocketConfig struct {
	Logger               Logger
	WSFactory            wsFactoryFn
	PingInterval         time.Duration
	PongTimeout          time.Duration
	ReconnectBackoffMax  time.Duration
	MaxReconnectAttempts int
	ReconnectStability   time.Duration
}

type MercuryTarget struct {
	ID               string   `json:"id"`
	ObjectType       string   `json:"objectType"`
	EncryptionKeyURL string   `json:"encryptionKeyUrl,omitempty"`
	Tags             []string `json:"tags,omitempty"`
}

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

type MetricsCallback func(event MetricsEvent)

type MetricsEvent struct {
	// Name is the metric name: "connect", "kms_fetch", or "decrypt".
	Name string

	// DurationMs is the duration in milliseconds.
	DurationMs float64

	// Success indicates whether the operation succeeded.
	Success bool

	// Metadata is optional context (e.g., key URI for kms_fetch).
	Metadata map[string]string
}

type NetworkMode string

type ParsedMentions struct {
	MentionedPeople []string
	MentionedGroups []string
}

type RoomActivity struct {
	// ID is the activity ID.
	ID string

	// RoomID is the conversation/space ID.
	RoomID string

	// ActorID is the ID of the person who performed the action.
	ActorID string

	// Action is the room action: "created" or "updated".
	Action string

	// Created is the ISO 8601 timestamp.
	Created string

	// Raw is the full raw activity for advanced use.
	Raw *MercuryActivity
}

type SlogLogger struct {
	L *slog.Logger
}

type WebSocket interface {
	Send(data string) error
	Receive() (string, error)
	Close() error
	Done() <-chan struct{}
}

type WebSocketFactory func(ctx context.Context, url string) (WebSocket, error)

type WebexError struct {
	Message string
	Code    string
	Cause   error
}

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