Compare commits
58 Commits
Author | SHA1 | Date | |
---|---|---|---|
b9550032ba | |||
6b44a5852e
|
|||
7af4ad9655
|
|||
cb09910123 | |||
d1da6a1d8b | |||
787fc8c590 | |||
b690725a47 | |||
8719a44720 | |||
2fa65e7c76 | |||
d3502bd935 | |||
de3183d4ed | |||
19f8383fb4 | |||
9e957b7533 | |||
5de6fac3dd | |||
de2524921e | |||
28001f3288 | |||
af82545980 | |||
8308ed0c9d | |||
bf9f19321a | |||
6284d6e631 | |||
63a6542293 | |||
6521a9a510 | |||
1d22188bfc | |||
3a718caacf | |||
06c4b9f845 | |||
00a835442c | |||
4349dcf4d7 | |||
c5c07bd75d | |||
52f2630fda | |||
80e861800c | |||
874892924f | |||
fd113f861b | |||
de7a9ef181 | |||
cde0393baf | |||
70073bf68e | |||
d4ad6609d6 | |||
1e6b2ccaca | |||
abd4f035ad | |||
0408cd676f | |||
b1c61f0a5b | |||
6e7d3c5e6f | |||
458c2ef615 | |||
dc9c83dc68 | |||
48d1d9291a | |||
451b0c5135 | |||
f950eaa339 | |||
bd3c62fed8
|
|||
16658efb17
|
|||
eb0a43e360 | |||
d3a423a560 | |||
20cc754a2a
|
|||
fc14cad3ff
|
|||
5ba763246b | |||
327b161b41
|
|||
c756c6b1dc
|
|||
9e9c90fce1
|
|||
91cc03f921 | |||
a0538625e2 |
21
examples/commands.json
Normal file
21
examples/commands.json
Normal file
@@ -0,0 +1,21 @@
|
|||||||
|
{
|
||||||
|
"help": {
|
||||||
|
"scopes": [
|
||||||
|
{
|
||||||
|
"name": "BotCommandScopeDefault"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"name": "BotCommandScopeChat",
|
||||||
|
"chat_id": "owner"
|
||||||
|
}
|
||||||
|
]
|
||||||
|
},
|
||||||
|
"shutdown": {
|
||||||
|
"scopes": [
|
||||||
|
{
|
||||||
|
"name": "BotCommandScopeChat",
|
||||||
|
"chat_id": "owner"
|
||||||
|
}
|
||||||
|
]
|
||||||
|
}
|
||||||
|
}
|
38
examples/config.json
Normal file
38
examples/config.json
Normal file
@@ -0,0 +1,38 @@
|
|||||||
|
{
|
||||||
|
"locale": "en",
|
||||||
|
"bot": {
|
||||||
|
"owner": 0,
|
||||||
|
"api_id": 0,
|
||||||
|
"api_hash": "",
|
||||||
|
"bot_token": "",
|
||||||
|
"workers": 1,
|
||||||
|
"max_concurrent_transmissions": 1,
|
||||||
|
"scoped_commands": true
|
||||||
|
},
|
||||||
|
"reports": {
|
||||||
|
"chat_id": "owner"
|
||||||
|
},
|
||||||
|
"disabled_plugins": [],
|
||||||
|
"commands": {
|
||||||
|
"help": {
|
||||||
|
"scopes": [
|
||||||
|
{
|
||||||
|
"name": "BotCommandScopeDefault"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"name": "BotCommandScopeChat",
|
||||||
|
"chat_id": "owner"
|
||||||
|
}
|
||||||
|
]
|
||||||
|
},
|
||||||
|
"shutdown": {
|
||||||
|
"scopes": [
|
||||||
|
{
|
||||||
|
"name": "BotCommandScopeChat",
|
||||||
|
"chat_id": "owner"
|
||||||
|
}
|
||||||
|
]
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
23
examples/locale.json
Normal file
23
examples/locale.json
Normal file
@@ -0,0 +1,23 @@
|
|||||||
|
{
|
||||||
|
"metadata": {
|
||||||
|
"flag": "🇬🇧",
|
||||||
|
"name": "English",
|
||||||
|
"codes": [
|
||||||
|
"en"
|
||||||
|
]
|
||||||
|
},
|
||||||
|
"bot": {
|
||||||
|
"name": "Your Bot",
|
||||||
|
"about": "I'm a your bot. Nice to meet you!",
|
||||||
|
"description": "I'm just your bot. Yet nice to meet you!"
|
||||||
|
},
|
||||||
|
"commands": {
|
||||||
|
"help": "Show help message"
|
||||||
|
},
|
||||||
|
"messages": {
|
||||||
|
"help": "Sample Text"
|
||||||
|
},
|
||||||
|
"callbacks": {
|
||||||
|
"sample": "This button is working!"
|
||||||
|
}
|
||||||
|
}
|
@@ -1,11 +1,11 @@
|
|||||||
black==23.12.1
|
black==24.4.2
|
||||||
build==1.0.3
|
build==1.2.1
|
||||||
isort==5.13.2
|
isort==5.13.2
|
||||||
mypy==1.8.0
|
mypy==1.10.0
|
||||||
pylint==3.0.3
|
pylint==3.2.0
|
||||||
pytest-asyncio==0.23.2
|
pytest-asyncio==0.23.6
|
||||||
pytest-cov==4.1.0
|
pytest-cov==5.0.0
|
||||||
pytest==7.4.3
|
pytest==8.2.0
|
||||||
tox==4.11.4
|
tox==4.15.0
|
||||||
types-aiofiles==23.2.0.0
|
types-aiofiles==23.2.0.20240403
|
||||||
types-ujson==5.9.0.0
|
types-ujson==5.9.0.0
|
@@ -1,2 +1,2 @@
|
|||||||
apscheduler~=3.10.4
|
apscheduler~=3.10.4
|
||||||
py-cord~=2.4.1
|
py-cord~=2.5.0
|
@@ -1,2 +1,2 @@
|
|||||||
apscheduler~=3.10.4
|
apscheduler~=3.10.4
|
||||||
pyrogram~=2.0.106
|
pyrofork~=2.3.21.post3
|
@@ -1 +1 @@
|
|||||||
ujson~=5.9.0
|
ujson~=5.10.0
|
@@ -1,4 +1,4 @@
|
|||||||
__version__ = "2.1.0"
|
__version__ = "3.0.1"
|
||||||
__license__ = "GPL3"
|
__license__ = "GPL3"
|
||||||
__author__ = "Profitroll"
|
__author__ = "Profitroll"
|
||||||
|
|
||||||
|
@@ -46,6 +46,7 @@ class PyroClient(Client):
|
|||||||
def __init__(
|
def __init__(
|
||||||
self,
|
self,
|
||||||
name: str = "bot_client",
|
name: str = "bot_client",
|
||||||
|
owner: Union[int, None] = None,
|
||||||
config: Union[Dict[str, Any], None] = None,
|
config: Union[Dict[str, Any], None] = None,
|
||||||
config_path: Union[str, Path] = Path("config.json"),
|
config_path: Union[str, Path] = Path("config.json"),
|
||||||
api_id: Union[int, None] = None,
|
api_id: Union[int, None] = None,
|
||||||
@@ -58,6 +59,8 @@ class PyroClient(Client):
|
|||||||
sleep_threshold: int = 120,
|
sleep_threshold: int = 120,
|
||||||
max_concurrent_transmissions: int = 1,
|
max_concurrent_transmissions: int = 1,
|
||||||
commands_source: Union[Dict[str, dict], None] = None,
|
commands_source: Union[Dict[str, dict], None] = None,
|
||||||
|
scoped_commands: Union[bool, None] = None,
|
||||||
|
i18n_bot_info: bool = False,
|
||||||
scheduler: Union[AsyncIOScheduler, BackgroundScheduler, None] = None,
|
scheduler: Union[AsyncIOScheduler, BackgroundScheduler, None] = None,
|
||||||
**kwargs,
|
**kwargs,
|
||||||
):
|
):
|
||||||
@@ -93,17 +96,21 @@ class PyroClient(Client):
|
|||||||
else max_concurrent_transmissions,
|
else max_concurrent_transmissions,
|
||||||
**kwargs,
|
**kwargs,
|
||||||
)
|
)
|
||||||
self.owner: int = self.config["bot"]["owner"]
|
self.owner: int = self.config["bot"]["owner"] if owner is None else owner
|
||||||
self.commands: List[PyroCommand] = []
|
self.commands: List[PyroCommand] = []
|
||||||
self.commands_source: Dict[str, dict] = (
|
self.commands_source: Dict[str, dict] = (
|
||||||
self.config["commands"] if commands_source is None else commands_source
|
self.config["commands"] if commands_source is None else commands_source
|
||||||
)
|
)
|
||||||
self.scoped_commands: bool = self.config["bot"]["scoped_commands"]
|
self.scoped_commands: bool = (
|
||||||
|
self.config["bot"]["scoped_commands"]
|
||||||
|
if scoped_commands is None
|
||||||
|
else scoped_commands
|
||||||
|
)
|
||||||
self.start_time: float = 0
|
self.start_time: float = 0
|
||||||
|
|
||||||
self.bot_locale: BotLocale = BotLocale(
|
self.bot_locale: BotLocale = BotLocale(
|
||||||
default_locale=self.config["locale"],
|
default_locale=self.config["locale"],
|
||||||
locales_root=(Path("locale") if locales_root is None else locales_root)
|
locales_root=(Path("locale") if locales_root is None else locales_root),
|
||||||
)
|
)
|
||||||
self.default_locale: str = self.bot_locale.default
|
self.default_locale: str = self.bot_locale.default
|
||||||
self.locales: dict = self.bot_locale.locales
|
self.locales: dict = self.bot_locale.locales
|
||||||
@@ -116,6 +123,8 @@ class PyroClient(Client):
|
|||||||
|
|
||||||
self.scopes_placeholders: Dict[str, int] = {"owner": self.owner}
|
self.scopes_placeholders: Dict[str, int] = {"owner": self.owner}
|
||||||
|
|
||||||
|
self.i18n_bot_info: bool = i18n_bot_info
|
||||||
|
|
||||||
async def start(self, register_commands: bool = True) -> None:
|
async def start(self, register_commands: bool = True) -> None:
|
||||||
await super().start()
|
await super().start()
|
||||||
|
|
||||||
@@ -129,6 +138,55 @@ class PyroClient(Client):
|
|||||||
getpid(),
|
getpid(),
|
||||||
)
|
)
|
||||||
|
|
||||||
|
if self.i18n_bot_info:
|
||||||
|
# Register default bot's info
|
||||||
|
try:
|
||||||
|
await self.set_bot_info(
|
||||||
|
name=self._("name", "bot"),
|
||||||
|
about=self._("about", "bot"),
|
||||||
|
description=self._("description", "bot"),
|
||||||
|
lang_code="",
|
||||||
|
)
|
||||||
|
logger.info(
|
||||||
|
"Bot's info for the default locale %s has been updated",
|
||||||
|
self.default_locale,
|
||||||
|
)
|
||||||
|
except KeyError:
|
||||||
|
logger.warning(
|
||||||
|
"Default locale %s has incorrect keys or values in bot section",
|
||||||
|
self.default_locale,
|
||||||
|
)
|
||||||
|
|
||||||
|
# Register bot's info for each available locale
|
||||||
|
for locale_code in self.locales:
|
||||||
|
locale = self.locales[locale_code]
|
||||||
|
|
||||||
|
if "metadata" not in locale or ("codes" not in locale["metadata"]):
|
||||||
|
logger.warning(
|
||||||
|
"Locale %s is missing metadata or metadata.codes key",
|
||||||
|
locale_code,
|
||||||
|
)
|
||||||
|
continue
|
||||||
|
|
||||||
|
for code in locale["metadata"]["codes"]:
|
||||||
|
try:
|
||||||
|
await self.set_bot_info(
|
||||||
|
name=locale["bot"]["name"],
|
||||||
|
about=locale["bot"]["about"],
|
||||||
|
description=locale["bot"]["description"],
|
||||||
|
lang_code=code,
|
||||||
|
)
|
||||||
|
logger.info(
|
||||||
|
"Bot's info for the locale %s has been updated",
|
||||||
|
self.code,
|
||||||
|
)
|
||||||
|
except KeyError:
|
||||||
|
logger.warning(
|
||||||
|
"Locale %s has incorrect keys or values in bot section",
|
||||||
|
locale_code,
|
||||||
|
)
|
||||||
|
|
||||||
|
# Send a message to the bot's reports chat about the startup
|
||||||
try:
|
try:
|
||||||
await self.send_message(
|
await self.send_message(
|
||||||
chat_id=self.owner
|
chat_id=self.owner
|
||||||
@@ -136,10 +194,13 @@ class PyroClient(Client):
|
|||||||
else self.config["reports"]["chat_id"],
|
else self.config["reports"]["chat_id"],
|
||||||
text=f"Bot started PID `{getpid()}`",
|
text=f"Bot started PID `{getpid()}`",
|
||||||
)
|
)
|
||||||
|
except BadRequest:
|
||||||
|
logger.warning("Unable to send message to report chat.")
|
||||||
|
|
||||||
if self.scheduler is None:
|
if self.scheduler is None:
|
||||||
return
|
return
|
||||||
|
|
||||||
|
# Schedule the task to register all commands
|
||||||
if register_commands:
|
if register_commands:
|
||||||
self.scheduler.add_job(
|
self.scheduler.add_job(
|
||||||
self.register_commands,
|
self.register_commands,
|
||||||
@@ -149,8 +210,6 @@ class PyroClient(Client):
|
|||||||
)
|
)
|
||||||
|
|
||||||
self.scheduler.start()
|
self.scheduler.start()
|
||||||
except BadRequest:
|
|
||||||
logger.warning("Unable to send message to report chat.")
|
|
||||||
|
|
||||||
async def stop(self, exit_completely: bool = True) -> None:
|
async def stop(self, exit_completely: bool = True) -> None:
|
||||||
try:
|
try:
|
||||||
@@ -170,16 +229,16 @@ class PyroClient(Client):
|
|||||||
if exit_completely:
|
if exit_completely:
|
||||||
try:
|
try:
|
||||||
exit()
|
exit()
|
||||||
except SystemExit as exp:
|
except SystemExit as exc:
|
||||||
raise SystemExit(
|
raise SystemExit(
|
||||||
"Bot has been shut down, this is not an application error!"
|
"Bot has been shut down, this is not an application error!"
|
||||||
) from exp
|
) from exc
|
||||||
|
|
||||||
async def collect_commands(self) -> Union[List[CommandSet], None]:
|
async def collect_commands(self) -> Union[List[CommandSet], None]:
|
||||||
"""Gather list of the bot's commands
|
"""Gather list of the bot's commands
|
||||||
|
|
||||||
### Returns:
|
### Returns:
|
||||||
* `List[CommandSet]`: List of the commands' sets
|
* `List[CommandSet]`: List of the commands' sets.
|
||||||
"""
|
"""
|
||||||
command_sets = None
|
command_sets = None
|
||||||
|
|
||||||
|
@@ -1,4 +1,16 @@
|
|||||||
{
|
{
|
||||||
|
"metadata": {
|
||||||
|
"flag": "🇬🇧",
|
||||||
|
"name": "English",
|
||||||
|
"codes": [
|
||||||
|
"en"
|
||||||
|
]
|
||||||
|
},
|
||||||
|
"bot": {
|
||||||
|
"name": "",
|
||||||
|
"about": "",
|
||||||
|
"description": ""
|
||||||
|
},
|
||||||
"foo": "bar",
|
"foo": "bar",
|
||||||
"messages": {
|
"messages": {
|
||||||
"example": "okay"
|
"example": "okay"
|
||||||
|
@@ -1,4 +1,16 @@
|
|||||||
{
|
{
|
||||||
|
"metadata": {
|
||||||
|
"flag": "🇺🇦",
|
||||||
|
"name": "Українська",
|
||||||
|
"codes": [
|
||||||
|
"uk"
|
||||||
|
]
|
||||||
|
},
|
||||||
|
"bot": {
|
||||||
|
"name": "",
|
||||||
|
"about": "",
|
||||||
|
"description": ""
|
||||||
|
},
|
||||||
"foo": "бар",
|
"foo": "бар",
|
||||||
"messages": {
|
"messages": {
|
||||||
"example": "окей"
|
"example": "окей"
|
||||||
|
Reference in New Issue
Block a user