This commit is contained in:
parent
98805b1878
commit
faecbaf784
|
@ -107,6 +107,8 @@ class Callbacks:
|
||||||
'content': thread_msg if not thread_msg.startswith(self.command_prefix) else thread_msg[len(self.command_prefix):].strip()
|
'content': thread_msg if not thread_msg.startswith(self.command_prefix) else thread_msg[len(self.command_prefix):].strip()
|
||||||
}) # if len(thread_content) >= 2 and thread_content[0].body.startswith(self.command_prefix): # if thread_content[len(thread_content) - 2].sender == self.client.user
|
}) # if len(thread_content) >= 2 and thread_content[0].body.startswith(self.command_prefix): # if thread_content[len(thread_content) - 2].sender == self.client.user
|
||||||
|
|
||||||
|
print(thread_content[0].event_id)
|
||||||
|
|
||||||
# TODO: process_chat() will set typing as false after generating.
|
# TODO: process_chat() will set typing as false after generating.
|
||||||
# TODO: If there is still another query in-progress that typing state will be overwritten by the one that just finished.
|
# TODO: If there is still another query in-progress that typing state will be overwritten by the one that just finished.
|
||||||
async def inner():
|
async def inner():
|
||||||
|
|
|
@ -218,8 +218,6 @@ async def process_chat(
|
||||||
resp = await send_text_to_room(client, room.room_id, text_response, reply_to_event_id=event.event_id, thread=True, thread_root_id=thread_root_id if thread_root_id else event.event_id)
|
resp = await send_text_to_room(client, room.room_id, text_response, reply_to_event_id=event.event_id, thread=True, thread_root_id=thread_root_id if thread_root_id else event.event_id)
|
||||||
await client.room_typing(room.room_id, typing_state=False, timeout=3000)
|
await client.room_typing(room.room_id, typing_state=False, timeout=3000)
|
||||||
|
|
||||||
print(thread_root_id)
|
|
||||||
|
|
||||||
store.add_event_id(event.event_id)
|
store.add_event_id(event.event_id)
|
||||||
if not isinstance(resp, RoomSendResponse):
|
if not isinstance(resp, RoomSendResponse):
|
||||||
logger.critical(f'Failed to respond to event {event.event_id} in room {room.room_id}:\n{vars(resp)}')
|
logger.critical(f'Failed to respond to event {event.event_id} in room {room.room_id}:\n{vars(resp)}')
|
||||||
|
|
Loading…
Reference in New Issue