(msg *meta.Message)
| 193 | } |
| 194 | |
| 195 | func (s *store) newMessage(msg *meta.Message) error { |
| 196 | log.Debugf("store newMessage[%d]:%+v", msg.ID, msg) |
| 197 | |
| 198 | req := &meta.StoreNewMessageRequest{Msg: msg} |
| 199 | resp, err := s.api.NewMessage(s.ctx, req) |
| 200 | if err != nil { |
| 201 | return errors.Trace(err) |
| 202 | } |
| 203 | |
| 204 | log.Debugf("send message[%d] success, resp:%v", msg.ID, resp) |
| 205 | return errors.Trace(resp.Header.Error()) |
| 206 | } |
| 207 | |
| 208 | func (s *store) loadMessage(userID, id int64, reverse bool) ([]*meta.PushMessage, error) { |
| 209 | log.Debugf("store loadMessage") |
no test coverage detected