feat(proxy-client): добавлены профили и системная служба
Добавлены независимые пользовательские профили, их выбор в Bash-командах и явная установка службы systemd. Инструкции размещены в README пакета. Проверка: 67 тестов на Python 3.8 и 3.14, shell-наборы и интеграция Bash с CLI. Загрузка ОС и восстановление настоящей службы требуют отдельной проверки.
This commit is contained in:
1 parent
b36ce50e12
commit
b34eb6ac4c
9 files changed
+835
-23
No files matched your search
@@ -15,7 +15,7 @@ from urllib.parse import quote
|
||||
|
||||
|
||||
REPO_ROOT = Path(__file__).resolve().parents[1]
|
||||
CLI = REPO_ROOT / "proxy-client/.local/bin/proxy-client"
|
||||
CLI = Path(os.environ.get("PROXY_CLIENT_TEST_CLI", str(REPO_ROOT / "proxy-client/.local/bin/proxy-client")))
|
||||
UUID = "11111111-2222-4333-8444-555555555555"
|
||||
PATH_SECRET = "/tenant/PATH_SENTINEL_a1b2"
|
||||
PROFILE = (
|
||||
@@ -28,7 +28,7 @@ REALITY_PROFILE = (
|
||||
"vless://{}@edge.example:443?type=tcp&security=reality&encryption=none"
|
||||
"&flow=xtls-rprx-vision&sni=front.example&fp=chrome&pbk={}&sid={}#Synthetic"
|
||||
).format(UUID, PBK, SID)
|
||||
READY = "остановка: Ctrl+C или proxy-client stop"
|
||||
READY = "Управляемый Xray работает на"
|
||||
|
||||
# Поддельный Xray — симлинк на интерпретатор Python: тогда /proc/PID/exe
|
||||
# совпадает с разрешённым путём к xray, как у настоящего бинарника.
|
||||
@@ -102,6 +102,47 @@ class ManagedXrayTest(unittest.TestCase):
|
||||
self.write_machine_config()
|
||||
self.profile = self.write_profile(self.config_dir / "default.url")
|
||||
|
||||
def test_profiles_run_independently_and_export_selected_environment(self):
|
||||
first = self.start()
|
||||
named = self.config_dir / "profiles/second"
|
||||
named.mkdir(parents=True)
|
||||
second_port = free_port()
|
||||
(named / "config").write_text(
|
||||
(self.config_dir / "config").read_text().replace(str(self.port), str(second_port)))
|
||||
# Переопределение -f должно работать без default.url у второго профиля.
|
||||
second = self.start("-f", str(self.profile), cli_prefix=["--profile", "second", "start"])
|
||||
self.assertIn("proxy-client --profile second stop", self.start_output)
|
||||
status = self.run_cli("--profile", "second", "status")
|
||||
self.assertEqual(status.returncode, 0, status.stderr)
|
||||
env = self.run_cli("--profile", "second", "env")
|
||||
self.assertIn("127.0.0.1:" + str(second_port), env.stdout)
|
||||
run = self.run_cli("--profile", "second", "run", "--", sys.executable,
|
||||
"-c", "import os,sys; print(os.environ['HTTP_PROXY']); sys.exit(23)")
|
||||
self.assertEqual(run.returncode, 23, run.stderr)
|
||||
self.assertIn("127.0.0.1:" + str(second_port), run.stdout)
|
||||
collision = self.run_cli("--profile", "second", "start", "-f", str(self.profile))
|
||||
self.assertEqual(collision.returncode, 1)
|
||||
stopped = self.run_cli("--profile", "second", "stop")
|
||||
self.assertEqual(stopped.returncode, 0, stopped.stderr)
|
||||
second.communicate(timeout=10)
|
||||
self.assertIsNone(first.poll())
|
||||
self.assertEqual(self.run_cli("--profile", "default", "status").returncode, 0)
|
||||
self.assertEqual(self.run_cli("stop").returncode, 0)
|
||||
first.communicate(timeout=10)
|
||||
|
||||
def test_service_run_uses_explicit_paths_and_pinned_binary(self):
|
||||
runtime = self.root / "service-runtime"
|
||||
process = self.start(cli_prefix=[
|
||||
"service", "run", "--config-dir", str(self.config_dir),
|
||||
"--runtime-dir", str(runtime), "--xray", str(self.xray),
|
||||
], PATH="/usr/bin:/bin")
|
||||
self.assertTrue((runtime / "state.json").exists())
|
||||
self.assertFalse(self.state_dir.exists())
|
||||
process.terminate()
|
||||
process.communicate(timeout=10)
|
||||
self.assertEqual(process.returncode, 0)
|
||||
self.assertFalse((runtime / "client.json").exists())
|
||||
|
||||
def write_machine_config(self, address="127.0.0.1"):
|
||||
self.config_dir.mkdir(parents=True, exist_ok=True)
|
||||
(self.config_dir / "config").write_text(
|
||||
@@ -126,10 +167,10 @@ class ManagedXrayTest(unittest.TestCase):
|
||||
check=False,
|
||||
)
|
||||
|
||||
def start(self, *arguments, **environment):
|
||||
def start(self, *arguments, cli_prefix=None, **environment):
|
||||
"""Запускает start и ждёт строку готовности; возвращает процесс."""
|
||||
process = subprocess.Popen(
|
||||
[str(CLI), "start"] + list(arguments),
|
||||
[str(CLI)] + (cli_prefix or ["start"]) + list(arguments),
|
||||
cwd=str(self.root),
|
||||
env=dict(self.environment, **environment),
|
||||
text=True,
|
||||
|
||||
Reference in new issue
Block a user