mirror of
https://github.com/peter-evans/dockerhub-description.git
synced 2024-11-22 20:19:33 +01:00
build: update distribution (#105)
Co-authored-by: actions-bot <actions-bot@users.noreply.github.com>
This commit is contained in:
parent
4e40b120de
commit
4b6b64d89b
1 changed files with 90 additions and 2 deletions
92
dist/index.js
vendored
92
dist/index.js
vendored
|
@ -3442,6 +3442,20 @@ const isDomainOrSubdomain = function isDomainOrSubdomain(destination, original)
|
||||||
return orig === dest || orig[orig.length - dest.length - 1] === '.' && orig.endsWith(dest);
|
return orig === dest || orig[orig.length - dest.length - 1] === '.' && orig.endsWith(dest);
|
||||||
};
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* isSameProtocol reports whether the two provided URLs use the same protocol.
|
||||||
|
*
|
||||||
|
* Both domains must already be in canonical form.
|
||||||
|
* @param {string|URL} original
|
||||||
|
* @param {string|URL} destination
|
||||||
|
*/
|
||||||
|
const isSameProtocol = function isSameProtocol(destination, original) {
|
||||||
|
const orig = new URL$1(original).protocol;
|
||||||
|
const dest = new URL$1(destination).protocol;
|
||||||
|
|
||||||
|
return orig === dest;
|
||||||
|
};
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Fetch function
|
* Fetch function
|
||||||
*
|
*
|
||||||
|
@ -3473,7 +3487,7 @@ function fetch(url, opts) {
|
||||||
let error = new AbortError('The user aborted a request.');
|
let error = new AbortError('The user aborted a request.');
|
||||||
reject(error);
|
reject(error);
|
||||||
if (request.body && request.body instanceof Stream.Readable) {
|
if (request.body && request.body instanceof Stream.Readable) {
|
||||||
request.body.destroy(error);
|
destroyStream(request.body, error);
|
||||||
}
|
}
|
||||||
if (!response || !response.body) return;
|
if (!response || !response.body) return;
|
||||||
response.body.emit('error', error);
|
response.body.emit('error', error);
|
||||||
|
@ -3514,9 +3528,41 @@ function fetch(url, opts) {
|
||||||
|
|
||||||
req.on('error', function (err) {
|
req.on('error', function (err) {
|
||||||
reject(new FetchError(`request to ${request.url} failed, reason: ${err.message}`, 'system', err));
|
reject(new FetchError(`request to ${request.url} failed, reason: ${err.message}`, 'system', err));
|
||||||
|
|
||||||
|
if (response && response.body) {
|
||||||
|
destroyStream(response.body, err);
|
||||||
|
}
|
||||||
|
|
||||||
finalize();
|
finalize();
|
||||||
});
|
});
|
||||||
|
|
||||||
|
fixResponseChunkedTransferBadEnding(req, function (err) {
|
||||||
|
if (signal && signal.aborted) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
destroyStream(response.body, err);
|
||||||
|
});
|
||||||
|
|
||||||
|
/* c8 ignore next 18 */
|
||||||
|
if (parseInt(process.version.substring(1)) < 14) {
|
||||||
|
// Before Node.js 14, pipeline() does not fully support async iterators and does not always
|
||||||
|
// properly handle when the socket close/end events are out of order.
|
||||||
|
req.on('socket', function (s) {
|
||||||
|
s.addListener('close', function (hadError) {
|
||||||
|
// if a data listener is still present we didn't end cleanly
|
||||||
|
const hasDataListener = s.listenerCount('data') > 0;
|
||||||
|
|
||||||
|
// if end happened before close but the socket didn't emit an error, do it now
|
||||||
|
if (response && hasDataListener && !hadError && !(signal && signal.aborted)) {
|
||||||
|
const err = new Error('Premature close');
|
||||||
|
err.code = 'ERR_STREAM_PREMATURE_CLOSE';
|
||||||
|
response.body.emit('error', err);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
req.on('response', function (res) {
|
req.on('response', function (res) {
|
||||||
clearTimeout(reqTimeout);
|
clearTimeout(reqTimeout);
|
||||||
|
|
||||||
|
@ -3588,7 +3634,7 @@ function fetch(url, opts) {
|
||||||
size: request.size
|
size: request.size
|
||||||
};
|
};
|
||||||
|
|
||||||
if (!isDomainOrSubdomain(request.url, locationURL)) {
|
if (!isDomainOrSubdomain(request.url, locationURL) || !isSameProtocol(request.url, locationURL)) {
|
||||||
for (const name of ['authorization', 'www-authenticate', 'cookie', 'cookie2']) {
|
for (const name of ['authorization', 'www-authenticate', 'cookie', 'cookie2']) {
|
||||||
requestOpts.headers.delete(name);
|
requestOpts.headers.delete(name);
|
||||||
}
|
}
|
||||||
|
@ -3681,6 +3727,13 @@ function fetch(url, opts) {
|
||||||
response = new Response(body, response_options);
|
response = new Response(body, response_options);
|
||||||
resolve(response);
|
resolve(response);
|
||||||
});
|
});
|
||||||
|
raw.on('end', function () {
|
||||||
|
// some old IIS servers return zero-length OK deflate responses, so 'data' is never emitted.
|
||||||
|
if (!response) {
|
||||||
|
response = new Response(body, response_options);
|
||||||
|
resolve(response);
|
||||||
|
}
|
||||||
|
});
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -3700,6 +3753,41 @@ function fetch(url, opts) {
|
||||||
writeToStream(req, request);
|
writeToStream(req, request);
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
function fixResponseChunkedTransferBadEnding(request, errorCallback) {
|
||||||
|
let socket;
|
||||||
|
|
||||||
|
request.on('socket', function (s) {
|
||||||
|
socket = s;
|
||||||
|
});
|
||||||
|
|
||||||
|
request.on('response', function (response) {
|
||||||
|
const headers = response.headers;
|
||||||
|
|
||||||
|
if (headers['transfer-encoding'] === 'chunked' && !headers['content-length']) {
|
||||||
|
response.once('close', function (hadError) {
|
||||||
|
// if a data listener is still present we didn't end cleanly
|
||||||
|
const hasDataListener = socket.listenerCount('data') > 0;
|
||||||
|
|
||||||
|
if (hasDataListener && !hadError) {
|
||||||
|
const err = new Error('Premature close');
|
||||||
|
err.code = 'ERR_STREAM_PREMATURE_CLOSE';
|
||||||
|
errorCallback(err);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
function destroyStream(stream, err) {
|
||||||
|
if (stream.destroy) {
|
||||||
|
stream.destroy(err);
|
||||||
|
} else {
|
||||||
|
// node < 8
|
||||||
|
stream.emit('error', err);
|
||||||
|
stream.end();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Redirect code matching
|
* Redirect code matching
|
||||||
*
|
*
|
||||||
|
|
Loading…
Reference in a new issue