feat: 补充部分测试用例

feat: 调整管理端api处理函数
feat: 补充说明文档

Author: iamtsm

api/router/tl_ops_api_get_balance.lua

@@ -13,47 +13,40 @@ local cjson                   = require("cjson.safe");
 cjson.encode_empty_table_as_object(false)
 
 
-local Router = function() 
+local Handler = function() 
    local service_empty = cache:get(tl_ops_constant_balance.cache_key.service_empty)
    if not service_empty then
-      tl_ops_utils_func:set_ngx_req_return_ok(tl_ops_rt.not_found, "not found service_empty", _);
-      return;
+      return tl_ops_rt.not_found, "not found service_empty", _
    end
 
    local mode_empty = cache:get(tl_ops_constant_balance.cache_key.mode_empty)
    if not mode_empty then
-      tl_ops_utils_func:set_ngx_req_return_ok(tl_ops_rt.not_found, "not found mode_empty", _);
-      return;
+      return tl_ops_rt.not_found, "not found mode_empty", _
    end
 
    local host_empty = cache:get(tl_ops_constant_balance.cache_key.host_empty)
    if not host_empty then
-      tl_ops_utils_func:set_ngx_req_return_ok(tl_ops_rt.not_found, "not found host_empty", _);
-      return;
+      return tl_ops_rt.not_found, "not found host_empty", _
    end
 
    local host_pass = cache:get(tl_ops_constant_balance.cache_key.host_pass)
    if not host_pass then
-      tl_ops_utils_func:set_ngx_req_return_ok(tl_ops_rt.not_found, "not found host_pass", _);
-      return;
+      return tl_ops_rt.not_found, "not found host_pass", _
    end
 
    local token_limit = cache:get(tl_ops_constant_balance.cache_key.token_limit)
    if not token_limit then
-      tl_ops_utils_func:set_ngx_req_return_ok(tl_ops_rt.not_found, "not found token_limit", _);
-      return;
+      return tl_ops_rt.not_found, "not found token_limit", _
    end
 
    local leak_limit = cache:get(tl_ops_constant_balance.cache_key.leak_limit)
    if not leak_limit then
-      tl_ops_utils_func:set_ngx_req_return_ok(tl_ops_rt.not_found, "not found leak_limit", _);
-      return;
+      return tl_ops_rt.not_found, "not found leak_limit", _
    end
 
    local offline = cache:get(tl_ops_constant_balance.cache_key.offline)
    if not offline then
-      tl_ops_utils_func:set_ngx_req_return_ok(tl_ops_rt.not_found, "not found offline", _);
-      return;
+      return tl_ops_rt.not_found, "not found offline", _
    end
 
    local res_data = {
@@ -66,7 +59,15 @@ local Router = function()
       offline = cjson.decode(offline)
    }
 
-   tl_ops_utils_func:set_ngx_req_return_ok(tl_ops_rt.ok, "success", res_data);
+   return tl_ops_rt.ok, "success", res_data
 end
 
-return Router
+
+local Router = function ()
+   tl_ops_utils_func:set_ngx_req_return_ok(Handler())
+end
+
+return {
+   Handler = Handler,
+   Router = Router
+}

api/router/tl_ops_api_get_balance_api.lua

@@ -4,39 +4,43 @@
 -- @author iamtsm
 -- @email 1905333456@qq.com
 
-local snowflake                     = require("lib.snowflake");
 local cache                         = require("cache.tl_ops_cache_core"):new("tl-ops-balance-api");
 local tl_ops_rt                     = require("constant.tl_ops_constant_comm").tl_ops_rt;
 local tl_ops_utils_func             = require("utils.tl_ops_utils_func");
 local tl_ops_constant_balance_api   = require("constant.tl_ops_constant_balance_api")
 local cjson                         = require("cjson.safe"); 
 cjson.encode_empty_table_as_object(false)
 
-local Router = function() 
+local Handler = function()
     local rule, _ = cache:get(tl_ops_constant_balance_api.cache_key.rule);
     if not rule or rule == nil then
-        tl_ops_utils_func:set_ngx_req_return_ok(tl_ops_rt.not_found, "not found rule", _);
-        return;
+        return tl_ops_rt.not_found, "not found rule", _
     end
 
     local rule_match_mode, _ = cache:get(tl_ops_constant_balance_api.cache_key.rule_match_mode);
     if not rule_match_mode or rule_match_mode == nil then
-        tl_ops_utils_func:set_ngx_req_return_ok(tl_ops_rt.not_found, "not found rule_match_mode", _);
-        return;
+        return tl_ops_rt.not_found, "not found rule_match_mode", _
     end
-    
+
     local list_str, _ = cache:get(tl_ops_constant_balance_api.cache_key.list);
     if not list_str or list_str == nil then
-        tl_ops_utils_func:set_ngx_req_return_ok(tl_ops_rt.not_found, "not found list", _);
-        return;
+        return tl_ops_rt.not_found, "not found list", _
     end
 
     local res_data = {}
     res_data[tl_ops_constant_balance_api.cache_key.rule] = rule
     res_data[tl_ops_constant_balance_api.cache_key.rule_match_mode] = rule_match_mode
     res_data[tl_ops_constant_balance_api.cache_key.list] = cjson.decode(list_str)
