feat: 유저 충전 api 개발 및 E2E 테스트 개발

Author: yeonjiyeon

apps/commerce-api/src/main/java/com/loopers/domain/point/PointService.java

@@ -2,6 +2,7 @@
 
 import com.loopers.domain.user.User;
 import com.loopers.domain.user.UserRepository;
+import com.loopers.interfaces.api.point.PointV1Dto.PointResponse;
 import com.loopers.support.error.CoreException;
 import com.loopers.support.error.ErrorType;
 import lombok.RequiredArgsConstructor;
@@ -19,10 +20,11 @@ public Integer getPoint(String userId) {
         .orElse(null);
   }
 
-  public void charge(String userId, int amount) {
+  public PointResponse charge(String userId, int amount) {
     User user = userRepository.findByUserId(userId)
         .orElseThrow(() -> new CoreException(ErrorType.NOT_FOUND, "유저를 찾을 수 없습니다."));
+    int chargePoint = user.chargePoint(amount);
 
-    user.chargePoint(amount);
+    return PointResponse.from(chargePoint);
   }
 }

apps/commerce-api/src/main/java/com/loopers/domain/user/User.java

@@ -93,11 +93,11 @@ public int getPoint() {
     return point;
   }
 
-  public void chargePoint(int amount) {
+  public int chargePoint(int amount) {
     if (amount <= 0) {
       throw new CoreException(ErrorType.BAD_REQUEST, "충전 금액은 0보다 커야 합니다.");
     }
 
-    this.point += amount;
+    return this.point += amount;
   }
 }

apps/commerce-api/src/main/java/com/loopers/interfaces/api/point/PointV1ApiSpec.java

@@ -10,8 +10,16 @@ public interface PointV1ApiSpec {
       summary = "포인트 조회",
       description = "헤더의 ID로 보유 포인트를 조회합니다."
   )
-  ApiResponse<PointV1Dto.PointResponse> getPoints(
+  ApiResponse<PointV1Dto.PointResponse> getPoint(
       @Schema(name = "X-USER-ID", description = "조회할 사용자 ID (헤더)")
           String userId
   );
+
+    @Operation(
+      summary = "포인트 충전",
+      description = "ID에 해당하는 사용자의 포인트를 충전합니다."
+  )
+  ApiResponse<PointV1Dto.PointResponse> chargePoint(
+        PointV1Dto.ChargePointsRequest request
+  );
 }

apps/commerce-api/src/main/java/com/loopers/interfaces/api/point/PointV1Controller.java

@@ -2,11 +2,14 @@
 
 import com.loopers.domain.point.PointService;
 import com.loopers.interfaces.api.ApiResponse;
+import com.loopers.interfaces.api.point.PointV1Dto.ChargePointsRequest;
 import com.loopers.interfaces.api.point.PointV1Dto.PointResponse;
 import com.loopers.support.error.CoreException;
 import com.loopers.support.error.ErrorType;
 import lombok.RequiredArgsConstructor;
 import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestHeader;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
