From 37926b4c1972cae788517c1f418b9c33e27a3b04 Mon Sep 17 00:00:00 2001 From: jxxghp Date: Thu, 27 Feb 2025 18:58:11 +0800 Subject: [PATCH] fix actions --- app/actions/send_event.py | 7 ++----- app/actions/send_message.py | 14 ++++++++------ app/actions/transfer_file.py | 2 +- 3 files changed, 11 insertions(+), 12 deletions(-) diff --git a/app/actions/send_event.py b/app/actions/send_event.py index fe56e648..ca07e6c4 100644 --- a/app/actions/send_event.py +++ b/app/actions/send_event.py @@ -17,15 +17,13 @@ class SendEventAction(BaseAction): 发送事件 """ - __success = False - @property def name(self) -> str: return "发送事件" @property def description(self) -> str: - return "发送特定事件" + return "发送队列中的所有事件" @property def data(self) -> dict: @@ -33,7 +31,7 @@ class SendEventAction(BaseAction): @property def success(self) -> bool: - return self.__success + return self.done async def execute(self, params: SendEventParams, context: ActionContext) -> ActionContext: """ @@ -45,7 +43,6 @@ class SendEventAction(BaseAction): for event in copy.deepcopy(context.events): eventmanager.send_event(etype=event.event_type, data=event.event_data) context.events.remove(event) - self.__success = True self.job_done() return context diff --git a/app/actions/send_message.py b/app/actions/send_message.py index 5dc5135a..38b5c3ab 100644 --- a/app/actions/send_message.py +++ b/app/actions/send_message.py @@ -1,16 +1,17 @@ +import copy from typing import List, Optional, Union from pydantic import Field from app.actions import BaseAction, ActionChain -from app.schemas import ActionParams, ActionContext, MessageChannel +from app.schemas import ActionParams, ActionContext class SendMessageParams(ActionParams): """ 发送消息参数 """ - channel: Optional[List[str]] = Field([], description="消息渠道") + client: Optional[List[str]] = Field([], description="消息渠道") userid: Optional[Union[str, int]] = Field(None, description="用户ID") @@ -29,7 +30,7 @@ class SendMessageAction(BaseAction): @property def description(self) -> str: - return "发送特定消息" + return "发送队列中的所有消息" @property def data(self) -> dict: @@ -43,12 +44,13 @@ class SendMessageAction(BaseAction): """ 发送messages中的消息 """ - for message in context.messages: - if params.channel: - message.channel = MessageChannel(params.channel) + for message in copy.deepcopy(context.messages): + if params.client: + message.source = params.client if params.userid: message.userid = params.userid self.chain.post_message(message) + context.messages.remove(message) context.messages = [] diff --git a/app/actions/transfer_file.py b/app/actions/transfer_file.py index dcfe96e9..1dbdf7fa 100644 --- a/app/actions/transfer_file.py +++ b/app/actions/transfer_file.py @@ -32,7 +32,7 @@ class TransferFileAction(BaseAction): @property def description(self) -> str: - return "转移和重命名文件" + return "整理下载队列中的文件" @property def data(self) -> dict: