Function insertJsMember

src/utils/member.utils.ts:57–111

(options: {
		store: Store,
		queue: DbQueue,
		jsMember: GuildMember,
		message?: string,
		force?: boolean,
	})

	}

	export async function insertJsMember(options: {
		store: Store,
		queue: DbQueue,
		jsMember: GuildMember,
		message?: string,
		force?: boolean,
	}) {
		const { store, queue, jsMember, message, force } = options;

		return await db.transaction(async () => {
			if (!force) {
				verifyMemberEligibility(store, queue, jsMember);
			}

			const priority = PriorityUtils.getMemberPriority(store, queue.id, jsMember);
			const archivedMember = store.dbArchivedMembers().find(member => member.queueId === queue.id && member.userId === jsMember.id);
			let positionTime = BigInt(Date.now());

			if (queue.rejoinCooldownPeriod && archivedMember?.reason === ArchivedMemberReason.Pulled) {
				const msSincePulled = BigInt(Date.now()) - archivedMember.archivedTime;
				const msCooldownRemaining = BigInt(queue.rejoinCooldownPeriod * 1000) - msSincePulled;
				if (msCooldownRemaining > 0) {
					throw new CustomError({
						message: "You are currently in a cooldown period and cannot rejoin the queue",
						embeds: [
							new EmbedBuilder()
								.setDescription(`You can rejoin the queue in ${timeMention(Number(msCooldownRemaining / 1000n))}.`),
						],
					});
				}
			}

			if (queue.rejoinGracePeriod && archivedMember?.reason === ArchivedMemberReason.Left) {
				if (BigInt(Date.now()) - archivedMember.archivedTime <= queue.rejoinGracePeriod) {
					// Reuse the positionTime
					positionTime = archivedMember.positionTime;
				}
			}

			const insertedMember = store.insertMember({
				guildId: store.guild.id,
				queueId: queue.id,
				userId: jsMember.id,
				message,
				priority,
				positionTime,
			});

			await modifyMemberRoles(store, jsMember.id, queue.roleInQueueId, "add");

			DisplayUtils.requestDisplayUpdate(store, queue.id);

			return insertedMember;
		});
	}

	export function updateMembers(store: Store, members: ArrayOrCollection<bigint, DbMember>, message: string) {
		const updatedMembers = map(members, member => store.updateMember({ ...member, message }));