클린 아키텍처 리팩토링

src/main/java/com/space/server/common/annotation/PersistenceAdapter.java

@@ -0,0 +1,21 @@
+package com.space.server.common.annotation;
+
+import java.lang.annotation.Documented;
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+import org.springframework.core.annotation.AliasFor;
+import org.springframework.stereotype.Component;
+
+@Target({ElementType.TYPE})
+@Retention(RetentionPolicy.RUNTIME)
+@Documented
+@Component
+public @interface PersistenceAdapter {
+
+  @AliasFor(annotation = Component.class)
+  String value() default "";
+
+}

src/main/java/com/space/server/common/annotation/UseCase.java

@@ -0,0 +1,22 @@
+package com.space.server.common.annotation;
+
+import java.lang.annotation.Documented;
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+import org.springframework.core.annotation.AliasFor;
+import org.springframework.stereotype.Component;
+
+@Target({ElementType.TYPE})
+@Retention(RetentionPolicy.RUNTIME)
+@Documented
+@Component
+public @interface UseCase {
+
+  @AliasFor(annotation = Component.class)
+  String value() default "";
+
+}
+

src/main/java/com/space/server/common/annotation/WebAdapter.java

@@ -0,0 +1,21 @@
+package com.space.server.common.annotation;
+
+import org.springframework.core.annotation.AliasFor;
+import org.springframework.stereotype.Component;
+
+import java.lang.annotation.Documented;
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+@Target({ElementType.TYPE})
+@Retention(RetentionPolicy.RUNTIME)
+@Documented
+@Component
+public @interface WebAdapter {
+
+  @AliasFor(annotation = Component.class)
+  String value() default "";
+
+}

src/main/java/com/space/server/domain/auth/service/implementation/UserJoiner.java

@@ -1,11 +1,11 @@
 package com.space.server.domain.auth.service.implementation;
 
+import com.space.server.domain.inventory.adapter.out.persistence.EquipInventoryAdapter;
+import com.space.server.domain.inventory.application.port.out.CreateInventoryPort;
 import com.space.server.domain.auth.presentation.dto.request.JoinUserRequest;
 import com.space.server.domain.inventory.domain.Inventory;
-import com.space.server.domain.inventory.service.implementation.InventoryCreator;
-import com.space.server.domain.inventory.service.implementation.InventoryUpdater;
+import com.space.server.domain.item.application.port.in.GetItemQuery;
 import com.space.server.domain.item.domain.Item;
-import com.space.server.domain.item.service.implementation.ItemReader;
 import com.space.server.domain.mail.exception.EmailNotVerifiedException;
 import com.space.server.domain.mail.service.EmailTokenService;
 import com.space.server.domain.user.domain.Users;
@@ -23,9 +23,9 @@ public class UserJoiner {
 
     private final UserRepository userRepository;
     private final BCryptPasswordEncoder passwordEncoder;
-    private final InventoryCreator inventoryCreator;
-    private final InventoryUpdater inventoryUpdater;
-    private final ItemReader itemReader;
+    private final CreateInventoryPort createInventoryPort;
+    private final GetItemQuery getItemQuery;
+    private final EquipInventoryAdapter equipInventoryAdapter;
     private final EmailTokenService emailTokenService;
 
     @Transactional
@@ -55,16 +55,13 @@ public void joinProcess(JoinUserRequest joinUserRequest) {
 
         userRepository.save(user);
 
-        Item head = itemReader.findById(1L);
-        Item theme = itemReader.findById(2L);
+        Item head = getItemQuery.getItem(1L);
+        Item theme = getItemQuery.getItem(2L);
 
-        Inventory In_head = new Inventory(head, user);
-        Inventory In_theme = new Inventory(theme, user);
+        Inventory In_head = createInventoryPort.create(head, user);
+        Inventory In_theme = createInventoryPort.create(theme, user);
 
-        inventoryCreator.create(In_head);
-        inventoryCreator.create(In_theme);
-
-        inventoryUpdater.equip(In_head);
-        inventoryUpdater.equip(In_theme);
+        equipInventoryAdapter.equipInventory(In_head);
+        equipInventoryAdapter.equipInventory(In_theme);
     }
 }

src/main/java/com/space/server/domain/chapter/presentation/ChapterController.java → src/main/java/com/space/server/domain/chapter/adapter/in/web/ChapterController.java

@@ -1,7 +1,8 @@
-package com.space.server.domain.chapter.presentation;
+package com.space.server.domain.chapter.adapter.in.web;
 
-import com.space.server.domain.chapter.presentation.dto.response.ChapterResponse;
-import com.space.server.domain.chapter.service.QueryChapterService;
+import com.space.server.domain.chapter.adapter.in.web.dto.response.ChapterResponse;
+import com.space.server.domain.chapter.application.port.in.GetChapterQuery;
+import com.space.server.domain.chapter.application.port.in.GetChaptersQuery;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.Parameter;
 import io.swagger.v3.oas.annotations.tags.Tag;
