Программирование ODNFC на Lua

local get, sleepms = Settings.get, thread.sleepms

-- В net_dest укажите адрес и UDP-порт получателя, например:
-- 192.168.1.10:9000
local host, _, _, port = net.parseUrl(get("net_dest"))
local osc_address = "/odnfc/uid"
local wdt_on = get("sys_wdt") == "on"

local leds = indication.Leds.new()
local snd = indication.Sound.new()

leds:start()
snd:start()

local function on_uid(uid)
    local message = osc.make(osc_address, "s", uid)
    net.udp.sendto(host, port, message)

    print("OSC sent:", osc_address, uid)
    leds:ok()
    snd:ok()
end

local function iteration()
    local ok, err = mfrc522.scan(0, on_uid)
    if ok == false then error(err, 0) end
end

while true do
    if wdt_on then cpu.watchdog.reset() end

    local ok, err = pcall(iteration)
    if not ok then
        local message = tostring(err)
        if message:find("interrupted!", 1, true) then
            error(err, 0)
        end
        eprint("Main loop: " .. message)
        leds:err()
        snd:err()
        sleepms(250)
    else
        sleepms(50)
    end
end

local get, sleepms = Settings.get, thread.sleepms

-- В net_dest укажите полный URL, например:
-- http://192.168.1.10:5000/check
local host, path, ssl, port = net.parseUrl(get("net_dest"))
local wdt_on = get("sys_wdt") == "on"

-- Проверьте пин и активный уровень на своей ревизии устройства.
local lock_pin = pio.GPIO32
pio.pin.setdir(pio.OUTPUT, lock_pin)

local function lock() pio.pin.setval(1, lock_pin) end
local function unlock() pio.pin.setval(0, lock_pin) end

lock()

local leds = indication.Leds.new()
local snd = indication.Sound.new()

leds:start()
snd:start()

local function pulse_lock()
    unlock()
    local ok, err = pcall(sleepms, 500)
    lock()
    if not ok then error(err, 0) end
end

local separator = path:find("?", 1, true) and "&" or "?"

local function on_uid(uid)
    if wdt_on then cpu.watchdog.reset() end
    local code = net.http.get(
        host,
        path .. separator .. "uid=" .. uid,
        nil,
        nil,
        ssl,
        port,
        1000,
        3
    )

    if code == 200 then
        pulse_lock()
        leds:ok()
        snd:ok()
    else
        wprint("Access denied: " .. uid .. ", HTTP " .. tostring(code))
        leds:err()
        snd:err()
    end
end

local function iteration()
    local ok, err = mfrc522.scan(0, on_uid)
    if ok == false then error(err, 0) end
end

while true do
    if wdt_on then cpu.watchdog.reset() end

    local ok, err = pcall(iteration)
    if not ok then
        lock()
        local message = tostring(err)
        if message:find("interrupted!", 1, true) then
            error(err, 0)
        end
        eprint("Main loop: " .. message)
        leds:err()
        snd:err()
        sleepms(250)
    else
        sleepms(50)
    end
end

from bottle import route, run, request

@route('/<path:path>')
def show_params(path):
    params = request.query.decode()
    print(f"Path: {path}")
    print("Parameters:")
    for key, value in params.items():
        print(f"  {key}: {value}")
    return "Parameters received"

run(host='0.0.0.0', port=5000, debug=True)

local get, sleepms = Settings.get, thread.sleepms
local wdt_on = get("sys_wdt") == "on"

-- Проверьте пин и активный уровень на своей ревизии устройства.
local lock_pin = pio.GPIO32
pio.pin.setdir(pio.OUTPUT, lock_pin)

local function lock() pio.pin.setval(1, lock_pin) end
local function unlock() pio.pin.setval(0, lock_pin) end

lock()

local allowed = {
    ["04A1B2C3"] = true,
    ["11223344"] = true,
}

local leds = indication.Leds.new()
local snd = indication.Sound.new()

leds:start()
snd:start()

local function pulse_lock()
    unlock()
    local ok, err = pcall(sleepms, 500)
    lock()
    if not ok then error(err, 0) end
end

local function on_uid(uid)
    if allowed[uid] then
        pulse_lock()
        leds:ok()
        snd:ok()
    else
        wprint("Access denied: " .. uid)
        leds:err()
        snd:err()
    end
end

local function iteration()
    local ok, err = mfrc522.scan(0, on_uid)
    if ok == false then error(err, 0) end
end

while true do
    if wdt_on then cpu.watchdog.reset() end

    local ok, err = pcall(iteration)
    if not ok then
        lock()
        local message = tostring(err)
        if message:find("interrupted!", 1, true) then
            error(err, 0)
        end
        eprint("Main loop: " .. message)
        leds:err()
        snd:err()
        sleepms(250)
    else
        sleepms(50)
    end
end

local get, sleepms = Settings.get, thread.sleepms

-- В net_dest укажите адрес и порт брокера, например:
-- broker.example.com:1883
local host, _, ssl, port = net.parseUrl(get("net_dest"))
local topic = "/odnfc/uid"
local client_id = "odnfc-" .. cpu.getmac(0, 1)
local wdt_on = get("sys_wdt") == "on"

