mudhorn/n8n
1
0
Fork 0
mirror of https://github.com/n8n-io/n8n.git synced 2025-03-05 20:50:17 -08:00
Code Issues Actions Packages Projects Releases Wiki Activity

🔀 Merge branch 'Remove-executeSingle' of https://github.com/MedAliMarz/n8n into MedAliMarz-Remove-executeSingle

Browse source
This commit is contained in:
Jan Oberhauser 2021-03-29 11:11:03 +02:00
parent 2ee5853bd0 3ec3f908e8
commit e48f555f07
7 changed files with 591 additions and 520 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

34
packages/nodes-base/nodes/EditImage.node.ts
View file

@ -1,6 +1,6 @@
import { import {
BINARY_ENCODING, BINARY_ENCODING,
IExecuteSingleFunctions, IExecuteFunctions,
} from 'n8n-core'; } from 'n8n-core';
import { import {
IDataObject, IDataObject,
@ -948,14 +948,21 @@ export class EditImage implements INodeType {
}, },
}; };
async execute(this: IExecuteFunctions): Promise<INodeExecutionData[][]> {
const items = this.getInputData();
async executeSingle(this: IExecuteSingleFunctions): Promise<INodeExecutionData> { const returnData: INodeExecutionData[] = [];
const item = this.getInputData(); const length = items.length as unknown as number;
let item: INodeExecutionData;
const operation = this.getNodeParameter('operation', 0) as string; for (let itemIndex = 0; itemIndex < length; itemIndex++) {
const dataPropertyName = this.getNodeParameter('dataPropertyName') as string; item = items[itemIndex];
const options = this.getNodeParameter('options', {}) as IDataObject;
const operation = this.getNodeParameter('operation', itemIndex) as string;
const dataPropertyName = this.getNodeParameter('dataPropertyName', itemIndex) as string;
const options = this.getNodeParameter('options', itemIndex,{}) as IDataObject;
const cleanupFunctions: Array<() => void> = []; const cleanupFunctions: Array<() => void> = [];
@ -1026,14 +1033,14 @@ export class EditImage implements INodeType {
let operations: IDataObject[] = []; let operations: IDataObject[] = [];
if (operation === 'multiStep') { if (operation === 'multiStep') {
// Operation parameters are already in the correct format // Operation parameters are already in the correct format
const operationsData = this.getNodeParameter('operations', { operations: [] }) as IDataObject; const operationsData = this.getNodeParameter('operations', itemIndex ,{ operations: [] }) as IDataObject;
operations = operationsData.operations as IDataObject[]; operations = operationsData.operations as IDataObject[];
} else { } else {
// Operation parameters have to first get collected // Operation parameters have to first get collected
const operationParameters: IDataObject = {}; const operationParameters: IDataObject = {};
requiredOperationParameters[operation].forEach(parameterName => { requiredOperationParameters[operation].forEach(parameterName => {
try { try {
operationParameters[parameterName] = this.getNodeParameter(parameterName); operationParameters[parameterName] = this.getNodeParameter(parameterName, itemIndex);
} catch (e) {} } catch (e) {}
}); });
@ -1062,7 +1069,7 @@ export class EditImage implements INodeType {
if (operation === 'information') { if (operation === 'information') {
// Just return the information // Just return the information
const imageData = await new Promise<IDataObject>((resolve, reject) => { const imageData = await new Promise<IDataObject>((resolve, reject) => {
gmInstance = gmInstance.identify((error, imageData) => { gmInstance = gmInstance.identify((error:any, imageData:any) => {
if (error) { if (error) {
reject(error); reject(error);
return; return;
@ -1072,7 +1079,7 @@ export class EditImage implements INodeType {
}); });
item.json = imageData; item.json = imageData;
return item; returnData.push(item);
} }
for (let i = 0; i < operations.length; i++) { for (let i = 0; i < operations.length; i++) {
@ -1220,7 +1227,7 @@ export class EditImage implements INodeType {
newItem.binary![dataPropertyName as string].fileName = options.fileName as string; newItem.binary![dataPropertyName as string].fileName = options.fileName as string;
} }
return new Promise<INodeExecutionData>((resolve, reject) => { returnData.push(await (new Promise<INodeExecutionData>((resolve, reject) => {
gmInstance gmInstance
.toBuffer((error: Error | null, buffer: Buffer) => { .toBuffer((error: Error | null, buffer: Buffer) => {
cleanupFunctions.forEach(async cleanup => await cleanup()); cleanupFunctions.forEach(async cleanup => await cleanup());
@ -1233,6 +1240,9 @@ export class EditImage implements INodeType {
return resolve(newItem); return resolve(newItem);
}); });
}); })));
}
return this.prepareOutputData(returnData);
} }
} }

37
packages/nodes-base/nodes/EmailSend.node.ts
View file

@ -1,6 +1,6 @@
import { import {
BINARY_ENCODING, BINARY_ENCODING,
IExecuteSingleFunctions, IExecuteFunctions
} from 'n8n-core'; } from 'n8n-core';
import { import {
IDataObject, IDataObject,
@ -124,18 +124,26 @@ export class EmailSend implements INodeType {
}; };
async executeSingle(this: IExecuteSingleFunctions): Promise<INodeExecutionData> { async execute(this: IExecuteFunctions): Promise<INodeExecutionData[][]> {
const item = this.getInputData(); const items = this.getInputData();
const fromEmail = this.getNodeParameter('fromEmail') as string; const returnData: INodeExecutionData[] = [];
const toEmail = this.getNodeParameter('toEmail') as string; const length = items.length as unknown as number;
const ccEmail = this.getNodeParameter('ccEmail') as string; let item: INodeExecutionData;
const bccEmail = this.getNodeParameter('bccEmail') as string;
const subject = this.getNodeParameter('subject') as string; for (let itemIndex = 0; itemIndex < length; itemIndex++) {
const text = this.getNodeParameter('text') as string;
const html = this.getNodeParameter('html') as string; item = items[itemIndex];
const attachmentPropertyString = this.getNodeParameter('attachments') as string;
const options = this.getNodeParameter('options', {}) as IDataObject; const fromEmail = this.getNodeParameter('fromEmail', itemIndex) as string;
const toEmail = this.getNodeParameter('toEmail', itemIndex) as string;
const ccEmail = this.getNodeParameter('ccEmail', itemIndex) as string;
const bccEmail = this.getNodeParameter('bccEmail', itemIndex) as string;
const subject = this.getNodeParameter('subject', itemIndex) as string;
const text = this.getNodeParameter('text', itemIndex) as string;
const html = this.getNodeParameter('html', itemIndex) as string;
const attachmentPropertyString = this.getNodeParameter('attachments', itemIndex) as string;
const options = this.getNodeParameter('options', itemIndex, {}) as IDataObject;
const credentials = this.getCredentials('smtp'); const credentials = this.getCredentials('smtp');
@ -201,7 +209,10 @@ export class EmailSend implements INodeType {
// Send the email // Send the email
const info = await transporter.sendMail(mailOptions); const info = await transporter.sendMail(mailOptions);
return { json: info }; returnData.push({ json: info });
}
return this.prepareOutputData(returnData);
} }
} }

22
packages/nodes-base/nodes/FunctionItem.node.ts
View file

@ -1,4 +1,4 @@
import { IExecuteSingleFunctions } from 'n8n-core'; import { IExecuteFunctions } from 'n8n-core';
import { import {
IBinaryKeyData, IBinaryKeyData,
IDataObject, IDataObject,
@ -40,8 +40,16 @@ export class FunctionItem implements INodeType {
], ],
}; };
async executeSingle(this: IExecuteSingleFunctions): Promise<INodeExecutionData> { async execute(this: IExecuteFunctions): Promise<INodeExecutionData[][]> {
let item = this.getInputData(); const items = this.getInputData();
const returnData: INodeExecutionData[] = [];
const length = items.length as unknown as number;
let item: INodeExecutionData;
for (let itemIndex = 0; itemIndex < length; itemIndex++) {
item = items[itemIndex];
// Copy the items as they may get changed in the functions // Copy the items as they may get changed in the functions
item = JSON.parse(JSON.stringify(item)); item = JSON.parse(JSON.stringify(item));
@ -61,7 +69,7 @@ export class FunctionItem implements INodeType {
}; };
// Make it possible to access data via $node, $parameter, ... // Make it possible to access data via $node, $parameter, ...
const dataProxy = this.getWorkflowDataProxy(); const dataProxy = this.getWorkflowDataProxy(itemIndex);
Object.assign(sandbox, dataProxy); Object.assign(sandbox, dataProxy);
const options = { const options = {
@ -84,7 +92,7 @@ export class FunctionItem implements INodeType {
const vm = new NodeVM(options); const vm = new NodeVM(options);
// Get the code to execute // Get the code to execute
const functionCode = this.getNodeParameter('functionCode') as string; const functionCode = this.getNodeParameter('functionCode', itemIndex) as string;
let jsonData: IDataObject; let jsonData: IDataObject;
@ -108,6 +116,8 @@ export class FunctionItem implements INodeType {
returnItem.binary = item.binary; returnItem.binary = item.binary;
} }
return returnItem; returnData.push(returnItem);
}
return this.prepareOutputData(returnData);
} }
} }

35
packages/nodes-base/nodes/Mailgun/Mailgun.node.ts
View file

@ -1,6 +1,6 @@
import { import {
BINARY_ENCODING, BINARY_ENCODING,
IExecuteSingleFunctions, IExecuteFunctions,
} from 'n8n-core'; } from 'n8n-core';
import { import {
IDataObject, IDataObject,
@ -105,17 +105,24 @@ export class Mailgun implements INodeType {
}; };
async executeSingle(this: IExecuteSingleFunctions): Promise<INodeExecutionData> { async execute(this: IExecuteFunctions): Promise<INodeExecutionData[][]> {
const item = this.getInputData(); const items = this.getInputData();
const fromEmail = this.getNodeParameter('fromEmail') as string; const returnData: INodeExecutionData[] = [];
const toEmail = this.getNodeParameter('toEmail') as string; const length = items.length as unknown as number;
const ccEmail = this.getNodeParameter('ccEmail') as string; let item: INodeExecutionData;
const bccEmail = this.getNodeParameter('bccEmail') as string;
const subject = this.getNodeParameter('subject') as string; for (let itemIndex = 0; itemIndex < length; itemIndex++) {
const text = this.getNodeParameter('text') as string; item = items[itemIndex];
const html = this.getNodeParameter('html') as string;
const attachmentPropertyString = this.getNodeParameter('attachments') as string; const fromEmail = this.getNodeParameter('fromEmail', itemIndex) as string;
const toEmail = this.getNodeParameter('toEmail', itemIndex) as string;
const ccEmail = this.getNodeParameter('ccEmail', itemIndex) as string;
const bccEmail = this.getNodeParameter('bccEmail', itemIndex) as string;
const subject = this.getNodeParameter('subject', itemIndex) as string;
const text = this.getNodeParameter('text', itemIndex) as string;
const html = this.getNodeParameter('html', itemIndex) as string;
const attachmentPropertyString = this.getNodeParameter('attachments', itemIndex) as string;
const credentials = this.getCredentials('mailgunApi'); const credentials = this.getCredentials('mailgunApi');
@ -177,8 +184,10 @@ export class Mailgun implements INodeType {
const responseData = await this.helpers.request(options); const responseData = await this.helpers.request(options);
return { returnData.push({
json: responseData, json: responseData,
}; });
}
return this.prepareOutputData(returnData)
} }
} }

20
packages/nodes-base/nodes/ReadBinaryFile.node.ts
View file

@ -1,4 +1,4 @@
import { IExecuteSingleFunctions } from 'n8n-core'; import { IExecuteFunctions } from 'n8n-core';
import { import {
INodeExecutionData, INodeExecutionData,
INodeType, INodeType,
@ -49,11 +49,17 @@ export class ReadBinaryFile implements INodeType {
}; };
async executeSingle(this: IExecuteSingleFunctions): Promise<INodeExecutionData> { async execute(this: IExecuteFunctions): Promise<INodeExecutionData[][]> {
const item = this.getInputData(); const items = this.getInputData();
const dataPropertyName = this.getNodeParameter('dataPropertyName') as string; const returnData: INodeExecutionData[] = [];
const filePath = this.getNodeParameter('filePath') as string; const length = items.length as unknown as number;
let item: INodeExecutionData;
for (let itemIndex = 0; itemIndex < length; itemIndex++) {
item = items[itemIndex];
const dataPropertyName = this.getNodeParameter('dataPropertyName', itemIndex) as string;
const filePath = this.getNodeParameter('filePath', itemIndex) as string;
let data; let data;
try { try {
@ -79,8 +85,10 @@ export class ReadBinaryFile implements INodeType {
} }
newItem.binary![dataPropertyName] = await this.helpers.prepareBinaryData(data, filePath); newItem.binary![dataPropertyName] = await this.helpers.prepareBinaryData(data, filePath);
returnData.push(newItem);
}
return newItem; return this.prepareOutputData(returnData);
} }
} }

22
packages/nodes-base/nodes/ReadPdf.node.ts
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);
}
} }

27
packages/nodes-base/nodes/WriteBinaryFile.node.ts
View file

@ -1,6 +1,7 @@
import { import {
BINARY_ENCODING, BINARY_ENCODING,
IExecuteSingleFunctions, IExecuteFunctions,
IExecuteSingleFunctions
} from 'n8n-core'; } from 'n8n-core';
import { import {
IDataObject, IDataObject,
@ -53,11 +54,21 @@ export class WriteBinaryFile implements INodeType {
}; };
async executeSingle(this: IExecuteSingleFunctions): Promise<INodeExecutionData> { async execute(this: IExecuteFunctions): Promise<INodeExecutionData[][]> {
const item = this.getInputData();
const dataPropertyName = this.getNodeParameter('dataPropertyName') as string; const items = this.getInputData();
const fileName = this.getNodeParameter('fileName') as string;
const returnData: INodeExecutionData[] = [];
const length = items.length as unknown as number;
let item: INodeExecutionData;
for (let itemIndex = 0; itemIndex < length; itemIndex++) {
const dataPropertyName = this.getNodeParameter('dataPropertyName', itemIndex) as string;
const fileName = this.getNodeParameter('fileName', itemIndex) as string;
item = items[itemIndex];
if (item.binary === undefined) { if (item.binary === undefined) {
throw new Error('No binary data set. So file can not be written!'); throw new Error('No binary data set. So file can not be written!');
@ -84,8 +95,12 @@ export class WriteBinaryFile implements INodeType {
} }
// Add the file name to data // Add the file name to data
(newItem.json as IDataObject).fileName = fileName; (newItem.json as IDataObject).fileName = fileName;
return newItem; returnData.push(newItem);
} }
return this.prepareOutputData(returnData);
}
} }