@@ -16,19 +17,19 @@
 @Tag(name = "Chapter", description = "챕터 API")
 public class ChapterController {
 
-  private final QueryChapterService queryChapterService;
+  private final GetChaptersQuery getChaptersQuery;
+  private final GetChapterQuery getChapterQuery;
 
   @GetMapping("{chapter-id}")
   @Operation(summary = "챕터 조회", description = "해당 챕터를 조회합니다.")
-  public ChapterResponse readOne(
-      @Parameter(description = "챕터 ID", required = true) @PathVariable(name = "chapter-id") Long chapterId) {
-    return ChapterResponse.from(queryChapterService.readOne(chapterId));
+  public ChapterResponse readOne(@Parameter(description = "챕터 ID", required = true) @PathVariable(name = "chapter-id") Long chapterId) {
+    return ChapterResponse.from(getChapterQuery.getChapter(chapterId));
   }
 
   @GetMapping
   @Operation(summary = "모든 챕터 조회", description = "모든 챕터를 조회합니다.")
   public List<ChapterResponse> readAll() {
-    return queryChapterService.readAll().stream()
+    return getChaptersQuery.getChapters().stream()
         .map(ChapterResponse::from)
         .toList();
   }

src/main/java/com/space/server/domain/chapter/presentation/dto/response/ChapterResponse.java → src/main/java/com/space/server/domain/chapter/adapter/in/web/dto/response/ChapterResponse.java

@@ -1,4 +1,4 @@
-package com.space.server.domain.chapter.presentation.dto.response;
+package com.space.server.domain.chapter.adapter.in.web.dto.response;
 
 import com.space.server.domain.chapter.domain.Chapter;
 import io.swagger.v3.oas.annotations.media.Schema;
@@ -19,6 +19,6 @@ public record ChapterResponse(
     Map<String, String> mapObjectImage
 ) {
   public static ChapterResponse from(Chapter chapter) {
-    return new ChapterResponse(chapter.getId(), chapter.getExplanation(), chapter.getMapObject(), chapter.getMapObjectImage());
+    return new ChapterResponse(chapter.getId().getValue(), chapter.getExplanation(), chapter.getMapObject(), chapter.getMapObjectImage());
   }
 }

src/main/java/com/space/server/domain/chapter/adapter/out/persistence/ChapterGetAdapter.java

@@ -0,0 +1,22 @@
+package com.space.server.domain.chapter.adapter.out.persistence;
+
+import com.space.server.common.annotation.PersistenceAdapter;
+import com.space.server.domain.chapter.application.port.out.LoadChapterPort;
+import com.space.server.domain.chapter.domain.Chapter;
+import com.space.server.domain.chapter.exception.ChapterNotFoundException;
+import lombok.RequiredArgsConstructor;
+
+@PersistenceAdapter
+@RequiredArgsConstructor
+public class ChapterGetAdapter implements LoadChapterPort {
+
+  private final ChapterRepository chapterRepository;
+  private final ChapterMapper chapterMapper;
+
+  @Override
+  public Chapter loadChapter(Long chapterId) {
+    return chapterRepository.findById(chapterId)
+        .map(chapterMapper::mapToChapter)
+        .orElseThrow(ChapterNotFoundException::new);
+  }
+}

src/main/java/com/space/server/domain/chapter/adapter/out/persistence/ChapterJpaEntity.java

@@ -0,0 +1,36 @@
+package com.space.server.domain.chapter.adapter.out.persistence;
+
+import io.hypersistence.utils.hibernate.type.basic.PostgreSQLHStoreType;
+import jakarta.persistence.*;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import org.hibernate.annotations.Type;
+
+import java.util.Map;
+
+@Builder
+@Entity
+@Table(name = "chapter")
+@Getter
+@AllArgsConstructor
+@NoArgsConstructor
+public class ChapterJpaEntity {
+
+  @Id
+  @GeneratedValue(strategy = GenerationType.IDENTITY)
+  private Long id;
+
+  @Column
+  private String explanation;
+
+  @Type(PostgreSQLHStoreType.class)
+  @Column(columnDefinition = "hstore")
+  private Map<String, String> mapObject;
+
+  @Type(PostgreSQLHStoreType.class)
+  @Column(columnDefinition = "hstore")
+  private Map<String, String> mapObjectImage;
+
+}

src/main/java/com/space/server/domain/chapter/adapter/out/persistence/ChapterMapper.java

@@ -0,0 +1,26 @@
+package com.space.server.domain.chapter.adapter.out.persistence;
+
+import com.space.server.domain.chapter.domain.Chapter;
+import org.springframework.stereotype.Component;
+
+@Component
+public class ChapterMapper {
+
+  public Chapter mapToChapter(ChapterJpaEntity chapter) {
+    return Chapter.builder()
+        .id(new Chapter.ChapterId(chapter.getId()))
+        .explanation(chapter.getExplanation())
+        .mapObject(chapter.getMapObject())
+        .mapObjectImage(chapter.getMapObjectImage())
+        .build();
+  }
+
+  public ChapterJpaEntity mapToChapterJpaEntity(Chapter chapter) {
+    return ChapterJpaEntity.builder()
+        .id(chapter.getId() == null ? null : chapter.getId().getValue())
+        .explanation(chapter.getExplanation())
+        .mapObject(chapter.getMapObject())
+        .mapObjectImage(chapter.getMapObjectImage())
+        .build();
+  }
+}

src/main/java/com/space/server/domain/chapter/domain/repository/ChapterRepository.java → src/main/java/com/space/server/domain/chapter/adapter/out/persistence/ChapterRepository.java

@@ -1,12 +1,11 @@
-package com.space.server.domain.chapter.domain.repository;
+package com.space.server.domain.chapter.adapter.out.persistence;
 
-import com.space.server.domain.chapter.domain.Chapter;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.stereotype.Repository;
 
 import java.util.List;
 
 @Repository
-public interface ChapterRepository extends JpaRepository<Chapter, Long> {
-  List<Chapter> findAllByOrderById();
+public interface ChapterRepository extends JpaRepository<ChapterJpaEntity, Long> {
+  List<ChapterJpaEntity> findAllByOrderById();
 }

src/main/java/com/space/server/domain/chapter/adapter/out/persistence/ChaptersGetAdapter.java

@@ -0,0 +1,23 @@
+package com.space.server.domain.chapter.adapter.out.persistence;
+
+import com.space.server.common.annotation.PersistenceAdapter;
+import com.space.server.domain.chapter.application.port.out.LoadChaptersPort;
+import com.space.server.domain.chapter.domain.Chapter;
+import lombok.RequiredArgsConstructor;
+
+import java.util.List;
+
+@PersistenceAdapter
+@RequiredArgsConstructor
+public class ChaptersGetAdapter implements LoadChaptersPort {
+
+  private final ChapterRepository chapterRepository;
+  private final ChapterMapper chapterMapper;
+
+  @Override
+  public List<Chapter> loadChapters() {
+    return chapterRepository.findAll().stream()
+        .map(chapterMapper::mapToChapter)
+        .toList();
+  }
+}

src/main/java/com/space/server/domain/chapter/application/port/in/GetChapterQuery.java

@@ -0,0 +1,8 @@
+package com.space.server.domain.chapter.application.port.in;
+
+import com.space.server.domain.chapter.domain.Chapter;
+
+public interface GetChapterQuery {
+
+  Chapter getChapter(Long id);
+}

src/main/java/com/space/server/domain/chapter/application/port/in/GetChaptersQuery.java

@@ -0,0 +1,10 @@
+package com.space.server.domain.chapter.application.port.in;
+
+import com.space.server.domain.chapter.domain.Chapter;
+
+import java.util.List;
+
+public interface GetChaptersQuery {
+
+  List<Chapter> getChapters();
+}

src/main/java/com/space/server/domain/chapter/application/port/out/LoadChapterPort.java

@@ -0,0 +1,8 @@
+package com.space.server.domain.chapter.application.port.out;
+
+import com.space.server.domain.chapter.domain.Chapter;
+
+public interface LoadChapterPort {
+
+  Chapter loadChapter(Long chapterId);
+}

src/main/java/com/space/server/domain/chapter/application/port/out/LoadChaptersPort.java

@@ -0,0 +1,10 @@
+package com.space.server.domain.chapter.application.port.out;
+
+import com.space.server.domain.chapter.domain.Chapter;
+
+import java.util.List;
+
+public interface LoadChaptersPort {
+
+  List<Chapter> loadChapters();
+}

src/main/java/com/space/server/domain/chapter/application/service/GetChapterService.java

@@ -0,0 +1,19 @@
+package com.space.server.domain.chapter.application.service;
+
+import com.space.server.common.annotation.UseCase;
+import com.space.server.domain.chapter.application.port.in.GetChapterQuery;
+import com.space.server.domain.chapter.application.port.out.LoadChapterPort;
+import com.space.server.domain.chapter.domain.Chapter;
+import lombok.RequiredArgsConstructor;
+
+@UseCase
+@RequiredArgsConstructor
+public class GetChapterService implements GetChapterQuery {
+
+  private final LoadChapterPort loadChapterPort;
+
+  @Override
+  public Chapter getChapter(Long chapterId) {
+    return loadChapterPort.loadChapter(chapterId);
+  }
+}

src/main/java/com/space/server/domain/chapter/application/service/GetChaptersService.java

@@ -0,0 +1,21 @@
+package com.space.server.domain.chapter.application.service;
+
+import com.space.server.common.annotation.UseCase;
+import com.space.server.domain.chapter.application.port.in.GetChaptersQuery;
+import com.space.server.domain.chapter.application.port.out.LoadChaptersPort;
+import com.space.server.domain.chapter.domain.Chapter;
+import lombok.RequiredArgsConstructor;
+
+import java.util.List;
+
+@UseCase
+@RequiredArgsConstructor
+public class GetChaptersService implements GetChaptersQuery {
+
+  private final LoadChaptersPort loadChaptersPort;
+
+  @Override
+  public List<Chapter> getChapters() {
+    return loadChaptersPort.loadChapters();
+  }
+}