[Issue14] 조회수 기능 구현

mitube-app/src/main/java/com/misim/MitubeAppApplication.java

@@ -5,6 +5,7 @@
 
 @SpringBootApplication
 public class MitubeAppApplication {
+
     public static void main(String[] args) {
         SpringApplication.run(MitubeAppApplication.class, args);
     }

mitube-app/src/main/java/com/misim/config/JpaConfig.java

@@ -6,4 +6,5 @@
 @Configuration
 @EnableJpaAuditing
 public class JpaConfig {
+
 }

mitube-app/src/main/java/com/misim/config/RedisConfig.java

@@ -6,7 +6,7 @@
 import org.springframework.data.redis.connection.RedisConnectionFactory;
 import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
 import org.springframework.data.redis.core.RedisTemplate;
-import org.springframework.data.redis.serializer.StringRedisSerializer;
+import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
 
 @Configuration
 public class RedisConfig {
@@ -26,8 +26,18 @@ public RedisConnectionFactory redisConnectionFactory() {
     public RedisTemplate<?, ?> redisTemplate() {
         RedisTemplate<?, ?> redisTemplate = new RedisTemplate<>();
         redisTemplate.setConnectionFactory(redisConnectionFactory());
-        redisTemplate.setKeySerializer(new StringRedisSerializer());
-        redisTemplate.setValueSerializer(new StringRedisSerializer());
+        redisTemplate.setKeySerializer(new GenericJackson2JsonRedisSerializer());
+        redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());
         return redisTemplate;
     }
+//
+//    @Bean
+//    public RedisMessageListenerContainer redisMessageListenerContainer(RedisConnectionFactory connectionFactory, MessageListenerAdapter listenerAdapter) {
+//
+//        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
+//        container.setConnectionFactory(connectionFactory);
+//        container.addMessageListener(listenerAdapter, new PatternTopic("keyspace"));
+//
+//        return container;
+//    }
 }

mitube-app/src/main/java/com/misim/config/SecurityConfig.java

@@ -17,14 +17,14 @@ public class SecurityConfig {
     @Bean
     public WebSecurityCustomizer webSecurityCustomizer() {
         return web -> web.ignoring()
-                .requestMatchers(
-                        "/users/**",
-                        "/terms/**",
-                        "/videos/**",
-                        "/comments/**",
-                        "/channels/**",
-                        "/home"
-                );
+            .requestMatchers(
+                "/users/**",
+                "/terms/**",
+                "/videos/**",
+                "/comments/**",
+                "/channels/**",
+                "/home"
+            );
     }
 
     @Bean

mitube-app/src/main/java/com/misim/config/SwaggerConfig.java

@@ -1,4 +1,5 @@
 package com.misim.config;
+
 import io.swagger.v3.oas.models.Components;
 import io.swagger.v3.oas.models.OpenAPI;
 import io.swagger.v3.oas.models.info.Info;
@@ -15,53 +16,53 @@ public class SwaggerConfig {
     @Bean
     public OpenAPI openAPI() {
         return new OpenAPI()
-                .components(new Components())
-                .info(apiInfo());
+            .components(new Components())
+            .info(apiInfo());
     }
 
     private Info apiInfo() {
         return new Info()
-                .title("Mitube Api")
-                .description("Youtube 클론 프로젝트")
-                .version("1.0.0");
+            .title("Mitube Api")
+            .description("Youtube 클론 프로젝트")
+            .version("1.0.0");
     }
 
     @Bean
     public GroupedOpenApi userGroup() {
         List<Tag> tags = List.of(
-                new Tag().name("유저 API").description("유저 정보 관련 API")
+            new Tag().name("유저 API").description("유저 정보 관련 API")
         );
 
         return GroupedOpenApi.builder()
-                .group("유저 API")
-                .pathsToMatch("/users/**")
-                .addOpenApiCustomizer(openApi -> openApi.setTags(tags))
-                .build();
+            .group("유저 API")
+            .pathsToMatch("/users/**")
+            .addOpenApiCustomizer(openApi -> openApi.setTags(tags))
+            .build();
     }
 
     @Bean
     public GroupedOpenApi termGroup() {
         List<Tag> tags = List.of(
-                new Tag().name("약관 API").description("약관 정보 제공 API")
+            new Tag().name("약관 API").description("약관 정보 제공 API")
         );
 
         return GroupedOpenApi.builder()
-                .group("약관 API")
-                .pathsToMatch("/terms/**")
-                .addOpenApiCustomizer(openApi -> openApi.setTags(tags))
-                .build();
+            .group("약관 API")
+            .pathsToMatch("/terms/**")
+            .addOpenApiCustomizer(openApi -> openApi.setTags(tags))
+            .build();
     }
 
     @Bean
     public GroupedOpenApi videoGroup() {
         List<Tag> tags = List.of(
-                new Tag().name("동영상 API").description("동영상 정보 관련 API")
+            new Tag().name("동영상 API").description("동영상 정보 관련 API")
         );
 
         return GroupedOpenApi.builder()
-                .group("동영상 API")
-                .pathsToMatch("/videos/**")
-                .addOpenApiCustomizer(openApi -> openApi.setTags(tags))
-                .build();
+            .group("동영상 API")
+            .pathsToMatch("/videos/**")
+            .addOpenApiCustomizer(openApi -> openApi.setTags(tags))
+            .build();
     }
 }

mitube-app/src/main/java/com/misim/controller/ChannelController.java

@@ -27,8 +27,8 @@ public class ChannelController {
     @Operation(summary = "채널 구독", description = "채널을 구독합니다.")
     @Parameter(name = "SubscribingRequest", description = "채널 구독 요청을 위한 정보", required = true)
     @ApiResponses(value = {
-            @ApiResponse(responseCode = "200", description = "채널 구독 성공"),
-            @ApiResponse(responseCode = "400", description = "요청이 올바르지 않습니다.", content = @Content(schema = @Schema(implementation = CommonResponse.class)))
+        @ApiResponse(responseCode = "200", description = "채널 구독 성공"),
+        @ApiResponse(responseCode = "400", description = "요청이 올바르지 않습니다.", content = @Content(schema = @Schema(implementation = CommonResponse.class)))
     })
     @PostMapping("/subscribe")
     public void subscribing(@RequestBody SubscribingRequest request) {
@@ -41,8 +41,8 @@ public void subscribing(@RequestBody SubscribingRequest request) {
     @Operation(summary = "채널 구독 취소", description = "채널 구독을 취소합니다.")
     @Parameter(name = "SubscribingRequest", description = "채널 구독 취소 요청을 위한 정보", required = true)
     @ApiResponses(value = {
-            @ApiResponse(responseCode = "200", description = "채널 구독 취소 성공"),
-            @ApiResponse(responseCode = "400", description = "요청이 올바르지 않습니다.", content = @Content(schema = @Schema(implementation = CommonResponse.class)))
+        @ApiResponse(responseCode = "200", description = "채널 구독 취소 성공"),
+        @ApiResponse(responseCode = "400", description = "요청이 올바르지 않습니다.", content = @Content(schema = @Schema(implementation = CommonResponse.class)))
     })
     @PostMapping("/unsubscribe")
     public void unsubscribing(@RequestBody SubscribingRequest request) {

mitube-app/src/main/java/com/misim/controller/CommentController.java

@@ -4,7 +4,6 @@
 import com.misim.controller.model.Request.CreateCommentRequest;
 import com.misim.controller.model.Request.UpdateCommentRequest;
 import com.misim.controller.model.Response.CommentListResponse;
-import com.misim.controller.model.Response.CommentResponse;
 import com.misim.controller.model.Response.CreateCommentResponse;
 import com.misim.exception.CommonResponse;
 import com.misim.exception.MitubeErrorCode;
@@ -18,9 +17,6 @@
 import io.swagger.v3.oas.annotations.responses.ApiResponses;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import lombok.RequiredArgsConstructor;
-import org.hibernate.sql.Update;
-import org.springframework.data.domain.Slice;
-import org.springframework.security.core.parameters.P;
 import org.springframework.web.bind.annotation.*;
 
 import java.util.Arrays;
@@ -48,46 +44,56 @@ public class CommentController {
     // commentService 메소드 호출 전, scrollDirection 데이터 검사
     @Operation(summary = "댓글 목록 요청", description = "동영상의 댓글 목록 10개 전달")
     @ApiResponses(value = {
-            @ApiResponse(responseCode = "200", description = "댓글 목록 요청 성공"),
-            @ApiResponse(responseCode = "400", description = "요청이 올바르지 않습니다.", content = @Content(schema = @Schema(implementation = CommonResponse.class)))
+        @ApiResponse(responseCode = "200", description = "댓글 목록 요청 성공"),
+        @ApiResponse(responseCode = "400", description = "요청이 올바르지 않습니다.", content = @Content(schema = @Schema(implementation = CommonResponse.class)))
     })
     @GetMapping("/{videoId}")
-    public CommonResponse<CommentListResponse> getParentComments(@PathVariable @Parameter(name = "videoId", description = "시청할 동영상 식별 정보", required = true) Long videoId, @RequestParam @Parameter(name = "idx", description = "댓글의 인덱스 정보") Long idx, @RequestParam @Parameter(name = "scrollDirection", description = "댓글 목록 스크롤 방향으로 up, down만 가능하다.") String scrollDirection) {
+    public CommonResponse<CommentListResponse> getParentComments(
+        @PathVariable @Parameter(name = "videoId", description = "시청할 동영상 식별 정보", required = true) Long videoId,
+        @RequestParam @Parameter(name = "idx", description = "댓글의 인덱스 정보") Long idx,
+        @RequestParam @Parameter(name = "scrollDirection", description = "댓글 목록 스크롤 방향으로 up, down만 가능하다.") String scrollDirection) {
 
         checkRequests(idx, scrollDirection);
 
-        CommentListResponse comments = commentService.getParentComments(videoId, idx, scrollDirection);
+        CommentListResponse comments = commentService.getParentComments(videoId, idx,
+            scrollDirection);
 
         return CommonResponse.<CommentListResponse>builder()
-                .body(comments)
-                .build();
+            .body(comments)
+            .build();
     }
 
     @Operation(summary = "대댓글 목록 요청", description = "동영상 댓글의 대댓글 목록 10개 전달")
     @ApiResponses(value = {
-            @ApiResponse(responseCode = "200", description = "대댓글 목록 요청 성공"),
-            @ApiResponse(responseCode = "400", description = "요청이 올바르지 않습니다.", content = @Content(schema = @Schema(implementation = CommonResponse.class)))
+        @ApiResponse(responseCode = "200", description = "대댓글 목록 요청 성공"),
+        @ApiResponse(responseCode = "400", description = "요청이 올바르지 않습니다.", content = @Content(schema = @Schema(implementation = CommonResponse.class)))
     })
     @GetMapping("/{videoId}/{parentCommentId}")
-    public CommonResponse<CommentListResponse> getChildComments(@PathVariable @Parameter(name = "videoId", description = "시청할 동영상 식별 정보", required = true) Long videoId, @PathVariable @Parameter(name = "parentCommentId", description = "대댓글이 달린 댓글의 식별 정보") Long parentCommentId, @RequestParam @Parameter(name = "idx", description = "댓글의 인덱스 정보") Long idx, @RequestParam @Parameter(name = "scrollDirection", description = "댓글 목록 스크롤 방향으로 up, down만 가능하다.") String scrollDirection) {
+    public CommonResponse<CommentListResponse> getChildComments(
+        @PathVariable @Parameter(name = "videoId", description = "시청할 동영상 식별 정보", required = true) Long videoId,
+        @PathVariable @Parameter(name = "parentCommentId", description = "대댓글이 달린 댓글의 식별 정보") Long parentCommentId,
+        @RequestParam @Parameter(name = "idx", description = "댓글의 인덱스 정보") Long idx,
+        @RequestParam @Parameter(name = "scrollDirection", description = "댓글 목록 스크롤 방향으로 up, down만 가능하다.") String scrollDirection) {
 
         checkRequests(idx, scrollDirection);
 
-        CommentListResponse comments = commentService.getChildComments(videoId, parentCommentId, idx, scrollDirection);
+        CommentListResponse comments = commentService.getChildComments(videoId, parentCommentId,
+            idx, scrollDirection);
 
         return CommonResponse.<CommentListResponse>builder()
-                .body(comments)
-                .build();
+            .body(comments)
+            .build();
     }
 
     @Operation(summary = "댓글 생성", description = "동영상 댓글을 생성합니다.")
     @ApiResponses(value = {
-            @ApiResponse(responseCode = "200", description = "댓글 생성 성공"),
-            @ApiResponse(responseCode = "400", description = "요청이 올바르지 않습니다.", content = @Content(schema = @Schema(implementation = CommonResponse.class)))
+        @ApiResponse(responseCode = "200", description = "댓글 생성 성공"),
+        @ApiResponse(responseCode = "400", description = "요청이 올바르지 않습니다.", content = @Content(schema = @Schema(implementation = CommonResponse.class)))
     })
     @PostMapping("/create")
-    public CommonResponse<CreateCommentResponse> createComments(@RequestBody CreateCommentRequest request) {
-
+    public CommonResponse<CreateCommentResponse> createComments(
+        @RequestBody CreateCommentRequest request) {
+
         request.check();
 
         CreateCommentResponse response = commentService.createComments(request);
@@ -97,8 +103,8 @@ public CommonResponse<CreateCommentResponse> createComments(@RequestBody CreateC
 
     @Operation(summary = "댓글 수정", description = "동영상 댓글을 수정합니다.")
     @ApiResponses(value = {
-            @ApiResponse(responseCode = "200", description = "댓글 수정 성공"),
-            @ApiResponse(responseCode = "400", description = "요청이 올바르지 않습니다.", content = @Content(schema = @Schema(implementation = CommonResponse.class)))
+        @ApiResponse(responseCode = "200", description = "댓글 수정 성공"),
+        @ApiResponse(responseCode = "400", description = "요청이 올바르지 않습니다.", content = @Content(schema = @Schema(implementation = CommonResponse.class)))
     })
     @PostMapping("/update")
     public void updateComments(@RequestBody UpdateCommentRequest request) {
@@ -110,8 +116,8 @@ public void updateComments(@RequestBody UpdateCommentRequest request) {
 
     @Operation(summary = "댓글 삭제", description = "동영상 댓글을 삭제합니다.")
     @ApiResponses(value = {
-            @ApiResponse(responseCode = "200", description = "댓글 삭제 성공"),
-            @ApiResponse(responseCode = "400", description = "요청이 올바르지 않습니다.", content = @Content(schema = @Schema(implementation = CommonResponse.class)))
+        @ApiResponse(responseCode = "200", description = "댓글 삭제 성공"),
+        @ApiResponse(responseCode = "400", description = "요청이 올바르지 않습니다.", content = @Content(schema = @Schema(implementation = CommonResponse.class)))
     })
     @PostMapping("/delete")
     public void deleteComments(@RequestBody CommentDto request) {
@@ -124,7 +130,7 @@ public void deleteComments(@RequestBody CommentDto request) {
     private void checkRequests(Long idx, String scrollDirection) {
 
         if (idx < 1) {
-            throw  new MitubeException(MitubeErrorCode.INVALID_COMMENT_INDEX);
+            throw new MitubeException(MitubeErrorCode.INVALID_COMMENT_INDEX);
         }
 
         if (scrollDirection.isBlank() || !scroll.contains(scrollDirection)) {

mitube-app/src/main/java/com/misim/controller/MainController.java

@@ -1,10 +1,8 @@
 package com.misim.controller;
 
 import com.misim.controller.model.Response.HomeResponse;
-import com.misim.entity.VideoCategory;
 import com.misim.exception.CommonResponse;
 import com.misim.service.HomeService;
-import com.misim.service.VideoService;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.Parameter;
 import io.swagger.v3.oas.annotations.media.Content;
@@ -16,27 +14,26 @@
 import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
-import java.util.Arrays;
-
 @RestController
 @RequiredArgsConstructor
 public class MainController {
 
     private final HomeService homeService;
-    
+
     @Operation(summary = "메인 화면 데이터 전송", description = "메인 화면에 필요한 데이터 전송")
     @ApiResponses(value = {
-            @ApiResponse(responseCode = "200", description = "메인 화면 데이터 전송 성공"),
-            @ApiResponse(responseCode = "400", description = "요청이 올바르지 않습니다.", content = @Content(schema = @Schema(implementation = CommonResponse.class)))
+        @ApiResponse(responseCode = "200", description = "메인 화면 데이터 전송 성공"),
+        @ApiResponse(responseCode = "400", description = "요청이 올바르지 않습니다.", content = @Content(schema = @Schema(implementation = CommonResponse.class)))
     })
     @GetMapping("/home")
-    public CommonResponse<HomeResponse> home(@RequestParam @Parameter(name = "userId", description = "Mitube에 접속한 유저 식별 정보로, 비로그인 사용자의 경우 null로 요청된다.") Long userId) {
+    public CommonResponse<HomeResponse> home(
+        @RequestParam @Parameter(name = "userId", description = "Mitube에 접속한 유저 식별 정보로, 비로그인 사용자의 경우 null로 요청된다.") Long userId) {
 
         HomeResponse response = homeService.getHome(userId);
 
         return CommonResponse
-                .<HomeResponse>builder()
-                .body(response)
-                .build();
+            .<HomeResponse>builder()
+            .body(response)
+            .build();
     }
 }