Closes #13

config_example.json

@@ -51,7 +51,8 @@
             "enabled": false
         },
         "spoilers": {
-            "enabled": true
+            "enabled": true,
+            "allow_external": true
         }
     },
     "scheduler": {
@@ -74,6 +75,11 @@
         "cache_admins": {
             "interval": 120,
             "enabled": true
+        },
+        "channels_monitor": {
+            "interval": 5,
+            "enabled": true,
+            "channels": []
         }
     },
     "locations": {

holochecker.py

@@ -31,7 +31,7 @@ from modules.commands.warnings import *
 from modules.callbacks.nothing import *
 from modules.callbacks.reapply import *
 from modules.callbacks.rules import *
-from modules.callbacks.sid import *
+from modules.callbacks.spoiler import *
 from modules.callbacks.sponsorship import *
 from modules.callbacks.sub import *
 from modules.callbacks.sus import *

locale/en.disabled

@@ -31,7 +31,6 @@
         "approved_joined": "Congratulations! Your application has been reviewed and confirmed as correct. Thank you for your time and have a nice day!",
         "read_rules": "Please read these rules before clicking the button and joining the chat.",
         "rejected.": "Oh dear! Your application has been reviewed but not confirmed as eligible to join the community. Better luck next time!\n\nYou can try to reapply with the /reapply command.",
-        "rejected_aggressive": "Oh dear! Your application has been reviewed, but not confirmed as eligible to join the community.",
         "rejected_russian": "Russian warship, go fuck yourself!",
         "approved_by": "✅ **Application approved**\nAdmin **{0}** has reviewed and approved application `{1}`.",
         "rejected_by": "❌ **Form rejected**\nAdmin **{0}** has reviewed and rejected form `{1}`.",
@@ -122,7 +121,6 @@
     "button": {
         "sub_yes": "✅ Accept",
         "sub_no": "❌ Reject",
-        "sub_aggressive": "🤡 Reject (Toxic)",
         "sub_russian": "🇷🇺 Reject (Russian)",
         "accepted": "✅ Accepted",
         "declined": "❌ Rejected",
@@ -145,7 +143,6 @@
     "callback": {
         "sub_accepted": "✅ Application {0} has been approved",
         "sub_rejected": "❌ Application {0} rejected",
-        "sub_aggressive": "🤡 Application {0} rejected",
         "sub_russian": "🇷🇺 Application {0} rejected",
         "sus_allowed": "✅ Access {0} allowed",
         "sus_rejected": "❌ Access {0} denied",

locale/uk.json

@@ -4,7 +4,7 @@
         "goodbye": "Добре, дякуємо за чесність! Вибачте, але за таких умов ми не будемо тебе додавати до спільноти. Якщо передумаєш та захочеш приєднатись - просто натисни на кнопку.",
         "privacy_notice": "Раді це чути!\n\nДля продовження треба буде заповнити невеличку анкетку. Будь ласка, віднесись до цього серйозно. Ми відповідально ставимось до персональних даних, тому ця анкета не буде передана третім особам, а буде використана лише для проходження до спільноти.",
         "question1": "Як до тебе можна звертатись?",
-        "question2": "Коли в тебе день народження?",
+        "question2": "Коли в тебе день народження?\n\nБудь ласка, у форматі ДД.ММ.РРРР",
         "question3": "З якого ти міста або де проживаєш зараз?\n\n⚠️ Будь ласка, не вказуйте точних адрес! \"Київ\" або \"Київська Область\" є достатньою конкретизацією.\n\nПриклади:\n• Київ\n• Одеська область\n• Макіївка (Луганська область)",
         "question4": "Коли вперше довелось дізнатись про Хололайв?",
         "question5": "Чим тебе зацікавив Хололайв?",
@@ -48,7 +48,6 @@
         "approved_joined": "Вітаємо! Твою анкету переглянули та підтвердили її правильність. Дякуємо за витрачений на заповнення час та гарного дня!",
         "read_rules": "Будь ласка, прочитай ці правила перш ніж натискати на кнопку та приєднуватись до чату.",
         "rejected": "Ой лишенько! Твою анкету переглянули, однак не підтвердили право на вступ до спільноти. Better luck next time!\n\nТи можеш спробувати повторно заповнити анкету командою /reapply",
-        "rejected_aggressive": "Ой лишенько! Твою анкету переглянули, однак не підтвердили право на вступ до спільноти.",
         "rejected_russian": "русский военньій корабль, иди нахуй!",
         "approved_by": "✅ **Анкету схвалено**\nАдмін **{0}** переглянув та схвалив анкету `{1}`.",
         "rejected_by": "❌ **Анкету відхилено**\nАдмін **{0}** переглянув та відхилив анкету `{1}`.",
@@ -109,7 +108,9 @@
         "spoiler_unfinished": "У вас ще є незавершений спойлер. Надішліть /cancel щоб зупинити його створення",
         "spoiler_cancel": "Створення спойлера було припинено",
         "spoiler_empty": "Спойлер категорії \"{0}\" без опису",
+        "spoiler_empty_named": "Спойлер категорії \"{0}\" без опису від **{1}**",
         "spoiler_described": "Спойлер категорії \"{0}\": {1}",
+        "spoiler_described_named": "Спойлер категорії \"{0}\" від **{1}**: {2}",
         "spoiler_description_enter": "Добре, введіть бажаний опис спойлера",
         "spoiler_description_too_long": "Текст занадто довгий. Будь ласка, умісти опис у 1024 символи.",
         "spoiler_using_description": "Встановлено опис спойлера: {0}\n\nЗалишилось додати вміст самого спойлера. Бот приймає текстове повідомлення, фото, відео, файл а також гіф зображення (1 шт.)",
@@ -118,6 +119,7 @@
         "spoiler_incorrect_content": "Бот не підтримує такий контент. Будь ласка, надішли текст, фото, відео, файл або анімацію (гіф).",
         "spoiler_incorrect_category": "Вказана категорія не є дійсною. Будь ласка, користуйся клавіатурою бота (кнопка біля 📎) для вибору категорії.",
         "spoiler_in_progress": "❌ **Дія неможлива**\nПерш ніж починати нову дію, треба завершити створення спойлера або перервати його командою /cancel.",
+        "youtube_video": "На каналі [{0}]({1}) нове відео!\n\n**[{2}]({3})**",
         "yes": "Так",
         "no": "Ні",
         "voice_message": [
@@ -203,7 +205,6 @@
     "button": {
         "sub_yes": "✅ Прийняти",
         "sub_no": "❌ Відхилити",
-        "sub_aggressive": "🤡 Відхилити (Токс)",
         "sub_russian": "🇷🇺 Відхилити (Русак)",
         "sponsor_yes": "✅ Прийняти",
         "sponsor_no": "❌ Відхилити",
@@ -226,13 +227,14 @@
         "done": "✅ Готово",
         "sponsor_apply": "Заповнити форму",
         "sponsor_started": "Форму розпочато",
-        "spoiler_send": "Надіслати",
+        "spoiler_view": "Переглянути",
-        "spoiler_view": "Переглянути"
+        "spoiler_preview": "Попередній перегляд",
+        "spoiler_send_chat": "Надіслати в холо-чат",
+        "spoiler_send_other": "Надіслати в інший чат"
     },
     "callback": {
         "sub_accepted": "✅ Анкету {0} схвалено",
         "sub_rejected": "❌ Анкету {0} відхилено",
-        "sub_aggressive": "🤡 Анкету {0} відхилено",
         "sub_russian": "🇷🇺 Анкету {0} відхилено",
         "sus_allowed": "✅ Доступ {0} дозволено",
         "sus_rejected": "❌ Доступ {0} заборонено",
@@ -243,7 +245,8 @@
         "reapply_stopped": "ℹ️ Перервано заповнення анкети",
         "sponsor_started": "ℹ️ Заповнення форми розпочато",
         "sponsor_accepted": "✅ Форму {0} схвалено",
-        "sponsor_rejected": "❌ Форму {0} відхилено"
+        "sponsor_rejected": "❌ Форму {0} відхилено",
+        "spoiler_sent": "✅ Повідомлення надіслано в холо-чат"
     },
     "inline": {
         "forbidden": {
@@ -266,7 +269,7 @@
             "description": "Надіслати цей спойлер до чату"
         }
     },
-    "rules_msg": "📢Правила можуть доповнюватись та змінюватись, залежно від потреби. У такому разі, порушення, які були вчинені до введення (змінення) правила, порушеннями вважатися не будуть. Про всі зміни в правилах, ви будете проінформовані за допомогою закріплених повідомлень. Але вони не будуть закріплені на постійній основі, тому, час від часу, перевіряйте актуальність правил у боті.\n\n🔔Якщо ви бачите, як хтось із учасників порушив правила, тегніть одного із адмінів, у відповідь на повідомлення, яке, на вашу думку, є порушенням. У дописі до тегу, вкажіть, по якому пункту ви побачили порушення. Або перешліть повідомлення до будь кого із адміністраторів у особисті повідомлення, та коротко опишіть ситуацію.\nСписок адміністраторів: @Chirkopol @Za_NerZula @Denialvapr\nЗ питань функціонування бота звертайтесь до @Profitroll2281337\n\n❗️Будь-який заборонений контент, може бути відправлений допомогою команди /spoiler у бота - з повним описом контенту, що міститься під спойлером. За неправильний або некоректний опис, може бути видане попередження.\n\n‼️Видалені або змінені повідомлення, все ще є повідомленнями від вашого імені, які могли побачити учасники чату, і які можуть бути відстежені через адмінську панель.\n\n🔨 За порушення - ви отримаєте попередження. За наявності 3-х попереджень - мут на добу. За повторні порушення, ви одразу отримаєте покарання, без додаткових попереджень.",
+    "rules_msg": "📢Правила можуть доповнюватись та змінюватись, залежно від потреби. У такому разі, порушення, які були вчинені до введення (змінення) правила, порушеннями вважатися не будуть. Про всі зміни в правилах, ви будете проінформовані за допомогою закріплених повідомлень. Але вони не будуть закріплені на постійній основі, тому, час від часу, перевіряйте актуальність правил у боті.\n\n🔔Якщо ви бачите, як хтось із учасників порушив правила, тегніть одного із адмінів, у відповідь на повідомлення, яке, на вашу думку, є порушенням. У дописі до тегу, вкажіть, по якому пункту ви побачили порушення. Або перешліть повідомлення до будь кого із адміністраторів у особисті повідомлення, та коротко опишіть ситуацію.\nСписок адміністраторів: @Chirkopol @Za_NerZula @Denialvapr\nЗ питань функціонування бота звертайтесь до @Profitroll2281337\n\n❗️Будь-який заборонений контент, може бути відправлений за допомогою команди /spoiler у бота - з повним описом контенту, що міститься під спойлером. За неправильний або некоректний опис, може бути видане попередження.\n\n‼️Видалені або змінені повідомлення, все ще є повідомленнями від вашого імені, які могли побачити учасники чату, і які можуть бути відстежені через адмінську панель.\n\n🔨 За порушення - ви отримаєте попередження. За наявності 3-х попереджень - мут на добу. За повторні порушення, ви одразу отримаєте покарання, без додаткових попереджень.",
     "rules": [
         "1️⃣) \"HoloKyiv Chat\" та \"HoloUA (Hololive Ukraine) Chat\" створені виключно для українців (13+). В них можуть знаходитись тільки люди які: \n- Народились в Україні, та проживають, на данний момент, у ній.\n- Народились за межами України, але проживають у ній.\n- Народились в Україні але, на даний момент, не проживають у ній.\n\"HoloUA (Hololive Ukraine) Chat\" відкритий для усіх українців. Щоб потрапити до нього, заповніть, будь ласка, анкету, та дочекайтесь, поки її схвалять адміни.\nУ \"HoloKyiv Chat\" можна потрапити тільки особисто, якщо ви проживаєте у Київі, або є близьким другом одного із учасників чату. Із приводу додавання до чату пишіть @Chirkopol у приватні повідомлення.\n🔨 Якщо у процесі спілкування виявиться, що ви не українець, вас буде видалено із чату, до моменту, поки ви їм не станете. Без образ. Ми створюємо виключно українське ком'юніті.",
         "2️⃣) Заборонено поширення NSFW-контенту з прямим або частково прихованим порнографічним змістом. На контенті \"еротичного характеру\" повинні бути закриті \"сумнівні\" ділянки тіл. \nЗаборонено поширення шок-контенту з великою наявністю крові та/або фізичних пошкоджень.",

modules/callbacks/reapply.py

@@ -83,13 +83,30 @@ async def callback_query_reapply_reject(app: Client, clb: CallbackQuery):
 # Use old application when user reapplies after leaving the chat
 @app.on_callback_query(filters.regex("reapply_old_[\s\S]*"))
 async def callback_query_reapply_old(app: Client, clb: CallbackQuery):
-    fullclb = clb.data.split("_")
 
-    if HoloUser(clb.from_user).sponsorship_state()[0] == "fill":
+    fullclb = clb.data.split("_")
+    holo_user = HoloUser(clb.from_user)
+
+    if holo_user.sponsorship_state()[0] == "fill":
         await clb.message.reply_text(locale("finish_sponsorship", "message"), quote=False)
         return
 
     message = await app.get_messages(clb.from_user.id, int(fullclb[2]))
+
+    if col_tmp.find_one({"user": holo_user.id, "type": "application"}) is None and col_applications.find_one({"user": holo_user.id}) is not None:
+        col_tmp.insert_one(
+            {
+                "user": holo_user.id,
+                "type": "application",
+                "complete": True,
+                "sent": False,
+                "state": "fill",
+                "reapply": True,
+                "stage": 10,
+                "application": col_applications.find_one({"user": holo_user.id})["application"]
+            }
+        )
+    
     await confirm_yes(app, message, kind="application")
     await clb.message.edit(clb.message.text, reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton(locale("done", "button", locale=clb.from_user), "nothing")]]))
 

modules/callbacks/sid.py

@@ -1,10 +0,0 @@
-from app import app
-from pyrogram.types import CallbackQuery
-from pyrogram.client import Client
-from pyrogram import filters
-
-# Callback rule ================================================================================================================
-@app.on_callback_query(filters.regex("sid_[\s\S]*"))
-async def callback_query_rule(app: Client, clb: CallbackQuery):
-    await clb.answer(url=f'https://t.me/{(await app.get_me()).username}?start={clb.data.split("_")[1]}')
-# ==============================================================================================================================

modules/callbacks/spoiler.py

@@ -0,0 +1,31 @@
+from app import app
+from pyrogram.types import CallbackQuery, InlineKeyboardMarkup, InlineKeyboardButton
+from pyrogram.client import Client
+from pyrogram import filters
+from modules.database import col_spoilers
+from bson.objectid import ObjectId
+
+from modules.utils import configGet, locale
+
+# Callback sid =================================================================================================================
+@app.on_callback_query(filters.regex("sid_[\s\S]*"))
+async def callback_query_sid(app: Client, clb: CallbackQuery):
+    await clb.answer(url=f'https://t.me/{(await app.get_me()).username}?start={clb.data.split("_")[1]}')
+# ==============================================================================================================================
+
+# Callback shc =================================================================================================================
+@app.on_callback_query(filters.regex("shc_[\s\S]*"))
+async def callback_query_shc(app: Client, clb: CallbackQuery):
+
+    spoil = col_spoilers.find_one( {"_id": ObjectId(clb.data.split("_")[1])} )
+
+    if spoil["description"] == "":
+        desc = locale("spoiler_empty_named", "message", locale=clb.from_user).format(locale(spoil["category"], "message", "spoiler_categories"), clb.from_user.first_name)
+    else:
+        desc = locale("spoiler_described_named", "message", locale=clb.from_user).format(locale(spoil["category"], "message", "spoiler_categories"), clb.from_user.first_name, spoil["description"])
+
+    await app.send_message(configGet("users", "groups"), desc, reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton(locale("spoiler_view", "button", locale=clb.from_user), callback_data=f'sid_{clb.data.split("_")[1]}')]]))
+    await app.send_message(configGet("admin", "groups"), desc, reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton(locale("spoiler_view", "button", locale=clb.from_user), callback_data=f'sid_{clb.data.split("_")[1]}')]]))
+
+    await clb.answer(locale("spoiler_sent", "callback", locale=clb.from_user), show_alert=True)
+# ==============================================================================================================================

