reverse-single-reference.subtest.ts
No OneTemporary
Actions

Size

9 KB

Referenced Files

None

Subscribers

None

reverse-single-reference.subtest.ts
View Options

	/* eslint-disable @typescript-eslint/no-unsafe-member-access */
	import assert from "assert";
	import { withRunningApp } from "../../../test_utils/with-test-app";
	import {
	App,
	Collection,
	FieldTypes,
	Field,
	Collections,
	Policies,
	} from "../../../main";
	import { TestAppType } from "../../../test_utils/test-app";
	import { CollectionResponse } from "../../../test_utils/rest-api";
	import asyncForEach from "../../../utils/async-foreach";
	import Bluebird from "bluebird";

	const extend = (with_reverse = true, clear_database = true) =>
	function (t: TestAppType) {
	const b_fields: { [name: string]: Field } = {
	number: new FieldTypes.Int(),
	};
	if (with_reverse) {
	b_fields.references_in_a = new FieldTypes.ReverseSingleReference({
	referencing_collection: "A",
	referencing_field: "reference_to_b",
	});
	}

	return class extends t {
	clear_database_on_stop = clear_database;
	collections = {
	...t.BaseCollections,
	A: new (class extends Collection {
	fields = {
	reference_to_b: new FieldTypes.SingleReference("B"),
	pairity: new FieldTypes.Text(),
	};
	})(),
	B: new (class extends Collection {
	fields = b_fields;
	})(),
	};
	};
	};

	describe("reverse-single-reference", () => {
	async function createResources(app: App) {
	const numbers = [1, 2, 3];
	const bs = await Bluebird.map(numbers, (number) =>
	app.collections.B.suCreate({
	number,
	})
	);

	for (const b of bs) {
	for (let i = 1; i <= b.get("number"); i++) {
	await app.collections.A.suCreate({
	reference_to_b: b.id,
	pairity: i % 2 ? "odd" : "even",
	});
	}
	}
	}

	it("recreates the cached values if the field has just been added", async () => {
	await withRunningApp(
	extend(false, false),
	async ({ app }) => {
	await createResources(app);
	},
	"cache-recreate"
	);
	await withRunningApp(
	extend(true),
	async ({ rest_api }) => {
	const {
	items: [result],
	} = (await rest_api.get(
	"/api/v1/collections/B?filter[number]=1"
	)) as CollectionResponse<{ references_in_a: string }>;
	assert.ok(result.references_in_a);
	assert.strictEqual(result.references_in_a.length, 1);
	const {
	items: [result2],
	} = (await rest_api.get(
	"/api/v1/collections/B?filter[number]=2"
	)) as CollectionResponse<{ references_in_a: string }>;
	assert(result2.references_in_a);
	assert.strictEqual(result2.references_in_a.length, 2);
	},
	"cache-recreate"
	);
	});

	it("updates the cached value when a new reference is created", async () => {
	await withRunningApp(extend(true), async ({ app, rest_api }) => {
	await createResources(app);
	const {
	items: [result],
	} = (await rest_api.get(
	"/api/v1/collections/B?filter[number]=2"
	)) as CollectionResponse;
	assert(result.references_in_a instanceof Array);
	assert.strictEqual(result.references_in_a.length, 2);
	});
	});

	it("updates the cached value when an old reference is deleted", async () =>
	withRunningApp(extend(true), async ({ app, rest_api }) => {
	await createResources(app);
	const { items } = (await rest_api.get(
	"/api/v1/collections/B?filter[number]=2"
	)) as CollectionResponse<{ references_in_a: string }>;
	const referencing_id = items[0].references_in_a[0];
	await rest_api.delete(`/api/v1/collections/A/${referencing_id}`);
	const {
	items: [new_result2],
	} = (await rest_api.get(
	"/api/v1/collections/B?filter[number]=2"
	)) as CollectionResponse<{ references_in_a: string }>;
	assert.strictEqual(new_result2.references_in_a.length, 1);
	}));

	it("updates the cached value when an old reference is edited to a new one", async () =>
	withRunningApp(extend(true), async ({ rest_api, app }) => {
	await createResources(app);
	const {
	items: [result1],
	} = (await rest_api.get(
	"/api/v1/collections/B?filter[number]=1"
	)) as CollectionResponse;
	const {
	items: [result2],
	} = (await rest_api.get(
	"/api/v1/collections/B?filter[number]=2"
	)) as CollectionResponse<{ references_in_a: string }>;
	const referencing_id = result2.references_in_a[0];

	await rest_api.patch(`/api/v1/collections/A/${referencing_id}`, {
	reference_to_b: result1.id,
	});

	const {
	items: [new_result2],
	} = (await rest_api.get(
	"/api/v1/collections/B?filter[number]=2"
	)) as CollectionResponse<{ references_in_a: string }>;
	assert.strictEqual(new_result2.references_in_a.length, 1);
	const {
	items: [new_result1],
	} = (await rest_api.get(
	"/api/v1/collections/B?filter[number]=1"
	)) as CollectionResponse<{ references_in_a: string }>;
	assert.strictEqual(new_result1.references_in_a.length, 2);
	}));

	it("updates the cached value when an old reference is edited to an empty one", async () =>
	withRunningApp(extend(true), async ({ rest_api, app }) => {
	await createResources(app);
	await rest_api.get("/api/v1/collections/B?filter[number]=1");
	const {
	items: [result2],
	} = (await rest_api.get(
	"/api/v1/collections/B?filter[number]=2"
	)) as CollectionResponse<{ references_in_a: string }>;
	const referencing_id = result2.references_in_a[0];

	await rest_api.patch(`/api/v1/collections/A/${referencing_id}`, {
	reference_to_b: "",
	});
	const {
	items: [new_result2],
	} = (await rest_api.get(
	"/api/v1/collections/B?filter[number]=2"
	)) as CollectionResponse<{ references_in_a: string }>;
	assert.strictEqual(new_result2.references_in_a.length, 1);
	}));

	it("allows to filter by a value of the referencing resource", async () =>
	withRunningApp(extend(true), async ({ rest_api, app }) => {
	await createResources(app);
	let { items: results } = (await rest_api.get(
	"/api/v1/collections/B?filter[references_in_a][pairity]=non-existant"
	)) as CollectionResponse;
	assert.strictEqual(results.length, 0);
	results = ((await rest_api.get(
	"/api/v1/collections/B?filter[references_in_a][pairity]=odd"
	)) as CollectionResponse).items;
	assert.strictEqual(results.length, 3);
	results = ((await rest_api.get(
	"/api/v1/collections/B?filter[references_in_a][pairity]=even&filter[number]=3"
	)) as CollectionResponse).items;
	assert.strictEqual(results.length, 1);
	}));

	it("allows to display the full body of the referencing resources", async () =>
	withRunningApp(extend(true), async ({ rest_api, app }) => {
	await createResources(app);
	const { items, attachments } = (await rest_api.get(
	"/api/v1/collections/B?attachments[references_in_a]=true"
	)) as CollectionResponse<{ references_in_a: string }>;

	const referenced_id = items[0].references_in_a[0];
	assert.strictEqual(attachments[referenced_id].pairity, "odd");
	}));

	it("handles nested attachments", async () =>
	withRunningApp(
	(test_app) =>
	class extends test_app {
	collections = {
	...App.BaseCollections,
	organizations: new (class extends Collection {
	fields = {
	name: FieldTypes.Required(
	new FieldTypes.Text({
	full_text_search: true,
	min_length: 2,
	max_length: 16,
	})
	),
	};
	})(),
	"user-organization": new (class extends Collection {
	fields = {
	organization: FieldTypes.Required(
	new FieldTypes.SingleReference(
	"organizations"
	)
	),
	user: FieldTypes.Required(
	new FieldTypes.SingleReference("users")
	),
	};
	})(),
	users: new (class extends Collections.users {
	fields = {
	...App.BaseCollections.users.fields,
	description: new FieldTypes.Text(),
	organizations: new FieldTypes.ReverseSingleReference(
	{
	referencing_collection:
	"user-organization",
	referencing_field: "user",
	}
	),
	};
	policies = {
	create: new Policies.Public(),
	show: new Policies.Public(),
	};
	defaultPolicy = new Policies.Public();
	})(),
	};
	},
	async ({ app, rest_api }) => {
	const user = await rest_api.post("/api/v1/collections/users", {
	username: "user1",
	password: "user1user1",
	email: "user1@example.com",
	});
	const org = await rest_api.post(
	"/api/v1/collections/organizations",
	{
	name: "org",
	}
	);
	await rest_api.post("/api/v1/collections/user-organization", {
	user: user.id,
	organization: org.id,
	});
	const response = await rest_api.get(
	"/api/v1/collections/users?attachments[organizations][organization]=true"
	);
	const rel_id = response.items[0].organizations[0];
	const org_id = response.attachments[rel_id].organization;
	assert.strictEqual(
	response?.attachments?.[org_id]?.name,
	"org"
	);
	const db_response = await app.collections.users
	.suList()
	.attach(({
	organizations: { organization: true },
	} as unknown) as any)
	.fetch();
	assert.strictEqual(
	db_response.items[0]
	.getAttachments(
	/* @ts-ignore */
	"organizations"
	)[0]
	.getAttachments("organization")[0]
	.get("name"),
	"org"
	);

	const user2 = await rest_api.post("/api/v1/collections/users", {
	username: "user2",
	password: "user2user2",
	email: "user2@example.com",
	});
	const db_response2 = await app.collections.users
	.suList()
	.ids([user2.id])
	.attach(({
	organizations: { organization: true },
	} as unknown) as any)
	.fetch();

	assert.deepStrictEqual(
	db_response2.items[0].getAttachments(
	/* @ts-ignore */
	"organizations"
	),
	[]
	);
	}
	));
	});

File Metadata

Mime Type: text/x-java
Expires: Wed, May 7, 19:38 (1 d, 21 h)
Storage Engine: blob
Storage Format: Raw Data
Storage Handle: 635893
Default Alt Text: reverse-single-reference.subtest.ts (9 KB)

reverse-single-reference.subtest.tsNo OneTemporaryActions

reverse-single-reference.subtest.tsView Options

File Metadata

Event Timeline

reverse-single-reference.subtest.ts
No OneTemporary
Actions

reverse-single-reference.subtest.ts
View Options