Feat/vote 투표 관련 구현

src/main/java/com/ject/vs/VsServerApplication.java

@@ -3,9 +3,11 @@
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.context.properties.ConfigurationPropertiesScan;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 @SpringBootApplication
 @ConfigurationPropertiesScan
+@EnableScheduling
 public class VsServerApplication {
 
 	public static void main(String[] args) {

src/main/java/com/ject/vs/chat/adapter/web/ChatController.java

@@ -3,7 +3,7 @@
 import com.ject.vs.chat.adapter.web.dto.*;
 import com.ject.vs.chat.port.in.*;
 import com.ject.vs.chat.port.in.dto.*;
-import com.ject.vs.vote.port.in.dto.VoteStatus;
+import com.ject.vs.vote.domain.VoteStatus;
 import jakarta.validation.Valid;
 import lombok.RequiredArgsConstructor;
 import org.springframework.http.HttpStatus;

src/main/java/com/ject/vs/chat/adapter/web/ChatDocs.java

@@ -7,7 +7,7 @@
 import com.ject.vs.chat.adapter.web.dto.MessagePageResponse;
 import com.ject.vs.chat.adapter.web.dto.MessageResponse;
 import com.ject.vs.chat.adapter.web.dto.SendMessageRequest;
-import com.ject.vs.vote.port.in.dto.VoteStatus;
+import com.ject.vs.vote.domain.VoteStatus;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.Parameter;
 import io.swagger.v3.oas.annotations.media.Content;

src/main/java/com/ject/vs/chat/adapter/web/dto/ChatRoomResponse.java

@@ -1,7 +1,7 @@
 package com.ject.vs.chat.adapter.web.dto;
 
 import com.ject.vs.chat.port.in.dto.ChatRoomResult;
-import com.ject.vs.vote.port.in.dto.VoteStatus;
+import com.ject.vs.vote.domain.VoteStatus;
 import io.swagger.v3.oas.annotations.media.Schema;
 
 import java.time.Instant;

src/main/java/com/ject/vs/chat/port/ChatService.java

@@ -11,7 +11,7 @@
 import com.ject.vs.chat.port.in.dto.*;
 import com.ject.vs.vote.port.in.VoteParticipationQueryUseCase;
 import com.ject.vs.vote.port.in.VoteQueryUseCase;
-import com.ject.vs.vote.port.in.dto.VoteStatus;
+import com.ject.vs.vote.domain.VoteStatus;
 import lombok.RequiredArgsConstructor;
 import org.springframework.data.domain.PageRequest;
 import org.springframework.stereotype.Service;

src/main/java/com/ject/vs/chat/port/in/ChatQueryUseCase.java

@@ -4,7 +4,7 @@
 import com.ject.vs.chat.port.in.dto.ChatRoomResult;
 import com.ject.vs.chat.port.in.dto.GaugeResult;
 import com.ject.vs.chat.port.in.dto.MessagePageResult;
-import com.ject.vs.vote.port.in.dto.VoteStatus;
+import com.ject.vs.vote.domain.VoteStatus;
 
 import java.util.List;
 

src/main/java/com/ject/vs/chat/port/in/dto/ChatRoomResult.java

@@ -1,6 +1,6 @@
 package com.ject.vs.chat.port.in.dto;
 
-import com.ject.vs.vote.port.in.dto.VoteStatus;
+import com.ject.vs.vote.domain.VoteStatus;
 
 import java.time.Instant;
 

src/main/java/com/ject/vs/common/exception/BusinessException.java

@@ -0,0 +1,25 @@
+package com.ject.vs.common.exception;
+
+import lombok.Getter;
+
+@Getter
+public class BusinessException extends RuntimeException {
+    private final ErrorCode errorCode;
+
+    public BusinessException(ErrorCode errorCode) {
+        super(errorCode.getMessage());
+        this.errorCode = errorCode;
+    }
+
+    public String getErrorCode() {
+        return this.errorCode.getCode();
+    }
+
+    public String getErrorMessage() {
+        return this.errorCode.getMessage();
+    }
+
+    public Integer getStatusCode() {
+        return this.errorCode.getStatusCode();
+    }
+}

src/main/java/com/ject/vs/common/exception/ErrorCode.java

@@ -0,0 +1,7 @@
+package com.ject.vs.common.exception;
+
+public interface ErrorCode {
+    String getCode();
+    String getMessage();
+    Integer getStatusCode();
+}

src/main/java/com/ject/vs/common/exception/GlobalExceptionHandler.java

@@ -0,0 +1,29 @@
+package com.ject.vs.common.exception;
+
+import org.springframework.http.ResponseEntity;
+import org.springframework.validation.FieldError;
+import org.springframework.web.bind.MethodArgumentNotValidException;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.bind.annotation.RestControllerAdvice;
+
+@RestControllerAdvice
+public class GlobalExceptionHandler {
+
+    @ExceptionHandler(BusinessException.class)
+    public ResponseEntity<ErrorResponse> handleBusiness(BusinessException e) {
+        return ResponseEntity.status(e.getStatusCode())
+                .body(new ErrorResponse(e.getErrorCode(), e.getErrorMessage()));
+    }
+
+    @ExceptionHandler(MethodArgumentNotValidException.class)
+    public ResponseEntity<ErrorResponse> handleValidation(MethodArgumentNotValidException e) {
+        String message = e.getBindingResult().getFieldErrors().stream()
+                .map(FieldError::getDefaultMessage)
+                .findFirst()
+                .orElse("입력값이 올바르지 않습니다");
+        return ResponseEntity.status(400).body(new ErrorResponse("INVALID_INPUT", message));
+    }
+
+    public record ErrorResponse(String code, String message) {
+    }
+}

src/main/java/com/ject/vs/config/AnonymousId.java

@@ -0,0 +1,11 @@
+package com.ject.vs.config;
+
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+@Target(ElementType.PARAMETER)
+@Retention(RetentionPolicy.RUNTIME)
+public @interface AnonymousId {
+}

src/main/java/com/ject/vs/config/AnonymousIdResolver.java

@@ -0,0 +1,61 @@
+package com.ject.vs.config;
+
+import jakarta.servlet.http.Cookie;
+import jakarta.servlet.http.HttpServletRequest;
+import jakarta.servlet.http.HttpServletResponse;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.ResponseCookie;
+import org.springframework.stereotype.Component;
+import org.springframework.web.bind.support.WebDataBinderFactory;
+import org.springframework.web.context.request.NativeWebRequest;
+import org.springframework.web.method.support.HandlerMethodArgumentResolver;
+import org.springframework.web.method.support.ModelAndViewContainer;
+
+import java.time.Duration;
+import java.util.Arrays;
+import java.util.UUID;
+
+@Component
+public class AnonymousIdResolver implements HandlerMethodArgumentResolver {
+
+    private static final String COOKIE_NAME = "anonymous_id";
+    private static final Duration MAX_AGE = Duration.ofDays(365);
+
+    @Override
+    public boolean supportsParameter(org.springframework.core.MethodParameter parameter) {
+        return parameter.hasParameterAnnotation(AnonymousId.class)
+                && parameter.getParameterType().equals(String.class);
+    }
+
+    @Override
+    public String resolveArgument(org.springframework.core.MethodParameter parameter,
+                                  ModelAndViewContainer mavContainer,
+                                  NativeWebRequest webRequest,
+                                  WebDataBinderFactory binderFactory) {
+        HttpServletRequest req = webRequest.getNativeRequest(HttpServletRequest.class);
+        HttpServletResponse res = webRequest.getNativeResponse(HttpServletResponse.class);
+
+        String existing = extractCookie(req, COOKIE_NAME);
+        if (existing != null) return existing;
+
+        String newId = UUID.randomUUID().toString();
+        ResponseCookie cookie = ResponseCookie.from(COOKIE_NAME, newId)
+                .httpOnly(true)
+                .secure(true)
+                .sameSite("None")
+                .maxAge(MAX_AGE)
+                .path("/")
+                .build();
+        res.addHeader(HttpHeaders.SET_COOKIE, cookie.toString());
+        return newId;
+    }
+
+    private String extractCookie(HttpServletRequest req, String name) {
+        if (req == null || req.getCookies() == null) return null;
+        return Arrays.stream(req.getCookies())
+                .filter(c -> name.equals(c.getName()))
+                .map(Cookie::getValue)
+                .findFirst()
+                .orElse(null);
+    }
+}

src/main/java/com/ject/vs/config/AsyncConfig.java

@@ -0,0 +1,35 @@
+package com.ject.vs.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.EnableAsync;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
+
+import java.util.concurrent.Executor;
+
+@Configuration
+@EnableAsync
+public class AsyncConfig {
+
+    @Bean("voteCloseExecutor")
+    public Executor voteCloseExecutor() {
+        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+        executor.setCorePoolSize(2);
+        executor.setMaxPoolSize(4);
+        executor.setQueueCapacity(100);
+        executor.setThreadNamePrefix("vote-close-");
+        executor.initialize();
+        return executor;
+    }
+
+    @Bean("aiInsightExecutor")
+    public Executor aiInsightExecutor() {
+        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+        executor.setCorePoolSize(2);
+        executor.setMaxPoolSize(4);
+        executor.setQueueCapacity(50);
+        executor.setThreadNamePrefix("ai-insight-");
+        executor.initialize();
+        return executor;
+    }
+}

src/main/java/com/ject/vs/config/ClockConfig.java

@@ -0,0 +1,15 @@
+package com.ject.vs.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import java.time.Clock;
+
+@Configuration
+public class ClockConfig {
+
+    @Bean
+    public Clock systemClock() {
+        return Clock.systemUTC();
+    }
+}

src/main/java/com/ject/vs/config/WebConfig.java

@@ -0,0 +1,20 @@
+package com.ject.vs.config;
+
+import lombok.RequiredArgsConstructor;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.web.method.support.HandlerMethodArgumentResolver;
+import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
+
+import java.util.List;
+
+@Configuration
+@RequiredArgsConstructor
+public class WebConfig implements WebMvcConfigurer {
+
+    private final AnonymousIdResolver anonymousIdResolver;
+
+    @Override
+    public void addArgumentResolvers(List<HandlerMethodArgumentResolver> resolvers) {
+        resolvers.add(anonymousIdResolver);
+    }
+}

src/main/java/com/ject/vs/domain/User.java

@@ -6,7 +6,6 @@
 import lombok.Getter;
 
 import java.time.LocalDate;
-import java.time.Year;
 
 @Entity
 @Getter
@@ -15,6 +14,11 @@ public class User {
     @Id @GeneratedValue(strategy = GenerationType.IDENTITY)
     private Long id;
 
+    private String sub;
+
+    private String gender;
+
+    private LocalDate birthDate;
     private String email;
     // 아직 유저에 대한 정보 확정 아님
     private String nickname;

src/main/java/com/ject/vs/vote/adapter/handler/VoteEventHandler.java

@@ -0,0 +1,36 @@
+package com.ject.vs.vote.adapter.handler;
+
+import com.ject.vs.vote.event.VoteEndedEvent;
+import lombok.RequiredArgsConstructor;
+import org.springframework.context.event.EventListener;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Component;
+
+@Component
+@RequiredArgsConstructor
+public class VoteEventHandler {
+
+    /**
+     * VoteCloseScheduler 요기서 해당 이벤트가 발행됨\
+     *
+     * EventListener는 동기로 동작해 그래서 처리량을 위해 async를 사용합니다.
+     *
+     * 다만 다음과 같은 고민할 부분이 존재합니다.
+     *
+     * 1. 비동기로 처리할 때, 유실되면 어떻게 처리할거에요?
+     * 2. 스케줄러에 의해 트리거 되는데, 1분 주기보다 처리 시간이 길어지면 같은 처리가 동시에 진행될 수 있어 보여요 어떻게 처리할거에요?
+     * 3. 멱등하게 어떻게 처리할 수 있을까요?
+     *
+     *
+     * 트랜잭션 아웃박스 패턴을 보면 좋을듯!
+     * 분산락을 사용할 수 있어보임
+     *
+     * 아웃박스를 구현할 떄, 발행 기준으로 저장할래? 아니면 컨슈밍 기준으로 만들래?
+     */
+    @EventListener(classes = VoteEndedEvent.class)
+    @Async("voteCloseExecutor")
+    public void handleVoteEnded(VoteEndedEvent event){
+        // log 추가하면 좋아보임
+        // ai 분석을 시작하면 좋아보임
+    }
+}

src/main/java/com/ject/vs/vote/adapter/web/GuestFreeVoteController.java

@@ -0,0 +1,22 @@
+package com.ject.vs.vote.adapter.web;
+
+import com.ject.vs.config.AnonymousId;
+import com.ject.vs.vote.adapter.web.dto.FreeVotesResponse;
+import com.ject.vs.vote.port.GuestFreeVoteService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping("/api/me")
+@RequiredArgsConstructor
+public class GuestFreeVoteController {
+
+    private final GuestFreeVoteService guestFreeVoteService;
+
+    @GetMapping("/free-votes")
+    public FreeVotesResponse getFreeVotes(@AnonymousId String anonymousId) {
+        return new FreeVotesResponse(guestFreeVoteService.remaining(anonymousId));
+    }
+}