Method processAggregates

api/src/services/payload.ts:285–333

(payload: Partial<Item>[], aggregate: Aggregate = {})

	}

	async processAggregates(payload: Partial<Item>[], aggregate: Aggregate = {}) {
		/**
		 * Build access path with -> delimiter
		 *
		 * input: { min: [ 'date', 'datetime', 'timestamp' ] }
		 * output: [ 'min->date', 'min->datetime', 'min->timestamp' ]
		 */
		const aggregateKeys = Object.entries(aggregate).reduce<string[]>((acc, [key, values]) => {
			acc.push(...values.map((value) => `${key}->${value}`));
			return acc;
		}, []);

		const fieldEntries = this.schema.collections[this.collection]!.fields;

		/**
		 * Expand -> delimited keys in the payload to the equivalent expanded object
		 *
		 * before: { "min->date": "2025-04-09", "min->datetime": "2025-04-08T12:00:00", "min->timestamp": "2025-04-17T23:18:00.000Z" }
		 * after: { "min": { "date": "2025-04-09", "datetime": "2025-04-08T12:00:00", "timestamp": "2025-04-17T23:18:00.000Z" } }
		 */
		if (aggregateKeys.length) {
			for (const item of payload) {
				for (const key of aggregateKeys) {
					// Ignore keys that do not follow the `A->B` naming like count=*
					if (key in item === false) continue;

					const [operation, fieldName] = key.split('->') as [string, string];

					const aggregateResult = { [fieldName]: item[key] };

					if (fieldEntries[fieldName]?.special?.length > 0) {
						const newValue = await this.processField(
							fieldEntries[fieldName],
							aggregateResult,
							'read',
							this.accountability,
						);

						if (newValue !== undefined) aggregateResult[fieldName] = newValue;
					}

					if (!isPlainObject(item[operation])) item[operation] = {};

					item[operation][fieldName] = aggregateResult[fieldName];
					delete item[key];
				}
			}
		}
	}

	async processField(
		field: SchemaOverview['collections'][string]['fields'][string],