mirror of
https://github.com/caiwx86/small-packages.git
synced 2026-11-08 05:04:46 +08:00
269 lines
9.5 KiB
Lua
269 lines
9.5 KiB
Lua
local m, s, data = ...
|
|
|
|
if not data.node or not data.node[".name"] then
|
|
return
|
|
end
|
|
|
|
local api = m.api
|
|
local section_id = s.section
|
|
local current_node = data.node
|
|
local current_node_id = current_node[".name"]
|
|
local verify_option = data.verify_option
|
|
local node_list = data.node_list or api.get_node_list()
|
|
local shunt_section_type = "shunt_option_list"
|
|
|
|
if data.tab then
|
|
if #s.tab_names > 0 then
|
|
table.insert(s.tab_names, 2, data.tab)
|
|
s.tabs[data.tab] = {
|
|
title = data.tab_desc,
|
|
childs = { }
|
|
}
|
|
else
|
|
s:tab(data.tab, data.tab_desc)
|
|
end
|
|
end
|
|
|
|
local groups = {}
|
|
m:foreach("shunt_rules", function(s)
|
|
if s.group and s.group ~= "" then
|
|
groups[s.group] = true
|
|
end
|
|
end)
|
|
|
|
local node_save_before = luci.http.formvalue("node_save_before")
|
|
local load_shunt = luci.http.formvalue("load_shunt")
|
|
|
|
local function get_cfgvalue()
|
|
return function(self, section)
|
|
return m:get(current_node_id, self.option)
|
|
end
|
|
end
|
|
local function get_write()
|
|
return function(self, section, value)
|
|
if node_save_before and node_save_before ~= current_node_id then return end
|
|
if load_shunt == "1" then return end
|
|
if verify_option then
|
|
if verify_option:formvalue(section) == current_node_id then
|
|
m:set(current_node_id, self.option, value)
|
|
end
|
|
else
|
|
m:set(current_node_id, self.option, value)
|
|
end
|
|
end
|
|
end
|
|
local function get_remove()
|
|
return function(self, section)
|
|
if node_save_before and node_save_before ~= current_node_id then return end
|
|
if load_shunt == "1" then return end
|
|
if verify_option then
|
|
if verify_option:formvalue(section) == current_node_id then
|
|
m:del(current_node_id, self.option)
|
|
end
|
|
else
|
|
m:del(current_node_id, self.option)
|
|
end
|
|
end
|
|
end
|
|
|
|
local function add_option(class, option_name, option_title, option_desc)
|
|
local a
|
|
if data.tab then
|
|
a = s:taboption(data.tab, class, option_name, option_title)
|
|
else
|
|
a = s:option(class, option_name, option_title)
|
|
end
|
|
if a then
|
|
if option_desc then
|
|
a.description = option_desc
|
|
end
|
|
a.cfgvalue = get_cfgvalue()
|
|
a.write = get_write()
|
|
a.remove = get_remove()
|
|
end
|
|
if verify_option then
|
|
a:depends(verify_option.option, current_node_id)
|
|
end
|
|
return a
|
|
end
|
|
|
|
local function add_depends(o, deps)
|
|
if #o.deps > 0 then
|
|
for index, value in ipairs(o.deps) do
|
|
for k, v in pairs(deps) do
|
|
o.deps[index][k] = v
|
|
end
|
|
end
|
|
else
|
|
o:depends(deps)
|
|
end
|
|
end
|
|
|
|
if current_node.type == "Xray" then
|
|
o = add_option(ListValue, "domainStrategy", translate("Domain Strategy"))
|
|
o:value("AsIs")
|
|
o:value("IPIfNonMatch")
|
|
o:value("IPOnDemand")
|
|
o.default = "IPOnDemand"
|
|
o.description = "<br /><ul><li>" .. translate("'AsIs': Only use domain for routing. Default value.")
|
|
.. "</li><li>" .. translate("'IPIfNonMatch': When no rule matches current domain, resolves it into IP addresses (A or AAAA records) and try all rules again.")
|
|
.. "</li><li>" .. translate("'IPOnDemand': As long as there is a IP-based rule, resolves the domain into IP immediately.")
|
|
.. "</li></ul>"
|
|
|
|
o = add_option(ListValue, "domainMatcher", translate("Domain matcher"))
|
|
o:value("hybrid")
|
|
o:value("linear")
|
|
end
|
|
|
|
o = add_option(Flag, "fakedns", '<a style="color:#FF8C00">FakeDNS</a>' .. " " .. translate("Main switch"), translate("Use FakeDNS work in the domain that proxy.") .. "<br>" ..
|
|
translate("Suitable scenarios for let the node servers get the target domain names.") .. "<br>" ..
|
|
translate("Such as: DNS unlocking of streaming media, reducing DNS query latency, etc."))
|
|
|
|
o = add_option(Flag, "write_ipset_direct", translate("Direct DNS result write to IPSet"), translate("Perform the matching direct domain name rules into IP to IPSet/NFTSet, and then connect directly (not entering the core).") .. " " .. translate("Maybe conflict with some special circumstances."))
|
|
o.default = 1
|
|
o.rmempty = false
|
|
|
|
if api.is_finded("geoview") then
|
|
o = add_option(Flag, "enable_geoview_ip", translate("Enable GeoIP Data Parsing"))
|
|
o.default = 1
|
|
o.rmempty = false
|
|
o.description = "<ul>"
|
|
.. "<li>" .. translate("Analyzes and preloads GeoIP data to enhance the shunt performance.") .. "</li>"
|
|
.. "<li>" .. translate("Note: Increases resource usage.") .. " " .. translate("Maybe conflict with some special circumstances.") .. "</li>"
|
|
.. "</ul>"
|
|
-- The preloaded NFTSet/IPSet are kept across restarts, so they must be
|
|
-- flushed when this option changes, otherwise stale GeoIP entries stay.
|
|
local write = o.write
|
|
o.write = function(self, section, value)
|
|
local old = m:get(current_node_id, self.option) or "0"
|
|
write(self, section, value)
|
|
if (m:get(current_node_id, self.option) or "0") ~= old then
|
|
m:set("@global[0]", "flush_set", "1")
|
|
end
|
|
end
|
|
end
|
|
|
|
shunt_group = add_option(ListValue, "shunt_group", translate("Shunt Rule Group"))
|
|
shunt_group:value("", translate("default"))
|
|
for k, v in pairs(groups) do
|
|
shunt_group:value(k)
|
|
end
|
|
|
|
local shunt_group_val = m:get(current_node_id, "shunt_group") or ""
|
|
shunt_group_val = shunt_group_val:lower()
|
|
local shunt_rules = {}
|
|
m:foreach("shunt_rules", function(e)
|
|
local group = e.group or ""
|
|
group = group:lower()
|
|
if group == shunt_group_val then
|
|
e.id = e[".name"]
|
|
e.remarks = e.remarks or e[".name"]
|
|
e["_node_option"] = e[".name"]
|
|
e["_node_default"] = ""
|
|
e["_fakedns_option"] = e[".name"] .. "_fakedns"
|
|
e["_proxy_tag_option"] = e[".name"] .. "_proxy_tag"
|
|
table.insert(shunt_rules, e)
|
|
end
|
|
end)
|
|
table.insert(shunt_rules, {
|
|
id = ".default",
|
|
remarks = translate("Default"),
|
|
_node_option = "default_node",
|
|
_node_default = "_direct",
|
|
_fakedns_option = "default_fakedns",
|
|
_proxy_tag_option = "default_proxy_tag",
|
|
})
|
|
|
|
s2 = m:section(Table, shunt_rules, " ")
|
|
s2.config = m.config
|
|
s2.sectiontype = shunt_section_type
|
|
|
|
o = s2:option(DummyValue, "remarks", translate("Rule"))
|
|
o.rawhtml = true
|
|
o.cfgvalue = function(self, section)
|
|
if shunt_rules[section].id == ".default" then
|
|
return string.format('<font style="color: red">%s</font>', shunt_rules[section].remarks)
|
|
else
|
|
return string.format('<a href="%s" target="_blank">%s</a>', api.url("shunt_rules", shunt_rules[section].id), shunt_rules[section].remarks)
|
|
end
|
|
end
|
|
|
|
_node = s2:option(Value, "_node", translate("Node"))
|
|
_node.template = m:template_path("/cbi/nodes_listvalue")
|
|
_node.group = {"","","",""}
|
|
_node:value("", translate("Close (Not use)"))
|
|
_node:value("_default", translate("Use default node"))
|
|
_node:value("_direct", translate("Direct Connection"))
|
|
_node:value("_blackhole", translate("Blackhole (Block)"))
|
|
_node.cfgvalue = function(self, section)
|
|
return m:get(current_node_id, shunt_rules[section]["_node_option"]) or shunt_rules[section]["_node_default"]
|
|
end
|
|
_node.write = function(self, section, value)
|
|
if node_save_before and node_save_before ~= current_node_id then return end
|
|
if load_shunt == "1" then return end
|
|
return m:set(current_node_id, shunt_rules[section]["_node_option"], value)
|
|
end
|
|
_node.remove = function(self, section)
|
|
if node_save_before and node_save_before ~= current_node_id then return end
|
|
if load_shunt == "1" then return end
|
|
return m:del(current_node_id, shunt_rules[section]["_node_option"])
|
|
end
|
|
|
|
o = s2:option(Flag, "_fakedns", string.format('<a style="color:#FF8C00" title="%s">FakeDNS</a>', translate("Use FakeDNS work in the domain that proxy.") .. "\n" ..
|
|
translate("Suitable scenarios for let the node servers get the target domain names.") .. "\n" ..
|
|
translate("Such as: DNS unlocking of streaming media, reducing DNS query latency, etc.")))
|
|
o.cfgvalue = function(self, section)
|
|
return m:get(current_node_id, shunt_rules[section]["_fakedns_option"])
|
|
end
|
|
o.write = function(self, section, value)
|
|
if node_save_before and node_save_before ~= current_node_id then return end
|
|
if load_shunt == "1" then return end
|
|
return m:set(current_node_id, shunt_rules[section]["_fakedns_option"], value)
|
|
end
|
|
o.remove = function(self, section)
|
|
if node_save_before and node_save_before ~= current_node_id then return end
|
|
if load_shunt == "1" then return end
|
|
return m:del(current_node_id, shunt_rules[section]["_fakedns_option"])
|
|
end
|
|
|
|
proxy_tag_node = s2:option(ListValue, "_proxy_tag", string.format('<a style="color:red" title="%s">%s</a>',
|
|
translate("Set the node to be used as a pre-proxy.") .. "\n" .. translate("Each rule has a separate switch that controls whether this rule uses the pre-proxy or not."),
|
|
translate("Preproxy")))
|
|
proxy_tag_node.template = m:template_path("/cbi/nodes_listvalue")
|
|
proxy_tag_node.group = {""}
|
|
proxy_tag_node:value("", translate("Close (Not use)"))
|
|
proxy_tag_node.cfgvalue = function(self, section)
|
|
return m:get(current_node_id, shunt_rules[section]["_proxy_tag_option"])
|
|
end
|
|
proxy_tag_node.write = function(self, section, value)
|
|
if node_save_before and node_save_before ~= current_node_id then return end
|
|
if load_shunt == "1" then return end
|
|
return m:set(current_node_id, shunt_rules[section]["_proxy_tag_option"], value)
|
|
end
|
|
proxy_tag_node.remove = function(self, section)
|
|
if node_save_before and node_save_before ~= current_node_id then return end
|
|
if load_shunt == "1" then return end
|
|
return m:del(current_node_id, shunt_rules[section]["_proxy_tag_option"])
|
|
end
|
|
|
|
for k1, v1 in pairs(node_list) do
|
|
if k1 ~= "shunt_list" then
|
|
for i, v in ipairs(v1) do
|
|
_node:value(v.id, v.remark)
|
|
_node.group[#_node.group+1] = (v.group and v.group ~= "") and v.group or translate("default")
|
|
|
|
proxy_tag_node:value(v.id, v.remark)
|
|
proxy_tag_node.group[#proxy_tag_node.group+1] = (v.group and v.group ~= "") and v.group or translate("default")
|
|
end
|
|
end
|
|
end
|
|
|
|
m:appendTemplate("/include/shunt_options", {
|
|
node_id = current_node_id,
|
|
section_id = section_id or current_node_id,
|
|
section_type = shunt_section_type,
|
|
tab_name = data.tab,
|
|
normal_list = api.jsonc.stringify(node_list.normal_list),
|
|
shunt_list = api.jsonc.stringify(node_list.shunt_list)
|
|
})
|