protocol

type AckMsg struct {
	Type string `json:"T"`
}

type BroadcastMsg struct {
	Type     string `json:"T"`
	AppId    string `json:",omitempty"`
	ChanId   string
	TopLevel int64
	Payloads []json.RawMessage
	// contains filtered or unexported fields
}

type ConnAckMsg struct {
	Type   string `json:"T"`
	Params ConnAckParams
}

type ConnAckParams struct {
	// ping interval formatted time.Duration
	PingInterval string
}

type ConnectMsg struct {
	Type      string `json:"T"`
	ClientVer string
	DeviceId  string
	Info      map[string]interface{} `json:",omitempty"` // platform etc...
	// maps channel ids (hex encoded UUIDs) to known client channel levels
	Levels map[string]int64
}

type Notification struct {
	AppId string `json:"A"`
	MsgId string `json:"M"`
	// payload
	Payload json.RawMessage `json:"P"`
}

type NotificationsMsg struct {
	Type          string `json:"T"`
	Notifications []Notification
}

type PingPongMsg struct {
	Type string `json:"T"`
}

type Protocol interface {
	SetDeadline(t time.Time)
	ReadMessage(msg interface{}) error
	WriteMessage(msg interface{}) error
}

type SplittableMsg interface {
	Split() (done bool)
}