types

type AccessToken interface {
	// Uid returns the user id.
	Uid() string
	// String returns the access token string.
	String() string
}

type AccessTokenMgr interface {
	// QueryForHttp queries access token from http query parameter
	QueryForHttp(args RequestArgs) string
	// Verify Verifies access token
	Verify(accessToken string) (AccessToken, *tp.Rerror)
}

type Business struct {
	// AccessTokenMgr access token manager
	AccessTokenMgr
	// SocketHooks TCP socket connecting event hooks
	SocketHooks
	// HttpHooks HTTP connecting event hooks
	HttpHooks
	// ProxyHooks proxy hooks
	ProxyHooks
}

type GwHosts struct {
	Http   []string `protobuf:"bytes,1,rep,name=http" json:"http,omitempty"`
	Socket []string `protobuf:"bytes,2,rep,name=socket" json:"socket,omitempty"`
}

type HttpHooks interface {
	// OnRequest is called when the client requests.
	OnRequest(RequestArgs, ...AccessToken) ([]socket.PacketSetting, *tp.Rerror)
}

type ProxyHooks interface {
	// BeforePull is called before pulling the internal service.
	BeforePull(uri string, args interface{}, reply interface{}, setting ...socket.PacketSetting) *tp.Rerror
	// BeforePush is called before pushing the internal service.
	BeforePush(uri string, args interface{}, setting ...socket.PacketSetting) *tp.Rerror
}

type RequestArgs interface {
	// Query returns query arguments from request URI.
	Query(key string) string
	// Header returns header value for the given key.
	Header(key string) string
	// Cookie returns cookie for the given key.
	Cookie(key string) string
}

type SocketHooks interface {
	// OnLogon is called when the client goes online.
	OnLogon(plugin.AuthSession, AccessToken) *tp.Rerror
	// OnLogoff is called when the client goes offline.
	OnLogoff(tp.BaseSession) *tp.Rerror
	// GetSession returns session from peer by uid.
	GetSession(peer tp.Peer, uid string) (tp.Session, *tp.Rerror)
	//PreWritePush is executed before writing PUSH packet.
	PreWritePush(tp.WriteCtx) *tp.Rerror
}

type SocketPushArgs struct {
	Uid       string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
	Uri       string `protobuf:"bytes,2,opt,name=uri,proto3" json:"uri,omitempty"`
	Body      []byte `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	BodyCodec int32  `protobuf:"varint,4,opt,name=body_codec,json=bodyCodec,proto3" json:"body_codec,omitempty"`
}

type SocketPushReply = codec.PbEmpty

type SocketTotalArgs = codec.PbEmpty

type SocketTotalReply struct {
	ConnTotal int32 `protobuf:"varint,1,opt,name=conn_total,json=connTotal,proto3" json:"conn_total,omitempty"`
}