main.py

# Donator Groups

import asyncio
import logging
import re
import time
import os
import sys
import requests

logging.basicConfig(level=logging.ERROR)

from telethon.tl.types import UpdateShortMessage,ReplyInlineMarkup,KeyboardButtonUrl
from telethon import TelegramClient, events
from telethon.tl.functions.channels import JoinChannelRequest
from telethon.tl.functions.messages import GetBotCallbackAnswerRequest
from datetime import datetime
from colorama import Fore, init as color_ama
from bs4 import BeautifulSoup

color_ama(autoreset=True)

os.system('cls' if os.name=='nt' else 'clear')

# Get your own values from my.telegram.org
api_id = 800812
api_hash = 'db55ad67a98df35667ca788b97f771f5'

# WELCOME BLOCK
print(Fore.MAGENTA + '		__      _____ _    ___ ___  __  __ ___ ')
print(Fore.MAGENTA + '		\ \    / / __| |  / __/ _ \|  \/  | __|')
print(Fore.MAGENTA + '		 \ \/\/ /| _|| |_| (_| (_) | |\/| | _| ')
print(Fore.MAGENTA + '		  \_/\_/ |___|____\___\___/|_|  |_|___|\n' + Fore.RESET)
print(Fore.RED + '   -                   Click Bot Script v4                 -' + Fore.RESET)
print('')
print(Fore.YELLOW + '   -               Channel Youtube :' + Fore.RED +' Zizi' + Fore.WHITE +'works' + Fore.YELLOW +'             -')
# DESCRIPTION BLOCK
print('\n		 Earn money using telegram bot.\n')
# Bot options
print(' Options: \n')
option = ["Dogecoin_click_bot", "Litecoin_click_bot", "BCH_clickbot", "Zcash_click_bot", "Bitcoinclick_bot"] #Bot option list
# Print bot options list with numberings
for number, letter in enumerate(option):
    print(	"	", number, letter)
# Ask user to select bot
ask = int(input ("	\n	Which bot do you want to run?" + Fore.RED + " (Number only)" + Fore.RESET + ":" ))
answer = (option[ask])
url_channel = answer

def print_msg_time(message):
	print('[' + Fore.CYAN + f'{datetime.now().strftime("%H:%M:%S")}' + Fore.RESET + f'] {message}')

def get_response(url, method='GET'):
	response = requests.request(method, url, headers={"User-Agent":"Mozilla/5.0 (Windows NT 10.0; Win32; x86) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/67.0.3396.99 Safari/537.36"}, timeout=15)
	text_response = response.text
	status_code = response.status_code
	return[status_code, text_response]
		
