68 lines
1.3 KiB
Lua
68 lines
1.3 KiB
Lua
|
local cjson = require "cjson"
|
||
|
|
|
||
|
|
-- Load configuration
|
||
|
|
function readConf(file)
|
||
|
|
local f, err = io.open(file, "rb")
|
||
|
|
local content = f:read("*all")
|
||
|
|
f:close()
|
||
|
|
return content
|
||
|
|
end
|
||
|
|
|
||
|
|
-- Print nested tables
|
||
|
|
function content_from_table(tbl)
|
||
|
|
for i, v in pairs(tbl) do
|
||
|
|
if type(v) == "table" then
|
||
|
|
content_from_table(v)
|
||
|
|
else
|
||
|
|
ngx.print(v)
|
||
|
|
end
|
||
|
|
end
|
||
|
|
end
|
||
|
|
|
||
|
|
local json = readConf('/etc/nginx/etc/swift.json')
|
||
|
|
local conf = cjson.decode(json)
|
||
|
|
|
||
|
|
-- Make authentication request to Ceph
|
||
|
|
headers_t = {}
|
||
|
|
headers_t["X-Auth-User"] = conf.user
|
||
|
|
headers_t["X-Auth-Key"] = conf.secret_key
|
||
|
|
|
||
|
|
local http = require("socket.http")
|
||
|
|
local r, c, h = http.request{
|
||
|
|
url = conf.auth_uri,
|
||
|
|
headers = headers_t,
|
||
|
|
method = "GET"
|
||
|
|
}
|
||
|
|
|
||
|
|
-- Return 403 if not authorized
|
||
|
|
if c ~= 200 then
|
||
|
|
ngx.exit(ngx.HTTP_FORBIDDEN)
|
||
|
|
end
|
||
|
|
|
||
|
|
-- OK, we get auth token now
|
||
|
|
local auth_token = ''
|
||
|
|
auth_token = h["x-auth-token"]
|
||
|
|
|
||
|
|
content_headers= {}
|
||
|
|
content_headers["X-Auth-Token"] = auth_token
|
||
|
|
|
||
|
|
local ltn12 = require("ltn12")
|
||
|
|
local io = require("io")
|
||
|
|
|
||
|
|
t = {}
|
||
|
|
|
||
|
|
local resp, code, http_st = http.request{
|
||
|
|
method = "GET",
|
||
|
|
headers = content_headers,
|
||
|
|
url = conf.rados_uri .. conf.bucket .. ngx.var.path,
|
||
|
|
sink = ltn12.sink.table(t)
|
||
|
|
}
|
||
|
|
|
||
|
|
-- Return 404 if object not found in Ceph
|
||
|
|
if code ~= 200 then
|
||
|
|
ngx.exit(ngx.HTTP_NOT_FOUND)
|
||
|
|
end
|
||
|
|
|
||
|
|
-- Print object
|
||
|
|
content_from_table(t)
|