test: unonline can push

icey-yu · Aug 2, 2024 · 724530a · 724530a
1 parent 51e170a
commit 724530a
Showing 1 changed file with 12 additions and 11 deletions.
diff --git a/internal/push/push_handler.go b/internal/push/push_handler.go
@@ -187,17 +187,18 @@ func (c *ConsumerHandler) GetConnsAndOnlinePush(ctx context.Context, msg *sdkws.
 		onlineUserIDs  []string
 		offlineUserIDs []string
 	)
-	for _, userID := range pushToUserIDs {
-		online, err := c.onlineCache.GetUserOnline(ctx, userID)
-		if err != nil {
-			return nil, err
-		}
-		if online {
-			onlineUserIDs = append(onlineUserIDs, userID)
-		} else {
-			offlineUserIDs = append(offlineUserIDs, userID)
-		}
-	}
+	onlineUserIDs = pushToUserIDs
+	//for _, userID := range pushToUserIDs {
+	//	online, err := c.onlineCache.GetUserOnline(ctx, userID)
+	//	if err != nil {
+	//		return nil, err
+	//	}
+	//	if online {
+	//		onlineUserIDs = append(onlineUserIDs, userID)
+	//	} else {
+	//		offlineUserIDs = append(offlineUserIDs, userID)
+	//	}
+	//}
 	log.ZDebug(ctx, "GetConnsAndOnlinePush online cache", "sendID", msg.SendID, "recvID", msg.RecvID, "groupID", msg.GroupID, "sessionType", msg.SessionType, "clientMsgID", msg.ClientMsgID, "serverMsgID", msg.ServerMsgID, "offlineUserIDs", offlineUserIDs, "onlineUserIDs", onlineUserIDs)
 	var result []*msggateway.SingleMsgToUserResults
 	if len(onlineUserIDs) > 0 {