dynapoint: add new package (fixes #3304)

Dynapoint is a dynamic access point manager

Signed-off-by: Tobias Ilte <tobias.ilte@campus.tu-berlin.de>
Acked-by: Thomas Huehn <thomas.huehn@evernet-eg.de>

- minor whitespace fixes/cleanups
- squashed multiple commits into a single one before merge

Signed-off-by: Michael Heimpold <mhei@heimpold.de>

net/dynapoint/Makefile

@@ -0,0 +1,47 @@
+#
+# Copyright (C) 2016 Tobias Ilte <tobias.ilte@campus.tu-berlin.de>
+#
+# This is free software, licensed under the GNU General Public License v2.
+# See /LICENSE for more information.
+#
+
+include $(TOPDIR)/rules.mk
+
+PKG_NAME:=dynapoint
+PKG_RELEASE:=1
+
+PKG_MAINTAINER:=Tobias Ilte <tobias.ilte@campus.tu-berlin.de>
+PKG_LICENSE:=GPL-3.0+
+
+include $(INCLUDE_DIR)/package.mk
+
+define Package/$(PKG_NAME)
+    SECTION:=net
+    CATEGORY:=Network
+    SUBMENU:=wireless
+    DEPENDS:=+lua +libubus-lua +libuci-lua +libubox-lua +luci-lib-nixio
+    TITLE:=Dynamic access point manager
+endef
+
+define Package/$(PKG_NAME)/description
+  Dynapoint uses LUA scripts to allow dynamic access point creation
+  and deletion depending on changes of certain network conditions.
+endef
+
+define Package/$(PKG_NAME)/conffiles
+/etc/config/dynapoint
+endef
+
+define Build/Compile
+endef
+
+define Package/$(PKG_NAME)/install
+	$(INSTALL_DIR) $(1)/usr/sbin
+	$(INSTALL_BIN) ./src/dynapoint.lua $(1)/usr/sbin/
+	$(INSTALL_DIR) $(1)/etc/init.d
+	$(INSTALL_BIN) ./src/dynapoint.init $(1)/etc/init.d/dynapoint
+	$(INSTALL_DIR) $(1)/etc/config
+	$(INSTALL_DATA) ./src/dynapoint.config $(1)/etc/config/dynapoint
+endef
+
+$(eval $(call BuildPackage,$(PKG_NAME)))

net/dynapoint/src/dynapoint.config

@@ -0,0 +1,9 @@
+config rule 'internet'
+	list hosts 'http://www.example.com'
+	list hosts 'http://www.google.com'
+	option interval '60'
+	option timeout '5'
+	option offline_threshold '3'
+	option add_hostname_to_ssid '0'
+	option use_curl '0'
+	option curl_interface 'eth0'

net/dynapoint/src/dynapoint.init

@@ -0,0 +1,15 @@
+#!/bin/sh /etc/rc.common
+
+START=99
+
+USE_PROCD=1
+PROG=/usr/sbin/dynapoint.lua
+CONFFILE=/etc/config/dynapoint
+
+start_service() {
+	procd_open_instance
+	procd_set_param command $PROG
+	procd_set_param file $CONFFILE
+	procd_set_param respawn
+	procd_close_instance
+}

net/dynapoint/src/dynapoint.lua

@@ -0,0 +1,203 @@
+#!/usr/bin/lua
+
+--[[
+
+Copyright (C) 2016 Tobias Ilte <tobias.ilte@campus.tu-berlin.de>
+
+This program is free software: you can redistribute it and/or modify
+it under the terms of the GNU General Public License as published by
+the Free Software Foundation, either version 3 of the License, or
+(at your option) any later version.
+
+This program is distributed in the hope that it will be useful,
+but WITHOUT ANY WARRANTY; without even the implied warranty of
+MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+GNU General Public License for more details.
+
+You should have received a copy of the GNU General Public License
+along with this program.  If not, see <http://www.gnu.org/licenses/>.
+
+--]]
+
+
+require "uci"
+require "ubus"
+require "uloop"
+log = require "nixio"
+
+--open sys-logging
+log.openlog("DynaPoint", "ndelay", "cons", "nowait");
+
+local uci_cursor = uci.cursor()
+
+-- get all config sections with the given type
+function getConfType(conf_file,type)
+  local ifce={}
+  uci_cursor:foreach(conf_file,type,function(s) ifce[s[".index"]]=s end)
+  return ifce
+end
+
+ubus = ubus.connect()
+if not ubus then
+  error("Failed to connect to ubusd")
+end
+ubus:call("network", "reload", {})
+
+local interval = uci_cursor:get("dynapoint", "internet", "interval")
+local timeout = uci_cursor:get("dynapoint", "internet", "timeout")
+local offline_threshold = tonumber(uci_cursor:get("dynapoint", "internet", "offline_threshold"))
+local hosts = uci_cursor:get("dynapoint", "internet", "hosts")
+local numhosts = #hosts
+local curl = tonumber(uci_cursor:get("dynapoint", "internet", "use_curl"))
+if (curl == 1) then
+  curl_interface = uci_cursor:get("dynapoint", "internet", "curl_interface")
+end
+if (tonumber(uci_cursor:get("dynapoint", "internet", "add_hostname_to_ssid")) == 1 ) then
+  localhostname = uci_cursor:get("system", "system", "hostname")
+end
+
+local table_names_rule = {}
+local table_names_not_rule = {}
+local ssids_with_hostname = {}
+local ssids_not_rule = {}
+
+function get_dynapoint_sections(t)
+  for pos,val in pairs(t) do
+    if (type(val)=="table") then
+      get_dynapoint_sections(val);
+    elseif (type(val)=="string") then
+      if (pos == "dynapoint_rule") then
+        if (val == "internet") then
+          table_names_rule[#table_names_rule+1] = t[".name"]
+        elseif (val == "!internet") then
+          table_names_not_rule[#table_names_not_rule+1] = t[".name"]
+          if (localhostname) then
+            ssids_not_rule[#ssids_not_rule+1] = t[".ssid"]
+            ssids_with_hostname[#ssids_with_hostname+1] = t[".ssid"].."_"..localhostname
+          end
+        end
+      end
+    end
+  end
+end
+
+
+--print(table.getn(hosts))
+
+get_dynapoint_sections(getConfType("wireless","wifi-iface"))
+
+-- revert all non-persistent ssid uci-changes regarding sections affecting dynapoint
+for i = 1, #table_names_not_rule do
+  uci_cursor:revert("wireless", table_names_not_rule[i], "ssid")
+end
+
+
+local online = true
+
+if (#table_names_rule > 0) then
+  if (tonumber(uci_cursor:get("wireless", table_names_rule[1], "disabled")) == 1) then
+    online = false
+  end
+else
+  log.syslog("info","Not properly configured. Please add <option dynapoint_rule 'internet'> to /etc/config/wireless")
+end
+
+local timer
+local offline_counter = 0
+uloop.init()
+
+function do_internet_check(host)
+  if (curl == 1 ) then
+    if (curl_interface) then
+      result = os.execute("curl -s -m "..timeout.." --max-redirs 0 --interface "..curl_interface.." --head "..host.." > /dev/null")
+    else
+      result = os.execute("curl -s -m "..timeout.." --max-redirs 0 --head "..host.." > /dev/null")
+    end
+  else
+    result = os.execute("wget -q --timeout="..timeout.." --spider "..host)
+  end
+  if (result == 0) then
+    return true
+  else
+    return false
+  end
+end
+
+function change_wireless_config(switch_to_offline)
+  if (switch_to_offline == 1) then
+    log.syslog("info","Switched to OFFLINE")
+
+    for i = 1, #table_names_not_rule do
+      uci_cursor:set("wireless",table_names_not_rule[i], "disabled", "0")
+      if (localhostname) then
+        uci_cursor:set("wireless", table_names_not_rule[i], "ssid", ssids_with_hostname[i])
+        log.syslog("info","Bring up new AP "..ssids_with_hostname[i])
+      else
+        log.syslog("info","Bring up new AP "..ssids_not_rule[i])
+      end
+    end
+
+    for i = 1, #table_names_rule do
+      uci_cursor:set("wireless",table_names_rule[i], "disabled", "1")
+    end
+
+  else
+    log.syslog("info","Switched to ONLINE")
+    for i = 1, #table_names_not_rule do
+      uci_cursor:set("wireless",table_names_not_rule[i], "disabled", "1")
+      if (localhostname) then
+        uci_cursor:set("wireless", table_names_not_rule[i], "ssid", ssids_not_rule[i])
+      end
+    end
+    for i = 1, #table_names_rule do
+      uci_cursor:set("wireless",table_names_rule[i], "disabled", "0")
+      log.syslog("info","Bring up new AP "..uci_cursor:get("wireless", table_names_rule[i], "ssid"))
+    end
+  end
+  uci_cursor:save("wireless")
+  ubus:call("network", "reload", {})
+end
+
+
+local hostindex = 1
+
+function check_internet_connection()
+  print("checking "..hosts[hostindex].."...")
+  if (do_internet_check(hosts[hostindex]) == true) then
+    -- online
+    print("...seems to be online")
+    offline_counter = 0
+    hostindex = 1
+    if (online == false) then
+      print("changed state to online")
+      online = true
+      change_wireless_config(0)
+    end
+  else
+    --offline
+    print("...seems to be offline")
+    hostindex = hostindex + 1
+    if (hostindex <= numhosts) then
+      check_internet_connection()
+    else
+      hostindex = 1
+      -- and activate offline-mode
+      print("all hosts offline")
+      if (online == true) then
+        offline_counter = offline_counter + 1
+        if (offline_counter == offline_threshold) then
+          print("changed state to offline")
+          online = false
+          change_wireless_config(1)
+        end
+      end
+    end
+  end
+  timer:set(interval * 1000)
+end
+
+timer = uloop.timer(check_internet_connection)
+timer:set(interval * 1000)
+
+uloop.run()
+