Merge pull request #105 from kakao-tech-campus-2nd-step3/weekly/10

동기화

.github/workflows/spring_test.yml

@@ -28,6 +28,12 @@ jobs:
           DB_CONTAINER_NAME=super_poo_container
           JWT_SECRET_KEY=top_secret_key_for_ci
           SERVICE_KEY = test_key
+          REDIS_PORT = 1111
+          REDIS_URL = jdbc:redis://aaa/superfoo:1111
+          REDIS_HOST = yeah
+          REDIS_ID = hello
+          REDIS_PASSWORD = redis
+
           EOF
 
       - name: Set up JDK 21

build.gradle.kts

@@ -46,7 +46,6 @@ dependencies {
 
 	//redis
 	implementation("org.springframework.boot:spring-boot-starter-data-redis")
-	implementation("org.springframework.boot:spring-boot-starter-data-redis-reactive")
 }
 
 tasks.withType<Test> {

src/main/java/jeje/work/aeatbe/config/RedisConfig.java

@@ -0,0 +1,57 @@
+package jeje.work.aeatbe.config;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.connection.RedisStandaloneConfiguration;
+import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.repository.configuration.EnableRedisRepositories;
+import org.springframework.data.redis.serializer.StringRedisSerializer;
+
+@Configuration
+@EnableRedisRepositories
+public class RedisConfig {
+
+    @Value("${spring.data.redis.host}")
+    private String host;
+
+    @Value("${spring.data.redis.port}")
+    private int port;
+
+    @Value("${spring.data.redis.password}")
+    private String password;
+
+    @Value("${spring.data.redis.username}")
+    private String username;
+
+    @Bean
+    public RedisConnectionFactory redisConnectionFactory() {
+        RedisStandaloneConfiguration config = new RedisStandaloneConfiguration(host, port);
+        config.setUsername(username);
+        config.setPassword(password);
+        return new LettuceConnectionFactory(config);
+
+    }
+
+
+    @Bean
+    public RedisTemplate<String, Object> redisTemplate() {
+        RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
+        redisTemplate.setConnectionFactory(redisConnectionFactory());
+
+        redisTemplate.setKeySerializer(new StringRedisSerializer());
+        redisTemplate.setValueSerializer(new StringRedisSerializer());
+
+        redisTemplate.setHashKeySerializer(new StringRedisSerializer());
+        redisTemplate.setHashValueSerializer(new StringRedisSerializer());
+
+        redisTemplate.setDefaultSerializer(new StringRedisSerializer());
+
+        return redisTemplate;
+    }
+
+
+
+}

src/main/java/jeje/work/aeatbe/config/WebConfig.java

@@ -27,7 +27,8 @@ public void addInterceptors(InterceptorRegistry registry) {
             .addPathPatterns("/api/article/likes/**")
                 .addPathPatterns("/api/users/logout/**")
                 . addPathPatterns("/api/wishlist/**")
-                .addPathPatterns("/api/reviews/my/**");
+                .addPathPatterns("/api/reviews/my/**")
+                .addPathPatterns("/api/users/info/**");
     }
 
     @Override
@@ -38,7 +39,7 @@ public void addArgumentResolvers(List<HandlerMethodArgumentResolver> argumentRes
     @Override
     public void addCorsMappings(CorsRegistry registry) {
         registry.addMapping("/**")
-            .allowedOriginPatterns("https://aeat.jeje.work", "http://localhost")
+            .allowedOriginPatterns("https://aeat.jeje.work", "http://localhost","*")
             .allowedMethods("*")
             .allowedHeaders("*")
             .allowCredentials(true)

src/main/java/jeje/work/aeatbe/controller/KakaoAuthController.java

@@ -9,13 +9,15 @@
 import jeje.work.aeatbe.dto.user.TokenResponseDTO;
 import jeje.work.aeatbe.dto.user.LoginUserInfo;
 import jeje.work.aeatbe.service.KakaoService;
+import jeje.work.aeatbe.service.TokenService;
 import jeje.work.aeatbe.service.UserService;
 import jeje.work.aeatbe.utility.JwtUtil;
 import lombok.RequiredArgsConstructor;
 import org.springframework.http.HttpHeaders;
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestHeader;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
@@ -29,6 +31,7 @@ public class KakaoAuthController {
     private final JwtUtil jwtUtil;
     private final KakaoProperties kakaoProperties;
     private final KakaoService kakaoService;
+    private final TokenService tokenService;
 
     /**
      * 카카오 로그인페이지로 리다이렉션
@@ -49,11 +52,11 @@ public void redirectKakaoLogin(HttpServletResponse response) throws IOException
      * @return httpHeader(Cookie)
      */
     @GetMapping("/callback")
-    public ResponseEntity<?> getAccessToken(@RequestParam String code) {
+    public ResponseEntity<TokenResponseDTO> getAccessToken(@RequestParam String code) {
         KakaoTokenResponsed token = kakaoService.getKakaoTokenResponse(code);
         TokenResponseDTO tokenResponseDto = kakaoService.login(token.accessToken(), token.refreshToken());
         HttpHeaders httpHeaders = userService.setCookie(tokenResponseDto);
-        return ResponseEntity.ok().headers(httpHeaders).build();
+        return ResponseEntity.ok().body(tokenResponseDto);
     }
 
     /**
@@ -63,9 +66,10 @@ public ResponseEntity<?> getAccessToken(@RequestParam String code) {
      * @throws IOException
      */
     @PostMapping("/logout")
-    public void logout(HttpServletResponse response, @LoginUser LoginUserInfo loginUserInfo) throws IOException{
+    public void logout(HttpServletResponse response, @RequestHeader("Authorization") String token, @LoginUser LoginUserInfo loginUserInfo) throws IOException{
         String url = kakaoProperties.logoutUrl() +
                 "?client_id=" + kakaoProperties.clientId() + "&logout_redirect_uri=" + kakaoProperties.logoutRedirectUrl();
+        tokenService.addBlackList(tokenService.removePrefix(token), loginUserInfo.userId().toString());
         LogoutResponseDto logoutResponseDto = kakaoService.logout(loginUserInfo.userId());
         response.sendRedirect(url);
     }

src/main/java/jeje/work/aeatbe/controller/TokenController.java

@@ -27,6 +27,6 @@ public class TokenController {
     public ResponseEntity<TokenResponseDTO> refreshToken(@RequestBody RefreshTokenRequestDTO refreshTokenRequestDTO){
         TokenResponseDTO tokenResponseDto = userService.reissueAccessToken(refreshTokenRequestDTO.refreshToken());
         HttpHeaders httpHeaders = userService.setCookie(tokenResponseDto);
-        return ResponseEntity.ok().headers(httpHeaders).build();
+        return ResponseEntity.ok().body(tokenResponseDto);
     }
 }

src/main/java/jeje/work/aeatbe/entity/BlackList.java

@@ -0,0 +1,20 @@
+package jeje.work.aeatbe.entity;
+
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import org.springframework.data.annotation.Id;
+import org.springframework.data.redis.core.RedisHash;
+
+@Getter
+@NoArgsConstructor
+@AllArgsConstructor
+@RedisHash(value = "blackList" , timeToLive = 3600)
+public class BlackList {
+
+    @Id
+    private String token;
+
+    private String userId;
+}

src/main/java/jeje/work/aeatbe/exception/GlobalExceptionHandler.java

@@ -19,12 +19,20 @@ public ResponseEntity illegalArgumentException(IllegalArgumentException e) {
     }
 
     @ExceptionHandler(IllegalStateException.class)
-    public ResponseEntity illegalStateException(IllegalStateException e) {
+    public ResponseEntity<String> illegalStateException(IllegalStateException e) {
         return ResponseEntity.status(HttpStatus.UNAUTHORIZED).body(e.getMessage());
     }
 
+    @ExceptionHandler(WishlistNotFoundException.class)
+    public ResponseEntity<String> wishlistNotFoundException(WishlistNotFoundException e) {
+        return ResponseEntity.status(HttpStatus.NOT_FOUND).body(e.getMessage());
+    }
+
     @ExceptionHandler(TokenExpException.class)
-    public ResponseEntity tokenExpException(TokenExpException e) {
+    public ResponseEntity<String> tokenExpException(TokenExpException e) {
         return ResponseEntity.status(HttpStatus.UNAUTHORIZED).body(e.getMessage());
     }
+
+
+
 }

src/main/java/jeje/work/aeatbe/interceptor/JwtInterceptor.java

@@ -4,6 +4,7 @@
 import jakarta.servlet.http.HttpServletResponse;
 import jeje.work.aeatbe.exception.TokenExpException;
 import jeje.work.aeatbe.exception.TokenException;
+import jeje.work.aeatbe.service.TokenService;
 import jeje.work.aeatbe.service.UserService;
 import jeje.work.aeatbe.utility.JwtUtil;
 import lombok.AllArgsConstructor;
@@ -17,6 +18,7 @@ public class JwtInterceptor implements HandlerInterceptor {
 
     private JwtUtil jwtUtil;
     private UserService userService;
+    private TokenService tokenService;
 
     @Override
     public boolean preHandle(final HttpServletRequest request, final HttpServletResponse response, final Object handler)
@@ -29,6 +31,9 @@ public boolean preHandle(final HttpServletRequest request, final HttpServletResp
 
         String token = header.substring(7);
 
+        if(tokenService.isInBlackList(token)){
+            throw new TokenException("이미로그아웃 된 사용자의 토큰입니다. 다시 로그인 해주세요");
+        }
 
         if(jwtUtil.validTokenExpiration(token, true)) {
            throw new TokenExpException("만료된 토큰입니다.");
@@ -38,6 +43,8 @@ public boolean preHandle(final HttpServletRequest request, final HttpServletResp
         if(!userService.validateToken(token)){
             throw new TokenException("올바르지 않은 토큰입니다.");
         }
+
+
         return true;
 
 

src/main/java/jeje/work/aeatbe/mapper/article/ArticleMapper.java

@@ -0,0 +1,51 @@
+package jeje.work.aeatbe.mapper.article;
+
+import java.util.Arrays;
+import jeje.work.aeatbe.dto.article.ArticleDTO;
+import jeje.work.aeatbe.dto.article.ArticleResponseDTO;
+import jeje.work.aeatbe.entity.Article;
+import jeje.work.aeatbe.utility.ArticleUtil;
+import org.springframework.stereotype.Component;
+
+/*
+칼럼 매퍼
+ */
+@Component
+public class ArticleMapper {
+
+    /**
+     * Entity -> DTO
+     * @param article
+     * @return
+     */
+    public ArticleDTO toDTO(Article article) {
+        return ArticleDTO.builder()
+            .title(article.getTitle())
+            .date(article.getDate())
+            .author(article.getAuthor())
+            .tags(article.getTags())
+            .content(article.getContent())
+            .thumbnailUrl(article.getThumbnailUrl())
+            .likes(article.getLikes())
+            .build();
+    }
+
+    /**
+     * Entity -> ResponseDTO
+     * @param article
+     * @return
+     */
+    public ArticleResponseDTO toResponseDTO(Article article) {
+        return ArticleResponseDTO.builder()
+            .id(article.getId())
+            .title(article.getTitle())
+            .imgurl(article.getThumbnailUrl())
+            .createdAt(article.getDate())
+            .auth(article.getAuthor())
+            .keyword(Arrays.asList(article.getTags().split(",")))
+            .content(ArticleUtil.extractContentList(article.getContent()))
+            .subtitle(ArticleUtil.extractSubtitle(article.getContent()))
+            .build();
+    }
+
+}

src/main/java/jeje/work/aeatbe/repository/BlackListRepository.java

@@ -0,0 +1,9 @@
+package jeje.work.aeatbe.repository;
+
+import java.util.Optional;
+import jeje.work.aeatbe.entity.BlackList;
+import org.springframework.data.repository.CrudRepository;
+
+public interface BlackListRepository extends CrudRepository<BlackList, String> {
+
+}