mirror of
https://github.com/nonebot/nonebot2.git
synced 2024-11-28 04:56:57 +08:00
💡 add comments in quart driver
This commit is contained in:
parent
496f64f103
commit
86965ee06d
12
docs_build/drivers/quart.rst
Normal file
12
docs_build/drivers/quart.rst
Normal file
@ -0,0 +1,12 @@
|
|||||||
|
---
|
||||||
|
contentSidebar: true
|
||||||
|
sidebarDepth: 0
|
||||||
|
---
|
||||||
|
|
||||||
|
NoneBot.drivers.quart 模块
|
||||||
|
==========================
|
||||||
|
|
||||||
|
.. automodule:: nonebot.drivers.quart
|
||||||
|
:members:
|
||||||
|
:private-members:
|
||||||
|
:show-inheritance:
|
@ -1,3 +1,13 @@
|
|||||||
|
"""
|
||||||
|
Quart 驱动适配
|
||||||
|
================
|
||||||
|
|
||||||
|
后端使用方法请参考: `Quart 文档`_
|
||||||
|
|
||||||
|
.. _Quart 文档:
|
||||||
|
https://pgjones.gitlab.io/quart/index.html
|
||||||
|
"""
|
||||||
|
|
||||||
import asyncio
|
import asyncio
|
||||||
from json.decoder import JSONDecodeError
|
from json.decoder import JSONDecodeError
|
||||||
from typing import (TYPE_CHECKING, Any, Callable, Coroutine, Dict, Optional,
|
from typing import (TYPE_CHECKING, Any, Callable, Coroutine, Dict, Optional,
|
||||||
@ -28,6 +38,14 @@ _AsyncCallable = TypeVar("_AsyncCallable", bound=Callable[..., Coroutine])
|
|||||||
|
|
||||||
|
|
||||||
class Driver(BaseDriver):
|
class Driver(BaseDriver):
|
||||||
|
"""
|
||||||
|
Quart 驱动框架
|
||||||
|
|
||||||
|
:上报地址:
|
||||||
|
|
||||||
|
* ``/{adapter name}/http/``: HTTP POST 上报
|
||||||
|
* ``/{adapter name}/ws``: WebSocket 上报
|
||||||
|
"""
|
||||||
|
|
||||||
@overrides(BaseDriver)
|
@overrides(BaseDriver)
|
||||||
def __init__(self, env: Env, config: NoneBotConfig):
|
def __init__(self, env: Env, config: NoneBotConfig):
|
||||||
@ -37,6 +55,7 @@ class Driver(BaseDriver):
|
|||||||
|
|
||||||
@overrides(BaseDriver)
|
@overrides(BaseDriver)
|
||||||
def register_adapter(self, name: str, adapter: Type["Bot"], **kwargs):
|
def register_adapter(self, name: str, adapter: Type["Bot"], **kwargs):
|
||||||
|
"""向 Quart 路由添加对应 adapter 响应的 handler"""
|
||||||
if name in self._adapters:
|
if name in self._adapters:
|
||||||
return
|
return
|
||||||
|
|
||||||
@ -53,32 +72,37 @@ class Driver(BaseDriver):
|
|||||||
@property
|
@property
|
||||||
@overrides(BaseDriver)
|
@overrides(BaseDriver)
|
||||||
def type(self) -> str:
|
def type(self) -> str:
|
||||||
|
"""驱动名称: ``quart``"""
|
||||||
return 'quart'
|
return 'quart'
|
||||||
|
|
||||||
@property
|
@property
|
||||||
@overrides(BaseDriver)
|
@overrides(BaseDriver)
|
||||||
def server_app(self) -> Quart:
|
def server_app(self) -> Quart:
|
||||||
|
"""``Quart`` 对象"""
|
||||||
return self._server_app
|
return self._server_app
|
||||||
|
|
||||||
@property
|
@property
|
||||||
@overrides(BaseDriver)
|
@overrides(BaseDriver)
|
||||||
def asgi(self):
|
def asgi(self):
|
||||||
|
"""``Quart`` 对象"""
|
||||||
return self._server_app
|
return self._server_app
|
||||||
|
|
||||||
@property
|
@property
|
||||||
@overrides(BaseDriver)
|
@overrides(BaseDriver)
|
||||||
def logger(self):
|
def logger(self):
|
||||||
|
"""fastapi 使用的 logger"""
|
||||||
return self._server_app.logger
|
return self._server_app.logger
|
||||||
|
|
||||||
@overrides(BaseDriver)
|
@overrides(BaseDriver)
|
||||||
def on_startup(self, func: _AsyncCallable) -> _AsyncCallable:
|
def on_startup(self, func: _AsyncCallable) -> _AsyncCallable:
|
||||||
|
"""参考文档: `Startup and Shutdown <https://pgjones.gitlab.io/quart/how_to_guides/startup_shutdown.html>`_"""
|
||||||
return self.server_app.before_serving(func) # type: ignore
|
return self.server_app.before_serving(func) # type: ignore
|
||||||
|
|
||||||
@overrides(BaseDriver)
|
@overrides(BaseDriver)
|
||||||
def on_shutdown(self, func: _AsyncCallable) -> _AsyncCallable:
|
def on_shutdown(self, func: _AsyncCallable) -> _AsyncCallable:
|
||||||
|
"""参考文档: `Startup and Shutdown <https://pgjones.gitlab.io/quart/how_to_guides/startup_shutdown.html>`_"""
|
||||||
return self.server_app.after_serving(func) # type: ignore
|
return self.server_app.after_serving(func) # type: ignore
|
||||||
|
|
||||||
@overrides(BaseDriver)
|
|
||||||
@overrides(BaseDriver)
|
@overrides(BaseDriver)
|
||||||
def run(self,
|
def run(self,
|
||||||
host: Optional[str] = None,
|
host: Optional[str] = None,
|
||||||
|
Loading…
Reference in New Issue
Block a user