feat: 사용자 인증 Kafka 메시지 반영 기능 구현

docker-compose-local.yml

@@ -0,0 +1,34 @@
+version: "3.8"
+
+services:
+  auth-server:
+    build:
+      context: .
+      dockerfile: Dockerfile
+    image: devnogi-auth-server:local
+    container_name: devnogi-auth-server-local
+    ports:
+      - "${SERVER_PORT:-8091}:${SERVER_PORT:-8091}"
+    env_file:
+      - .env
+    environment:
+      SPRING_PROFILES_ACTIVE: default
+      SERVER_PORT: ${SERVER_PORT:-8091}
+      DB_IP: ${DB_IP:-host.docker.internal}
+      DB_PORT: ${DB_PORT:-3316}
+      DB_SCHEMA: ${DB_SCHEMA:-devnogi}
+      DB_USER: ${DB_USER:-devnogi}
+      DB_PASSWORD: ${DB_PASSWORD:-devnogi0529!}
+      KAFKA_BOOTSTRAP_SERVERS: ${KAFKA_BOOTSTRAP_SERVERS:-119.194.235.11:9102}
+      KAFKA_TOPIC_USER_VERIFICATION_VERIFY: ${KAFKA_TOPIC_USER_VERIFICATION_VERIFY:-USER_VERIFICATION_VERIFY_EVENT}
+      KAFKA_CONSUMER_GROUP_ID: ${KAFKA_CONSUMER_GROUP_ID:-devnogi-auth-user-verification-consumer-local}
+      JAVA_OPTS: -Xms256m -Xmx512m
+    restart: unless-stopped
+    extra_hosts:
+      - "host.docker.internal:host-gateway"
+    healthcheck:
+      test: ["CMD", "wget", "--no-verbose", "--tries=1", "--spider", "http://localhost:${SERVER_PORT:-8091}/actuator/health"]
+      interval: 30s
+      timeout: 10s
+      retries: 3
+      start_period: 90s

src/main/java/until/the/eternity/das/common/config/KafkaListenerConfig.java

@@ -0,0 +1,9 @@
+package until.the.eternity.das.common.config;
+
+import org.springframework.context.annotation.Configuration;
+import org.springframework.kafka.annotation.EnableKafka;
+
+@Configuration
+@EnableKafka
+public class KafkaListenerConfig {
+}

src/main/java/until/the/eternity/das/common/constant/UserUpdateConstant.java

@@ -3,4 +3,5 @@
 public class UserUpdateConstant {
   public static final String INFO = "USER_INFO_UPDATE_EVENT";
   public static final String PASSWORD = "PASSWORD_UPDATE_EVENT";
+  public static final String USER_VERIFICATION_VERIFY = "USER_VERIFICATION_VERIFY_EVENT";
 }

src/main/java/until/the/eternity/das/common/exception/GlobalExceptionCode.java

@@ -39,6 +39,11 @@ public enum GlobalExceptionCode implements ExceptionCode {
 
   // User
   USER_INFO_UPDATE_FAILED(INTERNAL_SERVER_ERROR, "사용자 정보 수정에 실패했습니다. 잠시 후 다시 시도해주세요."),
+  USER_VERIFICATION_GENERATE_FAILED(INTERNAL_SERVER_ERROR, "인증 코드 생성에 실패했습니다. 잠시 후 다시 시도해주세요."),
+  USER_VERIFICATION_TOKEN_NOT_FOUND(HttpStatus.BAD_REQUEST, "발급된 인증 토큰이 존재하지 않습니다."),
+  USER_VERIFICATION_TOKEN_ALREADY_EXISTS(HttpStatus.BAD_REQUEST, "이미 유효한 인증 토큰이 존재합니다. 재발급을 이용해주세요."),
+  USER_VERIFICATION_COOLDOWN_ACTIVE(HttpStatus.BAD_REQUEST, "최근 7일 이내 인증 성공 이력이 있어 토큰 발급이 불가능합니다."),
+  USER_VERIFICATION_INVALID(HttpStatus.BAD_REQUEST, "유효하지 않거나 만료된 인증 코드입니다."),
 
   // OAUTH
   NOT_SUPPORTED_PROVIDER(HttpStatus.BAD_REQUEST, "지원하지 않는 소셜로그인입니다");

src/main/java/until/the/eternity/das/user/entity/User.java

@@ -68,6 +68,18 @@ public class User {
   @Enumerated(EnumType.STRING)
   private InactivatedType inactivatedType;
 
+  @Column(name = "server_name", length = 20)
+  @Comment("게임 서버명")
+  private String serverName;
+
+  @Column(name = "is_verified", nullable = false)
+  @Comment("사용자 인증 상태")
+  private boolean verified;
+
+  @Column(name = "verified_at")
+  @Comment("최근 인증 성공 시각")
+  private LocalDateTime verifiedAt;
+
   @ManyToOne(fetch = FetchType.LAZY)
   @JoinColumn(name = "role_id")
   private Role role;
@@ -90,4 +102,18 @@ public void updateUserStatus(Status status) {
     this.inactivatedAt = LocalDateTime.now();
   }
 
-}
+  public void updateServerName(String serverName) {
+    this.serverName = serverName;
+  }
+
+  public void updateVerificationStatus(boolean verified, LocalDateTime verifiedAt) {
+    this.verified = verified;
+    this.verifiedAt = verifiedAt;
+  }
+
+  public void updateGameProfile(String nickname, String serverName) {
+    this.nickname = nickname;
+    this.serverName = serverName;
+  }
+
+}

src/main/java/until/the/eternity/das/user/entity/UserRepository.java

@@ -10,6 +10,8 @@ public interface UserRepository extends JpaRepository<User, Long> {
 
   boolean existsByNickname(String nickname);
 
+  boolean existsByNicknameAndIdNot(String nickname, Long id);
+
   User save(User user);
 
   Optional<User> findByEmail(String email);