feat: added redis bgrewriteaof command to one time job

dappforce · Apr 3, 2024 · 8d098b1 · 8d098b1
1 parent 8701508
commit 8d098b1
Show file tree

Hide file tree

Showing 2 changed files with 33 additions and 1 deletion.
diff --git a/src/modules/aggregatorStateManager/oneTimeJobsManager.service.ts b/src/modules/aggregatorStateManager/oneTimeJobsManager.service.ts
@@ -12,10 +12,15 @@ type OneTimeJob = { id: string; action: string } & {
 
 const oneTimeJobsList: OneTimeJob[] = [
   {
-    id: '1710336390625',
+    id: '1712148386341',
     action: 'removeAllActiveJobs',
     payload: {},
   },
+  {
+    id: '1712148398499',
+    action: 'redisBgrewriteaof',
+    payload: {},
+  },
 ];
 
 @Injectable()
@@ -78,6 +83,22 @@ export class OneTimeJobsManagerService {
           }
           break;
         }
+        case 'redisBgrewriteaof': {
+          try {
+            await this.datasourceHandlingProducer.refreshRedisAofFile();
+
+            processedJobs.push(jobId);
+            console.log(
+              `OneTime Jobs :: OneTime Job has been completed with details: [id: ${jobDetails.id} // action: ${jobDetails.action}]`,
+            );
+          } catch (e) {
+            console.log(
+              `OneTime Jobs :: OneTime Job ${jobId} has been processed with error.`,
+            );
+            console.log(e);
+          }
+          break;
+        }
 
         default:
       }

diff --git a/src/modules/queueProcessor/services/producers/datasourceHandling.producer.ts b/src/modules/queueProcessor/services/producers/datasourceHandling.producer.ts
@@ -82,6 +82,17 @@ export class DatasourceHandlingProducer {
     }
   }
 
+  /**
+   * Command BGREWRITEAOF can be executed from any Redis DB connection client
+   * and it will have effect to global appendonly.aof file
+   */
+  async refreshRedisAofFile() {
+    await this.datasourceHandlingQueue.client.bgrewriteaof((err, result) => {
+      console.log(`bgrewriteaof :: err `, err);
+      console.log(`bgrewriteaof :: result `, result);
+    });
+  }
+
   //
   // async enqueueAndWaitCollectTransferEventDataChunkJobProducer(
   //   requestData: CollectEventDataChunkFromDataSourceInput,