Pasted

-- Send session to InfluxDB
 
uptime_skip = 10 -- do not sessions less 10 seconds
 
function auth_request(session_id, request, callback)
    if request ~= nil then
        callback(true)
        return nil
    end
 
    local stat = http_output_client_list[session_id]
    local ctime = os.time()
    local uptime = ctime - stat.st
    if uptime_skip > uptime then
        return nil
    end
 
    local content = "session" ..
        ",host=" .. hostname ..
        ",id=" .. stat.channel_id ..
        ",name=" .. stat.channel_name ..
        ",addr=" .. stat.request.addr ..
        " uptime=" .. uptime ..
        " " .. ctime .. "000000000"
 
    local event_config = {
        host = _event_request.host,
        port = _event_request.port,
        path = _event_request.path,
        method = "POST",
        headers = {
            "User-Agent: Astra " .. astra.version,
            "Host: " .. _event_request.host .. ":" .. _event_request.port,
            "Content-Type: application/x-www-form-urlencoded",
            "Content-Length: " .. #content,
            "Connection: close"
        },
        callback = function(self, response)
            if response.code ~= 204 then
                log.error(("[stream.lua] event_request_send() failed %d:%s")
                          :format(response.code, response.message))
            end
        end,
        content = content,
    }
 
    http_request(event_config)
end