subscription

type Chan struct {
}

type ChanID string

type ChanInfo struct {
	ID   ChanID
	Type ChanType

	Muted   bool
	Blocked bool
	Closed  bool

	Parent *ChanID
	Child  []ChanID
}

type ChanType int32

type Channel interface {
	Subscribe(id SubscriberID, extra interface{}) error

	Unsubscribe(id SubscriberID) error

	Update(i *ChanInfo) error

	Publish(msg Message) error

	Close() error
}

type ChannelUpdate struct {
	Flag int64

	Extra interface{}
}

type Interface interface {
	PublishMessage(id ChanID, message Message) error
}

type Message interface {
	GetFrom() SubscriberID

	// GetChatMessage convert message body to *messages.ChatMessage
	GetChatMessage() (*messages.ChatMessage, error)
}

type Server interface {
	Subscribe

	Run() error
}

type Subscribe interface {
	Interface

	SetGateInterface(gate gate.Interface)

	UpdateSubscriber(id ChanID, updates []Update) error

	UpdateChannel(id ChanID, update ChannelUpdate) error
}

type Subscriber struct {
	ID   string
	Type string
}

type SubscriberID string

type Update struct {
	Flag int64
	ID   SubscriberID

	Extra interface{}
}