Delete old room links routine

app/features/chat/RoomLinkRepository.server.ts

@@ -45,3 +45,14 @@ export function refreshTimestamp(userId: number) {
 		.where("userId", "=", userId)
 		.execute();
 }
+
+export function deleteOld() {
+	return db
+		.deleteFrom("RoomLink")
+		.where(
+			"refreshedAt",
+			"<",
+			dateToDatabaseTimestamp(sub(new Date(), { hours: 2 })),
+		)
+		.executeTakeFirst();
+}

app/routines/deleteOldRoomLinks.ts

@@ -0,0 +1,11 @@
+import * as RoomLinkRepository from "../features/chat/RoomLinkRepository.server";
+import { logger } from "../utils/logger";
+import { Routine } from "./routine.server";
+
+export const DeleteOldRoomLinksRoutine = new Routine({
+	name: "DeleteOldRoomLinks",
+	func: async () => {
+		const { numDeletedRows } = await RoomLinkRepository.deleteOld();
+		logger.info(`Deleted ${numDeletedRows} old room links`);
+	},
+});

app/routines/list.server.ts

@@ -2,6 +2,7 @@ import { CloseExpiredCommissionsRoutine } from "./closeExpiredCommissions";
 import { CloseExpiredContinueVotesRoutine } from "./closeExpiredContinueVotes";
 import { DeleteObsoleteMatchVodsRoutine } from "./deleteObsoleteMatchVods";
 import { DeleteOldNotificationsRoutine } from "./deleteOldNotifications";
+import { DeleteOldRoomLinksRoutine } from "./deleteOldRoomLinks";
 import { DeleteOrphanArtTagsRoutine } from "./deleteOrphanArtTags";
 import { NotifyCheckInStartRoutine } from "./notifyCheckInStart";
 import { NotifyPlusServerVotingRoutine } from "./notifyPlusServerVoting";
@@ -28,6 +29,7 @@ export const everyHourAt30 = [
 	SetOldGroupsAsInactiveRoutine,
 	UpdatePatreonDataRoutine,
 	CloseExpiredContinueVotesRoutine,
+	DeleteOldRoomLinksRoutine,
 ];
 
 /** List of Routines that should occur daily */