mirror of
https://github.com/Monadical-SAS/reflector.git
synced 2025-12-20 20:29:06 +00:00
Post new message if previous was deleted
This commit is contained in:
@@ -577,14 +577,21 @@ async def pipeline_post_to_zulip(transcript: Transcript, logger: Logger):
|
|||||||
|
|
||||||
if room.zulip_auto_post:
|
if room.zulip_auto_post:
|
||||||
message = get_zulip_message(transcript=transcript, include_topics=True)
|
message = get_zulip_message(transcript=transcript, include_topics=True)
|
||||||
|
message_updated = False
|
||||||
if transcript.zulip_message_id:
|
if transcript.zulip_message_id:
|
||||||
|
try:
|
||||||
update_zulip_message(
|
update_zulip_message(
|
||||||
transcript.zulip_message_id,
|
transcript.zulip_message_id,
|
||||||
room.zulip_stream,
|
room.zulip_stream,
|
||||||
room.zulip_topic,
|
room.zulip_topic,
|
||||||
message,
|
message,
|
||||||
)
|
)
|
||||||
else:
|
message_updated = True
|
||||||
|
except Exception as e:
|
||||||
|
logger.error(
|
||||||
|
f"Failed to update zulip message with id {transcript.zulip_message_id}"
|
||||||
|
)
|
||||||
|
if not message_updated:
|
||||||
response = send_message_to_zulip(
|
response = send_message_to_zulip(
|
||||||
room.zulip_stream, room.zulip_topic, message
|
room.zulip_stream, room.zulip_topic, message
|
||||||
)
|
)
|
||||||
|
|||||||
Reference in New Issue
Block a user