Remove executeSingle from ReadPdf node

This commit is contained in:
dali 2021-02-16 09:51:48 +01:00
parent 8d119852f6
commit b0664d2aa0

View file

@ -1,6 +1,6 @@
import { import {
BINARY_ENCODING, BINARY_ENCODING,
IExecuteSingleFunctions, IExecuteFunctions,
} from 'n8n-core'; } from 'n8n-core';
import { import {
@ -37,22 +37,30 @@ export class ReadPdf implements INodeType {
], ],
}; };
async execute(this: IExecuteFunctions): Promise<INodeExecutionData[][]> {
const items = this.getInputData();
async executeSingle(this: IExecuteSingleFunctions): Promise<INodeExecutionData> { const returnData: INodeExecutionData[] = [];
const length = items.length as unknown as number;
let item: INodeExecutionData;
const binaryPropertyName = this.getNodeParameter('binaryPropertyName') as string; for (let itemIndex = 0; itemIndex < length; itemIndex++) {
const item = this.getInputData(); item = items[itemIndex];
const binaryPropertyName = this.getNodeParameter('binaryPropertyName', itemIndex) as string;
if (item.binary === undefined) { if (item.binary === undefined) {
item.binary = {}; item.binary = {};
} }
const binaryData = Buffer.from(item.binary[binaryPropertyName].data, BINARY_ENCODING); const binaryData = Buffer.from(item.binary[binaryPropertyName].data, BINARY_ENCODING);
returnData.push({
return {
binary: item.binary, binary: item.binary,
json: await pdf(binaryData), json: await pdf(binaryData),
}; });
} }
return this.prepareOutputData(returnData);
}
} }