mirror of
https://github.com/zhayujie/bot-on-anything.git
synced 2026-01-19 01:21:06 +08:00
60 lines
2.1 KiB
Python
60 lines
2.1 KiB
Python
# 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
|