Custom mysql lua script for vernemq.

mysql.lua

-- /usr/share/vernemq/lua/auth/mysql.lua
-- Only replace the function

function auth_on_register(reg)
    if reg.username ~= nil and reg.password ~= nil then
        raw_client_id = reg.client_id
        form_client_id = raw_client_id:gsub("#", "%")
        results = mysql.execute(pool,
            [[SELECT publish_acl, subscribe_acl
              FROM vmq_auth_acl
              WHERE
                mountpoint = ? AND
                ? LIKE REPLACE(client_id, "#", "%") AND
                username = ? AND
                password = ]]..mysql.hash_method(),
            reg.mountpoint,
            reg.client_id,
            reg.username,
            reg.password)
        if #results == 1 then
            row = results[1]
            publish_acl = json.decode(row.publish_acl)
            subscribe_acl = json.decode(row.subscribe_acl)
            cache_insert(
                reg.mountpoint,
                reg.client_id,
                reg.username,
                publish_acl,
                subscribe_acl
                )
            return true
        else
            return false
        end
    end
end