Skip to content

Commit 1ed5e2a

Browse files
committed
fix : 오픈채팅방 오류 수정
1 parent 27a7329 commit 1ed5e2a

File tree

5 files changed

+9
-6
lines changed

5 files changed

+9
-6
lines changed

api/src/main/java/com/mbtips/common/configuration/WebSocketConfiguration.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ public class WebSocketConfiguration implements WebSocketConfigurer {
1616

1717
@Override
1818
public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
19-
registry.addHandler(webSocketChatHandler, "/ws/chats")
19+
registry.addHandler(webSocketChatHandler, "/api/ws/chats")
2020
.setAllowedOrigins("*");
2121
}
2222
}

api/src/main/java/com/mbtips/common/handler/WebSocketChatHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ public class WebSocketChatHandler extends TextWebSocketHandler {
3131
private static final String NICKNAME = "nickname";
3232
private static final String OPEN_CHAT_ID = "open_chat_id";
3333

34-
final Map<Long, Set<WebSocketSession>> webSocketSessionMap = new ConcurrentHashMap<>();
34+
public static final Map<Long, Set<WebSocketSession>> webSocketSessionMap = new ConcurrentHashMap<>();
3535

3636
// 연결
3737
@Override

api/src/main/java/com/mbtips/openChat/application/service/OpenChatService.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,13 @@
11
package com.mbtips.openChat.application.service;
22

3+
import com.mbtips.common.handler.WebSocketChatHandler;
34
import com.mbtips.domain.openChat.OpenChat;
45
import com.mbtips.openChat.application.dto.OpenChatDto;
56
import com.mbtips.openChat.interfaces.OpenChatRepository;
67
import lombok.RequiredArgsConstructor;
78
import org.springframework.stereotype.Service;
89

10+
import java.util.HashSet;
911
import java.util.List;
1012

1113
@Service
@@ -21,7 +23,8 @@ public void save(OpenChatDto openChatDto) {
2123
.description(openChatDto.description())
2224
.isDeleted(false)
2325
.build();
24-
openChatRepository.save(openChat);
26+
long openChatId = openChatRepository.save(openChat);
27+
WebSocketChatHandler.webSocketSessionMap.put(openChatId, new HashSet<>());
2528
}
2629

2730
public List<OpenChat> findAll() {

repository/src/main/java/com/mbtips/openChat/interfaces/OpenChatRepository.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66

77
public interface OpenChatRepository {
88

9-
void save(OpenChat openChat);
9+
long save(OpenChat openChat);
1010

1111
List<OpenChat> findActiveOpenChats();
1212
}

repository/src/main/java/com/mbtips/openChat/repository/impl/OpenChatRepositoryImpl.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,8 +16,8 @@ public class OpenChatRepositoryImpl implements OpenChatRepository {
1616
private final OpenChatJpaRepository openChatJpaRepository;
1717

1818
@Override
19-
public void save(OpenChat openChat) {
20-
openChatJpaRepository.save(new OpenChatEntity(openChat));
19+
public long save(OpenChat openChat) {
20+
return openChatJpaRepository.save(new OpenChatEntity(openChat)).getOpenChatId();
2121
}
2222

2323
@Override

0 commit comments

Comments
 (0)