from aiogram import Bot,types
from aiogram.dispatcher import Dispatcher
from aiogram.utils import executor
import selenium
import selenium.webdriver.support.ui as ui
from selenium.webdriver.chrome.options import Options
from selenium import webdriver
import requests
import random
from bs4 import BeautifulSoup as bs
from aiogram.contrib.fsm_storage.memory import MemoryStorage
from aiogram.dispatcher import FSMContext
from aiogram.dispatcher.filters.state import State, StatesGroup
from multiprocessing import Pool
storage = MemoryStorage()
def get_free_proxies():
url = "https://sslproxies.org./"
# получаем ответ HTTP и создаем объект soup
soup = bs(requests.get(url).content, "html.parser")
proxies = []
for row in soup.find("table", attrs={"class": "table table-striped table-bordered"}).find_all("tr")[1:]:
tds = row.find_all("td")
try:
ip = tds[0].text.strip()
port = tds[1].text.strip()
host = f"{ip}:{port}"
proxies.append(host)
except IndexError:
continue
return proxies
#command of watching video
def watch_video(PROXY):
#login
opts = WebDriver.ChromeOptions()
opts.add_argument('--proxy-server=%s' % PROXY)
opts.add_argument("user-agent=Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/105.0.0.0 Safari/537.36")
driver = webdriver.Chrome(chrome_options=opts, executable_path=r'C:\Users\s-isroilov\Desktop\chromedriver.exe')
driver.get('https://accounts.google.com/v3/signin/identifier?dsh=S486906257%3A1665674407916812&continue=https%3A%2F%2Faccounts.google.com%2F&followup=https%3A%2F%2Faccounts.google.com%2F&passive=1209600&flowName=GlifWebSignIn&flowEntry=ServiceLogin&ifkv=AQDHYWrVJuo3NB8buJ3kQD6yKMDsBX37LSgvbiX3TAtAp2-jAMW566ou8IdcVh2MqgcjG9sQpAglOA')
c = 0
while c != 10:
driver.implicitly_wait(1000)
email = driver.find_element_by_id('identifierId')
email.send_keys('gmail')
nextBtn = driver.find_element_by_id('identifierNext')
nextBtn.click()
driver.implicitly_wait(5)
try:
driver.find_element_by_name("Passwd").send_keys("psd")
driver.find_element_by_id("passwordNext").click()#clicking next
c = 10
except:
element = driver.find_element_by_id('next')
element.click()
continue
#_______
#timer
driver.get(link)
#subscribing
driver.implicitly_wait(1000)
sub = driver.find_element_by_id('subscribe-button').click()
driver.implicitly_wait(10000)
if driver.find_element_by_id('cancel-button')!=None:
driver.find_element_by_id('cancel-button').click()
while True:
driver.implicitly_wait(1000000)
if driver.find_element_by_class_name('ytp-autonav-endscreen-upnext-thumbnail') !=None:
return 1
else:
continue
bot = Bot('TOKEN')
dp = Dispatcher(bot, storage=storage)
class UserState(StatesGroup):
times = State()
link = State()
#telegram bot
@dp.message_handler(commands = ['start', 'help'])
async def start(message : types.Message):
await message.reply('Use command /watch')
@dp.message_handler(commands = ['watch'])
async def new_message(message: types.Message):
await message.reply('Enter the link to the video')
await UserState.link.set()
@dp.message_handler(state=UserState.link)
async def ok(message: types.Message, state:FSMContext):
await state.update_data(link=message.text)
await message.reply('Now enter how many times shall I watch this video?(just a number)')
await UserState.times.set()
def finish():
bot.reply('Successfully watched')
@dp.message_handler(state=UserState.times)
async def nevermind(message:types.Message, state:FSMContext):
await state.update_data(times=int(message.text))
data = await state.get_data()
if data['times']>100:
await message.reply('Please enter number that is less than 100 (now write /watch again)!!!')
global link
link = data['link']
times = data['times']
global proxies
proxies = get_free_proxies()
p = Pool(times)
for PROXY in proxies:
p.map(watch_video, PROXY)
executor.start_polling(dp, skip_updates=True)
