check 检查发件人是否有权发送这个消息.
(msg *meta.Message)
| 26 | |
| 27 | // check 检查发件人是否有权发送这个消息. |
| 28 | func (p *postman) check(msg *meta.Message) error { |
| 29 | if msg.Group != 0 { |
| 30 | // 检测组中是否存在这个发件人 |
| 31 | if err := p.group.exist(msg.Group, msg.From); err != nil { |
| 32 | return errors.Annotatef(ErrInvalidSender, "group:%d not found user:%d", msg.Group, msg.From) |
| 33 | } |
| 34 | return nil |
| 35 | } |
| 36 | |
| 37 | // 检测收件人的好友里面有没有发件人 |
| 38 | if err := p.friend.exist(msg.To, msg.From); err != nil { |
| 39 | return errors.Annotatef(ErrInvalidSender, "unrelated from:%d to:%d", msg.From, msg.To) |
| 40 | } |
| 41 | |
| 42 | return nil |
| 43 | } |
| 44 | |
| 45 | // sendToUser 发给单个用户 |
| 46 | func (p *postman) sendToUser(pm meta.PushMessage) error { |