king
07626bcaf8
상세설명 API 경로가 틀려 있던 것을 실물 확인으로 바로잡았다.
`/admin/products/{no}/description` 은 존재하지 않는다(운영몰 호출 결과
`No API found.`). 상세설명은 상품 리소스의 필드이므로 GET/PUT 을
`/admin/products/{no}` 로 옮겼고, PUT body 는 {"request": {...}} 다.
PC/모바일 상세설명이 별도 필드라는 것도 확인됐다. `separated_mobile_description`
('T'/'F') 이 분리 사용 여부이며, 미분리 상품을 수정할 때 description 만 바꾸면
모바일이 어긋난다. Descriptions 데이터클래스에 이 플래그와 불일치 여부를 담아
화면에서 경고로 노출한다.
목록 응답에는 description 이 없어(확인됨) 상세설명은 상품 1건씩 조회한다.
그래서 목록 화면에 미리보기를 뿌리지 않는다 — 상품 87개면 87호출이라 호출
제한에 걸린다.
화면은 읽기 전용이다(편집·적용은 Phase 3~4). 목록은 카페24를 매번 조회해
현재값을 보여주고, 결과를 cafe24_products 에 UPSERT 해둔다(예약·로그 화면에서
API 없이 상품명을 쓰기 위함).
상단 탭의 예약관리가 404 였으므로 Phase 5 안내 화면을 붙였다.
토큰 만료 시각이 화면에 +00:00 로 보이던 것도 고쳤다. 컬럼이 timestamptz 라
psycopg 가 UTC 로 돌려주는 값을 그대로 출력하고 있었다(시각 자체는 정확했다).
검증: 유닛테스트 23개 통과(신규 7개 — 상세설명 경로가 /description 으로
되돌아가지 않는지, PUT payload 모양, 미분리 플래그 파싱, 페이징 clamp).
라우트 8개 등록 확인. 실제 화면은 서버 배포 후 확인 필요.
Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
186 lines
8.7 KiB
Python
186 lines
8.7 KiB
Python
"""토큰 수명 관리 — 저장/복호화/만료판정/자동 갱신.
|
|
|
|
저장소(repo)는 duck typing 으로 주입한다. 실제 구현은
|
|
`app/modules/cafe24/db.py` 의 Cafe24Store 이며, 아래 3개만 있으면 된다.
|
|
|
|
repo.get_token_row(mall_id) -> dict | None (암호문 그대로)
|
|
repo.save_token_row(**fields)-> None (UPSERT)
|
|
repo.token_lock(mall_id) -> contextmanager (FOR UPDATE, .row / .save())
|
|
|
|
`token_lock` 은 web 컨테이너와 worker 컨테이너가 동시에 refresh 를 시도해도
|
|
한쪽만 카페24에 요청하도록 행 잠금을 건다(카페24는 refresh token 을 회전시키므로
|
|
동시 refresh 시 한쪽 토큰이 무효화된다).
|
|
"""
|
|
|
|
from __future__ import annotations
|
|
|
|
import logging
|
|
from datetime import timedelta
|
|
from typing import Any
|
|
|
|
from app.timezone import KST, now_kst
|
|
|
|
from .config import Cafe24Config
|
|
from .crypto import decrypt, encrypt
|
|
from .errors import Cafe24AuthError
|
|
from .oauth import TokenBundle, refresh_tokens
|
|
|
|
logger = logging.getLogger("cafe24.tokens")
|
|
|
|
# 만료 몇 초 전부터 미리 갱신할지 (네트워크 지연 여유)
|
|
REFRESH_MARGIN = timedelta(seconds=120)
|
|
|
|
|
|
class TokenService:
|
|
def __init__(self, repo: Any, config: Cafe24Config):
|
|
self._repo = repo
|
|
self._config = config
|
|
|
|
# ────────────────────────────────────────────────────────────
|
|
# 저장
|
|
# ────────────────────────────────────────────────────────────
|
|
def save_bundle(self, bundle: TokenBundle, *, connected_by: str = "") -> None:
|
|
"""최초 인증/재인증 후 토큰 저장. 토큰은 암호화해서 넣는다."""
|
|
secret = self._config.token_secret
|
|
self._repo.save_token_row(
|
|
mall_id=self._config.mall_id,
|
|
access_token=encrypt(bundle.access_token, secret=secret),
|
|
refresh_token=encrypt(bundle.refresh_token, secret=secret),
|
|
access_token_expires_at=bundle.access_token_expires_at,
|
|
refresh_token_expires_at=bundle.refresh_token_expires_at,
|
|
scopes=bundle.scopes,
|
|
last_refreshed_at=now_kst(),
|
|
last_error="",
|
|
connected_by=connected_by,
|
|
)
|
|
|
|
# ────────────────────────────────────────────────────────────
|
|
# 조회
|
|
# ────────────────────────────────────────────────────────────
|
|
def _aware(self, value: Any):
|
|
"""DB 에서 온 datetime 을 KST aware 로 정규화.
|
|
|
|
컬럼이 timestamptz 라 psycopg 는 UTC 로 돌려준다. 시각 자체는 같지만
|
|
화면에 `+00:00` 으로 보이므로 KST 로 변환해 다른 모듈과 표기를 맞춘다.
|
|
"""
|
|
if value is None:
|
|
return None
|
|
aware = value if value.tzinfo else value.replace(tzinfo=KST)
|
|
return aware.astimezone(KST)
|
|
|
|
def status(self) -> dict[str, Any]:
|
|
"""관리자 화면용 연결 상태. 토큰 값 자체는 절대 넣지 않는다."""
|
|
if not self._config.configured:
|
|
return {
|
|
"connected": False,
|
|
"mall_id": self._config.mall_id,
|
|
"missing": self._config.missing,
|
|
"needs_reauth": False,
|
|
"reason": "환경변수 미설정",
|
|
}
|
|
|
|
row = self._repo.get_token_row(self._config.mall_id)
|
|
if not row or not row.get("access_token"):
|
|
return {
|
|
"connected": False,
|
|
"mall_id": self._config.mall_id,
|
|
"missing": self._config.missing,
|
|
"needs_reauth": True,
|
|
"reason": "아직 카페24 연결(인증)을 하지 않았습니다.",
|
|
}
|
|
|
|
access_exp = self._aware(row.get("access_token_expires_at"))
|
|
refresh_exp = self._aware(row.get("refresh_token_expires_at"))
|
|
now = now_kst()
|
|
refresh_dead = bool(refresh_exp and now >= refresh_exp)
|
|
|
|
return {
|
|
"connected": not refresh_dead,
|
|
"mall_id": row.get("mall_id") or self._config.mall_id,
|
|
"missing": self._config.missing,
|
|
"needs_reauth": refresh_dead,
|
|
"reason": "refresh token 이 만료되었습니다. 재연결이 필요합니다." if refresh_dead else "",
|
|
"scopes": row.get("scopes") or "",
|
|
"access_token_expires_at": access_exp.isoformat(timespec="seconds") if access_exp else "",
|
|
"refresh_token_expires_at": refresh_exp.isoformat(timespec="seconds") if refresh_exp else "",
|
|
"access_expired": bool(access_exp and now >= access_exp),
|
|
"last_refreshed_at": (
|
|
self._aware(row.get("last_refreshed_at")).isoformat(timespec="seconds")
|
|
if row.get("last_refreshed_at")
|
|
else ""
|
|
),
|
|
"last_error": row.get("last_error") or "",
|
|
"connected_by": row.get("connected_by") or "",
|
|
}
|
|
|
|
# ────────────────────────────────────────────────────────────
|
|
# 사용 (Cafe24Client 가 호출)
|
|
# ────────────────────────────────────────────────────────────
|
|
def get_access_token(self) -> str:
|
|
"""유효한 access token. 만료(임박)면 잠금 걸고 1회 갱신 후 반환."""
|
|
mall_id = self._config.mall_id
|
|
row = self._repo.get_token_row(mall_id)
|
|
if not row or not row.get("access_token"):
|
|
raise Cafe24AuthError(
|
|
"카페24에 연결되어 있지 않습니다. 시스템 → 카페24 연결에서 인증하세요.",
|
|
needs_reauth=True,
|
|
)
|
|
|
|
expires_at = self._aware(row.get("access_token_expires_at"))
|
|
if expires_at and now_kst() < expires_at - REFRESH_MARGIN:
|
|
return decrypt(row["access_token"], secret=self._config.token_secret)
|
|
|
|
return self._refresh_locked(mall_id)
|
|
|
|
def force_expire(self) -> None:
|
|
"""access token 만료시각을 과거로 밀어 다음 호출에서 반드시 갱신하게 한다.
|
|
|
|
서버가 만료 전에 토큰을 무효화해 401 이 온 경우(Cafe24Client)에 쓴다.
|
|
"""
|
|
self._repo.save_token_row(
|
|
mall_id=self._config.mall_id,
|
|
access_token_expires_at=now_kst() - timedelta(seconds=1),
|
|
)
|
|
|
|
def _refresh_locked(self, mall_id: str) -> str:
|
|
"""행 잠금 안에서 갱신. 잠금 대기 중 다른 프로세스가 이미 갱신했으면 그 값 사용."""
|
|
secret = self._config.token_secret
|
|
with self._repo.token_lock(mall_id) as handle:
|
|
row = handle.row
|
|
if not row:
|
|
raise Cafe24AuthError("카페24 토큰이 없습니다.", needs_reauth=True)
|
|
|
|
expires_at = self._aware(row.get("access_token_expires_at"))
|
|
if expires_at and now_kst() < expires_at - REFRESH_MARGIN:
|
|
# 잠금 대기 사이에 다른 프로세스가 갱신 완료.
|
|
return decrypt(row["access_token"], secret=secret)
|
|
|
|
refresh_exp = self._aware(row.get("refresh_token_expires_at"))
|
|
if refresh_exp and now_kst() >= refresh_exp:
|
|
handle.save(last_error="refresh token 만료 — 재인증 필요")
|
|
raise Cafe24AuthError(
|
|
"카페24 refresh token 이 만료되었습니다. 시스템 → 카페24 연결에서 재인증하세요.",
|
|
needs_reauth=True,
|
|
)
|
|
|
|
try:
|
|
bundle = refresh_tokens(
|
|
self._config,
|
|
refresh_token=decrypt(row.get("refresh_token") or "", secret=secret),
|
|
)
|
|
except Cafe24AuthError as exc:
|
|
handle.save(last_error=str(exc))
|
|
raise
|
|
|
|
logger.info("카페24 access token 갱신 완료 (mall_id=%s)", mall_id)
|
|
handle.save(
|
|
access_token=encrypt(bundle.access_token, secret=secret),
|
|
refresh_token=encrypt(bundle.refresh_token, secret=secret),
|
|
access_token_expires_at=bundle.access_token_expires_at,
|
|
refresh_token_expires_at=bundle.refresh_token_expires_at,
|
|
scopes=bundle.scopes,
|
|
last_refreshed_at=now_kst(),
|
|
last_error="",
|
|
)
|
|
return bundle.access_token
|