mirror of
https://github.com/yasirarism/MissKatyPyro.git
synced 2026-01-01 10:34:51 +00:00
a7008c664e
* ci: Update .deepsource.toml
* ci: Update .deepsource.toml
* style: format code with black and isort
Format code with black and isort
This commit fixes the style issues introduced in 0fb651a according to the output
from Black and isort.
Details: https://app.deepsource.com/gh/yasirarism/MissKatyPyro/transform/d8f2f66e-b496-4686-aca6-9830236eda12/
---------
Co-authored-by: deepsource-io[bot] <42547082+deepsource-io[bot]@users.noreply.github.com>
Co-authored-by: deepsource-autofix[bot] <62050782+deepsource-autofix[bot]@users.noreply.github.com>
67 lines
2.3 KiB
Python
67 lines
2.3 KiB
Python
"""
|
|
* @author yasir <yasiramunandar@gmail.com>
|
|
* @date 2022-12-01 09:12:27
|
|
* @projectName MissKatyPyro
|
|
* Copyright @YasirPedia All rights reserved
|
|
"""
|
|
import platform
|
|
import time
|
|
from asyncio import Lock
|
|
from re import MULTILINE, findall
|
|
from subprocess import run as srun
|
|
|
|
from pyrogram import Client
|
|
from pyrogram import __version__ as pyrover
|
|
from pyrogram import filters
|
|
from pyrogram.types import Message
|
|
|
|
from misskaty import app, botStartTime, misskaty_version
|
|
from misskaty.core.decorator.ratelimiter import ratelimiter
|
|
from misskaty.helper.human_read import get_readable_time
|
|
from misskaty.vars import COMMAND_HANDLER
|
|
|
|
|
|
@app.on_message(filters.command(["ping"], COMMAND_HANDLER))
|
|
@ratelimiter
|
|
async def ping(self: Client, ctx: Message):
|
|
currentTime = get_readable_time(time.time() - botStartTime)
|
|
start_t = time.time()
|
|
rm = await ctx.reply_msg("🐱 Pong!!...")
|
|
end_t = time.time()
|
|
time_taken_s = round(end_t - start_t, 3)
|
|
await rm.edit_msg(
|
|
f"<b>🐈 MissKatyBot {misskaty_version} based Pyrogram {pyrover} Online.</b>\n\n<b>Ping:</b> <code>{time_taken_s} detik</code>\n<b>Uptime:</b> <code>{currentTime}</code>\n<b>Python Version:</b> <code>{platform.python_version()}</code>"
|
|
)
|
|
|
|
|
|
@app.on_message(filters.command(["ping_dc"], COMMAND_HANDLER))
|
|
@ratelimiter
|
|
async def ping_handler(self: Client, ctx: Message):
|
|
m = await ctx.reply_msg("Pinging datacenters...")
|
|
async with Lock():
|
|
ips = {
|
|
"dc1": "149.154.175.53",
|
|
"dc2": "149.154.167.51",
|
|
"dc3": "149.154.175.100",
|
|
"dc4": "149.154.167.91",
|
|
"dc5": "91.108.56.130",
|
|
}
|
|
text = "**Pings:**\n"
|
|
|
|
for dc, ip in ips.items():
|
|
try:
|
|
shell = srun(
|
|
["ping", "-c", "1", "-W", "2", ip],
|
|
text=True,
|
|
check=True,
|
|
capture_output=True,
|
|
)
|
|
resp_time = findall(r"time=.+m?s", shell.stdout, MULTILINE)[0].replace(
|
|
"time=", ""
|
|
)
|
|
|
|
text += f" **{dc.upper()}:** {resp_time} ✅\n"
|
|
except Exception:
|
|
# There's a cross emoji here, but it's invisible.
|
|
text += f" **{dc.upper}:** ❌\n"
|
|
await m.edit_msg(text)
|