feat: remove exiting job on force refresh (#1321)

remove exiting job on force refresh
enjin · Sep 30, 2024 · 7b131d7 · 7b131d7
1 parent 7082151
commit 7b131d7
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/src/jobs/process-metadata.ts b/src/jobs/process-metadata.ts
@@ -21,6 +21,14 @@ export const metadataQueue = new Queue<JobData>('metadataQueue', {
 })
 
 export const processMetadata = async (resourceId: string, type: JobData['type'], force = false, allTokens = false) => {
+    if (force) {
+        // on force, remove existing job and add a new one
+        const existingJob = await metadataQueue.getJob(`${type}-${resourceId}`)
+        if (existingJob) {
+            await existingJob.remove()
+        }
+    }
+
     metadataQueue.add({ resourceId, type, force, allTokens }, { jobId: `${type}-${resourceId}` }).catch(() => {
         // eslint-disable-next-line no-console
         console.log('Closing connection as Redis is not available')