Mina Choi
94551afdaf
가입 한 번이 회사를 하나 만들고 사장님이 그 회사의 직원이 됐다. 가입 폼은 "상호"를 묻고
에디터 헤더에는 "이름 · 회사명" 이 붙었다 — 쓰는 사람은 사장님 한 명인데.
negodata 보일러플레이트의 멀티테넌트 스코프 키를 그대로 물려받은 것이고,
DECISIONS.md 2절이 "대행사/운영사 단위로 그대로 쓴다" 로 유지 결정을 적어 뒀던 자리다.
- gmodel: `UserInfo.company_id` 삭제 — JWT 클레임에서도 사라진다. 스코프 키는 `user_id` 다
- place_crud·site_crud: WHERE 를 `places.owner_user_id` 로. `list_company_sites` → `list_owner_sites`
- place_service: **주인은 토큰이 정한다.** `Req_CreatePlace.owner_user_id` 를 없앴다 —
body 로 받으면 남의 계정을 적어 만들자마자 남의 목록에 넣을 수 있다.
실측: 기존 92건은 아무도 안 보내서 전부 NULL 이었고 스코프는 회사가 대신 하고 있었다
- 워커(collect·copy·build·vision): 잡 페이로드 키 `company_id` → `owner_user_id`.
잡이 세우는 `UserInfo.user_id` 는 이제 **사업장 주인**이다 — 예전엔 요청자·검증자·랜덤 uuid
순으로 채웠는데, 그 랜덤 uuid 가 스코프 키가 되는 순간 "남의 사업장" 이라 fact 조회가 0건이 된다
- auth: `Res_Me.company` · `Req_Signup.company_name` · `CompanyData` 삭제
- models·init.sql: `company.companies` 테이블 · `users.company_id` 삭제,
`places.owner_user_id` NOT NULL. 마이그레이션은 백필 → NOT NULL → DROP 순서다.
회사에 계정이 여럿이면 **가장 먼저 만든 계정**에게 몰고, 주인을 못 찾은 행은 지운다 —
스코프가 없으면 아무에게도 안 보이는 유령이다.
실측(로컬): place 92 → 91(고아 1건 삭제), `demoebf050` 56 · `test` 35
- 프론트: 가입 폼의 상호 칸, 내 정보의 상호 항목, 헤더의 "이름 · 회사명" 삭제
- 테스트: `company_id`/`other_company_id` 픽스처 → `owner_id` 하나.
격리는 `auth_headers("o2")` 를 한 번 더 부르면 그게 남이다
남긴 것 — DB 스키마 이름 `company` 는 그대로다. rename 은 모든 모델의 `__table_args__` 를
건드려야 해서 이번 변경에 섞지 않았다.
검증: 전체 568 passed(실패 1건은 HEAD 에서도 깨지는 레이트리밋 테스트) ·
프론트 tsc+eslint 통과 · 실제 API 로 가입→사업장→목록→격리→발행 한 바퀴
Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com>
Claude-Session: https://claude.ai/code/session_01QLWEFx4X3XRmKewUKjJWow
215 lines
10 KiB
Python
215 lines
10 KiB
Python
"""places 도메인 e2e — 등록 / 동일 업소 검증 / 사장님 스코프 / 채널 URL 확정 게이트.
|
|
|
|
★ 이 도메인의 핵심 규칙 두 개를 고정한다:
|
|
1. 검증(verify) 전에는 채널 URL 을 확정할 수 없다 → 크롤링이 안 열린다
|
|
2. 남의 사업장은 '없음'으로 보인다
|
|
"""
|
|
import uuid
|
|
|
|
from common.enums import ErrorType, LinkChannel, PlaceCategory, SourceType
|
|
|
|
|
|
async def _create_place(client, headers, name="테스트펜션", category=PlaceCategory.LODGING):
|
|
r = await client.post("/v1/place", headers=headers, json={"name": name, "category": category.value})
|
|
assert r.status_code == 200, r.text
|
|
return r.json()
|
|
|
|
|
|
async def test_create_place_starts_unverified(auth_headers, client):
|
|
"""검증: 상호명만으로 사업장을 등록한다.
|
|
기대결과: 생성되고 status=DRAFT, verified_at 없음 — 아직 수집이 열리지 않은 상태."""
|
|
h = await auth_headers("u1")
|
|
body = await _create_place(client, h)
|
|
|
|
assert body["result"]["success"] is True
|
|
assert body["place"]["name"] == "테스트펜션"
|
|
assert body["place"]["status"] == 1 # PlaceStatus.DRAFT
|
|
assert body["place"].get("verified_at") is None # RemoveNoneResponse 로 아예 빠진다
|
|
|
|
|
|
async def test_create_place_rejects_blank_name(auth_headers, client):
|
|
"""검증: 빈 상호명으로 등록.
|
|
기대결과: INVALID_REQUEST_DATA(101)."""
|
|
h = await auth_headers("u1")
|
|
r = await client.post("/v1/place", headers=h, json={"name": " ", "category": 1})
|
|
assert r.json()["result"]["code"] == ErrorType.INVALID_REQUEST_DATA.value
|
|
|
|
|
|
async def test_verify_place_opens_collection(auth_headers, client):
|
|
"""검증: 카카오 로컬 결과로 동일 업소를 확정한다.
|
|
기대결과: external_place_id·주소·행정구역코드가 박히고 verified_at 이 찍힌다."""
|
|
h = await auth_headers("u1")
|
|
pid = (await _create_place(client, h))["place"]["place_id"]
|
|
|
|
r = await client.post(
|
|
f"/v1/place/{pid}/verify",
|
|
headers=h,
|
|
json={
|
|
"external_place_id": "26338954",
|
|
"road_address": "강원특별자치도 양양군 현북면 하조대해안길 3",
|
|
"phone": "033-672-0000",
|
|
"latitude": "38.0451234",
|
|
"longitude": "128.6712345",
|
|
"region_code": "4283025",
|
|
},
|
|
)
|
|
body = r.json()
|
|
assert body["result"]["success"] is True
|
|
assert body["place"]["external_place_id"] == "26338954"
|
|
assert body["place"]["region_code"] == "4283025"
|
|
assert body["place"]["verified_at"] is not None
|
|
|
|
|
|
async def test_duplicate_kakao_place_is_allowed(auth_headers, client):
|
|
"""검증: 같은 사장님이 같은 카카오 장소를 두 사업장에 붙인다.
|
|
기대결과: 둘 다 등록된다 — 한 사용자가 같은 실제 업장으로 여러 프로젝트를 만들 수 있다."""
|
|
h = await auth_headers("u1")
|
|
first = (await _create_place(client, h, "A펜션"))["place"]["place_id"]
|
|
second = (await _create_place(client, h, "A펜션(중복)"))["place"]["place_id"]
|
|
|
|
await client.post(f"/v1/place/{first}/verify", headers=h, json={"external_place_id": "111"})
|
|
r = await client.post(f"/v1/place/{second}/verify", headers=h, json={"external_place_id": "111"})
|
|
assert r.json()["result"]["success"] is True
|
|
|
|
|
|
async def test_naver_verify_without_external_id(auth_headers, client):
|
|
"""검증: 네이버로 검증한다 — 고유 장소 id 가 없고 도로명주소만 있다.
|
|
기대결과: 확정된다 — 네이버는 카카오 같은 고유 id 를 주지 않으므로 주소가 식별 근거다."""
|
|
h = await auth_headers("u1")
|
|
body = await _create_place(client, h, "핑크비치펜션")
|
|
pid = body["place"]["place_id"]
|
|
|
|
r = await client.post(f"/v1/place/{pid}/verify", headers=h, json={
|
|
"source": 2, # ExternalPlaceSource.NAVER
|
|
"road_address": "강원특별자치도 양양군 현북면 하조대3길 11",
|
|
"latitude": "38.0219217", "longitude": "128.7221449",
|
|
})
|
|
place = r.json()["place"]
|
|
assert r.json()["result"]["success"] is True
|
|
assert place["verified_at"] is not None
|
|
assert place["external_source"] == 2
|
|
assert place.get("external_place_id") is None
|
|
|
|
|
|
async def test_naver_duplicate_name_and_address_is_allowed(auth_headers, client):
|
|
"""검증: 고유 id 없이 같은 상호명·같은 도로명주소로 두 번 등록한다.
|
|
기대결과: 둘 다 등록된다."""
|
|
h = await auth_headers("u1")
|
|
addr = "강원특별자치도 양양군 현북면 하조대3길 11"
|
|
first = (await _create_place(client, h, "핑크비치펜션"))["place"]["place_id"]
|
|
second = (await _create_place(client, h, "핑크비치펜션"))["place"]["place_id"]
|
|
|
|
await client.post(f"/v1/place/{first}/verify", headers=h, json={"source": 2, "road_address": addr})
|
|
r = await client.post(f"/v1/place/{second}/verify", headers=h, json={"source": 2, "road_address": addr})
|
|
assert r.json()["result"]["success"] is True
|
|
|
|
|
|
async def test_delete_place_removes_it_from_list(auth_headers, client):
|
|
"""사업장을 삭제하면 단건 조회와 목록에서 모두 사라진다."""
|
|
h = await auth_headers("u1")
|
|
pid = (await _create_place(client, h, "삭제할 사업장"))["place"]["place_id"]
|
|
|
|
deleted = await client.delete(f"/v1/place/{pid}", headers=h)
|
|
assert deleted.json()["result"]["success"] is True
|
|
|
|
fetched = await client.get(f"/v1/place/{pid}", headers=h)
|
|
assert fetched.json()["result"]["code"] == ErrorType.PLACE_NOT_FOUND.value
|
|
|
|
|
|
async def test_same_address_different_business_is_allowed(auth_headers, client):
|
|
"""검증: 같은 건물(같은 도로명주소)에 상호명이 다른 두 가게를 등록한다.
|
|
기대결과: 둘 다 통과 — ★ 한 건물에 카페와 식당이 같이 있다. 주소만으로 막으면 안 된다."""
|
|
h = await auth_headers("u1")
|
|
addr = "서울특별시 강남구 테헤란로 1"
|
|
a = (await _create_place(client, h, "1층카페"))["place"]["place_id"]
|
|
b = (await _create_place(client, h, "2층식당"))["place"]["place_id"]
|
|
|
|
assert (await client.post(f"/v1/place/{a}/verify", headers=h, json={"source": 2, "road_address": addr})).json()["result"]["success"] is True
|
|
assert (await client.post(f"/v1/place/{b}/verify", headers=h, json={"source": 2, "road_address": addr})).json()["result"]["success"] is True
|
|
|
|
|
|
async def test_verify_without_any_identifier_is_rejected(auth_headers, client):
|
|
"""검증: 고유 id 도 주소도 없이 확정을 시도한다.
|
|
기대결과: PLACE_VERIFY_NO_CANDIDATE — 식별 근거가 없으면 '그 가게'라고 말할 수 없다."""
|
|
h = await auth_headers("u1")
|
|
pid = (await _create_place(client, h))["place"]["place_id"]
|
|
|
|
r = await client.post(f"/v1/place/{pid}/verify", headers=h, json={"source": 2, "phone": "033-000-0000"})
|
|
assert r.json()["result"]["code"] == ErrorType.PLACE_VERIFY_NO_CANDIDATE.value
|
|
|
|
|
|
async def test_place_is_scoped_to_owner(auth_headers, client):
|
|
"""검증: 다른 사장님 계정으로 남의 사업장을 조회한다.
|
|
기대결과: PLACE_NOT_FOUND — 존재 자체가 보이지 않는다(IDOR 차단)."""
|
|
h1 = await auth_headers("owner1")
|
|
pid = (await _create_place(client, h1))["place"]["place_id"]
|
|
|
|
h2 = await auth_headers("owner2")
|
|
r = await client.get(f"/v1/place/{pid}", headers=h2)
|
|
assert r.json()["result"]["code"] == ErrorType.PLACE_NOT_FOUND.value
|
|
|
|
|
|
async def test_link_cannot_be_confirmed_before_place_verified(auth_headers, client):
|
|
"""검증: 동일 업소 검증 전에 채널 URL 을 확정하려 한다.
|
|
기대결과: PLACE_NOT_VERIFIED — ★ 검증 없이는 크롤링이 열리지 않는다."""
|
|
h = await auth_headers("u1")
|
|
pid = (await _create_place(client, h))["place"]["place_id"]
|
|
|
|
r = await client.post(
|
|
f"/v1/place/{pid}/link",
|
|
headers=h,
|
|
json={"channel": LinkChannel.YANOLJA.value, "url": "https://www.yanolja.com/pension/1", "discovered_by": SourceType.API.value},
|
|
)
|
|
link_id = r.json()["link"]["link_id"]
|
|
|
|
r = await client.post(f"/v1/place/{pid}/link/{link_id}/confirm", headers=h)
|
|
assert r.json()["result"]["code"] == ErrorType.PLACE_NOT_VERIFIED.value
|
|
|
|
|
|
async def test_confirmed_link_becomes_crawl_target(auth_headers, client):
|
|
"""검증: 검증 통과 후 채널 URL 을 확정한다.
|
|
기대결과: confirmed_at 이 찍히고 confirmed_only 목록에 나타난다(= 크롤링 대상)."""
|
|
h = await auth_headers("u1")
|
|
pid = (await _create_place(client, h))["place"]["place_id"]
|
|
await client.post(f"/v1/place/{pid}/verify", headers=h, json={"external_place_id": "222"})
|
|
|
|
r = await client.post(
|
|
f"/v1/place/{pid}/link",
|
|
headers=h,
|
|
json={"channel": LinkChannel.NAVER_PLACE.value, "url": "https://place.naver.com/1", "discovered_by": SourceType.API.value},
|
|
)
|
|
link_id = r.json()["link"]["link_id"]
|
|
|
|
# 확정 전에는 크롤링 대상이 아니다
|
|
r = await client.get(f"/v1/place/{pid}/link/list", headers=h, params={"confirmed_only": True})
|
|
assert r.json().get("links", []) == []
|
|
|
|
assert (await client.post(f"/v1/place/{pid}/link/{link_id}/confirm", headers=h)).json()["result"]["success"] is True
|
|
|
|
r = await client.get(f"/v1/place/{pid}/link/list", headers=h, params={"confirmed_only": True})
|
|
body = r.json()
|
|
assert len(body["links"]) == 1
|
|
assert body["links"][0]["confirmed_at"] is not None
|
|
|
|
|
|
async def test_confirm_link_twice_is_rejected(auth_headers, client):
|
|
"""검증: 이미 확정된 링크를 다시 확정한다.
|
|
기대결과: LINK_NOT_FOUND — 조건부 UPDATE 가 0행이라 동시 처리에도 안전하다."""
|
|
h = await auth_headers("u1")
|
|
pid = (await _create_place(client, h))["place"]["place_id"]
|
|
await client.post(f"/v1/place/{pid}/verify", headers=h, json={"external_place_id": "333"})
|
|
r = await client.post(f"/v1/place/{pid}/link", headers=h, json={"channel": 1, "url": "https://x.test/1"})
|
|
link_id = r.json()["link"]["link_id"]
|
|
|
|
await client.post(f"/v1/place/{pid}/link/{link_id}/confirm", headers=h)
|
|
r = await client.post(f"/v1/place/{pid}/link/{link_id}/confirm", headers=h)
|
|
assert r.json()["result"]["code"] == ErrorType.LINK_NOT_FOUND.value
|
|
|
|
|
|
async def test_unknown_place_returns_not_found(auth_headers, client):
|
|
"""검증: 없는 place_id 조회.
|
|
기대결과: PLACE_NOT_FOUND."""
|
|
h = await auth_headers("u1")
|
|
r = await client.get(f"/v1/place/{uuid.uuid4()}", headers=h)
|
|
assert r.json()["result"]["code"] == ErrorType.PLACE_NOT_FOUND.value
|