[melobot] Better arguments passing for hook invoke method

Author: aicorein

src/melobot/_hook.py

@@ -44,6 +44,7 @@ async def emit(
         self,
         hook_type: HookEnumT,
         wait: bool = False,
+        /,
         *,
         args: tuple | None = None,
         kwargs: dict[str, Any] | None = None,

src/melobot/adapter/base.py

@@ -185,7 +185,7 @@ async def __adapter_input_loop__(self, src: InSourceT) -> NoReturn:
                 event = await self._event_factory.create(packet)
                 with _EVENT_BUILD_INFO_CTX.unfold(EventBuildInfo(self, src)):
                     await self._life_bus.emit(
-                        AdapterLifeSpan.BEFORE_EVENT, wait=True, args=(event,)
+                        AdapterLifeSpan.BEFORE_EVENT, True, args=(event,)
                     )
                     asyncio.create_task(self.dispatcher.broadcast(event))
             except Exception:
@@ -223,7 +223,7 @@ async def __adapter_launch__(self) -> AsyncGenerator[Self, None]:
 
         finally:
             if self._inited:
-                await self._life_bus.emit(AdapterLifeSpan.STOPPED, wait=True)
+                await self._life_bus.emit(AdapterLifeSpan.STOPPED, True)
 
     @final
     def filter_out(
@@ -260,9 +260,7 @@ async def call_output(self, action: ActionT) -> tuple[ActionHandle, ...]:
         else:
             osrcs = (self.out_srcs[0],) if len(self.out_srcs) else ()
 
-        await self._life_bus.emit(
-            AdapterLifeSpan.BEFORE_ACTION, wait=True, args=(action,)
-        )
+        await self._life_bus.emit(AdapterLifeSpan.BEFORE_ACTION, True, args=(action,))
         return tuple(
             ActionHandle(action, osrc, self._output_factory, self._echo_factory)
             for osrc in osrcs

src/melobot/bot/base.py

@@ -367,7 +367,7 @@ async def core_run(self) -> None:
                 for t in self._tasks:
                     t.cancel()
 
-                await self._life_bus.emit(BotLifeSpan.STOPPED, wait=True)
+                await self._life_bus.emit(BotLifeSpan.STOPPED, True)
                 self.logger.info(f"{self} 已安全停止运行")
                 self._running = False
 
@@ -402,7 +402,7 @@ async def close(self) -> None:
         if not self._running:
             raise BotError(f"{self} 未在运行中，不能停止运行")
 
-        await self._life_bus.emit(BotLifeSpan.CLOSE, wait=True)
+        await self._life_bus.emit(BotLifeSpan.CLOSE, True)
         self._rip_signal.set()
 
     async def restart(self) -> NoReturn:

src/melobot/io/base.py

@@ -117,7 +117,7 @@ async def __aexit__(
         try:
             await self.close()
         finally:
-            await self._life_bus.emit(SourceLifeSpan.STOPPED, wait=True)
+            await self._life_bus.emit(SourceLifeSpan.STOPPED, True)
         return None
 
     def on(

src/melobot/protocols/onebot/v11/io/duplex_http.py

@@ -70,7 +70,7 @@ async def _respond(self, request: aiohttp.web.Request) -> aiohttp.web.Response:
                 and raw.get("meta_event_type") == "lifecycle"
                 and raw.get("sub_type") == "connect"
             ):
-                await self._life_bus.emit(SourceLifeSpan.RESTARTED, wait=False)
+                await self._life_bus.emit(SourceLifeSpan.RESTARTED, False)
             self.logger.generic_obj(
                 "收到上报，未格式化的字典", str(raw), level=LogLevel.DEBUG
             )

src/melobot/protocols/onebot/v11/io/forward.py

@@ -155,7 +155,7 @@ async def open(self) -> None:
 
             if self._restart_flag.is_set():
                 self._restart_flag.clear()
-                await self._life_bus.emit(SourceLifeSpan.RESTARTED, wait=False)
+                await self._life_bus.emit(SourceLifeSpan.RESTARTED, False)
 
     def opened(self) -> bool:
         return self._opened.is_set()

src/melobot/protocols/onebot/v11/io/reverse.py

@@ -72,7 +72,7 @@ async def _input_loop(self, ws: ServerConnection) -> None:
 
         if self._restart_flag.is_set():
             self._restart_flag.clear()
-            await self._life_bus.emit(SourceLifeSpan.RESTARTED, wait=False)
+            await self._life_bus.emit(SourceLifeSpan.RESTARTED, False)
 
         while True:
             try: