🗽 Sync 2026-10-23 00:46:23

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

@@ -1,3 +1,5 @@
+local http = require "luci.http"
+
 module("luci.controller.kaiplus", package.seeall)
 
 function index()
@@ -9,9 +11,36 @@ function index()
 	open.sysauth_authenticator = "htmlauth"
 
 	if not nixio.fs.access("/etc/config/kaiplus") then return end
+	local install_kai = entry({"admin", "services", "kaiplus", "install_kai"}, call("install_kai"))
+	install_kai.leaf = true
 	entry({"admin", "services", "kaiplus"}, cbi("kaiplus"), _("KaiPlus"), 100).dependent = true
 end
 
+local function write_json(obj)
+	http.prepare_content("application/json")
+	http.write_json(obj)
+end
+
+local function require_post_csrf()
+	local dispatcher = require "luci.dispatcher"
+	local context = dispatcher.context or {}
+	local expected = context.authtoken or context.token
+
+	if (http.getenv("REQUEST_METHOD") or "") ~= "POST" then
+		http.status(405, "Method Not Allowed")
+		write_json({ ok = false, error = "method not allowed" })
+		return false
+	end
+
+	if not context.authsession or not expected or http.formvalue("token") ~= expected then
+		http.status(403, "Forbidden")
+		write_json({ ok = false, error = "invalid csrf token" })
+		return false
+	end
+
+	return true
+end
+
 local function compat()
 	local dispatcher = require "luci.dispatcher"
 	return require("luci.model.linkease.apps_compat").new({
@@ -22,16 +51,19 @@ local function compat()
 end
 
 function kaiplus_status()
+	local fs = require "nixio.fs"
 	local sys = require "luci.sys"
 	local uci = require("luci.model.uci").cursor()
-	local external_port_enabled = uci:get_first("kaiplus", "kaiplus", "external_port_enabled") == "1"
 	compat():legacy_status("kaiplus", {
-		running = sys.call("pidof kaiplus_bin >/dev/null") == 0,
+		running = sys.call("pidof kaiplus >/dev/null") == 0,
+		kai_installed = not not (
+			fs.access("/usr/share/kai/kai-plugin.json")
+			and fs.access("/usr/lib/lua/luci/controller/kai.lua")
+		),
 		port = uci:get_first("kaiplus", "kaiplus", "port") or "8189",
-		base_path = uci:get_first("kaiplus", "kaiplus", "base_path") or "/apps/kaiplus/",
-		listen_mode = uci:get_first("kaiplus", "kaiplus", "listen_mode") or "auto",
-		socket_path = uci:get_first("kaiplus", "kaiplus", "socket_path") or "/var/run/kaiplus.sock",
-		external_port_enabled = external_port_enabled,
+		base_path = "/apps/kaiplus/",
+		listen_mode = "tcp",
+		external_port_enabled = true,
 		lan_ip = uci:get("network", "lan", "ipaddr") or ""
 	})
 end
@@ -39,3 +71,53 @@ end
 function kaiplus_open()
 	compat():open("kaiplus")
 end
+
+function install_kai()
+	local fs = require "nixio.fs"
+	local jsonc = require "luci.jsonc"
+	local sys = require "luci.sys"
+	local util = require "luci.util"
+	local task_id = "kaiplus-kai-install"
+
+	if not require_post_csrf() then
+		return
+	end
+
+	if fs.access("/usr/share/kai/kai-plugin.json")
+		and fs.access("/usr/lib/lua/luci/controller/kai.lua") then
+		write_json({ ok = true, installed = true })
+		return
+	end
+	if not fs.access("/etc/init.d/tasks") then
+		write_json({ ok = false, error = "taskd is not available" })
+		return
+	end
+	if not fs.access("/bin/is-opkg") then
+		write_json({ ok = false, error = "iStore package installer is not available" })
+		return
+	end
+
+	local task_status = sys.exec("/etc/init.d/tasks task_status " .. task_id .. " 2>/dev/null")
+	local status = jsonc.parse(task_status) or {}
+	local running = type(status) == "table" and status.running
+	if running == true or running == 1 or running == "1" or running == "true" then
+		write_json({ ok = true, busy = true, task_id = task_id })
+		return
+	end
+
+	local install_script = table.concat({
+		'set -e',
+		'echo "[KaiPlus] Installing classic KAI..."',
+		'/bin/is-opkg install luci-app-kai',
+		'rm -f /tmp/luci-indexcache',
+		'echo "[KaiPlus] Classic KAI installed successfully."'
+	}, "\n")
+	local command = "/bin/sh -c " .. util.shellquote(install_script)
+	local rc = sys.call("/etc/init.d/tasks task_add " .. task_id .. " " .. util.shellquote(command) .. " >/dev/null 2>&1")
+	if rc ~= 0 then
+		write_json({ ok = false, error = "failed to start KAI installation", task_id = task_id })
+		return
+	end
+
+	write_json({ ok = true, task_id = task_id })
+end