major changes

* Switched from Pyrogram to Pyrofork
* Implemented modules folder structure
* Added kernelsu command
* Fixed bugs
* Improved functions

Author: ahmetack

requirements.txt

@@ -17,7 +17,7 @@ psycopg2-binary
 pybase64
 pydrive
 pylast
-pyrogram==2.0.106
+pyrofork
 pysmartDL
 python-barcode
 python-dotenv

sedenbot/__init__.py

@@ -11,7 +11,7 @@
 from importlib import import_module
 from logging import CRITICAL, DEBUG, INFO, basicConfig, getLogger
 from os import environ, listdir, path, remove
-from os.path import isfile
+from os.path import isfile, join, isdir
 from pathlib import PurePath
 from re import search as resr
 from sqlite3 import connect
@@ -92,6 +92,7 @@ def set_logger():
         'pyrogram.session.session',
         'pyrogram.session.auth',
         'asyncio',
+        'aiosqlite',
     ]
     level = CRITICAL
 
@@ -258,18 +259,27 @@ def export_session_string(self):
 
 def __get_modules():
     folder = 'sedenbot/modules'
-    modules = [
-        f[:-3]
-        for f in listdir(folder)
-        if isfile(f'{folder}/{f}') and f[-3:] == '.py' and f != '__init__.py'
+    subdirectories = [
+        sub
+        for sub in listdir(folder)
+        if isdir(join(folder, sub))
     ]
+    modules = []
+    for subdirectory in subdirectories:
+        subfolder_path = join(folder, subdirectory)
+        py_files = [
+            f[:-3]
+            for f in listdir(subfolder_path)
+            if isfile(join(subfolder_path, f)) and f.endswith('.py')
+        ]
+        for module in py_files:
+            module_name = f"{subdirectory.replace('/', '.')}.{module}"
+            modules.append(module_name)
     return modules
 
 
 def __import_modules():
     get_modules = sorted(__get_modules())
-    modules = ', '.join(get_modules)
-    LOGS.info(get_translation('loadedModules', [modules]))
     for module in get_modules:
         try:
             import_module(f'sedenbot.modules.{module}')
@@ -278,5 +288,9 @@ def __import_modules():
                 LOGS.warn(format_exc())
             LOGS.warn(get_translation('loadedModulesError', [module]))
 
+    imported_modules = [module.split('.')[-1] for module in get_modules if module.count('.') > 0]
+    modules = ', '.join(imported_modules)
+    LOGS.info(get_translation('loadedModules', [modules]))
+
 
 __import_modules()

sedenbot/modules/ecem.py renamed to sedenbot/modules/admin/ecem.py

@@ -21,7 +21,7 @@
     set_local_env,
     unset_local_env,
 )
-from sedenbot.modules.horeke import restart
+from sedenbot.modules.miscs.horeke import restart
 from sedenecem.core import edit, extract_args, get_translation, sedenify
 
 

sedenbot/modules/env.py renamed to sedenbot/modules/admin/env.py

@@ -16,7 +16,7 @@
 from pyrogram.raw.functions.help import GetNearestDc
 
 from sedenbot import ALIVE_MSG, BOT_VERSION, CHANNEL, HELP
