feat(bot): sync on user updates (#372)

RhysSullivan · web-flow · commit 983bd9e4db5e · 2023-04-24T18:26:47.000-04:00
diff --git a/apps/discord-bot/src/listeners/parity/user-parity.test.ts b/apps/discord-bot/src/listeners/parity/user-parity.test.ts
@@ -0,0 +1,42 @@
+import type { SapphireClient } from '@sapphire/framework';
+import { Events } from 'discord.js';
+import { copyClass, emitEvent, mockUser } from '@answeroverflow/discordjs-mock';
+import { setupAnswerOverflowBot } from '~discord-bot/test/sapphire-mock';
+import {
+	createDiscordAccount,
+	findDiscordAccountById,
+} from '@answeroverflow/db';
+import { toAODiscordAccount } from '~discord-bot/utils/conversions';
+
+let client: SapphireClient;
+
+beforeEach(async () => {
+	client = await setupAnswerOverflowBot();
+});
+
+describe('Guild Member Update', () => {
+	it('should update an existing user', async () => {
+		const oldUser = mockUser(client, {
+			username: 'old name',
+		});
+		await createDiscordAccount(toAODiscordAccount(oldUser));
+		const newUser = copyClass(oldUser, client, {
+			username: 'new name',
+		});
+		await emitEvent(client, Events.UserUpdate, oldUser, newUser);
+		const updated = await findDiscordAccountById(oldUser.id);
+		expect(updated).toBeDefined();
+		expect(updated?.name).toBe('new name');
+	});
+	it("should not update a user that doesn't exist", async () => {
+		const oldUser = mockUser(client, {
+			username: 'old name',
+		});
+		const newUser = copyClass(oldUser, client, {
+			username: 'new name',
+		});
+		await emitEvent(client, Events.UserUpdate, oldUser, newUser);
+		const updated = await findDiscordAccountById(oldUser.id);
+		expect(updated).toBeNull();
+	});
+});
diff --git a/apps/discord-bot/src/listeners/parity/user-parity.ts b/apps/discord-bot/src/listeners/parity/user-parity.ts
@@ -0,0 +1,23 @@
+import { ApplyOptions } from '@sapphire/decorators';
+import { Listener } from '@sapphire/framework';
+import { Events, User } from 'discord.js';
+import {
+	findDiscordAccountById,
+	updateDiscordAccount,
+} from '@answeroverflow/db';
+
+@ApplyOptions<Listener.Options>({
+	event: Events.UserUpdate,
+	name: 'Sync On User Update',
+})
+export class SyncOnUserUpdate extends Listener<typeof Events.UserUpdate> {
+	public async run(_: User, updated: User) {
+		const existing = await findDiscordAccountById(updated.id);
+		if (!existing) return;
+		await updateDiscordAccount({
+			id: updated.id,
+			avatar: updated.avatar,
+			name: updated.username,
+		});
+	}
+}
