Багфикс
This commit is contained in:
parent
43ae5b9346
commit
39bebabcd6
2 changed files with 2 additions and 5 deletions
|
@ -58,7 +58,7 @@ class ChatDAO(BaseDAO):
|
||||||
stmt = insert(UserChat).values(user_id=user_id, chat_id=chat_id)
|
stmt = insert(UserChat).values(user_id=user_id, chat_id=chat_id)
|
||||||
await self.session.execute(stmt)
|
await self.session.execute(stmt)
|
||||||
except IntegrityError:
|
except IntegrityError:
|
||||||
raise UserAlreadyInChatException
|
pass
|
||||||
|
|
||||||
async def change_data(self, chat_id: int, chat_name: str, avatar_image: HttpUrl) -> None:
|
async def change_data(self, chat_id: int, chat_name: str, avatar_image: HttpUrl) -> None:
|
||||||
stmt = (
|
stmt = (
|
||||||
|
|
|
@ -51,10 +51,7 @@ class ChatService:
|
||||||
avatar_image=user_chat_for.avatar_image
|
avatar_image=user_chat_for.avatar_image
|
||||||
)
|
)
|
||||||
await uow.chat.add_user_to_chat(user_id, chat_id)
|
await uow.chat.add_user_to_chat(user_id, chat_id)
|
||||||
try:
|
await uow.chat.add_user_to_chat(settings.ADMIN_USER_ID, chat_id)
|
||||||
await uow.chat.add_user_to_chat(settings.ADMIN_USER_ID, chat_id)
|
|
||||||
except UserAlreadyInChatException:
|
|
||||||
pass
|
|
||||||
async with RedisService(is_raise=True) as redis:
|
async with RedisService(is_raise=True) as redis:
|
||||||
await redis.delete_key(key=f"user_allowed_chats: {user_id}")
|
await redis.delete_key(key=f"user_allowed_chats: {user_id}")
|
||||||
await uow.commit()
|
await uow.commit()
|
||||||
|
|
Loading…
Add table
Reference in a new issue