intergrate TCP connection to apps

apps/fis-fingerprint/Fis-Fingerprint

@@ -0,0 +1 @@
+Subproject commit 68b3e3fde46ef617efe2d99785124895ded647d7

apps/fis-fingerprint/src/fis-fingerprint.controller.ts

@@ -1,12 +1,22 @@
 import { Controller, Get } from '@nestjs/common';
 import { FisFingerprintService } from './fis-fingerprint.service';
+import { EventPattern, MessagePattern } from '@nestjs/microservices';
 
 @Controller()
 export class FisFingerprintController {
-  constructor(private readonly fisFingerprintService: FisFingerprintService) {}
 
-  @Get()
-  getHello(): string {
-    return this.fisFingerprintService.getHello();
+  constructor(private readonly fisFingerprintService: FisFingerprintService) {
+    //logic here
+  }
+
+  /* Testing for TCP connection */
+  @MessagePattern({ cmd: 'messageTest' })
+  messageTest(message: string): string {
+    return `Hello there. Just Responding to Message pattern`
+  }
+
+  @EventPattern(`eventTest`)
+  eventTest(message: string): void {
+    console.log(`Hello there. Just Responding to Event pattern`)
   }
 }

apps/fis-fingerprint/src/fis-fingerprint.module.ts

@@ -1,11 +1,22 @@
 import { Module } from '@nestjs/common';
 import { FisFingerprintController } from './fis-fingerprint.controller';
 import { FisFingerprintService } from './fis-fingerprint.service';
-import { FingerprintService, StorageService } from '../Fis-Fingerprint/src';
+import { ClientsModule, Transport } from '@nestjs/microservices';
 
 @Module({
-  imports: [],
+  imports: [
+    ClientsModule.register([
+      {
+        name: `SAMPLEAPP_SERVICE`,
+        transport: Transport.TCP,
+        options: {
+          host: `0.0.0.0`,
+          port: 3001
+        }
+      }
+    ])
+  ],
   controllers: [FisFingerprintController],
-  providers: [FingerprintService, StorageService, FisFingerprintService],
+  providers: [FisFingerprintService],
 })
-export class FisFingerprintModule {}
+export class FisFingerprintModule { }

apps/fis-fingerprint/src/fis-fingerprint.service.ts

@@ -1,12 +1,14 @@
-import { Injectable } from '@nestjs/common';
+import { Inject, Injectable } from '@nestjs/common';
+import { ClientProxy } from '@nestjs/microservices';
 
 @Injectable()
 export class FisFingerprintService {
 
-  constructor() {
+  constructor(@Inject(`SAMPLEAPP_SERVICE`) private client: ClientProxy) {
+    // logic here
+    setTimeout(() => {
+      this.client.emit(`message`, `Fingeprint says HI`)
+    }, 5000)
   }
 
-  getHello(): string {
-    return 'Hello World!';
-  }
-}
+}  

apps/fis-fingerprint/src/main.ts

@@ -1,8 +1,24 @@
 import { NestFactory } from '@nestjs/core';
 import { FisFingerprintModule } from './fis-fingerprint.module';
+import { MicroserviceOptions, Transport } from '@nestjs/microservices';
+import 'dotenv/config'
 
 async function bootstrap() {
-  const app = await NestFactory.create(FisFingerprintModule);
-  await app.listen(process.env.port ?? 3000);
+  const host: string = process.env.HOST as unknown as string
+  const port: number = process.env.FINGERPRINT_TCP_PORT as unknown as number
+  const app = await NestFactory.createMicroservice<MicroserviceOptions>(
+    FisFingerprintModule,
+    {
+      transport: Transport.TCP,
+      options: {
+        host: host,
+        port: port,
+        retryAttempts: 5,
+        retryDelay: 3000
+      },
+    }
+  );
+  await app.listen();
+  console.log(`Application is running on ${host}:${port}`);
 }
 bootstrap();

apps/fis-verification/src/fis-verification.controller.ts

@@ -1,12 +1,20 @@
 import { Controller, Get } from '@nestjs/common';
 import { FisVerificationService } from './fis-verification.service';
+import { EventPattern, MessagePattern } from '@nestjs/microservices';
 
 @Controller()
 export class FisVerificationController {
-  constructor(private readonly fisVerificationService: FisVerificationService) {}
+  constructor(private readonly fisVerificationService: FisVerificationService) { }
 
-  @Get()
-  getHello(): string {
-    return this.fisVerificationService.getHello();
+  /* Testing for TCP connection */
+  @MessagePattern({ cmd: 'messageTest' })
+  messageTest(message: string): string {
+    return `Hello there. Just Responding to Message pattern`
+  }
+
+  @EventPattern(`eventTest`)
+  eventTest(message: string): void {
+    console.log(`Hello there. Just Responding to Event pattern`)
   }
 }
+

apps/fis-verification/src/fis-verification.module.ts

@@ -1,9 +1,21 @@
 import { Module } from '@nestjs/common';
 import { FisVerificationController } from './fis-verification.controller';
 import { FisVerificationService } from './fis-verification.service';
+import { ClientsModule, Transport } from '@nestjs/microservices';
 
 @Module({
-  imports: [],
+  imports: [
+    ClientsModule.register([
+          {
+            name: `SAMPLEAPP_SERVICE`,
+            transport: Transport.TCP,
+            options: {
+              host: `0.0.0.0`,
+              port: 3001
+            }
+          }
+        ])
+  ],
   controllers: [FisVerificationController],
   providers: [FisVerificationService],
 })

apps/fis-verification/src/fis-verification.service.ts

@@ -1,8 +1,14 @@
-import { Injectable } from '@nestjs/common';
+import { Inject, Injectable } from '@nestjs/common';
+import { ClientProxy } from '@nestjs/microservices';
 
 @Injectable()
 export class FisVerificationService {
-  getHello(): string {
-    return 'Hello World!';
+  
+  constructor(@Inject(`SAMPLEAPP_SERVICE`) private client: ClientProxy) {
+    // logic here
+    setTimeout(() => {
+      this.client.emit(`message`, `Verification says HI`)
+    }, 5000)
   }
+  
 }

apps/fis-verification/src/main.ts

@@ -1,8 +1,24 @@
 import { NestFactory } from '@nestjs/core';
 import { FisVerificationModule } from './fis-verification.module';
+import { MicroserviceOptions, Transport } from '@nestjs/microservices';
+import 'dotenv/config'
 
 async function bootstrap() {
-  const app = await NestFactory.create(FisVerificationModule);
-  await app.listen(process.env.port ?? 3000);
+  const host: string = process.env.HOST as unknown as string
+  const port: number = process.env.VERIFICATION_TCP_PORT as unknown as number
+  const app = await NestFactory.createMicroservice<MicroserviceOptions>(
+    FisVerificationModule,
+    {
+      transport: Transport.TCP,
+      options: {
+        host: host,
+        port: port,
+        retryAttempts: 5,
+        retryDelay: 3000
+      },
+    }
+  );
+  await app.listen();
+  console.log(`Application is running on ${host}:${port}`);
 }
 bootstrap();

apps/sample-app/src/main.ts

@@ -1,8 +1,27 @@
 import { NestFactory } from '@nestjs/core';
 import { SampleAppModule } from './sample-app.module';
+import { MicroserviceOptions, Transport } from '@nestjs/microservices';
+import 'dotenv/config'
 
 async function bootstrap() {
+  // This example contains a hybrid application (HTTP + TCP + Socket)
+  const host: string = process.env.HOST as unknown as string
+  const restPort: number = process.env.SAMPLEAPP_REST_PORT as unknown as number
+  const tcpPort: number = process.env.SAMPLEAPP_TCP_PORT as unknown as number
+
   const app = await NestFactory.create(SampleAppModule);
-  await app.listen(process.env.port ?? 3000);
+  app.connectMicroservice<MicroserviceOptions>({
+    transport: Transport.TCP,
+    options: {
+      host: host,
+      port: tcpPort,
+      retryAttempts: 5,
+      retryDelay: 3000
+    },
+  });
+
+  await app.startAllMicroservices();
+  await app.listen(restPort, host);
+  console.log(`REST API is running on: ${await app.getUrl()} and TCP is running on ${host}:${tcpPort}`);
 }
 bootstrap();

apps/sample-app/src/sample-app.controller.ts

@@ -1,12 +1,25 @@
-import { Controller, Get } from '@nestjs/common';
+import { Body, Controller, Get, Post } from '@nestjs/common';
 import { SampleAppService } from './sample-app.service';
+import { EventPattern } from '@nestjs/microservices';
 
 @Controller()
 export class SampleAppController {
-  constructor(private readonly sampleAppService: SampleAppService) {}
+  constructor(private readonly sampleAppService: SampleAppService) { 
+    // logic here
+  }
 
   @Get()
   getHello(): string {
     return this.sampleAppService.getHello();
   }
+
+  @Post()
+  sayHelloToFingerprint(@Body() message: string): any {
+    return this.sampleAppService.talkToFingerprint(message)
+  }
+
+  @EventPattern(`message`)
+  sayHello(data: string): void {
+    console.log(data)
+  }
 }

apps/sample-app/src/sample-app.module.ts

@@ -1,10 +1,22 @@
 import { Module } from '@nestjs/common';
 import { SampleAppController } from './sample-app.controller';
 import { SampleAppService } from './sample-app.service';
+import { ClientsModule, Transport } from '@nestjs/microservices';
 
 @Module({
-  imports: [],
+  imports: [
+    ClientsModule.register([
+      {
+        name: `FINGERPRINT_SERVICE`,
+        transport: Transport.TCP,
+        options: {
+          host: `0.0.0.0`,
+          port: 3002
+        }
+      }
+    ])
+  ],
   controllers: [SampleAppController],
   providers: [SampleAppService],
 })
-export class SampleAppModule {}
+export class SampleAppModule { }

apps/sample-app/src/sample-app.service.ts

@@ -1,8 +1,22 @@
-import { Injectable } from '@nestjs/common';
+import { Inject, Injectable } from '@nestjs/common';
+import { ClientProxy } from '@nestjs/microservices';
 
 @Injectable()
 export class SampleAppService {
+
+  constructor(@Inject(`FINGERPRINT_SERVICE`) private client: ClientProxy) {
+    // logic here
+  }
+
   getHello(): string {
-    return 'Hello World!';
+    return 'Hello World! I am Sample App Nestjs.';
   }
+
+  // testing. Try to talk to Fingerprint App via microservice
+  talkToFingerprint(message: string): any {
+    this.client.emit<string>(`eventTest`, message)
+    return this.client.send<string>({ cmd: `messageTest` }, message)
+  }
+
+
 }

nest-cli.json

@@ -1,40 +1,44 @@
 {
   "$schema": "https://json.schemastore.org/nest-cli",
   "collection": "@nestjs/schematics",
-  "sourceRoot": "apps/microservices/src",
+  "sourceRoot": "./",
+  "entryFile": "./src/main",
   "compilerOptions": {
     "deleteOutDir": true,
     "webpack": true,
-    "tsConfigPath": "apps/microservices/tsconfig.app.json"
+    "tsConfigPath": "apps/sample-app/tsconfig.app.json"
   },
   "monorepo": true,
-  "root": "apps/microservices",
+  "root": "apps/sample-app",
   "projects": {
     "fis-fingerprint": {
       "type": "application",
       "root": "apps/fis-fingerprint",
-      "entryFile": "main",
+      "entryFile": "src/main",
       "sourceRoot": "apps/fis-fingerprint",
       "compilerOptions": {
-        "tsConfigPath": "apps/fis-fingerprint/tsconfig.app.json"
+        "tsConfigPath": "apps/fis-fingerprint/tsconfig.app.json",
+        "watchAssets": true
       }
     },
     "fis-verification": {
       "type": "application",
       "root": "apps/fis-verification",
-      "entryFile": "main",
-      "sourceRoot": "apps/fis-verification/src",
+      "entryFile": "src/main",
+      "sourceRoot": "apps/fis-verification/",
       "compilerOptions": {
-        "tsConfigPath": "apps/fis-verification/tsconfig.app.json"
+        "tsConfigPath": "apps/fis-verification/tsconfig.app.json",
+        "watchAssets": true
       }
     },
     "sample-app": {
       "type": "application",
       "root": "apps/sample-app",
-      "entryFile": "main",
-      "sourceRoot": "apps/sample-app/src",
+      "entryFile": "src/main",
+      "sourceRoot": "apps/sample-app/",
       "compilerOptions": {
-        "tsConfigPath": "apps/sample-app/tsconfig.app.json"
+        "tsConfigPath": "apps/sample-app/tsconfig.app.json",
+        "watchAssets": true
       }
     }
   }

package-lock.json

@@ -10,9 +10,11 @@
       "license": "UNLICENSED",
       "dependencies": {
         "@nestjs/common": "^11.0.1",
+        "@nestjs/config": "^4.0.2",
         "@nestjs/core": "^11.0.1",
         "@nestjs/microservices": "^11.0.12",
         "@nestjs/platform-express": "^11.0.1",
+        "dotenv": "^16.4.7",
         "reflect-metadata": "^0.2.2",
         "rxjs": "^7.8.1",
         "uuid": "^11.1.0"
@@ -2302,6 +2304,21 @@
         }
       }
     },
+    "node_modules/@nestjs/config": {
+      "version": "4.0.2",
+      "resolved": "https://registry.npmjs.org/@nestjs/config/-/config-4.0.2.tgz",
+      "integrity": "sha512-McMW6EXtpc8+CwTUwFdg6h7dYcBUpH5iUILCclAsa+MbCEvC9ZKu4dCHRlJqALuhjLw97pbQu62l4+wRwGeZqA==",
+      "license": "MIT",
+      "dependencies": {
+        "dotenv": "16.4.7",
+        "dotenv-expand": "12.0.1",
+        "lodash": "4.17.21"
+      },
+      "peerDependencies": {
+        "@nestjs/common": "^10.0.0 || ^11.0.0",
+        "rxjs": "^7.1.0"
+      }
+    },
     "node_modules/@nestjs/core": {
       "version": "11.0.12",
       "resolved": "https://registry.npmjs.org/@nestjs/core/-/core-11.0.12.tgz",
@@ -5274,6 +5291,33 @@
         "node": "^14.15.0 || ^16.10.0 || >=18.0.0"
       }
     },
+    "node_modules/dotenv": {
+      "version": "16.4.7",
+      "resolved": "https://registry.npmjs.org/dotenv/-/dotenv-16.4.7.tgz",
+      "integrity": "sha512-47qPchRCykZC03FhkYAhrvwU4xDBFIj1QPqaarj6mdM/hgUzfPHcpkHJOn3mJAufFeeAxAzeGsr5X0M4k6fLZQ==",
+      "license": "BSD-2-Clause",
+      "engines": {
+        "node": ">=12"
+      },
+      "funding": {
+        "url": "https://dotenvx.com"
+      }
+    },
+    "node_modules/dotenv-expand": {
+      "version": "12.0.1",
+      "resolved": "https://registry.npmjs.org/dotenv-expand/-/dotenv-expand-12.0.1.tgz",
+      "integrity": "sha512-LaKRbou8gt0RNID/9RoI+J2rvXsBRPMV7p+ElHlPhcSARbCPDYcYG2s1TIzAfWv4YSgyY5taidWzzs31lNV3yQ==",
+      "license": "BSD-2-Clause",
+      "dependencies": {
+        "dotenv": "^16.4.5"
+      },
+      "engines": {
+        "node": ">=12"
+      },
+      "funding": {
+        "url": "https://dotenvx.com"
+      }
+    },
     "node_modules/dunder-proto": {
       "version": "1.0.1",
       "resolved": "https://registry.npmjs.org/dunder-proto/-/dunder-proto-1.0.1.tgz",
@@ -8033,7 +8077,6 @@
       "version": "4.17.21",
       "resolved": "https://registry.npmjs.org/lodash/-/lodash-4.17.21.tgz",
       "integrity": "sha512-v2kDEe57lecTulaDIuNTPy3Ry4gLGJ6Z1O3vE1krgXZNrsQ+LFTGHVxVjcXPs17LhbZVGedAJv8XZ1tvj5FvSg==",
-      "dev": true,
       "license": "MIT"
     },
     "node_modules/lodash.memoize": {

package.json

@@ -21,9 +21,11 @@
   },
   "dependencies": {
     "@nestjs/common": "^11.0.1",
+    "@nestjs/config": "^4.0.2",
     "@nestjs/core": "^11.0.1",
     "@nestjs/microservices": "^11.0.12",
     "@nestjs/platform-express": "^11.0.1",
+    "dotenv": "^16.4.7",
     "reflect-metadata": "^0.2.2",
     "rxjs": "^7.8.1",
     "uuid": "^11.1.0"
@@ -75,4 +77,4 @@
       "<rootDir>/apps/"
     ]
   }
