123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657 |
- package websocket
- import (
- "github.com/gogf/gf/v2/os/gtime"
- "github.com/gogf/gf/v2/util/gconv"
- )
- // LoginController 用户登录
- func LoginController(client *Client, req *request) {
- userId := gconv.Uint64(0)
- // 用户登录
- login := &login{
- UserId: userId,
- Client: client,
- }
- clientManager.Login <- login
- client.SendMsg(&WResponse{
- Event: Login,
- Data: "success",
- })
- }
- func IsAppController(client *Client) {
- client.isApp = true
- }
- // JoinController 加入
- func JoinController(client *Client, req *request) {
- name := gconv.String(req.Data["name"])
- if !client.tags.Contains(name) {
- client.tags.Append(name)
- }
- client.SendMsg(&WResponse{
- Event: Join,
- Data: client.tags.Slice(),
- })
- }
- // QuitController 退出
- func QuitController(client *Client, req *request) {
- name := gconv.String(req.Data["name"])
- if client.tags.Contains(name) {
- client.tags.RemoveValue(name)
- }
- client.SendMsg(&WResponse{
- Event: Quit,
- Data: client.tags.Slice(),
- })
- }
- func PingController(client *Client) {
- currentTime := uint64(gtime.Now().Unix())
- client.Heartbeat(currentTime)
- }
|