modules/callbacks/sub.py

@@ -68,23 +68,6 @@ async def callback_query_reject(app: Client, clb: CallbackQuery):
     await clb.message.edit(text=clb.message.text, reply_markup=InlineKeyboardMarkup(edited_markup))
     await clb.answer(text=locale("sub_rejected", "callback", locale=clb.from_user).format(holo_user.id), show_alert=True)
 
-@app.on_callback_query(filters.regex("sub_aggressive_[\s\S]*"))
-async def callback_query_reject_aggressive(app: Client, clb: CallbackQuery):
-
-    fullclb = clb.data.split("_")
-    holo_user = HoloUser(int(fullclb[2]))
-
-    await app.send_message(configGet("admin", "groups"), locale("rejected_by_agr", "message").format(clb.from_user.first_name, holo_user.id), disable_notification=True)
-    await app.send_message(holo_user.id, locale("rejected_aggressive", "message", locale=holo_user))
-    logWrite(f"User {holo_user.id} got rejected by {clb.from_user.id} due to being aggressive")
-
-    col_tmp.update_one({"user": {"$eq": holo_user.id}, "type": {"$eq": "application"}}, {"$set": {"state": "rejected", "sent": False}})
-
-    edited_markup = [[InlineKeyboardButton(text=str(locale("declined", "button")), callback_data="nothing")]]
-
-    await clb.message.edit(text=clb.message.text, reply_markup=InlineKeyboardMarkup(edited_markup))
-    await clb.answer(text=locale("sub_aggressive", "callback", locale=clb.from_user).format(holo_user.id), show_alert=True)
-
 @app.on_callback_query(filters.regex("sub_russian_[\s\S]*"))
 async def callback_query_reject_russian(app: Client, clb: CallbackQuery):
 