-from sedenbot.modules.ecem import ecem
+from sedenbot.modules.admin.ecem import ecem
 from sedenecem.core import (
     edit,
     extract_args,

sedenbot/modules/seden.py renamed to sedenbot/modules/admin/seden.py

@@ -81,8 +81,8 @@ def keep_read(message):
 @sedenify(pattern='^.call')
 def call_notes(message):
     try:
-        from sedenbot.modules.notes import get_note
-        from sedenbot.modules.snips import get_snip
+        from sedenbot.modules.deneme.notes import get_note
+        from sedenbot.modules.var.snips import get_snip
     except BaseException:
         edit(message, f'`{get_translation("nonSqlMode")}`')
         return

sedenbot/modules/system.py renamed to sedenbot/modules/admin/system.py

@@ -12,7 +12,7 @@
 from pyrogram import enums
 from pyrogram.types import ChatPermissions
 from sedenbot import BRAIN, HELP, LOGS
-from sedenbot.modules.ban import get_reason
+from sedenbot.modules.chat.ban import get_reason
 from sedenecem.core import (
     edit,
     extract_args_split,

sedenbot/modules/updater.py renamed to sedenbot/modules/admin/updater.py

@@ -11,7 +11,7 @@
 from pyrogram.raw.functions.messages import ReportSpam
 from pyrogram.raw.types import InputPeerUser
 from sedenbot import HELP, LOGS, PM_AUTO_BAN, PM_MSG_COUNT, PM_UNAPPROVED, TEMP_SETTINGS
-from sedenbot.modules.chat import is_muted
+from sedenbot.modules.chat.chat import is_muted
 from sedenecem.core import edit, get_translation, reply, sedenify, send_log
 from sqlalchemy.exc import IntegrityError
 

sedenbot/modules/updown.py renamed to sedenbot/modules/admin/updown.py

@@ -0,0 +1,124 @@
+# Copyright (C) 2020-2024 TeamDerUntergang <https://github.com/TeamDerUntergang>
+#
+# This file is part of TeamDerUntergang project,
+# and licensed under GNU Affero General Public License v3.
+# See the GNU Affero General Public License for more details.
+#
+# All rights reserved. See COPYING, AUTHORS.
+#
+
+from os import path, remove
+from time import sleep
+from urllib.parse import quote_plus
+
+from gtts import gTTS
+from selenium.webdriver.common.by import By
+
+from sedenbot import HELP, SEDEN_LANG
+from sedenecem.core import (
+    edit,
+    extract_args,
+    extract_args_split,
+    get_translation,
+    get_webdriver,
+    reply_doc,
+    reply_voice,
+    sedenify,
+    send_log,
+)
+
+CARBONLANG = 'auto'
+TTS_LANG = SEDEN_LANG
+TRT_LANG = SEDEN_LANG
+
+
+@sedenify(pattern='^.crblang')
+def carbonlang(message):
+    global CARBONLANG
+    CARBONLANG = extract_args(message)
+    edit(message, get_translation('carbonLang', ['**', CARBONLANG]))
+
+
+@sedenify(pattern='^.carbon')
+def carbon(message):
+    match = extract_args(message)
+    if len(match) < 1:
+        edit(message, f'`{get_translation("wrongCommand")}`')
+        return
+    edit(message, f'`{get_translation("processing")}`')
+    reply = message.reply_to_message
+    pcode = message.text
+    if pcode[8:]:
+        pcode = str(pcode[8:])
+    elif reply:
+        pcode = str(reply.message)
+    code = quote_plus(pcode)
+    global CARBONLANG
+    CARBON = f'https://carbon.now.sh/?l={CARBONLANG}&code={code}'
+    edit(message, f'`{get_translation("processing")}\n%25`')
+    if path.isfile('./carbon.png'):
+        remove('./carbon.png')
+    driver = get_webdriver()
+    driver.get(CARBON)
+    edit(message, f'`{get_translation("processing")}\n%50`')
+    driver.command_executor._commands['send_command'] = (
+        'POST',
+        '/session/$sessionId/chromium/send_command',
+    )
+    driver.find_element(By.XPATH, "//button[contains(text(),'Export')]").click()
+    edit(message, f'`{get_translation("processing")}\n%75`')
+    while not path.isfile('./carbon.png'):
+        sleep(0.5)
+    edit(message, f'`{get_translation("processing")}\n%100`')
+    file = './carbon.png'
+    edit(message, f'`{get_translation("carbonUpload")}`')
+    reply_doc(
+        reply if reply else message,
+        file,
+        caption=get_translation('carbonResult'),
+        delete_after_send=True,
+    )
+    message.delete()
+    driver.quit()
+
+
+@sedenify(pattern='^.tts')
+def text_to_speech(message):
+    reply = message.reply_to_message
+    args = extract_args(message)
+    if args:
+        pass
+    elif reply:
+        if not reply.text:
+            return edit(message, f'`{get_translation("ttsUsage")}`')
+        args = reply.text
+    else:
+        edit(message, f'`{get_translation("ttsUsage")}`')
+        return
+
+    try:
+        gTTS(args, lang=TTS_LANG)
+    except AssertionError:
+        edit(message, f'`{get_translation("ttsBlank")}`')
+        return
+    except ValueError:
+        edit(message, f'`{get_translation("ttsNoSupport")}`')
+        return
+    except RuntimeError:
+        edit(message, f'`{get_translation("ttsError")}`')
+        return
+    tts = gTTS(args, lang=TTS_LANG)
+    tts.save('h.mp3')
+    with open('h.mp3', 'rb') as audio:
+        linelist = list(audio)
+        linecount = len(linelist)
+    if linecount == 1:
+        tts = gTTS(args, lang=TTS_LANG)
+        tts.save('h.mp3')
+    with open('h.mp3', 'r'):
+        reply_voice(reply if reply else message, 'h.mp3', delete_file=True)
+
+    message.delete()
+    send_log(get_translation('ttsLog'))
+
+HELP.update({'carbon': get_translation('carbonInfo')})