Feature/backend savings goals milestones comparison autodeposit

backend/src/app.module.ts

@@ -24,7 +24,7 @@ import { ChallengesModule } from './modules/challenges/challenges.module';
 import { AlertsModule } from './modules/alerts/alerts.module';
 import { AdminModule } from './modules/admin/admin.module';
 import { MailModule } from './modules/mail/mail.module';
-import { RedisCacheModule } from './modules/cache/cache.module';
+import { CacheModule } from './modules/cache/cache.module';
 import { WebhooksModule } from './modules/webhooks/webhooks.module';
 import { ClaimsModule } from './modules/claims/claims.module';
 import { DisputesModule } from './modules/disputes/disputes.module';
@@ -172,7 +172,7 @@ const envValidationSchema = Joi.object({
       },
     }),
     AuthModule,
-    RedisCacheModule,
+    CacheModule,
     HealthModule,
     BlockchainModule,
     UserModule,

backend/src/auth/auth.service.spec.ts

@@ -2,6 +2,7 @@ import { Test, TestingModule } from '@nestjs/testing';
 import { AuthService } from './auth.service';
 import { UserService } from '../modules/user/user.service';
 import { JwtService } from '@nestjs/jwt';
+import { EventEmitter2 } from '@nestjs/event-emitter';
 import { ConflictException, UnauthorizedException } from '@nestjs/common';
 // import { CACHE_MANAGER } from '@nestjs/cache-manager';
 import * as bcrypt from 'bcrypt';
@@ -42,6 +43,12 @@ describe('AuthService', () => {
             sign: jest.fn().mockReturnValue('mock-token'),
           },
         },
+        {
+          provide: EventEmitter2,
+          useValue: {
+            emit: jest.fn(),
+          },
+        },
         // {
         //   provide: CACHE_MANAGER,
         //   useValue: mockCacheManager,

backend/src/auth/dto/auth.dto.ts

@@ -1,4 +1,10 @@
-import { IsEmail, IsString, MinLength, MaxLength, IsOptional } from 'class-validator';
+import {
+  IsEmail,
+  IsString,
+  MinLength,
+  MaxLength,
+  IsOptional,
+} from 'class-validator';
 import { ApiProperty, ApiPropertyOptional } from '@nestjs/swagger';
 import { IsStellarPublicKey } from '../../common/validators/is-stellar-key.validator';
 
@@ -17,7 +23,10 @@ export class RegisterDto {
   @IsString()
   name?: string;
 
-  @ApiPropertyOptional({ example: 'ABC12345', description: 'Referral code from another user' })
+  @ApiPropertyOptional({
+    example: 'ABC12345',
+    description: 'Referral code from another user',
+  })
   @IsOptional()
   @IsString()
   referralCode?: string;

backend/src/common/interceptors/cache.interceptor.ts

@@ -4,8 +4,8 @@ import {
   ExecutionContext,
   CallHandler,
 } from '@nestjs/common';
-import { Observable, of } from 'rxjs';
-import { tap } from 'rxjs/operators';
+import { Observable, from, of } from 'rxjs';
+import { switchMap, tap } from 'rxjs/operators';
 import { CacheStrategyService } from '../../modules/cache/cache-strategy.service';
 
 @Injectable()
@@ -23,16 +23,18 @@ export class CacheInterceptor implements NestInterceptor {
 
     const cacheKey = `${url}:${JSON.stringify(query)}`;
 
-    return this.cacheStrategy.get(cacheKey).then((cached) => {
-      if (cached) {
-        return of(cached);
-      }
+    return from(this.cacheStrategy.get(cacheKey)).pipe(
+      switchMap((cached) => {
+        if (cached) {
+          return of(cached);
+        }
 
-      return next.handle().pipe(
-        tap((data) => {
-          this.cacheStrategy.set(cacheKey, data);
-        }),
-      );
-    });
+        return next.handle().pipe(
+          tap((data) => {
+            this.cacheStrategy.set(cacheKey, data);
+          }),
+        );
+      }),
+    );
   }
 }

backend/src/common/interceptors/graceful-shutdown.interceptor.ts

@@ -4,7 +4,7 @@ import {
   ExecutionContext,
   CallHandler,
 } from '@nestjs/common';
