Fix job cleanup

Author: needs

apps/worker/src/workers/fillClanActivePlayerCount.ts

@@ -3,6 +3,7 @@ import { prisma } from "../prisma";
 import { QUEUE_NAME_FILL_CLAN_ACTIVE_PLAYER_COUNT } from "@teerank/teerank";
 import { bullmqConnection } from "@teerank/teerank";
 import { redisClient } from "../redis";
+import { minutesToSeconds } from "date-fns";
 
 const MIN_CREATED_AT_KEY = 'fill-clan-active-player-count-min-created-at';
 
@@ -59,5 +60,11 @@ export async function startFillClanActivePlayerCountWorker() {
   return new Worker(QUEUE_NAME_FILL_CLAN_ACTIVE_PLAYER_COUNT, processor, {
     connection: bullmqConnection,
     concurrency: 1,
+    removeOnComplete: {
+      age: minutesToSeconds(10),
+    },
+    removeOnFail: {
+      count: 1000,
+    }
   });
 }

apps/worker/src/workers/pollGameServer.ts

@@ -7,7 +7,7 @@ import { Job, Worker } from "bullmq";
 import { bullmqConnection } from "@teerank/teerank";
 import { getEnvInt } from "@teerank/teerank";
 import { uniqBy } from "lodash";
-import { minutesToMilliseconds } from "date-fns";
+import { minutesToSeconds } from "date-fns";
 
 const POLL_GAME_SERVER_CONCURRENCY = getEnvInt('POLL_GAME_SERVER_CONCURRENCY', 100);
 
@@ -447,7 +447,7 @@ export async function startPollGameServerWorker() {
     connection: bullmqConnection,
     concurrency: POLL_GAME_SERVER_CONCURRENCY,
     removeOnComplete: {
-      age: minutesToMilliseconds(10),
+      age: minutesToSeconds(10),
     },
     removeOnFail: {
       count: 1000,

apps/worker/src/workers/pollMasterServer.ts

@@ -5,7 +5,7 @@ import { resetPackets, getReceivedPackets, sendData, setupSockets, listenForPack
 import { QUEUE_NAME_POLL_MASTER_SERVER, wait } from "@teerank/teerank";
 import { Job, Worker } from "bullmq";
 import { bullmqConnection } from "@teerank/teerank";
-import { minutesToMilliseconds } from "date-fns";
+import { minutesToSeconds } from "date-fns";
 
 function stringToCharCode(str: string) {
   return str.split('').map((char) => char.charCodeAt(0));
@@ -94,7 +94,7 @@ export async function startPollMasterServerWorker() {
   return new Worker(QUEUE_NAME_POLL_MASTER_SERVER, processor, {
     connection: bullmqConnection,
     removeOnComplete: {
-      age: minutesToMilliseconds(10),
+      age: minutesToSeconds(10),
     },
     removeOnFail: {
       count: 1000,

apps/worker/src/workers/rankPlayer.ts

@@ -5,7 +5,7 @@ import { rankPlayersTime } from "../rankMethods/rankPlayersTime";
 import { Worker } from "bullmq";
 import { bullmqConnection, QUEUE_NAME_RANK_PLAYER } from "@teerank/teerank";
 import { getEnvInt } from "@teerank/teerank";
-import { minutesToMilliseconds } from "date-fns";
+import { minutesToSeconds } from "date-fns";
 
 const RANK_PLAYER_CONCURRENCY = getEnvInt('RANK_PLAYER_CONCURRENCY', 20);
 
@@ -43,7 +43,7 @@ export async function startRankPlayerWorker() {
     connection: bullmqConnection,
     concurrency: RANK_PLAYER_CONCURRENCY,
     removeOnComplete: {
-      age: minutesToMilliseconds(10),
+      age: minutesToSeconds(10),
     },
   });
 }

apps/worker/src/workers/updateGameTypesCounts.ts

@@ -2,7 +2,7 @@ import { Worker } from "bullmq";
 import { prisma } from "../prisma";
 import { bullmqConnection, QUEUE_NAME_GAME_TYPE_COUNT } from "@teerank/teerank"
 import { getEnvInt } from "@teerank/teerank";
-import { minutesToMilliseconds } from "date-fns";
+import { minutesToSeconds } from "date-fns";
 
 const UPDATE_GAME_TYPES_COUNTS_CONCURRENCY = getEnvInt('UPDATE_GAME_TYPES_COUNTS_CONCURRENCY', 5);
 
@@ -50,7 +50,7 @@ export async function startUpdateGameTypesCountsWorker() {
     connection: bullmqConnection,
     concurrency: UPDATE_GAME_TYPES_COUNTS_CONCURRENCY,
     removeOnComplete: {
-      age: minutesToMilliseconds(10),
+      age: minutesToSeconds(10),
     },
     removeOnFail: {
       count: 1000,

apps/worker/src/workers/updateMapsCounts.ts

@@ -2,7 +2,7 @@ import { Worker } from "bullmq";
 import { prisma } from "../prisma";
 import { bullmqConnection, QUEUE_NAME_MAP_COUNT } from "@teerank/teerank"
 import { getEnvInt } from "@teerank/teerank";
-import { minutesToMilliseconds } from "date-fns";
+import { minutesToSeconds } from "date-fns";
 
 const UPDATE_MAPS_COUNTS_CONCURRENCY = getEnvInt('UPDATE_MAPS_COUNTS_CONCURRENCY', 5);
 
@@ -55,7 +55,7 @@ export async function startUpdateMapsCountsWorker() {
     connection: bullmqConnection,
     concurrency: UPDATE_MAPS_COUNTS_CONCURRENCY,
     removeOnComplete: {
-      age: minutesToMilliseconds(10),
+      age: minutesToSeconds(10),
     },
     removeOnFail: {
       count: 1000,

apps/worker/src/workers/updatePlayTime.ts

@@ -1,5 +1,5 @@
 import { prisma } from "../prisma";
-import { differenceInSeconds, minutesToMilliseconds } from "date-fns";
+import { differenceInSeconds, minutesToSeconds } from "date-fns";
 import { removeDuplicatedClients } from "../utils";
 import { Worker } from "bullmq";
 import { bullmqConnection, QUEUE_NAME_UPDATE_PLAY_TIME } from "@teerank/teerank";
@@ -254,7 +254,7 @@ export async function startUpdatePlayTimeWorker() {
     connection: bullmqConnection,
     concurrency: UPDATE_PLAY_TIME_CONCURRENCY,
     removeOnComplete: {
-      age: minutesToMilliseconds(10),
+      age: minutesToSeconds(10),
     },
   });
 }