Changes in Database

FileStream/Database/database.py

@@ -32,12 +32,12 @@ class Database:
     user = UserSchema(id, details)
     await self.users.insert_one(user)
 
-  async def add_admin(self, id):
+  async def add_admin(self, id, details=None):
     user= await self.get_user(id)
     if user:
       await self.users.update_one({"_id": user['_id']}, {"$set": {"access":"ADMIN" }})
     else:
-      user = UserSchema(id)
+      user = UserSchema(id,details)
       user['access']="ADMIN"
       await self.users.insert_one(user)
 

FileStream/bot/plugins/Admin/admin.py

@@ -6,18 +6,28 @@ import asyncio
 import aiofiles
 import datetime
 
-from FileStream.utils.FileProcessors.broadcast_helper import send_msg
-from FileStream.Database import Database
+from pyrogram.types import Message
+from pyrogram import filters, Client
 from FileStream.bot import FileStream
+from FileStream.Database import Database
 from FileStream.Exceptions import FileNotFound
 from FileStream.config import Telegram, Server
-from pyrogram import filters, Client
-from pyrogram.types import Message
+
 from pyrogram.enums.parse_mode import ParseMode
+from FileStream.utils.FileProcessors.translation import LANG, BUTTON
+from FileStream.utils.FileProcessors.broadcast_helper import send_msg
 
 db = Database(Telegram.DATABASE_URL, Telegram.SESSION_NAME)
 broadcast_ids = {}
 
+@FileStream.on_message(filters.command("admin") & filters.private & filters.user(Telegram.OWNER_ID))
+async def iamadmin(c: Client, m: Message):
+  if await db.is_admin(m.from_user.id):
+    await m.reply_text(
+        text=LANG.ADMIN_GUIDELINES_TEXT_Y.format("/add_user <UserID>","/add_admin <UserID>"),
+        parse_mode=ParseMode.MARKDOWN,
+        quote=True)
+  
 
 #Authorize User to Use the Services
 @FileStream.on_message(filters.command("auth") & filters.private & filters.user(Telegram.OWNER_ID))

FileStream/bot/plugins/FileHandlers/callback.py

@@ -58,8 +58,10 @@ async def cb_data(bot: Client, update: CallbackQuery):
 
   elif usr_cmd[0] == "N/A":
     await update.answer("N/A", True)
+
   elif usr_cmd[0] == "close":
     await update.message.delete()
+  
   elif usr_cmd[0] == "back":
     try:
       user_id = str(usr_cmd[1])
@@ -86,9 +88,11 @@ async def cb_data(bot: Client, update: CallbackQuery):
             InlineKeyboardButton(
                 "ɴᴏ", callback_data=f"myfile_{usr_cmd[1]}_{usr_cmd[2]}")
         ]]))
+
   elif usr_cmd[0] == "msgdelyes":
     await delete_user_file(usr_cmd[1], int(usr_cmd[2]), update)
     return
+
   elif usr_cmd[0] == "msgdelpvt":
     await update.message.edit_caption(
         caption="**Cᴏɴғɪʀᴍ ʏᴏᴜ ᴡᴀɴᴛ ᴛᴏ ᴅᴇʟᴇᴛᴇ ᴛʜᴇ Fɪʟᴇ**\n\n",
@@ -98,6 +102,7 @@ async def cb_data(bot: Client, update: CallbackQuery):
             InlineKeyboardButton("ɴᴏ",
                                  callback_data=f"mainstream_{usr_cmd[1]}")
         ]]))
+
   elif usr_cmd[0] == "msgdelpvtyes":
     await delete_user_filex(usr_cmd[1], update)
     return
@@ -111,8 +116,9 @@ async def cb_data(bot: Client, update: CallbackQuery):
         disable_web_page_preview=True,
         reply_markup=reply_markup,
     )
+
   elif usr_cmd[0] == "pubup":
-    
+
     try:
       print("Public Upload :",usr_cmd)
       user_id = str(usr_cmd[1])
@@ -178,6 +184,7 @@ async def cb_data(bot: Client, update: CallbackQuery):
           chat_id=Telegram.ULOG_GROUP,
           text=f"An error occurred: {str(e)}"
       )
+
   elif usr_cmd[0] == "tempup":
     try:
       print("Public Upload :",usr_cmd)

FileStream/bot/plugins/startup.py

@@ -42,6 +42,7 @@ async def start(bot: Client, message: Message, response):
           BotCommand("filebank", "ꜰɪʟᴇ ʙᴀɴᴋ"),
           BotCommand("files", "ᴍʏ ᴘᴜʙʟɪᴄ ꜰɪʟᴇꜱ"),
           BotCommand("myfiles", "ᴍʏ ᴘʀɪᴠᴀᴛᴇ ꜱᴘᴀᴄᴇ"),
