Vorkout/connect
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: CRUD ListEvent #14

Merged
ivan.dev merged 8 commits from VORKOUT-14 into master 2025-07-04 18:06:03 +05:00
Conversation 0 Commits 8 Files Changed 10 +3 -4
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit f65f4caf5c - Show all commits

7
api/api/db/logic/listevents.py
View File

@ -22,7 +22,6 @@ async def get_listevents_page_by_creator_id(connection: AsyncConnection, creator
""" """
first_event = page * limit - limit first_event = page * limit - limit
print(creator_id)
query = ( query = (
ivan.dev marked this conversation as resolved
vlad.dev commented 2025-07-01 23:08:05 +05:00
Review
Copy Link

Можно убрать, если надо логировать, то лучше через logger

Можно убрать, если надо логировать, то лучше через `logger`
select( select(
list_events_table.c.id, list_events_table.c.id,
@ -62,7 +61,7 @@ async def get_listevents_page_by_creator_id(connection: AsyncConnection, creator
async def get_listevents_page(connection: AsyncConnection, page, limit) -> Optional[AllListEventResponse]: async def get_listevents_page(connection: AsyncConnection, page, limit) -> Optional[AllListEventResponse]:
""" """
Получает список ползовелей заданных значениями page, limit. Получает список событий заданного создателя по значениям page и limit.
""" """
first_event = page * limit - (limit) first_event = page * limit - (limit)
@ -100,7 +99,7 @@ async def get_listevents_page(connection: AsyncConnection, page, limit) -> Optio
async def get_listevents_by_name(connection: AsyncConnection, name: str) -> Optional[ListEvent]: async def get_listevents_by_name(connection: AsyncConnection, name: str) -> Optional[ListEvent]:
""" """
Получает юзера по login. Получает list events по name.
""" """
ivan.dev marked this conversation as resolved
vlad.dev commented 2025-07-01 23:09:00 +05:00
Review
Copy Link

Тут, видимо, из другого метода скопировал случайно

Тут, видимо, из другого метода скопировал случайно
query = select(list_events_table).where(list_events_table.c.name == name) query = select(list_events_table).where(list_events_table.c.name == name)
@ -146,7 +145,7 @@ async def get_listevents_by_id(connection: AsyncConnection, id: int) -> Optional
ivan.dev marked this conversation as resolved
vlad.dev commented 2025-06-30 15:42:01 +05:00
Review
Copy Link

Тоже returning type не соответствует

Тоже returning type не соответствует
async def update_listevents_by_id(connection: AsyncConnection, update_values, listevents): async def update_listevents_by_id(connection: AsyncConnection, update_values, listevents):
""" """
Вносит изменеия в нужное поле таблицы account_table. Вносит изменеия в нужное поле таблицы list_events_table.
""" """
ivan.dev marked this conversation as resolved
vlad.dev commented 2025-07-01 23:09:19 +05:00
Review
Copy Link

Тоже из другого метода описание

Тоже из другого метода описание
await connection.execute(list_events_table.update().where(list_events_table.c.id == listevents.id).values(**update_values)) await connection.execute(list_events_table.update().where(list_events_table.c.id == listevents.id).values(**update_values))