-import { Observable } from 'rxjs';
+import { EMPTY, Observable } from 'rxjs';
 import { finalize } from 'rxjs/operators';
 import { GracefulShutdownService } from '../services/graceful-shutdown.service';
 
@@ -20,7 +20,7 @@ export class GracefulShutdownInterceptor implements NestInterceptor {
         statusCode: 503,
         message: 'Service is shutting down',
       });
-      return;
+      return EMPTY;
     }
 
     this.gracefulShutdown.incrementActiveRequests();

backend/src/common/services/graceful-shutdown.service.ts

@@ -49,9 +49,7 @@ export class GracefulShutdownService implements OnApplicationShutdown {
     await this.closeRedis();
 
     const shutdownDuration = Date.now() - shutdownStartTime;
-    this.logger.log(
-      `Graceful shutdown completed in ${shutdownDuration}ms`,
-    );
+    this.logger.log(`Graceful shutdown completed in ${shutdownDuration}ms`);
   }
 
   private async waitForInFlightRequests(): Promise<void> {
@@ -93,7 +91,22 @@ export class GracefulShutdownService implements OnApplicationShutdown {
     try {
       if (this.cacheManager) {
         this.logger.log('Closing Redis connections...');
-        await this.cacheManager.reset();
+        const cacheAny = this.cacheManager as unknown as {
+          clear?: () => Promise<void>;
+          stores?: Array<{ disconnect?: () => Promise<void> }>;
+        };
+
+        if (cacheAny.clear) {
+          await cacheAny.clear();
+        }
+
+        if (Array.isArray(cacheAny.stores)) {
+          for (const store of cacheAny.stores) {
+            if (store?.disconnect) {
+              await store.disconnect();
+            }
+          }
+        }
         this.logger.log('Redis connections closed');
       }
     } catch (error) {

backend/src/config/configuration.ts

@@ -93,10 +93,25 @@ export default () => ({
     ),
   },
   balanceSync: {
-    cacheTtlSeconds: parseInt(process.env.BALANCE_CACHE_TTL_SECONDS || '300', 10),
-    pollIntervalMs: parseInt(process.env.BALANCE_POLL_INTERVAL_MS || '5000', 10),
-    reconnectInitialDelayMs: parseInt(process.env.BALANCE_RECONNECT_INIT_MS || '1000', 10),
-    reconnectMaxDelayMs: parseInt(process.env.BALANCE_RECONNECT_MAX_MS || '60000', 10),
-    metricsPersistIntervalMs: parseInt(process.env.BALANCE_METRICS_PERSIST_MS || '60000', 10),
+    cacheTtlSeconds: parseInt(
+      process.env.BALANCE_CACHE_TTL_SECONDS || '300',
+      10,
+    ),
+    pollIntervalMs: parseInt(
+      process.env.BALANCE_POLL_INTERVAL_MS || '5000',
+      10,
+    ),
+    reconnectInitialDelayMs: parseInt(
+      process.env.BALANCE_RECONNECT_INIT_MS || '1000',
+      10,
+    ),
+    reconnectMaxDelayMs: parseInt(
+      process.env.BALANCE_RECONNECT_MAX_MS || '60000',
+      10,
+    ),
+    metricsPersistIntervalMs: parseInt(
+      process.env.BALANCE_METRICS_PERSIST_MS || '60000',
+      10,
+    ),
   },
 });

backend/src/migrations/1775400000000-CreateInterestHistoryTable.ts

@@ -6,9 +6,7 @@ import {
   TableIndex,
 } from 'typeorm';
 
-export class CreateInterestHistoryTable1775400000000
-  implements MigrationInterface
-{
+export class CreateInterestHistoryTable1775400000000 implements MigrationInterface {
   public async up(queryRunner: QueryRunner): Promise<void> {
     await queryRunner.createTable(
       new Table({

backend/src/migrations/1776000000000-CreateReferralsTable.ts

@@ -1,4 +1,10 @@
-import { MigrationInterface, QueryRunner, Table, TableIndex, TableForeignKey } from 'typeorm';
+import {
+  MigrationInterface,
+  QueryRunner,
+  Table,
+  TableIndex,
+  TableForeignKey,
+} from 'typeorm';
 
 export class CreateReferralsTable1776000000000 implements MigrationInterface {
   public async up(queryRunner: QueryRunner): Promise<void> {