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

feat(Summarize Node): Option to continue when field to summarize can't be found in any items (#9118)

Browse source
This commit is contained in:
Michael Kret 2024-04-11 12:23:44 +03:00 committed by GitHub
parent cf435c3311
commit d7abc30104
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
2 changed files with 21 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -14,6 +14,7 @@ import {
fieldValueGetter, fieldValueGetter,
splitData, splitData,
} from './utils'; } from './utils';
import { generatePairedItemData } from '../../../utils/utilities';
export class Summarize implements INodeType { export class Summarize implements INodeType {
description: INodeTypeDescription = { description: INodeTypeDescription = {
@ -239,6 +240,14 @@ export class Summarize implements INodeType {
placeholder: 'Add Option', placeholder: 'Add Option',
default: {}, default: {},
options: [ options: [
{
displayName: 'Continue if Field Not Found',
name: 'continueIfFieldNotFound',
type: 'boolean',
default: false,
description:
"Whether to continue if field to summarize can't be found in any items and return single empty item, owerwise an error would be thrown",
},
{ {
displayName: 'Disable Dot Notation', displayName: 'Disable Dot Notation',
name: 'disableDotNotation', name: 'disableDotNotation',
@ -304,7 +313,17 @@ export class Summarize implements INodeType {
const nodeVersion = this.getNode().typeVersion; const nodeVersion = this.getNode().typeVersion;
if (nodeVersion < 2.1) { if (nodeVersion < 2.1) {
try {
checkIfFieldExists.call(this, newItems, fieldsToSummarize, getValue); checkIfFieldExists.call(this, newItems, fieldsToSummarize, getValue);
} catch (error) {
if (options.continueIfFieldNotFound) {
const itemData = generatePairedItemData(items.length);
return [[{ json: {}, pairedItem: itemData }]];
} else {
throw error;
}
}
} }
const aggregationResult = splitData( const aggregationResult = splitData(

1
packages/nodes-base/nodes/Transform/Summarize/utils.ts
View file

@ -40,6 +40,7 @@ const AggregationDisplayNames = {
export const NUMERICAL_AGGREGATIONS = ['average', 'sum']; export const NUMERICAL_AGGREGATIONS = ['average', 'sum'];
export type SummarizeOptions = { export type SummarizeOptions = {
continueIfFieldNotFound: boolean;
disableDotNotation?: boolean; disableDotNotation?: boolean;
outputFormat?: 'separateItems' | 'singleItem'; outputFormat?: 'separateItems' | 'singleItem';
skipEmptySplitFields?: boolean; skipEmptySplitFields?: boolean;