(self, page=1, page_size=20)
| 266 | return result.scalar_one_or_none() |
| 267 | |
| 268 | async def get_all_conversations(self, page=1, page_size=20): |
| 269 | async with self.get_db() as session: |
| 270 | session: AsyncSession |
| 271 | offset = (page - 1) * page_size |
| 272 | result = await session.execute( |
| 273 | select(ConversationV2) |
| 274 | .order_by(desc(ConversationV2.created_at)) |
| 275 | .offset(offset) |
| 276 | .limit(page_size), |
| 277 | ) |
| 278 | return result.scalars().all() |
| 279 | |
| 280 | async def get_filtered_conversations( |
| 281 | self, |