From 672f3d40be83d9e380fd7be4b674d5e8d5fa36de Mon Sep 17 00:00:00 2001
From: HuabingZhao <zhao.huabing@zte.com.cn>
Date: Tue, 25 Jul 2017 15:18:33 +0800
Subject: Divide the MSB source codes into two repos

Change-Id: Ie76d545b214a8ce5191f215350a623e1529983d9
Issue-id: MSB-5
Signed-off-by: HuabingZhao <zhao.huabing@zte.com.cn>
---
 .../openresty/nginx/luaext/openoapirouter.lua      | 117 ---------------------
 1 file changed, 117 deletions(-)
 delete mode 100644 msb-core/openresty-ext/src/assembly/resources/openresty/nginx/luaext/openoapirouter.lua

(limited to 'msb-core/openresty-ext/src/assembly/resources/openresty/nginx/luaext/openoapirouter.lua')

diff --git a/msb-core/openresty-ext/src/assembly/resources/openresty/nginx/luaext/openoapirouter.lua b/msb-core/openresty-ext/src/assembly/resources/openresty/nginx/luaext/openoapirouter.lua
deleted file mode 100644
index 717bd1a..0000000
--- a/msb-core/openresty-ext/src/assembly/resources/openresty/nginx/luaext/openoapirouter.lua
+++ /dev/null
@@ -1,117 +0,0 @@
---[[
-
-    Copyright 2016 ZTE Corporation.
-
-    Licensed under the Apache License, Version 2.0 (the "License");
-    you may not use this file except in compliance with the License.
-    You may obtain a copy of the License at
-
-        http://www.apache.org/licenses/LICENSE-2.0
-
-    Unless required by applicable law or agreed to in writing, software
-    distributed under the License is distributed on an "AS IS" BASIS,
-    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-    See the License for the specific language governing permissions and
-    limitations under the License.
-
-        Author: Zhaoxing Meng
-        email: meng.zhaoxing1@zte.com.cn
-
-]]
--- put red into the connection pool of size 100,
--- with 10 seconds max idle time
-local function close_redis(red)
-	if not red then
-		return
-	end
-	--release connection to the pool
-	local pool_max_idle_time = 10000
-	local pool_size = 100
-	local ok, err = red:set_keepalive(pool_max_idle_time, pool_size)
-	if not ok then
-		ngx.log(ngx.ERR, "set keepalive error:", err)
-	end
-	return
-end
-
-local function rewrite_api_url()
-	local apiserver=ngx.var.apiserver
-	if apiserver=="fallback" then
-		ngx.status = ngx.HTTP_NOT_FOUND
-		ngx.exit(ngx.status)
-	end
-	local apiurl=ngx.var.apiurl
-	local uri = ngx.re.sub(ngx.var.uri, "^/openoapi/([^/]+)(/[Vv][^/]*)?(.*)", apiurl.."$3", "o")
-	ngx.req.set_uri(uri)
-end
-
-local function query_api_info()
-	local apiserver = ngx.var.apiserver
-	local apiname = ngx.var.apiname
-	local apiversion = ngx.var.apiversion
-	apiversion=string.sub(apiversion,2,string.len(apiversion))
-
-	-- Check if key exists in local cache
-	local cache = ngx.shared.ceryx
-	local server, flags = cache:get("server:api:"..apiname..":"..apiversion)
-	local url, flags = cache:get("url:api:"..apiname..":"..apiversion)
-	if server and url then
-		ngx.var.apiserver = server
-		ngx.var.apiurl = url
-		ngx.log(ngx.WARN, "==using api cache:", server.."&&"..url)
-		return
-	end
-
-	local redis = require "resty.redis"
-	local red = redis:new()
-	red:set_timeout(1000) -- 1000 ms
-	local redis_host = "127.0.0.1" 
-	local redis_port = 6379 
-	local res, err = red:connect(redis_host, redis_port)
-
-	-- Return if could not connect to Redis
-	if not res then
-		ngx.log(ngx.ERR, "connect to redis error:", err)
-		return
-	end
-
-	-- Construct Redis key
-	local prefix =  "msb"
-	local keyprefix = prefix..":routing:api:"..apiname..":"..apiversion
-
-	local infokey=keyprefix..":info"
-	-- first of all check whether the status is 1(enabled)
-	local status = red:hget(infokey,"status")
-	if not (status=="1")  then
-		ngx.log(ngx.WARN, keyprefix.."is disabled.status=", status)
-		return close_redis(red)
-	end
-	
-	-- Try to get url for apiname
-	local url, err = red:hget(infokey,"url")
-	ngx.log(ngx.WARN, "==url:", url)
-	if not url or url == ngx.null then
-		return close_redis(red) 
-	end
-
-	-- Try to get ip:port for apiname
-	local serverkey=keyprefix..":lb:server1"
-	local server, err = red:hget(serverkey,"ip")..":"..red:hget(serverkey,"port")
-	ngx.log(ngx.WARN, "==server:", server)
-	if not server or server == ngx.null then
-		return close_redis(red) 
-	end
-
-
-	-- Save found key to local cache for 5 seconds
-	cache:set("server:api:"..apiname..":"..apiversion, server, 5)
-	cache:set("url:api:"..apiname..":"..apiversion, url, 5)
-
-	ngx.log(ngx.WARN, "==api result:", server.."&&"..url)
-	ngx.var.apiserver = server
-	ngx.var.apiurl = url
-
-	return close_redis(red)
-end
-query_api_info()
-rewrite_api_url()
\ No newline at end of file
-- 
cgit 1.2.3-korg