Skip to content

Commit e9fdf79

Browse files
authored
Refactor/101 room detail (#106)
* feat: cors 설정 * 웹소켓 * 웹소켓 * 웹소켓
1 parent 12ad4ba commit e9fdf79

File tree

1 file changed

+13
-7
lines changed

1 file changed

+13
-7
lines changed

src/main/java/com/oronaminc/join/websocket/api/QuestionWebsocketController.java

Lines changed: 13 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,13 @@
11
package com.oronaminc.join.websocket.api;
22

3+
import java.security.Principal;
4+
5+
import org.springframework.messaging.handler.annotation.DestinationVariable;
6+
import org.springframework.messaging.handler.annotation.MessageMapping;
7+
import org.springframework.messaging.handler.annotation.Payload;
8+
import org.springframework.messaging.handler.annotation.SendTo;
9+
import org.springframework.stereotype.Controller;
10+
311
import com.oronaminc.join.global.exception.ErrorCode;
412
import com.oronaminc.join.global.exception.ErrorException;
513
import com.oronaminc.join.global.ratelimit.RateLimitService;
@@ -11,16 +19,11 @@
1119
import com.oronaminc.join.question.dto.QuestionUpdateResponse;
1220
import com.oronaminc.join.question.service.QuestionService;
1321
import com.oronaminc.join.question.util.QuestionMapper;
22+
1423
import io.github.bucket4j.Bucket;
1524
import jakarta.validation.Valid;
16-
import java.security.Principal;
1725
import lombok.RequiredArgsConstructor;
1826
import lombok.extern.slf4j.Slf4j;
19-
import org.springframework.messaging.handler.annotation.DestinationVariable;
20-
import org.springframework.messaging.handler.annotation.MessageMapping;
21-
import org.springframework.messaging.handler.annotation.Payload;
22-
import org.springframework.messaging.handler.annotation.SendTo;
23-
import org.springframework.stereotype.Controller;
2427

2528
@Slf4j
2629
@Controller
@@ -37,8 +40,12 @@ public QuestionCreateResponse createQuestion(
3740
@Payload @Valid QuestionRequest request,
3841
Principal principal
3942
) {
43+
log.debug("수신한 메시지 = {}", request.content());
44+
4045
Long memberId = Long.valueOf(principal.getName());
4146

47+
log.debug("회원 아이디 = {}", memberId);
48+
4249
Bucket bucket = rateLimitService.getBucket(RateLimitType.CREATE_QUESTION, roomId, memberId);
4350

4451
if (!bucket.tryConsume(1)) {
@@ -47,7 +54,6 @@ public QuestionCreateResponse createQuestion(
4754

4855
Question question = questionService.create(roomId, memberId, request);
4956

50-
log.info("수신한 메시지 = {}", request.content());
5157

5258
return QuestionMapper.toQuestionCreateResponse(question);
5359
}

0 commit comments

Comments
 (0)