def water_mark(self) -> bool:
if cb:
       wb = 0
       with open('input/watermarking/pfp/pfp.jpg', 'rb') as image_file:
         image_data_pfp = image_file.read()
       base64_image = base64.b64encode(image_data_pfp).decode('utf-8')
       headers = {
            'Authorization': self.token,
            'Content-Type': 'application/json'
       }
       payload = {
         'avatar': f'data:image/jpeg;base64,{base64_image}'
    }
       try:
            response = requests.patch('https://discord.com/api/v9/users/@me',
                                           json=payload,
                                           headers=headers,
                                           timeout=20)
       except:
            Logger.error('serve.py',f'failed to change pfp, token:
{self.token[:23]}***.** [ PROXY ERROR ]')
            return
       if response.status_code == 200:
            wb+=1
            Logger.success('serve.py',f'watermarked token {wb} time(s), token:
{self.token[:23]}***.** [ PFP ]')
       else:
            Logger.error('serve.py',f'watermarking failed, token:
{self.token[:23]}***.** [ PFP ] [ {response.json()} ]')
      headers = {
    'authority': 'discord.com',
    'accept': '*/*',
    'accept-language': 'en-US,en;q=0.9',
    'authorization': self.token,
    'content-type': 'application/json',
    'origin': 'https://discord.com',
    'referer': 'https://discord.com/channels/@me',
    'sec-ch-ua': '"Chromium";v="122", "Not(A:Brand";v="24", "Microsoft
Edge";v="122"',
    'sec-ch-ua-mobile': '?0',
    'sec-ch-ua-platform': '"Windows"',
    'sec-fetch-dest': 'empty',
    'sec-fetch-mode': 'cors',
    'sec-fetch-site': 'same-origin',
    'user-agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36
(KHTML, like Gecko) Chrome/122.0.0.0 Safari/537.36 Edg/122.0.0.0',
    'x-debug-options': 'bugReporterEnabled',
    'x-discord-locale': 'en-US',
    'x-discord-timezone': 'Europe/Budapest',
    'x-super-properties':
'eyJvcyI6IldpbmRvd3MiLCJicm93c2VyIjoiQ2hyb21lIiwiZGV2aWNlIjoiIiwic3lzdGVtX2xvY2FsZS
I6ImVuLVVTIiwiYnJvd3Nlcl91c2VyX2FnZW50IjoiTW96aWxsYS81LjAgKFdpbmRvd3MgTlQgMTAuMDsgV
2luNjQ7IHg2NCkgQXBwbGVXZWJLaXQvNTM3LjM2IChLSFRNTCwgbGlrZSBHZWNrbykgQ2hyb21lLzEyMi4w
LjAuMCBTYWZhcmkvNTM3LjM2IEVkZy8xMjIuMC4wLjAiLCJicm93c2VyX3ZlcnNpb24iOiIxMjIuMC4wLjA
iLCJvc192ZXJzaW9uIjoiMTAiLCJyZWZlcnJlciI6IiIsInJlZmVycmluZ19kb21haW4iOiIiLCJyZWZlcn
Jlcl9jdXJyZW50IjoiIiwicmVmZXJyaW5nX2RvbWFpbl9jdXJyZW50IjoiIiwicmVsZWFzZV9jaGFubmVsI
joic3RhYmxlIiwiY2xpZW50X2J1aWxkX251bWJlciI6Mjc2MDY0LCJjbGllbnRfZXZlbnRfc291cmNlIjpu
dWxsfQ==',
}
      json={
           'global_name': name
           }
      try:
           response=self.session.patch('https://discord.com/api/v9/users/@me',
                                       headers=headers,
                                       json=json)
      except Exception as e:
           print(e)
      if response.status_code in (200, 204):
           wb+=1
           Logger.success('serve.py',f'successfully watermarked {wb} time(s)
[ DISPLAY NAME ]')
      else:
           Logger.error('serve.py', f'watermark serving failed [ DISPLAY-NAME ],
water-marked times: {wb}')
     else:
         pass
def process(token):
    instance = Booster(token)
    joinerBool = instance.joiner()
    try:
         if joinerBool:
               instance.put_boost()
         else:
             pass
    except Exception as e:
         Logger.error('process', f'Failed to process token: {token[:23]}***.***,
error: {e}')
    instance.water_mark()
from colorama import init
init()
if __name__ == "__main__":
    threads = int(input(f'{Fore.GREEN}[?] {Fore.MAGENTA}- {Fore.WHITE}Enter Threads
To Run - '))
    os.system('cls')
    with ThreadPoolExecutor(max_workers=threads) as exc:
        with open('input/tokens.txt') as f:
             tokens = f.read().splitlines()
             for token in tokens:
                 exc.submit(process, token)
input("Press Enter to exit...")