Fixed toHexString is not a function

For some unknown reason, the data for a job when it is run no longer contains the user _id as an ObjectId, even though when the job was added to the queue, it was an ObjectId. Instead it emerges as a string. To fix, just convert back to ObjectId before we do anything else with the job.

Signed-off-by: Matthew Nickson <mnickson@sidingsmedia.com>

Author: Computroniks

src/tasks/delete-for-domain/delete-for-domain.processor.ts

@@ -9,6 +9,7 @@ import { Forwarder } from 'src/forwarders/class/forwarder.class'
 import { ForwardersService } from 'src/forwarders/forwarders.service'
 
 import { DeleteForDomainData } from './delete-for-domain.interfaces'
+import { ObjectId } from 'mongodb'
 
 @Processor('deleteForDomain')
 export class DeleteForDomainProcessor {
@@ -22,6 +23,9 @@ export class DeleteForDomainProcessor {
 
   @Process({ name: 'deleteAccounts' })
   private async processDeleteAccounts(job: Job<DeleteForDomainData>): Promise<void> {
+    // Job data contains _id as string, not as ObjectId for unknown reason
+    job.data.user._id = new ObjectId(job.data.user._id)
+
     let accounts: AccountListItem[] = []
     try {
       accounts = await this.accountsService.getAccounts(job.data.user, job.data.domain)
@@ -55,6 +59,9 @@ export class DeleteForDomainProcessor {
 
   @Process({ name: 'deleteForwarders' })
   private async processDeleteForwarders(job: Job<DeleteForDomainData>): Promise<void> {
+    // Job data contains _id as string, not as ObjectId for unknown reason
+    job.data.user._id = new ObjectId(job.data.user._id)
+
     let forwarders: Forwarder[] = []
     try {
       forwarders = await this.forwardersService.getForwarders(job.data.user, job.data.domain)
@@ -88,6 +95,9 @@ export class DeleteForDomainProcessor {
 
   @Process({ name: 'deleteAccountAliases' })
   private async processDeleteAccountAliases(job: Job<DeleteForDomainData>): Promise<void> {
+    // Job data contains _id as string, not as ObjectId for unknown reason
+    job.data.user._id = new ObjectId(job.data.user._id)
+
     const accountAliases = await this.accountsService.getAliases(job.data.user, job.data.domain)
     if (!accountAliases || accountAliases.length === 0) {
       return
@@ -114,6 +124,9 @@ export class DeleteForDomainProcessor {
 
   @Process({ name: 'deleteAliases' })
   private async processDeleteAliases(job: Job<DeleteForDomainData>): Promise<void> {
+    // Job data contains _id as string, not as ObjectId for unknown reason
+    job.data.user._id = new ObjectId(job.data.user._id)
+
     const aliases = job.data.user.domains.find((domain) => domain.domain === job.data.domain).aliases
     if (!aliases || aliases.length === 0) {
       return
@@ -141,7 +154,9 @@ export class DeleteForDomainProcessor {
   @OnQueueActive()
   private onActive(job: Job<DeleteForDomainData>): void {
     this.logger.log(
-      `Processing job ${job.id} (${job.name}) for user ${job.data.user._id} and domain ${job.data.domain}`,
+      `Processing job ${job.id} (${job.name}) for user ${job.data.user._id.toHexString()} and domain ${
+        job.data.domain
+      }`,
     )
   }