cascade

type DisconnectCallback func(string, error)

type Hub struct {
	Upgrader    *websocket.Upgrader
	MaxReadSize int64

	Peers                map[*Peer]bool         // client's map
	PeerRegister         chan *Peer             // channel that notify peer active
	PeerUnregister       chan *Peer             // channel that notify peer inactive
	ByteMessageChannel   chan *HubByteMessage   // message channel
	ObjectMessageChannel chan *HubObjectMessage // named object channel
	ExitChannel          chan int
	Slot                 Slot
}

type HubByteMessage struct {
	Peer    *Peer
	Message []byte
}

type HubObjectMessage struct {
	Peer       *Peer
	ObjectName string
	ObjectPtr  interface{}
}

type Peer struct {
	Hub            *Hub            // peer's hub
	Conn           *websocket.Conn // websocket connection
	SendChannel    chan []byte     // send channel
	CallbackOnRead func([]byte)    // on read message form peer
	ExtraInfo      interface{}     // extra information
	Header         http.Header     // header
}

type Slot interface {
	// peer message
	OnActive(*Peer)
	OnInactive(*Peer)
	OnRead(*Peer, []byte)

	// hub message
	OnHubByteMessage(*HubByteMessage)
	OnHubObjectMessage(*HubObjectMessage)
}