modules/commands/identify.py

@@ -51,7 +51,7 @@ async def cmd_identify(app: Client, msg: Message):
     if user.photo is not None:
         await app.send_chat_action(msg.chat.id, action=ChatAction.UPLOAD_PHOTO)
         await msg.reply_photo(
-            create_tmp(await download_tmp(app, user.photo.big_file_id), kind="image"),
+            create_tmp((await download_tmp(app, user.photo.big_file_id))[1], kind="image"),
             quote=should_quote(msg),
             caption=output
         )

modules/commands/reapply.py

@@ -6,7 +6,7 @@ from classes.holo_user import HoloUser
 from modules.logging import logWrite
 from modules.utils import configGet, locale, should_quote
 from modules.handlers.welcome import welcome_pass
-from modules.database import col_tmp
+from modules.database import col_tmp, col_applications
 from modules import custom_filters
 
 # Reapply command ==============================================================================================================
@@ -27,16 +27,20 @@ async def cmd_reapply(app: Client, msg: Message):
                 if member.user.id == msg.from_user.id:
                     left_chat = False
 
-            if not left_chat:
+            if left_chat is True:
-                if holo_user.sponsorship_state()[0] == "fill":
-                    await msg.reply_text(locale("finish_sponsorship", "message"), quote=should_quote(msg))
-                    return
-                holo_user.application_restart(reapply=True)
-                await welcome_pass(app, msg, once_again=True)
                 
