v3

Author: AlinsRan

lib/resty/apisix/upstream.lua

@@ -14,7 +14,7 @@ ffi.cdef([[
 typedef intptr_t        ngx_int_t;
 ngx_int_t ngx_http_apisix_upstream_set_cert_and_key(ngx_http_request_t *r, void *cert, void *key);
 ngx_int_t ngx_http_apisix_upstream_set_ssl_trusted_store(ngx_http_request_t *r, void *store);
-int ngx_http_apisix_set_upstream_ssl_verify(ngx_http_request_t *r, int verify);
+int ngx_http_apisix_upstream_set_ssl_verify(ngx_http_request_t *r, int verify);
 ]])
 local _M = {}
 
@@ -71,15 +71,15 @@ end
 _M.set_ssl_trusted_store = set_ssl_trusted_store
 
 
-local set_upstream_ssl_verify
+local set_ssl_verify
 do
     local ALLOWED_PHASES = {
         ['rewrite'] = true,
         ['balancer'] = true,
         ['access'] = true,
         ['preread'] = true,
     }
-    function set_upstream_ssl_verify(verify)
+    function set_ssl_verify(verify)
         if not ALLOWED_PHASES[get_phase()] then
             error("API disabled in the current context", 2)
         end
@@ -90,7 +90,7 @@ do
 
         local r = get_request()
 
-        local ret = C.ngx_http_apisix_set_upstream_ssl_verify(
+        local ret = C.ngx_http_apisix_upstream_set_ssl_verify(
             r, verify)
         if ret == NGX_OK then
             return true
@@ -103,7 +103,7 @@ do
         error("unknown return code: " .. tostring(ret))
     end
 end
-_M.set_upstream_ssl_verify = set_upstream_ssl_verify
+_M.set_ssl_verify = set_ssl_verify
 
 
 return _M

src/ngx_http_apisix_module.c

@@ -386,7 +386,7 @@ ngx_http_apisix_set_upstream_ssl(ngx_http_request_t *r, ngx_connection_t *c)
 
 
 int
-ngx_http_apisix_set_upstream_ssl_verify(ngx_http_request_t *r, int verify)
+ngx_http_apisix_upstream_set_ssl_verify(ngx_http_request_t *r, int verify)
 {
     ngx_http_apisix_ctx_t       *ctx;
 

t/upstream_ssl_verify.t

@@ -53,9 +53,9 @@ __DATA__
     location /t {
         access_by_lua_block {
             local upstream = require("resty.apisix.upstream")
-            local ok, err = upstream.set_upstream_ssl_verify(true)
+            local ok, err = upstream.set_ssl_verify(true)
             if not ok then
-                ngx.log(ngx.ERR, "set_upstream_ssl_verify failed: ", err)
+                ngx.log(ngx.ERR, "set_ssl_verify failed: ", err)
                 ngx.exit(500)
             end
         }
@@ -74,9 +74,9 @@ upstream SSL certificate verify error: (20:unable to get local issuer certificat
     location /t {
         access_by_lua_block {
             local upstream = require("resty.apisix.upstream")
-            local ok, err = upstream.set_upstream_ssl_verify(false)
+            local ok, err = upstream.set_ssl_verify(false)
             if not ok then
-                ngx.log(ngx.ERR, "set_upstream_ssl_verify failed: ", err)
+                ngx.log(ngx.ERR, "set_ssl_verify failed: ", err)
                 ngx.exit(500)
             end
         }
@@ -95,9 +95,9 @@ ok
     location /t {
         access_by_lua_block {
             local upstream = require("resty.apisix.upstream")
-            local ok, err = upstream.set_upstream_ssl_verify(true)
+            local ok, err = upstream.set_ssl_verify(true)
             if not ok then
-                ngx.log(ngx.ERR, "set_upstream_ssl_verify failed: ", err)
+                ngx.log(ngx.ERR, "set_ssl_verify failed: ", err)
                 ngx.exit(500)
             end
         }
@@ -118,7 +118,7 @@ ok
     location /t {
         content_by_lua_block {
             local upstream = require("resty.apisix.upstream")
-            upstream.set_upstream_ssl_verify(true)
+            upstream.set_ssl_verify(true)
         }
     }
 --- error_code: 500
@@ -133,22 +133,22 @@ API disabled in the current context
         rewrite_by_lua_block {
             local upstream = require("resty.apisix.upstream")
             ngx.status = 500
-            local ok, _ = pcall(upstream.set_upstream_ssl_verify, 1)
+            local ok, _ = pcall(upstream.set_ssl_verify, 1)
             if not ok then
                 ngx.say("invalid argument type: number")
             end
             
-            local ok, _ = pcall(upstream.set_upstream_ssl_verify, "true")
+            local ok, _ = pcall(upstream.set_ssl_verify, "true")
             if not ok then
                 ngx.say("invalid argument type: string")
             end
 
-            local ok, err = pcall(upstream.set_upstream_ssl_verify, nil)
+            local ok, err = pcall(upstream.set_ssl_verify, nil)
             if not ok then
                 ngx.say("invalid argument type: nil")
             end
 
-            local ok, err = pcall(upstream.set_upstream_ssl_verify, {})
+            local ok, err = pcall(upstream.set_ssl_verify, {})
             if not ok then
                 ngx.say("invalid argument type: table")
             end
@@ -188,9 +188,9 @@ invalid argument type: table
                 ngx.exit(500)
             end
 
-            local ok, err = upstream.set_upstream_ssl_verify(false)
+            local ok, err = upstream.set_ssl_verify(false)
             if not ok then
-                ngx.log(ngx.ERR, "set_upstream_ssl_verify failed: ", err)
+                ngx.log(ngx.ERR, "set_ssl_verify failed: ", err)
                 ngx.exit(500)
             end
         }
@@ -255,9 +255,9 @@ ok
                 ngx.exit(500)
             end
 
-            local ok, err = upstream.set_upstream_ssl_verify(true)
+            local ok, err = upstream.set_ssl_verify(true)
             if not ok then
-                ngx.log(ngx.ERR, "set_upstream_ssl_verify failed: ", err)
+                ngx.log(ngx.ERR, "set_ssl_verify failed: ", err)
                 ngx.exit(500)
             end
         }