+          BotCommand("admin", "ɪ ᴀᴍ ᴀᴅᴍɪɴ")
       ])
       await menu(bot, message)
       if Telegram.START_PIC:
@@ -109,13 +110,11 @@ async def start(bot: Client, message: Message, response):
 async def about_handler(bot, message):
   if Telegram.START_PIC:
     await message.reply_photo(photo=Telegram.START_PIC,
-                              caption=LANG.ABOUT_TEXT.format(
-                                  FileStream.fname, __version__),
+                              caption=LANG.ABOUT_TEXT.format(FileStream.fname, __version__),
                               parse_mode=ParseMode.HTML,
                               reply_markup=BUTTON.ABOUT_BUTTONS)
   else:
-    await message.reply_text(text=LANG.ABOUT_TEXT.format(
-        FileStream.fname, __version__),
+    await message.reply_text(text=LANG.ABOUT_TEXT.format(FileStream.fname, __version__),
                              disable_web_page_preview=True,
                              reply_markup=BUTTON.ABOUT_BUTTONS)
 

FileStream/utils/FileProcessors/file_properties.py

@@ -31,14 +31,14 @@ async def send_file(client: Client, db_id, file_info , message, send_to):
     #    quote=True)
     await log_msg.edit_text(
         text=
-        f"**{file_info['type']} :{file_info['title']} ReleaseDate {file_info['release_date']} \n**Description{file_info['description']} \n**Genre {file_info['genre']}\n\nRᴇQᴜᴇꜱᴛᴇᴅ ʙʏ :** {message.from_user.first_name} \n**Cʜᴀɴɴᴇʟ ɪᴅ :** `{message.chat.id}`\n**Fɪʟᴇ ɪᴅ :** `{db_id}`",
+        f"**{file_info['type']} :{file_info['title']} \nReleaseDate {file_info['release_date']} \n**Description{file_info['description']} \n**Genre {file_info['genre']}\n\nRᴇQᴜᴇꜱᴛᴇᴅ ʙʏ :** {message.from_user.first_name} \n**Cʜᴀɴɴᴇʟ ɪᴅ :** `{message.chat.id}`\n**Fɪʟᴇ ɪᴅ :** `{db_id}`",
         disable_web_page_preview=True,
         parse_mode=ParseMode.MARKDOWN,
         )
   else:
     await log_msg.edit_text(
         text=
-        f"**{file_info['type']} :{file_info['title']} ReleaseDate {file_info['release_date']} \n Description{file_info['description']} \n Genre {file_info['genre']}\n\nRᴇQᴜᴇꜱᴛᴇᴅ ʙʏ :** {message.chat.title} \n**Cʜᴀɴɴᴇʟ ɪᴅ :** `{message.chat.id}`\n**Fɪʟᴇ ɪᴅ :** `{db_id}`",
+        f"**{file_info['type']} :{file_info['title']} \nReleaseDate {file_info['release_date']} \n Description{file_info['description']} \n Genre {file_info['genre']}\n\nRᴇQᴜᴇꜱᴛᴇᴅ ʙʏ :** {message.chat.title} \n**Cʜᴀɴɴᴇʟ ɪᴅ :** `{message.chat.id}`\n**Fɪʟᴇ ɪᴅ :** `{db_id}`",
         disable_web_page_preview=True,
         parse_mode=ParseMode.MARKDOWN,
         quote=True)

FileStream/utils/FileProcessors/translation.py

@@ -47,7 +47,11 @@ class LANG(object):
 <b>📂 𝖣𝖾𝗋𝗂𝗏𝖾𝖽 𝖭𝖺𝗆𝖾 :</b> <b>{}</b>\n
 <b>📦 Fɪʟᴇ ꜱɪᴢᴇ :</b> <code>{}</code>\n
   """
-
+    ADMIN_GUIDELINES_TEXT_Y = """
+<b>🪂 ✩░▒▓▆▅▃▂▁🅰🅳🅼🅸🅽 🅶🆄🅸🅳🅴🅻🅸🅽🅴🆂▁▂▃▅▆▓▒░✩ 🪂</b>\n
+<b>🔗 ᴄᴏᴍᴍᴀɴᴅ 1:</b> <b>{}</b>\n
+<b>🔗 ᴄᴏᴍᴍᴀɴᴅ 2 :</b> <b>{}</b>\n
+  """
     STREAM_TEXT_X = """
 <i>Chose where you wand to upload this file !</i>\n
 <b>📂 Fɪʟᴇ ɴᴀᴍᴇ :</b> <b>{}</b>\n