Upload folder using huggingface_hub

.gitattributes

@@ -33,3 +33,9 @@ saved_model/**/* filter=lfs diff=lfs merge=lfs -text
 *.zip filter=lfs diff=lfs merge=lfs -text
 *.zst filter=lfs diff=lfs merge=lfs -text
 *tfevents* filter=lfs diff=lfs merge=lfs -text
+apps/oauthapp/src/public/images/OpenSource[[:space:]]Website[[:space:]]Load[[:space:]]After[[:space:]]dB[[:space:]]Restoration.png filter=lfs diff=lfs merge=lfs -text
+apps/oauthapp/src/public/images/OpenSource[[:space:]]dB[[:space:]]Restoration[[:space:]]Proof.png filter=lfs diff=lfs merge=lfs -text
+apps/oauthapp/src/public/images/apim.png filter=lfs diff=lfs merge=lfs -text
+apps/oauthapp/src/public/images/apimpolicy.png filter=lfs diff=lfs merge=lfs -text
+apps/oauthapp/src/public/images/botecosystem.png filter=lfs diff=lfs merge=lfs -text
+apps/oauthapp/src/public/images/redisusages.png filter=lfs diff=lfs merge=lfs -text

.gitignore

@@ -0,0 +1,56 @@
+# compiled output
+/dist
+/node_modules
+/build
+
+# Logs
+logs
+*.log
+npm-debug.log*
+pnpm-debug.log*
+yarn-debug.log*
+yarn-error.log*
+lerna-debug.log*
+
+# OS
+.DS_Store
+
+# Tests
+/coverage
+/.nyc_output
+
+# IDEs and editors
+/.idea
+.project
+.classpath
+.c9/
+*.launch
+.settings/
+*.sublime-workspace
+
+# IDE - VSCode
+.vscode/*
+!.vscode/settings.json
+!.vscode/tasks.json
+!.vscode/launch.json
+!.vscode/extensions.json
+
+# dotenv environment variable files
+.env
+.env.development.local
+.env.test.local
+.env.production.local
+.env.local
+
+# temp directory
+.temp
+.tmp
+
+# Runtime data
+pids
+*.pid
+*.seed
+*.pid.lock
+
+# Diagnostic reports (https://nodejs.org/api/report.html)
+report.[0-9]*.[0-9]*.[0-9]*.[0-9]*.json

.npmrc

@@ -0,0 +1,2 @@
+@bibhu2020:registry=https://npm.pkg.github.com
+//npm.pkg.github.com/:_authToken=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

.prettierrc

@@ -0,0 +1,4 @@
+{
+  "singleQuote": true,
+  "trailingComma": "all"
+}

Dockerfile

@@ -0,0 +1,23 @@
+# Use an official Node.js runtime as a parent image
+FROM node:20-alpine AS builder
+
+# Set working directory
+WORKDIR /app
+
+# Install dependencies
+COPY package*.json ./
+RUN npm install
+
+# Copy the rest of the app's source code
+COPY . .
+
+# Build the NestJS app
+RUN npm run build:apigateway
+
+RUN mkdir -p dist/libs/proto && cp -r libs/proto dist/libs
+
+# Start the application
+CMD ["node", "dist/apps/apigateway/main.js"]
+
+# Expose app port
+EXPOSE 8080

ENV_VARIABLES

@@ -0,0 +1,11 @@
+DATABASE_URL=""
+# uncomment next line if you use Prisma <5.10
+# DATABASE_URL_UNPOOLED="postgresql://neondb_owner:npg_vkaFtG8d3XPJ@ep-fancy-hill-a8tm0pqc.eastus2.azure.neon.tech/neondb?sslmode=require"
+AUTH_REDIRCET_URL=http://localhost:8080/auth/redirect
+AZURE_CLIENT_ID=908e42d2-fe86-41b7-8220-6bd41930b3b4
+AZURE_CLIENT_SECRET=
+AZURE_TENANT_ID=95595fde-7f04-4030-ace9-d08cf1e81bdc
+MANAGED_IDENTITY_CLIENT_ID=ddd
+NODE_ENV=development
+# Weather Service 3rd Party API (optional if you do not want to test 3rd party API: https://api.openweathermap.org)
+WEATHER_SERVICE_API_KEY=

README.md

@@ -1,10 +1,14 @@
 ---
-title: Northwind Api Gateway
-emoji: 📊
-colorFrom: purple
-colorTo: purple
+title: Northwind API Gateway
+emoji: 🐳
+colorFrom: blue
+colorTo: indigo
 sdk: docker
+app_file: app.py
 pinned: false
 ---
 
-Check out the configuration reference at https://huggingface.co/docs/hub/spaces-config-reference
+# 🐳 Northwind API Gateway
+
+Dockerized NestJS API Gateway for the Northwind dataset, running on Node.js 20 and exposing port 8080.
+EOF    

apps/apigateway/README.md

@@ -0,0 +1,11 @@
+## Required Packages
+```bash
+npm install @nestjs/axios @nestjs/config @nestjs/throttler opossum
+
+```
+
+## Add logging middleware to the monorepo
+this middleware intercept all requests hitting the microservices, and log them.
+```bash
+nest g middleware logger --project apigateway
+```

apps/apigateway/src/apigateway.controller.spec.ts

@@ -0,0 +1,22 @@
+import { Test, TestingModule } from '@nestjs/testing';
+import { ApigatewayController } from './apigateway.controller';
+import { ApigatewayService } from './apigateway.service';
+
+describe('ApigatewayController', () => {
+  let apigatewayController: ApigatewayController;
+
+  beforeEach(async () => {
+    const app: TestingModule = await Test.createTestingModule({
+      controllers: [ApigatewayController],
+      providers: [ApigatewayService],
+    }).compile();
+
+    apigatewayController = app.get<ApigatewayController>(ApigatewayController);
+  });
+
+  describe('root', () => {
+    it('should return "Hello World!"', () => {
+      expect(apigatewayController.getHello()).toBe('Hello World!');
+    });
+  });
+});

apps/apigateway/src/apigateway.controller.ts

@@ -0,0 +1,19 @@
+import { Controller, Req, Res, All, Get, Post } from '@nestjs/common';
+import { Request, Response } from 'express';
+
+@Controller(['/', '/healthz'])
+export class ApigatewayController {
+
+  @Get()
+  async healthz(@Req() req: Request, @Res() res: Response) {
+    console.log('Request received:', req.method, req.url);
+    res.send('🚀 ApiGateway is running...............');
+  }
+
+  @All()
+  async test(@Req() req: Request, @Res() res: Response) {
+    console.log('POST Request received:', req.method, req.url);
+    res.send('🚀 ApiGateway is running...............');
+  }
+
+}

apps/apigateway/src/apigateway.module.ts

@@ -0,0 +1,62 @@
+import { Module, NestModule, MiddlewareConsumer } from '@nestjs/common';
+import { ConfigModule } from '@nestjs/config';
+import { ThrottlerModule } from '@nestjs/throttler';
+import { HttpModule } from '@nestjs/axios';
+
+import { ApigatewayController } from './apigateway.controller';
+import { ApploggerModule } from '@bpm/common';
+import { LoggerMiddleware } from './middlewares/logger/logger.middleware';
+
+
+import { NorthwindModule } from './modules/northwind/northwind.module';
+import { AzureModule } from './modules/azure/azure.module';
+import { WeatherModule } from './modules/weather/weather.module';
+
+
+@Module({
+  imports: [
+    // ✅ Correct usage of ThrottlerModule (Rate Limiting)
+    // The limit is the maximum number of requests allowed within the ttl
+    // This configuration allows for 3 requests per 1 second (short limit)
+    // and 100 requests per 1 minute (long limit)
+    ThrottlerModule.forRoot([
+      {
+        name: 'short',
+        ttl: 1000, // 3 requests per 1 seconds (short limit)
+        limit: 1,
+      },
+      {
+        name: 'long',
+        ttl: 60000, // 100 requests per 1 minute (long limit)
+        limit: 100,
+      }
+    ]),
+
+    //ConfigModule should be imported with isGlobal: true
+    // This makes the configuration available globally in the application
+    ConfigModule.forRoot({ isGlobal: true }),
+
+    // ✅ HttpModule should not be passed directly like a class
+    // It provides a simple and easy-to-use interface for making HTTP requests
+    HttpModule,
+
+    ApploggerModule,
+
+    NorthwindModule,
+
+    AzureModule,
+
+    WeatherModule,
+
+  ],
+  controllers: [ApigatewayController],
+  providers: [LoggerMiddleware],
+})
+export class ApigatewayModule implements NestModule {
+  // No need to bind manually if LoggerMiddleware is injectable
+  configure(consumer: MiddlewareConsumer) {
+    consumer
+      .apply(LoggerMiddleware) // Apply LoggerMiddleware directly
+      .forRoutes('*'); // Apply to all routes
+  }
+}

apps/apigateway/src/common/circuitbraker/circuitbraker.module.ts

@@ -0,0 +1,20 @@
+import { Module } from '@nestjs/common';
+import { CircuitbrakerService } from './circuitbraker.service';
+import { ApploggerService } from '@bpm/common';
+
+@Module({
+  providers: [{
+    provide: CircuitbrakerService,
+    useFactory: (logger: ApploggerService) => {
+      return new CircuitbrakerService({
+        failureThreshold: 3,  // Fail after 3 consecutive failures
+        successThreshold: 2,  // Recover after 2 consecutive successes
+        timeout: 5000,  // Timeout after 5 seconds
+        serviceName: 'apigateway',  // The name of the service being protected by the circuit breaker
+      }, logger);
+    },
+    inject: [ApploggerService],
+  }],
+  exports: [CircuitbrakerService], // <-- must export it
+})
+export class CircuitbrakerModule {}

apps/apigateway/src/common/circuitbraker/circuitbraker.service.spec.ts

@@ -0,0 +1,18 @@
+import { Test, TestingModule } from '@nestjs/testing';
+import { CircuitbrakerService } from './circuitbraker.service';
+
+describe('CircuitbrakerService', () => {
+  let service: CircuitbrakerService;
+
+  beforeEach(async () => {
+    const module: TestingModule = await Test.createTestingModule({
+      providers: [CircuitbrakerService],
+    }).compile();
+
+    service = module.get<CircuitbrakerService>(CircuitbrakerService);
+  });
+
+  it('should be defined', () => {
+    expect(service).toBeDefined();
+  });
+});

apps/apigateway/src/common/circuitbraker/circuitbraker.service.ts

@@ -0,0 +1,93 @@
+import { ApploggerService } from '@bpm/common';
+import { Injectable } from '@nestjs/common';
+
+export type CircuitBreakerState = 'CLOSED' | 'OPEN' | 'HALF_OPEN';
+
+interface CircuitBreakerOptions {
+  failureThreshold: number;
+  successThreshold: number;
+  timeout: number; // in ms
+  serviceName: string; // Service name to track which service is failing
+}
+
+@Injectable()
+export class CircuitbrakerService {
+  private state: CircuitBreakerState = 'CLOSED';
+  private failureCount = 0;
+  private successCount = 0;
+  private nextAttempt = Date.now();
+
+  constructor(private options: CircuitBreakerOptions,
+              private readonly logger: ApploggerService
+  ) {}
+
+  async call<T>(fn: () => Promise<T>): Promise<T> {
+    if (this.state === 'OPEN') {
+      if (Date.now() > this.nextAttempt) {
+        this.state = 'HALF_OPEN';
+        //this.logger.log(`${this.options.serviceName} - Circuit is HALF_OPEN. Attempting recovery.`, CircuitbrakerService.name);
+      } else {
+        //this.logger.log(`${this.options.serviceName} - Circuit is OPEN. Request blocked.`, CircuitbrakerService.name);
+        throw new Error(`${this.options.serviceName} - Circuit is OPEN`);
+      }
+    }
+
+    try {
+      const result = await fn();
+      this.onSuccess();
+      return result;
+    } catch (err) {
+      this.onFailure(err);
+      throw err;
+    }
+  }
+
+  private onSuccess() {
+    if (this.state === 'HALF_OPEN') {
+      this.successCount++;
+      //this.logger.log(`${this.options.serviceName} - Success count: ${this.successCount}`, CircuitbrakerService.name);
+      if (this.successCount >= this.options.successThreshold) {
+        this.reset();
+        //this.logger.log(`${this.options.serviceName} - Circuit is now CLOSED`, CircuitbrakerService.name);
+      }
+    } else {
+      this.reset();
+      //this.logger.log(`${this.options.serviceName} - Circuit is CLOSED after success`, CircuitbrakerService.name);
+    }
+  }
+
+  private onFailure(err: any) {
+    const status = err?.response?.status || err?.status || 500;
+  
+    if (status <= 400) {
+      //this.logger.log(`${this.options.serviceName} - Ignoring non-error status: ${status}`, CircuitbrakerService.name);
+      return; // Don't count it as failure
+    }
+  
+    this.failureCount++;
+    //this.logger.log(`${this.options.serviceName} - Failure count: ${this.failureCount}`, CircuitbrakerService.name);
+    this.logger.error(`${this.options.serviceName} - Failure: ${err.message || 'Unknown error'}`, CircuitbrakerService.name);
+  
+    if (this.failureCount >= this.options.failureThreshold) {
+      this.trip();
+      //this.logger.log(`${this.options.serviceName} - Circuit is OPEN due to repeated failures`, CircuitbrakerService.name);
+    }
+  }
+
+  private reset() {
+    this.failureCount = 0;
+    this.successCount = 0;
+    this.state = 'CLOSED';
+    //this.logger.log(`${this.options.serviceName} - Circuit is RESET to CLOSED`, CircuitbrakerService.name);
+  }
+
+  private trip() {
+    this.state = 'OPEN';
+    this.nextAttempt = Date.now() + this.options.timeout;
+    //this.logger.log(`${this.options.serviceName} - Circuit is TRIPPED to OPEN. Next attempt will be after ${this.options.timeout}ms.`, CircuitbrakerService.name);
+  }
+
+  public getState() {
+    return this.state;
+  }
+}

apps/apigateway/src/main.ts

@@ -0,0 +1,58 @@
+import { NestFactory } from '@nestjs/core';
+import { ApigatewayModule } from './apigateway.module';
+import { ApploggerService } from '@bpm/common';
+
+async function bootstrap() {
+  const context = 'apigateway';
+  const logger = new ApploggerService(context);
+
+  logger.log('🛠️  Starting up the NestJS Application...\n', context);
+  logger.log('📦 Loading modules...\n', context);
+
+  const app = await NestFactory.create(ApigatewayModule);
+
+  app.enableShutdownHooks(); // 👈 Add this
+
+
+  app.enableCors({
+    origin: [/http:\/\/localhost:\d+$/, 'https://srepoc-northwind-vuejs-ctbmh6bufhgufqea.b01.azurefd.net'], // Allow all requests from localhost on any port
+    credentials: true, // Enable credentials if needed (cookies, auth headers, etc.)
+  });
+
+  app.setGlobalPrefix('api'); // 👈 This sets /api as the prefix
+
+  const port = process.env.PORT || 3001;
+
+  try {
+    await app.listen(port, () => {
+      logger.log('✅ App Modules initialized successfully\n', context);
+      logger.log('🌐 Enabling global configurations...\n', context);
+
+      logger.log(
+        `🚀 Application is running at: http://localhost:${port}\n`,
+        context,
+      );
+      logger.log('📡 Ready to accept incoming requests!\n', context);
+      logger.log('🧠 Powered by NestJS ❤️\n', context);
+    });
+  } catch (err) {
+    logger.error('❌ Failed to start application\n', err.stack);
+    if (app) {
+      await app.close();
+    }
+  }
+
+  // OS signal listeners (optional)
+  process.on('SIGINT', async () => {
+    logger.warn('🛑 SIGINT received. Gracefully shutting down...', context);
+    await app.close();
+    process.exit(1);
+  });
+
+  process.on('SIGTERM', async () => {
+    logger.warn('🛑 SIGTERM received. Gracefully shutting down...', context);
+    await app.close();
+    process.exit(1);
+  });
+}
+bootstrap();

apps/apigateway/src/middlewares/logger/logger.middleware.spec.ts

@@ -0,0 +1,10 @@
+import { LoggerMiddleware } from './logger.middleware';
+
+import { ApploggerService } from '@bpm/common/app-logger/applogger.service';
+
+describe('LoggerMiddleware', () => {
+  it('should be defined', () => {
+    const mockLogger = {} as ApploggerService;
+    expect(new LoggerMiddleware(mockLogger)).toBeDefined();
+  });
+});

apps/apigateway/src/middlewares/logger/logger.middleware.ts

@@ -0,0 +1,15 @@
+import { ApploggerService } from '@bpm/common';
+import { Injectable, NestMiddleware } from '@nestjs/common';
+
+@Injectable()
+export class LoggerMiddleware implements NestMiddleware {
+  constructor(private readonly logger: ApploggerService) {}
+
+  use(req: any, res: any, next: () => void) {
+    // Make sure to log relevant request details
+    this.logger.log(`[${req.method}] ${req.originalUrl}`, "apigateway"); // Log method and URL
+    // Log headers or any other information if needed
+    //this.logger.log(`Headers: ${JSON.stringify(req.headers)}`, "apigateway");
+    next();
+  }
+}

apps/apigateway/src/modules/azure/azure.controller.spec.ts

@@ -0,0 +1,18 @@
+import { Test, TestingModule } from '@nestjs/testing';
+import { AzureController } from './azure.controller';
+
+describe('AzureController', () => {
+  let controller: AzureController;
+
+  beforeEach(async () => {
+    const module: TestingModule = await Test.createTestingModule({
+      controllers: [AzureController],
+    }).compile();
+
+    controller = module.get<AzureController>(AzureController);
+  });
+
+  it('should be defined', () => {
+    expect(controller).toBeDefined();
+  });
+});

apps/apigateway/src/modules/azure/azure.controller.ts

@@ -0,0 +1,27 @@
+import { Controller, Get, Inject, OnModuleInit, Query } from '@nestjs/common';
+import { ClientGrpc } from '@nestjs/microservices';
+import { Observable } from 'rxjs';
+
+interface AzureApiService {
+  readSecret(data: { kvName: string; secretName: string }): Observable<{
+    kvName: string;
+    secretName: string;
+    secretValue: string;
+  }>;
+}
+
+@Controller('azure')
+export class AzureController implements OnModuleInit {
+  private grpcService: AzureApiService;
+
+  constructor(@Inject('AZURE_API_PACKAGE') private readonly client: ClientGrpc) {}
+
+  onModuleInit() {
+    this.grpcService = this.client.getService<AzureApiService>('AzureApiService');
+  }
+
+  @Get('secret')
+  async getSecret(@Query('kv') kv: string, @Query('secret') secret: string) {
+    return this.grpcService.readSecret({ kvName: kv, secretName: secret });
+  }
+}

apps/apigateway/src/modules/azure/azure.module.ts

@@ -0,0 +1,33 @@
+import { Module } from '@nestjs/common';
+import { ClientsModule, Transport } from '@nestjs/microservices';
+import { join } from 'path';
+import { AzureController } from './azure.controller';
+
+const isProd = process.env.NODE_ENV === 'production';
+const protoPath = isProd
+            ? '../../../libs/proto/azureapi.proto'
+            : '../../../../../libs/proto/azureapi.proto';
+
+//console.log('protoPath', join(__dirname, protoPath));
+const port = process.env.PORT || 3021;
+const apiURL = isProd
+    ? process.env.PROD_AZUREAPI_URL || 'weatherapi-nestjs-service.riskiq.svc.cluster.local'
+    : 'localhost:' + port;
+
+@Module({
+  imports: [
+    ClientsModule.register([
+      {
+        name: 'AZURE_API_PACKAGE',
+        transport: Transport.GRPC,
+        options: {
+          package: 'azureapi',
+          protoPath: join(__dirname, protoPath), // 👈 Adjust if needed
+          url: apiURL, // 👈 Adjust to your gRPC server host/port
+        },
+      },
+    ]),
+  ],
+  controllers: [AzureController]
+})
+export class AzureModule {}

apps/apigateway/src/modules/northwind/northwind.controller.spec.ts

@@ -0,0 +1,18 @@
+import { Test, TestingModule } from '@nestjs/testing';
+import { NorthwindController } from './northwind.controller';
+
+describe('NorthwindapiController', () => {
+  let controller: NorthwindController;
+
+  beforeEach(async () => {
+    const module: TestingModule = await Test.createTestingModule({
+      controllers: [NorthwindController],
+    }).compile();
+
+    controller = module.get<NorthwindController>(NorthwindController);
+  });
+
+  it('should be defined', () => {
+    expect(controller).toBeDefined();
+  });
+});

apps/apigateway/src/modules/northwind/northwind.controller.ts

@@ -0,0 +1,78 @@
+import { Controller, Req, Res, All, Get } from '@nestjs/common';
+import { NorthwindService } from './northwind.service';
+import { Request, Response } from 'express';
+
+@Controller('northwind')
+export class NorthwindController {
+    constructor(private readonly gateway: NorthwindService) {}
+
+    @Get('/')
+    async get(@Req() req: Request, @Res() res: Response) {
+        //console.log('Request received:', req.method, req.url);
+        res.send('🚀 You have reached northwind service...............');
+    }
+
+    @Get(['/swagger', '/swagger/*'])
+        async swagger(@Req() req: Request, @Res() res: Response) {
+        const baseUrl = "/api/northwind";
+        const strippedPath = req.url.toLocaleLowerCase().slice(baseUrl.length);
+        const isProd = process.env.NODE_ENV === 'production';
+
+        const targetBaseUrl = isProd
+            ? 'http://northwindapi-nestjs-service.riskiq.svc.cluster.local'
+            : 'http://localhost:3002';
+
+        console.log(strippedPath);
+
+        const result = await this.gateway.forwardRequest(
+            targetBaseUrl,
+            req.method as any,
+            strippedPath,
+            req.headers,
+            undefined
+        );
+
+        // Attempt to parse and transform JSON paths
+        if (typeof result === 'object' && result?.paths) {
+            const transformed = {
+            ...result,
+            paths: {},
+            };
+
+            for (const [path, value] of Object.entries(result.paths)) {
+            const newPath = path.replace(/^\/api/, baseUrl);
+            transformed.paths[newPath] = value;
+            }
+
+            return res.json(transformed);
+        }
+
+        // Fallback to regular response
+        return res.send(result);
+    }
+
+    
+    
+    @All('*')
+    async allRequests(@Req() req: Request, @Res() res: Response) {
+        const baseUrl = "/api/northwind";
+        const strippedPath = req.url.toLocaleLowerCase().slice(baseUrl.length); 
+        //console.log('Request received:', req.method, strippedPath);
+        const isProd = process.env.NODE_ENV === 'production';
+        let targetBaseUrl = isProd
+            ? 'http://northwindapi-nestjs-service.riskiq.svc.cluster.local/api'
+            : 'http://localhost:3002/api';
+
+        const hasBody = !['GET', 'HEAD'].includes(req.method.toUpperCase());
+
+        const result = await this.gateway.forwardRequest(
+            targetBaseUrl,
+            req.method as any,
+            strippedPath,
+            req.headers,
+            hasBody ? req.body : undefined
+        );
+
+        res.send(result);
+    }
+}

apps/apigateway/src/modules/northwind/northwind.module.ts

@@ -0,0 +1,31 @@
+import { Module } from '@nestjs/common';
+import { NorthwindController } from './northwind.controller';
+import { NorthwindService } from './northwind.service';
+import { CircuitbrakerModule } from '../../common/circuitbraker/circuitbraker.module';
+import { CircuitbrakerService } from '../../common/circuitbraker/circuitbraker.service';
+import { HttpModule } from '@nestjs/axios';
+import { ApploggerService } from '@bpm/common';
+
+@Module({
+  imports: [
+    HttpModule,               // ✅ Import this
+    CircuitbrakerModule      // ✅ Import CircuitbreakerService from its module
+  ],
+  controllers: [NorthwindController],
+  providers: [NorthwindService, 
+    {
+      provide: CircuitbrakerService,
+      useFactory: (logger: ApploggerService) => {
+            return new CircuitbrakerService({
+              failureThreshold: 3,  // Fail after 3 consecutive failures
+              successThreshold: 2,  // Recover after 2 consecutive successes
+              timeout: 5000,  // Timeout after 5 seconds
+              serviceName: 'apigateway',  // The name of the service being protected by the circuit breaker
+            }, logger);
+          },
+          inject: [ApploggerService],
+    },
+  ],
+  exports: [NorthwindService],
+})
+export class NorthwindModule {}

apps/apigateway/src/modules/northwind/northwind.service.spec.ts

@@ -0,0 +1,18 @@
+import { Test, TestingModule } from '@nestjs/testing';
+import { NorthwindService } from './northwind.service';
+
+describe('NorthwindapiService', () => {
+  let service: NorthwindService;
+
+  beforeEach(async () => {
+    const module: TestingModule = await Test.createTestingModule({
+      providers: [NorthwindService],
+    }).compile();
+
+    service = module.get<NorthwindService>(NorthwindService);
+  });
+
+  it('should be defined', () => {
+    expect(service).toBeDefined();
+  });
+});

apps/apigateway/src/modules/northwind/northwind.service.ts

@@ -0,0 +1,79 @@
+import { Injectable, InternalServerErrorException } from '@nestjs/common';
+import { HttpService } from '@nestjs/axios';
+//import { lastValueFrom } from 'rxjs';
+import { AxiosRequestConfig } from 'axios';
+import { CircuitbrakerService } from '../../common/circuitbraker/circuitbraker.service';
+import { ApploggerService } from '@bpm/common';
+
+@Injectable()
+export class NorthwindService {
+    constructor(
+    private readonly http: HttpService,
+    private readonly circuitBreaker: CircuitbrakerService,
+    private readonly logger: ApploggerService
+  ) {}
+  
+  async forwardRequest(
+    baseUrl: string,
+    method: 'GET' | 'POST' | 'PUT' | 'DELETE' | 'PATCH' | 'HEAD',
+    path: string,
+    headers: any,
+    body: any,
+  ) {
+    const url = `${baseUrl.replace(/\/$/, '')}/${path.replace(/^\//, '')}`;
+    this.logger.log(`Forwarding to ${url} using ${method}`, NorthwindService.name);
+
+    // Prepare default config
+    const config: AxiosRequestConfig = {
+      headers: {...headers },
+      url,
+      method,
+      validateStatus: (status) => status <= 500, // Avoid errors for 304, etc.
+    };
+
+    // Conditionally merge headers based on HTTP method
+    if (method === 'GET' || method === 'HEAD') {
+      // Create a copy of headers without 'content-type'
+      const { ['content-type']: _, ...headersWithoutContentType } = headers;
+
+      config.headers = {
+        ...headersWithoutContentType,
+        accept: 'application/json',
+        'cache-control': 'no-cache',
+        // 'if-none-match': '', // explicitly force full response (disable ETag)
+      }; // Keep original headers for GET and HEAD
+    } else {
+      config.headers = {
+        accept: 'application/json',
+        'content-type': 'application/json', // Only for POST, PUT, DELETE, etc.
+        'cache-control': 'no-cache',
+        'if-none-match': '', // explicitly force full response (disable ETag)
+      };
+      config.data = body; // Add data only for methods other than GET/HEAD
+    }
+
+
+    //this.logger.log(config, NorthwindService.name);
+
+    try {
+      //this.logger.log('Sending request to service through circuit breaker', NorthwindService.name);
+      const response = await this.circuitBreaker.call(() =>
+         this.http.request(config).toPromise(), // toPromise() converts observable to promise
+      );
+      // Check if response is defined
+      if (!response) {
+        throw new InternalServerErrorException('No response received from service');
+      }
+      return response.data;
+    } catch (error) {
+      console.error(`Request failed:`, {
+        message: error?.message,
+        code: error?.code,
+        response: error?.response?.data,
+        status: error?.response?.status,
+        stack: error?.stack,
+      });
+      throw new InternalServerErrorException('Failed to reach service');
+    }
+  }
+}

apps/apigateway/src/modules/weather/weather.controller.spec.ts

@@ -0,0 +1,18 @@
+import { Test, TestingModule } from '@nestjs/testing';
+import { WeatherController } from './weather.controller';
+
+describe('WeatherController', () => {
+  let controller: WeatherController;
+
+  beforeEach(async () => {
+    const module: TestingModule = await Test.createTestingModule({
+      controllers: [WeatherController],
+    }).compile();
+
+    controller = module.get<WeatherController>(WeatherController);
+  });
+
+  it('should be defined', () => {
+    expect(controller).toBeDefined();
+  });
+});

apps/apigateway/src/modules/weather/weather.controller.ts

@@ -0,0 +1,22 @@
+// apps/apigateway/src/weather/weather.controller.ts
+import { Controller, Get, Query } from '@nestjs/common';
+import { WeatherService } from './weather.service';
+
+@Controller('weather')
+export class WeatherController {
+  constructor(private readonly weatherService: WeatherService) {}
+
+  @Get('current')
+  getCurrentWeather(@Query('city') city: string, @Query('country') country: string) {
+    return this.weatherService.getCurrentWeather(city, country);
+  }
+
+  @Get('forecast')
+  getForecast(
+    @Query('city') city: string,
+    @Query('country') country: string,
+    @Query('days') days: string,
+  ) {
+    return this.weatherService.getForecast(city, country, parseInt(days));
+  }
+}

apps/apigateway/src/modules/weather/weather.module.ts

@@ -0,0 +1,37 @@
+import { Module } from '@nestjs/common';
+import { ClientsModule, Transport } from '@nestjs/microservices';
+import { join } from 'path';
+import { WeatherController } from './weather.controller';
+import { WeatherService } from './weather.service';
+
+const isProd = process.env.NODE_ENV === 'production';
+const protoPath = isProd
+            ? '../../../libs/proto/weatherapi.proto'
+            : '../../../../../libs/proto/weatherapi.proto';
+
+//console.log('protoPath', join(__dirname, protoPath));
+const port = process.env.PORT || 3022;
+const apiURL = isProd
+    ? process.env.PROD_WEATHERAPI_URL || 'weatherapi-nestjs-service.riskiq.svc.cluster.local'
+    : 'localhost:' + port;
+
+
+
+@Module({
+  imports: [
+    ClientsModule.register([
+      {
+        name: 'WEATHER_API_PACKAGE',
+        transport: Transport.GRPC,
+        options: {
+          package: 'weatherapi',
+          protoPath: join(__dirname, protoPath), // 👈 Adjust if needed
+          url: apiURL, // 👈 Adjust to your gRPC server host/port
+        },
+      },
+    ]),
+  ],
+  controllers: [WeatherController],
+  providers: [WeatherService]
+})
+export class WeatherModule {}

apps/apigateway/src/modules/weather/weather.service.spec.ts

@@ -0,0 +1,18 @@
+import { Test, TestingModule } from '@nestjs/testing';
+import { WeatherService } from './weather.service';
+
+describe('WeatherService', () => {
+  let service: WeatherService;
+
+  beforeEach(async () => {
+    const module: TestingModule = await Test.createTestingModule({
+      providers: [WeatherService],
+    }).compile();
+
+    service = module.get<WeatherService>(WeatherService);
+  });
+
+  it('should be defined', () => {
+    expect(service).toBeDefined();
+  });
+});

apps/apigateway/src/modules/weather/weather.service.ts

@@ -0,0 +1,61 @@
+// apps/apigateway/src/weather/weather.service.ts
+import { Inject, Injectable, OnModuleInit } from '@nestjs/common';
+import { ClientGrpc } from '@nestjs/microservices';
+import { Observable, lastValueFrom } from 'rxjs';
+import * as opossum from 'opossum';
+
+interface WeatherServiceClient {
+  GetCurrentWeather(data: { city: string; country: string }): Observable<any>;
+  GetForecast(data: { city: string; country: string; days: number }): Observable<any>;
+}
+
+@Injectable()
+export class WeatherService implements OnModuleInit {
+  private weatherService: WeatherServiceClient;
+
+  private currentWeatherBreaker: opossum<any, any>;
+  private forecastBreaker: opossum<any, any>;
+
+  constructor(@Inject('WEATHER_API_PACKAGE') private readonly client: ClientGrpc) {}
+
+  onModuleInit() {
+    this.weatherService = this.client.getService<WeatherServiceClient>('WeatherApiService');
+
+    // Circuit breaker for GetCurrentWeather
+    this.currentWeatherBreaker = new opossum(
+      (data: { city: string; country: string }) =>
+        lastValueFrom(this.weatherService.GetCurrentWeather(data)),
+      {
+        timeout: 5000, // 5 seconds timeout
+        errorThresholdPercentage: 50,
+        resetTimeout: 10000, // 10 seconds before retry
+      }
+    );
+
+    // Circuit breaker for GetForecast
+    this.forecastBreaker = new opossum(
+      (data: { city: string; country: string; days: number }) =>
+        lastValueFrom(this.weatherService.GetForecast(data)),
+      {
+        timeout: 5000,
+        errorThresholdPercentage: 50,
+        resetTimeout: 10000,
+      }
+    );
+
+    this.currentWeatherBreaker.on('open', () => console.warn('⚠️ GetCurrentWeather breaker opened'));
+    this.currentWeatherBreaker.on('close', () => console.log('✅ GetCurrentWeather breaker closed'));
+
+    this.forecastBreaker.on('open', () => console.warn('⚠️ GetForecast breaker opened'));
+    this.forecastBreaker.on('close', () => console.log('✅ GetForecast breaker closed'));
+    
+  }
+
+  async getCurrentWeather(city: string, country: string) {
+    return this.currentWeatherBreaker.fire({ city, country });
+  }
+
+  async getForecast(city: string, country: string, days: number) {
+    return this.forecastBreaker.fire({ city, country, days });
+  }
+}

apps/apigateway/src/service-map.json

@@ -0,0 +1,7 @@
+{
+    "/proxy/customers": "http://localhost:3002",
+    "/oauth": "http://localhost:3004",
+    "/weather": "http://localhost:3005",
+    "default": "http://localhost:3000"
+  }
+  

apps/apigateway/test/app.e2e-spec.ts

@@ -0,0 +1,24 @@
+import { Test, TestingModule } from '@nestjs/testing';
+import { INestApplication } from '@nestjs/common';
+import * as request from 'supertest';
+import { ApigatewayModule } from './../src/apigateway.module';
+
+describe('ApigatewayController (e2e)', () => {
+  let app: INestApplication;
+
+  beforeEach(async () => {
+    const moduleFixture: TestingModule = await Test.createTestingModule({
+      imports: [ApigatewayModule],
+    }).compile();
+
+    app = moduleFixture.createNestApplication();
+    await app.init();
+  });
+
+  it('/ (GET)', () => {
+    return request(app.getHttpServer())
+      .get('/')
+      .expect(200)
+      .expect('Hello World!');
+  });
+});

apps/apigateway/test/jest-e2e.json

@@ -0,0 +1,9 @@
+{
+  "moduleFileExtensions": ["js", "json", "ts"],
+  "rootDir": ".",
+  "testEnvironment": "node",
+  "testRegex": ".e2e-spec.ts$",
+  "transform": {
+    "^.+\\.(t|j)s$": "ts-jest"
+  }
+}

apps/apigateway/tsconfig.app.json

@@ -0,0 +1,10 @@
+{
+  "extends": "../../tsconfig.json",
+  "compilerOptions": {
+    "declaration": false,
+    "outDir": "../../dist/apps/apigateway",
+    "sourceMap": false
+  },
+  "include": ["src/**/*"],
+  "exclude": ["node_modules", "dist", "test", "**/*spec.ts"]
+}

