@@ -133,6 +133,10 @@ def wrapper(*args, **kwargs):
133
133
134
134
store = storage .load ()
135
135
136
+ headers = source_resp .headers
137
+ if 'Content-Encoding' in headers :
138
+ del headers ['Content-Encoding' ]
139
+
136
140
if not stream :
137
141
logger .debug ('JSON data found on source, writing response' )
138
142
resp_data = source_resp .content
@@ -143,19 +147,20 @@ def wrapper(*args, **kwargs):
143
147
)
144
148
return toolkit .response (
145
149
data = resp_data ,
146
- headers = source_resp . headers ,
150
+ headers = headers ,
147
151
raw = True
148
152
)
149
153
logger .debug ('Layer data found on source, preparing to '
150
154
'stream response...' )
151
155
layer_path = store .image_layer_path (kwargs ['image_id' ])
152
- return _handle_mirrored_layer (source_resp , layer_path , store )
156
+ return _handle_mirrored_layer (source_resp , layer_path , store ,
157
+ headers )
153
158
154
159
return wrapper
155
160
return decorator
156
161
157
162
158
- def _handle_mirrored_layer (source_resp , layer_path , store ):
163
+ def _handle_mirrored_layer (source_resp , layer_path , store , headers ):
159
164
sr = toolkit .SocketReader (source_resp )
160
165
tmp , hndlr = storage .temp_store_handler ()
161
166
sr .add_handler (hndlr )
@@ -167,7 +172,7 @@ def generate():
167
172
tmp .seek (0 )
168
173
store .stream_write (layer_path , tmp )
169
174
tmp .close ()
170
- return flask .Response (generate (), headers = source_resp . headers )
175
+ return flask .Response (generate (), headers = headers )
171
176
172
177
173
178
def store_mirrored_data (data , endpoint , args , store ):
0 commit comments