✨ Feature/#65 - FCM 푸시알림 기능 구현

.gitignore

@@ -7,7 +7,7 @@ http/http-client.private.env.json
 ### ignore application.yml ###
 src/main/resources/application-dev.yml
 src/main/resources/application-local.yml
-src/main/resources/firebase/firebase_service_key.json
+src/main/resources/firebase/firebase-key.json
 .gradle/*
 build/*
 

build.gradle

@@ -68,6 +68,10 @@ dependencies {
     implementation 'org.springframework.cloud:spring-cloud-aws-context:2.2.6.RELEASE'
     implementation 'org.springframework.cloud:spring-cloud-aws-autoconfigure:2.2.6.RELEASE'
 
+    // Firebase
+    implementation 'com.google.firebase:firebase-admin:6.8.1'
+    implementation group: 'com.squareup.okhttp3', name: 'okhttp', version: '4.2.2'
+
     // Secheduler
     implementation 'org.springframework.boot:spring-boot-starter-quartz'
 

src/main/java/com/daon/onjung/core/utility/FirebaseUtil.java

@@ -0,0 +1,83 @@
+package com.daon.onjung.core.utility;
+
+import com.daon.onjung.core.exception.error.ErrorCode;
+import com.daon.onjung.core.exception.type.CommonException;
+import com.google.auth.oauth2.GoogleCredentials;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import net.minidev.json.JSONObject;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.core.io.ClassPathResource;
+import org.springframework.http.HttpHeaders;
+import org.springframework.stereotype.Component;
+import org.springframework.web.util.UriComponentsBuilder;
+
+import java.util.List;
+import java.util.Map;
+
+@Component
+@RequiredArgsConstructor
+@Slf4j
+public class FirebaseUtil {
+
+    @Value("${google.firebase.config.path}")
+    private String firebaseConfigPath;
+
+    @Value("${google.access-token.request.url}")
+    private String GOOGLE_ACCESS_TOKEN_URL;
+
+    @Value("${google.notification.url}")
+    private String GOOGLE_NOTIFICATION_URL;
+
+    private static final String BEARER_PREFIX = "Bearer " ;
+    private static final String JSON_BODY_KEY_TITLE = "title";
+    private static final String JSON_BODY_KEY_BODY = "body";
+    private static final String JSON_BODY_KEY_TOKEN = "token";
+    private static final String JSON_BODY_KEY_NOTIFICATION = "notification";
+    private static final String JSON_BODY_KEY_MESSAGE = "message";
+    private static final String JSON_BODY_KEY_VALIDATE_ONLY = "validate_only";
+
+    public String createFirebaseRequestUrl() {
+        return UriComponentsBuilder.fromHttpUrl(GOOGLE_NOTIFICATION_URL)
+                .toUriString();
+    }
+
+    public HttpHeaders createFirebaseRequestHeaders() {
+
+        String accessToken = null;
+
+        try {
+            GoogleCredentials credentials = GoogleCredentials
+                    .fromStream(new ClassPathResource(firebaseConfigPath).getInputStream())
+                    .createScoped(List.of(GOOGLE_ACCESS_TOKEN_URL));
+
+            credentials.refreshIfExpired();
+
+            accessToken = BEARER_PREFIX + credentials.getAccessToken().getTokenValue();
+        } catch (Exception e) {
+            log.error("Google Access Token을 가져오는데 실패했습니다.", e);
+            throw new CommonException(ErrorCode.EXTERNAL_SERVER_ERROR);        }
+
+        HttpHeaders headers = new HttpHeaders();
+        headers.add("Content-Type", "application/json");
+        headers.add("Authorization", accessToken);
+        return headers;
+    }
+
+    public String createFirebaseRequestBody(String deviceToken, String storeName) {
+        JSONObject messageBody = new JSONObject();
+
+        JSONObject notificationJson = new JSONObject();
+        notificationJson.put(JSON_BODY_KEY_TITLE, storeName + " 가게의 식권에 당첨됐어요!");
+        notificationJson.put(JSON_BODY_KEY_BODY, "축하합니다! " + storeName + " 가게의 식권에 당첨되셨습니다. 지금 바로 확인해보세요!");
+
+        JSONObject messageJson = new JSONObject();
+        messageJson.put(JSON_BODY_KEY_TOKEN, deviceToken);
+        messageJson.put(JSON_BODY_KEY_NOTIFICATION, notificationJson);
+
+        messageBody.put(JSON_BODY_KEY_MESSAGE, messageJson);
+        messageBody.put(JSON_BODY_KEY_VALIDATE_ONLY, false);
+
+        return messageBody.toJSONString();
+    }
+}

src/main/java/com/daon/onjung/core/utility/HeaderUtil.java

@@ -17,13 +17,4 @@ public static Optional<String> refineHeader(HttpServletRequest request, String h
         return Optional.of(unpreparedToken.substring(prefix.length()));
     }
 
-//    public static Optional<String> refineHeader(StompHeaderAccessor request, String header, String prefix) {
-//        String unpreparedToken = request.getFirstNativeHeader(header);
-//
-//        if (!StringUtils.hasText(unpreparedToken) || !unpreparedToken.startsWith(prefix)) {
-//            return Optional.empty();
-//        }
-//
-//        return Optional.of(unpreparedToken.substring(prefix.length()));
-//    }
 }

src/main/java/com/daon/onjung/core/utility/HttpServletUtil.java

@@ -17,73 +17,8 @@
 @RequiredArgsConstructor
 public class HttpServletUtil {
 
-    @Value("${web-engine.client-url}")
-    private String clientUrl;
-
-    @Value("${web-engine.cookie-domain}")
-    private String cookieDomain;
-
-    @Value("${json-web-token.refresh-token-expire-period}")
-    private Long refreshTokenExpirePeriod;
-
     private final ObjectMapper objectMapper;
 
-    public void onSuccessRedirectResponseWithJWTCookie(
-            HttpServletResponse response,
-            DefaultJsonWebTokenDto tokenDto
-    ) throws IOException {
-        response.setContentType("application/json");
-        response.setCharacterEncoding("UTF-8");
-        response.setStatus(HttpStatus.CREATED.value());
-
-        CookieUtil.addCookie(
-                response,
-                cookieDomain,
-                Constants.ACCESS_TOKEN,
-                tokenDto.getAccessToken()
-        );
-        CookieUtil.addSecureCookie(
-                response,
-                cookieDomain,
-                Constants.REFRESH_TOKEN,
-                tokenDto.getRefreshToken(),
-                (int) (refreshTokenExpirePeriod / 1000L)
-        );
-
-        response.sendRedirect(String.format("%s/%s", clientUrl, "profile"));
-    }
-
-    public void onSuccessBodyResponseWithJWTCookie(
-            HttpServletResponse response,
-            DefaultJsonWebTokenDto tokenDto
-    ) throws IOException {
-        response.setContentType("application/json");
-        response.setCharacterEncoding("UTF-8");
-        response.setStatus(HttpStatus.CREATED.value());
-
-        CookieUtil.addCookie(
-                response,
-                cookieDomain,
-                Constants.ACCESS_TOKEN,
-                tokenDto.getAccessToken()
-        );
-        CookieUtil.addSecureCookie(
-                response,
-                cookieDomain,
-                Constants.REFRESH_TOKEN,
-                tokenDto.getRefreshToken(),
-                (int) (refreshTokenExpirePeriod / 1000L)
-        );
-
-        Map<String, Object> result = new HashMap<>();
-
-        result.put("success", true);
-        result.put("data", null);
-        result.put("error", null);
-
-        response.getWriter().write(objectMapper.writeValueAsString(result));
-    }
-
     public void onSuccessBodyResponseWithJWTBody(
             HttpServletResponse response,
             DefaultJsonWebTokenDto tokenDto

src/main/java/com/daon/onjung/event/application/service/ProcessCompletedEventService.java

@@ -7,6 +7,7 @@
 import com.daon.onjung.core.exception.error.ErrorCode;
 import com.daon.onjung.core.exception.type.CommonException;
 import com.daon.onjung.core.utility.BankUtil;
+import com.daon.onjung.core.utility.FirebaseUtil;
 import com.daon.onjung.core.utility.RestClientUtil;
 import com.daon.onjung.event.application.usecase.ProcessCompletedEventUseCase;
 import com.daon.onjung.event.domain.Event;
@@ -44,6 +45,7 @@ public class ProcessCompletedEventService implements ProcessCompletedEventUseCas
 
     private final RestClientUtil restClientUtil;
     private final BankUtil bankUtil;
+    private final FirebaseUtil firebaseUtil;
 
     private final ApplicationEventPublisher applicationEventPublisher;
 
@@ -89,8 +91,8 @@ public void execute(Long eventId) {
         applicationEventPublisher.publishEvent(
                 EventScheduled.builder()
                         .eventId(newEvent.getId())
-                        .scheduledTime(newEvent.getEndDate().plusDays(1).atStartOfDay())
-//                        .scheduledTime(LocalDateTime.now().plusMinutes(1)) // 테스트용 1분 뒤
+//                        .scheduledTime(newEvent.getEndDate().plusDays(1).atStartOfDay())
+                        .scheduledTime(LocalDateTime.now().plusMinutes(1)) // 테스트용 1분 뒤
                         .build()
         );
 
@@ -154,6 +156,16 @@ public void execute(Long eventId) {
                 );
                 ticketRepository.save(ticket);
 
+                // 푸시 알림 발송
+                url = firebaseUtil.createFirebaseRequestUrl();
+                headers = firebaseUtil.createFirebaseRequestHeaders();
+                String deviceToken = userRepository.findById(userId).
+                        orElseThrow(() -> new CommonException(ErrorCode.NOT_FOUND_RESOURCE)).getDeviceToken();
+                String storeName = store.getName();
+                String firebaseRequestBody = firebaseUtil.createFirebaseRequestBody(deviceToken, storeName);
+
+                restClientUtil.sendPostMethod(url, headers, firebaseRequestBody);
+
                 // 발급된 유저 기록 및 발급된 티켓 수 증가
                 issuedUserIds.add(userId);
                 issuedTickets++;

src/main/java/com/daon/onjung/security/application/service/SignUpOwnerByDefaultService.java

@@ -118,8 +118,8 @@ public void execute(MultipartFile logo,
         applicationEventPublisher.publishEvent(
                 EventScheduled.builder()
                         .eventId(event.getId())
-                        .scheduledTime(event.getEndDate().plusDays(1).atStartOfDay())
-//                        .scheduledTime(LocalDateTime.now().plusMinutes(1)) // 테스트용 1분 뒤
+//                        .scheduledTime(event.getEndDate().plusDays(1).atStartOfDay())
+                        .scheduledTime(LocalDateTime.now().plusMinutes(1)) // 테스트용 1분 뒤
                         .build()
         );