fix: update creart

pyproject.toml

@@ -7,14 +7,14 @@ authors = [
 ]
 requires-python = ">=3.8,<4.0"
 dependencies = [
-    "graia-broadcast>=0.22.1,<0.23",
+    "graia-broadcast~=0.23.0",
     "aiohttp~=3.8",
     "pydantic~=1.9",
     "typing-extensions>=4.4,<5.0",
     "graia-amnesia~=0.7.0",
-    "creart-graia @ git+https://github.com/GraiaProject/creart-graia.git",
-    "launart~=0.6.2",
+    "launart>=0.6.4,<0.7",
     "packaging>=23.0",
+    "creart~=0.3.0",
 ]
 name = "graia-ariadne"
 description = "Another elegant Python QQ Bot framework for mirai and mirai-api-http v2."
@@ -83,8 +83,8 @@ source = "file"
 path = "src/graia/ariadne/__init__.py"
 
 [build-system]
-requires = ["pdm-pep517>=1.0.0"]
-build-backend = "pdm.pep517.api"
+requires = ["pdm-backend"]
+build-backend = "pdm.backend"
 
 [tool.black]
 line-length = 110

src/graia/ariadne/app.py

@@ -309,7 +309,7 @@ def launch_blocking(cls, stop_signals: Iterable[signal.Signals] = (signal.SIGINT
             raise ValueError("No account specified.")
         cls._patch_launch_manager()
         try:
-            cls.launch_manager.launch_blocking(loop=cls.service.loop, stop_signal=stop_signals)
+            cls.launch_manager.launch_blocking(stop_signal=stop_signals)
         except asyncio.CancelledError:
             logger.info("Launch manager exited.", style="red")
 

src/graia/ariadne/console/__init__.py

@@ -3,8 +3,10 @@
 注意, 本实现并不 robust, 但是可以使用
 """
 
+import asyncio
 import contextlib
 import importlib.metadata
+from creart import it
 import sys
 from asyncio.events import AbstractEventLoop
 from asyncio.tasks import Task
@@ -173,7 +175,7 @@ async def catch(self, interface: DispatcherInterface):
                 if interface.annotation is Broadcast:
                     return self.console.broadcast
                 if interface.annotation is AbstractEventLoop:
-                    return self.console.broadcast.loop
+                    return asyncio.get_running_loop()
 
         while self.running:
             try:
@@ -214,7 +216,7 @@ def start(self):
                     logger.remove(0)
                 self.handler_id = logger.add(StdoutProxy(raw=True))  # type: ignore
 
-            self.task = self.broadcast.loop.create_task(self.loop())
+            self.task = it(AbstractEventLoop).create_task(self.loop())
 
     def stop(self):
         """提示 Console 停止, 非异步, 幂等"""

src/graia/ariadne/dispatcher.py

@@ -43,7 +43,7 @@ async def catch(interface: DispatcherInterface):
             return Ariadne.service.broadcast
 
         if generic_issubclass(asyncio.AbstractEventLoop, interface.annotation):
-            return Ariadne.service.broadcast.loop
+            return Ariadne.service.loop
 
         if generic_issubclass(Ariadne, interface.annotation):
             return Ariadne.current()

src/graia/ariadne/message/commander/__init__.py

@@ -608,7 +608,7 @@ def push_pending(index: int, nxt: MatchNode[CommandEntry], params: Tuple[ChainCo
             tasks: List[asyncio.Task] = []
             for entry, param in execution:
                 commander_param_ctx.set(param)
-                tasks.append(self.broadcast.loop.create_task(self.broadcast.Executor(entry, dispatchers)))
+                tasks.append(asyncio.create_task(self.broadcast.Executor(entry, dispatchers)))
             done, _ = await asyncio.wait(tasks)
             for task in done:
                 if task.exception() and isinstance(task.exception(), PropagationCancelled):