Refactor: 문서 목록 CQRS Read Model 전환 및 Domain Event Outbox 추가

build.gradle

@@ -25,7 +25,8 @@ repositories {
 
 test {
     testLogging {
-        events "passed", "skipped", "failed", "standardOut", "standardError"
+        events "skipped", "failed"
+        showStandardStreams = false
         exceptionFormat "full"
         showCauses true
         showExceptions true

infra/scripts/backfill-doc-list-local.sh

@@ -0,0 +1,23 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+ROOT_DIR="$(cd "$(dirname "${BASH_SOURCE[0]}")/../.." && pwd)"
+ENV_FILE="${ENV_FILE:-"$ROOT_DIR/infra/.local.env"}"
+
+if [[ ! -f "$ENV_FILE" ]]; then
+  echo "env file not found: $ENV_FILE" >&2
+  exit 1
+fi
+
+set -a
+# shellcheck disable=SC1090
+source "$ENV_FILE"
+set +a
+
+export SPRING_PROFILES_ACTIVE="${BACKFILL_PROFILES:-local,backfill}"
+export DDL_AUTO="${BACKFILL_DDL_AUTO:-none}"
+export MONGO_LOCAL_CLEANUP_ENABLED="false"
+export PERF_SEED_USER_COUNT="0"
+export DOC_LIST_READ_MODEL_BACKFILL_BATCH_SIZE="${DOC_LIST_READ_MODEL_BACKFILL_BATCH_SIZE:-100}"
+
+bash "$ROOT_DIR/gradlew" bootRun

infra/scripts/cert_renew.sh

@@ -11,19 +11,21 @@ ENV_FILE="$ROOT/docsa-alert.env"
 notify_slack () {
   local msg="$1"
   [[ -z "${SLACK_WEBHOOK_URL:-}" ]] && return 0
+
+  local payload
+  payload="$(python3 -c 'import json, sys; print(json.dumps({"text": sys.argv[1]}))' "$msg")"
+
   curl -sS -X POST -H 'Content-type: application/json' \
-    --data "{\"text\":${msg@Q}}" \
+    --data "$payload" \
     "$SLACK_WEBHOOK_URL" >/dev/null 2>&1 || true
 }
 
 # ---- 1) certbot renew 실행 ----
 out="$(
   docker compose run --rm --no-deps certbot_renew \
-    certbot renew --webroot -w /var/www/certbot 2>&1 || true
+    renew --webroot -w /var/www/certbot 2>&1 || true
 )"
 
-echo "$out"
-
 # ---- 2) 실패 감지 ----
 # certbot이 실패할 때 자주 나오는 문구 위주로 (오탐 줄임)
 if echo "$out" | grep -Eqi \

src/main/java/io/ejangs/docsa/DocsaApplication.java

@@ -4,7 +4,6 @@
 import io.swagger.v3.oas.annotations.info.Info;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.scheduling.annotation.EnableAsync;
 import org.springframework.scheduling.annotation.EnableScheduling;
 
 @OpenAPIDefinition(
@@ -14,7 +13,6 @@
                 description = "Docsa의 백엔드 API 명세입니다."
         )
 )
-@EnableAsync
 @EnableScheduling
 @SpringBootApplication
 public class DocsaApplication {

src/main/java/io/ejangs/docsa/domain/branch/app/BranchQueryService.java → src/main/java/io/ejangs/docsa/domain/branch/app/BranchReader.java

@@ -4,18 +4,16 @@
 import io.ejangs.docsa.domain.branch.entity.Branch;
 import io.ejangs.docsa.domain.commit.entity.Commit;
 import io.ejangs.docsa.domain.edge.dto.graph.BranchGraphDto;
-import io.ejangs.docsa.domain.doc.entity.Doc;
 import io.ejangs.docsa.global.exception.CustomException;
 import io.ejangs.docsa.global.exception.errorcode.BranchErrorCode;
-import io.ejangs.docsa.global.util.RenewUpdatedAtHelper;
 import java.util.List;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 @Service
 @RequiredArgsConstructor
-public class BranchQueryService {
+public class BranchReader {
 
     private final BranchRepository branchRepository;
 
@@ -29,31 +27,11 @@ public List<BranchGraphDto> getBranchGraphList(Long docId) {
         return branchRepository.findBranchGraphDtoList(docId);
     }
 
-    public Branch save(Branch branch) {
-        return branchRepository.save(branch);
-    }
-
-    public Branch createBranch(Doc doc, String branchName) {
-        Branch branch = branchRepository.save(Branch.builder().name(branchName).doc(doc).build());
-        RenewUpdatedAtHelper.touch(branch);
-        return branch;
-    }
-
-    public Branch createBranch(Doc doc, String branchName, Commit fromCommit) {
-        Branch branch = Branch.builder().name(branchName).doc(doc).fromCommit(fromCommit).build();
-        return branchRepository.save(branch);
-    }
-
     @Transactional(readOnly = true)
     public boolean existsSubBranchByFromCommitIds(List<Long> commitIds) {
         return branchRepository.existsByFromCommitIdIn(commitIds);
     }
 
-    public void delete(Branch branch) {
-        branchRepository.delete(branch);
-    }
-
-    //TODO: 검증하는 메소드는 별도의 ex.ValidationService로 분리(모든 도메인)
     public void checkBranchInDocOwnedByUser(Long documentId, Long branchId, Long userId) {
         boolean exists =
                 branchRepository.existsByIdAndDocIdAndDocUserId(branchId, documentId, userId);

src/main/java/io/ejangs/docsa/domain/branch/app/BranchService.java

@@ -7,20 +7,17 @@
 import io.ejangs.docsa.domain.branch.dto.response.BranchRenameResponse;
 import io.ejangs.docsa.domain.branch.entity.Branch;
 import io.ejangs.docsa.domain.branch.util.BranchMapper;
-import io.ejangs.docsa.domain.commit.app.CommitQueryService;
+import io.ejangs.docsa.domain.commit.app.CommitReader;
 import io.ejangs.docsa.domain.commit.dao.mongodb.CommitBlockSequenceRepository;
 import io.ejangs.docsa.domain.commit.entity.Commit;
-import io.ejangs.docsa.domain.doc.app.create.DocQueryService;
+import io.ejangs.docsa.domain.doc.app.DocReader;
 import io.ejangs.docsa.domain.edge.app.EdgeService;
 import io.ejangs.docsa.domain.doc.entity.Doc;
 import io.ejangs.docsa.global.exception.CustomException;
 import io.ejangs.docsa.global.exception.errorcode.BranchErrorCode;
 import io.ejangs.docsa.global.exception.errorcode.DocErrorCode;
 import io.ejangs.docsa.global.outbox.mongo.dto.MongoIdsDto;
-import io.ejangs.docsa.global.outbox.mongo.entity.MongoDeleteOutbox.DomainType;
-import io.ejangs.docsa.global.outbox.mongo.entity.MongoDeleteOutbox.OriginType;
-import io.ejangs.docsa.global.outbox.mongo.entity.MongoDeleteOutbox.TriggerType;
-import io.ejangs.docsa.global.outbox.mongo.app.MongoDeleteOutboxFactory;
+import io.ejangs.docsa.global.outbox.mongo.app.MongoDeleteJobEnqueuer;
 import io.ejangs.docsa.global.outbox.mongo.util.MongoDeleteMapper;
 import io.ejangs.docsa.global.util.RenewUpdatedAtHelper;
 
@@ -37,13 +34,14 @@
 @RequiredArgsConstructor
 public class BranchService {
 
-    private final DocQueryService docQueryService;
-    private final BranchQueryService branchQueryService;
-    private final CommitQueryService commitQueryService;
+    private final DocReader docReader;
+    private final BranchReader branchReader;
+    private final BranchWriter branchWriter;
+    private final CommitReader commitReader;
     private final CommitBlockSequenceRepository commitBlockSequenceRepository;
     private final EdgeService edgeService;
     private final BranchCreateOrchestrator branchCreateOrchestrator;
-    private final MongoDeleteOutboxFactory mongoDeleteOutboxFactory;
+    private final MongoDeleteJobEnqueuer mongoDeleteJobEnqueuer;
 
     public BranchCreateResponse createBranch(Long documentId, BranchCreateRequest request,
             Long userId) {
@@ -55,18 +53,18 @@ public BranchCreateResponse createBranch(Long documentId, BranchCreateRequest re
 
     private BranchCreateContext prepareBranchCreateContext(Long documentId,
             BranchCreateRequest request, Long userId) {
-        docQueryService.checkByIdAndUserId(documentId, userId);
+        docReader.checkByIdAndUserId(documentId, userId);
 
         Long fromCommitId = request.fromCommitId();
 
-        Commit fromCommit = commitQueryService.getById(fromCommitId);
+        Commit fromCommit = commitReader.getById(fromCommitId);
         Branch fromBranch = fromCommit.getBranch();
 
         if (!fromBranch.getDoc().getId().equals(documentId)) {
             throw new CustomException(DocErrorCode.COMMIT_NOT_IN_DOCUMENT);
         }
 
-        branchQueryService.checkDuplicatedWithBranchName(documentId, request.name());
+        branchReader.checkDuplicatedWithBranchName(documentId, request.name());
 
 
         return new BranchCreateContext(
@@ -83,8 +81,8 @@ public BranchRenameResponse renameBranch(Long documentId, Long branchId, String
             Long userId) {
 
         // 1. 브랜치 검증
-        branchQueryService.checkBranchInDocOwnedByUser(documentId, branchId, userId);
-        Branch branch = branchQueryService.getById(branchId);
+        branchReader.checkBranchInDocOwnedByUser(documentId, branchId, userId);
+        Branch branch = branchReader.getById(branchId);
         checkDefaultBranch(branch);
 
         // 2. 브랜치 이름 수정 후 브랜치와 문서의 수정시각 갱신
@@ -105,8 +103,8 @@ public BranchRenameResponse renameBranch(Long documentId, Long branchId, String
     public void deleteBranch(Long documentId, Long branchId, Long userId) {
 
         // 1. 브랜치 검증
-        branchQueryService.checkBranchInDocOwnedByUser(documentId, branchId, userId);
-        Branch branch = branchQueryService.getById(branchId);
+        branchReader.checkBranchInDocOwnedByUser(documentId, branchId, userId);
+        Branch branch = branchReader.getById(branchId);
 
         // 2. main브랜치는 삭제가 불가능하도록 함
         checkDefaultBranch(branch);
@@ -115,7 +113,7 @@ public void deleteBranch(Long documentId, Long branchId, Long userId) {
         List<Commit> branchCommits = branch.getCommits();
         List<Long> commitsIds = branchCommits.stream().map(Commit::getId).toList();
 
-        if (branchQueryService.existsSubBranchByFromCommitIds(commitsIds)) {
+        if (branchReader.existsSubBranchByFromCommitIds(commitsIds)) {
             throw new CustomException(BranchErrorCode.SUB_BRANCH_DELETE_UNAVAILABLE);
         }
 
@@ -133,15 +131,9 @@ public void deleteBranch(Long documentId, Long branchId, Long userId) {
         doc.getBranches().remove(branch);
 
         // 8. 브랜치, 나머지 RDB  브랜치 메타데이터 CASCADE 삭제
-        branchQueryService.delete(branch);
-
-        mongoDeleteOutboxFactory.create(
-                TriggerType.DELETE,
-                DomainType.BRANCH,
-                OriginType.BRANCH_ID,
-                branchId,
-                deletableMongoIds
-        );
+        branchWriter.delete(branch);
+
+        mongoDeleteJobEnqueuer.enqueueBranchDeletion(branchId, deletableMongoIds);
 
     }
 

src/main/java/io/ejangs/docsa/domain/branch/app/BranchWriter.java

@@ -0,0 +1,35 @@
+package io.ejangs.docsa.domain.branch.app;
+
+import io.ejangs.docsa.domain.branch.dao.mysql.BranchRepository;
+import io.ejangs.docsa.domain.branch.entity.Branch;
+import io.ejangs.docsa.domain.commit.entity.Commit;
+import io.ejangs.docsa.domain.doc.entity.Doc;
+import io.ejangs.docsa.global.util.RenewUpdatedAtHelper;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+@Service
+@RequiredArgsConstructor
+public class BranchWriter {
+
+    private final BranchRepository branchRepository;
+
+    public Branch save(Branch branch) {
+        return branchRepository.save(branch);
+    }
+
+    public Branch createBranch(Doc doc, String branchName) {
+        Branch branch = branchRepository.save(Branch.builder().name(branchName).doc(doc).build());
+        RenewUpdatedAtHelper.touch(branch);
+        return branch;
+    }
+
+    public Branch createBranch(Doc doc, String branchName, Commit fromCommit) {
+        Branch branch = Branch.builder().name(branchName).doc(doc).fromCommit(fromCommit).build();
+        return branchRepository.save(branch);
+    }
+
+    public void delete(Branch branch) {
+        branchRepository.delete(branch);
+    }
+}

src/main/java/io/ejangs/docsa/domain/branch/app/create/BranchCreateMySqlTxService.java

@@ -1,12 +1,16 @@
 package io.ejangs.docsa.domain.branch.app.create;
 
-import io.ejangs.docsa.domain.branch.app.BranchQueryService;
+import io.ejangs.docsa.domain.branch.app.BranchWriter;
 import io.ejangs.docsa.domain.branch.dto.BranchCreateContext;
 import io.ejangs.docsa.domain.branch.dto.response.BranchCreateResponse;
 import io.ejangs.docsa.domain.branch.entity.Branch;
 import io.ejangs.docsa.domain.branch.util.BranchMapper;
-import io.ejangs.docsa.domain.save.app.SaveQueryService;
+import io.ejangs.docsa.domain.doc.readmodel.util.DocPayloadFactory;
+import io.ejangs.docsa.domain.save.app.SaveWriter;
 import io.ejangs.docsa.domain.save.entity.Save;
+import io.ejangs.docsa.global.outbox.event.app.DomainEventOutboxPublisher;
+import io.ejangs.docsa.global.outbox.event.model.AggregateType;
+import io.ejangs.docsa.global.outbox.event.model.DomainEventType;
 import io.ejangs.docsa.global.util.RenewUpdatedAtHelper;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
@@ -16,17 +20,21 @@
 @RequiredArgsConstructor
 public class BranchCreateMySqlTxService {
 
-    private final BranchQueryService branchQueryService;
-    private final SaveQueryService saveQueryService;
+    private final BranchWriter branchWriter;
+    private final SaveWriter saveWriter;
+    private final DomainEventOutboxPublisher domainEventOutboxPublisher;
 
     @Transactional(rollbackFor = Exception.class)
     public BranchCreateResponse createMySqlPart(BranchCreateContext context, String saveContentId) {
 
-        Branch newBranch = branchQueryService.createBranch(context.doc(), context.branchName(), context.fromCommit());
+        Branch newBranch = branchWriter.createBranch(context.doc(), context.branchName(), context.fromCommit());
 
-        Save save = saveQueryService.createSave(newBranch, saveContentId);
+        Save save = saveWriter.createSave(newBranch, saveContentId);
         RenewUpdatedAtHelper.touch(save);
 
+        domainEventOutboxPublisher.publish(DomainEventType.DOC_ACTIVITY_CHANGED, AggregateType.DOC, context.doc()
+                .getId(), DocPayloadFactory.activityChanged(context.doc().getId(), save));
+
         return BranchMapper.toBranchCreateResponse(newBranch, save);
     }
 }

src/main/java/io/ejangs/docsa/domain/branch/app/create/BranchCreateOrchestrator.java

@@ -5,10 +5,7 @@
 import io.ejangs.docsa.global.exception.CustomException;
 import io.ejangs.docsa.global.exception.errorcode.BranchErrorCode;
 import io.ejangs.docsa.global.outbox.mongo.dto.MongoIdsDto;
-import io.ejangs.docsa.global.outbox.mongo.entity.MongoDeleteOutbox.DomainType;
-import io.ejangs.docsa.global.outbox.mongo.entity.MongoDeleteOutbox.OriginType;
-import io.ejangs.docsa.global.outbox.mongo.entity.MongoDeleteOutbox.TriggerType;
-import io.ejangs.docsa.global.outbox.mongo.app.MongoDeleteOutboxFactory;
+import io.ejangs.docsa.global.outbox.mongo.app.MongoDeleteJobEnqueuer;
 import java.util.List;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -21,7 +18,7 @@ public class BranchCreateOrchestrator {
 
     private final BranchCreateMongoTxService branchCreateMongoTxService;
     private final BranchCreateMySqlTxService branchCreateMySqlTxService;
-    private final MongoDeleteOutboxFactory mongoDeleteOutboxFactory;
+    private final MongoDeleteJobEnqueuer mongoDeleteJobEnqueuer;
 
     public BranchCreateResponse create(BranchCreateContext context) {
         String saveContentId = branchCreateMongoTxService.createSaveContentFromCommit(
@@ -32,13 +29,7 @@ public BranchCreateResponse create(BranchCreateContext context) {
         } catch (Exception e) {
             log.warn("[SAGA] 브랜치/저장 생성 실패 -> Mongo 삭제 Outbox 기록.", e);
             MongoIdsDto compensateTarget = new MongoIdsDto(List.of(saveContentId), null, null);
-            mongoDeleteOutboxFactory.create(
-                    TriggerType.COMPENSATE,
-                    DomainType.BRANCH,
-                    OriginType.SAVE_CONTENT_ID,
-                    saveContentId,
-                    compensateTarget
-            );
+            mongoDeleteJobEnqueuer.enqueueBranchCreateCompensation(saveContentId, compensateTarget);
             throw new CustomException(BranchErrorCode.FAIL_CREATE_BRANCH);
         }
     }

src/main/java/io/ejangs/docsa/domain/branch/dao/mysql/BranchRepository.java

@@ -2,6 +2,7 @@
 
 import io.ejangs.docsa.domain.edge.dto.graph.BranchGraphDto;
 import io.ejangs.docsa.domain.branch.entity.Branch;
+import io.ejangs.docsa.domain.doc.dto.LatestSaveIdDto;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.data.jpa.repository.Query;
 import org.springframework.data.repository.query.Param;
@@ -28,6 +29,26 @@ public interface BranchRepository extends JpaRepository<Branch, Long> {
 """)
     List<BranchGraphDto> findBranchGraphDtoList(@Param("docId") Long docId);
 
+    @Query("""
+            SELECT new io.ejangs.docsa.domain.doc.dto.LatestSaveIdDto(
+                b.doc.id,
+                s.id
+            )
+            FROM Branch b
+            JOIN b.save s
+            WHERE b.doc.id IN :docIds
+            AND NOT EXISTS (
+                SELECT 1
+                FROM Branch newer
+                WHERE newer.doc.id = b.doc.id
+                AND (
+                    newer.updatedAt > b.updatedAt
+                    OR (newer.updatedAt = b.updatedAt AND newer.id > b.id)
+                )
+            )
+            """)
+    List<LatestSaveIdDto> findLatestSaveIdsByDocIds(@Param("docIds") List<Long> docIds);
+
     boolean existsByIdAndDocIdAndDocUserId(Long branchId, Long documentId, Long userId);
 
     boolean existsByFromCommitIdIn(List<Long> commitIds);