Advertisement
StalkerneD

Untitled

Jun 5th, 2020
546
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  1. # Обмен сообщениями с ботом
  2.         @client.on(events.NewMessage(chats=dogeclick_channel, incoming=True))
  3.         async def join_start(event):
  4.                 message = event.raw_text
  5.                 if 'that is not a valid forwarded message' in message:
  6.                         await client(GetBotCallbackAnswerRequest(
  7.                                 peer=dogeclick_channel,
  8.                                 msg_id=event.message.id,
  9.                                 data=event.message.reply_markup.rows[1].buttons[1].data
  10.                         ))
  11.  
  12.                 elif 'Forward a message to' in message:
  13.                         channel_msg = event.original_update.message.reply_markup.rows[0].buttons[0].url
  14.                         print_msg_time(f'URL @{channel_msg}')
  15.                         Link = 'telegram.me'
  16.                         if Link in channel_msg:
  17.                                 if '?' in Link:
  18.                                         channel = re.search(r'telegram.me\/(.*?)\?', channel_msg).group(1)
  19.                                                                                                                                                                                                                  elif '?' not in Link:
  20.                                         channel = re.search(r'telegram.me\/(.*)', channel_msg).group(1)
  21.                                         fragment = urllib.parse.urlparse(channel).fragment
  22.                                         channel_name = channel.split("?")
  23.                                         channel_name = (format(channel_name[0]))
  24.                                         if 'start' in channel:
  25.                                                 channel_name1 = (format(channel[1]))
  26.                                                 fragment = urllib.parse.urlparse(channel_name1).fragment
  27.                                                 channel_name1 = channel.split("=")
  28.                                                 channel_name1 = (format(channel_name1[1]))
  29.                         else:
  30.  
  31.                                 if '?' in Link:
  32.                                         channel = re.search(r't.me\/(.*?)\?', channel_msg).group(1)
  33.  
  34.                                 elif '?' not in Link:
  35.                                         channel = re.search(r't.me\/(.*)', channel_msg).group(1)
  36.                                         fragment = urllib.parse.urlparse(channel).fragment
  37.                                         channel_name = channel.split("?")
  38.                                         channel_name = (format(channel_name[0]))
  39.                                         if 'start' in channel:
  40.                                                 channel_name1 = (format(channel[1]))
  41.                                                 fragment = urllib.parse.urlparse(channel_name1).fragment
  42.                                                 channel_name1 = channel.split("=")
  43.                                                 channel_name1 = (format(channel_name1[1]))
  44.                                         else:
  45.                                                 channel_name1 = 'startt'
  46.  
  47.                         # Отправка команды start в бот
  48.                         if channel_name1 in channel_msg:
  49.                                 print_msg_time(f'Обмен сообщениями с ботом: @{channel_name}...')
  50.                                 try:
  51.                                         await client.send_message(channel_name, "/start {}".format(channel_name1[1]))
  52.                                         time.sleep(2)
  53.                                 except ChatWriteForbiddenError:
  54.                                         await client(JoinChannelRequest(channel_name))
  55.  
  56.                         elif channel_name in channel_msg:
  57.                                 print_msg_time(f'Обмен сообщениями с ботом: @{channel_name}...')
  58.                                 try:
  59.                                         await client.send_message(channel_name, '/start')
  60.                                         time.sleep(2)
  61.                                 except ChatWriteForbiddenError:
  62.                                         await client(JoinChannelRequest(channel_name))
  63.                         else:
  64.                                 print_msg_time(Fore.RED + 'Бот не найден!'+ Fore.RED +' Пропуск рекламы...\n')
  65.                                 await client(GetBotCallbackAnswerRequest(
  66.                                         peer=dogeclick_channel,
  67.                                         msg_id=event.message.id,
  68.                                         data=event.message.reply_markup.rows[1].buttons[1].data
  69.                                 ))
  70.  
  71.                         # Переслать сообщение боту
  72.                         @client.on(events.NewMessage(chats=channel_name, incoming=True))
  73.                         async def earned_amount(event):
  74.                                 msg_id = event.message.id,
  75.                                 if msg_id is not None:
  76.                                         await client.forward_messages(dogeclick_channel, msg_id, channel_name)
  77.  
  78.         # Если сообщение не соответствует
  79.         @client.on(events.NewMessage(chats=dogeclick_channel, incoming=True))
  80.         async def earand_err(event):
  81.                 message = event.raw_text
  82.                 if 'that is not a valid forwarded message' in message:
  83.                         await join_start(event)
Advertisement
RAW Paste Data Copied
Advertisement