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:"-"`
	EndpointID string `json:"-"`
	SourceID   string `json:"-"`
	ProjectID  string `json:"-"`
}

type Client struct {
	Device *datastore.Device
	// contains filtered or unexported fields
}

type EndpointError struct {
	Err error
	// contains filtered or unexported fields
}

type EventDelivery struct {
	EventDeliveryID string
	ProjectID       string
}

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

type ListenRequest struct {
	HostName   string `json:"host_name" valid:"required~please provide a hostname"`
	ProjectID  string `json:"project_id" valid:"required~please provide a project id"`
	DeviceID   string `json:"device_id" valid:"required~please provide a device id"`
	SourceID   string `json:"-"`
	SourceName string `json:"source_name"`
}

type LoginRequest struct {
	HostName string `json:"host_name" valid:"required~please provide a hostname"`
}

type LoginResponse struct {
	Projects []ProjectDevice `json:"projects"`
	UserName string          `json:"user_name"`
}

type ProjectDevice struct {
	Project *datastore.Project `json:"project"`
	Device  *datastore.Device  `json:"device"`
}

type Repo struct {
	OrgMemberRepository datastore.OrganisationMemberRepository
	ProjectRepo         datastore.ProjectRepository
	DeviceRepo          datastore.DeviceRepository
	SourceRepo          datastore.SourceRepository
	EndpointRepo        datastore.EndpointRepository
	SubscriptionRepo    datastore.SubscriptionRepository
	EventDeliveryRepo   datastore.EventDeliveryRepository
	Queue               queue.Queuer
}

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