-    
-    tl_ops_utils_func:set_ngx_req_return_ok(tl_ops_rt.ok, "success", res_data);
+
+    return tl_ops_rt.ok, "success", res_data
+end
+
+
+local Router = function ()
+    tl_ops_utils_func:set_ngx_req_return_ok(Handler())
 end
 
-return Router
+return {
+    Handler = Handler,
+    Router = Router
+}

api/router/tl_ops_api_get_balance_body.lua

@@ -4,40 +4,43 @@
 -- @author iamtsm
 -- @email 1905333456@qq.com
 
-local snowflake                     = require("lib.snowflake");
 local cache                         = require("cache.tl_ops_cache_core"):new("tl-ops-balance-body");
 local tl_ops_rt                     = require("constant.tl_ops_constant_comm").tl_ops_rt;
 local tl_ops_utils_func             = require("utils.tl_ops_utils_func");
 local tl_ops_constant_balance_body  = require("constant.tl_ops_constant_balance_body")
 local cjson                         = require("cjson.safe"); 
 cjson.encode_empty_table_as_object(false)
 
-local Router = function() 
+local Handler = function()
     local rule, _ = cache:get(tl_ops_constant_balance_body.cache_key.rule);
     if not rule or rule == nil then
-        tl_ops_utils_func:set_ngx_req_return_ok(tl_ops_rt.not_found, "not found rule", _);
-        return;
+        return tl_ops_rt.not_found, "not found rule", _
     end
 
     local rule_match_mode, _ = cache:get(tl_ops_constant_balance_body.cache_key.rule_match_mode);
     if not rule_match_mode or rule_match_mode == nil then
-        tl_ops_utils_func:set_ngx_req_return_ok(tl_ops_rt.not_found, "not found rule_match_mode", _);
-        return;
+        return tl_ops_rt.not_found, "not found rule_match_mode", _
     end
 
     local list_str, _ = cache:get(tl_ops_constant_balance_body.cache_key.list);
     if not list_str or list_str == nil then
-        tl_ops_utils_func:set_ngx_req_return_ok(tl_ops_rt.not_found, "not found list", _);
-        return;
+        return tl_ops_rt.not_found, "not found list", _
     end
-    
-    
+
     local res_data = {}
     res_data[tl_ops_constant_balance_body.cache_key.rule] = rule
     res_data[tl_ops_constant_balance_body.cache_key.rule_match_mode] = rule_match_mode
     res_data[tl_ops_constant_balance_body.cache_key.list] = cjson.decode(list_str)
-    
-    tl_ops_utils_func:set_ngx_req_return_ok(tl_ops_rt.ok, "success", res_data);
+
+    return tl_ops_rt.ok, "success", res_data
+end
+
+
+local Router = function ()
+    tl_ops_utils_func:set_ngx_req_return_ok(Handler())
 end
 
-return Router
+return {
+    Handler = Handler,
+    Router = Router
+}

api/router/tl_ops_api_get_balance_cookie.lua

@@ -4,40 +4,43 @@
 -- @author iamtsm
 -- @email 1905333456@qq.com
 
-local snowflake                         = require("lib.snowflake");
 local cache                             = require("cache.tl_ops_cache_core"):new("tl-ops-balance-cookie");
 local tl_ops_rt                         = require("constant.tl_ops_constant_comm").tl_ops_rt;
 local tl_ops_utils_func                 = require("utils.tl_ops_utils_func");
 local tl_ops_constant_balance_cookie    = require("constant.tl_ops_constant_balance_cookie")
 local cjson                             = require("cjson.safe");
 cjson.encode_empty_table_as_object(false)
 
-local Router = function() 
+local Handler = function()
     local rule, _ = cache:get(tl_ops_constant_balance_cookie.cache_key.rule);
     if not rule or rule == nil then
-        tl_ops_utils_func:set_ngx_req_return_ok(tl_ops_rt.not_found, "not found rule", _);
-        return;
+        return tl_ops_rt.not_found, "not found rule", _
     end
-    
+
     local rule_match_mode, _ = cache:get(tl_ops_constant_balance_cookie.cache_key.rule_match_mode);
     if not rule_match_mode or rule_match_mode == nil then
-        tl_ops_utils_func:set_ngx_req_return_ok(tl_ops_rt.not_found, "not found rule_match_mode", _);
-        return;
+        return tl_ops_rt.not_found, "not found rule_match_mode", _
     end
 
     local list_str, _ = cache:get(tl_ops_constant_balance_cookie.cache_key.list);
     if not list_str or list_str == nil then
-        tl_ops_utils_func:set_ngx_req_return_ok(tl_ops_rt.not_found, "not found list", _);
-        return;
+        return tl_ops_rt.not_found, "not found list", _
     end
-    
-    
+
     local res_data = {}
     res_data[tl_ops_constant_balance_cookie.cache_key.rule] = rule
     res_data[tl_ops_constant_balance_cookie.cache_key.rule_match_mode] = rule_match_mode
     res_data[tl_ops_constant_balance_cookie.cache_key.list] = cjson.decode(list_str)
