types

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

type AccessTokenVerifier func(accessToken string) (AccessToken, *tp.Rerror)

type Business struct {
	// ApiVersion long connection API version
	ApiVersion string
	// AccessTokenVerifier access token manager
	AccessTokenVerifier
	// LongConnHooks TCP socket connecting event hooks
	LongConnHooks
	// ShortConnHooks HTTP connecting event hooks
	ShortConnHooks
	// ProxyHooks proxy hooks
	ProxyHooks
}

type GwHosts struct {
	Hosts []string `protobuf:"bytes,1,rep,name=hosts" json:"hosts,omitempty"`
}

type LongConnHooks interface {
	// OnLogon is called when the client goes online.
	OnLogon(AccessToken, plugin.AuthSession) *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 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 PushLongConnArgs 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 PushLongConnReply = codec.PbEmpty

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 ShortConnHooks interface {
	// OnRequest is called when the client requests.
	OnRequest(AccessToken, RequestArgs) ([]socket.PacketSetting, *tp.Rerror)
}

type TotalLongConnArgs = codec.PbEmpty

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