refactor: logs TTL

Author: venki91

lib/index.js

@@ -356,13 +356,15 @@ class ErrsoleSequelize extends EventEmitter {
    *
    * @async
    * @function ensureLogsTTL
-   * @returns {Promise<{}>} - Resolves with an empty object once the TTL configuration is confirmed or updated.
+   * @returns {Promise<{}>} - A promise that resolves with an empty object once the TTL configuration is confirmed or updated.
    */
   async ensureLogsTTL () {
     const DEFAULT_TTL = 2592000000; // 30 days in milliseconds
     try {
-      const config = await this.errsoleConfig.findOne({ where: { key: 'logsTTL' }, raw: true });
-      if (!config) await this.errsoleConfig.create({ key: 'logsTTL', value: DEFAULT_TTL.toString() });
+      const configResult = await this.getConfig('logsTTL');
+      if (!configResult.item) {
+        await this.setConfig('logsTTL', DEFAULT_TTL.toString());
+      }
       this.deleteExpiredLogs();
     } catch (err) {
       console.error(err);
@@ -378,26 +380,26 @@ class ErrsoleSequelize extends EventEmitter {
    */
   async deleteExpiredLogs () {
     try {
-      const config = await this.errsoleConfig.findOne({ where: { key: 'logsTTL' }, raw: true });
-      if (!config) {
+      const configResult = await this.getConfig('logsTTL');
+      if (!configResult.item) {
         throw new Error('Could not find the TTL configuration for logs.');
       }
 
-      const logsTTL = parseInt(config.value, 10);
+      const logsTTL = parseInt(configResult.item.value, 10);
       const expirationTime = new Date(new Date().getTime() - logsTTL);
-      const deletedRowCount = await this.errsoleLogs.destroy({
-        where: {
-          timestamp: {
-            [Sequelize.Op.lt]: expirationTime
-          }
-        },
-        limit: 1000
-      });
 
-      // Recurse based on whether logs were deleted
-      const delayTime = deletedRowCount ? 1000 : 3600000; // 3600000 ms equals 1 hour
-      await this.delay(delayTime);
-      this.deleteExpiredLogs();
+      while (true) {
+        const deletedRowCount = await this.errsoleLogs.destroy({
+          where: {
+            timestamp: {
+              [Sequelize.Op.lt]: expirationTime
+            }
+          },
+          limit: 1000
+        });
+        const delayTime = deletedRowCount ? 1000 : 3600000; // 1 second if rows were deleted, otherwise 1 hour
+        await this.delay(delayTime);
+      }
     } catch (err) {
       console.error(err);
     }