YF_BZYV2/Code/yfbzy_v2.5_code/BZY-AIR202/bzy/lib/console.lua

--- 模块功能 luat控制台
-- @module console
-- @author 小强
-- @license MIT
-- @copyright openLuat.com
-- @release 2017.9.15

require"ril"
module(..., package.seeall)
local uart_id
local console_task

local function read_line()
    while true do
        local s = uart.read(uart_id, "*l")
        if s ~= "" then
            return s
        end
        coroutine.yield()
    end
end

local function write(s)
    uart.write(uart_id, s)
end

local function on_wait_event_timeout()
    coroutine.resume(console_task, "TIEMOUT")
end

local function wait_event(event, timeout)
    if timeout then
        sys.timer_start(on_wait_event_timeout, timeout)
    end

    while true do
        local receive_event = coroutine.yield()
        if receive_event == event then
            sys.timer_stop(on_wait_event_timeout)
            return
        elseif receive_event == "TIMEOUT" then
            write("WAIT EVENT " .. event .. "TIMEOUT\r\n")
            return
        end
    end
end

local function main_loop()
    local cache_data = ""
    local wait_event_flag

    -- 定义执行环境，命令行下输入的脚本的print重写到命令行的write
    local execute_env = {
        print = function(...)
            for i, v in ipairs(arg) do
                arg[i] = type(v) == "nil" and "nil" or tostring(v)
            end
            write(table.concat(arg, "\t"))
            write("\r\n")
        end,
        sendat = function(cmd, data)
            ril.request(cmd, data, function(cmd, success, response, intermediate)
                if intermediate then
                    write("\r\n" .. intermediate .. "\r\n")
                end
                if response then
                    write("\r\n" .. response .. "\r\n")
                end
                coroutine.resume(console_task, "WAIT_AT_RESPONSE")
            end, nil)
            wait_event_flag = "WAIT_AT_RESPONSE"
        end,
    }
    setmetatable(execute_env, { __index = _G })

    -- 输出提示语
    write("\r\nWelcome to Luat Console\r\n")
    write("\r\n> ")

    while true do
        -- 读取输入
        local new_data = read_line("*l")
        -- 输出回显
        write(new_data)
        -- 拼接之前未成行的剩余数据
        cache_data = cache_data .. new_data
        -- 去掉回车换行
        local line = string.match(cache_data, "(.+\r*\n)")
        if line then
            -- 收到一整行的数据 清除缓冲数据
            cache_data = ""
            -- 输出新行
            write("\n")
            -- 用xpcall执行用户输入的脚本，可以捕捉脚本的错误
            xpcall(function()
                -- 执行用户输入的脚本
                local f = loadstring(line)
                setfenv(f, execute_env)
                f()
            end,
                function() -- 错误输出
                    write(debug.traceback())
                end)
            if wait_event_flag then
                wait_event(wait_event_flag, 3000)
                wait_event_flag = nil
            end
            -- 输出输入提示符
            write("\r\n> ")
        end
    end
end

--- console.setup
-- @param id 串口id
-- @param baudrate 串口波特率
-- @return 无
-- @usage console.setup(1, 115200)
function setup(id, baudrate)
    -- 默认串口1
    uart_id = id or 1
    -- 默认波特率115200
    baudrate = baudrate or 115200
    -- 创建console处理的协程
    console_task = coroutine.create(main_loop)
    -- 初始化串口
    uart.setup(uart_id, baudrate, 8, uart.PAR_NONE, uart.STOP_1)
    -- 串口收到数据时唤醒console协程
    uart.on(uart_id, "receive", function()
        coroutine.resume(console_task)
    end)
    coroutine.resume(console_task)
end