apps/azureapi/src/azureapi.controller.spec.ts

@@ -0,0 +1,22 @@
+import { Test, TestingModule } from '@nestjs/testing';
+import { AzureapiController } from './azureapi.controller';
+import { AzureapiService } from './azureapi.service';
+
+describe('AzureapiController', () => {
+  let azureapiController: AzureapiController;
+
+  beforeEach(async () => {
+    const app: TestingModule = await Test.createTestingModule({
+      controllers: [AzureapiController],
+      providers: [AzureapiService],
+    }).compile();
+
+    azureapiController = app.get<AzureapiController>(AzureapiController);
+  });
+
+  describe('root', () => {
+    it('should return "Hello World!"', () => {
+      expect(azureapiController.getHello()).toBe('Hello World!');
+    });
+  });
+});

apps/azureapi/src/azureapi.controller.ts

@@ -0,0 +1,16 @@
+// azureapi.controller.ts
+import { Controller } from '@nestjs/common';
+import { GrpcMethod } from '@nestjs/microservices';
+import { AzureApiService } from './azureapi.service';
+
+@Controller()
+export class AzureApiController {
+  constructor(private readonly azureApiService: AzureApiService) {}
+  
+
+  @GrpcMethod('AzureApiService', 'readSecret') // <== Matches proto service & method
+  readSecret(data: { kvName: string; secretName: string }) {
+    const { kvName, secretName } = data;
+    return this.azureApiService.readSecret({ kvName, secretName });
+  }
+}

