feat: add group friend rpc interface permission check

4 months ago · 54309b83a2
parent d55cb0fa8b
commit 54309b83a2
1 changed files with 1 additions and 0 deletions
--- a/internal/push/push_handler.go
+++ b/internal/push/push_handler.go
@ -142,6 +142,7 @@ func (c *ConsumerHandler) ConsumeClaim(sess sarama.ConsumerGroupSession, claim s
 	for msg := range claim.Messages() {
 		ctx := c.pushConsumerGroup.GetContextFromMsg(msg)
 		ctx = mcontext.WithOpUserIDContext(ctx, c.config.Share.IMAdminUserID[0])
 		c.handleMs2PsChat(ctx, msg.Value)
 		sess.MarkMessage(msg, "")
 	}