LoadMessage 收取用户消息,每次可逆序(旧消息)或正序(新消息)接收100条 如果ID为0,就逆序返回旧的100条消息
(_ context.Context, req *meta.StoreLoadMessageRequest)
| 259 | // LoadMessage 收取用户消息,每次可逆序(旧消息)或正序(新消息)接收100条 |
| 260 | // 如果ID为0,就逆序返回旧的100条消息 |
| 261 | func (s *Store) LoadMessage(_ context.Context, req *meta.StoreLoadMessageRequest) (*meta.StoreLoadMessageResponse, error) { |
| 262 | // 修正下,确定前面不会传错 |
| 263 | if req.ID == 0 { |
| 264 | req.ID = math.MaxInt64 |
| 265 | req.Reverse = true |
| 266 | } |
| 267 | |
| 268 | ids, err := s.user.getMessage(req.User, req.Reverse, req.ID) |
| 269 | if err != nil { |
| 270 | return &meta.StoreLoadMessageResponse{Header: &meta.ResponseHeader{Code: -1, Msg: err.Error()}}, nil |
| 271 | } |
| 272 | msgs, err := s.message.get(ids...) |
| 273 | if err != nil { |
| 274 | return &meta.StoreLoadMessageResponse{Header: &meta.ResponseHeader{Code: -1, Msg: err.Error()}}, nil |
| 275 | } |
| 276 | |
| 277 | return &meta.StoreLoadMessageResponse{Msgs: msgs}, nil |
| 278 | } |
| 279 | |
| 280 | // CreateGroup 创建群组 |
| 281 | func (s *Store) CreateGroup(_ context.Context, req *meta.StoreCreateGroupRequest) (*meta.StoreCreateGroupResponse, error) { |
nothing calls this directly
no test coverage detected