-    
-    tl_ops_utils_func:set_ngx_req_return_ok(tl_ops_rt.ok, "success", res_data);
+
+    return tl_ops_rt.ok, "success", res_data
+end
+
+
+local Router = function ()
+    tl_ops_utils_func:set_ngx_req_return_ok(Handler())
 end
 
-return Router
+return {
+    Handler = Handler,
+    Router = Router
+}

api/router/tl_ops_api_get_balance_count_api.lua

@@ -13,7 +13,8 @@ local tl_ops_constant_balance_count     = require("constant.tl_ops_constant_bala
 local cjson                             = require("cjson.safe"); 
 cjson.encode_empty_table_as_object(false)
 
-local Router = function()
+
+local Handler = function()
 
     -- 支持只获取某个服务节点的路由规则统计
     local args = ngx.req.get_uri_args()
@@ -23,26 +24,22 @@ local Router = function()
 
     local rule, _ = cache_balance_api:get(tl_ops_constant_balance_api.cache_key.rule);
     if not rule or rule == nil then
-        tl_ops_utils_func:set_ngx_req_return_ok(tl_ops_rt.args_error ,"bca args err1", _);
-        return;
+        return tl_ops_rt.args_error ,"bca args err1", _
     end
 
     local list_str, _ = cache_balance_api:get(tl_ops_constant_balance_api.cache_key.list);
     if not list_str or list_str == nil then
-        tl_ops_utils_func:set_ngx_req_return_ok(tl_ops_rt.args_error ,"bca args err2", _);
-        return;
+        return tl_ops_rt.args_error ,"bca args err2", _
     end
 
     local list = cjson.decode(list_str);
     if not list or list == nil then
-        tl_ops_utils_func:set_ngx_req_return_ok(tl_ops_rt.args_error ,"bca args err3", _);
-        return;
+        return tl_ops_rt.args_error ,"bca args err3", _
     end
 
     local api_rule_list = list[rule];
     if not api_rule_list or api_rule_list == nil then
-        tl_ops_utils_func:set_ngx_req_return_ok(tl_ops_rt.args_error ,"bca args err4", _);
-        return;
+        return tl_ops_rt.args_error ,"bca args err4", _
     end
 
     local res_data = {}
@@ -90,7 +87,14 @@ local Router = function()
         until true
     end
 
-    tl_ops_utils_func:set_ngx_req_return_ok(tl_ops_rt.ok, "success", res_data);
+    return tl_ops_rt.ok, "success", res_data
+end
+
+local Router = function ()
+    tl_ops_utils_func:set_ngx_req_return_ok(Handler())
 end
 
-return Router
+return {
+    Handler = Handler,
+    Router = Router
+}

api/router/tl_ops_api_get_balance_count_body.lua

@@ -13,7 +13,7 @@ local tl_ops_constant_balance_count     = require("constant.tl_ops_constant_bala
 local cjson                             = require("cjson.safe"); 
 cjson.encode_empty_table_as_object(false)
 
-local Router = function()
+local Handler = function()
 
     -- 支持只获取某个服务节点的路由规则统计
     local args = ngx.req.get_uri_args()
@@ -23,26 +23,22 @@ local Router = function()
 
     local rule, _ = cache_balance_body:get(tl_ops_constant_balance_body.cache_key.rule);
     if not rule or rule == nil then
-        tl_ops_utils_func:set_ngx_req_return_ok(tl_ops_rt.args_error ,"bc args err1", _);
-        return;
+        return tl_ops_rt.args_error ,"bc args err1", _
     end
 
     local list_str, _ = cache_balance_body:get(tl_ops_constant_balance_body.cache_key.list);
     if not list_str or list_str == nil then
-        tl_ops_utils_func:set_ngx_req_return_ok(tl_ops_rt.args_error ,"bc args err2", _);
-        return;
+        return tl_ops_rt.args_error ,"bc args err2", _
     end
 
     local list = cjson.decode(list_str);
     if not list or list == nil then
-        tl_ops_utils_func:set_ngx_req_return_ok(tl_ops_rt.args_error ,"bc args err3", _);
-        return;
+        return tl_ops_rt.args_error ,"bc args err3", _
     end
 
     local body_rule_list = list[rule];
     if not body_rule_list or body_rule_list == nil then
-        tl_ops_utils_func:set_ngx_req_return_ok(tl_ops_rt.args_error ,"bc args err4", _);
-        return;
+        return tl_ops_rt.args_error ,"bc args err4", _
     end
 
     local res_data = {}
@@ -91,7 +87,14 @@ local Router = function()
         until true
     end
 
-    tl_ops_utils_func:set_ngx_req_return_ok(tl_ops_rt.ok, "success", res_data);
+    return tl_ops_rt.ok, "success", res_data
 end
 
-return Router
+local Router = function ()
+    tl_ops_utils_func:set_ngx_req_return_ok(Handler())
+end
+
+return {
+    Handler = Handler,
+    Router = Router
+}