🔥 Sync 2026-09-05 21:18:46

luci-app-agentflow/Makefile

@@ -8,7 +8,7 @@ include $(TOPDIR)/rules.mk
 
 LUCI_TITLE:=AgentFlow
 PKG_VERSION:=1.0.0
-PKG_RELEASE:=3
+PKG_RELEASE:=4
 LUCI_DEPENDS:=+agentflow +luci-compat
 LUCI_MINIFY_CSS:=0
 LUCI_MINIFY_JS:=0

luci-app-agentflow/luasrc/controller/agentflow.lua

@@ -2,28 +2,128 @@ local http = require "luci.http"
 
 module("luci.controller.agentflow", package.seeall)
 
+local APPS_PROXY_PREFIX = "/apps=http://127.0.0.1:19290"
+local DEFAULT_BASE_PATH = "/apps/agentflow/"
+local DEFAULT_PORT = 9000
+
 function index()
+	entry({"admin", "services", "agentflow_status"}, call("agentflow_status"))
+	local open = entry({"admin", "services", "agentflow", "open"}, call("agentflow_open"))
+	open.leaf = true
+	open.dependent = false
+	open.sysauth = false
+
 	if not nixio.fs.access("/etc/config/agentflow") then
 		return
 	end
 
 	local page = entry({"admin", "services", "agentflow"}, cbi("agentflow"), _("AgentFlow"), 100)
 	page.dependent = true
-	entry({"admin", "services", "agentflow_status"}, call("agentflow_status"))
+end
+
+local function uhttpd_has_apps_proxy_prefix()
+	local uci = require "luci.model.uci".cursor()
+	local mappings = uci:get_list("uhttpd", "main", "proxy_prefix") or {}
+
+	for _, mapping in ipairs(mappings) do
+		if mapping == APPS_PROXY_PREFIX then
+			return true
+		end
+	end
+	return false
+end
+
+local function uhttpd_supports_proxy_prefix()
+	local sys = require "luci.sys"
+	return sys.call("grep -qr 'proxy_prefix' /etc/init.d/uhttpd /lib/functions /usr/share/uhttpd 2>/dev/null") == 0
+end
+
+local function uhttpd_apps_proxy_available()
+	return uhttpd_supports_proxy_prefix() and uhttpd_has_apps_proxy_prefix()
+end
+
+local function linkeasefull_running()
+	local sys = require "luci.sys"
+	return sys.call("[ -x /etc/init.d/linkeasefull ] && /etc/init.d/linkeasefull running >/dev/null 2>&1") == 0
+end
+
+local function normalized_base_path(path)
+	path = path or DEFAULT_BASE_PATH
+	if path:sub(1, 1) ~= "/" then
+		path = "/" .. path
+	end
+	if path:sub(-1) ~= "/" then
+		path = path .. "/"
+	end
+	return path
+end
+
+local function authority_host(authority)
+	if not authority or authority == "" then
+		return ""
+	end
+	if authority:sub(1, 1) == "[" then
+		return authority:match("^%[([^%]]+)%]") or ""
+	end
+	return authority:match("^([^:]+)") or authority
+end
+
+local function url_authority(host, port)
+	if not host or host == "" then
+		host = "127.0.0.1"
+	end
+	if host:find(":") and host:sub(1, 1) ~= "[" then
+		host = "[" .. host .. "]"
+	end
+	return host .. ":" .. tostring(port)
+end
+
+local function request_or_lan_host()
+	local uci = require "luci.model.uci".cursor()
+	local host = authority_host(http.getenv("HTTP_HOST") or "")
+	if host ~= "" then
+		return host
+	end
+	return uci:get("network", "lan", "ipaddr") or "127.0.0.1"
+end
+
+local function agentflow_config()
+	local uci = require "luci.model.uci".cursor()
+	local port = tonumber(uci:get_first("agentflow", "agentflow", "port")) or DEFAULT_PORT
+	if port < 1 or port > 65535 then
+		port = DEFAULT_PORT
+	end
+	local base_path = normalized_base_path(uci:get_first("agentflow", "agentflow", "base_path"))
+	return port, base_path
+end
+
+local function agentflow_entry_url()
+	local port, base_path = agentflow_config()
+	if linkeasefull_running() and uhttpd_apps_proxy_available() then
+		return base_path
+	end
+	return "http://" .. url_authority(request_or_lan_host(), port) .. base_path
 end
 
 function agentflow_status()
 	local sys = require "luci.sys"
