air780e-forwarder/script/util_notify.lua

local util_notify = {}

local function urlencodeTab(params)
    local msg = {}
    for k, v in pairs(params) do
        table.insert(msg, string.urlEncode(k) .. "=" .. string.urlEncode(v))
        table.insert(msg, "&")
    end
    table.remove(msg)
    return table.concat(msg)
end

-- 发送到 telegram
local function notifyToTelegram(msg)
    if config.TELEGRAM_PROXY_API == nil or config.TELEGRAM_PROXY_API == "" then
        log.error("util_notify.notifyToTelegram", "未配置 `config.TELEGRAM_PROXY_API`")
        return
    end

    local header = {
        ["content-type"] = "text/plain",
        ["x-disable-web-page-preview"] = "1",
        ["x-chat-id"] = config.TELEGRAM_CHAT_ID or "",
        ["x-token"] = config.TELEGRAM_TOKEN or ""
    }

    log.info("util_notify.notifyToTelegram", "POST", config.TELEGRAM_PROXY_API)
    return http.request("POST", config.TELEGRAM_PROXY_API, header, msg).wait()
end

-- 发送到 pushdeer
local function notifyToPushDeer(msg)
    if config.PUSHDEER_API == nil or config.PUSHDEER_API == "" then
        log.error("util_notify.notifyToPushDeer", "未配置 `config.PUSHDEER_API`")
        return
    end
    if config.PUSHDEER_KEY == nil or config.PUSHDEER_KEY == "" then
        log.error("util_notify.notifyToPushDeer", "未配置 `config.PUSHDEER_KEY`")
        return
    end

    local header = {
        ["Content-Type"] = "application/x-www-form-urlencoded"
    }
    local body = {
        pushkey = config.PUSHDEER_KEY or "",
        type = "text",
        text = msg
    }

    log.info("util_notify.notifyToPushDeer", "POST", config.PUSHDEER_API)
    return http.request("POST", config.PUSHDEER_API, header, urlencodeTab(body)).wait()
end

-- 发送到 bark
local function notifyToBark(msg)
    if config.BARK_API == nil or config.BARK_API == "" then
        log.error("util_notify.notifyToBark", "未配置 `config.BARK_API`")
        return
    end
    if config.BARK_KEY == nil or config.BARK_KEY == "" then
        log.error("util_notify.notifyToBark", "未配置 `config.BARK_KEY`")
        return
    end

    local header = {
        ["Content-Type"] = "application/x-www-form-urlencoded"
    }
    local body = {
        body = msg
    }
    local url = config.BARK_API .. "/" .. config.BARK_KEY

    log.info("util_notify.notifyToBark", "POST", url)
    return http.request("POST", url, header, urlencodeTab(body)).wait()
end

-- 发送到 dingtalk
local function notifyToDingTalk(msg)
    if config.DINGTALK_WEBHOOK == nil or config.DINGTALK_WEBHOOK == "" then
        log.error("util_notify.notifyToDingTalk", "未配置 `config.DINGTALK_WEBHOOK`")
        return
    end

    local header = {
        ["Content-Type"] = "application/json; charset=utf-8"
    }
    local body = {
        msgtype = "text",
        text = {
            content = msg
        }
    }
    local json_data = json.encode(body)
    -- LuatOS Bug, json.encode 会将 \n 转换为 \b
    json_data = string.gsub(json_data, "\\b", "\\n")

    log.info("util_notify.notifyToDingTalk", "POST", config.DINGTALK_WEBHOOK, json_data)
    return http.request("POST", config.DINGTALK_WEBHOOK, header, json_data).wait()
end

-- 发送到 feishu
local function notifyToFeishu(msg)
    if config.FEISHU_WEBHOOK == nil or config.FEISHU_WEBHOOK == "" then
        log.error("util_notify.notifyToFeishu", "未配置 `config.FEISHU_WEBHOOK`")
        return
    end

    local header = {
        ["Content-Type"] = "application/json; charset=utf-8"
    }
    local body = {
        msg_type = "text",
        content = {
            text = msg
        }
    }
    local json_data = json.encode(body)
    -- LuatOS Bug, json.encode 会将 \n 转换为 \b
    json_data = string.gsub(json_data, "\\b", "\\n")

    log.info("util_notify.notifyToFeishu", "POST", config.FEISHU_WEBHOOK, json_data)
    return http.request("POST", config.FEISHU_WEBHOOK, header, json_data).wait()
end

function util_notify.send(msg)
    log.info("util_notify.send", "发送通知", config.NOTIFY_TYPE)

    if type(msg) == "table" then
        msg = table.concat(msg, "\n")
    end
    if type(msg) ~= "string" then
        log.error("util_notify.send", "发送通知失败", "参数类型错误", type(msg))
        return
    end

    local model = hmeta.model() or ""
    local simid = mobile.simid()
    local iccid = mobile.iccid(simid) or ""
    local rsrp = mobile.rsrp()
    local mcc, mnc, band = util_mobile.mcc, util_mobile.mnc, util_mobile.band
    local oper = util_mobile.getOper(true)
    local lat, lng = util_location.getCoord()
    local map_url = "https://apis.map.qq.com/uri/v1/marker?coord_type=1&marker=title:+;coord:" .. lat .. "," .. lng

    msg = msg .. "\n"
    if model then
        msg = msg .. "\nMODEL: " .. model
    end
    if iccid then
        msg = msg .. "\nICCID: " .. iccid
    end
    if oper then
        msg = msg .. "\n运营商: " .. oper
    end
    msg = msg .. "\n信号: " .. rsrp .. "dBm"
    if band ~= "" then
        msg = msg .. "\n频段: B" .. band
    end
    if lat ~= 0 and lng ~= 0 then
        msg = msg .. "\n位置: " .. map_url
    end

    -- 判断通知类型
    local notify
    if config.NOTIFY_TYPE == "telegram" then
        notify = notifyToTelegram
    elseif config.NOTIFY_TYPE == "pushdeer" then
        notify = notifyToPushDeer
    elseif config.NOTIFY_TYPE == "bark" then
        notify = notifyToBark
    elseif config.NOTIFY_TYPE == "dingtalk" then
        notify = notifyToDingTalk
    elseif config.NOTIFY_TYPE == "feishu" then
        notify = notifyToFeishu
    else
        log.error("util_notify.send", "发送通知失败", "未配置 `config.NOTIFY_TYPE`")
        return
    end

    sys.taskInit(
        function()
            sys.wait(100)
            local max_retry = 10
            local retry_count = 0

            while retry_count < max_retry do
                local code, headers, body = notify(msg)
                if code == 200 then
                    log.info("util_notify.send", "发送通知成功", "retry_count:", retry_count, "code:", code, "body:", body)
                    break
                else
                    retry_count = retry_count + 1
                    log.error("util_notify.send", "发送通知失败", "retry_count:", retry_count, "code:", code, "body:", body)
                    util_netled.blink(500, 200, 3000)
                    sys.wait(10000)
                end
            end
        end
    )
end

return util_notify