async def main():
	print(Fore.GREEN + url_channel + Fore.RESET + " selected.\n")
	print('		DogeClick Bot Channel Actions Menu.\n')
	# Bot options
	print(' Options: \n')
	action = ["Visit", "Message", "Join"] #Bot option list
	# Print bot options list with numberings
	for number, letter in enumerate(action):
		print(	"	", number, letter)
	# Ask user to select bot
	ask_action = int(input ("	\n	What bot's action do you want to perform?" + Fore.RED + " (Number only)" + Fore.RESET + ":" ))
	answer = (action[ask_action])
	bot_action = answer
	if answer == action[0]:
		print(action[0] + " performed")
				# Check if phone number is not specified
		if len(sys.argv) < 2:
			print('Usage: python start.py phone_number')
			print('-> Input number in international format (example: +639162995600)\n')
			e = input('Press any key to exit...')
			exit(1)
			
		phone_number = sys.argv[1]
		
		if not os.path.exists("session"):
			os.mkdir("session")
	   
		# Connect to client
		client = TelegramClient('session/' + phone_number, api_id, api_hash)
		await client.start(phone_number)
		me = await client.get_me()
		ads_channel = "ziziworks"
		await client(JoinChannelRequest(ads_channel))
		ads_group = "ziziworksgroup"
		await client(JoinChannelRequest(ads_group))
		print('Current account:' + Fore.CYAN + f'{me.first_name}({me.username})\n' + Fore.RESET)
		print_msg_time(Fore.YELLOW + 'Sending /visit command' + Fore.RESET)
		
		# Start command /visit
		await client.send_message(url_channel, '/visit')
		
		# Start visiting the ads
		@client.on(events.NewMessage(chats=url_channel, incoming=True))
		async def visit_ads(event):
		
		
			original_update = event.original_update
			if type(original_update)is not UpdateShortMessage:
				if hasattr(original_update.message,'reply_markup') and type(original_update.message.reply_markup) is ReplyInlineMarkup:
					url = event.original_update.message.reply_markup.rows[0].buttons[0].url
					#url = event.message.reply_markup.rows[0].buttons[0].url
				
					if url is not None:
						print_msg_time('Visiting website...')

						# Parse the html of url
						(status_code, text_response) = get_response(url)
						parse_data = BeautifulSoup(text_response, 'html.parser')
						captcha = parse_data.find('div', {'class':'g-recaptcha'})
						
						# Captcha detected
						if captcha is not None:
							print_msg_time(Fore.RED + 'Captcha detected!'+ Fore.RED +' Skipping ads...\n')
										
							# Clicks the skip
							await client(GetBotCallbackAnswerRequest(
								peer=url_channel,
								msg_id=event.message.id,
								data=event.message.reply_markup.rows[1].buttons[1].data
							))		
			
		# Print earned money
		@client.on(events.NewMessage(chats=url_channel, incoming=True))
		async def wait_hours(event):
			message = event.raw_text
			if 'You earned' in message:	
				print_msg_time(Fore.GREEN + f'{message}' + Fore.RESET)
		# Balance Check
			#======== Start print balance
		#@client.on(events.NewMessage(chats=url_channel, incoming=True))
		#async def account_balance(event):
			#message = event.raw_text
			#if 'Available balance' in message:	
				#print_msg_time(Fore.YELLOW + f'{message}\n' + Fore.RESET)
			# Print earned money
		@client.on(events.NewMessage(chats=url_channel, incoming=True))
		async def manual_skip(event):
			message = event.raw_text
			if 'Skipping task...' in message:	
				print_msg_time(Fore.YELLOW + f'{message}' + Fore.RESET)
		# No longer valid
		@client.on(events.NewMessage(chats=url_channel, incoming=True))
		async def no_valid(event):
			message = event.raw_text
			if 'Sorry, that task is no longer valid' in message:	
				print_msg_time(Fore.RED + 'Sorry, that task is no longer valid.' + Fore.RESET)
				print_msg_time(Fore.YELLOW + 'Sending /visit command' + Fore.RESET)
				await client.send_message(url_channel, '/visit')
		# No more ads
		@client.on(events.NewMessage(chats=url_channel, incoming=True))
		async def no_ads(event):
			message = event.raw_text
			if 'no new ads available' in message:	
				print_msg_time(Fore.RED + 'Sorry, there are no new ads available\n' + Fore.RESET)
				e = input('Press any key to exit...')
				exit(1)
	elif answer == action[1]:
		print(action[1] + " performed")
				# Check if phone number is not specified
		if len(sys.argv) < 2:
			print('Usage: python start.py phone_number')
			print('-> Input number in international format (example: +639162995600)\n')
			e = input('Press any key to exit...')
			exit(1)
			
		phone_number = sys.argv[1]
		
		if not os.path.exists("session"):
			os.mkdir("session")
	   
		# Connect to client
		client = TelegramClient('session/' + phone_number, api_id, api_hash)
		await client.start(phone_number)
		me = await client.get_me()
		ads_channel = "ziziworks"
		await client(JoinChannelRequest(ads_channel))
		ads_group = "ziziworksgroup"
		await client(JoinChannelRequest(ads_group))
		print('Current account:' + Fore.CYAN + f'{me.first_name}({me.username})\n' + Fore.RESET)
		print_msg_time('Sending /bots command')
		
		# Start command /bots
		await client.send_message(url_channel, '/bots')
		
		# Message the bot
		@client.on(events.NewMessage(chats=url_channel, incoming=True))
		async def join_start(event):
			message = event.raw_text
			if 'Forward a message to' in message:	
				channel_msg = event.original_update.message.reply_markup.rows[0].buttons[0].url
				print_msg_time(f'URL @{channel_msg}')
				
				if '?' in channel_msg:
					channel_name = re.search(r't.me\/(.*?)\?', channel_msg).group(1)
				elif '?' not in channel_msg:
					channel_name = re.search(r't.me\/(.*?)', channel_msg).group(1)
				
				print_msg_time(f'Messaging @{channel_name}...')
				await client.send_message(channel_name, '/start')
				
				# Forward the bot message
				@client.on(events.NewMessage(chats=channel_name, incoming=True))
				async def earned_amount(event):
					msg_id = event.message.id,
					await client.forward_messages(url_channel, msg_id, channel_name)
		
		# Print earned amount
		@client.on(events.NewMessage(chats=url_channel, incoming=True))
		async def earned_amount(event):
			message = event.raw_text
			if 'You earned' in message:	
				print_msg_time(Fore.GREEN + event.raw_text + '\n' + Fore.RESET)
				
		# No more ads
		@client.on(events.NewMessage(chats=url_channel, incoming=True))
		async def no_ads(event):
			message = event.raw_text
			if 'no new ads available' in message:	
				print_msg_time(Fore.RED + 'Sorry, there are no new ads available\n' + Fore.RESET)
				e = input('Press any key to exit...')
				exit(1)
	elif answer == action[2]:
		print(action[2] + " performed")
				# Check if phone number is not specified
		if len(sys.argv) < 2:
			print('Usage: python start.py phone_number')
			print('-> Input number in international format (example: +639162995600)\n')
			e = input('Press any key to exit...')
			exit(1)
			
		phone_number = sys.argv[1]
		
		if not os.path.exists("session"):
			os.mkdir("session")
	   
		# Connect to client
		client = TelegramClient('session/' + phone_number, api_id, api_hash)
		await client.start(phone_number)
		me = await client.get_me()
		ads_channel = "ziziworks"
		await client(JoinChannelRequest(ads_channel))
		ads_group = "ziziworksgroup"
		await client(JoinChannelRequest(ads_group))
		print('Current account:' + Fore.CYAN + f'{me.first_name}({me.username})\n' + Fore.RESET)
		print_msg_time('Sending /join command')
		
		# Start command /join
		await client.send_message(url_channel, '/join')
		
		# Join the channel
		@client.on(events.NewMessage(chats=url_channel, incoming=True))
		async def join_start(event):
			message = event.raw_text
			if 'You must join' in message:	
				channel_name = re.search(r'You must join @(.*?) to earn', message).group(1)
				print_msg_time(f'Joining @{channel_name}...')
				
				# Join the channel
				await client(JoinChannelRequest(channel_name))
				print_msg_time(f'Verifying...')
				
				# Clicks the joined
				await client(GetBotCallbackAnswerRequest(
					peer=url_channel,
					msg_id=event.message.id,
					data=event.message.reply_markup.rows[0].buttons[1].data
				))
		
		# Print waiting hours
		@client.on(events.NewMessage(chats=url_channel, incoming=True))
		async def wait_hours(event):
			message = event.raw_text
			if 'You must stay' in message:	
				waiting_hours = re.search(r'at least (.*?) to earn', message).group(1)
				print_msg_time(Fore.GREEN + f'Success! Please wait {waiting_hours} to earn reward\n' + Fore.RESET)
				
		# No more ads
		@client.on(events.NewMessage(chats=url_channel, incoming=True))
		async def no_ads(event):
			message = event.raw_text
			if 'no new ads available' in message:	
				print_msg_time(Fore.RED + 'Sorry, there are no new ads available\n' + Fore.RESET)
				e = input('Press any key to exit...')
				exit(1)
	else:
		print("You insert nothing which me no action. Exit..")
		exit

	
	await client.run_until_disconnected()
	
asyncio.get_event_loop().run_until_complete(main())