fix: push redis pkg (#1019)

* fix: repeated modification session notification

* fix: repeated modification session notification

* fix: jpush return a nil pointer panic

* fix: push redis pkg

* fix: OANotification
pull/1021/head
withchao 1 year ago committed by GitHub
parent 2cca15d7ce
commit 94a4199855
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

@ -15,14 +15,12 @@
package api package api
import ( import (
"github.com/OpenIMSDK/Open-IM-Server/pkg/authverify"
"github.com/OpenIMSDK/Open-IM-Server/pkg/common/config"
"github.com/OpenIMSDK/tools/mcontext" "github.com/OpenIMSDK/tools/mcontext"
"github.com/gin-gonic/gin" "github.com/gin-gonic/gin"
"github.com/go-playground/validator/v10" "github.com/go-playground/validator/v10"
"github.com/mitchellh/mapstructure" "github.com/mitchellh/mapstructure"
"google.golang.org/protobuf/proto"
"github.com/OpenIMSDK/Open-IM-Server/pkg/authverify"
"github.com/OpenIMSDK/Open-IM-Server/pkg/common/config"
"github.com/OpenIMSDK/protocol/constant" "github.com/OpenIMSDK/protocol/constant"
"github.com/OpenIMSDK/protocol/msg" "github.com/OpenIMSDK/protocol/msg"
@ -56,7 +54,6 @@ func (MessageApi) SetOptions(options map[string]bool, value bool) {
func (m MessageApi) newUserSendMsgReq(c *gin.Context, params *apistruct.SendMsg) *msg.SendMsgReq { func (m MessageApi) newUserSendMsgReq(c *gin.Context, params *apistruct.SendMsg) *msg.SendMsgReq {
var newContent string var newContent string
var err error
options := make(map[string]bool, 5) options := make(map[string]bool, 5)
switch params.ContentType { switch params.ContentType {
case constant.Text: case constant.Text:
@ -106,14 +103,14 @@ func (m MessageApi) newUserSendMsgReq(c *gin.Context, params *apistruct.SendMsg)
OfflinePushInfo: params.OfflinePushInfo, OfflinePushInfo: params.OfflinePushInfo,
}, },
} }
if params.ContentType == constant.OANotification { //if params.ContentType == constant.OANotification {
var tips sdkws.TipsComm // var tips sdkws.TipsComm
tips.JsonDetail = utils.StructToJsonString(params.Content) // tips.JsonDetail = utils.StructToJsonString(params.Content)
pbData.MsgData.Content, err = proto.Marshal(&tips) // pbData.MsgData.Content, err = proto.Marshal(&tips)
if err != nil { // if err != nil {
log.ZError(c, "Marshal failed ", err, "tips", tips.String()) // log.ZError(c, "Marshal failed ", err, "tips", tips.String())
} // }
} //}
return &pbData return &pbData
} }

@ -23,7 +23,7 @@ import (
"sync" "sync"
"time" "time"
"github.com/go-redis/redis" "github.com/redis/go-redis/v9"
"github.com/OpenIMSDK/tools/errs" "github.com/OpenIMSDK/tools/errs"
"github.com/OpenIMSDK/tools/log" "github.com/OpenIMSDK/tools/log"

Loading…
Cancel
Save