blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-04-06 04:15:46 +08:00
Code Issues Packages Projects Releases Wiki Activity

pb modify

Browse Source
This commit is contained in:
Gordon 2022-03-15 10:17:24 +08:00
parent b4c16002ff
commit 1db0966675
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
internal/msg_gateway/gate/validate.go
View File

@ -217,12 +217,12 @@ func (ws *WServer) signalMessageAssemble(s *open_im_sdk.SignalReq) (isPass bool,
if err2 != nil { if err2 != nil {
return false, 201, err2.Error(), nil, nil return false, 201, err2.Error(), nil, nil
} }
cancel := open_im_sdk.SignalResp_Accept{&open_im_sdk.SignalAcceptReply{ accept := open_im_sdk.SignalResp_Accept{&open_im_sdk.SignalAcceptReply{
Token: token, Token: token,
LiveURL: media.GetUrl(), LiveURL: media.GetUrl(),
RoomID: payload.Accept.Invitation.RoomID, RoomID: payload.Accept.Invitation.RoomID,
}} }}
resp.Payload = &cancel resp.Payload = &accept
msg.OfflinePushInfo = payload.Accept.OfflinePushInfo msg.OfflinePushInfo = payload.Accept.OfflinePushInfo
msg.SendID = payload.Accept.OpUserID msg.SendID = payload.Accept.OpUserID
msg.SenderPlatformID = payload.Accept.Invitation.PlatformID msg.SenderPlatformID = payload.Accept.Invitation.PlatformID
@ -241,10 +241,10 @@ func (ws *WServer) signalMessageAssemble(s *open_im_sdk.SignalReq) (isPass bool,
return true, 0, "", &resp, &msg return true, 0, "", &resp, &msg
case *open_im_sdk.SignalReq_HungUp: case *open_im_sdk.SignalReq_HungUp:
case *open_im_sdk.SignalReq_Reject: case *open_im_sdk.SignalReq_Reject:
cancel := open_im_sdk.SignalResp_Reject{&open_im_sdk.SignalRejectReply{}} reject := open_im_sdk.SignalResp_Reject{&open_im_sdk.SignalRejectReply{}}
resp.Payload = &cancel resp.Payload = &reject
msg.OfflinePushInfo = payload.Reject.OfflinePushInfo msg.OfflinePushInfo = payload.Reject.OfflinePushInfo
msg.SendID = payload.Reject.InviteeUserID msg.SendID = payload.Reject.OpUserID
msg.SenderPlatformID = payload.Reject.Invitation.PlatformID msg.SenderPlatformID = payload.Reject.Invitation.PlatformID
msg.SessionType = payload.Reject.Invitation.SessionType msg.SessionType = payload.Reject.Invitation.SessionType
if len(payload.Reject.Invitation.InviteeUserIDList) > 0 { if len(payload.Reject.Invitation.InviteeUserIDList) > 0 {
@ -257,7 +257,7 @@ func (ws *WServer) signalMessageAssemble(s *open_im_sdk.SignalReq) (isPass bool,
} else { } else {
return false, 201, errors.New("InviteeUserIDList is null").Error(), nil, nil return false, 201, errors.New("InviteeUserIDList is null").Error(), nil, nil
} }
msg.ClientMsgID = utils.GetMsgID(payload.Reject.InviteeUserID) msg.ClientMsgID = utils.GetMsgID(payload.Reject.OpUserID)
return true, 0, "", &resp, &msg return true, 0, "", &resp, &msg
} }
return false, 201, errors.New("InviteeUserIDList is null").Error(), nil, nil return false, 201, errors.New("InviteeUserIDList is null").Error(), nil, nil