import requests,time,datetime,os,random
import threading

def times():
    today = str(datetime.datetime.today()).split(' ')
    time=today[1].split('.')
    t=""+today[0]+' '+time[0]+''
    return t

def item_fav(path,useProxy):
    proxies={}
    while True:
        try:
            proxies_list=open(os.path.join(path,'fav_item.proxies'),'r').readlines()
            if useProxy=='yes':
                proxy_good=random.choice(proxies_list)
                proxies=''
                proxy_goods=proxy_good.strip()
                proxy_good=proxy_good.strip().split(':')
                if len(proxy_good)==4:
                    proxies = {'http':'http://%s:%s@%s:%s'%(proxy_good[2],proxy_good[3],proxy_good[0],proxy_good[1]),
                               'https':'https://%s:%s@%s:%s'%(proxy_good[2],proxy_good[3],proxy_good[0],proxy_good[1])}
                else:
                    proxies = {'http':'http://%s:%s'%(proxy_good[0],proxy_good[1]),
                               'https':'https://%s:%s'%(proxy_good[0],proxy_good[1])}

            accs=open(os.path.join(path,'accounts.txt'),'r').readlines()
			print "FELIX: " + path + "accounts.txt"
            # username='smallduck809FR'
            # password='NEdcfltM4S3$'
            choi=random.choice(accs)
            username=choi.split(',')[1].strip()
            password=choi.split(',')[2].strip()
            s=requests.Session()

            data={
                'username' : username,
                'password':password
            }
            headers = {
                "user-agent":"Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/54.0.2840.100 Safari/537.36",
                "Host":"www.roblox.com",
                "Origin":"https://www.roblox.com",
                "Referer":"https://www.roblox.com/",
                "Connection":"keep-alive"
            }
            if useProxy=='yes':
                r=s.post('https://www.roblox.com/newlogin',data=data,headers=headers,proxies = proxies)
            else:
                r=s.post('https://www.roblox.com/newlogin',data=data,headers=headers)
            if useProxy=='yes':
                print "Login: %s Username: %s Password: %s  Proxy: %s"%(str(r.status_code),username,password,proxy_goods)
            if useProxy=='no':
                print "Login: %s Username: %s Password: %s"%(str(r.status_code),username,password)

            if r.status_code == 200:
                items=open(os.path.join(path,'items.txt'),'r').readlines()
                for item in items:
                    assetId=str(item.strip().split('catalog/')[1].split('/')[0]).strip()
                    # print assetId + 'das'
                    # exit()
                    if useProxy=='yes':
                        r=s.get(url=item,data=data,headers=headers,proxies = proxies)
                    else:
                        r=s.get(url=item,data=data,headers=headers)
                    token=''
                    for k in r.content.splitlines():
                        if 'XsrfToken' in k:
                            token=k.split("('")[1].split("')")[0]
                    data={
                        "assetId":assetId
                    }
                    # headers = {
                    #     "Access-Control-Allow-Credentials":"true",
                    #     "Access-Control-Allow-Origin":"https://www.roblox.com",
                    #     "Access-Control-Expose-Headers":"X-CSRF-TOKEN",
                    #     "Cache-Control":"private",
                    #     "Content-Encoding":"gzip",
                    #     "Content-Type":"application/json; charset=utf-8",
                    #     "user-agent":"Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/54.0.2840.100 Safari/537.36",
                    #     "Referer":"https://www.roblox.com/",
                    #     "Connection":"keep-alive"
                    # }
                    headers = {
                    "user-agent":"Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/54.0.2840.100 Safari/537.36",
                    "Host":"www.roblox.com",
                    "Origin":"https://www.roblox.com",
                    "Referer":"https://www.roblox.com/",
                    "Connection":"keep-alive",
                    "X-CSRF-TOKEN":token
                    }
                    if useProxy=='yes':
                        r=s.post(url="https://www.roblox.com/favorite/toggle",data=data,headers=headers, proxies = proxies)
                    else:
                        r=s.post(url='https://www.roblox.com/favorite/toggle',data=data,headers=headers)
                    if r.status_code == 200:
                        t=times()
                        open(os.path.join(path,'item_fav.txt'),'a').write("[%s] "%(t)+str(username)+str(item)+'\n')
                        print "[+] Fav: %s %s Item: %s"%(str(r.status_code),str(r.reason),item)
                    else:
                        print r.status_code,r.reason

        except Exception as e:
            #print "Error: %s"%(str(e))

if __name__=="__main__":
    t=times()
    print ("[%s] Starting..."%(t))
    global path
    path=os.path.dirname(os.path.abspath(__file__))
    open(os.path.join(path,'item_fav.txt'),'w').write("")
    conf=open(os.path.join(path,'fav_item.conf'),'r').readlines()
    useProxy=conf[0].split('=')[1].strip()
    threads=conf[1].split('=')[1].strip()
    getProxies=conf[2].split('=')[1].strip()

    if getProxies=='yes':
        r=requests.get('http://sslproxies24.blogspot.com/feeds/posts/default')
        data = str(r.content).split('<br />')
        dd=''
        for ip in data:
            parts = ip.split('.')
            if len(parts)==4:
                if not "pre class" in ip:
                    if not "?xml version" in ip:
                        if not "script" in ip:
                            print ip
                            dd=dd+ip+'\n'
        open(os.path.join(path, 'fav_item.proxies'), 'w').write('')
        open(os.path.join(path,'fav_item.proxies'),'a').write(dd)

    proxies_list=open(os.path.join(path,'fav_item.proxies'),'r').readlines()
    if useProxy=='yes':
        if len(proxies_list)==0:
            time.sleep(10)
            print('Error - No Proxies in proxies.txt')
            exit()

    for i in range(int(threads)):
        p = threading.Thread(target=item_fav,args=(path,useProxy))
        p.start()