GithubBackup/MoviePilot
1
0
Fork 0
mirror of https://github.com/jxxghp/MoviePilot.git synced 2026-09-05 07:27:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: exclude notification history flag from event payload

Browse Source
This commit is contained in:
jxxghp
2026-06-17 21:36:59 +08:00
parent a516bc1c77
commit 5e1bdfe725
1 changed files with 11 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/chain/__init__.py
+11 -4
View File
@@ -205,6 +205,13 @@ class ChainBase(metaclass=ABCMeta):
) )
return dispatch_message return dispatch_message
@staticmethod
def _build_notice_message_data(message: Notification) -> dict:
"""
构造消息通知事件数据。
"""
return {**message.model_dump(exclude={"save_history"}), "type": message.mtype}
async def async_remove_cache(self, filename: str) -> None: async def async_remove_cache(self, filename: str) -> None:
""" """
异步删除缓存，同时删除Redis和本地缓存 异步删除缓存，同时删除Redis和本地缓存
@@ -1540,7 +1547,7 @@ class ChainBase(metaclass=ABCMeta):
# 按设定发送 # 按设定发送
self.eventmanager.send_event( self.eventmanager.send_event(
etype=EventType.NoticeMessage, etype=EventType.NoticeMessage,
data={**send_message.model_dump(), "type": send_message.mtype}, data=self._build_notice_message_data(send_message),
) )
self.messagequeue.send_message( self.messagequeue.send_message(
"post_message", message=send_message, **kwargs "post_message", message=send_message, **kwargs
@@ -1550,7 +1557,7 @@ class ChainBase(metaclass=ABCMeta):
# 发送消息事件 # 发送消息事件
self.eventmanager.send_event( self.eventmanager.send_event(
etype=EventType.NoticeMessage, etype=EventType.NoticeMessage,
data={**dispatch_message.model_dump(), "type": dispatch_message.mtype}, data=self._build_notice_message_data(dispatch_message),
) )
# 按原消息发送 # 按原消息发送
self.messagequeue.send_message( self.messagequeue.send_message(
@@ -1656,7 +1663,7 @@ class ChainBase(metaclass=ABCMeta):
# 按设定发送 # 按设定发送
await self.eventmanager.async_send_event( await self.eventmanager.async_send_event(
etype=EventType.NoticeMessage, etype=EventType.NoticeMessage,
data={**send_message.model_dump(), "type": send_message.mtype}, data=self._build_notice_message_data(send_message),
) )
await self.messagequeue.async_send_message( await self.messagequeue.async_send_message(
"post_message", message=send_message, **kwargs "post_message", message=send_message, **kwargs
@@ -1666,7 +1673,7 @@ class ChainBase(metaclass=ABCMeta):
# 发送消息事件 # 发送消息事件
await self.eventmanager.async_send_event( await self.eventmanager.async_send_event(
etype=EventType.NoticeMessage, etype=EventType.NoticeMessage,
data={**dispatch_message.model_dump(), "type": dispatch_message.mtype}, data=self._build_notice_message_data(dispatch_message),
) )
# 按原消息发送 # 按原消息发送
await self.messagequeue.async_send_message( await self.messagequeue.async_send_message(