-	local uci = require "luci.model.uci".cursor()
-	local port = tonumber(uci:get_first("agentflow", "agentflow", "port")) or 9000
-	if port < 1 or port > 65535 then
-		port = 9000
-	end
+	local port, base_path = agentflow_config()
+	local entry_url = agentflow_entry_url()
 
 	local status = {
 		running = (sys.call("pidof agentflow >/dev/null") == 0),
-		port = port
+		port = port,
+		base_path = base_path,
+		entry_url = entry_url,
+		proxy_prefix_supported = uhttpd_supports_proxy_prefix(),
+		proxy_prefix_enabled = uhttpd_apps_proxy_available(),
+		linkeasefull_running = linkeasefull_running()
 	}
 	http.prepare_content("application/json")
 	http.write_json(status)
 end
+
+function agentflow_open()
+	local entry_url = agentflow_entry_url()
+	http.redirect(entry_url)
+end

luci-app-agentflow/luasrc/view/agentflow/status.htm

@@ -1,12 +1,20 @@
 <script type="text/javascript">//<![CDATA[
+var agentflowOpenUrl = '<%=url("admin/services/agentflow/open")%>';
 XHR.poll(5, '<%=url("admin/services/agentflow_status")%>', null, function(x, st) {
 	var el = document.getElementById('agentflow_status');
 	if (st && el) {
 		if (!st.running) {
 			el.innerHTML = '<br/><em style="color:red"><%:The AgentFlow service is not running.%></em>';
 		} else {
+			var accessMode = '';
+			if (st.proxy_prefix_enabled && st.linkeasefull_running) {
+				accessMode = '<br/><em><%:Access mode: LinkEase Desktop /apps proxy.%></em>';
+			} else {
+				accessMode = '<br/><em><%:Access mode: external port.%></em>';
+			}
 			el.innerHTML = '<br/><em style="color:green"><%:The AgentFlow service is running.%></em>'
-				+ "<br/><br/><input class=\"btn cbi-button cbi-button-apply\" type=\"button\" value=\" <%:Click to open AgentFlow%> \" onclick=\"window.open('http://" + window.location.hostname + ":" + st.port + "/')\"/>";
+				+ accessMode
+				+ "<br/><br/><input class=\"btn cbi-button cbi-button-apply\" type=\"button\" value=\" <%:Click to open AgentFlow%> \" onclick=\"window.open('" + agentflowOpenUrl + "')\"/>";
 		}
 	}
 });

luci-app-agentflow/po/zh-cn/agentflow.po

@@ -10,6 +10,12 @@ msgstr "AgentFlow 提供用于编排编码智能体和工作流的 Web 管理界
 msgid "Click to open AgentFlow"
 msgstr "点击打开 AgentFlow"
 
+msgid "Access mode: LinkEase Desktop /apps proxy."
+msgstr "访问模式：LinkEase Desktop /apps 代理。"
+
+msgid "Access mode: external port."
+msgstr "访问模式：外部端口。"
+
 msgid "Collecting data..."
 msgstr "正在获取数据……"
 

luci-app-agentflow/tests/test_agentflow_luci_open_contract.py

@@ -0,0 +1,32 @@
+from pathlib import Path
+import unittest
+
+
+APP_DIR = Path(__file__).resolve().parents[1]
+
+
+class AgentFlowLuciOpenContractTest(unittest.TestCase):
+    def read(self, relative):
+        return (APP_DIR / relative).read_text(encoding="utf-8")
+
+    def test_luci_open_matches_linkease_proxy_pattern(self):
+        makefile = self.read("Makefile")
+        controller = self.read("luasrc/controller/agentflow.lua")
+        status = self.read("luasrc/view/agentflow/status.htm")
+
+        self.assertNotIn("+luci-lib-linkeaseauth", makefile)
+        self.assertIn('entry({"admin", "services", "agentflow", "open"}', controller)
+        self.assertIn("open.sysauth = false", controller)
+        self.assertIn("function agentflow_open()", controller)
+        self.assertIn("uhttpd_apps_proxy_available()", controller)
+        self.assertIn("linkeasefull_running()", controller)
+        self.assertIn("return base_path", controller)
+        self.assertIn("url_authority(request_or_lan_host(), port)", controller)
+        self.assertIn("http.redirect(entry_url)", controller)
+        self.assertNotIn('linkease_auth_url("auth")', controller)
+        self.assertIn('url("admin/services/agentflow/open")', status)
+        self.assertNotIn('window.location.hostname + ":" + st.port', status)
+
+
+if __name__ == "__main__":
+    unittest.main()