From 634584400a8249fc8a9b7a6fb780e59c070c01f7 Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Tue, 5 Apr 2022 11:50:26 +0800 Subject: [PATCH] tag and set private tips --- internal/msg_gateway/gate/logic.go | 3 ++- internal/msg_gateway/gate/validate.go | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/internal/msg_gateway/gate/logic.go b/internal/msg_gateway/gate/logic.go index be3053e6a..ab3618c44 100644 --- a/internal/msg_gateway/gate/logic.go +++ b/internal/msg_gateway/gate/logic.go @@ -214,7 +214,8 @@ func (ws *WServer) sendSignalMsgReq(conn *UserConn, m *Req) { } rtcClient := pbRtc.NewRtcServiceClient(connGrpc) req := &pbRtc.SignalMessageAssembleReq{ - SignalReq: pData.(*pbRtc.SignalReq), + SignalReq: pData.(*pbRtc.SignalReq), + OperationID: m.OperationID, } respPb, err := rtcClient.SignalMessageAssemble(context.Background(), req) if err != nil { diff --git a/internal/msg_gateway/gate/validate.go b/internal/msg_gateway/gate/validate.go index d34883c5c..329f93655 100644 --- a/internal/msg_gateway/gate/validate.go +++ b/internal/msg_gateway/gate/validate.go @@ -9,6 +9,7 @@ package gate import ( "Open_IM/pkg/common/constant" "Open_IM/pkg/common/log" + pbRtc "Open_IM/pkg/proto/rtc" open_im_sdk "Open_IM/pkg/proto/sdk_ws" "github.com/golang/protobuf/proto" ) @@ -71,7 +72,7 @@ func (ws *WServer) argsValidate(m *Req, r int32) (isPass bool, errCode int32, er } return true, 0, "", data case constant.WSSendSignalMsg: - data := open_im_sdk.SignalReq{} + data := pbRtc.SignalReq{} if err := proto.Unmarshal(m.Data, &data); err != nil { log.ErrorByKv("Decode Data struct err", "", "err", err.Error(), "reqIdentifier", r) return false, 203, err.Error(), nil