# encoding:utf-8 from enum import Enum class Event(Enum): # ON_RECEIVE_MESSAGE = 1 # 收到消息 ON_HANDLE_CONTEXT = 2 # 对应通道处理消息前 """ e_context = { "channel": 消息channel, "context" : 本次消息的context, "reply" : 目前的回复,初始为空 , "args": 其他上下文参数 } """ ON_DECORATE_REPLY = 3 # 得到回复后准备装饰 """ e_context = { "channel": 消息channel, "context" : 本次消息的context, "reply" : 目前的回复 , "args": 其他上下文参数 } """ ON_SEND_REPLY = 4 # 发送回复前 """ bot-on-anything 不支持ON_SEND_REPLY事件,请使用ON_BRIDGE_HANDLE_CONTEXT或者ON_BRIDGE_HANDLE_STREAM_CONTEXT事件 """ # AFTER_SEND_REPLY = 5 # 发送回复后 ON_BRIDGE_HANDLE_CONTEXT = 6 # 模型桥处理消息前 """ e_context = { "context" : 本次消息的context, "reply" : 目前的回复,初始为空 , "args": 其他上下文参数 } """ ON_BRIDGE_HANDLE_STREAM_CONTEXT = 7 # 模型桥处理流式消息前,流式对话的消息处理仅支持一次性返回,请直接返回结果 """ e_context = { "context" : 本次消息的context, "reply" : 目前的回复,初始为空 , "args": 其他上下文参数 } """ class EventAction(Enum): CONTINUE = 1 # 事件未结束,继续交给下个插件处理,如果没有下个插件,则交付给默认的事件处理逻辑 BREAK = 2 # 事件结束,不再给下个插件处理,交付给默认的事件处理逻辑 BREAK_PASS = 3 # 事件结束,不再给下个插件处理,不交付给默认的事件处理逻辑 class EventContext: def __init__(self, event, econtext=dict()): self.event = event self.econtext = econtext self.action = EventAction.CONTINUE def __getitem__(self, key): return self.econtext.get(key,"") def __setitem__(self, key, value): self.econtext[key] = value def __delitem__(self, key): del self.econtext[key] def is_pass(self): return self.action == EventAction.BREAK_PASS