-            else:
+                if (holo_user.application_state()[1] is True and holo_user.application_state()[0] != "fill"):
 
-                if holo_user.application_state()[1] is True and holo_user.application_state()[0] != "fill":
+                    await msg.reply_text(locale("reapply_left_chat", "message", locale=holo_user), reply_markup=InlineKeyboardMarkup([
+                        [
+                            InlineKeyboardButton(locale("reapply_old_one", "button", locale=holo_user), f"reapply_old_{msg.id}")
+                        ],
+                        [
+                            InlineKeyboardButton(locale("reapply_new_one", "button", locale=holo_user), f"reapply_new_{msg.id}")
+                        ]
+                    ]))
+
+                elif col_tmp.find_one({"user": holo_user.id, "type": "application"}) is None and col_applications.find_one({"user": holo_user.id}) is not None:
 
                     await msg.reply_text(locale("reapply_left_chat", "message", locale=holo_user), reply_markup=InlineKeyboardMarkup([
                         [
@@ -52,6 +56,15 @@ async def cmd_reapply(app: Client, msg: Message):
                     holo_user.application_restart(reapply=True)
                     await welcome_pass(app, msg, once_again=True)
 
+            else:
+
+                if holo_user.sponsorship_state()[0] == "fill":
+                    await msg.reply_text(locale("finish_sponsorship", "message"), quote=should_quote(msg))
+                    return
+                
+                holo_user.application_restart(reapply=True)
+                await welcome_pass(app, msg, once_again=True)
+
         else:
 
             await msg.reply_text(locale("reapply_in_progress", "message", locale=holo_user).format(locale("confirm", "keyboard", locale=holo_user)[1][0]), reply_markup=InlineKeyboardMarkup([

modules/commands/spoiler.py

@@ -10,7 +10,7 @@ from modules.database import col_spoilers
 from modules import custom_filters
 
 # Spoiler command ==============================================================================================================
-@app.on_message(custom_filters.member & ~filters.scheduled & filters.private & filters.command(["spoiler"], prefixes=["/"]))
+@app.on_message(custom_filters.enabled_spoilers & custom_filters.member & ~filters.scheduled & filters.private & filters.command(["spoiler"], prefixes=["/"]))
 async def cmd_spoiler(app: Client, msg: Message):
 
     try:

modules/custom_filters.py

@@ -39,6 +39,9 @@ async def enabled_invites_check_func(_, __, msg: Message):
 async def enabled_dinovoice_func(_, __, msg: Message):
     return configGet("enabled", "features", "dinovoice")
 
+async def enabled_spoilers_func(_, __, msg: Message):
+    return configGet("enabled", "features", "spoilers")
+
 async def filling_sponsorship_func(_, __, msg: Message):
     return True if col_tmp.find_one({"user": msg.from_user.id, "type": "sponsorship"}) is not None else False
 
@@ -52,5 +55,6 @@ enabled_sponsorships = filters.create(enabled_sponsorships_func)
 enabled_warnings = filters.create(enabled_warnings_func)
 enabled_invites_check = filters.create(enabled_invites_check_func)
 enabled_dinovoice = filters.create(enabled_dinovoice_func)
+enabled_spoilers = filters.create(enabled_spoilers_func)
 
 filling_sponsorship = filters.create(filling_sponsorship_func)

modules/database.py

@@ -28,13 +28,14 @@ db = db_client.get_database(name=db_config["name"])
 
 collections = db.list_collection_names()
 
-for collection in ["tmp", "users", "context", "spoilers", "messages", "warnings", "applications", "sponsorships"]:
+for collection in ["tmp", "users", "context", "youtube", "spoilers", "messages", "warnings", "applications", "sponsorships"]:
     if not collection in collections:
         db.create_collection(collection)
 
 col_tmp = db.get_collection("tmp")
 col_users = db.get_collection("users")
 col_context = db.get_collection("context")
+col_youtube = db.get_collection("youtube")
 col_spoilers = db.get_collection("spoilers")
 col_messages = db.get_collection("messages")
 col_warnings = db.get_collection("warnings")

modules/handlers/confirmation.py

@@ -83,9 +83,6 @@ async def confirm_yes(app: Client, msg: Message, kind: Literal["application", "s
                             [
                                 InlineKeyboardButton(text=str(locale("sub_no", "button")), callback_data=f"sub_no_{holo_user.id}")
                             ],
-                            [
-                                InlineKeyboardButton(text=str(locale("sub_aggressive", "button")), callback_data=f"sub_aggressive_{holo_user.id}")
-                            ],
                             [
                                 InlineKeyboardButton(text=str(locale("sub_russian", "button")), callback_data=f"sub_russian_{holo_user.id}")
                             ]

modules/handlers/everything.py

@@ -22,7 +22,7 @@ async def message_context(msg: Message) -> tuple:
     return 0, 0
 
 # Any other input ==============================================================================================================
-@app.on_message(~ filters.scheduled & filters.private)
+@app.on_message(~ filters.scheduled & (filters.private | filters.chat(configGet("admin", "groups"))))
 async def any_stage(app: Client, msg: Message):
 
     if msg.via_bot is None:
@@ -52,6 +52,9 @@ async def any_stage(app: Client, msg: Message):
 
             return
 
+        if msg.chat.id == configGet("admin", "groups"):
+            return
+
         if msg.text is not None:
 
             if configGet("enabled", "features", "applications") is True:
@@ -66,6 +69,9 @@ async def any_stage(app: Client, msg: Message):
         
         if holo_user.application_state()[0] != "fill" and holo_user.sponsorship_state()[0] != "fill":
 
+            if configGet("enabled", "features", "spoilers") is False:
+                return
+
             spoiler = col_spoilers.find_one( {"user": msg.from_user.id, "completed": False} )
 
             if spoiler is None:
@@ -146,7 +152,37 @@ async def any_stage(app: Client, msg: Message):
                     ready = True
 
             if ready is True:
-                await msg.reply_text(locale("spoiler_ready", "message", locale=msg.from_user), reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton(locale("spoiler_send", "button", locale=msg.from_user), switch_inline_query=f"spoiler:{spoiler['_id'].__str__()}")]]))
+                if configGet("allow_external", "features", "spoilers") is True:
+                    await msg.reply_text(
+                        locale("spoiler_ready", "message", locale=msg.from_user),
+                        reply_markup=InlineKeyboardMarkup(
+                            [
+                                [
+                                    InlineKeyboardButton(locale("spoiler_preview", "button", locale=msg.from_user), callback_data=f"sid_{spoiler['_id'].__str__()}")
+                                ],
+                                [
+                                    InlineKeyboardButton(locale("spoiler_send_chat", "button", locale=msg.from_user), callback_data=f"shc_{spoiler['_id'].__str__()}")
+                                ],
+                                [
+                                    InlineKeyboardButton(locale("spoiler_send_other", "button", locale=msg.from_user), switch_inline_query=f"spoiler:{spoiler['_id'].__str__()}")
+                                ]
+                            ]
+                        )
+                    )
+                else:
+                    await msg.reply_text(
+                        locale("spoiler_ready", "message", locale=msg.from_user),
+                        reply_markup=InlineKeyboardMarkup(
+                            [
+                                [
+                                    InlineKeyboardButton(locale("spoiler_preview", "button", locale=msg.from_user), callback_data=f"sid_{spoiler['_id'].__str__()}")
+                                ],
+                                [
+                                    InlineKeyboardButton(locale("spoiler_send_chat", "button", locale=msg.from_user), callback_data=f"shc_{spoiler['_id'].__str__()}")
+                                ]
+                            ]
+                        )
+                    )
             else:
                 await msg.reply_text(locale("spoiler_incorrect_content", "message", locale=msg.from_user))
 

modules/handlers/welcome.py

@@ -30,7 +30,10 @@ async def welcome_pass(app: Client, msg: Message, once_again: bool = False) -> N
     if once_again is False:
         holo_user.application_restart()
         
+    if once_again is True:
         logWrite(f"User {msg.from_user.id} confirmed starting the application")
+    else:
+        logWrite(f"User {msg.from_user.id} confirmed starting the application once again")
     await msg.reply_text(locale("question1", "message", locale=msg.from_user), reply_markup=ForceReply(placeholder=locale("question1", "force_reply", locale=msg.from_user)))
 
 welcome_2 = []

modules/inline.py

@@ -22,6 +22,8 @@ async def inline_answer(client: Client, inline_query: InlineQuery):
 
     results = []
 
+    if configGet("allow_external", "features", "spoilers") is True:
+        
         if inline_query.query.startswith("spoiler:"):
             
             try:

modules/scheduled.py

@@ -1,7 +1,9 @@
 """Automatically register commands and execute
 some scheduled tasks is the main idea of this module"""
 
+from asyncio import sleep
 from os import listdir, makedirs, path, sep
+from traceback import format_exc
 from apscheduler.schedulers.asyncio import AsyncIOScheduler
 from datetime import datetime, timedelta
 from ujson import dumps
@@ -10,9 +12,11 @@ from pyrogram.types import BotCommand, BotCommandScopeChat, BotCommandScopeChatA
 from pyrogram.errors import bad_request_400
 from pyrogram.enums.chat_members_filter import ChatMembersFilter
 from classes.holo_user import HoloUser
-from modules.utils import configGet, jsonSave, locale, logWrite
+from modules.utils import configGet, jsonLoad, jsonSave, locale, logWrite
 from dateutil.relativedelta import relativedelta
-from modules.database import col_applications, col_sponsorships
+from modules.database import col_applications, col_sponsorships, col_youtube
+from xmltodict import parse
+from requests import get
 
 scheduler = AsyncIOScheduler()
 
@@ -62,6 +66,8 @@ if configGet("enabled", "features", "applications") is True:
             for entry in col_applications.find():
                 if entry["application"]["2"].strftime("%d.%m") == datetime.now().strftime("%d.%m"):
                     try:
+                        if entry["user"] not in jsonLoad(path.join(configGet("cache", "locations"), "group_members")):
+                            continue
                         tg_user = await app.get_users(entry["user"])
                         await app.send_message( configGet("admin", "groups"), locale("birthday", "message").format(str(tg_user.first_name), str(tg_user.username), str(relativedelta(datetime.now(), entry["application"]["2"], '%d.%m.%Y').years)) ) # type: ignore
                         logWrite(f"Notified admins about {entry['user']}'s birthday")
@@ -78,22 +84,26 @@ if configGet("enabled", "features", "sponsorships") is True:
         async def check_sponsors():
             for entry in col_sponsorships.find({"sponsorship.expires": {"$lt": datetime.now()+timedelta(days=2)}}):
                 try:
+                    if entry["user"] not in jsonLoad(path.join(configGet("cache", "locations"), "group_members")):
+                        continue
                     tg_user = await app.get_users(entry["user"])
-                    until_expiry = relativedelta(datetime.now(), entry["sponsorship"]["expires"]).days
+                    until_expiry = abs(relativedelta(datetime.now(), entry["sponsorship"]["expires"]).days)+1
                     await app.send_message( tg_user.id, locale("sponsorships_expires", "message").format(until_expiry) ) # type: ignore
-                    logWrite(f"Notified user that sponsorship expires in {until_expiry} days")
+                    logWrite(f"Notified user {entry['user']} that sponsorship expires in {until_expiry} days")
                 except Exception as exp:
                     logWrite(f"Could not find user {entry['user']} notify about sponsorship expiry due to '{exp}'")
                     continue
             for entry in col_sponsorships.find({"sponsorship.expires": {"$lt": datetime.now()}}):
                 try:
                     holo_user = HoloUser(entry["user"])
+                    col_sponsorships.find_one_and_delete({"user": holo_user.id})
+                    if entry["user"] not in jsonLoad(path.join(configGet("cache", "locations"), "group_members")):
+                        continue
                     await app.send_message( entry["user"], locale("sponsorships_expired", "message") ) # type: ignore
                     await holo_user.label_reset(configGet("users", "groups"))
-                    col_sponsorships.find_one_and_delete({"user": holo_user.id})
                     try:
                         tg_user = await app.get_users(entry["user"])
-                        logWrite(f"Notified user that sponsorship expired")
+                        logWrite(f"Notified user {entry['user']}  that sponsorship expired")
                     except Exception as exp:
                         logWrite(f"Could not find user {entry['user']} notify about sponsorship expired due to '{exp}'")
                 except Exception as exp:
@@ -234,3 +244,29 @@ async def commands_register():
     if configGet("debug") is True:
         print(commands, flush=True)
         logWrite(f"Complete commands registration:\n{dumps(commands_raw, indent=4, ensure_ascii=False, encode_html_chars=False)}", debug=True)
+
+
+if configGet("enabled", "scheduler", "channels_monitor"):
+    @scheduler.scheduled_job(trigger="interval", minutes=configGet("interval", "scheduler", "channels_monitor"))
+    async def channels_monitor():
+        for channel in configGet("channels", "scheduler", "channels_monitor"):
+            if configGet("debug") is True:
+                logWrite(f'Processing videos of {channel["name"]} ({channel["id"]})', debug=True)
+            try:
+                req = get(f'https://www.youtube.com/feeds/videos.xml?channel_id={channel["id"]}')
+                parsed = parse(req.content)
+                if "feed" not in parsed:
+                    continue
+                if "entry" not in parsed["feed"]:
+                    continue
+                for entry in parsed["feed"]["entry"]:
+                    if "yt:videoId" not in entry:
+                        continue
+                    if col_youtube.find_one( {"channel": channel["id"], "video": entry["yt:videoId"]} ) is None:
+                        col_youtube.insert_one( {"channel": channel["id"], "video": entry["yt:videoId"], "date": datetime.fromisoformat(entry["published"])} )
+                        await app.send_message(configGet("users", "groups"), locale("youtube_video", "message").format(channel["name"], channel["link"], entry["title"], entry["link"]["@href"]), disable_web_page_preview=False)
+                        await sleep(2)
+            except Exception as exp:
+                logWrite(f'Could not get last videos of {channel["name"]} ({channel["id"]}) due to {exp}: {format_exc()}')
+        if configGet("debug") is True:
+            logWrite("Admin group caching performed", debug=True)

modules/utils.py

@@ -1,4 +1,4 @@
-from typing import Any, Literal, Union
+from typing import Any, Literal, Tuple, Union
 from uuid import uuid1
 from requests import get
 from pyrogram.enums.chat_type import ChatType
@@ -212,7 +212,7 @@ def create_tmp(bytedata: Union[bytes, bytearray], kind: Union[Literal["image", "
         file.write(bytedata)
     return path.join("tmp", filename)
 
-async def download_tmp(app: Client, file_id: str) -> bytes:
+async def download_tmp(app: Client, file_id: str) -> Tuple[str, bytes]:
     """Download file by its ID and return its bytes
 
     ### Args:
@@ -220,14 +220,14 @@ async def download_tmp(app: Client, file_id: str) -> bytes:
         * file_id (`str`): File's unique id
 
     ### Returns:
-        * `bytes`: Bytes of downloaded file
+        * `Tuple[str, bytes]`: First is a filepath and the second is file's bytes
     """    
     filename = str(uuid1())
     makedirs("tmp", exist_ok=True)
     await app.download_media(file_id, path.join("tmp", filename))
     with open(path.join("tmp", filename), "rb") as f:
         bytedata = f.read()
-    return bytedata
+    return path.join("tmp", filename), bytedata
 
 try:
     from psutil import Process

requirements.txt

@@ -9,3 +9,4 @@ python_dateutil==2.8.2
 starlette~=0.22.0
 ujson~=5.7.0
 ftfy~=6.1.1
+xmltodict~=0.13.0