Function handleVersion

api/src/utils/versioning/handle-version.ts:18–279

(self: ItemsServiceType, key: PrimaryKey | null, query: Query, opts?: QueryOptions)

};

export async function handleVersion(self: ItemsServiceType, key: PrimaryKey | null, query: Query, opts?: QueryOptions) {
	const { VersionsService } = await import('../../services/versions.js');
	const { ItemsService } = await import('../../services/items.js');

	if (key && query.versionRaw) {
		const version = query.version;
		delete query.version;
		delete query.versionRaw;

		const originalData = await self.readByQuery(query, opts);

		if (originalData.length === 0) {
			throw new ForbiddenError();
		}

		const versionsService = new VersionsService({
			schema: self.schema,
			accountability: self.accountability,
			knex: self.knex,
		});

		const versions = await versionsService.getVersionSaves(version!, self.collection, key);

		return [Object.assign(originalData[0]!, versions?.[0]?.delta)];
	}

	const versionsService = new VersionsService({
		schema: self.schema,
		accountability: self.accountability,
		knex: self.knex,
	});

	const versions = await versionsService.getVersionSaves(query.version!, self.collection, key, false);

	if (key && versions.length === 0) {
		throw new ForbiddenError();
	}

	if (versions.length === 0) {
		return [];
	}

	let results: Item[] = [];
	const createdIDs: Record<string, PrimaryKey[]> = {};
	const itemlessErrors: VersionMeta[] = [];
	const itemMeta: Record<string, VersionMeta> = {};
	const primaryKeyField = self.schema.collections[self.collection]!.primary;

	const hasPrimaryKeyInQuery =
		query.fields?.includes(primaryKeyField) || query.fields?.includes('*') || query.fields?.length === 0;

	await transaction(self.knex, async (trx) => {
		for (const version of versions) {
			const { id, item } = version;
			let delta = version.delta;

			if (!delta && item) {
				itemMeta[item] = {