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

batch push

Browse Source
This commit is contained in:
withchao 2024-07-22 17:39:50 +08:00
parent 276c0ab188
commit 48db156ff7
1 changed files with 2 additions and 51 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

53
internal/msggateway/hub_server.go
View File

@ -182,7 +182,8 @@ func (s *Server) SuperGroupOnlineBatchPushOneMsg(ctx context.Context, req *msgga
ch := make(chan *msggateway.SingleMsgToUserResults, len(req.PushToUserIDs)) ch := make(chan *msggateway.SingleMsgToUserResults, len(req.PushToUserIDs))
var count atomic.Int64 var count atomic.Int64
count.Add(int64(len(req.PushToUserIDs))) count.Add(int64(len(req.PushToUserIDs)))
for _, userID := range req.PushToUserIDs { for i := range req.PushToUserIDs {
userID := req.PushToUserIDs[i]
err := s.queue.PushCtx(ctx, func() { err := s.queue.PushCtx(ctx, func() {
ch <- s.pushToUser(ctx, userID, req.MsgData) ch <- s.pushToUser(ctx, userID, req.MsgData)
if count.Add(-1) == 0 { if count.Add(-1) == 0 {
@ -225,56 +226,6 @@ func (s *Server) SuperGroupOnlineBatchPushOneMsg(ctx context.Context, req *msgga
} }
} }
//func (s *Server) SuperGroupOnlineBatchPushOneMsg(ctx context.Context, req *msggateway.OnlineBatchPushOneMsgReq) (*msggateway.OnlineBatchPushOneMsgResp, error) {
// var singleUserResults []*msggateway.SingleMsgToUserResults
// for _, userID := range req.PushToUserIDs {
// var resp []*msggateway.SingleMsgToUserPlatform
// results := &msggateway.SingleMsgToUserResults{
// UserID: userID,
// }
// clients, ok := s.LongConnServer.GetUserAllCons(userID)
// if !ok {
// log.ZDebug(ctx, "push user not online", "userID", userID)
// results.Resp = resp
// singleUserResults = append(singleUserResults, results)
// continue
// }
//
// log.ZDebug(ctx, "push user online", "clients", clients, "userID", userID)
// for _, client := range clients {
// if client == nil {
// continue
// }
//
// userPlatform := &msggateway.SingleMsgToUserPlatform{
// RecvPlatFormID: int32(client.PlatformID),
// }
// if !client.IsBackground ||
// (client.IsBackground && client.PlatformID != constant.IOSPlatformID) {
// err := client.PushMessage(ctx, req.MsgData)
// if err != nil {
// userPlatform.ResultCode = int64(servererrs.ErrPushMsgErr.Code())
// resp = append(resp, userPlatform)
// } else {
// if _, ok := s.pushTerminal[client.PlatformID]; ok {
// results.OnlinePush = true
// resp = append(resp, userPlatform)
// }
// }
// } else {
// userPlatform.ResultCode = int64(servererrs.ErrIOSBackgroundPushErr.Code())
// resp = append(resp, userPlatform)
// }
// }
// results.Resp = resp
// singleUserResults = append(singleUserResults, results)
// }
//
// return &msggateway.OnlineBatchPushOneMsgResp{
// SinglePushResult: singleUserResults,
// }, nil
//}
func (s *Server) KickUserOffline( func (s *Server) KickUserOffline(
ctx context.Context, ctx context.Context,
req *msggateway.KickUserOfflineReq, req *msggateway.KickUserOfflineReq,