feat: push notification

.github/workflows/deploy.yml

@@ -28,6 +28,10 @@ jobs:
           cd ./resources
           touch ./application.yml
           echo "${{ secrets.APPLICATION_YML }}" | base64 --decode >> application.yml
+          mkdir firebase
+          cd ./firebase
+          touch ./firebase_key.json
+          echo "${{ secrets.FIREBASE_KEY }}" | base64 --decode >> firebase_key.json
 
       # 빌드 권한 부여
       - name: Grant execute permission for gradlew

.gitignore

@@ -37,3 +37,4 @@ out/
 .vscode/
 
 application.yml
+firebase_key.json

build.gradle

@@ -51,6 +51,9 @@ dependencies {
 
 	// Thymeleaf 설정
 	implementation 'org.springframework.boot:spring-boot-starter-thymeleaf'
+
+	// firebase 설정
+	implementation 'com.google.firebase:firebase-admin:9.2.0'
 }
 
 tasks.named('test') {

src/main/java/com/fullcar/carpool/application/form/FormService.java

@@ -4,6 +4,7 @@
 import com.fullcar.carpool.domain.carpool.CarpoolId;
 import com.fullcar.carpool.domain.carpool.CarpoolRepository;
 import com.fullcar.carpool.domain.form.*;
+import com.fullcar.carpool.infra.NotificationClient;
 import com.fullcar.carpool.presentation.form.dto.request.FormRequestDto;
 import com.fullcar.carpool.presentation.form.dto.request.FormUpdateDto;
 import com.fullcar.carpool.presentation.form.dto.response.FormResponseDto;
@@ -28,10 +29,12 @@ public class FormService {
     private  final CarpoolRepository carpoolRepository;
     private final MemberRepository memberRepository; //TODO: Event 기반으로 변경 필요.
     private final FormMapper formMapper;
+    private final NotificationClient pushNotificationClient;
 
     @Transactional
     public FormResponseDto requestForm(Member member, CarpoolId carpoolId, FormRequestDto formRequestDto) {
         Carpool carpool = carpoolRepository.findByCarpoolIdAndIsDeletedOrThrow(carpoolId, false);
+        Member driver = memberRepository.findByIdAndIsDeletedOrThrow(carpool.getDriver().getMemberId(), false);
 
         if (carpool.isMyCarpool(member.getId())) {
             throw new CustomException(ErrorCode.CANNOT_SEND_TO_OWN_CARPOOL);
@@ -50,6 +53,7 @@ public FormResponseDto requestForm(Member member, CarpoolId carpoolId, FormReque
         }
 
         Form form = formMapper.toEntity(member, carpoolId, formRequestDto);
+        pushNotificationClient.sendNotification(driver.getNickname(), driver.getDeviceToken(), "탑승 요청이 들어왔어요!", "탑승자 정보를 확인하고 승인해 주세요🚘");
 
         return formMapper.toDto(
                 formRepository.saveAndFlush(form),
@@ -93,12 +97,26 @@ public FormResponseDto.FormDetailDto updateForm(Member member, FormId formId, Fo
         Form form = formRepository.findByFormIdAndIsDeletedOrThrow(formId, false);
         form.changeFormState(formUpdateDto);
 
+        Member passenger = memberRepository.findByIdAndIsDeletedOrThrow(form.getPassenger().getMemberId(), false);
         Carpool carpool = carpoolRepository.findByCarpoolIdAndIsDeletedOrThrow(form.getCarpoolId(), false);
 
         if (!carpool.isMyCarpool(member.getId())) {
             throw new CustomException(ErrorCode.CANNOT_CHANGE_FORM_STATE);
         }
 
+        System.out.println(passenger.getDeviceToken());
+
+        if (formUpdateDto.getFormState() == FormState.ACCEPT) {
+            String title = "카풀 매칭에 성공했어요!";
+            String body = "운전자 정보를 확인해 주세요🚘";
+            pushNotificationClient.sendNotification(passenger.getNickname(), passenger.getDeviceToken(), title, body);
+        }
+        else if (formUpdateDto.getFormState() == FormState.REJECT) {
+            String title = "카풀 매칭에 실패했어요.";
+            String body = "다른 카풀을 찾아볼까요?🥹";
+            pushNotificationClient.sendNotification(passenger.getNickname(), passenger.getDeviceToken(), title, body);
+        }
+
         return formMapper.toDetailDto(
                 formRepository.saveAndFlush(form),
                 memberRepository.findByIdAndIsDeletedOrThrow(
@@ -107,5 +125,4 @@ public FormResponseDto.FormDetailDto updateForm(Member member, FormId formId, Fo
                 )
         );
     }
-
 }

src/main/java/com/fullcar/carpool/domain/form/Form.java

@@ -73,6 +73,7 @@ else if (formState == FormState.REJECT) {
             throw new CustomException(ErrorCode.INVALID_FORM_STATE);
         }
     }
+
     public void accept(String contact, String toPassenger) {
         this.formState = FormState.ACCEPT;
         this.resultMessage = ResultMessage.builder()

src/main/java/com/fullcar/carpool/domain/service/NotificationService.java

@@ -0,0 +1,8 @@
+package com.fullcar.carpool.domain.service;
+
+import org.springframework.transaction.annotation.Transactional;
+
+@Transactional
+public interface NotificationService {
+    void sendNotification(String nickname, String deviceToken, String title, String body);
+}

src/main/java/com/fullcar/carpool/infra/NotificationClient.java

@@ -0,0 +1,39 @@
+package com.fullcar.carpool.infra;
+
+import com.fullcar.carpool.domain.service.NotificationService;
+import com.fullcar.core.exception.CustomException;
+import com.fullcar.core.response.ErrorCode;
+import com.google.firebase.messaging.FirebaseMessaging;
+import com.google.firebase.messaging.FirebaseMessagingException;
+import com.google.firebase.messaging.Message;
+import com.google.firebase.messaging.Notification;
+import lombok.AccessLevel;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+@Service
+@RequiredArgsConstructor(access = AccessLevel.PROTECTED)
+public class NotificationClient implements NotificationService {
+    private final FirebaseMessaging firebaseMessaging;
+
+    @Override
+    public void sendNotification(String nickname, String deviceToken, String title, String body) {
+        Notification notification = Notification.builder()
+                .setTitle(nickname + "님! " + title)
+                .setBody(body)
+                .build();
+
+        Message message = Message.builder()
+                .setToken(deviceToken)
+                .setNotification(notification)
+                .build();
+
+        try {
+            firebaseMessaging.send(message);
+        }
+        catch (FirebaseMessagingException e){
+            System.out.println(e);
+            throw new CustomException(ErrorCode.FAILED_TO_SEND_NOTIFICATION);
+        }
+    }
+}

src/main/java/com/fullcar/core/config/FirebaseConfig.java

@@ -0,0 +1,37 @@
+package com.fullcar.core.config;
+
+import com.google.auth.oauth2.GoogleCredentials;
+import com.google.firebase.FirebaseApp;
+import com.google.firebase.FirebaseOptions;
+import com.google.firebase.messaging.FirebaseMessaging;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.core.io.ClassPathResource;
+
+import java.io.IOException;
+
+@Configuration
+public class FirebaseConfig {
+
+    private final ClassPathResource firebaseResource = new ClassPathResource("firebase/firebase_key.json");
+
+    @Bean
+    FirebaseApp firebaseApp() throws IOException {
+        FirebaseOptions options = FirebaseOptions.builder()
+                .setCredentials(GoogleCredentials.fromStream(
+                        firebaseResource.getInputStream()))
+                .build();
+
+        if (FirebaseApp.getApps().isEmpty()) {
+            return FirebaseApp.initializeApp(options);
+        }
+        else {
+            return FirebaseApp.getApps().get(0);
+        }
+    }
+
+    @Bean
+    FirebaseMessaging firebaseMessaging() throws IOException {
+        return FirebaseMessaging.getInstance(firebaseApp());
+    }
+}

src/main/java/com/fullcar/core/response/ErrorCode.java

@@ -33,7 +33,10 @@ public enum ErrorCode {
     NOT_EXIST_USER(NOT_FOUND, "존재하지 않는 사용자입니다."),
     NOT_EXIST_CARPOOL(NOT_FOUND, "존재하지 않는 카풀입니다."),
     NOT_EXIST_CAR(NOT_FOUND, "존재하지 않는 차량입니다."),
-    NOT_EXIST_FORM(NOT_FOUND, "존재하지 않는 신청서입니다.");
+    NOT_EXIST_FORM(NOT_FOUND, "존재하지 않는 신청서입니다."),
+
+    /* 500 INTERNAL SERVER ERROR */
+    FAILED_TO_SEND_NOTIFICATION(INTERNAL_SERVER_ERROR, "푸시알림 전송 실패");
 
     private final HttpStatus status;
     private final String message;