[Feat/#7] ApiGatewayHandler 구현

src/main/java/com/sopt/push/common/Constants.java

@@ -43,6 +43,11 @@ public class Constants {
   public static final String HEADER_CONTENT_TYPE = "Content-Type";
   public static final String MEDIA_TYPE_APPLICATION_JSON = "application/json";
 
+  public static final String HEADER_ACTION = "action";
+  public static final String HEADER_PLATFORM = "platform";
+  public static final String HEADER_TRANSACTION_ID = "transactionId";
+  public static final String HEADER_SERVICE = "service";
+
   public static final String HTTP_METHOD_PATCH = "PATCH";
   public static final String HTTP_METHOD_POST = "POST";
   public static final String URL_PATH_FORMAT_ID = "%s/%s";
@@ -53,4 +58,5 @@ public class Constants {
 
   public static final int HTTP_CLIENT_CONNECT_TIMEOUT_SECONDS = 10;
   public static final int HTTP_REQUEST_TIMEOUT_SECONDS = 5;
+  public static final String SNS_PROTOCOL_APPLICATION = "application";
 }

src/main/java/com/sopt/push/common/DeviceTokenException.java

@@ -0,0 +1,24 @@
+package com.sopt.push.common;
+
+import lombok.Getter;
+
+@Getter
+public class DeviceTokenException extends RuntimeException {
+
+  private final ErrorMessage errorMessage;
+
+  public DeviceTokenException(ErrorMessage errorMessage) {
+    super(errorMessage.getMessage());
+    this.errorMessage = errorMessage;
+  }
+
+  public DeviceTokenException(ErrorMessage errorMessage, String detail) {
+    super(errorMessage.getMessage() + ": " + detail);
+    this.errorMessage = errorMessage;
+  }
+
+  public DeviceTokenException(ErrorMessage errorMessage, String detail, Throwable cause) {
+    super(errorMessage.getMessage() + ": " + detail, cause);
+    this.errorMessage = errorMessage;
+  }
+}

src/main/java/com/sopt/push/common/ErrorMessage.java

@@ -8,10 +8,21 @@ public enum ErrorMessage {
   INVALID_REQUEST(StatusCode.BAD_REQUEST, "잘못된 요청입니다."),
   NULL_VALUE(StatusCode.BAD_REQUEST, "필요한 값이 없습니다."),
   TOKEN_NOT_EXIST(StatusCode.BAD_REQUEST, "존재하지 않는 토큰입니다."),
+  USER_ID_REQUIRED(StatusCode.BAD_REQUEST, "userId가 필요합니다."),
+  TOKEN_NOT_FOUND(StatusCode.BAD_REQUEST, "토큰을 찾을 수 없습니다."),
+  ARN_UNDEFINED(StatusCode.BAD_REQUEST, "arn 또는 topicArn이 정의되지 않았습니다."),
+  INVALID_ENDPOINT(StatusCode.BAD_REQUEST, "유효하지 않은 SNS 엔드포인트입니다."),
+  ENDPOINT_ARN_UNDEFINED(StatusCode.INTERNAL_SERVER_ERROR, "endpointArn이 정의되지 않았습니다."),
+  SUBSCRIPTION_ARN_UNDEFINED(StatusCode.INTERNAL_SERVER_ERROR, "subscriptionArn이 정의되지 않았습니다."),
+  PLATFORM_APP_ARN_NOT_SET(StatusCode.INTERNAL_SERVER_ERROR, "플랫폼 애플리케이션 ARN이 설정되지 않았습니다."),
 
   /** 500 Internal Server Error */
   SEND_FAIL(StatusCode.INTERNAL_SERVER_ERROR, "메시지 전송 실패."),
-  INTERNAL_SERVER_ERROR(StatusCode.INTERNAL_SERVER_ERROR, "서버 내부 오류");
+  INTERNAL_SERVER_ERROR(StatusCode.INTERNAL_SERVER_ERROR, "서버 내부 오류"),
+  REGISTER_USER_ERROR(StatusCode.INTERNAL_SERVER_ERROR, "토큰 등록 중 오류가 발생했습니다."),
+  DELETE_TOKEN_ERROR(StatusCode.INTERNAL_SERVER_ERROR, "토큰 삭제 중 오류가 발생했습니다."),
+  SNS_PUBLISH_FAILED(StatusCode.INTERNAL_SERVER_ERROR, "SNS 발행 실패."),
+  UNKNOWN_PUSH_ERROR(StatusCode.INTERNAL_SERVER_ERROR, "알 수 없는 푸시 전송 오류가 발생했습니다.");
 
   private final int httpStatus;
   private final String message;

src/main/java/com/sopt/push/config/AppFactory.java

@@ -6,8 +6,8 @@
 import com.sopt.push.repository.HistoryRepository;
 import com.sopt.push.repository.UserRepository;
 import com.sopt.push.service.DeviceTokenService;
+import com.sopt.push.service.EndpointFacade;
 import com.sopt.push.service.HistoryService;
-import com.sopt.push.service.InvalidEndpointCleaner;
 import com.sopt.push.service.NotificationService;
 import com.sopt.push.service.SendPushFacade;
 import com.sopt.push.service.UserService;
@@ -22,12 +22,12 @@ public class AppFactory {
   private static final AppFactory INSTANCE = new AppFactory();
 
   private final SendPushFacade sendPushFacade;
+  private final EndpointFacade endpointFacade;
   private final WebHookService webHookService;
   private final UserService userService;
   private final HistoryService historyService;
   private final DeviceTokenService deviceTokenService;
   private final NotificationService notificationService;
-  private final InvalidEndpointCleaner invalidEndpointCleaner;
 
   private AppFactory() {
 
@@ -50,9 +50,8 @@ private AppFactory() {
     this.historyService = new HistoryService(historyRepository);
     this.deviceTokenService = new DeviceTokenService(tokenRepository);
     this.notificationService = new NotificationService(snsClient, envConfig);
-    this.invalidEndpointCleaner =
-        new InvalidEndpointCleaner(
-            this.userService, this.deviceTokenService, this.notificationService);
+    this.endpointFacade =
+        new EndpointFacade(this.deviceTokenService, this.userService, this.notificationService);
 
     this.webHookService = new WebHookService(httpClient, envConfig);
     this.sendPushFacade =
@@ -62,7 +61,7 @@ private AppFactory() {
             this.historyService,
             this.userService,
             this.deviceTokenService,
-            invalidEndpointCleaner);
+            this.endpointFacade);
   }
 
   public static AppFactory getInstance() {
@@ -89,11 +88,7 @@ public DeviceTokenService deviceTokenService() {
     return deviceTokenService;
   }
 
-  public NotificationService notificationService() {
-    return notificationService;
-  }
-
-  public InvalidEndpointCleaner invalidEndpointCleaner() {
-    return invalidEndpointCleaner;
+  public EndpointFacade endpointFacade() {
+    return endpointFacade;
   }
 }

src/main/java/com/sopt/push/config/EnvConfig.java

@@ -9,17 +9,23 @@ public final class EnvConfig {
   private static final String ALL_TOPIC_ARN_ENV_VAR = "ALL_TOPIC_ARN";
   private static final String MAKERS_APP_SERVER_URL = "MAKERS_APP_SERVER_URL";
   private static final String MAKERS_OPERATION_SERVER_URL = "MAKERS_OPERATION_SERVER_URL";
+  private static final String PLATFORM_APPLICATION_IOS_ENV = "PLATFORM_APPLICATION_iOS";
+  private static final String PLATFORM_APPLICATION_ANDROID_ENV = "PLATFORM_APPLICATION_ANDROID";
 
   private final String dynamoDbTableName;
   private final String allTopicArn;
   private final String makersAppServerUrl;
   private final String makersOperationServerUrl;
+  private final String platformApplicationIosArn;
+  private final String platformApplicationAndroidArn;
 
   public EnvConfig() {
     this.dynamoDbTableName = getRequiredEnv(DYNAMODB_TABLE_ENV_VAR);
     this.allTopicArn = getRequiredEnv(ALL_TOPIC_ARN_ENV_VAR);
     this.makersAppServerUrl = getRequiredEnv(MAKERS_APP_SERVER_URL);
     this.makersOperationServerUrl = getRequiredEnv(MAKERS_OPERATION_SERVER_URL);
+    this.platformApplicationIosArn = getRequiredEnv(PLATFORM_APPLICATION_IOS_ENV);
+    this.platformApplicationAndroidArn = getRequiredEnv(PLATFORM_APPLICATION_ANDROID_ENV);
   }
 
   private static String getRequiredEnv(String key) {

src/main/java/com/sopt/push/dto/ApiGatewayRequestDto.java

@@ -0,0 +1,5 @@
+package com.sopt.push.dto;
+
+import java.util.Map;
+
+public record ApiGatewayRequestDto(RegisterHeaderDto header, Map<String, Object> body) {}

src/main/java/com/sopt/push/dto/RegisterHeaderDto.java

@@ -0,0 +1,8 @@
+package com.sopt.push.dto;
+
+import com.sopt.push.enums.Actions;
+import com.sopt.push.enums.Platform;
+import com.sopt.push.enums.Services;
+
+public record RegisterHeaderDto(
+    String transactionId, Services service, Platform platform, Actions action) {}