apps/azureapi/src/azureapi.module.ts

@@ -0,0 +1,11 @@
+import { Module } from '@nestjs/common';
+import { AzureApiController } from './azureapi.controller';
+import { AzureApiService } from './azureapi.service';
+import { AzureTokenService } from '@bpm/common';
+
+@Module({
+  imports: [],
+  controllers: [AzureApiController],
+  providers: [AzureApiService, AzureTokenService],
+})
+export class AzureapiModule {}

apps/azureapi/src/azureapi.service.ts

@@ -0,0 +1,25 @@
+import { Injectable } from '@nestjs/common';
+import { AzureTokenService } from '@bpm/common';
+import { SecretClient } from '@azure/keyvault-secrets';
+
+@Injectable()
+export class AzureApiService {
+  constructor(private readonly azureTokenService: AzureTokenService) {}
+
+
+  readSecret({ kvName, secretName }: { kvName: string; secretName: string }) {
+    //console.log('Token:', this.azureTokenService.getToken());
+    const credential = this.azureTokenService.getTokenCredential();
+    if (!credential) {
+      console.error('Token is not available');
+      return null;  
+    }
+    else {
+      return {
+        kvName,
+        secretName,
+        secretValue: `Value-of-${secretName}-from-${kvName}`,
+      };
+    }  
+  }
+}

