import discord
import random
import asyncio
import aiohttp
from bs4 import BeautifulSoup as soup



client = discord.Client()

def random_line(fname):
    lines = open(fname).read().splitlines()
    return random.choice(lines)


def userornah():
    proxy = ""
    while proxy == "":
        proxy = random_line("proxies.txt")
    try:
        proxytest = proxy.split(":")[2]
        userpass = True
    except IndexError:
        userpass = False
    if userpass == True:
        ip = proxy.split(":")[0]
        port = proxy.split(":")[1]
        userpassproxy = ip + ":" + port
        proxyuser = proxy.split(":")[2].rstrip()
        proxypass = proxy.split(":")[3].rstrip()

    if userpass:
        proxies = {'http': 'http://' + proxyuser + ':' + proxypass + '@' + userpassproxy,
                   'https': 'http://' + proxyuser + ':' + proxypass + '@' + userpassproxy}

        proxies = "http://" + proxyuser + ':' + proxypass + '@' + userpassproxy
    if not userpass:
        proxies = "http://{}".format(proxy)

    return proxies


def page_content(page):
    page_soup = soup(page, 'html.parser')
    watch_link = page_soup.find('a', {'class': ' '})
    return watch_link['href']


def page_content2(page):
    page_soup = soup(page, 'html.parser')
    if 'ADDEDTO' in page_soup.text:
        print('added to watch list')

    else:
        print('no idiot')

firstname = ["Jackson", "Aiden", "Sophia", "Emma", "Olivia", "Lucas", "Ava", "Liam", "Mia", "Noah", "Ethan", "Isabella", "Riley", "Caden", "Aria", "Mason", "Elijah", "Zoe", "Lily", "Michael", "Benjamin", "Emily", "James", "Chloe", "Abigail", "Avery", "Evelyn", "Daniel", "Jack", "Madison", "Caleb", "Alexander", "Daniel", "Jack", "Evelyn", "Isaac", "Cameron", "Julian", "Eli", "Peyton", "Mackenzie", "Maria", "Camilla", "John", "Lincoln", "Brayden", "Victoria"]
lastname = ["Smith", "Johnson", "Williams", "Jones", "Brown", "Davis", "Miller", "Wilson", "Moore", "Taylor", "Anderson",
     "Thomas", "Jackson", "White", "Harris", "Martin", "Thompson", "Garcia", "Martinez", "Lewis", "Hall", "Allen",
     "Young", "Hernandez", "King", "Wright", "Lopez", "Hill", "Scott", "Green", "Adams", "Baker", "Gonzales", "Nelson",
     "Carter", "Mitchell", "Perez", "Roberts", "Turner", "Phillips", "Campbell", "Parker", "Evans", "Stewart",
     "Sanchez", "Morris"]

def loopityloop(itemlink, numberofwatchers):
    loop = asyncio.get_event_loop()
    #loop.run_until_complete(asyncio.gather(*(create_account(itemlink) for x in range(int(numberofwatchers)))))
    asyncio.gather(*(create_account(itemlink) for x in range(int(numberofwatchers))))

def loopityloop2(itemlink, numberofviews):
    asyncio.gather(*(viewthis(itemlink) for x in range(int(numberofviews))))

