webexmessagehandler

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

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

type ConnectionStatus string

type DecryptedMessage struct {
	// ID is the unique message ID.
	ID 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

	// 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"`
	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"`
}

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

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
}

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 NetworkMode string

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
}