apps/azureapi/src/main.ts

@@ -0,0 +1,49 @@
+import { NestFactory } from '@nestjs/core';
+import { AzureapiModule } from './azureapi.module';
+import { Transport, MicroserviceOptions } from '@nestjs/microservices';
+import { join } from 'path';
+import { ApploggerService } from '@bpm/common';
+import * as dotenv from 'dotenv';
+
+// Load environment variables from .env file
+dotenv.config();
+
+async function bootstrap() {
+  const context = 'azureapi';
+  const logger = new ApploggerService(context);
+  
+  const isProd = process.env.NODE_ENV === 'production';
+  const protoPath = isProd
+            ? '../../libs/proto/azureapi.proto'
+            : '../../../libs/proto/azureapi.proto';
+
+  //console.log('protoPath', join(__dirname, protoPath));
+
+  const port = process.env.PORT || 3021;
+  const hostingURL = 'localhost:' + port;
+
+  NestFactory.createMicroservice<MicroserviceOptions>(AzureapiModule, {
+    transport: Transport.GRPC,
+    options: {
+      package: 'azureapi',
+      protoPath: join(__dirname, protoPath),
+      url: hostingURL,
+    },
+  })
+    .then(app => {
+      logger.log('🛠️  Starting up the NestJS Application...\n', context);
+
+      return app.listen().then(() => {
+        logger.log('✅ App Modules initialized successfully\n', context);
+        logger.log('🌐 Enabling global configurations...\n', context);
+        logger.log('📡 Ready to accept incoming requests!\n', context);
+        logger.log('🧠 Powered by NestJS ❤️\n', context);
+      });
+    })
+    .catch(err => {
+      logger.error('❌ Failed to start WeatherAPI microservice: ' + err, context);
+      process.exit(1);
+    });
+
+}
+bootstrap();

