blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-12-03 19:02:31 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: solve unmarshal fail problem

Browse Source
This commit is contained in:
luhaoling 2024-01-15 18:10:51 +08:00
parent f910dcf314
commit 22a926d64d
1 changed files with 23 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
internal/api/msg.go
View File

@ -15,6 +15,7 @@
package api package api
import ( import (
"encoding/json"
"github.com/OpenIMSDK/protocol/auth" "github.com/OpenIMSDK/protocol/auth"
"github.com/OpenIMSDK/protocol/constant" "github.com/OpenIMSDK/protocol/constant"
"github.com/OpenIMSDK/protocol/msg" "github.com/OpenIMSDK/protocol/msg"
@ -409,26 +410,36 @@ func (m *MessageApi) CallbackExample(c *gin.Context) {
} }
apiresp.GinSuccess(c, resp) apiresp.GinSuccess(c, resp)
if req.SendID == config.Config.IMAdmin.UserID[0] { imAdmin := config.Config.IMAdmin.UserID[0]
if req.SendID == imAdmin || (req.SendID != imAdmin && req.SendID != imAdmin) {
return return
} }
url := "http://127.0.0.1:10002/auth/user_token" url := "http://127.0.0.1:10002/auth/user_token"
header := map[string]string{} header := map[string]string{}
header["operationID"] = req.OperationID header["operationID"] = req.OperationID
input_token := auth.UserTokenReq{ input_token := &auth.UserTokenReq{
Secret: config.Config.Secret, Secret: config.Config.Secret,
PlatformID: req.SenderPlatformID, PlatformID: req.SenderPlatformID,
UserID: config.Config.IMAdmin.UserID[0], UserID: config.Config.IMAdmin.UserID[0],
} }
output_token := &auth.UserTokenResp{} output_token := &auth.UserTokenResp{}
if err := http.PostReturn(c, url, header, input_token, output_token, 10); err != nil { data, err := http.Post(c, url, header, input_token, 10)
if err != nil {
log.ZError(c, "CallbackExample get Sender token failed", err) log.ZError(c, "CallbackExample get Sender token failed", err)
apiresp.GinError(c, errs.ErrInternalServer.WithDetail(err.Error()).Wrap()) apiresp.GinError(c, errs.ErrInternalServer.WithDetail(err.Error()).Wrap())
return return
} }
if err = json.Unmarshal(data, output_token); err != nil {
log.ZError(c, "CallbackExample unmarshal userToken failed", err)
apiresp.GinError(c, errs.ErrInternalServer.WithDetail(err.Error()).Wrap())
return
}
log.ZDebug(c, "CallbackExample get User Token", "token", output_token)
user, err := m.userRpcClient.GetUserInfo(c, req.RecvID) user, err := m.userRpcClient.GetUserInfo(c, req.RecvID)
if err != nil { if err != nil {
log.ZError(c, "CallbackExample get Sender failed", err) log.ZError(c, "CallbackExample get Sender failed", err)
@ -456,11 +467,19 @@ func (m *MessageApi) CallbackExample(c *gin.Context) {
header["token"] = output_token.Token header["token"] = output_token.Token
output := &msg.SendMsgResp{} output := &msg.SendMsgResp{}
if err := http.PostReturn(c, url, header, input, output, 10); err != nil { log.ZDebug(c, "CallbackExample Header", "header", header)
b, err := http.Post(c, url, header, input, 10)
if err != nil {
log.ZError(c, "CallbackExample send message failed", err) log.ZError(c, "CallbackExample send message failed", err)
apiresp.GinError(c, errs.ErrInternalServer.WithDetail(err.Error()).Wrap()) apiresp.GinError(c, errs.ErrInternalServer.WithDetail(err.Error()).Wrap())
return return
} }
if err = json.Unmarshal(b, output); err != nil {
log.ZError(c, "CallbackExample unmarshal failed", err)
apiresp.GinError(c, errs.ErrInternalServer.WithDetail(err.Error()).Wrap())
return
}
apiresp.GinSuccess(c, output) apiresp.GinSuccess(c, output)
} }