Merge pull request #217 from TaloDev/develop

Release 0.29.2

Author: tudddorrr

package.json

@@ -1,6 +1,6 @@
 {
   "name": "game-services",
-  "version": "0.29.1",
+  "version": "0.29.2",
   "description": "",
   "main": "src/index.ts",
   "scripts": {

src/lib/queues/createEmailQueue.ts

@@ -1,8 +1,8 @@
 import createQueue, { WorkerEvents } from './createQueue'
 import sendEmail, { EmailConfig } from '../messaging/sendEmail'
 
-const createEmailQueue = (events: WorkerEvents<EmailConfig> = {}) => {
-  const queue = createQueue<EmailConfig>('email', async (job) => {
+const createEmailQueue = (events: WorkerEvents<EmailConfig> = {}, prefix = '') => {
+  const queue = createQueue<EmailConfig>(prefix + 'email', async (job) => {
     await sendEmail(job.data.mail)
   }, events)
 

src/services/data-export.service.ts

@@ -75,7 +75,7 @@ export default class DataExportService extends Service {
       failed: async (job: Job<EmailConfig>) => {
         await this.updateDataExportStatus(job.data.metadata.dataExportId as number, { failedAt: new Date() })
       }
-    })
+    }, 'data-export')
 
     this.queue = createQueue<DataExportJob>('data-export', async (job: Job<DataExportJob>) => {
       const { dataExportId, includeDevData } = job.data
@@ -93,7 +93,7 @@ export default class DataExportService extends Service {
       const zip: AdmZip = await this.createZip(dataExport, em as EntityManager, includeDevData)
       zip.writeZip(filepath)
 
-      dataExport.status = DataExportStatus.QUEUED
+      dataExport.status = DataExportStatus.GENERATED
       await em.flush()
       await orm.close()