proto

type AuthConnection interface {
	Connection

	DoAuth(session *TcpSession, auth *LoginAuth) *Response
	OnAck(msg *Message)
}

type ClientConnection interface {
	Connection

	OnAuthSuccess(session *TcpSession)
	HandleResponse(msgHead MsgHead, resp map[string]interface{})
	HandlePushResponse(msgHead MsgHead, method string, resp map[string]interface{})
}

type Connection interface {
	OnConnected(session *TcpSession)
	OnDisconnected(session *TcpSession)
	HandleMessage(session *TcpSession, msg *Message)
}

type LoginAuth struct {
	UserId int64  `json:"userId"`
	Token  string `json:"token"`
}

type Message struct {
	MsgHead
	Body []byte
}

type MsgHead struct {
	Version uint8
	Cmd     uint8
	Flag    uint8
	Ext     uint8
	Length  int
	MsgId   string
}

type Response struct {
	sync.RWMutex
	Code string
	// contains filtered or unexported fields
}

type TcpRequest struct {
	Method string
	Data   []byte
}

type TcpSession struct {
	Conn               *net.TCPConn // socket
	BR                 *bufio.Reader
	GmtConnect         time.Time
	RemoteAddr         string
	UniqueKey          string
	ConnectionListener Connection
	// contains filtered or unexported fields
}