코스 추가 기능 구현

backend/src/main/java/coursepick/coursepick/application/CourseApplicationService.java

@@ -2,7 +2,10 @@
 
 import coursepick.coursepick.application.dto.CourseResponse;
 import coursepick.coursepick.application.dto.CoursesResponse;
+import coursepick.coursepick.application.dto.SnapResponse;
 import coursepick.coursepick.domain.course.*;
+import coursepick.coursepick.domain.user.User;
+import coursepick.coursepick.domain.user.UserRepository;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.jspecify.annotations.Nullable;
@@ -13,6 +16,7 @@
 import java.util.List;
 
 import static coursepick.coursepick.application.exception.ErrorType.NOT_EXIST_COURSE;
+import static coursepick.coursepick.application.exception.ErrorType.NOT_EXIST_USER;
 
 @Slf4j
 @Service
@@ -21,6 +25,9 @@ public class CourseApplicationService {
 
     private final CourseRepository courseRepository;
     private final RouteFinder routeFinder;
+    private final CoordinateSnapper coordinateSnapper;
+    private final UserRepository userRepository;
+    private final UserCreatedCourseRepository userCreatedCourseRepository;
 
     @Transactional(readOnly = true)
     public CoursesResponse findNearbyCourses(CourseFindCondition condition, @Nullable Double userLatitude, @Nullable Double userLongitude) {
@@ -67,4 +74,24 @@ private void loggingForNotExistsCourse(List<String> ids, List<Course> courses) {
             }
         }
     }
+
+    @Transactional(readOnly = true)
+    public SnapResponse snapCoordinates(List<Coordinate> coordinates) {
+        SnapResult snapResult = coordinateSnapper.snap(coordinates);
+        return new SnapResponse(snapResult.coordinates(), snapResult.length());
+    }
+
+    @Transactional
+    public CourseResponse create(String userId, String name, List<Coordinate> coordinates) {
+        User user = userRepository.findById(userId)
+                .orElseThrow(() -> NOT_EXIST_USER.create(userId));
+
+        Course course = new Course(null, name, coordinates);
+        Course savedCourse = courseRepository.save(course);
+
+        UserCreatedCourse userCreatedCourse = new UserCreatedCourse(user.id(), savedCourse.id(), false);
+        userCreatedCourseRepository.save(userCreatedCourse);
+
+        return CourseResponse.from(savedCourse);
+    }
 }

backend/src/main/java/coursepick/coursepick/application/dto/SnapResponse.java

@@ -0,0 +1,11 @@
+package coursepick.coursepick.application.dto;
+
+import coursepick.coursepick.domain.course.Coordinate;
+
+import java.util.List;
+
+public record SnapResponse(
+        List<Coordinate> coordinates,
+        double length
+) {
+}

backend/src/main/java/coursepick/coursepick/application/exception/ErrorType.java

@@ -25,6 +25,14 @@ public enum ErrorType {
             "시작과 끝 좌표만 존재할 때 둘은 중복될 수 없습니다.",
             IllegalArgumentException::new
     ),
