54 lines
1.6 KiB
Python
54 lines
1.6 KiB
Python
"""Feedback service for VoIdea."""
|
|
|
|
from typing import Optional
|
|
from uuid import UUID
|
|
|
|
from sqlalchemy import select
|
|
from sqlalchemy.ext.asyncio import AsyncSession
|
|
|
|
from app.models.feedback import Feedback
|
|
|
|
|
|
class FeedbackService:
|
|
def __init__(self, db: AsyncSession):
|
|
self.db = db
|
|
|
|
async def create(
|
|
self, user_id: Optional[UUID], text: str, page_url: Optional[str] = None
|
|
) -> Feedback:
|
|
fb = Feedback(user_id=user_id, text=text, page_url=page_url, status="new")
|
|
self.db.add(fb)
|
|
await self.db.commit()
|
|
await self.db.refresh(fb)
|
|
return fb
|
|
|
|
async def list_feedback(
|
|
self, skip: int = 0, limit: int = 50, status: Optional[str] = None
|
|
) -> list[Feedback]:
|
|
query = select(Feedback)
|
|
if status:
|
|
query = query.where(Feedback.status == status)
|
|
query = query.order_by(Feedback.created_at.desc()).offset(skip).limit(limit)
|
|
result = await self.db.execute(query)
|
|
return list(result.scalars().all())
|
|
|
|
async def get_by_id(self, feedback_id: UUID) -> Optional[Feedback]:
|
|
return await self.db.get(Feedback, feedback_id)
|
|
|
|
async def update_status(self, feedback_id: UUID, status: str) -> Optional[Feedback]:
|
|
fb = await self.get_by_id(feedback_id)
|
|
if not fb:
|
|
return None
|
|
fb.status = status
|
|
await self.db.commit()
|
|
await self.db.refresh(fb)
|
|
return fb
|
|
|
|
async def delete(self, feedback_id: UUID) -> bool:
|
|
fb = await self.get_by_id(feedback_id)
|
|
if not fb:
|
|
return False
|
|
await self.db.delete(fb)
|
|
await self.db.commit()
|
|
return True
|