|
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
|
|
28
|
29 for (i = 0; /* void */; i++) {
|
|
0
|
30
|
|
|
31 if (i >= part->nelts) {
|
|
|
32 if (part->next == NULL) {
|
|
|
33 break;
|
|
|
34 }
|
|
|
35
|
|
|
36 part = part->next;
|
|
|
37 h = part->elts;
|
|
|
38 i = 0;
|
|
|
39 }
|
|
|
40
|
|
|
41 /* ignore some headers */
|
|
|
42
|
|
|
43 if (&h[i] == headers_in->connection) {
|
|
|
44 continue;
|
|
|
45 }
|
|
|
46
|
|
|
47 if (&h[i] == headers_in->x_pad) {
|
|
|
48 continue;
|
|
|
49 }
|
|
|
50
|
|
|
51 if (p->accel) {
|
|
|
52 if (&h[i] == headers_in->date
|
|
|
53 || &h[i] == headers_in->accept_ranges) {
|
|
|
54 continue;
|
|
|
55 }
|
|
|
56
|
|
|
57 if (&h[i] == headers_in->x_accel_expires
|
|
|
58 && !p->lcf->pass_x_accel_expires)
|
|
|
59 {
|
|
|
60 continue;
|
|
|
61 }
|
|
|
62
|
|
|
63 if (&h[i] == headers_in->server && !p->lcf->pass_server) {
|
|
|
64 continue;
|
|
|
65 }
|
|
|
66
|
|
|
67 if (&h[i] == headers_in->location) {
|
|
|
68 if (ngx_http_proxy_rewrite_location_header(p, &h[i])
|
|
|
69 == NGX_ERROR)
|
|
|
70 {
|
|
|
71 return NGX_ERROR;
|
|
|
72 }
|
|
|
73
|
|
|
74 continue;
|
|
|
75 }
|
|
|
76 }
|
|
|
77
|
|
|
78
|
|
|
79 /* "Content-Type" is handled specially */
|
|
|
80
|
|
|
81 if (&h[i] == headers_in->content_type) {
|
|
|
82 r->headers_out.content_type = &h[i];
|
|
|
83 r->headers_out.content_type->key.len = 0;
|
|
|
84 continue;
|
|
|
85 }
|
|
|
86
|
|
|
87
|
|
|
88 /* copy some header pointers and set up r->headers_out */
|
|
|
89
|
|
50
|
90 ho = ngx_list_push(&r->headers_out.headers);
|
|
|
91 if (ho == NULL) {
|
|
0
|
92 return NGX_ERROR;
|
|
|
93 }
|
|
|
94
|
|
|
95 *ho = h[i];
|
|
|
96
|
|
|
97 if (&h[i] == headers_in->expires) {
|
|
|
98 r->headers_out.expires = ho;
|
|
|
99 continue;
|
|
|
100 }
|
|
|
101
|
|
|
102 if (&h[i] == headers_in->cache_control) {
|
|
|
103 r->headers_out.cache_control = ho;
|
|
|
104 continue;
|
|
|
105 }
|
|
|
106
|
|
|
107 if (&h[i] == headers_in->etag) {
|
|
|
108 r->headers_out.etag = ho;
|
|
|
109 continue;
|
|
|
110 }
|
|
|
111
|
|
28
|
112 #if (NGX_HTTP_GZIP)
|
|
4
|
113 if (&h[i] == headers_in->content_encoding) {
|
|
|
114 r->headers_out.content_encoding = ho;
|
|
|
115 continue;
|
|
|
116 }
|
|
28
|
117 #endif
|
|
4
|
118
|
|
0
|
119 if (&h[i] == headers_in->last_modified) {
|
|
|
120 r->headers_out.last_modified = ho;
|
|
|
121 /* TODO: update r->headers_out.last_modified_time */
|
|
|
122 continue;
|
|
|
123 }
|
|
|
124
|
|
|
125 /*
|
|
|
126 * ngx_http_header_filter() passes the following headers as is
|
|
|
127 * and does not handle them specially if they are set:
|
|
|
128 * r->headers_out.server,
|
|
|
129 * r->headers_out.date,
|
|
|
130 * r->headers_out.content_length
|
|
|
131 */
|
|
|
132
|
|
|
133 if (&h[i] == headers_in->server) {
|
|
|
134 r->headers_out.server = ho;
|
|
|
135 continue;
|
|
|
136 }
|
|
|
137
|
|
|
138 if (&h[i] == headers_in->date) {
|
|
|
139 r->headers_out.date = ho;
|
|
|
140 continue;
|
|
|
141 }
|
|
|
142
|
|
|
143 if (&h[i] == headers_in->content_length) {
|
|
|
144 r->headers_out.content_length = ho;
|
|
|
145 r->headers_out.content_length_n = ngx_atoi(ho->value.data,
|
|
|
146 ho->value.len);
|
|
|
147 continue;
|
|
|
148 }
|
|
|
149 }
|
|
|
150
|
|
|
151 return NGX_OK;
|
|
|
152 }
|
|
|
153
|
|
|
154
|
|
|
155 static int ngx_http_proxy_rewrite_location_header(ngx_http_proxy_ctx_t *p,
|
|
|
156 ngx_table_elt_t *loc)
|
|
|
157 {
|
|
|
158 u_char *last;
|
|
|
159 ngx_table_elt_t *location;
|
|
|
160 ngx_http_request_t *r;
|
|
|
161 ngx_http_proxy_upstream_conf_t *uc;
|
|
|
162
|
|
|
163 r = p->request;
|
|
|
164 uc = p->lcf->upstream;
|
|
|
165
|
|
50
|
166 location = ngx_list_push(&r->headers_out.headers);
|
|
|
167 if (location == NULL) {
|
|
0
|
168 return NGX_ERROR;
|
|
|
169 }
|
|
|
170
|
|
28
|
171 if (p->lcf->preserve_host
|
|
|
172 || uc->url.len > loc->value.len
|
|
0
|
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;
|
|
50
|
194 location->value.data = ngx_palloc(r->pool, location->value.len);
|
|
|
195 if (location->value.data == NULL) {
|
|
0
|
196 return NGX_ERROR;
|
|
|
197 }
|
|
|
198
|
|
|
199 last = ngx_cpymem(location->value.data,
|
|
|
200 uc->location->data, uc->location->len);
|
|
|
201
|
|
|
202 ngx_cpystrn(last, loc->value.data + uc->url.len,
|
|
|
203 loc->value.len - uc->url.len + 1);
|
|
|
204
|
|
|
205 return NGX_OK;
|
|
|
206 }
|
