-
Notifications
You must be signed in to change notification settings - Fork 1
/
Copy pathrest_nginx.conf
218 lines (195 loc) · 5.54 KB
/
rest_nginx.conf
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
worker_processes 4;
worker_rlimit_nofile 500000;
timer_resolution 100ms;
worker_priority -10;
events {
worker_connections 10000;
use epoll;
multi_accept on;
}
http {
charset utf-8;
client_body_buffer_size 2048;
client_max_body_size 4096;
client_header_buffer_size 512;
large_client_header_buffers 4 1k;
output_buffers 1 512;
postpone_output 1460;
gzip on;
gzip_disable "msie6";
gzip_types text/plain text/css application/json application/x-javascript text/xml application/xml application/xml+rss text/javascript application/javascript;
keepalive_timeout 100;
keepalive_requests 20000;
reset_timedout_connection on;
client_body_timeout 10;
send_timeout 60s;
default_type "application/json; charset=utf-8";
access_log off;
error_log off;
sendfile on;
tcp_nopush on;
tcp_nodelay on;
upstream backend {
# Tarantool hosts
server 127.0.0.1:3310;
keepalive 2000;
}
server {
listen 80;
server_name 127.0.0.1;
proxy_buffering off;
proxy_buffer_size 512;
chunked_transfer_encoding off;
tnt_pass_http_request on parse_args pass_body unescape;
tnt_pure_result on;
tnt_http_methods all;
tnt_buffer_size 1024;
tnt_pass_http_request_buffer_size 4048;
lua_need_request_body on;
proxy_http_version 1.1;
proxy_set_header Connection "";
#-----------------------------------------users
location = /users {
internal;
tnt_http_rest_methods get post;
tnt_method userEndpoint;
tnt_pass backend;
}
location = /users/new {
rewrite_by_lua_block {
local cjson = require("cjson")
local data = ngx.req.get_body_data()
local res = ngx.location.capture('/users',{ method = ngx.HTTP_POST, body = data})
local answ = cjson.decode(res.body)
if answ[1]==200 then
ngx.say(cjson.encode(answ[2]))
else
ngx.exit(answ[1])
end
}
}
location ~ /users/(\d+) {
if ($request_method = "GET") {
rewrite_by_lua_block {
local cjson = require("cjson")
local res = ngx.location.capture('/users',{args = ngx.var.args, method = ngx.HTTP_GET})
local answ = cjson.decode(res.body)
if answ[1]==200 then
local result = cjson.encode(answ[2])
result = result:gsub("{}", "[]")
ngx.say(result)
else
ngx.exit(answ[1])
end
}
}
if ($request_method = "POST") {
rewrite_by_lua_block {
local cjson = require("cjson")
local data = ngx.req.get_body_data()
local res = ngx.location.capture('/users',{ method = ngx.HTTP_POST, body = data})
local answ = cjson.decode(res.body)
if answ[1]==200 then
ngx.say(cjson.encode(answ[2]))
else
ngx.exit(answ[1])
end
}
}
}
#-----------------------------------------visits
location = /visits {
internal;
tnt_http_rest_methods get post;
tnt_method visitEndpoint;
tnt_pass backend;
}
location = /visits/new {
rewrite_by_lua_block {
local cjson = require("cjson")
local data = ngx.req.get_body_data()
local res = ngx.location.capture('/visits',{ method = ngx.HTTP_POST, body = data})
local answ = cjson.decode(res.body)
if answ[1]==200 then
ngx.say(cjson.encode(answ[2]))
else
ngx.exit(answ[1])
end
}
}
location ~ /visits/(\d+) {
if ($request_method = "GET") {
rewrite_by_lua_block {
local cjson = require("cjson")
local res = ngx.location.capture('/visits')
local answ = cjson.decode(res.body)
if answ[1]==200 then
ngx.say(cjson.encode(answ[2]))
else
ngx.exit(answ[1])
end
}
}
if ($request_method = "POST") {
rewrite_by_lua_block {
local cjson = require("cjson")
local data = ngx.req.get_body_data()
local res = ngx.location.capture('/visits',{ method = ngx.HTTP_POST, body = data})
local answ = cjson.decode(res.body)
if answ[1]==200 then
ngx.say(cjson.encode(answ[2]))
else
ngx.exit(answ[1])
end
}
}
}
#-----------------------------------------locations
location = /locations {
internal;
tnt_http_rest_methods get post;
tnt_method locationEndpoint;
tnt_pass backend;
}
location = /locations/new {
rewrite_by_lua_block {
local cjson = require("cjson")
local data = ngx.req.get_body_data()
local res = ngx.location.capture('/locations',{ method = ngx.HTTP_POST, body = data})
local answ = cjson.decode(res.body)
if answ[1]==200 then
ngx.say(cjson.encode(answ[2]))
else
ngx.exit(answ[1])
end
}
}
location ~ /locations/(\d+) {
if ($request_method = "GET") {
rewrite_by_lua_block {
local cjson = require("cjson")
local res = ngx.location.capture('/locations',{args = ngx.var.args, method = ngx.HTTP_GET})
local answ = cjson.decode(res.body)
if answ[1]==200 then
ngx.say(cjson.encode(answ[2]))
else
ngx.exit(answ[1])
end
}
}
if ($request_method = "POST") {
rewrite_by_lua_block {
local cjson = require("cjson")
local data = ngx.req.get_body_data()
local res = ngx.location.capture('/locations',{ method = ngx.HTTP_POST, body = data})
local answ = cjson.decode(res.body)
if answ[1]==200 then
ngx.say(cjson.encode(answ[2]))
else
ngx.exit(answ[1])
end
}
}
}
}
}