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

progress

Browse source
This commit is contained in:
Ria 2025-01-18 18:41:01 +01:00
parent 6b7e109afc
commit 1d7883ec6e
1 changed files with 18 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -18,6 +18,7 @@ import {
fieldValueGetter,
splitData,
} from './utils';
import { fields } from '../../Contentful/AssetDescription';
// import { generatePairedItemData } from '../../../utils/utilities';
// [ria] not needed
export class Summarize implements INodeType {
@ -329,24 +330,29 @@ export class Summarize implements INodeType {
getValue,
);
const fieldsNotFound: NodeExecutionHint[] = [];
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 instanceof Error ? error.message : String(error),
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]);
fieldsNotFound.push(fieldNotFoundHint);
// const executionOutput = Object.keys(aggregationResult).reduce(
// (acc, key) => {
// const { pairedItem, ...json } = aggregationResult;
// acc[key] = json;
// return acc;
// },
// {} as { [key: string]: any },
// );
// return new NodeExecutionOutput(
// [[{ json: executionOutput }, { json: executionOutput }], [{ json: executionOutput }]],
// [fieldNotFoundHint],
// aggregationResult.fieldnotfoundhint = fieldNotFoundHint;
// );
} else {
throw error;
}
@ -381,7 +387,8 @@ export class Summarize implements INodeType {
})),
};
});
return [executionData];
return new NodeExecutionOutput([executionData], fieldsNotFound);
}
}
}
// testing: if node version >1 return output needs to have fieldsnotFound