mudhorn/n8n
1
0
Fork 0
mirror of https://github.com/n8n-io/n8n.git synced 2025-02-02 07:01:30 -08:00
Code Issues Actions Packages Projects Releases Wiki Activity

adds processed output with hint

Browse source
This commit is contained in:
Ria 2025-01-15 12:01:14 +01:00
parent 1f4639f834
commit 401a0d2501
1 changed files with 24 additions and 16 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

40
packages/nodes-base/nodes/Transform/Summarize/Summarize.node.ts
View file

@ -18,7 +18,7 @@ import {
fieldValueGetter,
splitData,
} from './utils';
import { generatePairedItemData } from '../../../utils/utilities';
export class Summarize implements INodeType {
description: INodeTypeDescription = {
displayName: 'Summarize',
@ -320,21 +320,6 @@ export class Summarize implements INodeType {
const nodeVersion = this.getNode().typeVersion;
try {
checkIfFieldExists.call(this, newItems, fieldsToSummarize, getValue);
} catch (error) {
if (nodeVersion > 1 || options.continueIfFieldNotFound) {
const itemData = generatePairedItemData(items.length);
const fieldNotFoundHint: NodeExecutionHint = {
message: error.message,
location: 'outputPane',
};
return new NodeExecutionOutput([[{ json: {}, pairedItem: itemData }]], [fieldNotFoundHint]);
} else {
throw error;
}
}
const aggregationResult = splitData(
fieldsToSplitBy,
newItems,
@ -343,6 +328,29 @@ export class Summarize implements INodeType {
getValue,
);
try {
checkIfFieldExists.call(this, newItems, fieldsToSummarize, getValue);
} catch (error) {
if (nodeVersion > 1 || options.continueIfFieldNotFound) {
// const itemData = generatePairedItemData(items.length); // deleted from return array
const fieldNotFoundHint: NodeExecutionHint = {
message: error.message,
location: 'outputPane',
};
const { pairedItems, ...json } = aggregationResult;
const executionData: INodeExecutionData = {
json,
pairedItem: ((pairedItems as number[]) || []).map((index: number) => ({
item: index,
})),
};
return new NodeExecutionOutput([[executionData]], [fieldNotFoundHint]);
// return new NodeExecutionOutput([[{ json: aggregationResult }]], [fieldNotFoundHint]);
} else {
throw error;
}
}
if (options.outputFormat === 'singleItem') {
const executionData: INodeExecutionData = {
json: aggregationResult,