async def create_account(itemlink):

    first = random.choice(firstname)
    last = random.choice(lastname)
    email = first + last + str(random.randint(00000,10000)) + '@gmail.com'
    url = 'https://reg.ebay.com/reg/PartialReg'
    headers = {
        "Accept": "text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,image/apng,*/*;q=0.8",
        "Accept-Encoding": "gzip, deflate, br",
        "Accept-Language": "en-US,en;q=0.9",
        "Cache-Control": "max-age=0",
        "Connection": "keep-alive",
        # "Content-Length": "1295",
        "Content-Type": "application/x-www-form-urlencoded",
        #"DNT": "1",
        "Host": "reg.ebay.com",
        "Origin": "https://reg.ebay.com",
        "Referer": "https://reg.ebay.com/reg/PartialReg?siteid=0&co_partnerId=0&UsingSSL=1&rv4=1&pageType=3984&ru=https%3A%2F%2Fmy.ebay.com%2Fws%2FeBayISAPI.dll%3FMyEbayBeta%26MyEbay%3D%26gbh%3D1%26guest%3D1&signInUrl=https%3A%2F%2Fwww.ebay.com%2Fsignin%3Fsgn%3Dreg%26siteid%3D0%26co_partnerId%3D0%26UsingSSL%3D1%26rv4%3D1%26pageType%3D3984%26ru%3Dhttps%253A%252F%252Fmy.ebay.com%252Fws%252FeBayISAPI.dll%253FMyEbayBeta%2526MyEbay%253D%2526gbh%253D1%2526guest%253D1",
        "Upgrade-Insecure-Requests": "1",
        #"User-Agent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_13_4) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/68.0.3440.106 Safari/537.36" ORIGINAL
        "User-Agent": "Mozilla/5.0 (Windows NT 6.3; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/69.0.3497.100 Safari/537.36" #CHANGED 9/25

    }

    data = {

        "isSug": "false",
        "countryId": "1",
        "userid": "",
        "ru": "http://www.ebay.com",
        "firstname": first,
        "lastname": last,
        "email": email,
        "PASSWORD": 'sadCheetah69',
        "promotion": "true",
        "iframeMigration1": "true",
        "mode": "1",
        "frmaction": "submit",
        #"tagInfo": 'ht5%3DAQAAAWWsLakOAAUxNjViN2Y4MmE2NC5hNDgyMmZjLjczNTU3LmZmZmZlYmNkutBiUPfY5KE9GOep8hH5mfnR7xI*%7Cht5new%3Dfalse%26usid%3Dc20115171650ad4fff676554ffff6308', #original TagInfo
        "tagInfo": 'ht5%3DAQAAAWXfrUENAAUxNjYwZjYxYTlmNi5hYmM2NjFiLjQ1ZmJhLmZmZmM4OWU1rp13lY%252FhVto1tsEk5Z19OLKmx4U*%7Cht5new%3Dtrue%26usid%3D0f61a9f61660abc661b45fbafffc89e4', #changed 9/25
        # "tagInfo": 'ht5%3DAQAAAWWsLakOAAUxNjViN2Y4MmE2NC5hNDgyMmZjLjczNTU3LmZmZmZlYmNkutBiUPfY5KE9GOep8hH5mfnR7xI*%7Cht5new%3Dfalse%26usid%3D' + str(
        # tmxSessionId),
        "hmvb": "",
        "isGuest": "0",
        "idlstate": "",
        "profilePicture": "",
        "agreement": "Terms and conditions",
        #"signInUrl": "https%3A%2F%2Fsignin.ebay.com%2Fws%2FeBayISAPI.dll%3FSignIn%26regUrl%3Dhttps%253A%252F%252Freg.ebay.com%252Freg%252FPartialReg", ORIGINAL
        'signInUrl': 'https%3A%2F%2Fsignin.ebay.com%2Fws%2FeBayISAPI.dll%3FSignIn%26ru%3Dhttps%253A%252F%252Fwww.ebay.com%252F%26regUrl%3Dhttps%253A%252F%252Freg.ebay.com%252Freg%252FPartialReg%253Fru%253Dhttps%25253A%25252F%25252Fwww.ebay.com%25252F', #CHANGED 9/25
        "personalFlag": "true",
        "isMobilePhone": "",
        "_trksid": "p2052190",
        # "_trksid": trksid,
        #"ets": "AQADAAAAEIqCgeCg9oW5tDS30Hfl7Aw" #original ets
        "ets": "AQADAAAAEM_0M70QMkWoUSWkTIOtdLk" #changed 9/25
        # "ets": ets
    }

    # "https": proxy1


    print('creating account with {}'.format(email))

    headers3 = {
        "authority": "www.ebay.com",
        "method": "GET",
        "path": itemlink[20::],
        "scheme": "https",
        "accept": "text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,image/apng,*/*;q=0.8",
        "accept-encoding": "gzip, deflate, br",
        "accept-language": "en-US,en;q=0.9",
        "dnt": "1",
        "Upgrade-Insecure-Requests": "1",
        "User-Agent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_13_4) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/68.0.3440.106 Safari/537.36"

    }


    proxy1 = userornah()
    print(proxy1)
    #proxy1 = "http://{}".format(proxy1)
    async with aiohttp.ClientSession() as session:
        async with session.post(url, headers=headers, data=data, proxy=proxy1) as resp:
            #return page_content(await resp.text())
            async with session.get(itemlink, headers=headers3, proxy=proxy1) as resp1:
                watch_link = page_content(await resp1.text())
                async with session.get(watch_link, headers=headers3, proxy=proxy1) as resp2:
                    page_content2(await resp2.text())

