working on supports for pipelines

src/utils/commands.py

+import re
+
+from nonebot.message import event_preprocessor, event_postprocessor
+from nonebot.adapters.cqhttp import Bot, Event, MessageEvent, Message
+from nonebot.typing import T_State
+
+re_pipeline = re.compile(r'(.*)[|](.*)')
+
+
+@event_preprocessor
+async def cmd_grep(bot: Bot, event: Event, state: T_State):
+    if not isinstance(event, MessageEvent):
+        return
+    text = event.get_plaintext()
+    if m := re_pipeline.match(text):
+        msg, command = m.group(0).strip(), m.group(1).strip()
+        event.message = Message(msg)
+        event.raw_message = msg
+        state['_command'] = command
+        state['_send'] = msg
+
+
+@event_postprocessor
+async def sender(bot: Bot, event: Event, state: T_State):
+    if '_send' not in state:
+        return
+    send = state['_send']
+    if '_command' in state:
+        pass
+    await bot.send(event, send)