mirror of
https://github.com/openimsdk/open-im-server.git
synced 2025-04-06 04:15:46 +08:00
Merge branch 'tuoyun' of github.com:OpenIMSDK/Open-IM-Server into tuoyun
This commit is contained in:
commit
cc1ad41e94
@ -132,7 +132,7 @@ func (ws *WServer) signalMessageAssemble(s *open_im_sdk.SignalReq, operationID s
|
|||||||
options := make(map[string]bool, 6)
|
options := make(map[string]bool, 6)
|
||||||
utils.SetSwitchFromOptions(options, constant.IsHistory, false)
|
utils.SetSwitchFromOptions(options, constant.IsHistory, false)
|
||||||
utils.SetSwitchFromOptions(options, constant.IsPersistent, false)
|
utils.SetSwitchFromOptions(options, constant.IsPersistent, false)
|
||||||
utils.SetSwitchFromOptions(options, constant.IsSenderSync, false)
|
utils.SetSwitchFromOptions(options, constant.IsSenderSync, true)
|
||||||
utils.SetSwitchFromOptions(options, constant.IsConversationUpdate, false)
|
utils.SetSwitchFromOptions(options, constant.IsConversationUpdate, false)
|
||||||
utils.SetSwitchFromOptions(options, constant.IsUnreadCount, false)
|
utils.SetSwitchFromOptions(options, constant.IsUnreadCount, false)
|
||||||
utils.SetSwitchFromOptions(options, constant.IsOfflinePush, true)
|
utils.SetSwitchFromOptions(options, constant.IsOfflinePush, true)
|
||||||
|
@ -38,15 +38,15 @@ func (mc *HistoryConsumerHandler) Init() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (mc *HistoryConsumerHandler) handleChatWs2Mongo(msg []byte, msgKey string) {
|
func (mc *HistoryConsumerHandler) handleChatWs2Mongo(msg []byte, msgKey string) {
|
||||||
log.NewInfo("msg come mongo!!!", "", "msg", string(msg))
|
|
||||||
time := utils.GetCurrentTimestampByNano()
|
time := utils.GetCurrentTimestampByNano()
|
||||||
msgFromMQ := pbMsg.MsgDataToMQ{}
|
msgFromMQ := pbMsg.MsgDataToMQ{}
|
||||||
err := proto.Unmarshal(msg, &msgFromMQ)
|
err := proto.Unmarshal(msg, &msgFromMQ)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.ErrorByKv("msg_transfer Unmarshal msg err", "", "msg", string(msg), "err", err.Error())
|
log.Error("msg_transfer Unmarshal msg err", "", "msg", string(msg), "err", err.Error())
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
operationID := msgFromMQ.OperationID
|
operationID := msgFromMQ.OperationID
|
||||||
|
log.NewInfo(operationID, "msg come mongo!!!", "", "msg", string(msg))
|
||||||
//Control whether to store offline messages (mongo)
|
//Control whether to store offline messages (mongo)
|
||||||
isHistory := utils.GetSwitchFromOptions(msgFromMQ.MsgData.Options, constant.IsHistory)
|
isHistory := utils.GetSwitchFromOptions(msgFromMQ.MsgData.Options, constant.IsHistory)
|
||||||
//Control whether to store history messages (mysql)
|
//Control whether to store history messages (mysql)
|
||||||
@ -99,28 +99,28 @@ func (mc *HistoryConsumerHandler) ConsumeClaim(sess sarama.ConsumerGroupSession,
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
func sendMessageToPush(message *pbMsg.MsgDataToMQ, pushToUserID string) {
|
func sendMessageToPush(message *pbMsg.MsgDataToMQ, pushToUserID string) {
|
||||||
log.InfoByKv("msg_transfer send message to push", message.OperationID, "message", message.String())
|
log.Info(message.OperationID, "msg_transfer send message to push", "message", message.String())
|
||||||
rpcPushMsg := pbPush.PushMsgReq{OperationID: message.OperationID, MsgData: message.MsgData, PushToUserID: pushToUserID}
|
rpcPushMsg := pbPush.PushMsgReq{OperationID: message.OperationID, MsgData: message.MsgData, PushToUserID: pushToUserID}
|
||||||
mqPushMsg := pbMsg.PushMsgDataToMQ{OperationID: message.OperationID, MsgData: message.MsgData, PushToUserID: pushToUserID}
|
mqPushMsg := pbMsg.PushMsgDataToMQ{OperationID: message.OperationID, MsgData: message.MsgData, PushToUserID: pushToUserID}
|
||||||
grpcConn := getcdv3.GetConn(config.Config.Etcd.EtcdSchema, strings.Join(config.Config.Etcd.EtcdAddr, ","), config.Config.RpcRegisterName.OpenImPushName)
|
grpcConn := getcdv3.GetConn(config.Config.Etcd.EtcdSchema, strings.Join(config.Config.Etcd.EtcdAddr, ","), config.Config.RpcRegisterName.OpenImPushName)
|
||||||
if grpcConn == nil {
|
if grpcConn == nil {
|
||||||
log.ErrorByKv("rpc dial failed", rpcPushMsg.OperationID, "push data", rpcPushMsg.String())
|
log.Error(rpcPushMsg.OperationID, "rpc dial failed", "push data", rpcPushMsg.String())
|
||||||
pid, offset, err := producer.SendMessage(&mqPushMsg)
|
pid, offset, err := producer.SendMessage(&mqPushMsg)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.ErrorByKv("kafka send failed", mqPushMsg.OperationID, "send data", message.String(), "pid", pid, "offset", offset, "err", err.Error())
|
log.Error(mqPushMsg.OperationID, "kafka send failed", "send data", message.String(), "pid", pid, "offset", offset, "err", err.Error())
|
||||||
}
|
}
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
msgClient := pbPush.NewPushMsgServiceClient(grpcConn)
|
msgClient := pbPush.NewPushMsgServiceClient(grpcConn)
|
||||||
_, err := msgClient.PushMsg(context.Background(), &rpcPushMsg)
|
_, err := msgClient.PushMsg(context.Background(), &rpcPushMsg)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.ErrorByKv("rpc send failed", rpcPushMsg.OperationID, "push data", rpcPushMsg.String(), "err", err.Error())
|
log.Error(rpcPushMsg.OperationID, "rpc send failed", rpcPushMsg.OperationID, "push data", rpcPushMsg.String(), "err", err.Error())
|
||||||
pid, offset, err := producer.SendMessage(&mqPushMsg)
|
pid, offset, err := producer.SendMessage(&mqPushMsg)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.ErrorByKv("kafka send failed", mqPushMsg.OperationID, "send data", mqPushMsg.String(), "pid", pid, "offset", offset, "err", err.Error())
|
log.Error("kafka send failed", mqPushMsg.OperationID, "send data", mqPushMsg.String(), "pid", pid, "offset", offset, "err", err.Error())
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
log.InfoByKv("rpc send success", rpcPushMsg.OperationID, "push data", rpcPushMsg.String())
|
log.Info("rpc send success", rpcPushMsg.OperationID, "push data", rpcPushMsg.String())
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -351,7 +351,7 @@ func (s *friendServer) IsInBlackList(ctx context.Context, req *pbFriend.IsInBlac
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (s *friendServer) IsFriend(ctx context.Context, req *pbFriend.IsFriendReq) (*pbFriend.IsFriendResp, error) {
|
func (s *friendServer) IsFriend(ctx context.Context, req *pbFriend.IsFriendReq) (*pbFriend.IsFriendResp, error) {
|
||||||
log.NewInfo("IsFriend args ", req.String())
|
log.NewInfo(req.CommID.OperationID, req.String())
|
||||||
var isFriend bool
|
var isFriend bool
|
||||||
if !token_verify.CheckAccess(req.CommID.OpUserID, req.CommID.FromUserID) {
|
if !token_verify.CheckAccess(req.CommID.OpUserID, req.CommID.FromUserID) {
|
||||||
log.NewError(req.CommID.OperationID, "CheckAccess false ", req.CommID.OpUserID, req.CommID.FromUserID)
|
log.NewError(req.CommID.OperationID, "CheckAccess false ", req.CommID.OpUserID, req.CommID.FromUserID)
|
||||||
@ -363,7 +363,7 @@ func (s *friendServer) IsFriend(ctx context.Context, req *pbFriend.IsFriendReq)
|
|||||||
} else {
|
} else {
|
||||||
isFriend = false
|
isFriend = false
|
||||||
}
|
}
|
||||||
log.NewInfo("IsFriend rpc ok ", pbFriend.IsFriendResp{Response: isFriend})
|
log.NewInfo(req.CommID.OperationID, pbFriend.IsFriendResp{Response: isFriend})
|
||||||
return &pbFriend.IsFriendResp{Response: isFriend}, nil
|
return &pbFriend.IsFriendResp{Response: isFriend}, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -46,6 +46,7 @@ func userRelationshipVerification(data *pbChat.SendMsgReq) (bool, int32, string)
|
|||||||
if data.MsgData.SessionType == constant.GroupChatType {
|
if data.MsgData.SessionType == constant.GroupChatType {
|
||||||
return true, 0, ""
|
return true, 0, ""
|
||||||
}
|
}
|
||||||
|
log.NewDebug(data.OperationID, config.Config.MessageVerify.FriendVerify)
|
||||||
req := &rpc.IsInBlackListReq{CommID: &rpc.CommID{}}
|
req := &rpc.IsInBlackListReq{CommID: &rpc.CommID{}}
|
||||||
req.CommID.OperationID = data.OperationID
|
req.CommID.OperationID = data.OperationID
|
||||||
req.CommID.OpUserID = data.MsgData.RecvID
|
req.CommID.OpUserID = data.MsgData.RecvID
|
||||||
@ -60,6 +61,7 @@ func userRelationshipVerification(data *pbChat.SendMsgReq) (bool, int32, string)
|
|||||||
log.NewDebug(data.OperationID, "IsInBlackListReq ", req.String())
|
log.NewDebug(data.OperationID, "IsInBlackListReq ", req.String())
|
||||||
return false, 600, "in black list"
|
return false, 600, "in black list"
|
||||||
}
|
}
|
||||||
|
log.NewDebug(data.OperationID, config.Config.MessageVerify.FriendVerify)
|
||||||
if config.Config.MessageVerify.FriendVerify {
|
if config.Config.MessageVerify.FriendVerify {
|
||||||
friendReq := &rpc.IsFriendReq{CommID: &rpc.CommID{}}
|
friendReq := &rpc.IsFriendReq{CommID: &rpc.CommID{}}
|
||||||
friendReq.CommID.OperationID = data.OperationID
|
friendReq.CommID.OperationID = data.OperationID
|
||||||
@ -74,10 +76,11 @@ func userRelationshipVerification(data *pbChat.SendMsgReq) (bool, int32, string)
|
|||||||
log.NewDebug(data.OperationID, "not friend ", req.String())
|
log.NewDebug(data.OperationID, "not friend ", req.String())
|
||||||
return friendReply.Response, 601, "not friend"
|
return friendReply.Response, 601, "not friend"
|
||||||
}
|
}
|
||||||
|
log.NewDebug(data.OperationID, config.Config.MessageVerify.FriendVerify, friendReply.Response)
|
||||||
|
return true, 0, ""
|
||||||
} else {
|
} else {
|
||||||
return true, 0, ""
|
return true, 0, ""
|
||||||
}
|
}
|
||||||
return true, 0, ""
|
|
||||||
}
|
}
|
||||||
func (rpc *rpcChat) encapsulateMsgData(msg *sdk_ws.MsgData) {
|
func (rpc *rpcChat) encapsulateMsgData(msg *sdk_ws.MsgData) {
|
||||||
msg.ServerMsgID = GetMsgID(msg.SendID)
|
msg.ServerMsgID = GetMsgID(msg.SendID)
|
||||||
|
@ -2,6 +2,7 @@ package log
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"Open_IM/pkg/common/config"
|
"Open_IM/pkg/common/config"
|
||||||
|
"bufio"
|
||||||
"fmt"
|
"fmt"
|
||||||
"os"
|
"os"
|
||||||
"time"
|
"time"
|
||||||
@ -32,13 +33,13 @@ func loggerInit(moduleName string) *Logger {
|
|||||||
//All logs will be printed
|
//All logs will be printed
|
||||||
logger.SetLevel(logrus.Level(config.Config.Log.RemainLogLevel))
|
logger.SetLevel(logrus.Level(config.Config.Log.RemainLogLevel))
|
||||||
//Close std console output
|
//Close std console output
|
||||||
//src, err := os.OpenFile(os.DevNull, os.O_APPEND|os.O_WRONLY, os.ModeAppend)
|
src, err := os.OpenFile(os.DevNull, os.O_APPEND|os.O_WRONLY, os.ModeAppend)
|
||||||
//if err != nil {
|
if err != nil {
|
||||||
// panic(err.Error())
|
panic(err.Error())
|
||||||
//}
|
}
|
||||||
//writer := bufio.NewWriter(src)
|
writer := bufio.NewWriter(src)
|
||||||
//logger.SetOutput(writer)
|
logger.SetOutput(writer)
|
||||||
logger.SetOutput(os.Stdout)
|
//logger.SetOutput(os.Stdout)
|
||||||
//Log Console Print Style Setting
|
//Log Console Print Style Setting
|
||||||
logger.SetFormatter(&nested.Formatter{
|
logger.SetFormatter(&nested.Formatter{
|
||||||
TimestampFormat: "2006-01-02 15:04:05.000",
|
TimestampFormat: "2006-01-02 15:04:05.000",
|
||||||
|
Loading…
x
Reference in New Issue
Block a user