diff --git a/src/events/events.service.ts b/src/events/events.service.ts index 1a1aaae..0dd2502 100644 --- a/src/events/events.service.ts +++ b/src/events/events.service.ts @@ -395,7 +395,7 @@ export class EventsService implements OnApplicationBootstrap { name: 'add-registration-credit', queueName: 'registrator-updates-queue', data: { - account: accountString, + address: accountString, fingerprint: fingerprintString, tx: event.transactionHash }, diff --git a/src/events/processors/registrator-updates-queue.ts b/src/events/processors/registrator-updates-queue.ts index b22d13c..f1babc3 100644 --- a/src/events/processors/registrator-updates-queue.ts +++ b/src/events/processors/registrator-updates-queue.ts @@ -19,12 +19,15 @@ export class RegistratorUpdatesQueue extends WorkerHost { async process( job: Job, ): Promise { - this.logger.debug(`Dequeueing ${job.name} [${job.id}] - ${job.data}`) + this.logger.debug( + `Dequeueing ${job.name} [${job.id}] - ${JSON.stringify(job.data)}` + ) switch (job.name) { case RegistratorUpdatesQueue.JOB_ADD_REGISTRATION_CREDIT: try { - const data: AddRegistrationCreditEventData = job.data as AddRegistrationCreditEventData + const data: AddRegistrationCreditEventData = + job.data as AddRegistrationCreditEventData if (data != undefined) { this.logger.log( `Adding registration credit for ${data.address} seen at ${data.tx}`,