From 33c460d35855b574601dec4a87f70792c73c8686 Mon Sep 17 00:00:00 2001
From: eun-seong <eunseong.dev@gmail.com>
Date: Thu, 21 Mar 2024 20:34:13 +0900
Subject: [PATCH 1/6] =?UTF-8?q?refactor:=20Survey,=20Question=20=EC=B0=B8?=
 =?UTF-8?q?=EC=A1=B0=20=EC=BB=AC=EB=9F=BC=EC=97=90=20lazy=20=EC=A0=81?=
 =?UTF-8?q?=EC=9A=A9(#98)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/dnd/namuiwiki/domain/question/entity/Question.java    | 2 +-
 .../com/dnd/namuiwiki/domain/survey/model/entity/Survey.java  | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/main/java/com/dnd/namuiwiki/domain/question/entity/Question.java b/src/main/java/com/dnd/namuiwiki/domain/question/entity/Question.java
index 6449ed9b..e2a2371d 100644
--- a/src/main/java/com/dnd/namuiwiki/domain/question/entity/Question.java
+++ b/src/main/java/com/dnd/namuiwiki/domain/question/entity/Question.java
@@ -28,7 +28,7 @@ public class Question extends BaseTimeEntity {
     private Long surveyOrder;
     private boolean reasonRequired;
 
-    @DocumentReference
+    @DocumentReference(collection = "options")
     private Map<String, Option> options;
 
     public Optional<Option> getOption(String optionId) {
diff --git a/src/main/java/com/dnd/namuiwiki/domain/survey/model/entity/Survey.java b/src/main/java/com/dnd/namuiwiki/domain/survey/model/entity/Survey.java
index 4ea9a237..af05d8ae 100644
--- a/src/main/java/com/dnd/namuiwiki/domain/survey/model/entity/Survey.java
+++ b/src/main/java/com/dnd/namuiwiki/domain/survey/model/entity/Survey.java
@@ -22,10 +22,10 @@ public class Survey extends BaseTimeEntity {
     @Id
     private String id;
 
-    @DocumentReference
+    @DocumentReference(collection = "users", lazy = true)
     private User owner;
 
-    @DocumentReference
+    @DocumentReference(collection = "users", lazy = true)
     private User sender;
 
     private String senderName;

From ae4e051c2e60754b283ef86a7f7228530128aa4f Mon Sep 17 00:00:00 2001
From: eun-seong <eunseong.dev@gmail.com>
Date: Thu, 21 Mar 2024 20:37:57 +0900
Subject: [PATCH 2/6] =?UTF-8?q?refactor:=20CacheManager=20=EC=84=A4?=
 =?UTF-8?q?=EC=A0=95(#98)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../namuiwiki/config/CacheConfiguration.java  | 28 +++++++++++++++++++
 .../domain/question/QuestionRepository.java   | 14 ++++++++++
 2 files changed, 42 insertions(+)
 create mode 100644 src/main/java/com/dnd/namuiwiki/config/CacheConfiguration.java

diff --git a/src/main/java/com/dnd/namuiwiki/config/CacheConfiguration.java b/src/main/java/com/dnd/namuiwiki/config/CacheConfiguration.java
new file mode 100644
index 00000000..d19f1915
--- /dev/null
+++ b/src/main/java/com/dnd/namuiwiki/config/CacheConfiguration.java
@@ -0,0 +1,28 @@
+package com.dnd.namuiwiki.config;
+
+import org.springframework.cache.Cache;
+import org.springframework.cache.CacheManager;
+import org.springframework.cache.annotation.EnableCaching;
+import org.springframework.cache.concurrent.ConcurrentMapCache;
+import org.springframework.cache.support.SimpleCacheManager;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import java.util.ArrayList;
+import java.util.List;
+
+@EnableCaching
+@Configuration
+public class CacheConfiguration {
+
+    @Bean
+    CacheManager cacheManager() {
+        SimpleCacheManager cacheManager = new SimpleCacheManager();
+        List<Cache> caches = new ArrayList<>();
+        caches.add(new ConcurrentMapCache("questions"));
+        caches.add(new ConcurrentMapCache("question"));
+        cacheManager.setCaches(caches);
+        return cacheManager;
+    }
+
+}
diff --git a/src/main/java/com/dnd/namuiwiki/domain/question/QuestionRepository.java b/src/main/java/com/dnd/namuiwiki/domain/question/QuestionRepository.java
index b51a68ce..6bef69dd 100644
--- a/src/main/java/com/dnd/namuiwiki/domain/question/QuestionRepository.java
+++ b/src/main/java/com/dnd/namuiwiki/domain/question/QuestionRepository.java
@@ -1,7 +1,21 @@
 package com.dnd.namuiwiki.domain.question;
 
 import com.dnd.namuiwiki.domain.question.entity.Question;
+import org.springframework.cache.annotation.Cacheable;
 import org.springframework.data.mongodb.repository.MongoRepository;
+import org.springframework.lang.NonNull;
+
+import java.util.List;
+import java.util.Optional;
 
 public interface QuestionRepository extends MongoRepository<Question, String> {
+
+    @NonNull
+    @Cacheable("questions")
+    List<Question> findAll();
+
+    @NonNull
+    @Cacheable("question")
+    Optional<Question> findById(@NonNull String id);
+
 }

From ddec1c770ee6651e307d8a3f5c766b3312a806d7 Mon Sep 17 00:00:00 2001
From: eun-seong <eunseong.dev@gmail.com>
Date: Thu, 21 Mar 2024 20:52:50 +0900
Subject: [PATCH 3/6] =?UTF-8?q?refactor:=20=EB=B9=84=EB=8F=99=EA=B8=B0=20c?=
 =?UTF-8?q?onfiguration=20=EC=84=A4=EC=A0=95(#92)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/dnd/namuiwiki/config/AsyncConfiguration.java     | 9 +++++++++
 1 file changed, 9 insertions(+)
 create mode 100644 src/main/java/com/dnd/namuiwiki/config/AsyncConfiguration.java

diff --git a/src/main/java/com/dnd/namuiwiki/config/AsyncConfiguration.java b/src/main/java/com/dnd/namuiwiki/config/AsyncConfiguration.java
new file mode 100644
index 00000000..a9b57381
--- /dev/null
+++ b/src/main/java/com/dnd/namuiwiki/config/AsyncConfiguration.java
@@ -0,0 +1,9 @@
+package com.dnd.namuiwiki.config;
+
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.EnableAsync;
+
+@EnableAsync
+@Configuration
+public class AsyncConfiguration {
+}

From a8376dc4c191913118723598911f45cb24ef6c43 Mon Sep 17 00:00:00 2001
From: eun-seong <eunseong.dev@gmail.com>
Date: Thu, 21 Mar 2024 20:55:59 +0900
Subject: [PATCH 4/6] =?UTF-8?q?refactor:=20=EC=84=A4=EB=AC=B8=20=EC=83=9D?=
 =?UTF-8?q?=EC=84=B1=20event=20=ED=95=B8=EB=93=A4=EB=9F=AC=20=EB=93=B1?=
 =?UTF-8?q?=EB=A1=9D(#92)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../namuiwiki/config/EventConfiguration.java  | 19 ++++++++++++++
 .../domain/survey/SurveyEventHandler.java     | 25 +++++++++++++++++++
 .../survey/model/dto/SurveyCreatedEvent.java  | 11 ++++++++
 3 files changed, 55 insertions(+)
 create mode 100644 src/main/java/com/dnd/namuiwiki/config/EventConfiguration.java
 create mode 100644 src/main/java/com/dnd/namuiwiki/domain/survey/SurveyEventHandler.java
 create mode 100644 src/main/java/com/dnd/namuiwiki/domain/survey/model/dto/SurveyCreatedEvent.java

diff --git a/src/main/java/com/dnd/namuiwiki/config/EventConfiguration.java b/src/main/java/com/dnd/namuiwiki/config/EventConfiguration.java
new file mode 100644
index 00000000..ffe40db8
--- /dev/null
+++ b/src/main/java/com/dnd/namuiwiki/config/EventConfiguration.java
@@ -0,0 +1,19 @@
+package com.dnd.namuiwiki.config;
+
+import com.dnd.namuiwiki.domain.statistic.StatisticsService;
+import com.dnd.namuiwiki.domain.survey.SurveyEventHandler;
+import lombok.RequiredArgsConstructor;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+@RequiredArgsConstructor
+public class EventConfiguration {
+    private final StatisticsService statisticsService;
+
+    @Bean
+    public SurveyEventHandler surveyEventHandler() {
+        return new SurveyEventHandler(statisticsService);
+    }
+
+}
diff --git a/src/main/java/com/dnd/namuiwiki/domain/survey/SurveyEventHandler.java b/src/main/java/com/dnd/namuiwiki/domain/survey/SurveyEventHandler.java
new file mode 100644
index 00000000..d2ab2ca0
--- /dev/null
+++ b/src/main/java/com/dnd/namuiwiki/domain/survey/SurveyEventHandler.java
@@ -0,0 +1,25 @@
+package com.dnd.namuiwiki.domain.survey;
+
+import com.dnd.namuiwiki.domain.statistic.StatisticsService;
+import com.dnd.namuiwiki.domain.survey.model.dto.SurveyCreatedEvent;
+import com.dnd.namuiwiki.domain.survey.model.entity.Survey;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.event.EventListener;
+import org.springframework.scheduling.annotation.Async;
+
+@Slf4j
+@RequiredArgsConstructor
+public class SurveyEventHandler {
+    private final StatisticsService statisticsService;
+
+    @Async
+    @EventListener
+    public void handleSurveySuccessEvent(SurveyCreatedEvent event) {
+        Survey survey = event.getSurvey();
+        log.info("SurveyEventHandler.handleSurveySuccessEvent: surveyId={}", survey.getId());
+
+        statisticsService.updateStatistics(survey);
+    }
+
+}
diff --git a/src/main/java/com/dnd/namuiwiki/domain/survey/model/dto/SurveyCreatedEvent.java b/src/main/java/com/dnd/namuiwiki/domain/survey/model/dto/SurveyCreatedEvent.java
new file mode 100644
index 00000000..79ccc0c8
--- /dev/null
+++ b/src/main/java/com/dnd/namuiwiki/domain/survey/model/dto/SurveyCreatedEvent.java
@@ -0,0 +1,11 @@
+package com.dnd.namuiwiki.domain.survey.model.dto;
+
+import com.dnd.namuiwiki.domain.survey.model.entity.Survey;
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+
+@Getter
+@RequiredArgsConstructor
+public class SurveyCreatedEvent {
+    private final Survey survey;
+}

From 94c1e0c2245400cf2e14b2d637f2e4a1485dfc4a Mon Sep 17 00:00:00 2001
From: eun-seong <eunseong.dev@gmail.com>
Date: Thu, 21 Mar 2024 20:57:38 +0900
Subject: [PATCH 5/6] =?UTF-8?q?refactor:=20=EC=84=A4=EB=AC=B8=20=EC=83=9D?=
 =?UTF-8?q?=EC=84=B1=20=EC=9D=B4=EB=B2=A4=ED=8A=B8=20=EB=B0=9C=ED=96=89(#9?=
 =?UTF-8?q?2)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../dnd/namuiwiki/domain/survey/SurveyService.java    | 11 ++++++++---
 1 file changed, 8 insertions(+), 3 deletions(-)

diff --git a/src/main/java/com/dnd/namuiwiki/domain/survey/SurveyService.java b/src/main/java/com/dnd/namuiwiki/domain/survey/SurveyService.java
index 9450ad41..54f9505f 100644
--- a/src/main/java/com/dnd/namuiwiki/domain/survey/SurveyService.java
+++ b/src/main/java/com/dnd/namuiwiki/domain/survey/SurveyService.java
@@ -9,7 +9,6 @@
 import com.dnd.namuiwiki.domain.option.entity.Option;
 import com.dnd.namuiwiki.domain.question.QuestionRepository;
 import com.dnd.namuiwiki.domain.question.entity.Question;
-import com.dnd.namuiwiki.domain.statistic.StatisticsService;
 import com.dnd.namuiwiki.domain.survey.model.dto.AnswerDto;
 import com.dnd.namuiwiki.domain.survey.model.dto.CreateSurveyRequest;
 import com.dnd.namuiwiki.domain.survey.model.dto.CreateSurveyResponse;
@@ -18,6 +17,7 @@
 import com.dnd.namuiwiki.domain.survey.model.dto.ReceivedSurveyDto;
 import com.dnd.namuiwiki.domain.survey.model.dto.SentSurveyDto;
 import com.dnd.namuiwiki.domain.survey.model.dto.SingleAnswerWithSurveyDetailDto;
+import com.dnd.namuiwiki.domain.survey.model.dto.SurveyCreatedEvent;
 import com.dnd.namuiwiki.domain.survey.model.entity.Answer;
 import com.dnd.namuiwiki.domain.survey.model.entity.Survey;
 import com.dnd.namuiwiki.domain.survey.type.AnswerType;
@@ -26,6 +26,8 @@
 import com.dnd.namuiwiki.domain.user.UserRepository;
 import com.dnd.namuiwiki.domain.user.entity.User;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.PageRequest;
 import org.springframework.data.domain.Pageable;
@@ -34,6 +36,7 @@
 
 import java.util.List;
 
+@Slf4j
 @Service
 @RequiredArgsConstructor
 public class SurveyService {
@@ -42,7 +45,7 @@ public class SurveyService {
     private final QuestionRepository questionRepository;
     private final OptionRepository optionRepository;
     private final JwtProvider jwtProvider;
-    private final StatisticsService statisticsService;
+    private final ApplicationEventPublisher applicationEventPublisher;
 
     public CreateSurveyResponse createSurvey(CreateSurveyRequest request, String accessToken) {
         User owner = getUserByWikiId(request.getOwner());
@@ -59,7 +62,9 @@ public CreateSurveyResponse createSurvey(CreateSurveyRequest request, String acc
                 .answers(surveyAnswer)
                 .build());
 
-        statisticsService.updateStatistics(survey);
+        log.info("SurveyService.createSurvey: surveyId={} done", survey.getId());
+
+        applicationEventPublisher.publishEvent(new SurveyCreatedEvent(survey));
 
         return new CreateSurveyResponse(survey.getId());
     }

From 48587e28f3274b9b884e2092bd0db89c8532e75e Mon Sep 17 00:00:00 2001
From: eun-seong <eunseong.dev@gmail.com>
Date: Thu, 21 Mar 2024 20:59:09 +0900
Subject: [PATCH 6/6] =?UTF-8?q?feat:=20=EB=B9=84=EB=8F=99=EA=B8=B0=20?=
 =?UTF-8?q?=EB=A9=94=EC=86=8C=EB=93=9C=20=EC=98=88=EC=99=B8=20=EC=B2=98?=
 =?UTF-8?q?=EB=A6=AC=20=ED=95=B8=EB=93=A4=EB=9F=AC=20=EC=B6=94=EA=B0=80(#9?=
 =?UTF-8?q?2)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../exception/AsyncExceptionHandler.java      | 20 +++++++++++++++++++
 .../namuiwiki/config/AsyncConfiguration.java  | 17 +++++++++++++++-
 2 files changed, 36 insertions(+), 1 deletion(-)
 create mode 100644 src/main/java/com/dnd/namuiwiki/common/exception/AsyncExceptionHandler.java

diff --git a/src/main/java/com/dnd/namuiwiki/common/exception/AsyncExceptionHandler.java b/src/main/java/com/dnd/namuiwiki/common/exception/AsyncExceptionHandler.java
new file mode 100644
index 00000000..b77d3607
--- /dev/null
+++ b/src/main/java/com/dnd/namuiwiki/common/exception/AsyncExceptionHandler.java
@@ -0,0 +1,20 @@
+package com.dnd.namuiwiki.common.exception;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;
+
+import java.lang.reflect.Method;
+
+@Slf4j
+public class AsyncExceptionHandler implements AsyncUncaughtExceptionHandler {
+
+    @Override
+    public void handleUncaughtException(Throwable ex, Method method, Object... params) {
+        log.error("AsyncException message={}, declaringClass={}, methodName={}", ex.getMessage(), method.getDeclaringClass(), method.getName(), ex);
+
+        for (Object param : params) {
+            log.error("Parameter value - {}, declaringClass={}, methodName={}", param, method.getDeclaringClass(), method.getName());
+        }
+    }
+
+}
diff --git a/src/main/java/com/dnd/namuiwiki/config/AsyncConfiguration.java b/src/main/java/com/dnd/namuiwiki/config/AsyncConfiguration.java
index a9b57381..58921553 100644
--- a/src/main/java/com/dnd/namuiwiki/config/AsyncConfiguration.java
+++ b/src/main/java/com/dnd/namuiwiki/config/AsyncConfiguration.java
@@ -1,9 +1,24 @@
 package com.dnd.namuiwiki.config;
 
+import com.dnd.namuiwiki.common.exception.AsyncExceptionHandler;
+import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;
+import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.AsyncConfigurer;
 import org.springframework.scheduling.annotation.EnableAsync;
 
 @EnableAsync
 @Configuration
-public class AsyncConfiguration {
+public class AsyncConfiguration implements AsyncConfigurer {
+
+    @Override
+    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
+        return asyncExceptionHandler();
+    }
+
+    @Bean
+    public AsyncExceptionHandler asyncExceptionHandler() {
+        return new AsyncExceptionHandler();
+    }
+
 }