Untitled

import logging
import time

from telethon import TelegramClient, events

import lib.ProbitApiOperations as proao
import lib.gateapi as gateio
import lib.mxcApiOperations as mxcao

mesaj_icerigi = ['sonraki mesaj','Bir sonraki mesajda']
borsa_name = "PROBIT"
mesajlar = []
logging.basicConfig(format='%(asctime)s :: %(name)s :: %(levelname)-8s ::  %(message)s', datefmt='%m/%d/%Y %H:%M:%S',
                    level=logging.INFO)
logger = logging.getLogger(__name__)


def listen_group():
    global mesajlar,borsa_name
    # Remember to use your own values from my.telegram.org!
    logger.warning("Waiting for coin message.")
    api_id = 1111111
    api_hash = '1111111'
    client = TelegramClient('anon', api_id, api_hash)

    # @client.on(events.NewMessage(chats='gateiopumpp'))
    # @client.on(events.NewMessage(chats=('gateiopumptrade','gateiopumpp')))
    @client.on(events.NewMessage(chats=("gateiopumptrade", "gateiopumpp", "pump123")))
    async def my_event_handler(event):
        logger.warning(event.raw_text)
        logger.warning(event.grouped_id)
        event_borsa_operation(message=event.raw_text)
        for mesaj in mesaj_icerigi :
            if mesaj in str(event.raw_text) :
                mesajlar.append([str(event.grouped_id),borsa_name])
        event_coin_operation(message=event)

    client.start()
    client.run_until_disconnected()

 
def event_borsa_operation(message):
    global borsa_name
    message = f"abdulsamed {message}"
    if message.find("gate.io") > 0 or message.find("GATE.İO") > 0 or message.find("Gate.io") > 0 or message.find("GATE.IO") > 0 or message.find(
            "gateio") > 0 or message.find("GATEIO") > 0 or message.find("GATEİO") > 0:
        borsa_name = "GATEIO"
        logger.warning(f"Spot operations will be made on {borsa_name}")
    elif message.find("MEXC") > 0 or message.find("mexc") > 0 or message.find("MEXC.COM") > 0 or message.find("mxc.com") > 0 or message.find("mexc.com") > 0 or message.find(
            "MXC.COM") > 0:
        borsa_name = "MXC"
        logger.warning(f"Spot operations will be made on {borsa_name}")
    elif message.find("PROBİT") > 0 or message.find("PROBIT") > 0 or message.find("probit") > 0 or message.find(
            "probit.com") > 0:
        borsa_name = "PROBIT"
        logger.warning(f"Spot operations will be made on {borsa_name}")
    else:
        logger.warning(f"No borsa_name set. Last status {borsa_name}.")


def event_coin_operation(messages):
    global borsa_name,mesajlar
    message = messages.raw_text
    grup_id = messages.grouped_id
    grup_ids = [i[0] for i in mesajlar]
    borsa_names = [i[1] for i in mesajlar]
    pump_message_control_en = message.find("ADI")
    pump_message_control_tr = message.find("ADİ")
    pump_message_control_tr1 = message.find("is")
    if pump_message_control_en > 0 or pump_message_control_tr > 0 or pump_message_control_tr1 > 0:
        for line in message.split('\n'):
            line_control_en = line.find("ADI")
            line_control_tr = line.find("ADİ")
            line_control_tr1 = line.find("is")
            if line_control_en > 0 or line_control_tr > 0 or line_control_tr1 > 0:
                message_list = line.split(":")
                pair = message_list[(len(message_list) - 1)].strip().replace('/USDT','').replace('_USDT','').replace(' / USDT','').replace('/ USDT','').replace('#','').replace('-USDT','').replace(' - USDT','')
                logger.warning(f"Buy-Sell Pair : {pair}.")
                logger.warning(f"Spot operations will be made on {borsa_name}.")
                if borsa_name == "MXC":
                    buy = mxcao.buy_coin_market(pair=pair, quote=9)
                    time.sleep(30)
                    sell = mxcao.sell_coin_market(pair=pair)
                elif borsa_name == "GATEIO":
                    if gateio.check_pair(pair=pair) != -1:
                        buy = gateio.spot(pair=pair, side="BUY", quote=9)
                        time.sleep(30)
                        sell = gateio.spot(pair=pair, side="SELL")
                    else:
                        logger.warning(f"Pair {pair} not exist on market {borsa_name}")
                elif borsa_name == "PROBIT":
                    buy = proao.buy_coin_market(pair=pair, cost=2)
                    logger.warning(f"Buy operation response {buy}")
                    time.sleep(30)
                    sell = proao.sell_coin_market(pair=pair)
                    logger.warning(f"Sell operation response {sell}")
                else:
                    logger.warning("Borsa can not found.")


    elif grup_id in grup_ids :
        pair = message.strip().replace('/USDT','').replace('_USDT','').replace(' / USDT','').replace('/ USDT','').replace('#','').replace('-USDT','').replace(' - USDT','')
        borsa_name = borsa_names[grup_ids.index(grup_id)]
        mesajlar.remove(grup_ids.index(grup_id))
        logger.warning(f"Buy-Sell Pair : {pair}.")
        logger.warning(f"Spot operations will be made on {borsa_name}.")
        if borsa_name == "MXC":
            buy = mxcao.buy_coin_market(pair=pair, quote=9)
            time.sleep(30)
            sell = mxcao.sell_coin_market(pair=pair)
        elif borsa_name == "GATEIO":
            if gateio.check_pair(pair=pair) != -1:
                buy = gateio.spot(pair=pair, side="BUY", quote=9)
                time.sleep(30)
                sell = gateio.spot(pair=pair, side="SELL")
            else:
                logger.warning(f"Pair {pair} not exist on market {borsa_name}")
        elif borsa_name == "PROBIT":
            buy = proao.buy_coin_market(pair=pair, cost=2)
            logger.warning(f"Buy operation response {buy}")
            time.sleep(30)
            sell = proao.sell_coin_market(pair=pair)
            logger.warning(f"Sell operation response {sell}")
        else:
            logger.warning("Borsa can not found.")

    else:
        logger.warning("No coin found on message.")


# Press the green button in the gutter to run the script.
if __name__ == '__main__':
    listen_group()