Профили
Управление прокси
Бэкапы
Оставить:
__BACKUPS__
Выберите прокси для переименования:
Новое имя:
['"]?) - захватывает кавычку (если она есть) в группу 'quote' # \\1 - ссылается на захваченную кавычку, чтобы заменить на такую же pattern_def = r"(name\s*:\s*)(?P['\"]?)" + escaped_old + r"(?P=quote)" # Заменяем, сохраняя оригинальные кавычки content = re.sub(pattern_def, r'\g<1>"' + new_name + '"', content, count=1) # 2. Замена в списках proxy-groups: - "old_name" # Regex для поиска `- 'old_name'`, `- "old_name"` или `- old_name` pattern_list = r"(-\s+)(?P['\"]?)" + escaped_old + r"(?P=quote)" content = re.sub(pattern_list, r'\g<1>"' + new_name + '"', content) s.wfile.write(json.dumps({'status': 'ok', 'new_content': content}).encode('utf-8')) return # --- EXISTING ACTIONS --- if a == 'parse': link = p.get('link', '') custom_name = p.get('proxy_name') d, e = parse_vless(link, custom_name) s.wfile.write(json.dumps(d if d else {'error': e}).encode('utf-8')); return if a == 'add_wireguard': config_text = p.get('config_text', '') custom_name = p.get('proxy_name') if not config_text: s.wfile.write(json.dumps({'error': 'Empty config'}).encode('utf-8')) return proxy_data, err = parse_wireguard(config_text, custom_name) if err: s.wfile.write(json.dumps({'error': err}).encode('utf-8')) return s.wfile.write(json.dumps(proxy_data).encode('utf-8')) return if a == 'apply_insert': content = p.get('content', ''); p_name = p.get('proxy_name', ''); p_yaml = p.get('proxy_yaml', ''); targets = json.loads(p.get('targets', '[]')) lines = content.splitlines(); inserted = False for i, line in enumerate(lines): if line.strip().startswith('proxies:'): blk = p_yaml.splitlines(); for bi, bl in enumerate(blk): lines.insert(i + 1 + bi, " " + bl) inserted = True; break if not inserted: lines.append("proxies:"); lines.extend([" " + l for l in p_yaml.splitlines()]) uc = insert_proxy_logic("\n".join(lines), p_name, targets) s.wfile.write(json.dumps({'new_content': uc}).encode('utf-8')); return if a == 'clean_backups': limit = int(p.get('limit', 5)) files = sorted(glob.glob(BACKUP_DIR + "/*.yaml"), key=os.path.getmtime, reverse=True) if len(files) > limit: for f in files[limit:]: try: os.remove(f) except: pass s.wfile.write(json.dumps({'backups': s.get_bks()}).encode('utf-8')); return if a == 'del_backup': fname = p.get('f') path = os.path.join(BACKUP_DIR, os.path.basename(fname)) if os.path.exists(path): os.remove(path) s.wfile.write(json.dumps({'backups': s.get_bks()}).encode('utf-8')); return if a == 'rest': shutil.copy(os.path.join(BACKUP_DIR, os.path.basename(p.get('f'))), CONFIG_PATH) s.wfile.write(json.dumps({'status': 'ok'}).encode('utf-8')); return if a == 'view_backup': fname = p.get('f') path = os.path.join(BACKUP_DIR, os.path.basename(fname)) if os.path.exists(path): with open(path, 'r', encoding='utf-8') as f: content = f.read() s.wfile.write(json.dumps({'content': content}).encode('utf-8')) else: s.wfile.write(json.dumps({'error': 'File not found'}).encode('utf-8')) return new_c = p.get('content', '').replace('\r\n', '\n') if a in ['save', 'restart']: if os.path.exists(CONFIG_PATH): real_p = os.path.basename(os.path.realpath(CONFIG_PATH)) prof_n = os.path.splitext(real_p)[0] ts = datetime.now().strftime('%Y%m%d_%H%M%S') shutil.copy(CONFIG_PATH, f"{BACKUP_DIR}/{prof_n}_{ts}.yaml") with open(CONFIG_PATH, 'w') as f: f.write(new_c); f.flush(); os.fsync(f.fileno()) if a == 'restart': my_env = os.environ.copy(); my_env["TERM"] = "xterm-256color" subprocess.run(RESTART_CMD, shell=True, env=my_env) log = open(LOG_FILE).read() if os.path.exists(LOG_FILE) else "Log empty" s.wfile.write(json.dumps({'log': log}).encode('utf-8')) elif a == 'save': s.wfile.write(json.dumps( {'status': 'ok', 'time': datetime.now().strftime("%H:%M:%S"), 'backups': s.get_bks()}).encode('utf-8')) def do_PUT(s): if s.path.startswith('/mihomo_panel/'): s.proxy_pass('PUT') return s.send_error(405, "Method Not Allowed") def do_DELETE(s): if s.path.startswith('/mihomo_panel/'): s.proxy_pass('DELETE') return s.send_error(405, "Method Not Allowed") try: socketserver.TCPServer.allow_reuse_address = True; socketserver.TCPServer(("", PORT), H).serve_forever() except Exception as e: print(e)