Done ig
This commit is contained in:
1
app.py
1
app.py
@@ -1,6 +1,7 @@
|
||||
from flask import Flask
|
||||
app = Flask(__name__)
|
||||
|
||||
|
||||
@app.route('/')
|
||||
def hello_world():
|
||||
return 'This is Moon'
|
||||
|
||||
12
main.py
12
main.py
@@ -53,6 +53,7 @@ if config.STRINGSESSION:
|
||||
|
||||
app = Client("my_account", **common_params)
|
||||
|
||||
|
||||
async def main():
|
||||
logging.basicConfig(
|
||||
format="%(asctime)s - %(name)s - %(levelname)s - %(message)s",
|
||||
@@ -73,8 +74,9 @@ async def main():
|
||||
raise
|
||||
except (errors.NotAcceptable, errors.Unauthorized) as e:
|
||||
logging.error(
|
||||
f"{e.__class__.__name__}: {e}\n"
|
||||
f"Moving session file to my_account.session-old..."
|
||||
"%s: %s\nMoving session file to my_account.session-old..." % (
|
||||
e.__class__.__name__, e
|
||||
)
|
||||
)
|
||||
os.rename("./my_account.session", "./my_account.session-old")
|
||||
restart()
|
||||
@@ -88,14 +90,14 @@ async def main():
|
||||
path.stem, app, core="custom_modules" not in path.parent.parts
|
||||
)
|
||||
except Exception:
|
||||
logging.warning(f"Can't import module {path.stem}", exc_info=True)
|
||||
logging.warning("Can't import module %s", path.stem, exc_info=True)
|
||||
failed_modules += 1
|
||||
else:
|
||||
success_modules += 1
|
||||
|
||||
logging.info(f"Imported {success_modules} modules")
|
||||
logging.info("Imported %s modules", success_modules)
|
||||
if failed_modules:
|
||||
logging.warning(f"Failed to import {failed_modules} modules")
|
||||
logging.warning("Failed to import %s modules", failed_modules)
|
||||
|
||||
if info := db.get("core.updater", "restart_info"):
|
||||
text = {
|
||||
|
||||
@@ -40,8 +40,8 @@ async def sessions_list(client: Client, message: Message):
|
||||
for num, session in enumerate(sessions, 1):
|
||||
formatted_sessions.append(
|
||||
f"<b>{num}</b>. <b>{escape(session.device_model)}</b> on <code>{escape(session.platform if session.platform!= '' else 'unknown platform')}</code>\n"
|
||||
f"<b>Hash:</b> {escape(session.hash)}\n"
|
||||
f"<b>App name:</b> <code>{escape(session.app_name)}</code> v.{escape(session.app_version if session.app_version!= '' else 'unknown')}</>\n"
|
||||
f"<b>Hash:</b> <code>{session.hash}</code>\n"
|
||||
f"<b>App name:</b> <code>{escape(session.app_name)}</code> <code>v.{escape(session.app_version if session.app_version!= '' else 'unknown')}</code>\n"
|
||||
f"<b>Created (last activity):</b> {datetime.fromtimestamp(session.date_created).isoformat()} ({datetime.fromtimestamp(session.date_active).isoformat()})\n"
|
||||
f"<b>IP and location: </b>: <code>{session.ip}</code> (<i>{session.country}</i>)\n"
|
||||
f"<b>Official status:</b> <code>{'✅' if session.official_app else '❌️'}</code>\n"
|
||||
|
||||
@@ -23,6 +23,7 @@ from pyrogram.types import Message
|
||||
|
||||
from utils.misc import modules_help, prefix
|
||||
|
||||
|
||||
@Client.on_message(filters.command(["shell", "sh"], prefix) & filters.me)
|
||||
async def shell(_, message: Message):
|
||||
if len(message.command) < 2:
|
||||
|
||||
@@ -1 +0,0 @@
|
||||
|
||||
|
||||
@@ -228,6 +228,7 @@ class SqliteDatabase(Database):
|
||||
def getaiusers(self):
|
||||
return self.get("core.chatbot", "chatai_users", default=[])
|
||||
|
||||
|
||||
if config.db_type in ["mongo", "mongodb"]:
|
||||
db = MongoDatabase(config.db_url, config.db_name)
|
||||
else:
|
||||
|
||||
@@ -3,6 +3,7 @@ import logging
|
||||
import asyncio
|
||||
from lexica import AsyncClient, Client
|
||||
|
||||
|
||||
def ImageModels():
|
||||
models = Client().models['models']['image']
|
||||
dict_models = {}
|
||||
@@ -12,7 +13,8 @@ def ImageModels():
|
||||
dict_models[model_name] = model_id
|
||||
return dict_models
|
||||
|
||||
async def ImageGeneration(model,prompt):
|
||||
|
||||
async def ImageGeneration(model, prompt):
|
||||
try:
|
||||
output = await AsyncClient().generate(model, prompt, "")
|
||||
if output['code'] != 1:
|
||||
@@ -40,6 +42,7 @@ async def ImageGeneration(model,prompt):
|
||||
finally:
|
||||
await AsyncClient().close()
|
||||
|
||||
|
||||
async def UpscaleImages(image: bytes) -> str:
|
||||
content = await AsyncClient().upscale(image)
|
||||
await AsyncClient().close()
|
||||
|
||||
@@ -444,6 +444,7 @@ def parse_meta_comments(code: str) -> Dict[str, str]:
|
||||
|
||||
return {groups[i]: groups[i + 1] for i in range(0, len(groups), 2)}
|
||||
|
||||
|
||||
def ReplyCheck(message: Message):
|
||||
reply_id = None
|
||||
|
||||
|
||||
Reference in New Issue
Block a user