@@ -20,12 +23,21 @@ public class PointV1Controller implements PointV1ApiSpec {
 
   @GetMapping()
   @Override
-  public ApiResponse<PointResponse> getPoints(@RequestHeader(value = "X-USER-ID", required = false) String userId) {
+  public ApiResponse<PointResponse> getPoint(@RequestHeader(value = "X-USER-ID", required = false) String userId) {
     if (userId == null || userId.isBlank()) {
       throw new CoreException(ErrorType.BAD_REQUEST, "필수 헤더인 X-USER-ID가 없거나 유효하지 않습니다.");
     }
     Integer point = pointService.getPoint(userId);
     PointResponse response = new PointResponse(point);
     return ApiResponse.success(response);
   }
+
+  @PostMapping()
+  @Override
+  public ApiResponse<PointResponse> chargePoint(@RequestBody ChargePointsRequest request) {
+    PointResponse response = pointService.charge(request.userId(), request.point());
+    return ApiResponse.success(response);
+  }
+
+
 }

apps/commerce-api/src/main/java/com/loopers/interfaces/api/point/PointV1Dto.java

@@ -1,6 +1,20 @@
 package com.loopers.interfaces.api.point;
 
+import jakarta.validation.constraints.NotNull;
+
 public class PointV1Dto {
 
-  public record PointResponse(Integer point) {}
+  public record PointResponse(Integer point) {
+
+    public static PointResponse from(int chargePoint) {
+      return new PointResponse(
+        chargePoint
+      );
+    }
+  }
+
+  public record ChargePointsRequest(
+      @NotNull String userId,
+      @NotNull int point
+  ) {}
 }

apps/commerce-api/src/main/java/com/loopers/interfaces/api/user/UserV1ApiSpec.java

@@ -17,10 +17,10 @@ public interface UserV1ApiSpec {
 
   @Operation(
       summary = "내 정보 조회",
-      description = "헤더의 ID로 내 정보를 조회합니다."
+      description = "유저의 ID로 내 정보를 조회합니다."
   )
   ApiResponse<UserV1Dto.UserResponse> getMyInfo(
-      @Schema(name = "USER-ID", description = "조회할 사용자 ID (헤더)")
+      @Schema(name = "userId-ID", description = "조회할 사용자 ID")
           String userId
   );
 

apps/commerce-api/src/main/java/com/loopers/interfaces/api/user/UserV1Controller.java

@@ -35,7 +35,7 @@ public ApiResponse<UserResponse> getMyInfo(@PathVariable(value = "userId") Strin
     User user = userService.getUser(userId);
 
     if(user == null) {
-      throw new CoreException(ErrorType.NOT_FOUND, "[userId = " + userId + "] 예시를 찾을 수 없습니다.");
+      throw new CoreException(ErrorType.NOT_FOUND, "유저를 찾을 수 없습니다.");
     }
     UserResponse response = UserResponse.from(user);
     return ApiResponse.success(response);

apps/commerce-api/src/test/java/com/loopers/domain/user/UserTest.java

@@ -164,10 +164,10 @@ void chargePoint_with_positive_amount() {
       int expectedPoint = 100;
 
       // act
-      user.chargePoint(chargeAmount);
+      int chargePoint = user.chargePoint(chargeAmount);
 
       // assert
-      assertEquals(expectedPoint, user.getPoint());
+      assertEquals(expectedPoint, chargePoint);
     }
 
     private void assertChargePointFails(int invalidAmount) {

apps/commerce-api/src/test/java/com/loopers/interfaces/api/PointV1ApiE2ETest.java

@@ -1,5 +1,6 @@
 package com.loopers.interfaces.api;
 
+import static org.assertj.core.api.Assertions.assertThat;
 import static org.junit.jupiter.api.Assertions.assertAll;
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertTrue;
@@ -8,6 +9,7 @@
 import com.loopers.domain.user.User.Gender;
 import com.loopers.domain.user.UserRepository;
 import com.loopers.interfaces.api.point.PointV1Dto;
+import com.loopers.interfaces.api.point.PointV1Dto.ChargePointsRequest;
 import com.loopers.utils.DatabaseCleanUp;
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.DisplayName;
@@ -27,6 +29,7 @@
 class PointV1ApiE2ETest {
 
   private static final String ENDPOINT_GET = "/api/v1/point";
+  private static final String ENDPOINT_POST = "/api/v1/point";
 
   private final TestRestTemplate testRestTemplate;
   private final UserRepository userRepository;
@@ -79,6 +82,8 @@ void returnsPoint_whenHeaderIsProvided() {
       );
     }
 
+
+
     @DisplayName("X-USER-ID 헤더가 없을 경우, 400 Bad Request 응답을 반환한다.")
     @Test
     void returnsBadRequest_whenHeaderIsMissing() {
@@ -95,7 +100,62 @@ void returnsBadRequest_whenHeaderIsMissing() {
           () -> assertTrue(response.getStatusCode().is4xxClientError()),
           () -> assertEquals(HttpStatus.BAD_REQUEST, response.getStatusCode())
       );
+    }
+  }
+
+  @DisplayName("Post /api/v1/point")
+  @Nested
+  class Post {
+
+    @DisplayName("존재하는 유저가 1000원을 충전할 경우, 충전된 보유 총량을 응답으로 반환한다.")
+    @Test
+    void returnsPoint_whenHeaderIsProvided() {
+      // arrange
+      int expectedPoint = 1000;
+
+      User user = userRepository.save(
+          new User("validId10", "valid@email.com", "2025-10-28", Gender.FEMALE)
+      );
+
+      ChargePointsRequest request = new ChargePointsRequest(user.getUserId(), expectedPoint);
+
+      // act
+      ParameterizedTypeReference<ApiResponse<PointV1Dto.PointResponse>> responseType = new ParameterizedTypeReference<>() {};
+
+      ResponseEntity<ApiResponse<PointV1Dto.PointResponse>> response =
+          testRestTemplate.exchange(ENDPOINT_POST, HttpMethod.POST, new HttpEntity<>(request), responseType);
+
+      // assert
+      assertAll(
+          () -> assertTrue(response.getStatusCode().is2xxSuccessful()),
+          () -> assertThat(response.getBody().data().point()).isEqualTo(expectedPoint)
+      );
+    }
+
+
+
+    @DisplayName("존재하지 않는 유저로 요청할 경우, 404 Not Found 응답을 반환한다.")
+    @Test
+    void returnsPoint_whenHeaderddIsProvided() {
+      // arrange
+      String invalidUserId = "non-existent-user-id";
+      int expectedPoint = 1000;
+
+      ChargePointsRequest request = new ChargePointsRequest(invalidUserId, expectedPoint);
 
+      // act
+      ParameterizedTypeReference<ApiResponse<PointV1Dto.PointResponse>> responseType = new ParameterizedTypeReference<>() {};
+
+      ResponseEntity<ApiResponse<PointV1Dto.PointResponse>> response =
+          testRestTemplate.exchange(ENDPOINT_POST, HttpMethod.POST, new HttpEntity<>(request), responseType);
+
+      // assert
+      assertAll(
+          () -> assertTrue(response.getStatusCode().is4xxClientError()),
+          () -> assertThat(response.getStatusCode()).isEqualTo(HttpStatus.NOT_FOUND)
+      );
     }
   }
+
+
 }