Security: Sync from Public / sync-from-public (push) Has been cancelled
Test: Benchmark Nightly / build (push) Has been cancelled
Test: Benchmark Nightly / Notify Cats on failure (push) Has been cancelled
CI: Python / Checks (push) Has been cancelled
Test: Evals Python / Workflow Comparison Python (push) Has been cancelled
Util: Check Docs URLs / check-docs-urls (push) Has been cancelled
Test: Visual Storybook / Cloudflare Pages (push) Has been cancelled
Test: E2E Performance / build-and-test-performance (push) Has been cancelled
Test: Workflows Nightly / Run Workflow Tests (push) Has been cancelled
Util: Cleanup CI Docker Images / Delete stale CI images (push) Has been cancelled
Test: Benchmark Destroy Env / build (push) Has been cancelled
Util: Update Node Popularity / update-popularity (push) Has been cancelled
Test: E2E Coverage Weekly / Coverage Tests (push) Has been cancelled
31 lines
995 B
TypeScript
31 lines
995 B
TypeScript
import type { IBinaryData, IDataObject, IN8nHttpResponse } from 'n8n-workflow';
|
|
import { BINARY_ENCODING } from 'n8n-workflow';
|
|
import type { Readable } from 'stream';
|
|
|
|
const setContentLength = (responseBody: IN8nHttpResponse | Readable, headers: IDataObject) => {
|
|
if (Buffer.isBuffer(responseBody)) {
|
|
headers['content-length'] = responseBody.length;
|
|
} else if (typeof responseBody === 'string') {
|
|
headers['content-length'] = Buffer.byteLength(responseBody, 'utf8');
|
|
}
|
|
};
|
|
|
|
/**
|
|
* Returns a response body for a binary data and sets the content-type header.
|
|
*/
|
|
export const getBinaryResponse = (binaryData: IBinaryData, headers: IDataObject) => {
|
|
let responseBody: IN8nHttpResponse | Readable;
|
|
|
|
if (binaryData.id) {
|
|
responseBody = { binaryData };
|
|
} else {
|
|
const responseBuffer = Buffer.from(binaryData.data, BINARY_ENCODING);
|
|
responseBody = responseBuffer;
|
|
setContentLength(responseBody, headers);
|
|
}
|
|
|
|
headers['content-type'] ??= binaryData.mimeType;
|
|
|
|
return responseBody;
|
|
};
|