fix(im): 强化好友关系、消息历史和前端交互

- 校验群资料字段长度，并在同意好友申请时复验双方用户 - 仅向双向有效好友推送资料更新通知 - WebSocket 推送收件人去重，并忽略空用户编号 - 群聊和私聊历史保留撤回消息记录 - 校验群通话排除发起人后仍需存在被邀请人 - 统一 IM 前端接口参数传递方式 - 抽取全局 URL 安全打开工具，并复用到消息预览 - 防止好友申请同意和拒绝按钮重复操作 - 补充好友、消息、RTC、WebSocket 相关测试

fix(im): 强化好友关系、消息历史和前端交互
- 校验群资料字段长度，并在同意好友申请时复验双方用户 - 仅向双向有效好友推送资料更新通知 - WebSocket 推送收件人去重，并忽略空用户编号 - 群聊和私聊历史保留撤回消息记录 - 校验群通话排除发起人后仍需存在被邀请人 - 统一 IM 前端接口参数传递方式 - 抽取全局 URL 安全打开工具，并复用到消息预览 - 防止好友申请同意和拒绝按钮重复操作 - 补充好友、消息、RTC、WebSocket 相关测试
YunaiV
1 parent f5ef0a89
Showing 17 changed files with 160 additions and 17 deletions
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/controller/admin/group/vo/ImGroupCreateReqVO.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/controller/admin/group/vo/ImGroupUpdateReqVO.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/dal/mysql/friend/ImFriendMapper.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/dal/mysql/message/ImGroupMessageMapper.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/dal/mysql/message/ImPrivateMessageMapper.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/mq/consumer/friend/AdminUserProfileUpdateConsumer.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/service/friend/ImFriendRequestServiceImpl.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/service/friend/ImFriendService.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/service/friend/ImFriendServiceImpl.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/service/rtc/ImRtcCallServiceImpl.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/service/websocket/ImWebSocketServiceImpl.java
yudao-module-im/src/test/java/cn/iocoder/yudao/module/im/dal/mysql/message/ImGroupMessageMapperTest.java
yudao-module-im/src/test/java/cn/iocoder/yudao/module/im/dal/mysql/message/ImPrivateMessageMapperTest.java
yudao-module-im/src/test/java/cn/iocoder/yudao/module/im/service/friend/ImFriendRequestServiceImplTest.java
yudao-module-im/src/test/java/cn/iocoder/yudao/module/im/service/friend/ImFriendServiceImplTest.java
yudao-module-im/src/test/java/cn/iocoder/yudao/module/im/service/rtc/ImRtcCallServiceImplTest.java
yudao-module-im/src/test/java/cn/iocoder/yudao/module/im/service/websocket/ImWebSocketServiceImplTest.java
@@ -2,6 +2,7 @@ package cn.iocoder.yudao.module.im.controller.admin.group.vo;
  
 import io.swagger.v3.oas.annotations.media.Schema;
 import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.Size;
 import lombok.Data;
  
 import java.util.List;
@@ -12,6 +13,7 @@ public class ImGroupCreateReqVO {
  
     @Schema(description = "群名称", requiredMode = Schema.RequiredMode.REQUIRED, example = "芋道技术交流群")
     @NotBlank(message = "群名称不能为空")
+    @Size(max = 64, message = "群名称长度不能超过 64")
     private String name;
  
     @Schema(description = "初始成员用户编号列表（建群同时邀请的好友，不含创建者自己）", example = "[1024, 2048]")
 package cn.iocoder.yudao.module.im.controller.admin.group.vo;
  
+import cn.hutool.core.util.StrUtil;
+import com.fasterxml.jackson.annotation.JsonIgnore;
 import io.swagger.v3.oas.annotations.media.Schema;
+import jakarta.validation.constraints.AssertTrue;
 import jakarta.validation.constraints.NotNull;
+import jakarta.validation.constraints.Size;
 import lombok.Data;
  
 @Schema(description = "管理后台 - 群更新 Request VO")
@@ -13,15 +17,30 @@ public class ImGroupUpdateReqVO {
     private Long id;
  
     @Schema(description = "群名称", example = "芋道技术交流群")
+    @Size(max = 64, message = "群名称长度不能超过 64")
     private String name;
  
     @Schema(description = "群头像")
+    @Size(max = 512, message = "群头像长度不能超过 512")
     private String avatar;
  
     @Schema(description = "群公告")
+    @Size(max = 2048, message = "群公告长度不能超过 2048")
     private String notice;
  
     @Schema(description = "进群是否需群主 / 管理员审批", example = "true")
     private Boolean joinApproval;
  
+    @AssertTrue(message = "群名称不能为空")
+    @JsonIgnore
+    public boolean isNameValid() {
+        return name == null || StrUtil.isNotBlank(name);
+    }
+
+    @AssertTrue(message = "群头像不能为空")
+    @JsonIgnore
+    public boolean isAvatarValid() {
+        return avatar == null || StrUtil.isNotBlank(avatar);
+    }
+
 }
@@ -47,6 +47,15 @@ public interface ImFriendMapper extends BaseMapperX&lt;ImFriendDO&gt; {
                 .eq(ImFriendDO::getStatus, status));
     }
  
