summaryrefslogtreecommitdiff
path: root/AyaBot/plugins/aio
diff options
context:
space:
mode:
authorKyomotoi <[email protected]>2020-05-31 13:01:26 +0800
committerKyomotoi <[email protected]>2020-05-31 13:01:26 +0800
commitdc793e5d8d2c2ea2d48a51f6b04c1518dd44c200 (patch)
treee7a19132b013c8ccb899d384e8509bdcd54108ae /AyaBot/plugins/aio
parent76bc38277716348f4ecc5d8adbc199d40d9c1064 (diff)
downloadATRI-dc793e5d8d2c2ea2d48a51f6b04c1518dd44c200.tar.gz
ATRI-dc793e5d8d2c2ea2d48a51f6b04c1518dd44c200.tar.bz2
ATRI-dc793e5d8d2c2ea2d48a51f6b04c1518dd44c200.zip
删除部分失败作品,新增疫情查询
Diffstat (limited to 'AyaBot/plugins/aio')
-rw-r--r--AyaBot/plugins/aio/__init__.py8
-rw-r--r--AyaBot/plugins/aio/__pycache__/__init__.cpython-37.pycbin432 -> 0 bytes
-rw-r--r--AyaBot/plugins/aio/requests.py71
3 files changed, 0 insertions, 79 deletions
diff --git a/AyaBot/plugins/aio/__init__.py b/AyaBot/plugins/aio/__init__.py
deleted file mode 100644
index 3cc81f0..0000000
--- a/AyaBot/plugins/aio/__init__.py
+++ /dev/null
@@ -1,8 +0,0 @@
-import asyncio
-from functools import partial
-from typing import Any
-
-
-async def run_sync_func(func, *args, **kwargs) -> Any:
- return await asyncio.get_event_loop().run_in_executor(
- None, partial(func, *args, **kwargs))
diff --git a/AyaBot/plugins/aio/__pycache__/__init__.cpython-37.pyc b/AyaBot/plugins/aio/__pycache__/__init__.cpython-37.pyc
deleted file mode 100644
index 416e999..0000000
--- a/AyaBot/plugins/aio/__pycache__/__init__.cpython-37.pyc
+++ /dev/null
Binary files differ
diff --git a/AyaBot/plugins/aio/requests.py b/AyaBot/plugins/aio/requests.py
deleted file mode 100644
index 4f7b9d3..0000000
--- a/AyaBot/plugins/aio/requests.py
+++ /dev/null
@@ -1,71 +0,0 @@
-from typing import Optional, Any
-
-import requests
-from requests import *
-
-from . import run_sync_func
-
-
-class AsyncResponse:
- def __init__(self, response: requests.Response):
- self.raw_response = response
-
- @property
- def ok(self) -> bool:
- return self.raw_response.ok
-
- def __repr__(self):
- return '<AsyncResponse [%s]>' % self.raw_response.status_code
-
- def __bool__(self):
- return self.ok
-
- @property
- async def content(self) -> Optional[bytes]:
- return await run_sync_func(lambda: self.raw_response.content)
-
- @property
- async def text(self) -> str:
- return await run_sync_func(lambda: self.raw_response.text)
-
- async def json(self, **kwargs) -> Any:
- return await run_sync_func(self.raw_response.json, **kwargs)
-
-
-async def request(method, url, **kwargs) -> AsyncResponse:
- return AsyncResponse(await run_sync_func(requests.request,
- method=method, url=url, **kwargs))
-
-
-async def get(url, params=None, **kwargs) -> AsyncResponse:
- return AsyncResponse(
- await run_sync_func(requests.get, url=url, params=params, **kwargs))
-
-
-async def options(url, **kwargs) -> AsyncResponse:
- return AsyncResponse(
- await run_sync_func(requests.options, url=url, **kwargs))
-
-
-async def head(url, **kwargs) -> AsyncResponse:
- return AsyncResponse(await run_sync_func(requests.head, url=url, **kwargs))
-
-
-async def post(url, data=None, json=None, **kwargs) -> AsyncResponse:
- return AsyncResponse(await run_sync_func(requests.post, url=url,
- data=data, json=json, **kwargs))
-
-
-async def put(url, data=None, **kwargs) -> AsyncResponse:
- return AsyncResponse(
- await run_sync_func(requests.put, url=url, data=data, **kwargs))
-
-
-async def patch(url, data=None, **kwargs) -> AsyncResponse:
- return AsyncResponse(
- await run_sync_func(requests.patch, url=url, data=data, **kwargs))
-
-
-async def delete(url, **kwargs) -> AsyncResponse:
- return AsyncResponse(
- await run_sync_func(requests.delete, url=url, **kwargs))