feat(indexer): scheduled event retention cleanup job for transaction audit log (closes #174)

server/.env.example

@@ -30,6 +30,8 @@ SOROBAN_NETWORK_PASSPHRASE=Test SDF Network ; September 2015
 PRODUCTION_ESCROW_CONTRACT_ID=
 ESCROW_CONTRACT_ID=
 EVENT_POLL_INTERVAL_MS=5000
+# Retention window in days for generic Transaction event audit log rows (pruned daily).
+# Domain records (Investment, Tranche, Dispute, Campaign, User) are permanently retained.
 EVENT_RETENTION_DAYS=7
 # Ledger to start indexing from on first run (no persisted cursor yet).
 # Leave unset to start from the current latest ledger.

server/package.json

@@ -42,6 +42,7 @@
     "@nestjs/core": "^10.4.4",
     "@nestjs/platform-express": "^10.4.4",
     "@nestjs/platform-socket.io": "^10.4.22",
+    "@nestjs/schedule": "^4.1.2",
     "@nestjs/terminus": "^10.2.3",
     "@nestjs/throttler": "^6.5.0",
     "@nestjs/websockets": "^10.4.22",

server/src/app.module.ts

@@ -4,6 +4,7 @@ import {
   ConfigModule as NestConfigModule,
   ConfigService,
 } from '@nestjs/config';
+import { ScheduleModule } from '@nestjs/schedule';
 import { ThrottlerGuard, ThrottlerModule } from '@nestjs/throttler';
 import { ConfigModule } from './config/config.module';
 import { LoggerModule } from './common/logger/logger.module';
@@ -22,6 +23,7 @@ import { InvestorsModule } from './modules/investors/investors.module';
   imports: [
     ConfigModule,
     LoggerModule,
+    ScheduleModule.forRoot(),
     ThrottlerModule.forRootAsync({
       imports: [NestConfigModule],
       inject: [ConfigService],

server/src/indexer/indexer.module.ts

@@ -1,11 +1,20 @@
 import { Module } from '@nestjs/common';
 import { SorobanEventListenerService } from './soroban-event-listener.service';
 import { EventParserService } from './parsers/event-parser.service';
+import { EventRetentionService } from './retention/event-retention.service';
 import { WebsocketModule } from '../websocket/websocket.module';
 
 @Module({
   imports: [WebsocketModule],
-  providers: [SorobanEventListenerService, EventParserService],
-  exports: [SorobanEventListenerService, EventParserService],
+  providers: [
+    SorobanEventListenerService,
+    EventParserService,
+    EventRetentionService,
+  ],
+  exports: [
+    SorobanEventListenerService,
+    EventParserService,
+    EventRetentionService,
+  ],
 })
 export class IndexerModule {}