local leds = indication.Leds.new()
local snd = indication.Sound.new()
local use_umqtt = umqtt ~= nil
local client

-- ODNFC-LAN использует uMQTT, ODNFC-LAN-C — модуль MQTT на ESP-MQTT.
if use_umqtt then
    client = umqtt.new(
        client_id,
        host,
        port,
        nil,
        nil,
        ssl == true,
        60
    )
elseif mqtt ~= nil then
    client = mqtt.client(client_id, host, port, ssl == true)
else
    error("MQTT module is not available in this firmware", 0)
end

local connected_once = false

leds:start()
snd:start()

local function connect()
    if client:connected() then return end

    if use_umqtt then
        if connected_once then
            local reconnected, reconnect_err = client:reconnect()
            if not reconnected then
                error("MQTT reconnect failed: " .. tostring(reconnect_err), 0)
            end
            return
        end

        local session, err = client:connect(true, 3000)
        if session == nil then
            error("MQTT connect failed: " .. tostring(err), 0)
        end
        connected_once = true
        return
    end

    -- mqtt.connect имеет собственный ограниченный таймаут 20 секунд, который
    -- длиннее 5-секундного task watchdog штатной прошивки ODNFC-LAN-C.
    if wdt_on then cpu.watchdog.remove() end
    local ok, err = pcall(client.connect, client, "", "", true)
    if wdt_on then cpu.watchdog.add() end
    if not ok then error(err, 0) end
end

local function on_uid(uid)
    if wdt_on then cpu.watchdog.reset() end
    connect()
    if wdt_on then cpu.watchdog.reset() end

    if use_umqtt then
        local sent, err = client:publish(topic, uid, false, 0)
        if not sent then
            error("MQTT publish failed: " .. tostring(err), 0)
        end
    else
        client:publish(topic, uid, mqtt.QOS0, false)
    end

    print("MQTT sent:", uid)
    leds:ok()
    snd:ok()
end

local function iteration()
    local ok, err = mfrc522.scan(0, on_uid)
    if ok == false then error(err, 0) end
end

while true do
    if wdt_on then cpu.watchdog.reset() end

    local ok, err = pcall(iteration)
    if not ok then
        local message = tostring(err)
        if message:find("interrupted!", 1, true) then
            error(err, 0)
        end
        eprint("Main loop: " .. message)
        leds:err()
        snd:err()
        sleepms(1000)
    else
        sleepms(50)
    end
end

# Подписаться на топик
mosquitto_sub -h broker.example.com -t "/odnfc/uid" -v

local get, sleepms = Settings.get, thread.sleepms
local wdt_on = get("sys_wdt") == "on"

local leds = indication.Leds.new()
local snd = indication.Sound.new()

leds:start()
snd:start()

-- Потокобезопасное хранилище последнего UID.
local mutex = thread.createmutex()
local last_uid = ""

local function set_uid(uid)
    mutex:lock()
    last_uid = uid
    mutex:unlock()
end

local function take_uid()
    mutex:lock()
    local uid = last_uid
    last_uid = ""
    mutex:unlock()
    return uid
end

-- Вызывается системным Web-обработчиком:
-- http://<ip-считывателя>/backend?action=get
function http_get()
    return take_uid()
end

local function on_uid(uid)
    set_uid(uid)
    leds:ok()
    snd:ok()
end

local function iteration()
    local ok, err = mfrc522.scan(0, on_uid)
    if ok == false then error(err, 0) end
end

while true do
    if wdt_on then cpu.watchdog.reset() end

    local ok, err = pcall(iteration)
    if not ok then
        local message = tostring(err)
        if message:find("interrupted!", 1, true) then
            error(err, 0)
        end
        eprint("Main loop: " .. message)
        leds:err()
        snd:err()
        sleepms(250)
    else
        sleepms(50)
    end
end

local get, sleepms = Settings.get, thread.sleepms

-- Сеть запускается системным кодом по Web-настройкам.
local host, _, ssl, port = net.parseUrl(get("net_dest"))
local wdt_on = get("sys_wdt") == "on"

local leds = indication.Leds.new()
local snd = indication.Sound.new()

leds:start()
snd:start()

local function on_uid(uid)
    if wdt_on then cpu.watchdog.reset() end
    local sent = net.tcp.sendto(host, port, uid, 3, ssl == true)
    if not sent then error("TCP send failed", 0) end

    print("TCP sent:", uid)
    leds:ok()
    snd:ok()
end

local function iteration()
    local ok, err = mfrc522.scan(0, on_uid)
    if ok == false then error(err, 0) end
end

while true do
    if wdt_on then cpu.watchdog.reset() end

    local ok, err = pcall(iteration)
    if not ok then
        local message = tostring(err)
        if message:find("interrupted!", 1, true) then
            error(err, 0)
        end
        eprint("Main loop: " .. message)
        leds:err()
        snd:err()
        sleepms(250)
    else
        sleepms(50)
    end
end