Feat: OOO Nickname Update Job

src/constants.ts

@@ -0,0 +1,3 @@
+const NAMESPACE_NAME = 'CRON_JOBS_TIMESTAMPS';
+
+export { NAMESPACE_NAME };

src/handlers/scheduledEventHandler.ts

@@ -1,8 +1,60 @@
+import { KVNamespace } from '@cloudflare/workers-types';
+
 import { handleConfig } from '../config/config';
-import { env } from '../types/global.types';
+import { NAMESPACE_NAME } from '../constants';
+import { env, nicknameUpdateResponseType } from '../types/global.types';
+import { generateJwt } from '../utils/generateJwt';
 
 export async function ping(env: env) {
 	const url = handleConfig(env);
 	const response = await fetch(`${url.baseUrl}/healthcheck`);
 	return response;
 }
+
+export async function callDiscordNicknameBatchUpdate(env: env) {
+	const namespace = env[NAMESPACE_NAME] as unknown as KVNamespace;
+	let lastNicknameUpdate: string | number | null = 0;
+	try {
+		lastNicknameUpdate = await namespace.get('DISCORD_NICKNAME_CHANGED');
+		if (lastNicknameUpdate === null) {
+			throw new Error('Error while fetching KV "DISCORD_NICKNAME_CHANGED" timestamp');
+		}
+	} catch (err) {
+		console.log('Error while fetching the timestamp for last nickname update');
+		throw err;
+	}
+
+	const url = handleConfig(env);
+	let token;
+	try {
+		token = await generateJwt(env);
+	} catch (err) {
+		console.log(`Error while generating JWT token: ${err}`);
+		throw err;
+	}
+	const response = await fetch(`${url.baseUrl}/discord-actions/nickname/status`, {
+		method: 'POST',
+		headers: {
+			Authorization: `Bearer ${token}`,
+			'Content-Type': 'application/json',
+		},
+		body: JSON.stringify({
+			lastNicknameUpdate,
+		}),
+	});
+	if (!response.ok) {
+		throw new Error("Error while trying to update users' discord nickname");
+	}
+
+	const data: nicknameUpdateResponseType = await response.json();
+	if (data?.data.totalUsersStatus !== 0 && data?.data.successfulNicknameUpdates === 0) {
+		throw new Error("Error while trying to update users' discord nickname");
+	}
+	try {
+		await namespace.put('DISCORD_NICKNAME_CHANGED', Date.now().toString());
+	} catch (err) {
+		console.log('Error while trying to update the last nickname change timestamp');
+	}
+
+	return data;
+}

src/types/global.types.ts

@@ -1,3 +1,12 @@
 export type env = {
 	[key: string]: string;
 };
+
+export type nicknameUpdateResponseType = {
+	message: string;
+	data: {
+		totalUsersStatus: number;
+		successfulNicknameUpdates: number;
+		unsuccessfulNicknameUpdates: number;
+	};
+};

src/worker.ts

@@ -1,12 +1,20 @@
-import { ping } from './handlers/scheduledEventHandler';
+import { callDiscordNicknameBatchUpdate, ping } from './handlers/scheduledEventHandler';
 import { env } from './types/global.types';
 
 export default {
 	// We need to keep all 3 parameters in this format even if they are not used as as cloudflare workers need them to be present So we are disabling eslint rule of no-unused-vars
 	// for more details read here: https://community.cloudflare.com/t/waituntil-is-not-a-function-when-using-workers-with-modules/375781/4
 	// eslint-disable-next-line no-unused-vars
-	async scheduled(req: Request, env: env, ctx: ExecutionContext) {
-		ctx.waitUntil(ping(env));
+	async scheduled(req: ScheduledController, env: env, ctx: ExecutionContext) {
+		switch (req.cron) {
+			case '0 */4 * * *':
+				ctx.waitUntil(ping(env));
+				break;
+			case '0 */6 * * *':
+				return await callDiscordNicknameBatchUpdate(env);
+			default:
+				console.log('Unknown Trigger Value!');
+		}
 	},
 	// We need to keep all 3 parameters in this format even if they are not used as as cloudflare workers need them to be present So we are disabling eslint rule of no-unused-vars
 	// for more details read here: https://community.cloudflare.com/t/waituntil-is-not-a-function-when-using-workers-with-modules/375781/4

wrangler.toml

@@ -1,13 +1,25 @@
 name = "cron-jobs"
 main = "src/worker.ts"
 compatibility_date = "2023-07-17"
-[triggers]
-crons = ["0 */4 * * *"]
 
-# # KV Namespace binding - For more information: https://developers.cloudflare.com/workers/runtime-apis/kv
-# [[kv_namespaces]]
-# binding = "MY_KV_NAMESPACE"
-# id = "xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx"
+kv_namespaces = [
+  { binding = "CRON_JOBS_TIMESTAMPS", id = "a5431887e6c94dc9b3e36c35a07081b9" }
+]
+
+# [env.staging]
+# the BINDING_NAME must be CRON_JOBS_TIMESTAMPS to override in the staging env
+# kv_namespaces = [
+#  { binding = "<BINDING_NAME>", id = "<BINDING_ID>" }
+# ]
+
+# [env.production]
+# the BINDING_NAME must be CRON_JOBS_TIMESTAMPS to override in the production env
+# kv_namespaces = [
+#  { binding = "<BINDING_NAME>", id = "<BINDING_ID>" }
+# ]
+
+[triggers]
+crons = ["0 */4 * * *", "0 */6 * * *"]
 
 # # Durable Object binding - For more information: https://developers.cloudflare.com/workers/runtime-apis/durable-objects
 # [[durable_objects]]