+    default List<ImFriendDO> selectListByUserIdsAndFriendUserIdAndStatus(Collection<Long> userIds,
+                                                                        Long friendUserId,
+                                                                        Integer status) {
+        return selectList(new LambdaQueryWrapperX<ImFriendDO>()
+                .in(ImFriendDO::getUserId, userIds)
+                .eq(ImFriendDO::getFriendUserId, friendUserId)
+                .eq(ImFriendDO::getStatus, status));
+    }
+
     default PageResult<ImFriendDO> selectPage(ImFriendManagerPageReqVO reqVO) {
         return selectPage(reqVO, new LambdaQueryWrapperX<ImFriendDO>()
                 .eqIfPresent(ImFriendDO::getUserId, reqVO.getUserId())
@@ -81,7 +81,6 @@ public interface ImGroupMessageMapper extends BaseMapperX&lt;ImGroupMessageDO&gt; {
     default List<ImGroupMessageDO> selectHistoryList(Long groupId, Long maxId, Integer limit, LocalDateTime joinTime) {
         QueryWrapperX<ImGroupMessageDO> wrapper = new QueryWrapperX<>();
         wrapper.eq("group_id", groupId)
-                .ne("status", ImMessageStatusEnum.RECALL.getStatus())
                 .lt(maxId != null, "id", maxId)
                 .ge(joinTime != null, "send_time", joinTime)
                 .orderByDesc("id");
@@ -6,7 +6,6 @@ import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
 import cn.iocoder.yudao.framework.mybatis.core.query.QueryWrapperX;
 import cn.iocoder.yudao.module.im.controller.admin.manager.message.vo.privates.ImPrivateMessageManagerPageReqVO;
 import cn.iocoder.yudao.module.im.dal.dataobject.message.ImPrivateMessageDO;
-import cn.iocoder.yudao.module.im.enums.message.ImMessageStatusEnum;
 import org.apache.ibatis.annotations.Mapper;
  
 import java.time.LocalDateTime;
@@ -56,7 +55,6 @@ public interface ImPrivateMessageMapper extends BaseMapperX&lt;ImPrivateMessageDO&gt; 
         wrapper.and(w -> w.eq("sender_id", userId).eq("receiver_id", receiverId)
                         .or()
                         .eq("sender_id", receiverId).eq("receiver_id", userId))
-                .ne("status", ImMessageStatusEnum.RECALL.getStatus())
                 .lt(maxId != null, "id", maxId)
                 .orderByDesc("id");
         wrapper.limitN(limit);
@@ -35,8 +35,8 @@ public class AdminUserProfileUpdateConsumer {
     public void onMessage(AdminUserProfileUpdateMessage message) {
         log.info("[onMessage][消息内容({})]", message);
         Long userId = message.getUserId();
-        // 1. SQL 层过滤 ENABLE 好友
-        List<ImFriendDO> friends = friendService.getEnableFriendList(userId);
+        // 1. 过滤双向有效好友
+        List<ImFriendDO> friends = friendService.getMutualEnableFriendList(userId);
         if (friends.isEmpty()) {
             return;
         }
@@ -143,10 +143,12 @@ public class ImFriendRequestServiceImpl implements ImFriendRequestService {
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void agreeFriendRequest(Long userId, Long requestId) {
-        // 1. 校验申请存在 + 未处理 + 操作人是接收方（fail-fast；并发场景仍由下面的乐观锁兜底）
+        // 1.1 校验申请存在、未处理、操作人是接收方
         ImFriendRequestDO request = validateRequestForHandle(userId, requestId);
+        // 1.2 复验双方用户有效
+        adminUserApi.validateUserList(List.of(request.getFromUserId(), request.getToUserId()));
  
-        // 2. 乐观锁更新申请：handleResult=AGREED + handleTime；并发同意会有一方 affectedRows=0
+        // 2. 乐观锁更新申请处理结果
         ImFriendRequestDO updateObj = new ImFriendRequestDO()
                 .setHandleResult(ImFriendRequestHandleResultEnum.AGREED.getResult()).setHandleTime(LocalDateTime.now());
         int affected = friendRequestMapper.updateByIdAndHandleResult(request.getId(),
@@ -48,6 +48,11 @@ public interface ImFriendService {
     List<ImFriendDO> getEnableFriendList(Long userId);
  
     /**
+     * 获得当前用户的双向有效好友列表（双方均 ENABLE 状态）
+     */
+    List<ImFriendDO> getMutualEnableFriendList(Long userId);
+
+    /**
      * 获得当前用户与指定用户之间的有效好友列表（仅 ENABLE 状态）
      */
     List<ImFriendDO> getActiveFriendList(Long userId, Collection<Long> friendUserIds);
@@ -31,8 +31,11 @@ import java.time.LocalDateTime;
 import java.util.Collection;
 import java.util.Collections;
 import java.util.List;
+import java.util.Set;
  
 import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
+import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertSet;
+import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.filterList;
 import static cn.iocoder.yudao.module.im.dal.redis.RedisKeyConstants.FRIEND_STATE;
 import static cn.iocoder.yudao.module.im.enums.ErrorCodeConstants.FRIEND_BLOCKED_BY_PEER;
 import static cn.iocoder.yudao.module.im.enums.ErrorCodeConstants.FRIEND_NOT_BLOCKED;
@@ -101,6 +104,24 @@ public class ImFriendServiceImpl implements ImFriendService {
     }
  
     @Override
+    public List<ImFriendDO> getMutualEnableFriendList(Long userId) {
+        // 1. 查询本端启用好友
+        List<ImFriendDO> friends = getEnableFriendList(userId);
+        if (CollUtil.isEmpty(friends)) {
+            return Collections.emptyList();
+        }
+
+        // 2. 查询对端启用好友关系
+        Set<Long> friendUserIds = convertSet(friends, ImFriendDO::getFriendUserId);
+        List<ImFriendDO> mutualFriends = friendMapper.selectListByUserIdsAndFriendUserIdAndStatus(friendUserIds, userId,
+                CommonStatusEnum.ENABLE.getStatus());
+        Set<Long> mutualUserIds = convertSet(mutualFriends, ImFriendDO::getUserId);
+
+        // 3. 过滤双向启用好友
+        return filterList(friends, friend -> mutualUserIds.contains(friend.getFriendUserId()));
+    }
+
+    @Override
     public List<ImFriendDO> getActiveFriendList(Long userId, Collection<Long> friendUserIds) {
         if (CollUtil.isEmpty(friendUserIds)) {
             return Collections.emptyList();
@@ -812,6 +812,9 @@ public class ImRtcCallServiceImpl implements ImRtcCallService {
         Set<Long> initial = new LinkedHashSet<>(reqVO.getInviteeIds());
         // 发起人本人不进被邀请池
         initial.remove(inviterId);
+        if (CollUtil.isEmpty(initial)) {
+            throw exception(RTC_GROUP_INVITEE_REQUIRED);
+        }
         int max = imProperties.getRtc().getGroupMaxParticipants();
         if (initial.size() + 1 > max) {
             throw exception(RTC_GROUP_INVITEE_OVER_LIMIT);
@@ -15,6 +15,9 @@ import org.springframework.transaction.support.TransactionSynchronizationManager
 import org.springframework.validation.annotation.Validated;
  
 import java.util.Collection;
+import java.util.Set;
+
+import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertLinkedSet;
  
 /**
  * IM WebSocket 推送 Service 实现类
@@ -59,7 +62,7 @@ public class ImWebSocketServiceImpl implements ImWebSocketService {
      */
     @Async
     public void doSendPrivateMessage(Collection<Long> userIds, ImPrivateMessageDTO dto) {
-        for (Long userId : userIds) {
+        for (Long userId : getDistinctUserIds(userIds)) {
             try {
                 webSocketMessageSender.sendObject(UserTypeEnum.ADMIN.getValue(), userId,
                         ImPrivateMessageDTO.TYPE, dto);
@@ -74,7 +77,7 @@ public class ImWebSocketServiceImpl implements ImWebSocketService {
      */
     @Async
     public void doSendGroupMessage(Collection<Long> userIds, ImGroupMessageDTO dto) {
-        for (Long userId : userIds) {
+        for (Long userId : getDistinctUserIds(userIds)) {
             try {
                 webSocketMessageSender.sendObject(UserTypeEnum.ADMIN.getValue(), userId,
                         ImGroupMessageDTO.TYPE, dto);
@@ -89,7 +92,7 @@ public class ImWebSocketServiceImpl implements ImWebSocketService {
      */
     @Async
     public void doSendChannelMessage(Collection<Long> userIds, ImChannelMessageDTO dto) {
-        for (Long userId : userIds) {
+        for (Long userId : getDistinctUserIds(userIds)) {
             try {
                 webSocketMessageSender.sendObject(UserTypeEnum.ADMIN.getValue(), userId,
                         ImChannelMessageDTO.TYPE, dto);
@@ -113,6 +116,10 @@ public class ImWebSocketServiceImpl implements ImWebSocketService {
         }
     }
  
+    private static Set<Long> getDistinctUserIds(Collection<Long> userIds) {
+        return convertLinkedSet(userIds, userId -> userId);
+    }
+
     /**
      * 事务感知的任务调度：
      * - 有事务：注册 afterCommit 回调，事务提交后再执行，防止客户端拿到消息去查库时数据还没落盘
@@ -165,7 +165,7 @@ public class ImGroupMessageMapperTest extends BaseDbUnitTest {
     }
  
     @Test
-    public void testSelectHistoryList_excludeRecall() {
+    public void testSelectHistoryList_includeRecall() {
         ImGroupMessageDO normal = buildMessage(10L, 1L, ImMessageStatusEnum.UNREAD);
         mapper.insert(normal);
         ImGroupMessageDO recalled = buildMessage(10L, 1L, ImMessageStatusEnum.RECALL);
@@ -173,8 +173,9 @@ public class ImGroupMessageMapperTest extends BaseDbUnitTest {
  
         List<ImGroupMessageDO> result = mapper.selectHistoryList(10L, null, 100, null);
  
-        assertEquals(1, result.size());
-        assertEquals(normal.getId(), result.get(0).getId());
+        assertEquals(2, result.size());
+        assertEquals(recalled.getId(), result.get(0).getId());
+        assertEquals(normal.getId(), result.get(1).getId());
     }
  
     @Test
@@ -120,7 +120,7 @@ public class ImPrivateMessageMapperTest extends BaseDbUnitTest {
     }
  
     @Test
-    public void testSelectHistoryList_excludeRecall() {
+    public void testSelectHistoryList_includeRecall() {
         // 准备
         ImPrivateMessageDO msg1 = buildMessage(1L, 2L, ImMessageStatusEnum.UNREAD);
         mapper.insert(msg1);
@@ -130,9 +130,10 @@ public class ImPrivateMessageMapperTest extends BaseDbUnitTest {
         // 调用
         List<ImPrivateMessageDO> result = mapper.selectHistoryList(1L, 2L, null, 100);
  
-        // 断言：撤回的不返回
-        assertEquals(1, result.size());
-        assertEquals(msg1.getId(), result.get(0).getId());
+        // 断言：撤回消息一并返回
+        assertEquals(2, result.size());
+        assertEquals(msg2.getId(), result.get(0).getId());
+        assertEquals(msg1.getId(), result.get(1).getId());
     }
  
     @Test
@@ -19,6 +19,8 @@ import org.mockito.ArgumentCaptor;
 import org.mockito.InjectMocks;
 import org.mockito.Mock;
  
+import java.util.List;
+
 import static cn.iocoder.yudao.module.im.enums.ErrorCodeConstants.*;
 import static org.junit.jupiter.api.Assertions.*;
 import static org.mockito.ArgumentMatchers.any;
@@ -198,6 +200,7 @@ public class ImFriendRequestServiceImplTest extends BaseMockitoUnitTest {
         friendRequestService.agreeFriendRequest(2L, 100L);
  
         // 断言：双向建立好友 + 推 APPROVED 给发起方
+        verify(adminUserApi).validateUserList(List.of(1L, 2L));
         verify(friendService).becomeFriends(request);
         verify(websocketService).sendPrivateMessageAsync(eq(1L), any(ImPrivateMessageDTO.class));
     }
@@ -222,4 +222,23 @@ public class ImFriendServiceImplTest extends BaseMockitoUnitTest {
         verify(imFriendMapper, never()).selectListByUserIdAndFriendUserIdsAndStatus(anyLong(), anyCollection(), anyInt());
     }
  
+    @Test
+    public void testGetMutualEnableFriendList_filterSingleSideDeleted() {
+        ImFriendDO friend2 = ImFriendDO.builder().id(1L).userId(1L).friendUserId(2L)
+                .status(CommonStatusEnum.ENABLE.getStatus()).build();
+        ImFriendDO friend3 = ImFriendDO.builder().id(2L).userId(1L).friendUserId(3L)
+                .status(CommonStatusEnum.ENABLE.getStatus()).build();
+        when(imFriendMapper.selectListByUserIdAndStatus(1L, CommonStatusEnum.ENABLE.getStatus()))
+                .thenReturn(List.of(friend2, friend3));
+        when(imFriendMapper.selectListByUserIdsAndFriendUserIdAndStatus(anyCollection(), eq(1L),
+                eq(CommonStatusEnum.ENABLE.getStatus()))).thenReturn(List.of(
+                        ImFriendDO.builder().userId(2L).friendUserId(1L)
+                                .status(CommonStatusEnum.ENABLE.getStatus()).build()));
+
+        List<ImFriendDO> result = friendService.getMutualEnableFriendList(1L);
+
+        assertEquals(1, result.size());
+        assertEquals(2L, result.get(0).getFriendUserId());
+    }
+
 }
@@ -2,11 +2,13 @@ package cn.iocoder.yudao.module.im.service.rtc;
  
 import cn.iocoder.yudao.framework.common.exception.ServiceException;
 import cn.iocoder.yudao.framework.test.core.ut.BaseMockitoUnitTest;
+import cn.iocoder.yudao.module.im.controller.admin.rtc.vo.ImRtcCallCreateReqVO;
 import cn.iocoder.yudao.module.im.dal.dataobject.group.ImGroupMemberDO;
 import cn.iocoder.yudao.module.im.dal.dataobject.rtc.ImRtcCallDO;
 import cn.iocoder.yudao.module.im.dal.dataobject.rtc.ImRtcParticipantDO;
 import cn.iocoder.yudao.module.im.dal.mysql.rtc.ImRtcCallMapper;
 import cn.iocoder.yudao.module.im.dal.mysql.rtc.ImRtcParticipantMapper;
+import cn.iocoder.yudao.module.im.dal.redis.rtc.ImRtcCallLockRedisDAO;
 import cn.iocoder.yudao.module.im.enums.ImConversationTypeEnum;
 import cn.iocoder.yudao.module.im.enums.rtc.ImRtcCallStatusEnum;
 import cn.iocoder.yudao.module.im.enums.rtc.ImRtcParticipantRoleEnum;
@@ -27,7 +29,10 @@ import java.time.LocalDateTime;
 import java.util.Collections;
 import java.util.List;
 import java.util.Map;
+import java.util.Set;
+import java.util.concurrent.Callable;
  
+import static cn.iocoder.yudao.module.im.enums.ErrorCodeConstants.RTC_GROUP_INVITEE_REQUIRED;
 import static cn.iocoder.yudao.module.im.enums.ErrorCodeConstants.RTC_SELF_BUSY;
 import static org.junit.jupiter.api.Assertions.*;
 import static org.mockito.ArgumentMatchers.*;
@@ -43,6 +48,8 @@ public class ImRtcCallServiceImplTest extends BaseMockitoUnitTest {
     @Mock
     private ImRtcCallMapper rtcCallMapper;
     @Mock
+    private ImRtcCallLockRedisDAO rtcCallLockRedisDAO;
+    @Mock
     private AdminUserApi adminUserApi;
     @Mock
     private ImWebSocketService webSocketService;
@@ -228,6 +235,28 @@ public class ImRtcCallServiceImplTest extends BaseMockitoUnitTest {
         verify(rtcCallMapper, never()).updateByIdAndStatusIn(any(), anyCollection(), any());
     }
  
+    // ========== createCall ==========
+
+    @Test
+    public void testCreateCall_groupOnlyInviteSelf_throwInviteeRequired() throws Exception {
+        when(imProperties.getRtc()).thenReturn(new ImProperties.Rtc());
+        when(rtcCallLockRedisDAO.lockGroup(eq(10L), any())).thenAnswer(invocation -> {
+            @SuppressWarnings("unchecked")
+            Callable<ImRtcCallDO> callable = invocation.getArgument(1);
+            return callable.call();
+        });
+        ImRtcCallCreateReqVO reqVO = new ImRtcCallCreateReqVO();
+        reqVO.setConversationType(ImConversationTypeEnum.GROUP.getType());
+        reqVO.setGroupId(10L);
+        reqVO.setInviteeIds(Set.of(100L));
+
+        ServiceException exception = assertThrows(ServiceException.class,
+                () -> rtcCallService.createCall(100L, reqVO));
+
+        assertEquals(RTC_GROUP_INVITEE_REQUIRED.getCode(), exception.getCode());
+        verify(rtcParticipantMapper, never()).insertBatch(anyList());
+    }
+
     // ========== acceptCall / joinCall 忙线校验 ==========
  
     @Test
@@ -14,6 +14,8 @@ import org.mockito.MockedStatic;
 import org.springframework.transaction.support.TransactionSynchronization;
 import org.springframework.transaction.support.TransactionSynchronizationManager;
  
+import java.util.Arrays;
+import java.util.Collections;
 import java.util.List;
  
 import static org.junit.jupiter.api.Assertions.assertEquals;
@@ -137,6 +139,29 @@ public class ImWebSocketServiceImplTest extends BaseMockitoUnitTest {
     }
  
     @Test
+    public void testDoSendGroupMessage_emptyUserIds_noSend() {
+        ImGroupMessageDTO dto = new ImGroupMessageDTO().setGroupId(10L);
+
+        imWebSocketService.doSendGroupMessage(Collections.emptyList(), dto);
+        imWebSocketService.doSendGroupMessage(null, dto);
+
+        verifyNoInteractions(webSocketMessageSender);
+    }
+
+    @Test
+    public void testDoSendGroupMessage_distinctUserIds() {
+        ImGroupMessageDTO dto = new ImGroupMessageDTO().setGroupId(10L);
+
+        imWebSocketService.doSendGroupMessage(Arrays.asList(1L, 2L, 1L, null), dto);
+
+        verify(webSocketMessageSender).sendObject(
+                eq(UserTypeEnum.ADMIN.getValue()), eq(1L), eq(ImGroupMessageDTO.TYPE), eq(dto));
+        verify(webSocketMessageSender).sendObject(
+                eq(UserTypeEnum.ADMIN.getValue()), eq(2L), eq(ImGroupMessageDTO.TYPE), eq(dto));
+        verifyNoMoreInteractions(webSocketMessageSender);
+    }
+
+    @Test
     public void testSendPrivateMessageAsync_exceptionSwallowed() {
         try (MockedStatic<SpringUtil> springUtilMockedStatic = mockStatic(SpringUtil.class)) {
             springUtilMockedStatic.when(() -> SpringUtil.getBean(eq(ImWebSocketServiceImpl.class)))