CreateGroup 用户创建一个聊天组.
(ctx context.Context, req *meta.GateCreateGroupRequest)
| 404 | |
| 405 | // CreateGroup 用户创建一个聊天组. |
| 406 | func (g *Gate) CreateGroup(ctx context.Context, req *meta.GateCreateGroupRequest) (*meta.GateCreateGroupResponse, error) { |
| 407 | s, err := g.getOnlineSession(ctx) |
| 408 | if err != nil { |
| 409 | log.Errorf("getSession error:%s", errors.ErrorStack(err)) |
| 410 | return &meta.GateCreateGroupResponse{Header: &meta.ResponseHeader{Code: util.ErrorGetOnlineSession, Msg: err.Error()}}, nil |
| 411 | } |
| 412 | |
| 413 | gid, err := g.master.NewID() |
| 414 | if err != nil { |
| 415 | return &meta.GateCreateGroupResponse{Header: &meta.ResponseHeader{Code: util.ErrorMasterNewID, Msg: err.Error()}}, nil |
| 416 | } |
| 417 | |
| 418 | if err = g.store.createGroup(s.getID(), gid, req.GroupName); err != nil { |
| 419 | return &meta.GateCreateGroupResponse{Header: &meta.ResponseHeader{Code: util.ErrorCreateGroup, Msg: err.Error()}}, nil |
| 420 | } |
| 421 | |
| 422 | log.Debugf("user:%d, create group:%d", s.getID(), gid) |
| 423 | return &meta.GateCreateGroupResponse{ID: gid}, nil |
| 424 | } |
| 425 | |
| 426 | // LoadGroupList 加载群组列表 |
| 427 | func (g *Gate) LoadGroupList(ctx context.Context, req *meta.GateLoadGroupListRequest) (*meta.GateLoadGroupListResponse, error) { |
nothing calls this directly
no test coverage detected