|
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
|
|
|
90 if (!(ho = ngx_list_push(&r->headers_out.headers))) {
|
|
|
91 return NGX_ERROR;
|
|
|
92 }
|
|
|
93
|
|
|
94 *ho = h[i];
|
|
|
95
|
|
|
96 if (&h[i] == headers_in->expires) {
|
|
|
97 r->headers_out.expires = ho;
|
|
|
98 continue;
|
|
|
99 }
|
|
|
100
|
|
|
101 if (&h[i] == headers_in->cache_control) {
|
|
|
102 r->headers_out.cache_control = ho;
|
|
|
103 continue;
|
|
|
104 }
|
|
|
105
|
|
|
106 if (&h[i] == headers_in->etag) {
|
|
|
107 r->headers_out.etag = ho;
|
|
|
108 continue;
|
|
|
109 }
|
|
|
110
|
|
28
|
111 #if (NGX_HTTP_GZIP)
|
|
4
|
112 if (&h[i] == headers_in->content_encoding) {
|
|
|
113 r->headers_out.content_encoding = ho;
|
|
|
114 continue;
|
|
|
115 }
|
|
28
|
116 #endif
|
|
4
|
117
|
|
0
|
118 if (&h[i] == headers_in->last_modified) {
|
|
|
119 r->headers_out.last_modified = ho;
|
|
|
120 /* TODO: update r->headers_out.last_modified_time */
|
|
|
121 continue;
|
|
|
122 }
|
|
|
123
|
|
|
124 /*
|
|
|
125 * ngx_http_header_filter() passes the following headers as is
|
|
|
126 * and does not handle them specially if they are set:
|
|
|
127 * r->headers_out.server,
|
|
|
128 * r->headers_out.date,
|
|
|
129 * r->headers_out.content_length
|
|
|
130 */
|
|
|
131
|
|
|
132 if (&h[i] == headers_in->server) {
|
|
|
133 r->headers_out.server = ho;
|
|
|
134 continue;
|
|
|
135 }
|
|
|
136
|
|
|
137 if (&h[i] == headers_in->date) {
|
|
|
138 r->headers_out.date = ho;
|
|
|
139 continue;
|
|
|
140 }
|
|
|
141
|
|
|
142 if (&h[i] == headers_in->content_length) {
|
|
|
143 r->headers_out.content_length = ho;
|
|
|
144 r->headers_out.content_length_n = ngx_atoi(ho->value.data,
|
|
|
145 ho->value.len);
|
|
|
146 continue;
|
|
|
147 }
|
|
|
148 }
|
|
|
149
|
|
|
150 return NGX_OK;
|
|
|
151 }
|
|
|
152
|
|
|
153
|
|
|
154 static int ngx_http_proxy_rewrite_location_header(ngx_http_proxy_ctx_t *p,
|
|
|
155 ngx_table_elt_t *loc)
|
|
|
156 {
|
|
|
157 u_char *last;
|
|
|
158 ngx_table_elt_t *location;
|
|
|
159 ngx_http_request_t *r;
|
|
|
160 ngx_http_proxy_upstream_conf_t *uc;
|
|
|
161
|
|
|
162 r = p->request;
|
|
|
163 uc = p->lcf->upstream;
|
|
|
164
|
|
|
165 if (!(location = ngx_list_push(&r->headers_out.headers))) {
|
|
|
166 return NGX_ERROR;
|
|
|
167 }
|
|
|
168
|
|
28
|
169 if (p->lcf->preserve_host
|
|
|
170 || uc->url.len > loc->value.len
|
|
0
|
171 || ngx_rstrncmp(loc->value.data, uc->url.data, uc->url.len) != 0)
|
|
|
172 {
|
|
2
|
173
|
|
|
174 /*
|
|
|
175 * we do not set r->headers_out.location here to avoid the handling
|
|
|
176 * the local redirects without a host name by ngx_http_header_filter()
|
|
|
177 */
|
|
|
178
|
|
0
|
179 *location = *loc;
|
|
|
180 return NGX_OK;
|
|
|
181 }
|
|
|
182
|
|
|
183 /* TODO: proxy_reverse */
|
|
|
184
|
|
2
|
185 r->headers_out.location = location;
|
|
|
186
|
|
|
187 location->key.len = 0;
|
|
|
188 location->key.data = NULL;
|
|
|
189
|
|
0
|
190 location->value.len = uc->location->len
|
|
|
191 + (loc->value.len - uc->url.len) + 1;
|
|
|
192 if (!(location->value.data = ngx_palloc(r->pool, location->value.len))) {
|
|
|
193 return NGX_ERROR;
|
|
|
194 }
|
|
|
195
|
|
|
196 last = ngx_cpymem(location->value.data,
|
|
|
197 uc->location->data, uc->location->len);
|
|
|
198
|
|
|
199 ngx_cpystrn(last, loc->value.data + uc->url.len,
|
|
|
200 loc->value.len - uc->url.len + 1);
|
|
|
201
|
|
|
202 return NGX_OK;
|
|
|
203 }
|
