[FEAT] 알림 토큰 생성, 삭제 API 구현

eeos/build.gradle.kts

@@ -63,6 +63,10 @@ dependencies {
 
     // OpenFeign
     implementation(libs.spring.cloud.starter.openfeign)
+
+    // Firebase Admin SDK
+    implementation(libs.firebase.admin)
+
 }
 
 dependencyManagement {

eeos/gradle/libs.versions.toml

@@ -10,6 +10,7 @@ spotless = "7.2.1"
 asciidoctor = "4.0.2"
 epages-restdocs = "0.18.2"
 swagger = "5.10.3"
+firebase-admin = "9.2.0"
 
 # Security
 jwt = "0.12.6"
@@ -57,6 +58,9 @@ jbcrypt = { group = "org.mindrot", name = "jbcrypt", version.ref = "jbcrypt" }
 # Lombok
 lombok = { group = "org.projectlombok", name = "lombok" }
 
+# Firebase Admin SDK
+firebase-admin = { group = "com.google.firebase", name = "firebase-admin", version.ref = "firebase-admin" }
+
 [plugins]
 spring-boot = { id = "org.springframework.boot", version.ref = "spring-boot" }
 spring-dependency-management = { id = "io.spring.dependency-management", version.ref = "spring-dependency-management" }

eeos/src/main/java/com/blackcompany/eeos/config/security/SecurityFilterChainConfig.java

@@ -87,7 +87,8 @@ SecurityFilterChain authenticated(HttpSecurity httpSecurity) throws Exception {
 							.requestMatchers("/api/admin/**")
 							.requestMatchers("/api/team-building/**")
 							.requestMatchers("/api/semester-periods/**")
-							.requestMatchers("/api/calendars/**");
+							.requestMatchers("/api/calendars/**")
+							.requestMatchers("/api/pushToken", "/api/pushToken/**");
 				});
 
 		httpSecurity.authorizeHttpRequests(

eeos/src/main/java/com/blackcompany/eeos/notification/application/dto/CreateMemberPushTokenRequest.java

@@ -0,0 +1,16 @@
+package com.blackcompany.eeos.notification.application.dto;
+
+import jakarta.validation.constraints.NotBlank;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Getter
+@AllArgsConstructor
+@NoArgsConstructor
+@Builder(toBuilder = true)
+public class CreateMemberPushTokenRequest {
+	@NotBlank private String pushToken;
+	@NotBlank private String provider;
+}

eeos/src/main/java/com/blackcompany/eeos/notification/application/dto/DeleteMemberPushTokenRequest.java

@@ -0,0 +1,15 @@
+package com.blackcompany.eeos.notification.application.dto;
+
+import jakarta.validation.constraints.NotBlank;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Getter
+@AllArgsConstructor
+@NoArgsConstructor
+@Builder(toBuilder = true)
+public class DeleteMemberPushTokenRequest {
+	@NotBlank private String pushToken;
+}

eeos/src/main/java/com/blackcompany/eeos/notification/application/exception/DeniedDeletePushTokenException.java

@@ -0,0 +1,17 @@
+package com.blackcompany.eeos.notification.application.exception;
+
+import com.blackcompany.eeos.common.exception.BusinessException;
+import org.springframework.http.HttpStatus;
+
+public class DeniedDeletePushTokenException extends BusinessException {
+	private static final String FAIL_CODE = "5008";
+
+	public DeniedDeletePushTokenException() {
+		super(FAIL_CODE, HttpStatus.FORBIDDEN);
+	}
+
+	@Override
+	public String getMessage() {
+		return "토큰 수정 권한이 없습니다.";
+	}
+}

eeos/src/main/java/com/blackcompany/eeos/notification/application/exception/NotFoundNotificationProviderException.java

@@ -0,0 +1,20 @@
+package com.blackcompany.eeos.notification.application.exception;
+
+import com.blackcompany.eeos.common.exception.BusinessException;
+import org.springframework.http.HttpStatus;
+
+public class NotFoundNotificationProviderException extends BusinessException {
+
+	private static final String FAIL_CODE = "5006";
+	private final String provider;
+
+	public NotFoundNotificationProviderException(String provider) {
+		super(FAIL_CODE, HttpStatus.NOT_FOUND);
+		this.provider = provider;
+	}
+
+	@Override
+	public String getMessage() {
+		return String.format("%s 는 존재하지 않는 외부 제공자 입니다.", provider);
+	}
+}

eeos/src/main/java/com/blackcompany/eeos/notification/application/exception/NotFoundPushTokenException.java

@@ -0,0 +1,19 @@
+package com.blackcompany.eeos.notification.application.exception;
+
+import com.blackcompany.eeos.common.exception.BusinessException;
+import org.springframework.http.HttpStatus;
+
+public class NotFoundPushTokenException extends BusinessException {
+
+	private static final String FAIL_CODE = "5007";
+
+	public NotFoundPushTokenException() {
+
+		super(FAIL_CODE, HttpStatus.NOT_FOUND);
+	}
+
+	@Override
+	public String getMessage() {
+		return "존재하지 않는 알림토큰 입니다.";
+	}
+}

eeos/src/main/java/com/blackcompany/eeos/notification/application/model/MemberPushTokenModel.java

@@ -0,0 +1,24 @@
+package com.blackcompany.eeos.notification.application.model;
+
+import com.blackcompany.eeos.common.support.AbstractModel;
+import java.time.LocalDateTime;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Getter
+@Builder(toBuilder = true)
+@AllArgsConstructor
+@NoArgsConstructor
+public class MemberPushTokenModel implements AbstractModel {
+	private Long id;
+	private Long memberId;
+	private NotificationProvider notificationProvider;
+	private String pushToken;
+	private LocalDateTime lastActiveAt;
+
+	public MemberPushTokenModel renew(Long memberId) {
+		return this.toBuilder().memberId(memberId).lastActiveAt(LocalDateTime.now()).build();
+	}
+}

eeos/src/main/java/com/blackcompany/eeos/notification/application/model/NotificationProvider.java

@@ -0,0 +1,24 @@
+package com.blackcompany.eeos.notification.application.model;
+
+import com.blackcompany.eeos.notification.application.exception.NotFoundNotificationProviderException;
+import java.util.Arrays;
+import lombok.Getter;
+
+@Getter
+public enum NotificationProvider {
+	FCM("fcm"),
+	ETC("etc");
+
+	private final String provider;
+
+	NotificationProvider(String provider) {
+		this.provider = provider;
+	}
+
+	public static NotificationProvider find(String name) {
+		return Arrays.stream(NotificationProvider.values())
+				.filter(provider -> provider.name().equalsIgnoreCase(name))
+				.findFirst()
+				.orElseThrow(() -> new NotFoundNotificationProviderException(name));
+	}
+}

eeos/src/main/java/com/blackcompany/eeos/notification/application/model/converter/MemberPushTokenEntityConverter.java

@@ -0,0 +1,33 @@
+package com.blackcompany.eeos.notification.application.model.converter;
+
+import com.blackcompany.eeos.common.support.converter.AbstractEntityConverter;
+import com.blackcompany.eeos.notification.application.model.MemberPushTokenModel;
+import com.blackcompany.eeos.notification.persistence.MemberPushTokenEntity;
+import org.springframework.stereotype.Component;
+
+@Component
+public class MemberPushTokenEntityConverter
+		implements AbstractEntityConverter<MemberPushTokenEntity, MemberPushTokenModel> {
+
+	@Override
+	public MemberPushTokenModel from(MemberPushTokenEntity source) {
+		return MemberPushTokenModel.builder()
+				.id(source.getId())
+				.memberId(source.getMemberId())
+				.notificationProvider(source.getProvider())
+				.pushToken(source.getPushToken())
+				.lastActiveAt(source.getLastActiveAt())
+				.build();
+	}
+
+	@Override
+	public MemberPushTokenEntity toEntity(MemberPushTokenModel source) {
+		return MemberPushTokenEntity.builder()
+				.id(source.getId())
+				.memberId(source.getMemberId())
+				.pushToken(source.getPushToken())
+				.provider(source.getNotificationProvider())
+				.lastActiveAt(source.getLastActiveAt())
+				.build();
+	}
+}

eeos/src/main/java/com/blackcompany/eeos/notification/application/repository/MemberPushTokenRepository.java

@@ -0,0 +1,24 @@
+package com.blackcompany.eeos.notification.application.repository;
+
+import com.blackcompany.eeos.notification.application.model.MemberPushTokenModel;
+import com.blackcompany.eeos.notification.application.model.NotificationProvider;
+import java.time.LocalDateTime;
+import java.util.List;
+import java.util.Optional;
+
+public interface MemberPushTokenRepository {
+	Optional<MemberPushTokenModel> findByPushToken(String pushToken);
+
+	List<MemberPushTokenModel> findByMemberId(Long memberId);
+
+	List<MemberPushTokenModel> findByMemberIdAndProvider(
+			Long memberId, NotificationProvider provider);
+
+	void deleteByPushToken(String pushToken);
+
+	void deleteByMemberId(Long memberId);
+
+	int deleteByUpdatedDateBefore(LocalDateTime updatedDate);
+
+	MemberPushTokenModel save(MemberPushTokenModel memberPushToken);
+}

eeos/src/main/java/com/blackcompany/eeos/notification/application/service/NotificationTokenService.java

@@ -0,0 +1,67 @@
+package com.blackcompany.eeos.notification.application.service;
+
+import com.blackcompany.eeos.notification.application.dto.CreateMemberPushTokenRequest;
+import com.blackcompany.eeos.notification.application.dto.DeleteMemberPushTokenRequest;
+import com.blackcompany.eeos.notification.application.exception.DeniedDeletePushTokenException;
+import com.blackcompany.eeos.notification.application.exception.NotFoundPushTokenException;
+import com.blackcompany.eeos.notification.application.model.MemberPushTokenModel;
+import com.blackcompany.eeos.notification.application.model.NotificationProvider;
+import com.blackcompany.eeos.notification.application.repository.MemberPushTokenRepository;
+import com.blackcompany.eeos.notification.application.usecase.CreateMemberPushTokenUsecase;
+import com.blackcompany.eeos.notification.application.usecase.DeleteAllMemberPushTokensUsecase;
+import com.blackcompany.eeos.notification.application.usecase.DeleteMemberPushTokenUsecase;
+import java.time.LocalDateTime;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service
+@RequiredArgsConstructor
+@Transactional(readOnly = true)
+public class NotificationTokenService
+		implements CreateMemberPushTokenUsecase,
+				DeleteAllMemberPushTokensUsecase,
+				DeleteMemberPushTokenUsecase {
+
+	private final MemberPushTokenRepository memberPushTokenRepository;
+
+	@Override
+	@Transactional
+	public void create(Long memberId, CreateMemberPushTokenRequest request) {
+		NotificationProvider provider = NotificationProvider.find(request.getProvider());
+
+		MemberPushTokenModel model =
+				memberPushTokenRepository
+						.findByPushToken(request.getPushToken())
+						.map(existingModel -> existingModel.renew(memberId))
+						.orElseGet(
+								() ->
+										MemberPushTokenModel.builder()
+												.memberId(memberId)
+												.pushToken(request.getPushToken())
+												.notificationProvider(provider)
+												.lastActiveAt(LocalDateTime.now())
+												.build());
+
+		memberPushTokenRepository.save(model);
+	}
+
+	@Override
+	@Transactional
+	public void deleteAllMemberPushTokens(Long memberId) {
+		memberPushTokenRepository.deleteByMemberId(memberId);
+	}
+
+	@Override
+	@Transactional
+	public void delete(Long memberId, DeleteMemberPushTokenRequest request) {
+		MemberPushTokenModel model =
+				memberPushTokenRepository
+						.findByPushToken(request.getPushToken())
+						.orElseThrow(NotFoundPushTokenException::new);
+		if (!model.getMemberId().equals(memberId)) {
+			throw new DeniedDeletePushTokenException();
+		}
+		memberPushTokenRepository.deleteByPushToken(request.getPushToken());
+	}
+}

eeos/src/main/java/com/blackcompany/eeos/notification/application/usecase/CreateMemberPushTokenUsecase.java

@@ -0,0 +1,7 @@
+package com.blackcompany.eeos.notification.application.usecase;
+
+import com.blackcompany.eeos.notification.application.dto.CreateMemberPushTokenRequest;
+
+public interface CreateMemberPushTokenUsecase {
+	void create(Long memberId, CreateMemberPushTokenRequest request);
+}

eeos/src/main/java/com/blackcompany/eeos/notification/application/usecase/DeleteAllMemberPushTokensUsecase.java

@@ -0,0 +1,5 @@
+package com.blackcompany.eeos.notification.application.usecase;
+
+public interface DeleteAllMemberPushTokensUsecase {
+	void deleteAllMemberPushTokens(Long memberId);
+}

eeos/src/main/java/com/blackcompany/eeos/notification/application/usecase/DeleteMemberPushTokenUsecase.java

@@ -0,0 +1,7 @@
+package com.blackcompany.eeos.notification.application.usecase;
+
+import com.blackcompany.eeos.notification.application.dto.DeleteMemberPushTokenRequest;
+
+public interface DeleteMemberPushTokenUsecase {
+	void delete(Long memberId, DeleteMemberPushTokenRequest request);
+}

eeos/src/main/java/com/blackcompany/eeos/notification/persistence/JpaMemberPushTokenRepository.java

@@ -0,0 +1,28 @@
+package com.blackcompany.eeos.notification.persistence;
+
+import com.blackcompany.eeos.notification.application.model.NotificationProvider;
+import java.sql.Timestamp;
+import java.util.List;
+import java.util.Optional;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Modifying;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+
+public interface JpaMemberPushTokenRepository extends JpaRepository<MemberPushTokenEntity, Long> {
+
+	Optional<MemberPushTokenEntity> findByPushToken(String token);
+
+	List<MemberPushTokenEntity> findByMemberId(Long memberId);
+
+	List<MemberPushTokenEntity> findByMemberIdAndProvider(
+			Long memberId, NotificationProvider provider);
+
+	@Modifying
+	@Query("DELETE FROM MemberPushTokenEntity t WHERE t.memberId = :memberId")
+	void deleteByMemberId(@Param("memberId") Long memberId);
+
+	void deleteByPushToken(String token);
+
+	int deleteByUpdatedDateBefore(Timestamp updatedDate);
+}