From 4fa8f5b24806aaf919f00ab95b8c1b6d943d3e1b Mon Sep 17 00:00:00 2001 From: InfinityPacer <160988576+InfinityPacer@users.noreply.github.com> Date: Fri, 24 Jan 2025 17:26:54 +0800 Subject: [PATCH] feat(event): use latest subscribe_info in SubscribeModified --- app/api/endpoints/subscribe.py | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/app/api/endpoints/subscribe.py b/app/api/endpoints/subscribe.py index 83805c00..b84365e0 100644 --- a/app/api/endpoints/subscribe.py +++ b/app/api/endpoints/subscribe.py @@ -128,7 +128,7 @@ def update_subscribe( eventmanager.send_event(EventType.SubscribeModified, { "subscribe_id": subscribe.id, "old_subscribe_info": old_subscribe_dict, - "subscribe_info": subscribe_dict, + "subscribe_info": subscribe.to_dict(), }) return schemas.Response(success=True) @@ -152,12 +152,11 @@ def update_subscribe_status( subscribe.update(db, { "state": state }) - subscribe_dict = subscribe.to_dict() # 发送订阅调整事件 eventmanager.send_event(EventType.SubscribeModified, { "subscribe_id": subscribe.id, "old_subscribe_info": old_subscribe_dict, - "subscribe_info": subscribe_dict, + "subscribe_info": subscribe.to_dict(), }) return schemas.Response(success=True) @@ -229,12 +228,11 @@ def reset_subscribes( "lack_episode": subscribe.total_episode, "state": "R" }) - subscribe_dict = subscribe.to_dict() # 发送订阅调整事件 eventmanager.send_event(EventType.SubscribeModified, { "subscribe_id": subscribe.id, "old_subscribe_info": old_subscribe_dict, - "subscribe_info": subscribe_dict, + "subscribe_info": subscribe.to_dict(), }) return schemas.Response(success=True) return schemas.Response(success=False, message="订阅不存在")