arclet-letoderea

A high-performance, simple-structured event system, relies on asyncio


Keywords
asyncio, event-system, dispatch, dependency-injection, eventbus, python
License
MIT
Install
pip install arclet-letoderea==0.11.0

Documentation

Letoderea

Licence PyPI PyPI - Python Version

一个高性能,结构简洁,依赖于 Python内置库asyncio 的事件系统, 设计灵感来自Graia BroadcastControl

项目仍处于开发阶段,部分内容可能会有较大改变

安装

从 PyPI 安装

pip install arclet-letoderea

样例

import asyncio
from arclet.letoderea import EventSystem, make_event

es = EventSystem()

@make_event
class TestEvent:
    name = "Letoderea"


@es.on()
async def test_subscriber(name: str):
    print(name)

async def main():
    await es.publish(TestEvent())

asyncio.run(main())

说明

事件

  • 事件可以是任何对象,只要实现了 gather 异步方法
  • gather 方法的参数为 Contexts 类型,用于传递上下文信息
  • 事件可以通过 gather 方法将自身想要传递的信息整合进 Contexts
  • 事件可以携带 ProviderAuxiliary,它们会在事件被订阅时注入到订阅者中
  • 订阅子类事件时,父类事件的 ProviderAuxiliary 会被继承
  • 订阅父类事件时,其子类事件也会被分发给订阅者

订阅

  • 通过 Publisher.register, EventSystem.onsubscribe 装饰器可以将一个函数注册为事件的订阅者
  • 订阅者的参数可以是任何类型,事件系统会尝试从 Contexts 中查找对应的值并注入
  • 默认情况下 event 为名字的参数会被注入为事件的实例
  • 订阅者可以设置优先级,值越小优先级越高

上下文

  • Contexts 类型是一个 dict 的子类,用于传递上下文信息,除此之外与 dict 没有区别
  • Contexts 默认包含 $event 键,其值为事件的实例
  • Contexts 默认包含 $subscriber 键,其值为订阅者的实例

依赖注入

  • Provider[T] 负责管理参数的注入, 其会尝试从 Contexts 中选择需求的参数返回
  • 对于订阅者的每个参数,在订阅者注册后,事件系统会遍历该订阅者拥有的所有 Provider, 并依次调用 Provider.validate 方法,如果返回 True,则将该 Provider 绑定到该参数上。 当进行依赖解析时,事件系统会遍历该参数绑定的所有 Provider,并依次调用 Provider.__call__ 方法, 如果返回值不为 None,则将该返回值注入到该参数中。
  • Provider.validate 方法用于验证订阅函数的参数是否为该 Provider 可绑定的参数。默认实现为检查目标参数的类型声明是否为 T。 也可以通过重写该方法来实现自定义的验证逻辑。
  • Provider.__call__ 方法用于从 Contexts 中获取参数
  • 原则上 Provider 只负责注入单一类型的参数。若想处理多个类型的参数,可以声明自己为 Provider[Union[A, B, ...]] 类型, 并在 Provider.validate 方法中进行自定义的逻辑判断。但更推荐的做法是构造多个 Provider,并将其绑定到同一个参数上。
  • 对于特殊的辅助器 Depend,事件系统会将其作为特殊的 Provider 处理,绑定了 Depend 的参数在解析时将直接调用 Depend.__call__ 方法。
  • Provider 可以设置优先级,值越小优先级越高
  • 另有 ProviderFactory,用于集成多个 Provider 的分配,以方便 event.providers 的设置

事件发布

  • 一般情况下通过 EventSystem.publish 方法可以发布一个事件让事件系统进行处理
  • Publisher 类负责管理订阅者与事件的交互
  • Publisher.validate 方法用于验证该事件是否为该发布者的订阅者所关注的事件
  • Publisher.publish 方法用于将事件直接分发给属于自身的订阅者
  • Publisher.supply 方法用于让事件系统主动获取事件并分发给所有订阅者
  • EventSystem.onEventSystem.publish 可以指定 Publisher

辅助

  • Auxiliary 提供了一系列辅助方法,方便事件的处理
  • Auxiliary 分为 Judge, SupplyDepend 三类:
    • Judge: 用于判断此时是否应该处理事件
    • Supply: 用于为 Contexts 提供额外的信息
    • Depend: 用于依赖注入
  • Auxiliary.scopes 声明了 Auxiliary 的作用域:
    • prepare: 表示该 Auxiliary 会在依赖注入之前执行
    • parsing: 表示该 Auxiliary 会在依赖注入解析时执行
    • complete: 表示该 Auxiliary 会在依赖注入完成后执行
    • cleanup: 表示该 Auxiliary 会在事件处理完成后执行
  • Auxiliary 可以设置 CombineMode, 用来设置多个 Auxiliary 的组合方式:
    • single: 表示该 Auxiliary 独立执行
    • and: 表示该 Auxiliary 的执行结果应该与其他 Auxiliary 的执行结果都为有效值
    • or: 表示该 Auxiliary 的执行结果应该与其他 Auxiliary 的执行结果至少有一个为有效值
  • Auxiliary 可以设置优先级,值越小优先级越高

开源协议

本实现以 MIT 为开源协议。