♻️ store 패키지 리팩토링 (#52)

Author: Yeonu-Kim

alembic/env.py

@@ -23,7 +23,7 @@
 import app.models.event  # noqa: F401
 import app.models.review_image  # noqa: F401
 import app.models.review_submission  # noqa: F401
-import app.models.store  # noqa: F401
+import app.store.models  # noqa: F401
 import app.models.user  # noqa: F401
 
 target_metadata = Base.metadata

app/api/v1/router.py

@@ -2,9 +2,7 @@
 
 from app.api.v1.endpoints.application import router as application_router
 from app.api.v1.endpoints.event import router as event_router
-from app.api.v1.endpoints.store import router as store_router
 
 router = APIRouter()
-router.include_router(store_router)
 router.include_router(event_router)
 router.include_router(application_router)

app/db/seed.py

@@ -17,8 +17,8 @@
 from app.models.review_submission import (
     ReviewSubmission as ReviewSubmission,  # noqa: F401
 )
-from app.models.store import Store
 from app.models.user import User
+from app.store.models import Store
 
 logger = logging.getLogger(__name__)
 

app/main.py

@@ -13,6 +13,7 @@
 from app.db.seed import reset_and_seed
 from app.db.session import engine
 from app.s3.router import router as s3_router
+from app.store.router import router as store_router
 
 
 @asynccontextmanager
@@ -26,6 +27,7 @@ async def lifespan(app: FastAPI) -> AsyncGenerator[None, None]:
 
 app.include_router(auth_router, prefix="/api")
 app.include_router(s3_router, prefix="/api")
+app.include_router(store_router, prefix="/api")
 app.include_router(api_router, prefix="/api")
 
 

app/services/event.py

@@ -12,10 +12,10 @@
 from app.models.application import Application
 from app.models.event import Event
 from app.models.review_submission import ReviewSubmission
-from app.models.store import Store
 from app.models.user import User
 from app.schemas.event import ApplicationSummary, EventCreateReq
 from app.services import blockchain as blockchain_service
+from app.store.models import Store
 
 
 async def _get_store_or_404(db: AsyncSession, store_id: str) -> Store:

app/services/store.py

@@ -0,0 +1,18 @@
+from fastapi import Depends
+from sqlalchemy.ext.asyncio import AsyncSession
+
+from app.db.session import get_db
+from app.store.repository import StoreRepository
+from app.store.repository_impl import StoreRepositoryImpl
+from app.store.service import StoreService
+from app.store.service_impl import StoreServiceImpl
+
+
+def get_store_repository(db: AsyncSession = Depends(get_db)) -> StoreRepository:
+    return StoreRepositoryImpl(db)
+
+
+def get_store_service(
+    repo: StoreRepository = Depends(get_store_repository),
+) -> StoreService:
+    return StoreServiceImpl(repo)

app/store/__init__.py

@@ -0,0 +1,29 @@
+from abc import ABC, abstractmethod
+from uuid import UUID
+
+from app.models.event import Event
+from app.store.models import Store
+
+
+class StoreRepository(ABC):
+    @abstractmethod
+    async def find_by_id(self, store_id: UUID) -> Store | None: ...
+
+    @abstractmethod
+    async def find_all(
+        self,
+        *,
+        category: str | None,
+        name: str | None,
+        offset: int,
+        limit: int,
+    ) -> tuple[list[Store], int]: ...
+
+    @abstractmethod
+    async def save(self, store: Store) -> Store: ...
+
+    @abstractmethod
+    async def delete(self, store: Store) -> None: ...
+
+    @abstractmethod
+    async def find_events_by_store_id(self, store_id: UUID) -> list[Event]: ...