applications/luci-splash: use RETURN target for count rules
[project/luci.git] / applications / luci-splash / root / usr / sbin / luci-splash
old mode 100644 (file)
new mode 100755 (executable)
index 347bdcc..3f6356a
@@ -1,41 +1,35 @@
 #!/usr/bin/lua
 
-require("luci.http")
-require("luci.sys")
+require("luci.util")
 require("luci.model.uci")
+require("luci.sys.iptparser")
 
 -- Init state session
-luci.model.uci.set_savedir(luci.model.uci.savedir_state)
-local uci = luci.model.uci
-local cfg = uci.config
+local uci = luci.model.uci.cursor_state()
+local ipt = luci.sys.iptparser.IptParser()
 
 
 function main(argv)
        local cmd = argv[1]
        local arg = argv[2]
        
-       if cmd == "status" then
-               if not arg then
-                       os.exit(1)
-               end
-               
-               if iswhitelisted(arg) then
+       if cmd == "status" and arg then
+               if islisted("whitelist", arg) then
                        print("whitelisted")
-                       os.exit(0)
+               elseif islisted("blacklist", arg) then
+                       print("blacklisted")
+               else            
+                       local lease = haslease(arg)
+                       if lease and lease.kicked then
+                               print("kicked")
+                       elseif lease then
+                               print("lease")
+                       else
+                               print("unknown")
+                       end
                end
-               
-               if haslease(arg) then
-                       print("lease")
-                       os.exit(0)
-               end             
-               
-               print("unknown")
                os.exit(0)
-       elseif cmd == "add" then
-               if not arg then
-                       os.exit(1)
-               end
-               
+       elseif cmd == "add" and arg then
                if not haslease(arg) then
                        add_lease(arg)
                else
@@ -43,11 +37,7 @@ function main(argv)
                        os.exit(2)
                end
                os.exit(0)
-       elseif cmd == "remove" then
-               if not arg then
-                       os.exit(1)
-               end
-               
+       elseif cmd == "remove" and arg then
                remove_lease(arg)
                os.exit(0)              
        elseif cmd == "sync" then
@@ -61,81 +51,100 @@ end
 
 -- Add a lease to state and invoke add_rule
 function add_lease(mac)
-       cfg.luci_splash[""] = "lease"
-       cfg.luci_splash[""].mac = mac
-       cfg.luci_splash[""].start = os.time()
+       uci:section("luci_splash", "lease", nil, {
+               mac = mac,
+               start = os.time()
+       })
        add_rule(mac)
        
-       uci.save()
+       uci:save("luci_splash")
 end
 
 
 -- Remove a lease from state and invoke remove_rule
 function remove_lease(mac)
        mac = mac:lower()
+       remove_rule(mac)
 
-       uci.foreach("luci_splash", "lease",
-               function (section)
-                       if section.mac:lower() == mac then
-                               remove_rule(mac)
-                               uci.delete("luci_splash", section[".name"])
-                       end
-               end)
+       uci:delete_all("luci_splash", "lease",
+               function(s) return ( s.mac:lower() == mac ) end)
                
-       uci.save()
+       uci:save("luci_splash")
 end
 
 
 -- Add an iptables rule
 function add_rule(mac)
+       os.execute("iptables -I luci_splash_counter -m mac --mac-source '"..mac.."' -j RETURN")
        return os.execute("iptables -t nat -I luci_splash_leases -m mac --mac-source '"..mac.."' -j RETURN")
 end
 
 
 -- Remove an iptables rule
 function remove_rule(mac)
-       return os.execute("iptables -t nat -D luci_splash_leases -m mac --mac-source '"..mac.."' -j RETURN")
+       for _, r in ipairs(ipt:find({table="filter", chain="luci_splash_counter"})) do
+               if r.options and #r.options >= 2 and r.options[1] == "MAC" and
+                  r.options[2]:lower() == mac:lower()
+               then
+                       os.execute("iptables -D luci_splash_counter -m mac --mac-source %q -j %s"
+                               %{ mac, r.target })
+               end
+       end
+
+       for _, r in ipairs(ipt:find({table="nat", chain="luci_splash_leases"})) do
+               if r.options and #r.options >= 2 and r.options[1] == "MAC" and
+                  r.options[2]:lower() == mac:lower()
+               then
+                       os.execute("iptables -t nat -D luci_splash_leases -m mac --mac-source %q -j %s"
+                               %{ mac, r.target })
+               end
+       end
+
+       ipt:resync()
 end
 
 
 -- Check whether a MAC-Address is listed in the lease state list
 function haslease(mac)
        mac = mac:lower()
-       local stat = false
-       
-       uci.foreach("luci_splash", "lease",
+       local lease = nil
+
+       uci:foreach("luci_splash", "lease",
                function (section)
                        if section.mac:lower() == mac then
-                               stat = true
-                               return
+                               lease = section
                        end
                end)
-       
-       return stat
+
+       return lease
 end
 
 
--- Check whether a MAC-Address is whitelisted
-function iswhitelisted(mac)
+-- Check whether a MAC-Address is in given list
+function islisted(what, mac)
        mac = mac:lower()
-       
-       uci.foreach("luci_splash", "whitelist",
+
+       uci:foreach("luci_splash", what,
                function (section)
                        if section.mac:lower() == mac then
                                stat = true
                                return
                        end
                end)
-       
+
        return false
 end
 
 
 -- Returns a list of MAC-Addresses for which a rule is existing
 function listrules()
-       local cmd = "iptables -t nat -L luci_splash_leases | grep RETURN |"
-       cmd = cmd .. "egrep -io [0-9a-f]+:[0-9a-f]+:[0-9a-f]+:[0-9a-f]+:[0-9a-f]+:[0-9a-f]+"
-       return luci.util.split(luci.sys.exec(cmd))
+       local macs = { }
+       for i, r in ipairs(ipt:find({table="nat", chain="luci_splash_leases"})) do
+               if r.options and #r.options >= 2 and r.options[1] == "MAC" then
+                       macs[r.options[2]:lower()] = true
+               end
+       end
+       return luci.util.keys(macs)
 end
 
 
@@ -145,13 +154,14 @@ function sync()
        local time = os.time()
        
        -- Current leases in state files
-       local leases = uci.get_all("luci_splash")
+       local leases = uci:get_all("luci_splash")
        
        -- Convert leasetime to seconds
-       local leasetime = tonumber(cfg.luci_splash.general.leasetime) * 3600
+       local leasetime = tonumber(uci:get("luci_splash", "general", "leasetime")) * 3600
        
        -- Clean state file
-       uci.revert("luci_splash")
+       uci:load("luci_splash")
+       uci:revert("luci_splash")
        
        
        -- For all leases
@@ -162,11 +172,15 @@ function sync()
                                remove_rule(v.mac)
                        else
                                -- Rewrite state
-                               cfg.luci_splash[""] = "lease"
-                               cfg.luci_splash[""].mac = v.mac
-                               cfg.luci_splash[""].start = v.start
+                               uci:section("luci_splash", "lease", nil, {              
+                                       mac    = v.mac,
+                                       start  = v.start,
+                                       kicked = v.kicked
+                               })
                                written[v.mac:lower()] = 1
                        end
+               elseif v[".type"] == "whitelist" or v[".type"] == "blacklist" then
+                       written[v.mac:lower()] = 1
                end
        end
        
@@ -178,7 +192,7 @@ function sync()
                end
        end
        
-       uci.save("luci_splash")
+       uci:save("luci_splash")
 end
 
-main(arg)
\ No newline at end of file
+main(arg)