message update

This commit is contained in:
Gordon
2022-05-30 17:46:06 +08:00
committed by Xinwei Xiong(cubxxw-openim)
parent 26edb159d9
commit cb44e1678d
2 changed files with 105 additions and 1 deletions
+7 -1
View File
@@ -2,6 +2,7 @@ package logic
import (
"Open_IM/pkg/common/config"
"Open_IM/pkg/common/constant"
"Open_IM/pkg/common/log"
"Open_IM/pkg/grpc-etcdv3/getcdv3"
"Open_IM/pkg/proto/push"
@@ -49,7 +50,12 @@ func (r *RPCServer) run() {
}
func (r *RPCServer) PushMsg(_ context.Context, pbData *pbPush.PushMsgReq) (*pbPush.PushMsgResp, error) {
//Call push module to send message to the user
MsgToUser(pbData)
switch pbData.MsgData.SessionType {
case constant.SuperGroupChatType:
MsgToSuperGroupUser(pbData)
default:
MsgToUser(pbData)
}
return &pbPush.PushMsgResp{
ResultCode: 0,
}, nil