sendToUser 发给单个用户
(pm meta.PushMessage)
| 44 | |
| 45 | // sendToUser 发给单个用户 |
| 46 | func (p *postman) sendToUser(pm meta.PushMessage) error { |
| 47 | before, err := p.user.addMessage(pm.Msg.To, pm.Msg.ID) |
| 48 | if err != nil { |
| 49 | return errors.Trace(err) |
| 50 | } |
| 51 | log.Debugf("send msg:%v, ids:%v", pm, pm.Msg.To) |
| 52 | return p.notice.Push(pm, &meta.PushID{Before: before, User: pm.Msg.To}) |
| 53 | } |
| 54 | |
| 55 | // sendToGroup 发送给群 |
| 56 | func (p *postman) sendToGroup(pm meta.PushMessage) error { |
no test coverage detected