apps/azureapi/test/app.e2e-spec.ts

@@ -0,0 +1,24 @@
+import { Test, TestingModule } from '@nestjs/testing';
+import { INestApplication } from '@nestjs/common';
+import * as request from 'supertest';
+import { AzureapiModule } from './../src/azureapi.module';
+
+describe('AzureapiController (e2e)', () => {
+  let app: INestApplication;
+
+  beforeEach(async () => {
+    const moduleFixture: TestingModule = await Test.createTestingModule({
+      imports: [AzureapiModule],
+    }).compile();
+
+    app = moduleFixture.createNestApplication();
+    await app.init();
+  });
+
+  it('/ (GET)', () => {
+    return request(app.getHttpServer())
+      .get('/')
+      .expect(200)
+      .expect('Hello World!');
+  });
+});

apps/azureapi/test/jest-e2e.json

@@ -0,0 +1,9 @@
+{
+  "moduleFileExtensions": ["js", "json", "ts"],
+  "rootDir": ".",
+  "testEnvironment": "node",
+  "testRegex": ".e2e-spec.ts$",
+  "transform": {
+    "^.+\\.(t|j)s$": "ts-jest"
+  }
+}

apps/azureapi/tsconfig.app.json

@@ -0,0 +1,9 @@
+{
+  "extends": "../../tsconfig.json",
+  "compilerOptions": {
+    "declaration": false,
+    "outDir": "../../dist/apps/azureapi"
+  },
+  "include": ["src/**/*"],
+  "exclude": ["node_modules", "dist", "test", "**/*spec.ts"]
+}

apps/northwindapi/src/config/typeorm.config.ts

@@ -0,0 +1,81 @@
+import { DataSource } from 'typeorm';
+import * as Entities from '@bpm/data/models';
+import { config } from 'dotenv';
+config(); // Ensure environment variables are loaded
+import * as path from 'path';
+
+// console.log('Database URL:', process.env.DATABASE_URL);
+
+const appRoot = path.resolve(__dirname, '..', '..');
+console.log('App root:', appRoot);
+
+const dbUrl = new URL(process.env.DATABASE_URL || '');
+// const appDirectory = process.cwd();
+const isDev = process.env.NODE_ENV !== 'production';
+// const sourceDir = isDev ? 'src' : 'dist';
+
+// console.log('Current directory:', appDirectory);
+// console.log('Root directory:', rootDir);
+// console.log('isDev:', isDev);
+
+
+// const entitiesPath = path.join(
+//   appRoot,
+//   "src",
+//   'models',
+//   `*.entity.${isDev ? 'ts' : 'js'}`,
+// );
+// const migrationsPath = path.join(
+//   appRoot,
+//   "src",
+//   'database',
+//   'migrations',
+//   `*-migration.${isDev ? 'ts' : 'js'}`,
+// );
+
+
+// const entities = path.join(
+//   appRoot,
+//   "src",
+//   'models',
+//   `*.entity.${isDev ? 'ts' : 'js'}`,
+// );
+const migrations = path.join(
+  appRoot,
+  "src",
+  'database',
+  'migrations',
+  `*-migration.${isDev ? 'ts' : 'js'}`,
+);
+
+// console.log('Entities path:', entities);
+// console.log('Migrations path:', migrations);
+
+
+
+const AppDataSource = new DataSource({
+  type: 'postgres',
+  host: dbUrl.hostname,
+  port: Number(dbUrl.port) || 5432, // Default to 5432 if not set
+  username: dbUrl.username,
+  password: dbUrl.password,
+  database: dbUrl.pathname.slice(1), // Remove the leading slash from the database name
+  // ssl: dbUrl.protocol === 'postgresqls:',  // Use SSL if the protocol is postgresqls
+  ssl: {
+    rejectUnauthorized: false,
+  },
+  extra: {
+    ssl: {
+      rejectUnauthorized: false,
+    },
+  },
+  // entities: [entities],
+  // migrations: [migrations],
+  entities: Object.values(Entities),
+  migrations: [migrations],
+  synchronize: false, // Set to false in production
+  migrationsRun: false,
+  logging: false,
+});
+
+export default AppDataSource;

apps/northwindapi/src/database/migrations/1745487689382-migration.ts

