move get_all_users to get_all

This commit is contained in:
IluaAir
2025-08-09 01:00:39 +03:00
parent b2824c2bb2
commit d6646716b8
3 changed files with 8 additions and 8 deletions

View File

@@ -21,6 +21,12 @@ class BaseRepo:
result = await self.session.execute(query) result = await self.session.execute(query)
model = result.scalars().one_or_none() model = result.scalars().one_or_none()
return model return model
async def get_all(self) -> list[model]:
query = select(self.model)
result = await self.session.execute(query)
models = result.scalars().all()
return models
async def delete_one(self, **filter_by) -> None: async def delete_one(self, **filter_by) -> None:
await self.session.execute(delete(self.model).filter_by(**filter_by)) await self.session.execute(delete(self.model).filter_by(**filter_by))

View File

@@ -1,4 +1,4 @@
from sqlalchemy import select, update from sqlalchemy import update
from src.models import UsersORM from src.models import UsersORM
from src.repository.base import BaseRepo from src.repository.base import BaseRepo
@@ -7,12 +7,6 @@ from src.repository.base import BaseRepo
class UsersRepo(BaseRepo): class UsersRepo(BaseRepo):
model = UsersORM model = UsersORM
async def get_all_users(self) -> list[UsersORM]:
query = select(self.model)
result = await self.session.execute(query)
models = result.scalars().all()
return models
async def update_one(self, id: int, data: dict) -> UsersORM: async def update_one(self, id: int, data: dict) -> UsersORM:
stmt = ( stmt = (
update(self.model) update(self.model)

View File

@@ -24,7 +24,7 @@ class UserService(BaseService):
return user return user
async def get_all_users(self) -> list[User]: async def get_all_users(self) -> list[User]:
users = await self.session.user.get_all_users() users = await self.session.user.get_all()
return [User.model_validate(user) for user in users] return [User.model_validate(user) for user in users]
async def delete_user(self, id: int) -> None: async def delete_user(self, id: int) -> None: