v0.1.3 #74
@ -23,7 +23,7 @@ class PyroClient(LibPyroClient):
|
|||||||
|
|
||||||
super().__init__(**kwargs)
|
super().__init__(**kwargs)
|
||||||
|
|
||||||
self.updater = Updater(ClientSession())
|
self.updater = Updater()
|
||||||
self.contexts = []
|
self.contexts = []
|
||||||
|
|
||||||
if self.scheduler is not None:
|
if self.scheduler is not None:
|
||||||
|
@ -1,5 +1,5 @@
|
|||||||
import logging
|
import logging
|
||||||
from typing import Any, Dict, Tuple
|
from typing import Any, Dict, Tuple, Union
|
||||||
|
|
||||||
from aiohttp import ClientSession
|
from aiohttp import ClientSession
|
||||||
|
|
||||||
@ -7,12 +7,15 @@ logger = logging.getLogger(__name__)
|
|||||||
|
|
||||||
|
|
||||||
class Updater:
|
class Updater:
|
||||||
def __init__(self, client_session: ClientSession) -> None:
|
def __init__(self, client_session: Union[ClientSession, None] = None) -> None:
|
||||||
self.client_session: ClientSession = client_session
|
self.client_session: Union[ClientSession, None] = client_session
|
||||||
|
|
||||||
async def check_updates(
|
async def check_updates(
|
||||||
self, version_current: Tuple[int, int, int], api_url: str
|
self, version_current: Tuple[int, int, int], api_url: str
|
||||||
) -> bool:
|
) -> bool:
|
||||||
|
if not self.client_session:
|
||||||
|
self.client_session = ClientSession()
|
||||||
|
|
||||||
response = await self.client_session.get(api_url)
|
response = await self.client_session.get(api_url)
|
||||||
|
|
||||||
if response.status != 200:
|
if response.status != 200:
|
||||||
@ -30,6 +33,9 @@ class Updater:
|
|||||||
)
|
)
|
||||||
|
|
||||||
async def get_latest_release(self, api_url: str) -> Dict[str, Any]:
|
async def get_latest_release(self, api_url: str) -> Dict[str, Any]:
|
||||||
|
if not self.client_session:
|
||||||
|
self.client_session = ClientSession()
|
||||||
|
|
||||||
response = await self.client_session.get(api_url)
|
response = await self.client_session.get(api_url)
|
||||||
|
|
||||||
if response.status != 200:
|
if response.status != 200:
|
||||||
|
4
main.py
4
main.py
@ -4,6 +4,7 @@ from argparse import ArgumentParser
|
|||||||
from os import getpid
|
from os import getpid
|
||||||
from pathlib import Path
|
from pathlib import Path
|
||||||
|
|
||||||
|
from aiohttp import ClientSession
|
||||||
from convopyro import Conversation
|
from convopyro import Conversation
|
||||||
from libbot import sync
|
from libbot import sync
|
||||||
|
|
||||||
@ -41,7 +42,8 @@ def main():
|
|||||||
exit()
|
exit()
|
||||||
|
|
||||||
client = PyroClient(
|
client = PyroClient(
|
||||||
scheduler=scheduler, commands_source=sync.json_read(Path("commands.json"))
|
scheduler=scheduler,
|
||||||
|
commands_source=sync.json_read(Path("commands.json")),
|
||||||
)
|
)
|
||||||
Conversation(client)
|
Conversation(client)
|
||||||
|
|
||||||
|
@ -1,4 +1,4 @@
|
|||||||
aiohttp~=3.9.5
|
aiohttp~=3.10.2
|
||||||
apscheduler~=3.10.4
|
apscheduler~=3.10.4
|
||||||
async_pymongo==0.1.6
|
async_pymongo==0.1.6
|
||||||
convopyro==0.5
|
convopyro==0.5
|
||||||
|
Reference in New Issue
Block a user