@@ -0,0 +1,91 @@
+import { MigrationInterface, QueryRunner } from 'typeorm';
+
+export class Migration1745487689382 implements MigrationInterface {
+  name = 'Migration1745487689382';
+
+  public async up(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `CREATE TABLE "Shippers" ("ShipperID" SERIAL NOT NULL, "CompanyName" character varying(40) NOT NULL, "Phone" character varying(24), "createdAt" TIMESTAMP NOT NULL DEFAULT now(), "updatedAt" TIMESTAMP NOT NULL DEFAULT now(), CONSTRAINT "PK_475819881aa030a55cbb4dfa077" PRIMARY KEY ("ShipperID"))`,
+    );
+    await queryRunner.query(
+      `CREATE TABLE "Customers" ("CustomerID" character(5) NOT NULL, "CompanyName" character varying(40) NOT NULL, "ContactName" character varying(30), "ContactTitle" character varying(30), "Address" character varying(60), "City" character varying(15), "Region" character varying(15), "PostalCode" character varying(10), "Country" character varying(15), "Phone" character varying(24), "Fax" character varying(24), "createdAt" TIMESTAMP NOT NULL DEFAULT now(), "updatedAt" TIMESTAMP NOT NULL DEFAULT now(), CONSTRAINT "PK_20d9e62f5dfe25e72bc90e46257" PRIMARY KEY ("CustomerID"))`,
+    );
+    await queryRunner.query(
+      `CREATE TABLE "Employees" ("EmployeeID" SERIAL NOT NULL, "LastName" character varying(20) NOT NULL, "FirstName" character varying(10) NOT NULL, "Title" character varying(30), "TitleOfCourtesy" character varying(25), "BirthDate" TIMESTAMP, "HireDate" TIMESTAMP, "Address" character varying(60), "City" character varying(15), "Region" character varying(15), "PostalCode" character varying(10), "Country" character varying(15), "HomePhone" character varying(24), "Extension" character varying(4), "Notes" text, "createdAt" TIMESTAMP NOT NULL DEFAULT now(), "updatedAt" TIMESTAMP NOT NULL DEFAULT now(), "ReportsTo" integer, CONSTRAINT "PK_31149b984f38111c8faf85124c7" PRIMARY KEY ("EmployeeID"))`,
+    );
+    await queryRunner.query(
+      `CREATE TABLE "Orders" ("OrderID" SERIAL NOT NULL, "OrderDate" TIMESTAMP, "RequiredDate" TIMESTAMP, "ShippedDate" TIMESTAMP, "Freight" numeric(18,2), "ShipName" character varying(60), "ShipAddress" character varying(60), "ShipCity" character varying(15), "ShipRegion" character varying(15), "ShipPostalCode" character varying(10), "ShipCountry" character varying(15), "createdAt" TIMESTAMP NOT NULL DEFAULT now(), "updatedAt" TIMESTAMP NOT NULL DEFAULT now(), "CustomerID" character(5), "EmployeeID" integer, "ShipVia" integer, CONSTRAINT "PK_55f8443f4d79e9a848cf42b69d9" PRIMARY KEY ("OrderID"))`,
+    );
+    await queryRunner.query(
+      `CREATE TABLE "Suppliers" ("SupplierID" SERIAL NOT NULL, "CompanyName" character varying(40) NOT NULL, "ContactName" character varying(30), "ContactTitle" character varying(30), "Address" character varying(60), "City" character varying(15), "Region" character varying(15), "PostalCode" character varying(10), "Country" character varying(15), "Phone" character varying(24), "Fax" character varying(24), "HomePage" text, "createdAt" TIMESTAMP NOT NULL DEFAULT now(), "updatedAt" TIMESTAMP NOT NULL DEFAULT now(), CONSTRAINT "PK_9af75be88249fe42e9a8fb47629" PRIMARY KEY ("SupplierID"))`,
+    );
+    await queryRunner.query(
+      `CREATE TABLE "Categories" ("CategoryID" SERIAL NOT NULL, "CategoryName" character varying(15) NOT NULL, "Description" text, "Picture" bytea, "createdAt" TIMESTAMP NOT NULL DEFAULT now(), "updatedAt" TIMESTAMP NOT NULL DEFAULT now(), CONSTRAINT "PK_8fb0727baad4afaed25ac7c9861" PRIMARY KEY ("CategoryID"))`,
+    );
+    await queryRunner.query(
+      `CREATE TABLE "Products" ("ProductID" SERIAL NOT NULL, "ProductName" character varying(40) NOT NULL, "QuantityPerUnit" character varying(20), "UnitPrice" numeric(18,2), "UnitsInStock" smallint, "UnitsOnOrder" smallint, "ReorderLevel" smallint, "Discontinued" boolean NOT NULL, "createdAt" TIMESTAMP NOT NULL DEFAULT now(), "updatedAt" TIMESTAMP NOT NULL DEFAULT now(), "SupplierID" integer, "CategoryID" integer, CONSTRAINT "PK_07f84037390838453c1426c7cb5" PRIMARY KEY ("ProductID"))`,
+    );
+    await queryRunner.query(
+      `CREATE TABLE "OrderDetails" ("OrderDetailID" SERIAL NOT NULL, "UnitPrice" numeric(18,2) NOT NULL, "Quantity" smallint NOT NULL, "Discount" real NOT NULL, "createdAt" TIMESTAMP NOT NULL DEFAULT now(), "updatedAt" TIMESTAMP NOT NULL DEFAULT now(), "OrderID" integer, "ProductID" integer, CONSTRAINT "PK_62169a0638c62361a12768293f8" PRIMARY KEY ("OrderDetailID"))`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "Employees" ADD CONSTRAINT "FK_0a2e430ee66d427d2fd728ce671" FOREIGN KEY ("ReportsTo") REFERENCES "Employees"("EmployeeID") ON DELETE NO ACTION ON UPDATE NO ACTION`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "Orders" ADD CONSTRAINT "FK_fcb27b11e453edc543d0a5436eb" FOREIGN KEY ("CustomerID") REFERENCES "Customers"("CustomerID") ON DELETE NO ACTION ON UPDATE NO ACTION`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "Orders" ADD CONSTRAINT "FK_4ef049bfb564e1dbab6b55d9503" FOREIGN KEY ("EmployeeID") REFERENCES "Employees"("EmployeeID") ON DELETE NO ACTION ON UPDATE NO ACTION`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "Orders" ADD CONSTRAINT "FK_bd8071f28699758415c62dfd7be" FOREIGN KEY ("ShipVia") REFERENCES "Shippers"("ShipperID") ON DELETE NO ACTION ON UPDATE NO ACTION`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "Products" ADD CONSTRAINT "FK_3631250b029818892d266a3a0a8" FOREIGN KEY ("SupplierID") REFERENCES "Suppliers"("SupplierID") ON DELETE NO ACTION ON UPDATE NO ACTION`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "Products" ADD CONSTRAINT "FK_9d404e9029f724e36f0ce2f0024" FOREIGN KEY ("CategoryID") REFERENCES "Categories"("CategoryID") ON DELETE NO ACTION ON UPDATE NO ACTION`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "OrderDetails" ADD CONSTRAINT "FK_36af61326d32a5b6853c79642f1" FOREIGN KEY ("OrderID") REFERENCES "Orders"("OrderID") ON DELETE NO ACTION ON UPDATE NO ACTION`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "OrderDetails" ADD CONSTRAINT "FK_2dd62647d008dcfcc7846aee102" FOREIGN KEY ("ProductID") REFERENCES "Products"("ProductID") ON DELETE NO ACTION ON UPDATE NO ACTION`,
+    );
+  }
+
+  public async down(queryRunner: QueryRunner): Promise<void> {
+    await queryRunner.query(
+      `ALTER TABLE "OrderDetails" DROP CONSTRAINT "FK_2dd62647d008dcfcc7846aee102"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "OrderDetails" DROP CONSTRAINT "FK_36af61326d32a5b6853c79642f1"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "Products" DROP CONSTRAINT "FK_9d404e9029f724e36f0ce2f0024"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "Products" DROP CONSTRAINT "FK_3631250b029818892d266a3a0a8"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "Orders" DROP CONSTRAINT "FK_bd8071f28699758415c62dfd7be"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "Orders" DROP CONSTRAINT "FK_4ef049bfb564e1dbab6b55d9503"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "Orders" DROP CONSTRAINT "FK_fcb27b11e453edc543d0a5436eb"`,
+    );
+    await queryRunner.query(
+      `ALTER TABLE "Employees" DROP CONSTRAINT "FK_0a2e430ee66d427d2fd728ce671"`,
+    );
+    await queryRunner.query(`DROP TABLE "OrderDetails"`);
+    await queryRunner.query(`DROP TABLE "Products"`);
+    await queryRunner.query(`DROP TABLE "Categories"`);
+    await queryRunner.query(`DROP TABLE "Suppliers"`);
+    await queryRunner.query(`DROP TABLE "Orders"`);
+    await queryRunner.query(`DROP TABLE "Employees"`);
+    await queryRunner.query(`DROP TABLE "Customers"`);
+    await queryRunner.query(`DROP TABLE "Shippers"`);
+  }
+}

