Method join

api/src/websocket/collab/room.ts:364–447

* Client requesting to join a room. If the client hasn't entered the room already, add a new client. * Otherwise all users just will be informed again that the user has joined.

(client: WebSocketClient, color?: JoinMessage['color'])

	 * Otherwise all users just will be informed again that the user has joined.
	 */
	async join(client: WebSocketClient, color?: JoinMessage['color']) {
		this.messenger.addClient(client);

		let added = false;
		let clientColor: Color | undefined;

		if (!(await this.hasClient(client.uid))) {
			await this.store(async (store) => {
				const clients = await store.get('clients');
				added = true;

				const existingColors = clients.map((c) => c.color);
				const colorsAvailable = COLORS.filter((color) => !existingColors.includes(color));

				if (colorsAvailable.length === 0) {
					colorsAvailable.push(...COLORS);
				}

				if (color && colorsAvailable.includes(color)) {
					clientColor = color;
				} else {
					clientColor = colorsAvailable[random(colorsAvailable.length - 1)]!;
				}

				clients.push({
					uid: client.uid,
					accountability: client.accountability!,
					color: clientColor,
				});

				await store.set('clients', clients);
			});
		}

		if (added && clientColor) {
			await this.sendExcluding(
				{
					action: ACTION.SERVER.JOIN,
					user: client.accountability!.user!,
					connection: client.uid,
					color: clientColor,
				},
				client.uid,
			);
		}

		const { changes, focuses, clients } = await this.store(async (store) => {
			return {
				changes: await store.get('changes'),
				focuses: await store.get('focuses'),
				clients: await store.get('clients'),
			};
		});

		const schema = await getSchema();
		const knex = getDatabase();

		const allowedFields = await verifyPermissions(client.accountability, this.collection, this.item, 'read', {