Merge pull request #380 from team-yello/staging

YEL-173 [deploy] v1.21

Author: Lee Euije

src/main/java/com/yello/server/domain/authorization/filter/JwtExceptionFilter.java

@@ -47,6 +47,7 @@ protected void doFilterInternal(
             || requestPath.startsWith("/actuator") || requestPath.startsWith("/prometheus")
             || requestPath.startsWith("/api/v1/admin/login")
             || requestPath.startsWith("/v2/apple/notifications")
+            || requestPath.startsWith("/v2/google/notifications")
             || (requestPath.startsWith("/api/v1/auth")
             && !requestPath.startsWith("/api/v1/auth/token/issue"))) {
             filterChain.doFilter(request, response);
@@ -60,8 +61,8 @@ protected void doFilterInternal(
                 log.info("Authorization-access : {}", accessHeader);
                 log.info("Authorization-refresh : {}", refreshHeader);
 
-                if (accessHeader==null || !accessHeader.startsWith(BEARER)
-                    || refreshHeader==null || !refreshHeader.startsWith(BEARER)) {
+                if (accessHeader == null || !accessHeader.startsWith(BEARER)
+                    || refreshHeader == null || !refreshHeader.startsWith(BEARER)) {
                     throw new CustomAuthenticationException(AUTHENTICATION_ERROR);
                 }
 
@@ -72,7 +73,7 @@ protected void doFilterInternal(
                 val accessHeader = request.getHeader(AUTHORIZATION);
                 log.info("Authorization : {}", accessHeader);
 
-                if (accessHeader==null || !accessHeader.startsWith(BEARER)) {
+                if (accessHeader == null || !accessHeader.startsWith(BEARER)) {
                     throw new CustomAuthenticationException(AUTHENTICATION_ERROR);
                 }
 

src/main/java/com/yello/server/domain/authorization/filter/JwtFilter.java

@@ -40,7 +40,8 @@ protected void doFilterInternal(HttpServletRequest request, HttpServletResponse
             || requestPath.startsWith("/actuator") || requestPath.startsWith("/prometheus")
             || requestPath.startsWith("/api/v1/admin/login")
             || requestPath.startsWith("/api/v1/auth")
-            || requestPath.startsWith("/v2/apple/notifications")) {
+            || requestPath.startsWith("/v2/apple/notifications")
+            || requestPath.startsWith("/v2/google/notifications")) {
             filterChain.doFilter(request, response);
             return;
         }

src/main/java/com/yello/server/domain/purchase/controller/PurchaseNotificationController.java

@@ -1,16 +1,21 @@
 package com.yello.server.domain.purchase.controller;
 
 import static com.yello.server.global.common.SuccessCode.POST_APPLE_NOTIFICATION_SUCCESS;
+import static com.yello.server.global.common.SuccessCode.POST_GOOGLE_NOTIFICATION_SUCCESS;
 
 import com.yello.server.domain.purchase.dto.request.AppleNotificationRequest;
+import com.yello.server.domain.purchase.dto.request.GooglePubSubNotificationRequest;
 import com.yello.server.domain.purchase.service.PurchaseService;
 import com.yello.server.global.common.dto.BaseResponse;
+import com.yello.server.global.common.dto.EmptyObject;
 import com.yello.server.infrastructure.slack.annotation.SlackApplePurchaseNotification;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RestController;
 
+@Slf4j
 @RestController
 @RequiredArgsConstructor
 public class PurchaseNotificationController {
@@ -25,4 +30,12 @@ public BaseResponse appleNotification(
         purchaseService.appleNotification(request);
         return BaseResponse.success(POST_APPLE_NOTIFICATION_SUCCESS);
     }
+
+    @PostMapping("/v2/google/notifications")
+    public BaseResponse<EmptyObject> googleNotification(
+        @RequestBody GooglePubSubNotificationRequest request
+    ) {
+        purchaseService.googleNotification(request);
+        return BaseResponse.success(POST_GOOGLE_NOTIFICATION_SUCCESS, EmptyObject.builder().build());
+    }
 }

src/main/java/com/yello/server/domain/purchase/dto/request/GooglePubSubNotificationRequest.java

@@ -0,0 +1,10 @@
+package com.yello.server.domain.purchase.dto.request;
+
+import com.yello.server.domain.purchase.dto.request.google.GooglePubSubMessage;
+
+public record GooglePubSubNotificationRequest(
+    GooglePubSubMessage message,
+    String subscription
+) {
+
+}

src/main/java/com/yello/server/domain/purchase/dto/request/google/DeveloperNotification.java

@@ -0,0 +1,42 @@
+package com.yello.server.domain.purchase.dto.request.google;
+
+import static com.yello.server.global.common.util.ConstantUtil.GOOGLE_FIVE_TICKET_ID;
+import static com.yello.server.global.common.util.ConstantUtil.GOOGLE_ONE_TICKET_ID;
+import static com.yello.server.global.common.util.ConstantUtil.GOOGLE_TWO_TICKET_ID;
+
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonInclude.Include;
+import com.yello.server.domain.purchase.entity.ProductType;
+import org.springframework.util.ObjectUtils;
+
+@JsonInclude(Include.NON_NULL)
+public record DeveloperNotification(
+    String version,
+    String packageName,
+    Long eventTimeMillis,
+    OneTimeProductNotification oneTimeProductNotification,
+    SubscriptionNotification subscriptionNotification,
+    TestNotification testNotification
+) {
+
+    public ProductType getProductType() {
+        if (!ObjectUtils.isEmpty(testNotification)) {
+            return ProductType.TEST;
+        } else if (!ObjectUtils.isEmpty(subscriptionNotification)) {
+            return ProductType.YELLO_PLUS;
+        } else if (!ObjectUtils.isEmpty(oneTimeProductNotification)) {
+            switch (oneTimeProductNotification.sku()) {
+                case GOOGLE_ONE_TICKET_ID -> {
+                    return ProductType.ONE_TICKET;
+                }
+                case GOOGLE_TWO_TICKET_ID -> {
+                    return ProductType.TWO_TICKET;
+                }
+                case GOOGLE_FIVE_TICKET_ID -> {
+                    return ProductType.FIVE_TICKET;
+                }
+            }
+        }
+        return null;
+    }
+}

src/main/java/com/yello/server/domain/purchase/dto/request/google/GooglePubSubMessage.java

@@ -0,0 +1,15 @@
+package com.yello.server.domain.purchase.dto.request.google;
+
+import java.util.Map;
+import java.util.Optional;
+
+public record GooglePubSubMessage(
+    Optional<Map<String, String>> attributes,
+    String data,
+    Long messageId,
+    Optional<Long> message_id,
+    Optional<String> publishTime,
+    Optional<String> publish_time
+) {
+
+}

src/main/java/com/yello/server/domain/purchase/dto/request/google/OneTimeProductNotification.java

@@ -0,0 +1,10 @@
+package com.yello.server.domain.purchase.dto.request.google;
+
+public record OneTimeProductNotification(
+    String version,
+    OneTimeProductNotificationType notificationType,
+    String purchaseToken,
+    String sku
+) {
+
+}

src/main/java/com/yello/server/domain/purchase/dto/request/google/OneTimeProductNotificationType.java

@@ -0,0 +1,23 @@
+package com.yello.server.domain.purchase.dto.request.google;
+
+import com.google.gson.annotations.SerializedName;
+import lombok.Getter;
+
+@Getter
+public enum OneTimeProductNotificationType {
+    @SerializedName("1")
+    ONE_TIME_PRODUCT_PURCHASED(1),
+    @SerializedName("2")
+    ONE_TIME_PRODUCT_CANCELED(2);
+
+    private final Long value;
+
+    OneTimeProductNotificationType(long value) {
+        this.value = value;
+    }
+
+    @Override
+    public String toString() {
+        return this.name();
+    }
+}

src/main/java/com/yello/server/domain/purchase/dto/request/google/SubscriptionNotification.java

@@ -0,0 +1,10 @@
+package com.yello.server.domain.purchase.dto.request.google;
+
+public record SubscriptionNotification(
+    String version,
+    SubscriptionNotificationType notificationType,
+    String purchaseToken,
+    String subscriptionId
+) {
+
+}

src/main/java/com/yello/server/domain/purchase/dto/request/google/SubscriptionNotificationType.java

@@ -0,0 +1,45 @@
+package com.yello.server.domain.purchase.dto.request.google;
+
+import com.google.gson.annotations.SerializedName;
+import lombok.Getter;
+
+@Getter
+public enum SubscriptionNotificationType {
+    @SerializedName("1")
+    SUBSCRIPTION_RECOVERED(1),
+    @SerializedName("2")
+    SUBSCRIPTION_RENEWED(2),
+    @SerializedName("3")
+    SUBSCRIPTION_CANCELED(3),
+    @SerializedName("4")
+    SUBSCRIPTION_PURCHASED(4),
+    @SerializedName("5")
+    SUBSCRIPTION_ON_HOLD(5),
+    @SerializedName("6")
+    SUBSCRIPTION_IN_GRACE_PERIOD(6),
+    @SerializedName("7")
+    SUBSCRIPTION_RESTARTED(7),
+    @SerializedName("8")
+    SUBSCRIPTION_PRICE_CHANGE_CONFIRMED(8),
+    @SerializedName("9")
+    SUBSCRIPTION_DEFERRED(9),
+    @SerializedName("10")
+    SUBSCRIPTION_PAUSED(10),
+    @SerializedName("11")
+    SUBSCRIPTION_PAUSE_SCHEDULE_CHANGED(11),
+    @SerializedName("12")
+    SUBSCRIPTION_REVOKED(12),
+    @SerializedName("13")
+    SUBSCRIPTION_EXPIRED(13);
+
+    private final Integer value;
+
+    SubscriptionNotificationType(int value) {
+        this.value = value;
+    }
+
+    @Override
+    public String toString() {
+        return this.name();
+    }
+}