im

type App struct {
	AppId string `form:"appId" binding:"required" json:"appId"`
	Plat  int32  `form:"plat" binding:"-" json:"plat"`
}

type Client struct {
	// contains filtered or unexported fields
}

type ClientCmd struct {
	Cmd     int
	Reason  string
	TraceId string
	Client  *Client
}

type Config struct {
	WorkForceReset bool                                                          `json:"workForceReset" yaml:"workForceReset"`
	RegisterClient int                                                           `json:"registerClient" yaml:"registerClient"`
	ServerAddr     server.Address                                                `json:"serverAddr" yaml:"serverAddr"` //服务地址
	CheckFunc      func(ctx context.Context, client *Client, token string) error `json:"-" yaml:"-"`
	// contains filtered or unexported fields
}

type Connect struct {
	Session
	Version  string `form:"version" json:"version"`
	Token    string `form:"token" json:"token"`
	RemoteIP string `form:"remoteIP" json:"remoteIP"`
}

type Copy struct {
	Begin   func(count int) interface{}
	Process func(be interface{}, index int, data interface{})
}

type DisposeFunc func(client *Client, req *EventReq) (interface{}, error)

type Event struct {
	EvTypeBase  int32  `json:"-"`           // 事件基数
	EventType   int32  `json:"eventType"`   // 事件类型, EventType
	ContentType string `json:"contentType"` // Content 格式,json,xml...protobuff, 默认json
	Content     string `json:"content"`     // 具体的业务数据
	TraceId     string `json:"-"`
}

type EventReq struct {
	ReqHead
	Event
	Session
	// 事件相应的回应类型
	EvTypeRsp int32  `json:"-"`
	TraceId   string `json:"-"`
}

type EventRes struct {
	ResHead
	Event
}

type EventType int32

type IAmMemberFunc func(user *Session, iAmMember bool) error

type IM struct {
	// contains filtered or unexported fields
}

type Manager interface {
	DoClientCmd(ctx context.Context, reg *ClientCmd)
	DoClientCmdSync(ctx context.Context, reg *ClientCmd)
	Kicked(ctx context.Context, client *Client, reason string)
	UserStatusChanged(ctx context.Context, us *UserStatus)
	OnLogin(ctx context.Context, log *UserLog)
	OnLogout(ctx context.Context, log *UserLog)
	Source() string
}

type MemberFunc func(groupId int64, user *Session) error

type MsgPack struct {
	TraceId string
	Body    []byte
}

type Online struct {
	AppId  string `json:"appId"`
	UserId uint64 `json:"userId"`
	Plat   int32  `json:"plat"`
	// 用户所在的服务器ip
	Host string `json:"host,omitempty"`
	// 用户所在的服务器端口
	Port int `json:"port,omitempty"`
	// 客户端Ip
	ClientIp string `json:"clientIp,omitempty"`
	// 客户端端口
	ClientPort string `json:"clientPort,omitempty"`
	// 用户上次登录时间
	LoginTime int64 `json:"loginTime,omitempty"`
	// 用户上次心跳时间
	HeartbeatTime int64 `json:"heartbeatTime,omitempty"`
	// 用户退出登录的时间
	LogOutTime int64 `json:"logOutTime,omitempty"`
	// 是否离线
	IsOffline bool `json:"isOffline"`
}

type Option struct {
	CrmNotifyEnable bool
}

type ReqHead struct {
	Source  string        `json:"source"`
	Version string        `json:"version"`
	SeqId   string        `json:"seqId"`
	ReqAt   int64         `json:"timeAt"` //客户端或服务器的时间
	RecvAt  int64         `json:"-"`      //服务器收到的时间
	TimeOut time.Duration `json:"-"`
}

type ResHead struct {
	result.Result
	Version  string `json:"version"`            //版本，请求者版本
	Source   string `json:"source,omitempty"`   //请求源，可以请求者填写
	SeqId    string `json:"seqId,omitempty"`    //请求序号，由请求者定义，服务器原路返回
	TimeAt   int64  `json:"timeAt,omitempty"`   //服务收到请求的时间(ms)
	DiffAt   int64  `json:"diffAt,omitempty"`   //客户端与服务端时间差值（ms)
	SpendAt  int64  `json:"spendAt,omitempty"`  //从服务收到请求到响应完成，所花的时长(ms)
	ServerAt int64  `json:"serverAt,omitempty"` //服务器时间，豪秒，用于检验对时(ms)
	LogId    string `json:"logId,omitempty"`
}

type Session struct {
	AppId    string `form:"appId" binding:"required" json:"appId"`
	Plat     int32  `form:"plat" binding:"-" json:"plat"`
	UserId   uint64 `form:"userId" binding:"required" json:"userId"`
	ClientId uint64 `form:"clientId" binding:"-" json:"clientId"`
}

type Status struct {
	Session
	TimeAt  int64  `json:"timeAt"`
	Status  int32  `json:"status"`
	Desc    string `json:"desc"`
	TraceId string `json:"-"`
}

type User interface {
	SetSupportApp(apps []App)
	NextSupportApp(fn func(app App) bool)
	ExistSupportApp(app App) bool
	HeartbeatTimeout() int64
	GetUserKey(session *Session) string
	GetUserOnline(session *Session) (*Online, error)
	// SetUserOnline 写到redis中
	SetUserOnline(session *Session, online *Online) error
	RemoveUserOnline(session *Session) error
	IsUserOnline(session *Session) (bool, error)

	GetAllOnline(cc *Copy, session *Session) error

	//UserStatusChanged 通知基它服务有变化
	UserStatusChanged(status *Status, option *Option)
}

type UserList struct {
	Count int        `json:"count"`
	List  []*Session `json:"list,omitempty"`
}

type UserLog struct {
	Session Session
	TimeAt  int64
	Client  *Client
}

type UserStatus struct {
	Session Session
	Addr    string
	TraceId string
	Status  int32
	TimeAt  int64
}