Added new package

etc/rc.d/ocsense.lua

@@ -0,0 +1,125 @@
+local event = require("event")
+local minitel = require("minitel")
+
+local function loadConf()
+  local f = io.open("/etc/ocsense.conf", "r")
+  if not f then
+    return {
+      name = "home",
+      port = 5353,
+      parent = "net",
+      children = {},
+      local_domain = "home",
+    }
+  end
+  local text = f:read("*a")
+  f:close()
+  local ok, t = pcall(load("return " .. text))
+  if ok and type(t) == "table" then
+    if not t.port then t.port = 5353 end
+    if not t.children then t.children = {} end
+    return t
+  end
+  return {
+    name = "home1",
+    port = 5353,
+    parent = "net",
+    children = {},
+    local_domain = "home",
+  }
+end
+
+local cfg = loadConf()
+local PORT = cfg.port
+local records = {}
+local running = true
+
+local local_suffixes = {}
+if cfg.local_domain and cfg.local_domain ~= "" then
+  table.insert(local_suffixes, cfg.local_domain)
+  if cfg.parent and cfg.parent ~= "" then
+    table.insert(local_suffixes, cfg.local_domain .. "." .. cfg.parent)
+  end
+end
+
+print(string.format("[ocsense] %s läuft auf port %d", cfg.name, cfg.port))
+if cfg.parent then
+  print("[ocsense] parent:", cfg.parent)
+end
+if #cfg.children > 0 then
+  print("[ocsense] children:", table.concat(cfg.children, ", "))
+end
+print("[ocsense] lokale suffixe:", table.concat(local_suffixes, ", "))
+print("[ocsense] Strg+C zum Beenden")
+
+local function endsWith(str, suffix)
+  return suffix ~= "" and str:sub(-#suffix) == suffix
+end
+
+local function stripLocalSuffixes(name)
+  for _, suf in ipairs(local_suffixes) do
+    if endsWith(name, suf) then
+      local cut = #name - #suf
+      if name:sub(cut, cut) == "." then
+        return name:sub(1, cut - 1)
+      else
+        return name:sub(1, cut)
+      end
+    end
+  end
+  return name
+end
+
+while running do
+  local ev, fromName, port, data, fromAddr = event.pull()
+  if ev == "interrupted" then
+    print("[ocsense] beendet")
+    running = false
+
+  elseif ev == "net_msg" and port == PORT and type(data) == "string" then
+    local cmd, a, b = data:match("^(%S+)%s*(%S*)%s*(%S*)")
+
+    if cmd == "REG" and a ~= "" and b ~= "" then
+      records[a] = b
+      print("[ocsense] REG", a, "=>", b)
+
+    elseif cmd == "Q" and a ~= "" then
+      local replyto = (b ~= "" and b) or fromName
+      local target  = a
+
+      local addr = records[target]
+
+      if not addr then
+        local stripped = stripLocalSuffixes(target)
+        if stripped ~= target then
+          addr = records[stripped]
+          if not addr then
+            stripped = stripLocalSuffixes(stripped)
+            addr = records[stripped]
+          end
+        end
+      end
+
+      if addr then
+        minitel.usend(replyto, PORT, "A " .. target .. " " .. addr)
+      else
+        local forwarded = false
+        for _, child in ipairs(cfg.children) do
+          if endsWith(target, child) then
+            minitel.usend(child, PORT, "Q " .. target .. " " .. replyto)
+            forwarded = true
+            break
+          end
+        end
+
+        if not forwarded then
+          if cfg.parent and cfg.parent ~= "" then
+            minitel.usend(cfg.parent, PORT, "Q " .. target .. " " .. replyto)
+          else
+            minitel.usend(replyto, PORT, "NX " .. target)
+          end
+        end
+      end
+    end
+  end
+end