global count
async def viewthis(itemlink):
    count = 0
    headers3 = {
        "authority": "www.ebay.com",
        "method": "GET",
        "path": itemlink[20::],
        "scheme": "https",
        "accept": "text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,image/apng,*/*;q=0.8",
        "accept-encoding": "gzip, deflate, br",
        "accept-language": "en-US,en;q=0.9",
        "dnt": "1",
        "Upgrade-Insecure-Requests": "1",
        "User-Agent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_13_4) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/68.0.3440.106 Safari/537.36"

    }

    proxy2 = userornah()
    # proxy2 = random_line('proxies.txt')
    # proxy2 = "http://{}".format(proxy2)


    async with aiohttp.ClientSession() as session1:
        try:
            async with session1.get(itemlink, headers=headers3, proxy=proxy2) as resp1:
                print('item viewed')
        except aiohttp.client_exceptions.ClientHttpProxyError:
            print('item not viewed')
        except aiohttp.client_exceptions.ClientConnectorSSLError:
            print('item not viewed')


@client.event
async def on_ready():
    print('------')
    print('Logged in as ' + client.user.name)
    print(client.user.id)
    print('------')
    print('Made by k0rndawg')
    print('ready when you are, dude')
    print('------')


@client.event
async def on_message(message):
    if message.content.startswith("!watch"):
        itemlink = message.content.split(" ")[1]
        if 'www.ebay.com' in itemlink:
            #await client.send_message(message.channel, 'Correct link')
            try:
                number_of_watchers = message.content.split(" ")[2]
            except IndexError:
                embed = discord.Embed(title="You need to add the number of watchers after the link!", color=0xe74c3c)
                embed.set_footer(text='Developed By ~ @k0rnsyrup')
                await client.send_message(message.channel, embed=embed)
                return


            embed = discord.Embed(title="Sending {} Watchers...".format(number_of_watchers), color=0xc27c0e)
            embed.set_footer(text='Developed By ~ @k0rnsyrup')
            await client.send_message(message.channel, embed=embed)
            client.send_message(message.channel, embed=embed)

        else:
            embed = discord.Embed(title="Incorrect Link! Link needs to start with www.ebay.com", color=0xe74c3c)
            embed.set_footer(text='Developed By ~ @k0rnsyrup')
            await client.send_message(message.channel, embed=embed)
            client.send_message(message.channel, embed=embed)
            return


        loopityloop(itemlink, number_of_watchers)
        embed = discord.Embed(title="Successfully Sent {} Watchers!".format(number_of_watchers), color=0x2ecc71)
        embed.set_footer(text='Developed By ~ @k0rnsyrup')
        await client.send_message(message.channel, embed=embed)



    if message.content.startswith('!view'):
        itemlink = message.content.split(" ")[1]
        if 'www.ebay.com' in itemlink:
            # await client.send_message(message.channel, 'Correct link')
            number_of_views = message.content.split(" ")[2]
            embed = discord.Embed(title="Sending {} Views...".format(number_of_views), color=0xc27c0e)
            embed.set_footer(text='Developed By ~ @k0rnsyrup')
            await client.send_message(message.channel, embed=embed)
            try:
                loopityloop2(itemlink, number_of_views)
            except aiohttp.client_exceptions.ClientConnectorSSLError:
                print('not viewed')

            embed = discord.Embed(title="Successfully Sent {} Views!".format(number_of_views), color=0x2ecc71)
            embed.set_footer(text='Developed By ~ @k0rnsyrup')
            await client.send_message(message.channel, embed=embed)
        else:
            embed = discord.Embed(title="Invalid Link!", color=0xe74c3c)
            embed.set_footer(text='Developed By ~ @k0rnsyrup')
            await client.send_message(message.channel, embed=embed)
            client.send_message(message.channel, embed=embed)
            return


    if message.content.startswith("!quit"):
        if message.author.id == '142813946879934464':
            embed = discord.Embed(title=" ")
            embed.add_field(name='Status Update', value="{} has taken me offline!".format(message.author.mention))
            await client.send_message(message.channel, embed=embed)
            await client.logout()
        else:
            embed = discord.Embed(title=' ')
            embed.add_field(name="Not Authorized", value="You Thought, {}".format(message.author.mention))
            await client.send_message(message.channel, embed=embed)


    if message.content.startswith("!format"):
        embed = discord.Embed(title='Format:\n\n`!view <ebay link> <# of views desired>` \n`!watch <ebay link> <# of watchers desired>`', color=0x3498db)
        embed.set_footer(text='Developed By ~ @k0rnsyrup')
        await client.send_message(message.channel, embed=embed)
        client.send_message(message.channel, embed=embed)




if __name__ == '__main__':
    client.run("NDk0MzU1NjIyNzk2NDYwMDMz.DoycKw.rfnx3R2mSR_DaDV7MU5bS3CB1L0")