aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--msb-core/openresty-ext/src/assembly/resources/openresty/nginx/luaext/plugins/driver_manager.lua12
1 files changed, 11 insertions, 1 deletions
diff --git a/msb-core/openresty-ext/src/assembly/resources/openresty/nginx/luaext/plugins/driver_manager.lua b/msb-core/openresty-ext/src/assembly/resources/openresty/nginx/luaext/plugins/driver_manager.lua
index 1dc1af7..fac8a64 100644
--- a/msb-core/openresty-ext/src/assembly/resources/openresty/nginx/luaext/plugins/driver_manager.lua
+++ b/msb-core/openresty-ext/src/assembly/resources/openresty/nginx/luaext/plugins/driver_manager.lua
@@ -41,8 +41,10 @@ end
local function get_driver_url(driver_header)
local cjson = require "cjson"
local query_url = get_query_url(driver_header)
+ local driver_header_value = get_driver_header();
ngx.req.clear_header(_HEADER)
local res = ngx.location.capture(query_url, { method = ngx.HTTP_GET})
+ ngx.req.set_header(_HEADER, driver_header_value);
ngx.log (ngx.ERR, "Driver manager resp url : ", tostring(res.body))
if (res.status == 200 and res.body ~= nil and res.body ~= '')
then
@@ -52,6 +54,14 @@ local function get_driver_url(driver_header)
end
end
+-- get the ori query param string
+local function get_ori_query()
+ local args = ngx.req.get_uri_args();
+ local ori_query_param = "?"..ngx.encode_args(args);
+ ngx.log(ngx.ERR, "The original request query parameter is ", ori_query_param);
+ return ori_query_param;
+end
+
-- get headers
local function get_headers()
local headers = {}
@@ -86,7 +96,7 @@ function _M.access()
if (driver_header ~= "")
then
- local driver_url = get_driver_url(driver_header)
+ local driver_url = get_driver_url(driver_header)..get_ori_query();
ngx.log (ngx.ERR, "Driver manager URl:: ", driver_url)
local http = require "resty.http"