feat: add health and email consumer

services/email_service/.env.sample

@@ -10,4 +10,3 @@ MAIL_HOST=<smtp-host>
 MAIL_PORT=<smtp-port>
 SMTP_USER=<your-email>
 SMTP_PASS=<your-password>
-MAIL_FROM="Framez <noreply@framez.app>"

services/email_service/README.md

@@ -90,7 +90,6 @@ MAIL_HOST=<smtp-host>
 MAIL_PORT=<smtp-port>
 SMTP_USER=<your-email>
 SMTP_PASS=<your-password>
-MAIL_FROM="Framez <noreply@framez.app>"
 ```
 
 #### 4. Run PostgreSQL and RabbitMQ (via Docker Compose or local):

services/email_service/package.json

@@ -17,18 +17,33 @@
     "test:watch": "jest --watch",
     "test:cov": "jest --coverage",
     "test:debug": "node --inspect-brk -r tsconfig-paths/register -r ts-node/register node_modules/.bin/jest --runInBand",
-    "test:e2e": "jest --config ./test/jest-e2e.json"
+    "test:e2e": "jest --config ./test/jest-e2e.json",
+    "typeorm": "typeorm-ts-node-esm",
+    "migration:generate": "ts-node ./node_modules/typeorm/cli.js migration:generate -d src/config/data-source.ts",
+    "migration:run": "ts-node ./node_modules/typeorm/cli.js migration:run -d src/config/data-source.ts",
+    "migration:revert": "ts-node ./node_modules/typeorm/cli.js migration:revert -d src/config/data-source.ts"
   },
   "dependencies": {
     "@nestjs-modules/mailer": "^2.0.2",
+    "@nestjs/axios": "^4.0.1",
+    "@nestjs/cache-manager": "^3.0.1",
     "@nestjs/common": "^11.0.1",
     "@nestjs/config": "^4.0.2",
     "@nestjs/core": "^11.0.1",
     "@nestjs/microservices": "^11.1.8",
     "@nestjs/platform-express": "^11.0.1",
+    "@nestjs/swagger": "^11.2.1",
+    "@nestjs/terminus": "^11.0.0",
     "@nestjs/typeorm": "^11.0.0",
+    "@sendgrid/mail": "^8.1.6",
     "amqp-connection-manager": "^5.0.0",
     "amqplib": "^0.10.9",
+    "cache-manager": "^7.2.4",
+    "class-transformer": "^0.5.1",
+    "class-validator": "^0.14.2",
+    "dotenv": "^17.2.3",
+    "ioredis": "^5.8.2",
+    "mailersend": "^2.6.0",
     "nodemailer": "^7.0.10",
     "pg": "^8.16.3",
     "reflect-metadata": "^0.2.2",

services/email_service/src/app.module.ts

@@ -1,18 +1,30 @@
+import {
+  DatabaseModule,
+  CacheConfigModule,
+  MailerConfigModule,
+} from './config';
 import { Module } from '@nestjs/common';
-import { AppService } from './app.service';
+import { HttpModule } from '@nestjs/axios';
 import { ConfigModule } from '@nestjs/config';
-import { AppController } from './app.controller';
-import { DatabaseModule } from './config/database.module';
-import { MailerConfigModule } from './config/mailer.module';
+import { TerminusModule } from '@nestjs/terminus';
+import { EmailModule } from './email/email.module';
+import { HealthController } from './health/health.controller';
 import { DatabaseLogger } from './utils/database-logger.service';
+import { EmailStatusModule } from './email-status/email-status.module';
+import { SendGridService } from './sendgrid/sendgrid.service';
 
 @Module({
   imports: [
     ConfigModule.forRoot({ isGlobal: true, envFilePath: '.env' }),
     DatabaseModule,
     MailerConfigModule,
+    TerminusModule,
+    HttpModule,
+    CacheConfigModule,
+    EmailModule,
+    EmailStatusModule,
   ],
-  controllers: [AppController],
-  providers: [AppService, DatabaseLogger],
+  controllers: [HealthController],
+  providers: [DatabaseLogger, SendGridService],
 })
 export class AppModule {}

services/email_service/src/config/cache.module.ts

@@ -0,0 +1,39 @@
+import Redis from 'ioredis';
+import { Module } from '@nestjs/common';
+import { CacheModule } from '@nestjs/cache-manager';
+
+@Module({
+  imports: [
+    CacheModule.registerAsync({
+      isGlobal: true,
+      useFactory: () => {
+        if (!process.env.REDIS_URL) {
+          throw new Error('CacheModule: REDIS_URL is not defined!');
+        }
+
+        const redisClient = new Redis(process.env.REDIS_URL);
+
+        // optional logging
+        redisClient.on('connect', () => console.log('Redis connected'));
+        redisClient.on('error', (err) => console.error('Redis error:', err));
+
+        return {
+          store: {
+            get: async (key: string): Promise<any> => {
+              const val = await redisClient.get(key);
+              return val ? JSON.parse(val) : null;
+            },
+            set: async (key: string, value: any, ttl: number) => {
+              return redisClient.set(key, JSON.stringify(value), 'EX', ttl);
+            },
+            del: async (key: string) => {
+              return redisClient.del(key);
+            },
+          },
+        };
+      },
+    }),
+  ],
+  exports: [CacheModule],
+})
+export class CacheConfigModule {}

services/email_service/src/config/data-source.ts

@@ -0,0 +1,18 @@
+import { config } from 'dotenv';
+import { DataSource } from 'typeorm';
+import { NotificationEmail } from '../email/entity/email.entity';
+
+config();
+
+export const AppDataSource = new DataSource({
+  type: 'postgres',
+  host: process.env.DB_HOST,
+  port: Number(process.env.DB_PORT),
+  username: process.env.DB_USER,
+  password: process.env.DB_PASS,
+  database: process.env.DB_NAME,
+  entities: [NotificationEmail],
+  migrations: ['src/migrations/*.ts'],
+  synchronize: true, // TODO: false
+  logging: true,
+});

services/email_service/src/config/database.module.ts

@@ -1,19 +1,16 @@
 import { Module } from '@nestjs/common';
 import { TypeOrmModule } from '@nestjs/typeorm';
 import { ConfigModule, ConfigService } from '@nestjs/config';
+import { NotificationEmail } from 'src/email/entity/email.entity';
 
 @Module({
   imports: [
     TypeOrmModule.forRootAsync({
       imports: [ConfigModule],
       useFactory: (configService: ConfigService) => ({
         type: 'postgres',
-        host: configService.get('DB_HOST'),
-        port: +configService.get('DB_PORT'),
-        username: configService.get('DB_USER'),
-        password: configService.get('DB_PASS'),
-        database: configService.get('DB_NAME'),
-        entities: [__dirname + '/../**/*.entity{.ts,.js}'],
+        url: configService.get('DATABASE_URL'),
+        entities: [NotificationEmail],
         synchronize: false,
         logging: ['error'],
         extra: { max: 20, idleTimeoutMillis: 30000 },

services/email_service/src/config/index.ts

@@ -0,0 +1,3 @@
+export * from './cache.module';
+export * from './mailer.module';
+export * from './database.module';

services/email_service/src/config/mailer.module.ts

@@ -15,7 +15,7 @@ import { ConfigModule, ConfigService } from '@nestjs/config';
             pass: configService.get('MAIL_PASS'),
           },
         },
-        defaults: { from: configService.get('MAIL_FROM') },
+        defaults: { from: configService.get('MAIL_USER') },
       }),
       inject: [ConfigService],
     }),

services/email_service/src/email-status/email-status.module.ts

@@ -0,0 +1,11 @@
+import { Module } from '@nestjs/common';
+import { TypeOrmModule } from '@nestjs/typeorm';
+import { NotificationEmail } from 'src/email/entity/email.entity';
+import { EmailStatusService } from './email-status.service';
+
+@Module({
+  imports: [TypeOrmModule.forFeature([NotificationEmail])],
+  providers: [EmailStatusService],
+  exports: [EmailStatusService],
+})
+export class EmailStatusModule {}

services/email_service/src/email-status/email-status.service.ts

@@ -0,0 +1,39 @@
+import { Repository } from 'typeorm';
+import { Injectable } from '@nestjs/common';
+import { InjectRepository } from '@nestjs/typeorm';
+import { NotificationEmail } from '../email/entity/email.entity';
+
+@Injectable()
+export class EmailStatusService {
+  constructor(
+    @InjectRepository(NotificationEmail)
+    private readonly notificationEmailRepo: Repository<NotificationEmail>,
+  ) {}
+
+  async handleStatusUpdate(body: any) {
+    const { notification_id, status, error } = body;
+
+    const email = await this.notificationEmailRepo.findOne({
+      where: { notification_id },
+    });
+    if (!email) return { success: false, message: 'Notification not found' };
+
+    email.status = status || 'failed';
+    email.error_message = error || null;
+    await this.notificationEmailRepo.save(email);
+
+    return {
+      success: true,
+      data: { notification_id, status },
+      message: 'Notification status updated',
+      meta: {
+        total: 1,
+        limit: 1,
+        page: 1,
+        total_pages: 1,
+        has_next: false,
+        has_previous: false,
+      },
+    };
+  }
+}