Skip to content

Commit df21fbd

Browse files
committed
Fixed an error with reply
1 parent 64190fe commit df21fbd

1 file changed

Lines changed: 14 additions & 6 deletions

File tree

chats/consumers.py

Lines changed: 14 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -151,9 +151,13 @@ async def __process_new_direct_message_event(self, event: Event):
151151
# if not, create such chat
152152
await sync_to_async(DirectChat.create_from_two_users)(self.user, other_user)
153153

154-
reply_to_message = await sync_to_async(DirectChatMessage.objects.get)(
155-
pk=event.content["reply_to"]
156-
)
154+
try:
155+
reply_to_message = await sync_to_async(DirectChatMessage.objects.get)(
156+
pk=event.content["reply_to"]
157+
)
158+
except DirectChatMessage.DoesNotExist:
159+
reply_to_message = None
160+
157161
msg = await create_message(
158162
chat_id=chat_id,
159163
chat_model=DirectChatMessage,
@@ -191,9 +195,13 @@ async def __process_new_project_message_event(self, event: Event, room_name: str
191195
f"User {self.user.id} is not in project chat {chat_id}"
192196
)
193197

194-
reply_to_message = await sync_to_async(ProjectChatMessage.objects.get)(
195-
pk=event.content["reply_to"]
196-
)
198+
try:
199+
reply_to_message = await sync_to_async(ProjectChatMessage.objects.get)(
200+
pk=event.content["reply_to"]
201+
)
202+
except ProjectChatMessage.DoesNotExist:
203+
reply_to_message = None
204+
197205
msg = await create_message(
198206
chat_id=chat_id,
199207
chat_model=ProjectChatMessage,

0 commit comments

Comments
 (0)