feat: 중복 저장 시 PIN_DUPLICATED 알림 발송

[sudosubin]

📌 Related Issue

• 없음

🚀 Description

이미 저장돼 있던 장소를 다시 저장하면 이미 저장해둔 곳이에요 알림을 남깁니다. (PRD [SYS-002] Flow B)

방이 몇 개 중복이었든 장소당 한 건이고, 대상 이름에는 장소명만 싣습니다. 어느 방에서 중복이었는지는 알림함이 알리지 않습니다. (FR-021, EC-019) payload에는 { placeId }만 담아 앱이 장소 상세로 이동하도록 합니다.

중복 판정 기준으로 pins.source_id를 쓰려 했는데, ensureActiveInstagramSource가 게시물 URL 하나에 source 행 하나를 재사용해서 같은 글을 두 번 저장해도 sourceId가 같습니다. 그래서 task payload에 enqueuedAt을 싣고 그보다 먼저 만들어진 핀만 중복으로 봅니다.

이 기준이 필요한 이유는 재배달입니다. 큐는 최대 10회 재시도하고 워커는 핀을 저장한 뒤에도 던질 수 있어서, insert 결과의 차집합으로 판정하면 2회차에 앞선 시도가 넣은 핀이 전부 중복으로 잡힙니다. 재배달은 payload를 그대로 다시 받으므로 enqueuedAt이 같아 이 문제가 없습니다.

sequenceDiagram
    participant CT as Cloud Tasks
    participant W as PlaceWorkerController
    participant Repo as PlaceResultRepository
    participant Notif as NotificationService

    CT->>W: POST /tasks/pins (task)
    W->>Repo: save(task, matches)

    rect rgb(245, 245, 245)
        Note over Repo: 한 트랜잭션
        Repo->>Repo: places upsert
        Repo->>Repo: 기존 활성 핀 조회 (created_at < enqueuedAt)
        Note right of Repo: 핀 insert 전에 읽어야 함
        Repo->>Repo: pins insert (onConflictDoNothing)
    end

    Repo-->>W: duplicatedPlaces
    W->>Notif: PIN_DUPLICATED (장소당 1건)
    Note right of Notif: key에 enqueuedAt 포함, 재배달 시 접힘

Loading

📢 Notes

• enqueuedAt은 optional입니다. 배포 시점에 큐에 남아 있던 옛 task는 판정 기준이 없어 중복을 알리지 않습니다.
• key에 enqueuedAt을 넣어야 같은 글을 다시 저장했을 때 별개 행으로 남습니다. (TS-052)
• 썸네일은 places.images ->> 0으로 읽는데, 현재 places.images를 채우는 코드가 없어서 항상 null입니다. images가 채워지면 코드 변경 없이 동작합니다.

[coderabbitai]

Warning

Review limit reached

Next included review available in 49 minutes.

Check out review usage here.

View limit details

Limit details: You’ve used the included review currently available.

You've used all free OSS reviews for now. Wait for the free limit to reset to keep reviewing this public repository.

Learn how review limits work.

Review configuration:

⚙️ Run configuration

Configuration used: Path: .coderabbit.yaml

Review profile: ASSERTIVE

Plan: Team

Run ID: c211178b-6cf1-4961-883c-6afd4387c61f

📥 Commits

Reviewing files that changed from the base of the PR and between f46bce5 and 46b033f.

📒 Files selected for processing (11)

• e2e/scenarios/place/place.e2e.spec.ts
• e2e/scenarios/place/place.worker.scenarios.ts
• src/common/tasks/pin-extraction-task.dto.ts
• src/modules/notification/notification.repository.ts
• src/modules/notification/notification.service.ts
• src/modules/pin/pin.service.ts
• src/modules/place/place-result.repository.ts
• src/modules/place/place-worker.controller.spec.ts
• src/modules/place/place-worker.controller.ts
• src/modules/place/place.module.ts
• src/modules/place/place.type.ts

---

Thanks for using CodeRabbit! It's free for OSS, and your support helps us grow. If you like it, consider giving us a shout-out.

❤️ Share

• X
• Mastodon
• Reddit
• LinkedIn

_{Comment @coderabbitai help to get the list of available commands.}