socket

type AckEventDelivery struct {
	UID string `json:"uid"`
}

type CLIEvent struct {
	UID     string                `json:"uid"`
	Headers httpheader.HTTPHeader `json:"headers" bson:"headers"`
	Data    json.RawMessage       `json:"data"`

	// for filtering this event delivery
	EventType string `json:"-"`
	DeviceID  string `json:"-"`
	AppID     string `json:"-"`
	GroupID   string `json:"-"`
}

type Client struct {
	EventTypes []string
	Device     *datastore.Device
	// contains filtered or unexported fields
}

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

type ListenRequest struct {
	HostName   string   `json:"host_name"`
	DeviceID   string   `json:"device_id"`
	SourceID   string   `json:"source_id"`
	EventTypes []string `json:"event_types"`
}

type LoginRequest struct {
	HostName string `json:"host_name"`
	DeviceID string `json:"device_id"`
}

type LoginResponse struct {
	Device *datastore.Device      `json:"device"`
	Group  *datastore.Group       `json:"group"`
	App    *datastore.Application `json:"app"`
}

type Repo struct {
	DeviceRepo        datastore.DeviceRepository
	SourceRepo        datastore.SourceRepository
	AppRepo           datastore.ApplicationRepository
	SubscriptionRepo  datastore.SubscriptionRepository
	EventDeliveryRepo datastore.EventDeliveryRepository
}

type WatchCollectionFn func(fn func(doc map[string]interface{}), collection string, stop chan struct{}) error

type WebSocketConnection interface {
	Close() error
	SetReadLimit(limit int64)
	SetPingHandler(h func(appData string) error)
	WriteMessage(messageType int, data []byte) error
	ReadMessage() (messageType int, p []byte, err error)
}