events.py

# Copyright (C) 2020 TeamDerUntergang.
#
# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with this program.  If not, see <https://www.gnu.org/licenses/>.
#

""" Olayları yönetmek için UserBot modülü.
 UserBot'un ana bileşenlerinden biri. """

import sys

from asyncio import create_subprocess_shell as asyncsubshell
from asyncio import subprocess as asyncsub
from os import remove
from time import gmtime, strftime
from traceback import format_exc
from telethon import events

from sedenbot import bot, BOTLOG, BOTLOG_CHATID, LOGSPAMMER, BLACKLIST, me

def sedenify(**args):
    """ Yeni bir etkinlik kaydedin. """
    pattern = args.get('pattern', None)
    disable_edited = args.get('disable_edited', False)
    ignore_unsafe = args.get('ignore_unsafe', False)
    groups_only = args.get('groups_only', False)
    trigger_on_fwd = args.get('trigger_on_fwd', False)
    trigger_on_inline = args.get('trigger_on_inline', False)
    disable_errors = args.get('disable_errors', False)

    if pattern and '.' in pattern[:2]:
        args['pattern'] = pattern = pattern.replace('.','[.?]')

    if "disable_edited" in args:
        del args['disable_edited']

    if "ignore_unsafe" in args:
        del args['ignore_unsafe']

    if "groups_only" in args:
        del args['groups_only']

    if "disable_errors" in args:
        del args['disable_errors']

    if "trigger_on_fwd" in args:
        del args['trigger_on_fwd']

    if "trigger_on_inline" in args:
        del args['trigger_on_inline']

    def decorator(func):
        async def wrapper(check):
            if check.edit_date and check.is_channel and not check.is_group:
                return
            if groups_only and not check.is_group:
                await check.respond("`Bunun bir grup olduğuna emin misin?`")
                return
            if check.via_bot_id and check.out:
                return

            try:
                if me.id not in BLACKLIST:
                    await func(check)
                else:
                    raise RetardsException()
            except events.StopPropagation:
                raise events.StopPropagation
            except RetardsException:
                exit(1)
            except KeyboardInterrupt:
                pass
            except:
                if not disable_errors:
                    try:
                        date = strftime("%Y-%m-%d %H:%M:%S", gmtime())

                        text = "**USERBOT HATA RAPORU**\n"
                        link = "[Seden Destek Grubu](https://t.me/SedenUserBotSupport)"
                        text += "İsterseniz, bunu rapor edebilirsiniz "
                        text += f"- sadece bu mesajı buraya iletin {link}.\n"
                        text += "Hata ve Tarih dışında hiçbir şey kaydedilmez\n"

                        ftext = "========== UYARI =========="
                        ftext += "\nBu dosya sadece burada yüklendi,"
                        ftext += "\nsadece hata ve tarih kısmını kaydettik,"
                        ftext += "\ngizliliğinize saygı duyuyoruz,"
                        ftext += "\nburada herhangi bir gizli veri varsa"
                        ftext += "\nbu hata raporu olmayabilir, kimse verilerinize ulaşamaz.\n"
                        ftext += "================================\n\n"
                        ftext += "--------USERBOT HATA GUNLUGU--------\n"
                        ftext += "\nTarih: " + date
                        ftext += "\nGrup ID: " + str(check.chat_id)
                        ftext += "\nGönderen kişinin ID: " + str(check.sender_id)
                        ftext += "\n\nOlay Tetikleyici:\n"
                        ftext += str(check.text)
                        ftext += "\n\nGeri izleme bilgisi:\n"
                        ftext += str(format_exc())
                        ftext += "\n\nHata metni:\n"
                        ftext += str(sys.exc_info()[1])
                        ftext += "\n\n--------USERBOT HATA GUNLUGU BITIS--------"

                        command = "git log --pretty=format:\"%an: %s\" -10"

                        ftext += "\n\n\nSon 10 commit:\n"

                        process = await asyncsubshell(command,
                                                      stdout=asyncsub.PIPE,
                                                      stderr=asyncsub.PIPE)
                        stdout, stderr = await process.communicate()
                        result = str(stdout.decode().strip()) \
                            + str(stderr.decode().strip())

                        ftext += result

                        file = open("hata.log", "w+")
                        file.write(ftext)
                        file.close()

                        await check.client.send_file(BOTLOG_CHATID
                                                 if BOTLOG
                                                 else me.id, "hata.log", caption=text, )
                        remove("hata.log")
                    except:
                        pass

        if not disable_edited:
            bot.add_event_handler(wrapper, events.MessageEdited(**args))
        bot.add_event_handler(wrapper, events.NewMessage(**args))
        return wrapper

    return decorator

def has_args(command):
    return command.strip().find(' ') != -1

def _extract_text(command):
    command = command.strip()
    if not has_args(command):
        return ''
    return command[command.find(' ')+1:].strip()

def extract_args(event):
    return _extract_text(event.text)

def extract_args_arr(event):
	return extract_args(event).split()

class RetardsException(Exception):
    pass