[BE] feature/#253 특정 핀에 대해 내 지도에 저장하기 API

backend/src/docs/asciidoc/topic.adoc

@@ -12,6 +12,9 @@ operation::topic-controller-test/find-bests[snippets='http-request,http-response
 
 operation::topic-controller-test/find-by-id[snippets='http-request,http-response']
 
+=== 최신 토픽 목록 조회
+operation::topic-controller-test/find-all-by-order-by-updated-at-desc[snippets='http-request,http-response']
+
 === 토픽 생성
 
 operation::topic-controller-test/create[snippets='http-request,http-response']
@@ -20,6 +23,9 @@ operation::topic-controller-test/create[snippets='http-request,http-response']
 
 operation::topic-controller-test/merge-and-create[snippets='http-request,http-response']
 
+== 토픽에 핀 추가
+operation::topic-controller-test/copy-pin[snippets='http-request,http-response']
+
 === 토픽 수정
 
 operation::topic-controller-test/update[snippets='http-request,http-response']

backend/src/main/java/com/mapbefine/mapbefine/atlas/application/AtlasCommandService.java

@@ -0,0 +1,74 @@
+package com.mapbefine.mapbefine.atlas.application;
+
+import com.mapbefine.mapbefine.atlas.domain.Atlas;
+import com.mapbefine.mapbefine.atlas.domain.AtlasRepository;
+import com.mapbefine.mapbefine.auth.domain.AuthMember;
+import com.mapbefine.mapbefine.member.domain.Member;
+import com.mapbefine.mapbefine.member.domain.MemberRepository;
+import com.mapbefine.mapbefine.topic.domain.Topic;
+import com.mapbefine.mapbefine.topic.domain.TopicRepository;
+import java.util.NoSuchElementException;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service
+@Transactional
+public class AtlasCommandService {
+
+    private final TopicRepository topicRepository;
+    private final MemberRepository memberRepository;
+    private final AtlasRepository atlasRepository;
+
+    public AtlasCommandService(
+            TopicRepository topicRepository,
+            MemberRepository memberRepository,
+            AtlasRepository atlasRepository
+    ) {
+        this.topicRepository = topicRepository;
+        this.memberRepository = memberRepository;
+        this.atlasRepository = atlasRepository;
+    }
+
+    public void addTopic(AuthMember authMember, Long topicId) {
+        Long memberId = authMember.getMemberId();
+
+        // TODO: 2023/08/10 memberId가 없는 경우 터짐 (Guest인 경우) (단, loginRequired로 일차적으로 막아놓긴 함)
+        if (isTopicAlreadyAdded(topicId, memberId)) {
+            return;
+        }
+
+        Topic topic = findTopicById(topicId);
+        validateReadPermission(authMember, topic);
+
+        Member member = findMemberById(memberId);
+
+        Atlas atlas = Atlas.from(topic, member);
+        atlasRepository.save(atlas);
+    }
+
+    private boolean isTopicAlreadyAdded(Long topicId, Long memberId) {
+        return atlasRepository.existsByMemberIdAndTopicId(memberId, topicId);
+    }
+
+    private Member findMemberById(Long memberId) {
+        return memberRepository.findById(memberId)
+                .orElseThrow(NoSuchElementException::new);
+    }
+
+    private Topic findTopicById(Long topicId) {
+        return topicRepository.findById(topicId)
+                .orElseThrow(NoSuchElementException::new);
+    }
+
+    private void validateReadPermission(AuthMember authMember, Topic topic) {
+        if (authMember.canRead(topic)) {
+            return;
+        }
+        throw new IllegalArgumentException("해당 지도에 접근권한이 없습니다.");
+    }
+
+    public void removeTopic(AuthMember authMember, Long topicId) {
+        atlasRepository.deleteByMemberIdAndTopicId(authMember.getMemberId(), topicId);
+    }
+
+}

backend/src/main/java/com/mapbefine/mapbefine/atlas/application/AtlasQueryService.java

@@ -0,0 +1,30 @@
+package com.mapbefine.mapbefine.atlas.application;
+
+import com.mapbefine.mapbefine.atlas.domain.Atlas;
+import com.mapbefine.mapbefine.atlas.domain.AtlasRepository;
+import com.mapbefine.mapbefine.auth.domain.AuthMember;
+import com.mapbefine.mapbefine.topic.dto.response.TopicResponse;
+import java.util.List;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service
+@Transactional(readOnly = true)
+public class AtlasQueryService {
+
+    private final AtlasRepository atlasRepository;
+
+    public AtlasQueryService(AtlasRepository atlasRepository) {
+        this.atlasRepository = atlasRepository;
+    }
+
+    public List<TopicResponse> findTopicsByMember(AuthMember member) {
+        return atlasRepository.findAllByMemberId(member.getMemberId())
+                .stream()
+                .map(Atlas::getTopic)
+                .filter(member::canRead)
+                .map(TopicResponse::from)
+                .toList();
+    }
+
+}

backend/src/main/java/com/mapbefine/mapbefine/atlas/domain/Atlas.java

@@ -0,0 +1,50 @@
+package com.mapbefine.mapbefine.atlas.domain;
+
+import static lombok.AccessLevel.PROTECTED;
+
+import com.mapbefine.mapbefine.member.domain.Member;
+import com.mapbefine.mapbefine.topic.domain.Topic;
+import jakarta.persistence.Entity;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.Id;
+import jakarta.persistence.JoinColumn;
+import jakarta.persistence.ManyToOne;
+import java.util.Objects;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Entity
+@NoArgsConstructor(access = PROTECTED)
+@Getter
+public class Atlas {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    @ManyToOne
+    @JoinColumn(name = "topic_id", nullable = false)
+    private Topic topic;
+
+    @ManyToOne
+    @JoinColumn(name = "member_id", nullable = false)
+    private Member member;
+
+    private Atlas(Topic topic, Member member) {
+        this.topic = topic;
+        this.member = member;
+    }
+
+    public static Atlas from(Topic topic, Member member) {
+        validateNotNull(topic, member);
+        return new Atlas(topic, member);
+    }
+
+    private static void validateNotNull(Topic topic, Member member) {
+        if (Objects.isNull(topic) || Objects.isNull(member)) {
+            throw new IllegalArgumentException("토픽과 멤버는 Null이어선 안됩니다.");
+        }
+    }
+
+}

backend/src/main/java/com/mapbefine/mapbefine/atlas/domain/AtlasRepository.java

@@ -0,0 +1,15 @@
+package com.mapbefine.mapbefine.atlas.domain;
+
+import java.util.List;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface AtlasRepository extends JpaRepository<Atlas, Long> {
+
+    List<Atlas> findAllByMemberId(Long memberId);
+
+    boolean existsByMemberIdAndTopicId(Long memberId, Long topicId);
+
+    void deleteByMemberIdAndTopicId(Long memberId, Long topicId);
+}

backend/src/main/java/com/mapbefine/mapbefine/atlas/presentation/AtlasController.java

@@ -0,0 +1,54 @@
+package com.mapbefine.mapbefine.atlas.presentation;
+
+import com.mapbefine.mapbefine.atlas.application.AtlasCommandService;
+import com.mapbefine.mapbefine.atlas.application.AtlasQueryService;
+import com.mapbefine.mapbefine.auth.domain.AuthMember;
+import com.mapbefine.mapbefine.common.interceptor.LoginRequired;
+import com.mapbefine.mapbefine.topic.dto.response.TopicResponse;
+import java.util.List;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.DeleteMapping;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping("/atlas")
+public class AtlasController {
+
+    private final AtlasCommandService atlasCommandService;
+    private final AtlasQueryService atlasQueryService;
+
+    public AtlasController(AtlasCommandService atlasCommandService, AtlasQueryService atlasQueryService) {
+        this.atlasCommandService = atlasCommandService;
+        this.atlasQueryService = atlasQueryService;
+    }
+
+    @LoginRequired
+    @GetMapping
+    public ResponseEntity<List<TopicResponse>> findTopicsFromAtlas(AuthMember member) {
+        List<TopicResponse> topicResponses = atlasQueryService.findTopicsByMember(member);
+
+        return ResponseEntity.ok(topicResponses);
+    }
+
+    @LoginRequired
+    @PostMapping("/{topicId}")
+    public ResponseEntity<Void> addTopicToAtlas(AuthMember authMember, @PathVariable Long topicId) {
+        atlasCommandService.addTopic(authMember, topicId);
+
+        return ResponseEntity.status(HttpStatus.CREATED).build();
+    }
+
+    @LoginRequired
+    @DeleteMapping("/{topicId}")
+    public ResponseEntity<Void> removeTopicFromAtlas(AuthMember authMember, @PathVariable Long topicId) {
+        atlasCommandService.removeTopic(authMember, topicId);
+
+        return ResponseEntity.noContent().build();
+    }
+
+}

backend/src/main/java/com/mapbefine/mapbefine/pin/domain/PinRepository.java

@@ -22,4 +22,5 @@ public interface PinRepository extends JpaRepository<Pin, Long> {
 
     List<Pin> findByCreatorId(Long creatorId);
 
+    List<Pin> findAllByOrderByUpdatedAtDesc();
 }

backend/src/main/java/com/mapbefine/mapbefine/topic/application/TopicCommandService.java

@@ -158,6 +158,29 @@ private List<Pin> getAllPinsFromTopics(List<Topic> topics) {
                 .toList();
     }
 
+    public void copyPin(AuthMember member, Long topicId, List<Long> pinIds) {
+        Topic topic = findTopic(topicId);
+        validatePinCreateOrUpdateAuth(member, topic);
+
+        if (pinIds.isEmpty()) {
+            throw new IllegalArgumentException("복사할 핀을 선택해주세요");
+        }
+
+        copyPinsToTopic(member, topic, pinIds);
+    }
+
+    private Topic findTopic(Long topicId) {
+        return topicRepository.findById(topicId)
+                .orElseThrow(() -> new IllegalArgumentException("존재하지 않는 Topic입니다."));
+    }
+
+    private void validatePinCreateOrUpdateAuth(AuthMember member, Topic topic) {
+        if (member.canPinCreateOrUpdate(topic)) {
+            return;
+        }
+        throw new IllegalArgumentException("핀을 추가할 권한이 없습니다.");
+    }
+
     public void updateTopicInfo(
             AuthMember member,
             Long topicId,
@@ -171,16 +194,10 @@ public void updateTopicInfo(
         topic.updateTopicStatus(request.publicity(), request.permission());
     }
 
-    private Topic findTopic(Long topicId) {
-        return topicRepository.findById(topicId)
-                .orElseThrow(() -> new IllegalArgumentException("존재하지 않는 Topic입니다."));
-    }
-
     private void validateUpdateAuth(AuthMember member, Topic topic) {
         if (member.canTopicUpdate(topic)) {
             return;
         }
-
         throw new IllegalArgumentException("업데이트 권한이 없습니다.");
     }
 
@@ -197,7 +214,6 @@ private void validateDeleteAuth(AuthMember member, Topic topic) {
         if (member.canDelete(topic)) {
             return;
         }
-
         throw new IllegalArgumentException("삭제 권한이 없습니다.");
     }
 

backend/src/main/java/com/mapbefine/mapbefine/topic/application/TopicQueryService.java

@@ -1,6 +1,8 @@
 package com.mapbefine.mapbefine.topic.application;
 
 import com.mapbefine.mapbefine.auth.domain.AuthMember;
+import com.mapbefine.mapbefine.pin.domain.Pin;
+import com.mapbefine.mapbefine.pin.domain.PinRepository;
 import com.mapbefine.mapbefine.topic.domain.Topic;
 import com.mapbefine.mapbefine.topic.domain.TopicRepository;
 import com.mapbefine.mapbefine.topic.dto.response.TopicDetailResponse;
@@ -13,9 +15,11 @@
 @Transactional(readOnly = true)
 public class TopicQueryService {
 
+    private final PinRepository pinRepository;
     private final TopicRepository topicRepository;
 
-    public TopicQueryService(final TopicRepository topicRepository) {
+    public TopicQueryService(PinRepository pinRepository, TopicRepository topicRepository) {
+        this.pinRepository = pinRepository;
         this.topicRepository = topicRepository;
     }
 
@@ -75,4 +79,13 @@ private void validateReadableTopics(AuthMember member, List<Topic> topics) {
         }
     }
 
+    public List<TopicResponse> findAllByOrderByUpdatedAtDesc(AuthMember member) {
+        return pinRepository.findAllByOrderByUpdatedAtDesc()
+                .stream()
+                .map(Pin::getTopic)
+                .distinct()
+                .filter(member::canRead)
+                .map(TopicResponse::from)
+                .toList();
+    }
 }

backend/src/main/java/com/mapbefine/mapbefine/topic/presentation/TopicController.java

@@ -58,6 +58,14 @@ public ResponseEntity<Void> mergeAndCreate(
                 .build();
     }
 
+    @LoginRequired
+    @PostMapping("/{topicId}/copy")
+    public ResponseEntity<Void> copyPin(AuthMember member, @PathVariable Long topicId, @RequestParam List<Long> pinIds) {
+        topicCommandService.copyPin(member, topicId, pinIds);
+
+        return ResponseEntity.ok().build();
+    }
+
     @GetMapping
     public ResponseEntity<List<TopicResponse>> findAll(AuthMember member) {
         List<TopicResponse> topics = topicQueryService.findAllReadable(member);
@@ -85,6 +93,13 @@ public ResponseEntity<List<TopicDetailResponse>> findByIds(
         return ResponseEntity.ok(responses);
     }
 
+    @GetMapping("/newest")
+    public ResponseEntity<List<TopicResponse>> findAllByOrderByUpdatedAtDesc(AuthMember member) {
+        List<TopicResponse> responses = topicQueryService.findAllByOrderByUpdatedAtDesc(member);
+
+        return ResponseEntity.ok(responses);
+    }
+
     @LoginRequired
     @PutMapping("/{topicId}")
     public ResponseEntity<Void> update(