-}
+}

startDev.bat

@@ -0,0 +1,6 @@
+@echo off
+
+cd /d "%~dp0"
+
+echo Starting services DEV MODE...
+start wt -M -d "." cmd /k "nest start sample-app --watch" ; split-pane -d "." cmd /k "nest start fis-fingerprint --watch" ; split-pane -d "." cmd /k "nest start fis-verification --watch"

startTCP.bat

@@ -1,12 +0,0 @@
-
-@echo off
-
-echo Building grpc...
-call nest build 
-
-echo Starting Service ApiGateWay && MessageGRPC
-start wt -M -d "E:\Task\nest-micro" cmd /k "nest start apigateway" ; split-pane -d "E:\Task\nest-micro" cmd /k "nest start tcp"
-
-
-//wt -p "Command Prompt" ; split-pane -p "Windows PowerShell" ; split-pane -H 
-

startall.bat

@@ -1,14 +1,9 @@
-
 @echo off
 
-cd "E:\Task\nest-micro"
+cd /d "%~dp0"
 
 echo Building all Nest...
 call nest build
 
 echo Starting services...
-start wt -M -d "E:\Task\nest-micro" cmd /k "nest start apigateway" ; split-pane -d "E:\Task\nest-micro" cmd /k "nest start grpc" ; split-pane -d "E:\Task\nest-micro" cmd /k "nest start tcp"
-
-
-//wt -p "Command Prompt" ; split-pane -p "Windows PowerShell" ; split-pane -H 
-
+start wt -M -d "." cmd /k "nest start sample-app" ; split-pane -d "." cmd /k "nest start fis-fingerprint" ; split-pane -d "." cmd /k "nest start fis-verification"

startgrpc.bat

@@ -1,12 +0,0 @@
-
-@echo off
-
-echo Building grpc...
-call nest build 
-
-echo Starting Service ApiGateWay && MessageGRPC
-start wt -M -d "E:\Task\nest-micro" cmd /k "nest start apigateway" ; split-pane -d "E:\Task\nest-micro" cmd /k "nest start grpc"
-
-
-//wt -p "Command Prompt" ; split-pane -p "Windows PowerShell" ; split-pane -H 
-

tsconfig.json

@@ -17,6 +17,13 @@
     "noImplicitAny": false,
     "strictBindCallApply": false,
     "noFallthroughCasesInSwitch": false,
-    "paths": {}
+    "paths": {
+      "@app/common": [
+        "libs/common/src"
+      ],
+      "@app/common/*": [
+        "libs/common/src/*"
+      ]
+    }
   }
 }