feat(http-request/custom-request): utilize accept header for parsing response
This commit is contained in:
@@ -90,7 +90,7 @@ export default defineAction({
|
|||||||
|
|
||||||
async run($) {
|
async run($) {
|
||||||
const method = $.step.parameters.method;
|
const method = $.step.parameters.method;
|
||||||
const data = $.step.parameters.data;
|
const data = $.step.parameters.data || null;
|
||||||
const url = $.step.parameters.url;
|
const url = $.step.parameters.url;
|
||||||
const headers = $.step.parameters.headers;
|
const headers = $.step.parameters.headers;
|
||||||
|
|
||||||
@@ -108,14 +108,17 @@ export default defineAction({
|
|||||||
return result;
|
return result;
|
||||||
}, {});
|
}, {});
|
||||||
|
|
||||||
let contentType = headersObject['content-type'];
|
let expectedResponseContentType = headersObject.accept;
|
||||||
|
|
||||||
// in case HEAD request is not supported by the URL
|
// in case HEAD request is not supported by the URL
|
||||||
try {
|
try {
|
||||||
const metadataResponse = await $.http.head(url, {
|
const metadataResponse = await $.http.head(url, {
|
||||||
headers: headersObject,
|
headers: headersObject,
|
||||||
});
|
});
|
||||||
contentType = metadataResponse.headers['content-type'];
|
|
||||||
|
if (!expectedResponseContentType) {
|
||||||
|
expectedResponseContentType = metadataResponse.headers['content-type'];
|
||||||
|
}
|
||||||
|
|
||||||
throwIfFileSizeExceedsLimit(metadataResponse.headers['content-length']);
|
throwIfFileSizeExceedsLimit(metadataResponse.headers['content-length']);
|
||||||
// eslint-disable-next-line no-empty
|
// eslint-disable-next-line no-empty
|
||||||
@@ -128,7 +131,7 @@ export default defineAction({
|
|||||||
headers: headersObject,
|
headers: headersObject,
|
||||||
};
|
};
|
||||||
|
|
||||||
if (!isPossiblyTextBased(contentType)) {
|
if (!isPossiblyTextBased(expectedResponseContentType)) {
|
||||||
requestData.responseType = 'arraybuffer';
|
requestData.responseType = 'arraybuffer';
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -138,7 +141,7 @@ export default defineAction({
|
|||||||
|
|
||||||
let responseData = response.data;
|
let responseData = response.data;
|
||||||
|
|
||||||
if (!isPossiblyTextBased(contentType)) {
|
if (!isPossiblyTextBased(expectedResponseContentType)) {
|
||||||
responseData = Buffer.from(responseData).toString('base64');
|
responseData = Buffer.from(responseData).toString('base64');
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user