apps/northwindapi/src/database/migrations/1748636404589-migration.ts

@@ -0,0 +1,14 @@
+import { MigrationInterface, QueryRunner } from "typeorm";
+
+export class Migration1748636404589 implements MigrationInterface {
+    name = 'Migration1748636404589'
+
+    public async up(queryRunner: QueryRunner): Promise<void> {
+        await queryRunner.query(`ALTER TABLE "Customers" ADD "PhotoURL" character varying(60)`);
+    }
+
+    public async down(queryRunner: QueryRunner): Promise<void> {
+        await queryRunner.query(`ALTER TABLE "Customers" DROP COLUMN "PhotoURL"`);
+    }
+
+}

apps/northwindapi/src/database/seed/index.ts

@@ -0,0 +1,36 @@
+import AppDataSource from '../../config/typeorm.config';
+import { seedCategories } from './seed-categories';
+import { seedShippers } from './seed-shippers';
+import { seedCustomers } from './seed-customers';
+import { seedEmployees } from './seed-employees';
+import { seedSuppliers } from './seed-suppliers';
+import { seedProducts } from './seed-products';
+import { seedOrders } from './seed-orders';
+import { orderDetailSeed } from './seed-order-details';
+
+async function runSeeding() {
+  try {
+    await AppDataSource.initialize();
+    console.log('🚀 DataSource initialized');
+
+    // Debug: List the loaded entities
+    console.log(AppDataSource.entityMetadatas);
+
+    await seedCategories(AppDataSource);
+    await seedShippers(AppDataSource);
+    await seedCustomers(AppDataSource);
+    await seedEmployees(AppDataSource);
+    await seedSuppliers(AppDataSource);
+    await seedProducts(AppDataSource);
+    await seedOrders(AppDataSource);
+    await orderDetailSeed(AppDataSource);
+
+    await AppDataSource.destroy();
+    console.log('✅ Seeding completed, connection closed');
+  } catch (error) {
+    console.error('❌ Error during seeding:', error);
+    process.exit(1);
+  }
+}
+
+runSeeding();

apps/northwindapi/src/database/seed/seed-categories.ts

@@ -0,0 +1,30 @@
+import { DataSource } from 'typeorm';
+import { Category } from '@bpm/data/models/category.entity';
+
+export async function seedCategories(dataSource: DataSource) {
+  const repo = dataSource.getRepository(Category);
+  const existing = await repo.count();
+  if (existing > 0) {
+    console.log('🛑 Categories already exist. Skipping...');
+    return;
+  }
+
+  const categories = [
+    { CategoryName: 'Beverages', Description: 'Soft drinks, tea, coffee' },
+    { CategoryName: 'Condiments', Description: 'Sauces and seasonings' },
+    { CategoryName: 'Confections', Description: 'Desserts and sweet breads' },
+    { CategoryName: 'Dairy Products', Description: 'Cheeses and other dairy' },
+    { CategoryName: 'Grains/Cereals', Description: 'Breads, crackers, pasta' },
+    { CategoryName: 'Meat/Poultry', Description: 'Prepared meats' },
+    {
+      CategoryName: 'Produce',
+      Description: 'Dried and fresh fruit/vegetables',
+    },
+    { CategoryName: 'Seafood', Description: 'Seaweed, fish' },
+    { CategoryName: 'Snacks', Description: 'Chips and small packs' },
+    { CategoryName: 'Health', Description: 'Supplements and vitamins' },
+  ];
+
+  await repo.save(categories);
+  console.log('✅ Seeded categories');
+}

apps/northwindapi/src/database/seed/seed-customers.ts

@@ -0,0 +1,148 @@
+// src/database/seed/seed-customers.ts
+import { DataSource } from 'typeorm';
+import { Customer } from '@bpm/data/models/customer.entity';
+
+export async function seedCustomers(dataSource: DataSource) {
+  const repo = dataSource.getRepository(Customer);
+  const existing = await repo.count();
+  if (existing > 0) {
+    console.log('🛑 Customers already exist. Skipping...');
+    return;
+  }
+
+  const customers: Partial<Customer>[] = [
+    {
+      CustomerID: 'ALFKI',
+      CompanyName: 'Alfreds Futterkiste',
+      ContactName: 'Maria Anders',
+      ContactTitle: 'Sales Representative',
+      Address: 'Obere Str. 57',
+      City: 'Berlin',
+      PostalCode: '12209',
+      Country: 'Germany',
+      Phone: '030-0074321',
+      Fax: '030-0076545',
+      PhotoURL: 'https://randomuser.me/api/portraits/men/1.jpg'
+    },
+    {
+      CustomerID: 'ANATR',
+      CompanyName: 'Ana Trujillo Emparedados y helados',
+      ContactName: 'Ana Trujillo',
+      ContactTitle: 'Owner',
+      Address: 'Avda. de la Constitución 2222',
+      City: 'México D.F.',
+      PostalCode: '05021',
+      Country: 'Mexico',
+      Phone: '(5) 555-4729',
+      Fax: '(5) 555-3745',
+      PhotoURL: 'https://randomuser.me/api/portraits/men/2.jpg'
+    },
+    {
+      CustomerID: 'ANTON',
+      CompanyName: 'Antonio Moreno Taquería',
+      ContactName: 'Antonio Moreno',
+      ContactTitle: 'Owner',
+      Address: 'Mataderos 2312',
+      City: 'México D.F.',
+      PostalCode: '05023',
+      Country: 'Mexico',
+      Phone: '(5) 555-3932',
+      PhotoURL: 'https://randomuser.me/api/portraits/women/3.jpg'
+    },
+    {
+      CustomerID: 'AROUT',
+      CompanyName: 'Around the Horn',
+      ContactName: 'Thomas Hardy',
+      ContactTitle: 'Sales Representative',
+      Address: '120 Hanover Sq.',
+      City: 'London',
+      PostalCode: 'WA1 1DP',
+      Country: 'UK',
+      Phone: '(171) 555-7788',
+      Fax: '(171) 555-6750',
+      PhotoURL: 'https://randomuser.me/api/portraits/men/4.jpg'
+    },
+    {
+      CustomerID: 'BERGS',
+      CompanyName: 'Berglunds snabbköp',
+      ContactName: 'Christina Berglund',
+      ContactTitle: 'Order Administrator',
+      Address: 'Berguvsvägen 8',
+      City: 'Luleå',
+      PostalCode: 'S-958 22',
+      Country: 'Sweden',
+      Phone: '0921-12 34 65',
+      Fax: '0921-12 34 67',
+      PhotoURL: 'https://randomuser.me/api/portraits/women/5.jpg'
+    },
+    {
+      CustomerID: 'BLAUS',
+      CompanyName: 'Blauer See Delikatessen',
+      ContactName: 'Hanna Moos',
+      ContactTitle: 'Sales Representative',
+      Address: 'Forsterstr. 57',
+      City: 'Mannheim',
+      PostalCode: '68306',
+      Country: 'Germany',
+      Phone: '0621-08460',
+      Fax: '0621-08924',
+      PhotoURL: 'https://randomuser.me/api/portraits/women/6.jpg'
+    },
+    {
+      CustomerID: 'BLONP',
+      CompanyName: 'Blondel père et fils',
+      ContactName: 'Frédérique Citeaux',
+      ContactTitle: 'Marketing Manager',
+      Address: '24, place Kléber',
+      City: 'Strasbourg',
+      PostalCode: '67000',
+      Country: 'France',
+      Phone: '88.60.15.31',
+      Fax: '88.60.15.32',
+      PhotoURL: 'https://randomuser.me/api/portraits/men/7.jpg'
+    },
+    {
+      CustomerID: 'BOLID',
+      CompanyName: 'Bólido Comidas preparadas',
+      ContactName: 'Martín Sommer',
+      ContactTitle: 'Owner',
+      Address: 'C/ Araquil, 67',
+      City: 'Madrid',
+      PostalCode: '28023',
+      Country: 'Spain',
+      Phone: '(91) 555 22 82',
+      Fax: '(91) 555 91 99',
+      PhotoURL: 'https://randomuser.me/api/portraits/women/8.jpg'
+    },
+    {
+      CustomerID: 'BONAP',
+      CompanyName: "Bon app'",
+      ContactName: 'Laurence Lebihan',
+      ContactTitle: 'Owner',
+      Address: '12, rue des Bouchers',
+      City: 'Marseille',
+      PostalCode: '13008',
+      Country: 'France',
+      Phone: '91.24.45.40',
+      Fax: '91.24.45.41',
+      PhotoURL: 'https://randomuser.me/api/portraits/women/9.jpg'
+    },
+    {
+      CustomerID: 'BOTTM',
+      CompanyName: 'Bottom-Dollar Markets',
+      ContactName: 'Elizabeth Lincoln',
+      ContactTitle: 'Accounting Manager',
+      Address: '23 Tsawassen Blvd.',
+      City: 'Tsawassen',
+      Region: 'BC',
+      PostalCode: 'T2F 8M4',
+      Country: 'Canada',
+      Phone: '(604) 555-4729',
+      Fax: '(604) 555-3745',
+      PhotoURL: 'https://randomuser.me/api/portraits/men/10.jpg'
+    },
+  ];
+
+  await repo.save(customers);
+  console.log('✅ Seeded customers');
+}

