[Feat/#7] ApiGatewayHandler 구현

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/common/PushFailException.java

@@ -0,0 +1,8 @@
+package com.sopt.push.common;
+
+public class PushFailException extends RuntimeException {
+
+  public PushFailException(String message, Throwable cause) {
+    super(message, cause);
+  }
+}

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

@@ -46,9 +46,17 @@ private AppFactory() {
     HistoryRepository historyRepository = new HistoryRepository(dynamoClient, tableName);
     DeviceTokenRepository tokenRepository = new DeviceTokenRepository(dynamoClient, tableName);
 
+    HistoryService historyService = new HistoryService(historyRepository);
+    NotificationService notificationService = new NotificationService(snsClient, envConfig);
+    SnsFactory snsFactory = new SnsFactory(snsClient, envConfig);
+    DeviceTokenService deviceTokenService =
+        new DeviceTokenService(tokenRepository, userRepository, snsFactory);
+    UserService userService = new UserService(userRepository);
+    InvalidEndpointCleaner invalidEndpointCleaner =
+        new InvalidEndpointCleaner(userService, deviceTokenService, notificationService);
     this.userService = new UserService(userRepository);
     this.historyService = new HistoryService(historyRepository);
-    this.deviceTokenService = new DeviceTokenService(tokenRepository);
+    this.deviceTokenService = new DeviceTokenService(tokenRepository, userRepository, snsFactory);
     this.notificationService = new NotificationService(snsClient, envConfig);
     this.invalidEndpointCleaner =
         new InvalidEndpointCleaner(

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

@@ -0,0 +1,64 @@
+package com.sopt.push.config;
+
+import com.sopt.push.common.DeviceTokenException;
+import com.sopt.push.common.ErrorMessage;
+import com.sopt.push.enums.Platform;
+import lombok.extern.slf4j.Slf4j;
+import software.amazon.awssdk.services.sns.SnsClient;
+import software.amazon.awssdk.services.sns.model.CreatePlatformEndpointRequest;
+import software.amazon.awssdk.services.sns.model.CreatePlatformEndpointResponse;
+import software.amazon.awssdk.services.sns.model.SubscribeRequest;
+import software.amazon.awssdk.services.sns.model.SubscribeResponse;
+
+@Slf4j
+public class SnsFactory {
+
+  private final SnsClient snsClient;
+  private final String allTopicArn;
+  private static final String PLATFORM_APPLICATION_IOS_ENV = "PLATFORM_APPLICATION_iOS";
+  private static final String PLATFORM_APPLICATION_ANDROID_ENV = "PLATFORM_APPLICATION_ANDROID";
+
+  public SnsFactory(SnsClient snsClient, EnvConfig envConfig) {
+    this.snsClient = snsClient;
+    this.allTopicArn = envConfig.getAllTopicArn();
+  }
+
+  public SubscribeResponse subscribe(String endpointArn) {
+    SubscribeRequest request =
+        SubscribeRequest.builder()
+            .protocol("application")
+            .endpoint(endpointArn)
+            .topicArn(allTopicArn)
+            .build();
+
+    return snsClient.subscribe(request);
+  }
+
+  public CreatePlatformEndpointResponse registerEndPoint(
+      String deviceToken, Platform platform, String userId) {
+    String platformApplicationArn = getPlatformApplicationArn(platform);
+
+    CreatePlatformEndpointRequest.Builder requestBuilder =
+        CreatePlatformEndpointRequest.builder()
+            .platformApplicationArn(platformApplicationArn)
+            .token(deviceToken);
+
+    if (userId != null && !userId.isBlank()) {
+      requestBuilder.customUserData(userId);
+    }
+
+    CreatePlatformEndpointRequest request = requestBuilder.build();
+    return snsClient.createPlatformEndpoint(request);
+  }
+
+  private String getPlatformApplicationArn(Platform platform) {
+    String envVar =
+        platform == Platform.IOS ? PLATFORM_APPLICATION_IOS_ENV : PLATFORM_APPLICATION_ANDROID_ENV;
+    String value = System.getenv(envVar);
+    if (value == null || value.isBlank()) {
+      throw new DeviceTokenException(
+          ErrorMessage.PLATFORM_APP_ARN_NOT_SET, "Platform application ARN not set: " + envVar);
+    }
+    return value;
+  }
+}

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/DeleteTokenDto.java

@@ -0,0 +1,5 @@
+package com.sopt.push.dto;
+
+import java.util.Set;
+
+public record DeleteTokenDto(String deviceToken, Set<String> userIds) {}

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

@@ -0,0 +1,39 @@
+package com.sopt.push.dto;
+
+import com.sopt.push.enums.Actions;
+import com.sopt.push.enums.Category;
+import com.sopt.push.enums.NotificationStatus;
+import com.sopt.push.enums.NotificationType;
+import com.sopt.push.enums.Platform;
+import com.sopt.push.enums.Services;
+import java.util.Set;
+
+public record LogCreateRequestDto(
+    String transactionId,
+    String entity,
+    String title,
+    String content,
+    String deviceToken,
+    String webLink,
+    String applink,
+    NotificationType notificationType,
+    Services orderServiceName,
+    NotificationStatus status,
+    Actions action,
+    Platform platform,
+    Category category,
+    String errorCode,
+    String errorMessage,
+    Set<String> userIds,
+    Set<String> messageIds,
+    String id) {
+  private static final String NULL = "NULL";
+
+  private static String nvl(String v) {
+    return (v == null || v.isBlank()) ? NULL : v;
+  }
+
+  private static Set<String> normalizeSet(Set<String> s) {
+    return (s == null || s.isEmpty()) ? Set.of(NULL) : s;
+  }
+}

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

@@ -0,0 +1,15 @@
+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) {
+
+  public RegisterHeaderDto {
+    if ((action == Actions.REGISTER || action == Actions.CANCEL) && platform == null) {
+      throw new IllegalArgumentException("Platform is required for REGISTER and CANCEL actions");
+    }
+  }
+}

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

@@ -0,0 +1,5 @@
+package com.sopt.push.dto;
+
+import java.util.Set;
+
+public record RegisterUserDto(String deviceToken, Set<String> userIds) {}

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

@@ -0,0 +1,6 @@
+package com.sopt.push.dto;
+
+import com.sopt.push.enums.Category;
+
+public record SendAllPushDto(
+    String title, String content, Category category, String deepLink, String webLink) {}

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

@@ -0,0 +1,12 @@
+package com.sopt.push.dto;
+
+import com.sopt.push.enums.Category;
+import java.util.Set;
+
+public record SendPushDto(
+    Set<String> userIds,
+    String title,
+    String content,
+    Category category,
+    String deepLink,
+    String webLink) {}