Comprehensive Notification System (Email, SMS, Push)

.env.example

@@ -48,6 +48,19 @@ QUEUE_REMOVE_ON_FAIL=false
 JWT_SECRET=your-super-secret-jwt-key-change-this-in-production
 JWT_EXPIRES_IN=3600
 JWT_REFRESH_SECRET=your-refresh-secret-key-change-this-in-production
+
+# Email (SMTP) Configuration - Nodemailer
+SMTP_HOST=smtp.example.com
+SMTP_PORT=587
+SMTP_SECURE=false
+SMTP_USER=noreply@swaptrade.com
+SMTP_PASSWORD=your-smtp-password
+EMAIL_FROM=noreply@swaptrade.com
+
+# SMS Configuration - Twilio
+TWILIO_ACCOUNT_SID=your-twilio-account-sid
+TWILIO_AUTH_TOKEN=your-twilio-auth-token
+TWILIO_PHONE_NUMBER=+1234567890
 JWT_REFRESH_EXPIRES_IN=604800
 BCRYPT_ROUNDS=12
 AUTH_MAX_LOGIN_ATTEMPTS=5
@@ -119,4 +132,4 @@ OTEL_EXPORTER_OTLP_ENDPOINT=http://localhost:4318/v1/traces
 # Sampling rate: 1.0 = 100 % of traces, 0.1 = 10 %, etc.
 OTEL_SAMPLING_RATE=1.0
 # How often (ms) the batch processor flushes spans in production
-OTEL_EXPORT_INTERVAL=5000
+OTEL_EXPORT_INTERVAL=5000

src/app.module.ts

@@ -73,6 +73,7 @@ import { PoolSwap } from './exchange/entities/pool-swap.entity';
 import { EmergencyWithdrawal } from './exchange/entities/emergency-withdrawal.entity';
 import { ExchangeModule } from './exchange/exchange.module';
 import { MobileModule } from './mobile/mobile.module';
+import { NotificationsModule } from './notifications/notifications.module';
 
 @Module({
   imports: [
@@ -81,7 +82,7 @@ import { MobileModule } from './mobile/mobile.module';
     I18nModule.forRoot({
       fallbackLanguage: 'en',
       loaderOptions: {
-        path: path.join(__dirname, '/i18n/'),
+        path: path.join(__dirname, '/notifications/templates/i18n/'),
         watch: true,
       },
       resolvers: [
@@ -103,7 +104,7 @@ import { MobileModule } from './mobile/mobile.module';
       imports: [ConfigModule],
       inject: [ConfigService],
       useFactory: (configService: ConfigService) => ({
-        type: configService.get<string>('DB_TYPE', 'postgres') as '' | 'sqlite',
+        type: configService.get<string>('DB_TYPE', 'postgres') as 'postgres' | 'sqlite',
         host: configService.get<string>('DB_HOST', 'localhost'),
         port: configService.get<number>('DB_PORT', 5432),
         username: configService.get<string>('DB_USERNAME', 'postgres'),
@@ -169,17 +170,20 @@ import { MobileModule } from './mobile/mobile.module';
     // ── Trading Features — Advanced Order Types (issue #382) ──
     OrdersModule,
 
-    // ── Mobile Integration ──
+    // Mobile Integration ──
     MobileModule,
     // ── Institutional Portal ──
     InstitutionalModule,
     // ── AI Features — Trading Assistant (issue #395) ──
     AiTradingAssistantModule,
 
+    // ── Notifications Module ──
+    NotificationsModule,
+
     // ── Error Handling ──
     ErrorModule,
   ],
   controllers: [AppController],
   providers: [AppService],
 })
-export class AppModule {}
+export class AppModule {}

src/auth/auth.controller.ts

@@ -17,7 +17,7 @@ import {
   ApiResponse,
   ApiTags,
 } from '@nestjs/swagger';
-import { Request } from 'express';
+import type { Request } from 'express';
 
 import { AuthService } from './auth.service';
 import { RegisterDto } from './dto/register.dto';
@@ -29,7 +29,8 @@ import {
   ChangePasswordDto,
 } from './dto/password-reset.dto';
 import { Enable2FADto, TwoFADto, Verify2FASetupDto } from './dto/2fa.dto';
-import { JwtAuthGuard, JwtPayload } from './guards/jwt-auth.guard';
+import { JwtAuthGuard } from './guards/jwt-auth.guard';
+import type { JwtPayload } from './guards/jwt-auth.guard';
 import { CurrentUser } from './decorators/current-user.decorator';
 import { Public } from './decorators/public.decorator';
 import { ApiAuthErrorResponses } from '../common/decorators/swagger-error-responses.decorator';
@@ -201,4 +202,4 @@ export class AuthController {
   disable2FA(@CurrentUser() user: JwtPayload, @Body() dto: TwoFADto) {
     return this.authService.disable2FA(user.sub, dto);
   }
-}
+}

src/auth/mfa.controller.ts

@@ -4,7 +4,7 @@ import { ApiBearerAuth, ApiOperation, ApiResponse, ApiTags } from '@nestjs/swagg
 import { MFAService } from './mfa.service';
 import { JwtAuthGuard } from './guards/jwt-auth.guard';
 import { CurrentUser } from './decorators/current-user.decorator';
-import { JwtPayload } from './guards/jwt-auth.guard';
+import type { JwtPayload } from './guards/jwt-auth.guard';
 
 @ApiTags('identity/auth/mfa')
 @UseGuards(JwtAuthGuard)
@@ -53,4 +53,4 @@ export class MFAController {
     const isValid = await this.mfaService.verifyToken(user.sub, body.token);
     return { success: isValid };
   }
-}
+}

src/common/enums/notification-channel.enum.ts

@@ -0,0 +1,5 @@
+export enum NotificationChannel {
+  EMAIL = 'EMAIL',
+  SMS = 'SMS',
+  PUSH = 'PUSH',
+}

src/common/enums/notification-event-type.enum.ts

@@ -1,5 +1,10 @@
 export enum NotificationEventType {
   ORDER_FILLED = 'ORDER_FILLED',
+  TRADE_EXECUTED = 'TRADE_EXECUTED',
+  LIQUIDATION = 'LIQUIDATION',
+  DEPOSIT_RECEIVED = 'DEPOSIT_RECEIVED',
   PRICE_ALERT = 'PRICE_ALERT',
   ACHIEVEMENT_UNLOCKED = 'ACHIEVEMENT_UNLOCKED',
-}
+  WITHDRAWAL_COMPLETED = 'WITHDRAWAL_COMPLETED',
+  SECURITY_ALERT = 'SECURITY_ALERT',
+}

src/common/enums/notification-status.enum.ts

@@ -1,5 +1,10 @@
 export enum NotificationStatus {
+  PENDING = 'PENDING',
+  PROCESSING = 'PROCESSING',
+  RETRYING = 'RETRYING',
   SENT = 'SENT',
+  DELIVERED = 'DELIVERED',
   READ = 'READ',
   FAILED = 'FAILED',
-}
+  PERMANENTLY_FAILED = 'PERMANENTLY_FAILED',
+}