apps/northwindapi/src/database/seed/seed-employees.ts

@@ -0,0 +1,173 @@
+// ../../database/seed/seed-employees.ts
+import { DataSource, DeepPartial } from 'typeorm';
+import { Employee } from '@bpm/data/models/employee.entity';
+
+export async function seedEmployees(dataSource: DataSource) {
+  const repo = dataSource.getRepository(Employee);
+  const existing = await repo.count();
+  if (existing > 0) {
+    console.log('🛑 Employees already exist. Skipping...');
+    return;
+  }
+
+  const now = new Date();
+  const employees = repo.create([
+    {
+      FirstName: 'Nancy',
+      LastName: 'Davolio',
+      Title: 'Sales Representative',
+      TitleOfCourtesy: 'Ms.',
+      BirthDate: new Date('1948-12-08'),
+      HireDate: new Date('1992-05-01'),
+      Address: '507 - 20th Ave. E. Apt. 2A',
+      City: 'Seattle',
+      Region: 'WA',
+      PostalCode: '98122',
+      Country: 'USA',
+      HomePhone: '(206) 555-9857',
+      Extension: '5467',
+      Notes: 'Education includes a BA in psychology.',
+    },
+    {
+      FirstName: 'Andrew',
+      LastName: 'Fuller',
+      Title: 'Vice President, Sales',
+      TitleOfCourtesy: 'Dr.',
+      BirthDate: new Date('1952-02-19'),
+      HireDate: new Date('1992-08-14'),
+      Address: '908 W. Capital Way',
+      City: 'Tacoma',
+      Region: 'WA',
+      PostalCode: '98401',
+      Country: 'USA',
+      HomePhone: '(206) 555-9482',
+      Extension: '3457',
+      Notes: 'Andrew received his BTS commercial in 1974.',
+    },
+    {
+      FirstName: 'Janet',
+      LastName: 'Leverling',
+      Title: 'Sales Representative',
+      TitleOfCourtesy: 'Ms.',
+      BirthDate: new Date('1963-08-30'),
+      HireDate: new Date('1992-04-01'),
+      Address: '722 Moss Bay Blvd.',
+      City: 'Kirkland',
+      Region: 'WA',
+      PostalCode: '98033',
+      Country: 'USA',
+      HomePhone: '(206) 555-3412',
+      Extension: '3355',
+      Notes: 'Janet has a BS degree in chemistry.',
+    },
+    {
+      FirstName: 'Margaret',
+      LastName: 'Peacock',
+      Title: 'Sales Representative',
+      TitleOfCourtesy: 'Mrs.',
+      BirthDate: new Date('1937-09-19'),
+      HireDate: new Date('1993-05-03'),
+      Address: '4110 Old Redmond Rd.',
+      City: 'Redmond',
+      Region: 'WA',
+      PostalCode: '98052',
+      Country: 'USA',
+      HomePhone: '(206) 555-8122',
+      Extension: '5176',
+      Notes: 'Margaret holds a BA in English literature.',
+    },
+    {
+      FirstName: 'Steven',
+      LastName: 'Buchanan',
+      Title: 'Sales Manager',
+      TitleOfCourtesy: 'Mr.',
+      BirthDate: new Date('1955-03-04'),
+      HireDate: new Date('1993-10-17'),
+      Address: '14 Garrett Hill',
+      City: 'London',
+      Region: null,
+      PostalCode: 'SW1 8JR',
+      Country: 'UK',
+      HomePhone: '(71) 555-4848',
+      Extension: '3453',
+      Notes: 'Steven was a Navy officer before his sales career.',
+    },
+    {
+      FirstName: 'Michael',
+      LastName: 'Suyama',
+      Title: 'Sales Representative',
+      TitleOfCourtesy: 'Mr.',
+      BirthDate: new Date('1963-07-02'),
+      HireDate: new Date('1993-10-17'),
+      Address: 'Coventry House Miner Rd.',
+      City: 'London',
+      Region: null,
+      PostalCode: 'EC2 7JR',
+      Country: 'UK',
+      HomePhone: '(71) 555-7773',
+      Extension: '428',
+      Notes: 'Michael enjoys tennis and classical music.',
+    },
+    {
+      FirstName: 'Robert',
+      LastName: 'King',
+      Title: 'Sales Representative',
+      TitleOfCourtesy: 'Mr.',
+      BirthDate: new Date('1960-05-29'),
+      HireDate: new Date('1994-01-02'),
+      Address: 'Edgeham Hollow Winchester Way',
+      City: 'London',
+      Region: null,
+      PostalCode: 'RG1 9SP',
+      Country: 'UK',
+      HomePhone: '(71) 555-5598',
+      Extension: '465',
+      Notes: 'Robert is a certified Salesforce administrator.',
+    },
+    {
+      FirstName: 'Laura',
+      LastName: 'Callahan',
+      Title: 'Inside Sales Coordinator',
+      TitleOfCourtesy: 'Ms.',
+      BirthDate: new Date('1958-01-09'),
+      HireDate: new Date('1994-03-05'),
+      Address: '4726 - 11th Ave. N.E.',
+      City: 'Seattle',
+      Region: 'WA',
+      PostalCode: '98105',
+      Country: 'USA',
+      HomePhone: '(206) 555-1189',
+      Extension: '2344',
+      Notes: 'Laura is passionate about volunteer work.',
+    },
+    {
+      FirstName: 'Anne',
+      LastName: 'Dodsworth',
+      Title: 'Sales Representative',
+      TitleOfCourtesy: 'Ms.',
+      BirthDate: new Date('1966-01-27'),
+      HireDate: new Date('1994-11-15'),
+      Address: '7 Houndstooth Rd.',
+      City: 'London',
+      Region: null,
+      PostalCode: 'WG2 7LT',
+      Country: 'UK',
+      HomePhone: '(71) 555-4444',
+      Extension: '452',
+      Notes: 'Anne enjoys travel and gourmet cooking.',
+    },
+  ] as DeepPartial<Employee>[]);
+
+  const savedEmployees = await repo.save(employees);
+
+  // Add ReportsTo relationships
+  await repo.save([
+    { ...savedEmployees[0], ReportsTo: savedEmployees[1] }, // Nancy -> Andrew
+    { ...savedEmployees[2], ReportsTo: savedEmployees[1] }, // Janet -> Andrew
+    { ...savedEmployees[3], ReportsTo: savedEmployees[4] }, // Margaret -> Steven
+    { ...savedEmployees[5], ReportsTo: savedEmployees[4] }, // Michael -> Steven
+    { ...savedEmployees[6], ReportsTo: savedEmployees[4] }, // Robert -> Steven
+    { ...savedEmployees[8], ReportsTo: savedEmployees[4] }, // Anne -> Steven
+  ]);
+  console.log('✅ Seeded employees');
+}

apps/northwindapi/src/database/seed/seed-order-details.ts

@@ -0,0 +1,49 @@
+import { DataSource } from 'typeorm';
+import { OrderDetail } from '@bpm/data/models/orderdetail.entity';
+import { Order } from '@bpm/data/models/order.entity';
+import { Product } from '@bpm/data/models/product.entity';
+
+export async function orderDetailSeed(dataSource: DataSource) {
+  const orderRepo = dataSource.getRepository(Order);
+  const productRepo = dataSource.getRepository(Product);
+  const orderDetailRepo = dataSource.getRepository(OrderDetail);
+
+  const existing = await orderDetailRepo.count();
+  if (existing > 0) {
+    console.log('🛑 OrderDetail already exist. Skipping...');
+    return;
+  }
+
+  const orders = await orderRepo.find();
+  const products = await productRepo.find();
+
+  if (orders.length === 0 || products.length === 0) {
+    throw new Error(
+      '🛑 Orders or Products must be seeded before OrderDetails.',
+    );
+  }
+
+  // const orders = await orderRepo.find({ take: 10 }); // adjust as needed
+  // const products = await productRepo.find({ take: 30 });
+
+  const orderDetails: OrderDetail[] = [];
+
+  for (let i = 0; i < 20; i++) {
+    const order = orders[Math.floor(Math.random() * orders.length)];
+    const product = products[Math.floor(Math.random() * products.length)];
+
+    const detail = new OrderDetail();
+    detail.Order = order;
+    detail.OrderID = order.OrderID;
+    detail.Product = product;
+    detail.ProductID = product.ProductID;
+    detail.UnitPrice = parseFloat((Math.random() * 100 + 10).toFixed(2));
+    detail.Quantity = Math.floor(Math.random() * 10) + 1;
+    detail.Discount = parseFloat((Math.random() * 0.5).toFixed(2));
+
+    orderDetails.push(detail);
+  }
+
+  await orderDetailRepo.save(orderDetails);
+  console.log('✅ Seeded OrderDetails with realistic product lines.');
+}