diff options
| author | 2024-03-11 09:40:55 +0800 | |
|---|---|---|
| committer | 2024-03-11 09:40:55 +0800 | |
| commit | 93581961abaf7edd2dc89170fb73a97a65857628 (patch) | |
| tree | 2dcdc9e47bdceb86ad2df23e87137e38fcd015a1 /tests/test_workflow.py | |
| parent | 67cf02ba9bf39116126ef8360cedff5410a20694 (diff) | |
| parent | 5e07496ab7f428379f2ecb3505894241b9073b9e (diff) | |
| download | infini-93581961abaf7edd2dc89170fb73a97a65857628.tar.gz infini-93581961abaf7edd2dc89170fb73a97a65857628.zip | |
Merge branches 'master' and 'master' of https://github.com/HydroRoll-Team/infini
Diffstat (limited to 'tests/test_workflow.py')
| -rw-r--r-- | tests/test_workflow.py | 47 |
1 files changed, 47 insertions, 0 deletions
diff --git a/tests/test_workflow.py b/tests/test_workflow.py new file mode 100644 index 00000000..18dab9d5 --- /dev/null +++ b/tests/test_workflow.py @@ -0,0 +1,47 @@ +from infini.core import Core +from infini.generator import Generator +from infini.handler import Handler +from infini.injector import Injector +from infini.input import Input +from infini.interceptor import Interceptor +from infini.output import Output +from infini.router import Startswith + + +def test_workflow(): + def func_workflow(input: Input): + yield input.output("workflow", "test.workflow", block=True) + + input = Input("testmsg") + + handler = Handler() + handler.handlers = [ + { + "priority": 0, + "router": Startswith(""), + "handler": func_workflow, + } + ] + + interceptor = Interceptor() + interceptor.interceptors = [] + + generator = Generator() + generator.events = { + "test.cmd": "cmd", + "test.add": "{{ result }}", + "block.jianlvchun": "检测到违禁词", + } + generator.global_variables = {} + + core = Core() + core.handler = handler + core.interceptor = interceptor + core.pre_interceptor = interceptor + core.generator = generator + core.injector = Injector() + + for output in core.input(input): + assert isinstance(output, Output) + assert output.type == "workflow" + output.status = 0 |