src/common/logging/audit_service.ts

@@ -56,7 +56,7 @@ interface UserAuditData {
 }
 
 interface CreateEntryDto {
-  userId: number;
+  userId: string;
   eventType: string;
   entityType: string;
   entityId: string;
@@ -278,4 +278,4 @@ export class AuditService {
 
     this.logger.audit(auditData);
   }
-}
+}

src/common/monitoring/interceptors/monitoring.interceptor.ts

@@ -126,8 +126,6 @@ export class MonitoringInterceptor implements NestInterceptor {
       // eslint-disable-next-line @typescript-eslint/no-this-alias
       const self = this;
 
-      context.active(); // keep TypeScript happy — using OTel context below
-
       // Bind the handler execution to the active span context
       const handlerResult$ = (
         require('@opentelemetry/api').context as typeof import('@opentelemetry/api').context
@@ -211,4 +209,4 @@ export class MonitoringInterceptor implements NestInterceptor {
         .subscribe(subscriber);
     });
   }
-}
+}

src/governance/constants/index.ts

@@ -1 +1 @@
-export * from './constants/governance.constants';
+export * from './governance.constants';

src/governance/controllers/index.ts

@@ -0,0 +1 @@
+export * from './governance.controller';

src/governance/entities/governance-proposal.entity.ts

@@ -74,4 +74,10 @@ export class GovernanceProposal {
 
   @UpdateDateColumn()
   updatedAt: Date;
-}
+
+  @Column('decimal', { precision: 18, scale: 8, default: 51 })
+  passThresholdVotes: number;
+
+  @Column({ nullable: true })
+  executionReason: string;
+}

src/governance/entities/governance-vote.entity.ts

@@ -3,6 +3,7 @@ import {
   PrimaryGeneratedColumn,
   Column,
   CreateDateColumn,
+  UpdateDateColumn,
   Index,
 } from 'typeorm';
 
@@ -40,4 +41,10 @@ export class GovernanceVote {
 
   @Column('text', { nullable: true })
   reason: string;
-}
+
+  @CreateDateColumn()
+  createdAt: Date;
+
+  @UpdateDateColumn()
+  updatedAt: Date;
+}

src/governance/entities/index.ts

@@ -0,0 +1,7 @@
+export * from './governance-config.entity';
+export * from './governance-discussion.entity';
+export * from './governance-execution.entity';
+export * from './governance-proposal.entity';
+export * from './governance-vote.entity';
+export * from './token-holding.entity';
+export * from './vote-delegation.entity';

src/governance/services/governance.service.ts

@@ -6,8 +6,8 @@ import {
   ProposalType,
   VoteType,
   DiscussionMessageType,
-  GOVERNANCE_PARAMS,
-} from '../constants/governance.constants';
+} from '../enums/governance.enum';
+import { GOVERNANCE_PARAMS } from '../constants/governance.constants';
 import {
   GovernanceProposal,
   GovernanceVote,
@@ -176,4 +176,4 @@ export class GovernanceService {
       take: limit,
     });
   }
-}
+}