Method constructor

api/src/websocket/collab/room.ts:198–305

(
		uid: string,
		collection: string,
		item: PrimaryKey | null,
		version: string | null,
		initialChanges?: Item,
		messenger: Messenger = new Messenger(),
	)

	onDeleteHandler: (meta: Record<string, any>, context?: any) => Promise<void>;

	constructor(
		uid: string,
		collection: string,
		item: PrimaryKey | null,
		version: string | null,
		initialChanges?: Item,
		messenger: Messenger = new Messenger(),
	) {
		this.uid = uid;
		this.collection = collection;
		this.item = item;
		this.version = version;
		this.initialChanges = initialChanges;
		this.messenger = messenger;
		this.store = useStore<RoomData>(uid, roomDefaults);

		this.onUpdateHandler = async (meta) => {
			const { keys } = meta as { keys: PrimaryKey[] };

			const target = this.version ?? this.item;

			// Skip updates for different items (singletons have item=null)
			if (target !== null && !keys.some((key) => String(key) === String(target))) return;

			try {
				const schema = await getSchema();

				const result = await (async () => {
					if (this.version) {
						const service = getService('directus_versions', { schema });
						const versionData = await service.readOne(this.version);
						return versionData['delta'] ?? {};
					}

					const service = getService(collection, { schema });
					return item ? await service.readOne(item) : await service.readSingleton({});
				})();

				const clients = await this.store(async (store) => {
					let changes = await store.get('changes');

					changes = Object.fromEntries(
						Object.entries(changes).filter(([key, value]) => {
							// Always clear relational fields after save to prevent duplicate creation
							if (isDetailedUpdateSyntax(value)) return false;

							// Partial delta for versions and full record for regular items
							if (!(key in result)) return !!this.version;

							// For primitives, only clear if saved value matches pending change
							if (isEqual(value, result[key])) return false;

							// Reconcile M2O objects with the PK in result
							if (isObject(value)) {
								const relation = schema.relations.find((r: any) => r.collection === collection && r.field === key);

								if (relation) {
									const pkField = schema.collections[relation.related_collection as string]?.primary;