hacker07/NeoTachyon
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

fix(core): хотфиксы issues #23, #32, #39, #41

Browse Source 
- service_check: lan_interface() запрашивала несуществующий конфиг
  forkop/podkop, из-за чего все проверки сервисов смотрели в br-lan вместо
  настроенных LAN-интерфейсов - секции AWG/WireGuard всегда получали вердикт
  "не отвечает" при рабочем kernel-конфиге (#41, #32, #39)
- rag: у push() были перепутаны аргументы - коллекция эмбеддингов оставалась
  пустой для всех провайдеров OpenAI-формата; кэш эмбеддингов теперь
  инвалидируется по отпечатку индекса (mtime+size), null model_override
  обрабатывается корректно
- warp_generator: curl к Clash API без таймаута и матрица ретраев без общего
  дедлайна могли блокировать выполнение минутами и ловить XHR timeout LuCI
  (#39); добавлены -m 5 на локальные вызовы и бюджеты 40с/90с на весь цикл
- build.sh: релизные пакеты теперь содержат тот же состав файлов, что и
  сборка через OpenWrt Makefile (hotplug WAN-монитор, агентский CGI в
  /usr/lib/cgi-bin, defaults/config, профили servicecheck); конфиги с
  секретами ставятся с правами 0600; тест паритета инвентаря
- updates UI: после самообновления tachyon страница перезагружается только
  когда перезапущенный бэкенд снова отвечает на get_ui_state, вместо
  фиксированной задержки 8 секунд (#23)
This commit is contained in:
Dushnilin
2026-08-21 19:19:17 +03:00
parent 432fa31337
commit 8996790f25
6 changed files with 134 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tachyon/files/usr/lib/service/warp_generator.uc
+29 -3
View File
@@ -79,6 +79,13 @@ function exec_output(command) {
return data == null ? "" : trim(data);
}
function now_ms() {
let c = clock();
if (type(c) != "array" || length(c) < 2)
return 0;
return c[0] * 1000 + int(c[1] / 1000000);
}
function contains(arr, val) {
for (let x in arr) {
if (x == val) return true;
@@ -89,6 +96,10 @@ function contains(arr, val) {
function call_api(method, url, auth_header, body_file) {
let resolve_ips = [ "162.159.192.1", "162.159.193.1", "188.114.98.1", "188.114.99.1" ];
let last_res = "";
// Hard wall-clock budget: without it the full retry matrix (transports x
// resolve IPs x fallbacks) can block for minutes and trip the LuCI XHR
// timeout before any answer is produced.
let deadline = now_ms() + 40000;
let transport_flags = [];
if (proxy_interface != "") {
@@ -105,8 +116,10 @@ function call_api(method, url, auth_header, body_file) {
// 1. Try selected tunnel transport(s)
for (let tr in transport_flags) {
if (now_ms() > deadline) break;
// A. With --resolve to Cloudflare IPs
for (let ip in resolve_ips) {
if (now_ms() > deadline) break;
let auth_str = auth_header != "" ? "-H 'Authorization: Bearer " + auth_header + "' " : "";
let data_str = body_file != "" ? "-d @" + body_file + " " : "";
let cmd = "curl -s --connect-timeout 3 --max-time 7 " + tr + " --resolve api.cloudflareclient.com:443:" + ip + " -X " + method + " -H 'Content-Type: application/json' -H 'User-Agent: okhttp/3.12.1' " + auth_str + data_str + url;
@@ -121,6 +134,7 @@ function call_api(method, url, auth_header, body_file) {
}
}
}
if (now_ms() > deadline) break;
// B. Directly via DNS on tunnel
let auth_str = auth_header != "" ? "-H 'Authorization: Bearer " + auth_header + "' " : "";
let data_str = body_file != "" ? "-d @" + body_file + " " : "";
@@ -137,8 +151,13 @@ function call_api(method, url, auth_header, body_file) {
}
}
if (now_ms() > deadline) {
return last_res != "" ? { success: false, message: last_res } : null;
}
// 2. Direct WAN fallback if no tunnel transport worked
for (let ip in resolve_ips) {
if (now_ms() > deadline) break;
let auth_str = auth_header != "" ? "-H 'Authorization: Bearer " + auth_header + "' " : "";
let data_str = body_file != "" ? "-d @" + body_file + " " : "";
let cmd = "curl -s --connect-timeout 3 --max-time 6 --resolve api.cloudflareclient.com:443:" + ip + " -X " + method + " -H 'Content-Type: application/json' -H 'User-Agent: okhttp/3.12.1' " + auth_str + data_str + url;
@@ -160,7 +179,7 @@ function call_api(method, url, auth_header, body_file) {
// Query current proxy selection from Clash API for automatic rate limit rotation if proxy is used
let original_server = "";
let available_servers = [];
let clash_data_str = exec_output("curl -s " + get_clash_base_url() + "/proxies/MAIN-out");
let clash_data_str = exec_output("curl -s -m 5 " + get_clash_base_url() + "/proxies/MAIN-out");
if (clash_data_str != "") {
try {
let parsed = json(clash_data_str);
@@ -177,7 +196,7 @@ function restore_original_server() {
let body = { name: original_server };
let tmp_file = "/tmp/restore_clash.json";
fs.writefile(tmp_file, sprintf("%J", body));
exec_output("curl -s -X PUT -H 'Content-Type: application/json' -d @" + tmp_file + " " + get_clash_base_url() + "/proxies/MAIN-out");
exec_output("curl -s -m 5 -X PUT -H 'Content-Type: application/json' -d @" + tmp_file + " " + get_clash_base_url() + "/proxies/MAIN-out");
fs.unlink(tmp_file);
}
}
@@ -186,7 +205,7 @@ function switch_server(srv_name) {
let body = { name: srv_name };
let tmp_file = "/tmp/switch_clash.json";
fs.writefile(tmp_file, sprintf("%J", body));
exec_output("curl -s -X PUT -H 'Content-Type: application/json' -d @" + tmp_file + " " + get_clash_base_url() + "/proxies/MAIN-out");
exec_output("curl -s -m 5 -X PUT -H 'Content-Type: application/json' -d @" + tmp_file + " " + get_clash_base_url() + "/proxies/MAIN-out");
fs.unlink(tmp_file);
exec_output("sleep 1");
}
@@ -257,8 +276,15 @@ let response_data = null;
let last_error = "";
let chosen_prefix = "";
let server_try_index = 0;
// Overall budget for the whole registration attempt matrix: each call_api()
// is bounded, but the prefix list is long enough to multiply into minutes.
let registration_deadline = now_ms() + 90000;
for (let prefix in api_prefixes) {
if (now_ms() > registration_deadline) {
last_error = "Registration aborted: overall time budget exceeded";
break;
}
let url = "https://api.cloudflareclient.com/" + prefix + "/reg";
let parsed = call_api("POST", url, "", tmp_req_file);