deleted row logging

Author: EspressoTrip-v2

modules/module-mongodb-storage/src/storage/MongoReportStorage.ts

@@ -166,7 +166,9 @@ export class MongoReportStorage implements storage.ReportStorageFactory {
       $or: [{ disconnect_at: { $exists: true } }, { jwt_exp: { $lt: new Date() }, disconnect_at: { $exists: false } }]
     });
     if (result.deletedCount > 0) {
-      logger.info(`TTL: ${result.deletedCount} documents have been removed from sdk_report_events collection`);
+      logger.info(
+        `TTL ${interval}/${timeframe}: ${result.deletedCount} MongoDB documents have been removed from sdk_report_events.`
+      );
     }
   }
 

modules/module-postgres-storage/src/storage/PostgresReportStorageFactory.ts

@@ -16,6 +16,8 @@ import {
   SdkDisconnectEventData
 } from '@powersync/service-types/src/events.js';
 import { SdkReporting, SdkReportingDecoded } from '../types/models/SdkReporting.js';
+import { toInteger } from 'ix/util/tointeger.js';
+import { logger } from '@powersync/lib-services-framework';
 
 export type PostgresReportStorageOptions = {
   config: NormalizedPostgresStorageConfig;
@@ -367,7 +369,12 @@ export class PostgresReportStorageFactory implements storage.ReportStorageFactor
           )
         );
     `.execute();
-    console.log(result);
+    const deletedRows = toInteger(result.results[1].status.split(' ')[1] || '0');
+    if (deletedRows > 0) {
+      logger.info(
+        `TTL ${interval}/${timeframe}: ${deletedRows} PostgresSQL rows have been removed from sdk_report_events.`
+      );
+    }
   }
 
   async [Symbol.asyncDispose]() {