http

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

type ClientList map[*Client]struct{}

type Event struct {
	Type    string          `json:"type"`
	Payload json.RawMessage `json:"payload"`
}

type EventHandler func(event Event, c *Client) error

type HandlerFunc func(w http.ResponseWriter, r *http.Request) error

type NewMessageEvent struct {
	SendMessageEvent
	Sent time.Time `json:"sent"`
}

type RateLimiter struct {
	Enabled bool
	Burst   int
	Limit   int
}

type Response struct {
	Status  ResponseStatus `json:"status"`
	Code    string         `json:"code,omitempty"`
	Message string         `json:"message,omitempty"`
	Data    W              `json:"data,omitempty"`
	Errors  any            `json:"errors,omitempty"`
}

type ResponseStatus string

type SendMessageEvent struct {
	Message string `json:"message"`
	From    string `json:"from"`
}

type Server struct {
	IsDev bool

	RateLimiter RateLimiter

	UserService       echosight.UserService
	HostService       echosight.HostService
	DetectorService   echosight.DetectorService
	RecipientService  echosight.RecipientService
	PreferenceService echosight.PreferenceService
	SessionService    echosight.SessionService

	MetricReader echosight.MetricReader
	Scheduler    *observer.Scheduler
	EventHandler *eventflow.Engine
	Crypter      echosight.Crypter
	// contains filtered or unexported fields
}

type ServerOpts struct {
	TrustedOrigins []string
	Addr           string
}

type W map[string]any

type WebSocketManager struct {
	sync.RWMutex

	TrustedOrigins []string
	// contains filtered or unexported fields
}