chore(http client): AbstractClientInterface

Author: ProgramRipper

src/graia/amnesia/builtins/aiohttp.py

@@ -38,7 +38,10 @@
 
 from graia.amnesia.json import Json, TJson
 from graia.amnesia.transport import Transport
-from graia.amnesia.transport.common.http import AbstractServerRequestIO
+from graia.amnesia.transport.common.http import (
+    AbstractClientInterface,
+    AbstractServerRequestIO,
+)
 from graia.amnesia.transport.common.http import HttpEndpoint as HttpEndpoint
 from graia.amnesia.transport.common.http.extra import HttpRequest, HttpResponse
 from graia.amnesia.transport.common.http.io import AbstractClientRequestIO
@@ -96,7 +99,7 @@ def __init__(self, rider: ClientConnectionRider) -> None:
         self.response = rider.response
 
     async def read(self) -> bytes:
-        data=await self.response.read()
+        data = await self.response.read()
         if self.rider.status.connected and not self.rider.status.drop:
             self.close()
         return data
@@ -297,7 +300,7 @@ def use(self, transport: Transport):
         return self.task
 
 
-class AiohttpClientInterface(ExportInterface["AiohttpService"]):
+class AiohttpClientInterface(AbstractClientInterface["AiohttpService"]):
     service: AiohttpService
 
     def __init__(self, service: AiohttpService) -> None:

src/graia/amnesia/transport/common/http/__init__.py

@@ -1,8 +1,13 @@
+from abc import ABCMeta, abstractmethod
 from dataclasses import dataclass, field
-from typing import Callable, Coroutine, List, Literal
+from typing import Any, Callable, Coroutine, List, Literal, Optional
 
+from launart.service import ExportInterface, TService
+
+from graia.amnesia.json import TJson
 from graia.amnesia.transport.common.http.io import AbstractServerRequestIO
 from graia.amnesia.transport.common.http.responses import T_HttpResponse
+from graia.amnesia.transport.rider import TransportRider
 from graia.amnesia.transport.signature import TransportSignature
 
 
@@ -20,3 +25,28 @@ class HttpEndpoint(
 
     def __hash__(self) -> int:
         return hash(self.path) + hash(id(self.methods))
+
+
+class AbstractClientInterface(ExportInterface[TService], metaclass=ABCMeta):
+    @abstractmethod
+    def __init__(self, service: TService) -> None:
+        raise NotImplementedError
+
+    @abstractmethod
+    def request(
+        self,
+        method: str,
+        url: str,
+        params: Optional[dict] = None,
+        data: Optional[Any] = None,
+        headers: Optional[dict] = None,
+        cookies: Optional[dict] = None,
+        timeout: Optional[float] = None,
+        *,
+        json: Optional[TJson] = None,
+        **kwargs: Any,
+    ) -> TransportRider:
+        raise NotImplementedError
+
+    def websocket(self, url: str, **kwargs) -> TransportRider:
+        raise NotImplementedError