refactor code

Author: Ihar

common/src/mq/nats-service.ts

@@ -212,7 +212,7 @@ export abstract class NatsService {
      * @param noRespond
      */
     public getMessages<T, A>(subject: string, cb: Function, noRespond = false): Subscription {
-        const sub = this.connection.subscribe(subject, {
+        return this.connection.subscribe(subject, {
             queue: this.messageQueueName,
             callback: async (error, msg) => {
                 try {
@@ -236,7 +236,5 @@ export abstract class NatsService {
                 }
             }
         });
-
-        return sub;
     }
 }

worker-service/src/api/worker.ts

@@ -28,7 +28,6 @@ function logMemoryUsage(label: string) {
 function rejectTimeout(t: number): Promise<void> {
     return new Promise((_, reject) => {
         setTimeout(() => {
-            console.log(`⏳ Timeout reached after ${t}ms`);
             reject(new Error('Timeout error'));
         }, t);
     })
@@ -165,8 +164,6 @@ export class Worker extends NatsService {
         }
 
         this.subscribe(WorkerEvents.GET_FREE_WORKERS, async (msg) => {
-            // console.log('this.replySubject worker init', this.replySubject)
-            // console.log('msg.replySubject worker init', msg.replySubject)
             if (!this.isInUse) {
                 this.publish(msg.replySubject, {
                     subject: [this.replySubject, WorkerEvents.SEND_TASK_TO_WORKER].join('.'),
@@ -311,9 +308,7 @@ export class Worker extends NatsService {
                     if (!task.data.payload || !task.data.payload.cid || !task.data.payload.responseType) {
                         result.error = 'Invalid CID';
                     } else {
-                        logMemoryUsage('Before IPFS File Fetch');
                         let fileContent = await this.ipfsClient.getFile(task.data.payload.cid);
-                        logMemoryUsage('After IPFS File Fetch');
                         if (fileContent instanceof Buffer) {
                             const data = await this.channel.request<any, any>(ExternalMessageEvents.IPFS_AFTER_READ_CONTENT, {
                                 responseType: !task.data.payload.responseType,
@@ -1001,12 +996,10 @@ export class Worker extends NatsService {
     private processTaskWithTimeout(task: ITask): Promise<ITaskResult> {
         return new Promise(async (resolve, reject) => {
             try {
-                logMemoryUsage('Before Processing Task');
                 const result = await Promise.race([
                     this.processTask(task),
                     rejectTimeout(this.taskTimeout)
                 ]);
-                logMemoryUsage('After Processing Task');
                 resolve(result as ITaskResult);
             } catch (e) {
                 const error = {