mercury

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

type Config struct {
	ForceCloseDelay             time.Duration // Delay after which to force close a websocket connection if no close event is received
	PingInterval                time.Duration // Interval between ping messages
	PongTimeout                 time.Duration // Timeout for receiving a pong response
	BackoffTimeMax              time.Duration // Maximum time between connection attempts
	BackoffTimeReset            time.Duration // Initial time before the first retry
	MaxRetries                  int           // Number of times to retry before giving up
	InitialConnectionMaxRetries int           // Number of times to retry before giving up on the initial connection
}

type DeviceProvider interface {
	Register() error
	GetWebSocketURL() (string, error)
}

type Event struct {
	// JSON fields from the websocket message
	ID               string                 `json:"id,omitempty"`
	Data             map[string]interface{} `json:"data,omitempty"`
	Timestamp        int64                  `json:"timestamp,omitempty"`
	TrackingID       string                 `json:"trackingId,omitempty"`
	AlertType        string                 `json:"alertType,omitempty"`
	SequenceNumber   int64                  `json:"sequenceNumber,omitempty"`
	FilterMessage    bool                   `json:"filterMessage,omitempty"`
	WsWriteTimestamp int64                  `json:"wsWriteTimestamp,omitempty"`
	Headers          map[string]interface{} `json:"headers,omitempty"`

	// Derived fields populated during processing
	EventType      string                 `json:"-"` // Populated from data.eventType
	ActivityType   string                 `json:"-"` // Populated from data.activity.verb
	WebSocketError string                 `json:"-"` // Internal field for connection errors
	ResourceType   string                 `json:"-"` // Type of resource in the event
	ActorID        string                 `json:"-"` // ID of the actor who performed the activity
	OrgID          string                 `json:"-"` // Organization ID associated with the activity
	Resource       map[string]interface{} `json:"-"` // Resource data from the event
}

type EventHandler func(event *Event)