|
0
|
1
|
|
|
2 /*
|
|
|
3 * Copyright (C) Igor Sysoev
|
|
|
4 */
|
|
|
5
|
|
|
6
|
|
|
7 #include <ngx_config.h>
|
|
|
8 #include <ngx_core.h>
|
|
|
9 #include <ngx_http.h>
|
|
|
10 #include <ngx_http_proxy_handler.h>
|
|
|
11
|
|
|
12
|
|
|
13 static int ngx_http_proxy_rewrite_location_header(ngx_http_proxy_ctx_t *p,
|
|
|
14 ngx_table_elt_t *loc);
|
|
|
15
|
|
|
16 int ngx_http_proxy_copy_header(ngx_http_proxy_ctx_t *p,
|
|
|
17 ngx_http_proxy_headers_in_t *headers_in)
|
|
|
18 {
|
|
|
19 ngx_uint_t i;
|
|
|
20 ngx_list_part_t *part;
|
|
|
21 ngx_table_elt_t *ho, *h;
|
|
|
22 ngx_http_request_t *r;
|
|
|
23
|
|
|
24 r = p->request;
|
|
|
25
|
|
|
26 part = &headers_in->headers.part;
|
|
|
27 h = part->elts;
|
|
|
28
|
|
|
29 #if 0
|
|
|
30 h = headers_in->headers.elts;
|
|
|
31 for (i = 0; i < headers_in->headers.nelts; i++) {
|
|
|
32 #endif
|
|
|
33
|
|
|
34 for (i = 0 ; /* void */; i++) {
|
|
|
35
|
|
|
36 if (i >= part->nelts) {
|
|
|
37 if (part->next == NULL) {
|
|
|
38 break;
|
|
|
39 }
|
|
|
40
|
|
|
41 part = part->next;
|
|
|
42 h = part->elts;
|
|
|
43 i = 0;
|
|
|
44 }
|
|
|
45
|
|
|
46 /* ignore some headers */
|
|
|
47
|
|
|
48 if (&h[i] == headers_in->connection) {
|
|
|
49 continue;
|
|
|
50 }
|
|
|
51
|
|
|
52 if (&h[i] == headers_in->x_pad) {
|
|
|
53 continue;
|
|
|
54 }
|
|
|
55
|
|
|
56 if (p->accel) {
|
|
|
57 if (&h[i] == headers_in->date
|
|
|
58 || &h[i] == headers_in->accept_ranges) {
|
|
|
59 continue;
|
|
|
60 }
|
|
|
61
|
|
|
62 if (&h[i] == headers_in->x_accel_expires
|
|
|
63 && !p->lcf->pass_x_accel_expires)
|
|
|
64 {
|
|
|
65 continue;
|
|
|
66 }
|
|
|
67
|
|
|
68 if (&h[i] == headers_in->server && !p->lcf->pass_server) {
|
|
|
69 continue;
|
|
|
70 }
|
|
|
71
|
|
|
72 if (&h[i] == headers_in->location) {
|
|
|
73 if (ngx_http_proxy_rewrite_location_header(p, &h[i])
|
|
|
74 == NGX_ERROR)
|
|
|
75 {
|
|
|
76 return NGX_ERROR;
|
|
|
77 }
|
|
|
78
|
|
|
79 continue;
|
|
|
80 }
|
|
|
81 }
|
|
|
82
|
|
|
83
|
|
|
84 /* "Content-Type" is handled specially */
|
|
|
85
|
|
|
86 if (&h[i] == headers_in->content_type) {
|
|
|
87 r->headers_out.content_type = &h[i];
|
|
|
88 r->headers_out.content_type->key.len = 0;
|
|
|
89 continue;
|
|
|
90 }
|
|
|
91
|
|
|
92
|
|
|
93 /* copy some header pointers and set up r->headers_out */
|
|
|
94
|
|
|
95 if (!(ho = ngx_list_push(&r->headers_out.headers))) {
|
|
|
96 return NGX_ERROR;
|
|
|
97 }
|
|
|
98
|
|
|
99 *ho = h[i];
|
|
|
100
|
|
|
101 if (&h[i] == headers_in->expires) {
|
|
|
102 r->headers_out.expires = ho;
|
|
|
103 continue;
|
|
|
104 }
|
|
|
105
|
|
|
106 if (&h[i] == headers_in->cache_control) {
|
|
|
107 r->headers_out.cache_control = ho;
|
|
|
108 continue;
|
|
|
109 }
|
|
|
110
|
|
|
111 if (&h[i] == headers_in->etag) {
|
|
|
112 r->headers_out.etag = ho;
|
|
|
113 continue;
|
|
|
114 }
|
|
|
115
|
|
4
|
116 if (&h[i] == headers_in->content_encoding) {
|
|
|
117 r->headers_out.content_encoding = ho;
|
|
|
118 continue;
|
|
|
119 }
|
|
|
120
|
|
0
|
121 if (&h[i] == headers_in->last_modified) {
|
|
|
122 r->headers_out.last_modified = ho;
|
|
|
123 /* TODO: update r->headers_out.last_modified_time */
|
|
|
124 continue;
|
|
|
125 }
|
|
|
126
|
|
|
127 /*
|
|
|
128 * ngx_http_header_filter() passes the following headers as is
|
|
|
129 * and does not handle them specially if they are set:
|
|
|
130 * r->headers_out.server,
|
|
|
131 * r->headers_out.date,
|
|
|
132 * r->headers_out.content_length
|
|
|
133 */
|
|
|
134
|
|
|
135 if (&h[i] == headers_in->server) {
|
|
|
136 r->headers_out.server = ho;
|
|
|
137 continue;
|
|
|
138 }
|
|
|
139
|
|
|
140 if (&h[i] == headers_in->date) {
|
|
|
141 r->headers_out.date = ho;
|
|
|
142 continue;
|
|
|
143 }
|
|
|
144
|
|
|
145 if (&h[i] == headers_in->content_length) {
|
|
|
146 r->headers_out.content_length = ho;
|
|
|
147 r->headers_out.content_length_n = ngx_atoi(ho->value.data,
|
|
|
148 ho->value.len);
|
|
|
149 continue;
|
|
|
150 }
|
|
|
151 }
|
|
|
152
|
|
|
153 return NGX_OK;
|
|
|
154 }
|
|
|
155
|
|
|
156
|
|
|
157 static int ngx_http_proxy_rewrite_location_header(ngx_http_proxy_ctx_t *p,
|
|
|
158 ngx_table_elt_t *loc)
|
|
|
159 {
|
|
|
160 u_char *last;
|
|
|
161 ngx_table_elt_t *location;
|
|
|
162 ngx_http_request_t *r;
|
|
|
163 ngx_http_proxy_upstream_conf_t *uc;
|
|
|
164
|
|
|
165 r = p->request;
|
|
|
166 uc = p->lcf->upstream;
|
|
|
167
|
|
|
168 if (!(location = ngx_list_push(&r->headers_out.headers))) {
|
|
|
169 return NGX_ERROR;
|
|
|
170 }
|
|
|
171
|
|
|
172 if (uc->url.len > loc->value.len
|
|
|
173 || ngx_rstrncmp(loc->value.data, uc->url.data, uc->url.len) != 0)
|
|
|
174 {
|
|
2
|
175
|
|
|
176 /*
|
|
|
177 * we do not set r->headers_out.location here to avoid the handling
|
|
|
178 * the local redirects without a host name by ngx_http_header_filter()
|
|
|
179 */
|
|
|
180
|
|
0
|
181 *location = *loc;
|
|
|
182 return NGX_OK;
|
|
|
183 }
|
|
|
184
|
|
|
185 /* TODO: proxy_reverse */
|
|
|
186
|
|
2
|
187 r->headers_out.location = location;
|
|
|
188
|
|
|
189 location->key.len = 0;
|
|
|
190 location->key.data = NULL;
|
|
|
191
|
|
0
|
192 location->value.len = uc->location->len
|
|
|
193 + (loc->value.len - uc->url.len) + 1;
|
|
|
194 if (!(location->value.data = ngx_palloc(r->pool, location->value.len))) {
|
|
|
195 return NGX_ERROR;
|
|
|
196 }
|
|
|
197
|
|
|
198 last = ngx_cpymem(location->value.data,
|
|
|
199 uc->location->data, uc->location->len);
|
|
|
200
|
|
|
201 ngx_cpystrn(last, loc->value.data + uc->url.len,
|
|
|
202 loc->value.len - uc->url.len + 1);
|
|
|
203
|
|
|
204 return NGX_OK;
|
|
|
205 }
|
