Feat: OOO Nickname Update Job

src/config/config.ts

@@ -9,7 +9,7 @@ export const handleConfig = (env: env) => {
 			baseUrl = 'https://staging-api.realdevsquad.com';
 		}
 	} else {
-		baseUrl = 'https://staging-api.realdevsquad.com';
+		baseUrl = 'https://93f5-49-204-135-151.ngrok.io';
 	}
 	return { baseUrl };
 };

src/constants.ts

@@ -0,0 +1,4 @@
+const KEY_NAME = 'DISCORD_NICKNAME_CHANGED';
+const NAMESPACE_NAME = 'CRON_JOBS_TIMESTAMPS';
+
+export { KEY_NAME, NAMESPACE_NAME };

src/handlers/scheduledEventHandler.ts

@@ -1,8 +1,54 @@
+import { KVNamespace } from '@cloudflare/workers-types';
+
 import { handleConfig } from '../config/config';
+import { KEY_NAME, NAMESPACE_NAME } from '../constants';
 import { env } 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 = 0;
+	try {
+		lastNicknameUpdate = (await namespace.get(KEY_NAME)) ?? 0;
+	} 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");
+	}
+
+	try {
+		await namespace.put(KEY_NAME, Date.now().toString());
+	} catch (err) {
+		console.log('Error while trying to update the last nickname change timestamp');
+	}
+
+	const data = await response.json();
+	return data;
+}

src/worker.ts

@@ -1,12 +1,21 @@
-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));
+		switch (req.cron) {
+			case '0 */4 * * *':
+				ctx.waitUntil(ping(env));
+				break;
+			case '0 */6 * * *':
+				await callDiscordNicknameBatchUpdate(env);
+				break;
+			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,19 @@
 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.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]]