feat: allow syncing from lurkr

Author: ToastedDev

api/index.ts

@@ -340,7 +340,7 @@ app.post("/admin/:action/:guild/:target", authMiddleware, async (req, res) => {
 			}
 		}
 		case "sync": {
-			if (target !== "polaris" && target !== "mee6") {
+			if (target !== "polaris" && target !== "mee6" && target !== "lurkr") {
 				return res.status(400).json({ message: "Illegal request" });
 			}
 
@@ -375,6 +375,21 @@ app.post("/admin/:action/:guild/:target", authMiddleware, async (req, res) => {
 						return res.status(500).json({ message: "Internal server error", err });
 					}
 				}
+				case "lurkr": {
+					try {
+						const [err, success] = await syncFromLurkr(guild);
+						if (err) {
+							if (err instanceof Error && err.message === "Server not found in Lurkr") {
+								return res.status(404).json({ message: "Server not found in Lurkr" });
+							}
+							return res.status(500).json({ message: "Internal server error", err });
+						} else {
+							return res.status(200).json(success);
+						}
+					} catch (err) {
+						return res.status(500).json({ message: "Internal server error", err });
+					}
+				}
 				default:
 					return res.status(500).json({ message: "Internal server error" });
 			}
@@ -610,4 +625,69 @@ async function syncFromMee6(guild: string) {
 		return [err, false];
 	}
 }
+
+async function syncFromLurkr(guild: string) {
+	const res = await fetch(`https://api.lurkr.gg/v2/levels/${guild}?page=1`);
+	const data = await res.json();
+	if (data.message === "Guild no found") {
+		return [new Error("Server not found in Lurkr"), false];
+	}
+	const users = data.levels;
+
+	if (users.length === 0) {
+		return [new Error("No users found"), false];
+	}
+
+	let pageNumber = 2;
+	// this is needed because Lurkr doesn't give us the total amount of pages
+	// eslint-disable-next-line no-constant-condition
+	while (true) {
+		const res = await fetch(`https://api.lurkr.gg/v2/levels/${guild}?page=${pageNumber}`);
+		const data = await res.json();
+		users.push(...data.levels);
+		if (data.levels.length < 100) break;
+		pageNumber += 1;
+	}
+
+	try {
+		for (const user of users) {
+			const xpValue = user.xp;
+			const level = Math.floor(Math.sqrt(user.xp / 100));
+			const nextLevel = level + 1;
+			const nextLevelXp = Math.pow(nextLevel, 2) * 100;
+			const xpNeededForNextLevel = nextLevelXp - user.xp;
+			const currentLevelXp = Math.pow(level, 2) * 100;
+			const progressToNextLevel =
+				((user.xp - currentLevelXp) / (nextLevelXp - currentLevelXp)) * 100;
+
+			await new Promise((resolve, reject) => {
+				pool.query(
+					`INSERT INTO users (id, guild_id, xp, pfp, name, nickname, level, xp_needed_next_level, progress_next_level) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)`,
+					[
+						user.userId,
+						guild,
+						xpValue,
+						`https://cdn.discordapp.com/avatars/${user.userId}/${user.user.avatar}.webp`,
+						user.user.username,
+						user.user.username,
+						level,
+						xpNeededForNextLevel,
+						progressToNextLevel.toFixed(2),
+					],
+					(err) => {
+						if (err) {
+							console.error("Error syncing from Lurkr:", err);
+							reject(err);
+						} else {
+							resolve(null);
+						}
+					},
+				);
+			});
+		}
+		return [null, true]
+	} catch (err) {
+		return [err, false];
+	}
+}
 //#endregion

bot/commands.ts

@@ -737,7 +737,11 @@ const commands: Record<string, Command> = {
 					{
 						name: 'MEE6',
 						value: 'mee6',
-					}
+					},
+					{
+						name: 'Lurkr',
+						value: 'lurkr',
+					},
 				]
 			}],
 			name: 'sync',
@@ -763,7 +767,8 @@ const commands: Record<string, Command> = {
 			const bot = interaction.options.get('bot')?.value;
 			const formattedBotNames = {
 				'polaris': 'Polaris',
-				'mee6': 'MEE6'
+				'mee6': 'MEE6',
+				'lurkr': 'Lurkr'
 			};
 
 			await interaction.reply({ ephemeral: true, content: `Syncing data from ${formattedBotNames[bot as keyof typeof formattedBotNames]}...` });