+    INVALID_ROAD_TYPE(
+            "허용된 길 타입이 아닙니다. [트랙, 트레일, 보도, 알수없음] 입력값=%s",
+            IllegalArgumentException::new
+    ),
+    INVALID_DIFFICULTY(
+            "허용된 난이도가 아닙니다. [쉬움, 보통, 어려움] 입력값=%s",
+            IllegalArgumentException::new
+    ),
     NOT_EXIST_COURSE(
             "코스가 존재하지 않습니다. 코스id=%s",
             NoSuchElementException::new
@@ -49,10 +57,18 @@ public enum ErrorType {
             "잘못된 관리자 비밀번호입니다.",
             SecurityException::new
     ),
+    INVALID_SNAP_COORDINATE_SIZE(
+            "스냅을 위해선 최소 2개 이상의 좌표가 필요합니다.",
+            IllegalArgumentException::new
+    ),
     NOT_FOUND_NOTICE(
             "존재하지 않는 공지 사항입니다. 공지 사항id=%s",
             NoSuchElementException::new
     ),
+    NOT_EXIST_USER(
+            "존재하지 않는 사용자입니다. 유저id=%s",
+            NoSuchElementException::new
+    ),
     AUTHENTICATION_FAIL(
             "인증에 실패하였습니다.",
             UnauthorizedException::new

backend/src/main/java/coursepick/coursepick/domain/course/CoordinateSnapper.java

@@ -4,5 +4,5 @@
 
 public interface CoordinateSnapper {
 
-    List<Coordinate> snap(List<Coordinate> coordinates);
+    SnapResult snap(List<Coordinate> coordinates);
 }

backend/src/main/java/coursepick/coursepick/domain/course/CourseRepository.java

@@ -7,7 +7,7 @@
 
 public interface CourseRepository {
 
-    void save(Course course);
+    Course save(Course course);
 
     void saveAll(Iterable<? extends Course> courses);
 

backend/src/main/java/coursepick/coursepick/domain/course/SnapResult.java

@@ -0,0 +1,9 @@
+package coursepick.coursepick.domain.course;
+
+import java.util.List;
+
+public record SnapResult(
+        List<Coordinate> coordinates,
+        double length
+) {
+}

backend/src/main/java/coursepick/coursepick/domain/course/UserCreatedCourse.java

@@ -0,0 +1,22 @@
+package coursepick.coursepick.domain.course;
+
+import lombok.AccessLevel;
+import lombok.AllArgsConstructor;
+import org.springframework.data.annotation.Id;
+import org.springframework.data.annotation.PersistenceCreator;
+import org.springframework.data.mongodb.core.mapping.Document;
+
+@Document
+@AllArgsConstructor(access = AccessLevel.PROTECTED, onConstructor_ = @PersistenceCreator)
+public class UserCreatedCourse {
+
+    @Id
+    private final String id;
+    private final String userId;
+    private final String courseId;
+    private boolean isPublic;
+
+    public UserCreatedCourse(String userId, String courseId, boolean isPublic) {
+        this(null, userId, courseId, isPublic);
+    }
+}

backend/src/main/java/coursepick/coursepick/domain/course/UserCreatedCourseRepository.java

@@ -0,0 +1,8 @@
+package coursepick.coursepick.domain.course;
+
+import org.springframework.data.repository.Repository;
+
+public interface UserCreatedCourseRepository extends Repository<UserCreatedCourse, String> {
+
+    void save(UserCreatedCourse userCreatedCourse);
+}

backend/src/main/java/coursepick/coursepick/domain/user/UserRepository.java

@@ -8,4 +8,6 @@ public interface UserRepository extends Repository<User, String> {
     User save(User user);
 
     Optional<User> findByProviderAndProviderId(UserProvider provider, String providerId);
+
+    Optional<User> findById(String id);
 }

backend/src/main/java/coursepick/coursepick/infrastructure/mongodb/CourseRepositoryMongoTemplateImpl.java

@@ -27,8 +27,8 @@ public class CourseRepositoryMongoTemplateImpl implements CourseRepository {
     private final MongoTemplate mongoTemplate;
 
     @Override
-    public void save(Course course) {
-        mongoTemplate.save(course);
+    public Course save(Course course) {
+        return mongoTemplate.save(course);
     }
 
     @Override

backend/src/main/java/coursepick/coursepick/infrastructure/snapper/DummyCoordinateSnapper.java

@@ -2,6 +2,7 @@
 
 import coursepick.coursepick.domain.course.Coordinate;
 import coursepick.coursepick.domain.course.CoordinateSnapper;
+import coursepick.coursepick.domain.course.SnapResult;
 import org.springframework.context.annotation.Fallback;
 import org.springframework.stereotype.Component;
 
@@ -12,7 +13,7 @@
 public class DummyCoordinateSnapper implements CoordinateSnapper {
 
     @Override
-    public List<Coordinate> snap(List<Coordinate> coordinates) {
-        return coordinates;
+    public SnapResult snap(List<Coordinate> coordinates) {
+        return new SnapResult(coordinates, 100);
     }
 }

backend/src/main/java/coursepick/coursepick/infrastructure/snapper/OsrmCoordinateSnapper.java

@@ -2,6 +2,7 @@
 
 import coursepick.coursepick.domain.course.Coordinate;
 import coursepick.coursepick.domain.course.CoordinateSnapper;
+import coursepick.coursepick.domain.course.SnapResult;
 import coursepick.coursepick.logging.LogContent;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -17,6 +18,8 @@
 import java.util.stream.Collectors;
 import java.util.stream.IntStream;
 
+import static coursepick.coursepick.application.exception.ErrorType.INVALID_SNAP_COORDINATE_SIZE;
+
 @Slf4j
 @Component
 @Profile({"dev", "prod"})
@@ -26,9 +29,9 @@ public class OsrmCoordinateSnapper implements CoordinateSnapper {
     private final RestClient osrmRestClient;
 
     @Override
-    public List<Coordinate> snap(List<Coordinate> coordinates) {
+    public SnapResult snap(List<Coordinate> coordinates) {
         if (coordinates.size() < 2) {
-            return coordinates;
+            throw INVALID_SNAP_COORDINATE_SIZE.create();
         }
 
         String coordinatesParam = coordinates.stream()
@@ -52,26 +55,29 @@ public List<Coordinate> snap(List<Coordinate> coordinates) {
                     .body(new ParameterizedTypeReference<>() {
                     });
 
-            log.info("OSRM Match 결과: {}", response);
-            return parseMatchResponse(response, coordinates);
+            log.info("[OSRM Snap 결과] {}", response);
+            return parseSnapResponse(response, coordinates);
         } catch (Exception e) {
-            log.warn("[EXCEPTION] OSRM 좌표 매칭 실패", LogContent.exception(e));
-            return coordinates;
+            log.warn("[EXCEPTION] OSRM 좌표 Snap 실패", LogContent.exception(e));
+            return new SnapResult(coordinates, 0);
         }
     }
 
-    private List<Coordinate> parseMatchResponse(Map<String, Object> response, List<Coordinate> originals) {
+    private SnapResult parseSnapResponse(Map<String, Object> response, List<Coordinate> originals) {
         try {
             List<Map<String, Object>> matchings = (List<Map<String, Object>>) response.get("matchings");
             Map<String, Object> geometry = (Map<String, Object>) matchings.get(0).get("geometry");
             List<List<Double>> coordinates = (List<List<Double>>) geometry.get("coordinates");
+            Double length = (Double) matchings.get(0).get("distance");
 
-            return coordinates.stream()
+            List<Coordinate> snappedCoordinates = coordinates.stream()
                     .map(coord -> new Coordinate(coord.get(1), coord.get(0)))
                     .toList();
+
+            return new SnapResult(snappedCoordinates, length);
         } catch (Exception e) {
-            log.warn("[EXCEPTION] OSRM Match 응답 파싱 실패", LogContent.exception(e));
-            return originals;
+            log.warn("[EXCEPTION] OSRM Snap 응답 파싱 실패", LogContent.exception(e));
+            return new SnapResult(originals, 0);
         }
     }
 

backend/src/main/java/coursepick/coursepick/presentation/AdminWebController.java

@@ -144,7 +144,7 @@ public void deleteCourse(@PathVariable("id") String id) {
 
     @PostMapping("/admin/api/coordinates/snap")
     public CoordinatesSnapWebResponse snapCoordinates(@RequestBody @Valid CoordinatesSnapWebRequest request) {
-        List<Coordinate> snapped = coordinateSnapper.snap(request.coordinates());
-        return CoordinatesSnapWebResponse.from(snapped);
+        SnapResult snapResult = coordinateSnapper.snap(request.coordinates());
+        return CoordinatesSnapWebResponse.from(snapResult.coordinates());
     }
 }

backend/src/main/java/coursepick/coursepick/presentation/CoordinateWebController.java

@@ -0,0 +1,34 @@
+package coursepick.coursepick.presentation;
+
+import coursepick.coursepick.application.CourseApplicationService;
+import coursepick.coursepick.application.dto.SnapResponse;
+import coursepick.coursepick.domain.course.Coordinate;
+import coursepick.coursepick.presentation.api.CoordinateWebApi;
+import coursepick.coursepick.presentation.dto.SnapWebRequest;
+import coursepick.coursepick.presentation.dto.SnapWebResponse;
+import coursepick.coursepick.security.Login;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+@RestController
+@RequiredArgsConstructor
+public class CoordinateWebController implements CoordinateWebApi {
+
+    private final CourseApplicationService courseApplicationService;
+
+    @Override
+    @Login
+    @PostMapping("/coordinates/snap")
+    public SnapWebResponse snapCoordinates(@RequestBody SnapWebRequest snapWebRequest) {
+        List<Coordinate> coordinates = snapWebRequest.coordinates().stream()
+                .map(dto -> new Coordinate(dto.latitude(), dto.longitude()))
+                .toList();
+
+        SnapResponse snapResponse = courseApplicationService.snapCoordinates(coordinates);
+        return SnapWebResponse.from(snapResponse);
+    }
+}

backend/src/main/java/coursepick/coursepick/presentation/CourseV1WebController.java

@@ -1,13 +1,17 @@
 package coursepick.coursepick.presentation;
 
 import coursepick.coursepick.application.CourseApplicationService;
+import coursepick.coursepick.application.dto.CourseResponse;
 import coursepick.coursepick.application.dto.CoursesResponse;
 import coursepick.coursepick.domain.course.Coordinate;
 import coursepick.coursepick.domain.course.CourseFindCondition;
 import coursepick.coursepick.presentation.api.CourseWebApi;
 import coursepick.coursepick.presentation.dto.CoordinateWebResponse;
+import coursepick.coursepick.presentation.dto.CourseCreateWebRequest;
 import coursepick.coursepick.presentation.dto.CourseWebResponse;
 import coursepick.coursepick.presentation.dto.CoursesWebResponse;
+import coursepick.coursepick.security.Login;
+import coursepick.coursepick.security.UserId;
 import lombok.RequiredArgsConstructor;
 import org.springframework.web.bind.annotation.*;
 
@@ -66,4 +70,17 @@ public List<CourseWebResponse> findFavoriteCourses(@RequestParam("courseIds") Li
                 .map(CourseWebResponse::from)
                 .toList();
     }
+
+    @Override
+    @Login
+    @PostMapping("/courses/create")
+    public CourseWebResponse create(@UserId String userId, @RequestBody CourseCreateWebRequest courseCreateWebRequest) {
+        List<Coordinate> coordinates = courseCreateWebRequest.coordinates().stream()
+                .map(dto -> new Coordinate(dto.latitude(), dto.longitude()))
+                .toList();
+
+        CourseResponse courseResponse = courseApplicationService.create(userId, courseCreateWebRequest.name(), coordinates);
+
+        return CourseWebResponse.from(courseResponse);
+    }
 }