Function upsertMany

packages/core/src/utils/operations.ts:15–45

(calls: {
	input: Data[];
	find: () => Promise<T[]>;
	getInputId: (input: Data) => string;
	getFetchedDataId: (input: T) => string;
	create: (input: Data[]) => Promise<F[]>;
	update: (input: Data[]) => Promise<F[]>;
})

}

export async function upsertMany<T, F, Data>(calls: {
	input: Data[];
	find: () => Promise<T[]>;
	getInputId: (input: Data) => string;
	getFetchedDataId: (input: T) => string;
	create: (input: Data[]) => Promise<F[]>;
	update: (input: Data[]) => Promise<F[]>;
}) {
	const { find, create, getInputId, getFetchedDataId, input, update } = calls;
	const existing = await find();
	// map existing to id
	const existingMap = existing.reduce(
		(acc, cur) => {
			acc[getFetchedDataId(cur)] = cur;
			return acc;
		},
		{} as Record<string, T>,
	);

	const toCreate = input
		.filter((c) => !existingMap[getInputId(c)])
		.map((c) => c);
	const toUpdate = input
		.filter((c) => existingMap[getInputId(c)])
		.map((c) => c);
	const [created, updated] = await Promise.all([
		update(toUpdate),
		create(toCreate),
	]);
	return [...created, ...updated];
}

export function addDefaultValues<T, F>(
	input: T[],