yudao
/
spring-cloud
mirror of https://gitee.com/zhijiantianya/yudao-cloud.git
3
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

feat(im): 统一 WebSocket 推送依赖 

- 移除 IM 对 websocket starter 的直接依赖
- 改为通过 infra WebSocketSenderApi 发送推送消息
- 同步调整已有 WebSocket 推送单测
master-jdk17
YunaiV 2026-06-01 00:38:26 +08:00
parent 2ba231aa55
commit 9431722bae
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
yudao-module-im/yudao-module-im-server/src/test/java/cn/iocoder/yudao/module/im/service/websocket/ImWebSocketServiceImplTest.java
View File

@ -1,5 +1,6 @@
package cn.iocoder.yudao.module.im.service.websocket; package cn.iocoder.yudao.module.im.service.websocket;
import cn.hutool.core.collection.ListUtil;
import cn.hutool.extra.spring.SpringUtil; import cn.hutool.extra.spring.SpringUtil;
import cn.iocoder.yudao.framework.common.enums.UserTypeEnum; import cn.iocoder.yudao.framework.common.enums.UserTypeEnum;
import cn.iocoder.yudao.framework.test.core.ut.BaseMockitoUnitTest; import cn.iocoder.yudao.framework.test.core.ut.BaseMockitoUnitTest;
@ -107,7 +108,7 @@ public class ImWebSocketServiceImplTest extends BaseMockitoUnitTest {
dto.setGroupId(10L); dto.setGroupId(10L);
dto.setSenderId(1L); dto.setSenderId(1L);
imWebSocketService.sendGroupMessageAsync(List.of(1L, 2L, 3L), dto); imWebSocketService.sendGroupMessageAsync(ListUtil.of(1L, 2L, 3L), dto);
verify(webSocketSenderApi).sendObject( verify(webSocketSenderApi).sendObject(
eq(UserTypeEnum.ADMIN.getValue()), eq(1L), eq(ImGroupMessageDTO.TYPE), eq(dto)); eq(UserTypeEnum.ADMIN.getValue()), eq(1L), eq(ImGroupMessageDTO.TYPE), eq(dto));
@ -130,7 +131,7 @@ public class ImWebSocketServiceImplTest extends BaseMockitoUnitTest {
doThrow(new RuntimeException("user offline")) doThrow(new RuntimeException("user offline"))
.when(webSocketSenderApi).sendObject(anyInt(), eq(1L), anyString(), any()); .when(webSocketSenderApi).sendObject(anyInt(), eq(1L), anyString(), any());
imWebSocketService.sendGroupMessageAsync(List.of(1L, 2L, 3L), dto); imWebSocketService.sendGroupMessageAsync(ListUtil.of(1L, 2L, 3L), dto);
// 2L 和 3L 也都被推送 // 2L 和 3L 也都被推送
verify(webSocketSenderApi).sendObject(anyInt(), eq(2L), anyString(), any()); verify(webSocketSenderApi).sendObject(anyInt(), eq(2L), anyString(), any());