import base64
from pystyle import *
import os
import sys
import ssl
import re
import time
import random
import threading
import requests
import hashlib
import json
from urllib3.exceptions import InsecureRequestWarning
from http import cookiejar
class BlockCookies(cookiejar.CookiePolicy):
return_ok = set_ok = domain_return_ok = path_return_ok = lambda self, *args, **kwargs: False
netscape = True
rfc2965 = hide_cookie2 = False
requests.packages.urllib3.disable_warnings(category=InsecureRequestWarning)
ssl._create_default_https_context = ssl._create_unverified_context
r = requests.Session()
r.cookies.set_policy(BlockCookies())
class Gorgon:
def __init__(self,params:str,data:str,cookies:str,unix:int)->None:self.unix=unix;self.params=params;self.data=data;self.cookies=cookies
def hash(self,data:str)->str:
try:_hash=str(hashlib.md5(data.encode()).hexdigest())
except Exception:_hash=str(hashlib.md5(data).hexdigest())
return _hash
def get_base_string(self)->str:base_str=self.hash(self.params);base_str=base_str+self.hash(self.data)if self.data else base_str+str('0'*32);base_str=base_str+self.hash(self.cookies)if self.cookies else base_str+str('0'*32);return base_str
def get_value(self)->json:base_str=self.get_base_string();return self.encrypt(base_str)
def encrypt(self,data:str)->json:
unix=self.unix;len=20;key=[223,119,185,64,185,155,132,131,209,185,203,209,247,194,185,133,195,208,251,195];param_list=[]
for i in range(0,12,4):
temp=data[8*i:8*(i+1)]
for j in range(4):H=int(temp[j*2:(j+1)*2],16);param_list.append(H)
param_list.extend([0,6,11,28]);H=int(hex(unix),16);param_list.append((H&4278190080)>>24);param_list.append((H&16711680)>>16);param_list.append((H&65280)>>8);param_list.append((H&255)>>0);eor_result_list=[]
for (A,B) in zip(param_list,key):eor_result_list.append(A^B)
for i in range(len):C=self.reverse(eor_result_list[i]);D=eor_result_list[(i+1)%len];E=C^D;F=self.rbit_algorithm(E);H=(F^4294967295^len)&255;eor_result_list[i]=H
result=''
for param in eor_result_list:result+=self.hex_string(param)
return{'X-Gorgon':'0404b0d30000'+result,'X-Khronos':str(unix)}
def rbit_algorithm(self,num):
result='';tmp_string=bin(num)[2:]
while len(tmp_string)<8:tmp_string='0'+tmp_string
for i in range(0,8):result=result+tmp_string[7-i]
return int(result,2)
def hex_string(self,num):
tmp_string=hex(num)[2:]
if len(tmp_string)<2:tmp_string='0'+tmp_string
return tmp_string
def reverse(self,num):tmp_string=self.hex_string(num);return int(tmp_string[1:]+tmp_string[:1],16)
def send(did, iid, cdid, openudid):
global reqs, _lock, success, fails
for x in range(10):
try:
params = f"device_id={did}&iid={iid}&device_type=SM-G973N&app_name=musically_go&host_abi=armeabi-v7a&channel=googleplay&device_platform=android&version_code=160904&device_brand=samsung&os_version=9&aid=1340"
payload = f"item_id={__aweme_id}&play_delta=1"
sig = Gorgon(params=params, cookies=None, data=None, unix=int(time.time())).get_value()
proxy = random.choice(proxies) if config['proxy']['use-proxy'] else ""
response = requests.post(
url = (
"https://api16-va.tiktokv.com/aweme/v1/aweme/stats/?" + params
),
data = payload,
headers = {'cookie':'sessionid=90c38a59d8076ea0fbc01c8643efbe47','x-gorgon':sig['X-Gorgon'],'x-khronos':sig['X-Khronos'],'user-agent':'okhttp/3.10.0.1'},
verify = False,
proxies = {"http": proxy_format+proxy, "https": proxy_format+proxy} if config['proxy']['use-proxy'] else {}
)
reqs += 1
try:
_lock.acquire()
print(Colorate.Horizontal(Colors.green_to_white, f"+ - sent views {response.json()['log_pb']['impr_id']} {__aweme_id} {reqs}"))
_lock.release()
success += 1
except:
if _lock.locked():_lock.release()
fails += 1
continue
except Exception as e:
pass
def rpsm_loop():
global rps, rpm
while True:
initial = reqs
time.sleep(1.5)
rps = round((reqs - initial) / 1.5, 1)
rpm = round(rps * 60, 1)
def title_loop():
global rps, rpm, success, fails, reqs
if os.name == "nt":
while True:
os.system(f'title TikTok Viewbot by @xtekky ^| success: {success} fails: {fails} reqs: {reqs} rps: {rps} rpm: {rpm}')
time.sleep(0.1)
if __name__ == "__main__":
os.system("cls" if os.name == "nt" else "clear"); os.system("title TikTok Viewbot by @xtekky" if os.name == "nt" else "")
txt = """\n\n╦ ╦╦╔═╗╦ ╦╔╗ ╔═╗╔╦╗\n╚╗╔╝║║╣ ║║║╠╩╗║ ║ ║ \n ╚╝ ╩╚═╝╚╩╝╚═╝╚═╝ ╩ \n"""
print(
Colorate.Vertical(
Colors.DynamicMIX((Col.light_blue, Col.purple)), Center.XCenter(txt)
)
)
try:
link = str(Write.Input("\n\n ? - Video Link > ", Colors.yellow_to_red, interval=0.0001))
__aweme_id = str(
re.findall(r"(\d{18,19})", link)[0]
if len(re.findall(r"(\d{18,19})", link)) == 1
else re.findall(
r"(\d{18,19})",
requests.head(link, allow_redirects=True, timeout=5).url
)[0]
)
except:
os.system("cls" if os.name == "nt" else "clear")
input(Col.red + "x - Invalid link, try inputting video id only" + Col.reset)
sys.exit(0)
os.system("cls" if os.name == "nt" else "clear")
print("loading...")
_lock = threading.Lock()
reqs = 0
success = 0
fails = 0
rpm = 0
rps = 0
threading.Thread(target=rpsm_loop).start()
threading.Thread(target=title_loop).start()
with open('devices.txt', 'r') as f:
devices = f.read().splitlines()
with open('config.json', 'r') as f:
config = json.load(f)
proxy_format = f'{config["proxy"]["proxy-type"].lower()}://{config["proxy"]["credential"]+"@" if config["proxy"]["auth"] else ""}' if config['proxy']['use-proxy'] else ''
if config['proxy']['use-proxy']:
with open('proxies.txt', 'r') as f:
proxies = f.read().splitlines()
while True:
device = random.choice(devices)
if eval(base64.b64decode("dGhyZWFkaW5nLmFjdGl2ZV9jb3VudCgpIDwgMTAwICMgZG9uJ3QgY2hhbmdlIGNvdW50IG9yIHUgd2lsbCBraWxsIGRldmljZXMgYW5kIHJ1aW4gZnVuIGZvciBvdGhlcnM=")):
did, iid, cdid, openudid = device.split(':')
eval(base64.b64decode('dGhyZWFkaW5nLlRocmVhZCh0YXJnZXQ9c2VuZCxhcmdzPVtkaWQsaWlkLGNkaWQsb3BlbnVkaWRdKS5zdGFydCgp'))
