feat(be): 🚀 update worker name for tracking & monitor

apps/be/.env.example

@@ -13,6 +13,7 @@ REDIS_CONNECT_TIMEOUT=5000
 
 # OPTIONAL
 
+BULL_NAME='tasktr'
 BULL_TASK_CONCURRENCY=20
 BULL_BACKGROUND_CONCURRENCY=10
 BULL_SAVE_LOG_CONCURRENCY=10

apps/be/common/src/bullmq/task-log.processor.ts

@@ -39,6 +39,9 @@ export class TaskLogProcessor extends WorkerHost implements OnModuleInit {
     async saveTaskLog(job: Job<unknown, unknown, TaskJobName>): Promise<boolean> {
         try {
             const res = await this.taskLogsService.create(job.data as CreateTaskLogDto);
+            if (res) {
+                this.logger.info(`Saved task log: ${res._id}`);
+            }
             return !!res;
         } catch (error) {
             this.logger.error(`Error saving task log: ${error}`);

apps/be/common/src/bullmq/task.processor.ts

@@ -70,6 +70,7 @@ export class TaskProcessor extends WorkerHost implements OnModuleInit {
             taskId: job.data._id,
             endpoint,
             method,
+            workerName: process.env['BULL_NAME'] ?? 'default',
             scheduledAt: new Date(job?.processedOn ?? now),
             executedAt: new Date(job?.finishedOn ?? now),
             duration: 0,

apps/be/src/app/task-logs/dtos/task-log.dto.ts

@@ -38,6 +38,10 @@ export class TaskLogDto implements TaskLog {
     @IsNumber()
     statusCode: number;
 
+    @ApiProperty({ type: String })
+    @IsString()
+    workerName: string;
+
     @ApiProperty({ type: Date, required: false })
     @IsDate()
     @IsOptional()

apps/be/src/app/task-logs/task-log.schema.ts

@@ -32,6 +32,9 @@ export class TaskLog extends AbstractDocument {
     @Prop({ required: true, type: Date })
     executedAt: Date;
 
+    @Prop({ required: false, default: '' })
+    workerName: string;
+
     @Prop({ required: false, default: new Date() })
     createdAt?: Date;