1 | 'use strict';
|
2 |
|
3 | const http = require('http');
|
4 | const https = require('https');
|
5 | const url = require('url');
|
6 |
|
7 | const requiredHeaders = {
|
8 | 'accept-encoding': 'gzip, deflate'
|
9 | };
|
10 |
|
11 |
|
12 |
|
13 |
|
14 |
|
15 |
|
16 |
|
17 |
|
18 |
|
19 |
|
20 |
|
21 |
|
22 | module.exports = filterHeaders => (fragmentUrl, fragmentAttributes, request) =>
|
23 | new Promise((resolve, reject) => {
|
24 | const parsedUrl = url.parse(fragmentUrl);
|
25 | const options = Object.assign(
|
26 | {
|
27 | headers: Object.assign(
|
28 | filterHeaders(fragmentAttributes, request),
|
29 | requiredHeaders
|
30 | ),
|
31 | keepAlive: true,
|
32 | timeout: fragmentAttributes.timeout
|
33 | },
|
34 | parsedUrl
|
35 | );
|
36 | const { protocol: reqProtocol, timeout } = options;
|
37 | const protocol = reqProtocol === 'https:' ? https : http;
|
38 | const fragmentRequest = protocol.request(options);
|
39 | if (timeout) {
|
40 | fragmentRequest.setTimeout(timeout, fragmentRequest.abort);
|
41 | }
|
42 | fragmentRequest.on('response', response => {
|
43 | if (response.statusCode >= 500) {
|
44 | reject(new Error('Internal Server Error'));
|
45 | } else {
|
46 | resolve(response);
|
47 | }
|
48 | });
|
49 | fragmentRequest.on('error', reject);
|
50 | fragmentRequest.end();
|
51 | });
|