MCPcopy Index your code
hub / github.com/dearcode/candy / LoadMessage

Method LoadMessage

store/server.go:261–278  ·  view source on GitHub ↗

LoadMessage 收取用户消息,每次可逆序(旧消息)或正序(新消息)接收100条 如果ID为0,就逆序返回旧的100条消息

(_ context.Context, req *meta.StoreLoadMessageRequest)

Source from the content-addressed store, hash-verified

259// LoadMessage 收取用户消息,每次可逆序(旧消息)或正序(新消息)接收100条
260// 如果ID为0,就逆序返回旧的100条消息
261func (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 创建群组
281func (s *Store) CreateGroup(_ context.Context, req *meta.StoreCreateGroupRequest) (*meta.StoreCreateGroupResponse, error) {

Callers

nothing calls this directly

Calls 3

getMessageMethod · 0.80
ErrorMethod · 0.45
getMethod · 0.45

Tested by

no test coverage detected